msgqueue

Nov 24, 2025

Changes in this version

+ type ChanMQ struct

+ func NewChanMQ(capacity int, deviceId string) *ChanMQ

+ func (q *ChanMQ) Clear() error

+ func (q *ChanMQ) Deq(ctx context.Context) ([]byte, error)

+ func (q *ChanMQ) Destroy()

+ func (q *ChanMQ) Enq(msg []byte) error

+ func (q *ChanMQ) IsLive() bool

+ func (q *ChanMQ) Len() int

+ func (q *ChanMQ) Renew()

+ type MessageQueueInterface interface

+ Clear func() error

+ Deq func(ctx context.Context) ([]byte, error)

+ Destroy func()

+ Enq func(msg []byte) error

+ IsLive func() bool

+ Len func() int

+ Renew func()