Versions in this module Expand all Collapse all v0 v0.1.0 Aug 4, 2025 Changes in this version + type AsyncConsumer interface + Start func(handler MessageHandler, opts ConsumerOptions) error + Stop func() error + func NewAsyncConsumer(id string, manager *queue.Manager, opts ...ClientOption) (AsyncConsumer, error) + type Client interface + Close func() error + ID func() string + func NewClient(id string, manager *queue.Manager, opts ...ClientOption) (Client, error) + type ClientOption func(*clientConfig) + func WithMetadata(key, value string) ClientOption + type ConnectionInfo struct + ClientID string + LastActivity string + Metadata map[string]string + Subscriptions []string + type Consumer interface + Ack func(ctx context.Context, messageID string) error + Nack func(ctx context.Context, messageID string, reason string) error + Receive func(ctx context.Context, limit int) ([]*types.Message, error) + Subscribe func(ctx context.Context, topics ...string) error + Unsubscribe func(ctx context.Context, topics ...string) error + type ConsumerOptions struct + AutoAck bool + BatchSize int + MaxConcurrency int + PollInterval int + type MessageHandler func(ctx context.Context, msg *types.Message) error + type MessageOption func(*types.Message) + func WithMaxRetries(maxRetries int) MessageOption + func WithMessageMetadata(key, value string) MessageOption + func WithPriority(priority int) MessageOption + func WithTTL(ttl time.Duration) MessageOption + type Producer interface + SendDirect func(ctx context.Context, to string, payload []byte, opts ...MessageOption) (*types.Message, error) + SubmitTask func(ctx context.Context, topic string, payload []byte, opts ...MessageOption) (*types.Message, error)
Go to main page