Versions in this module Expand all Collapse all v2 v2.1.4 Nov 7, 2023 Changes in this version + type Producer interface + Request func(ctx context.Context, ttl time.Duration, msg *primitive.Message) (*primitive.Message, error) + RequestAsync func(ctx context.Context, ttl time.Duration, callback internal.RequestCallback, ...) error + SendAsync func(ctx context.Context, ...) error + SendOneWay func(ctx context.Context, mq ...*primitive.Message) error + SendSync func(ctx context.Context, mq ...*primitive.Message) (*primitive.SendResult, error) + Shutdown func() error + Start func() error + func NewProducer(opts ...producer.Option) (Producer, error) + type PullConsumer interface + ACK func(ctx context.Context, cr *consumer.ConsumeRequest, ...) + CurrentOffset func(queue *primitive.MessageQueue) (int64, error) + PersistOffset func(ctx context.Context, topic string) error + Poll func(ctx context.Context, timeout time.Duration) (*consumer.ConsumeRequest, error) + Pull func(ctx context.Context, numbers int) (*primitive.PullResult, error) + PullFrom func(ctx context.Context, queue *primitive.MessageQueue, offset int64, numbers int) (*primitive.PullResult, error) + Shutdown func() error + Start func() error + Subscribe func(topic string, selector consumer.MessageSelector) error + Unsubscribe func(topic string) error + UpdateOffset func(queue *primitive.MessageQueue, offset int64) error + func NewPullConsumer(opts ...consumer.Option) (PullConsumer, error) + type PushConsumer interface + GetOffsetDiffMap func() map[string]int64 + Resume func() + Shutdown func() error + Start func() error + Subscribe func(topic string, selector consumer.MessageSelector, ...) error + Suspend func() + Unsubscribe func(topic string) error + func NewPushConsumer(opts ...consumer.Option) (PushConsumer, error) + type TransactionProducer interface + SendMessageInTransaction func(ctx context.Context, mq *primitive.Message) (*primitive.TransactionSendResult, error) + Shutdown func() error + Start func() error + func NewTransactionProducer(listener primitive.TransactionListener, opts ...producer.Option) (TransactionProducer, error)
Go to main page