mq

Sep 13, 2021

Changes in this version

+ var ErrClosed = errors.New("pipe.q.closed")

+ var ErrCtrlQFull = errors.New("pipe.q.ctrl.full")

+ var ErrReqQFull = errors.New("pipe.q.req.full")

+ var ErrSync = errors.New("never.gonna.happen.crazy")

+ type MQ struct

+ func NewMQ(options ...Option) *MQ

+ func (a *MQ) AddCtrl(cmd interface{}) error

+ func (a *MQ) AddCtrlAnyway(cmd interface{}, ts time.Duration) error

+ func (a *MQ) AddPriorCtrl(cmd interface{}) error

+ func (a *MQ) AddPriorReq(req interface{}) error

+ func (a *MQ) AddReq(req interface{}) error

+ func (a *MQ) AddReqAnyway(req interface{}, ts time.Duration) error

+ func (a *MQ) Close()

+ func (a *MQ) IsCleared() bool

+ func (a *MQ) IsClosed() bool

+ func (a *MQ) Pop() (interface{}, error)

+ func (a *MQ) PopAnyway() (interface{}, error)

+ func (a *MQ) TryClear() bool

+ func (a *MQ) TryClose() bool

+ func (a *MQ) WaitClear(ctx context.Context) error

+ func (a *MQ) WaitClose(ctx context.Context) error

+ type Option func(o *_Option)

+ func WithQCtrlSize(num int) Option

+ func WithQReqSize(num int) Option