queue

type Manager struct {
	// contains filtered or unexported fields
}

type NoticePublisher interface {
	Publish(channel string, message datadef.Marshaler)
}

type Queue interface {
	sync.Locker

	// lockfree
	Name() string
	Len() int

	// ErrRunOut ErrAlreadyExist
	Push(key, value string, priority int64, force bool) (pos protodef.QUEUEPOS, rank int, err error)

	// ErrRunOut ErrAlreadyExist
	Repush(key, value string, pos protodef.QUEUEPOS) (rank int, err error)

	// ErrRunOut
	Pop(numMin, numMax int) (pops []protodef.PopElement, err error)

	// ErrNotFound
	Remove(key string, pos protodef.QUEUEPOS) error

	// concurrently-access
	PublishNotice()
}

type RedisPublisherConfig struct {
	Addr string
	Pass string

	BufferSize int
	WorkerNum  int
}