Versions in this module Expand all Collapse all v0 v0.2.19 Mar 17, 2026 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
Go to main page