queue

Apr 28, 2025

Changes in this version

+ type DeliverMessage interface

+ Ack func(ctx context.Context) error

+ Message func() *Message

+ Nack func(ctx context.Context) error

+ type Iterator interface

+ Next func() bool

+ Value func() E

+ type Message struct

+ ID string

+ Payload string

+ Timestamp time.Time

+ Topic string

+ type MessageQueue interface

+ Publish func(ctx context.Context, payload string) (string, error)

+ Size func() int64

+ Subscribe func(ctx context.Context, handler func(DeliverMessage)) error

+ type MessageQueueProvider interface

+ Close func() error

+ MessageQueue func(subject string) (MessageQueue, error)

+ PublishToTopic func(ctx context.Context, topic string, payload string) error

+ QueueSubscribe func(ctx context.Context, topic string, handler func(DeliverMessage)) (Subscription, error)

+ RequestReply func(ctx context.Context, topic string, payload string) (*Message, error)

+ SubscribeToTopic func(ctx context.Context, topic string, handler func(DeliverMessage)) (Subscription, error)

+ type MutexQueue struct

+ func NewMutexQueue[E any]() *MutexQueue[E]

+ func (q *MutexQueue[E]) Clear()

+ func (q *MutexQueue[E]) IsEmpty() bool

+ func (q *MutexQueue[E]) Iterator() Iterator[E]

+ func (q *MutexQueue[E]) Offer(e E) bool

+ func (q *MutexQueue[E]) Peek() (E, bool)

+ func (q *MutexQueue[E]) Poll() (E, bool)

+ func (q *MutexQueue[E]) Size() int64

+ func (q *MutexQueue[E]) ToSlice() []E

+ type Provider interface

+ Close func() error

+ Publish func(ctx context.Context, topic string, payload E) error

+ Queue func(topic string) Queue[E]

+ Subscribe func(ctx context.Context, topic string, handler func(E)) error

+ type Queue interface

+ Clear func()

+ IsEmpty func() bool

+ Iterator func() Iterator[E]

+ Offer func(E) bool

+ Peek func() (E, bool)

+ Poll func() (E, bool)

+ Size func() int64

+ ToSlice func() []E

+ type Subscription interface

+ ClearMaxPending func() error

+ Delivered func() (uint64, error)

+ Dropped func() (uint64, error)

+ HandlerMessage func(handler func(*Message)) error

+ IsActive func() bool

+ IsQueue func() bool

+ MaxPending func() (int, int, error)

+ Pause func() error

+ Pending func() (int, error)

+ Queue func() (string, bool)

+ Resume func() error

+ Topic func() string

+ Unsubscribe func() error