connections

Dec 11, 2023

Changes in this version

+ type Connection interface

+ CreateSubscription func(ctx context.Context, opts *SubscriptionOptions) (Queue, error)

+ CreateTopic func(ctx context.Context, opts *TopicOptions) (Topic, error)

+ DeleteSubscription func(ctx context.Context, opts *SubscriptionOptions) error

+ Raw func() interface{}

+ func NewJetstream(js jetstream.JetStream) Connection

+ func NewPlain(natsConn *nats.Conn) Connection

+ type Queue interface

+ Ack func(ctx context.Context, ids []driver.AckID) error

+ IsQueueGroup func() bool

+ Nack func(ctx context.Context, ids []driver.AckID) error

+ ReceiveMessages func(ctx context.Context, batchCount int) ([]*driver.Message, error)

+ Unsubscribe func() error

+ type SubscriptionOptions struct

+ ConsumerAckWaitTimeoutMs int

+ ConsumerMaxAckPending int

+ ConsumerMaxRequestExpiresMs int

+ ConsumerMaxWaiting int

+ ConsumerName string

+ ConsumerRequestBatch int

+ ConsumerRequestMaxBatchBytes int

+ ConsumerRequestTimeoutMs int

+ ConsumersMaxCount int

+ Durable string

+ StreamDescription string

+ StreamName string

+ Subjects []string

+ type Topic interface

+ PublishMessage func(ctx context.Context, msg *nats.Msg) (string, error)

+ Subject func() string

+ type TopicOptions struct

+ Subject string