natsclient

Jun 26, 2024

Changes in this version

type ConsumerOpt

+ func WithMaxDeliver(count int) ConsumerOpt

Mar 1, 2024

Changes in this version

+ const GiB

+ const KiB

+ const MiB

+ const StreamDefaultMaxAge

+ var ConsumerMetrics = promauto.NewHistogramVec(prometheus.HistogramOpts{ ... }, []string{ ... })

+ var ErrGroupRequired = errors.New("group is required")

+ var ErrInvalidChars = errors.New("subject contains spaces")

+ var ErrSubjectRequired = errors.New("subject is required")

+ var PublisherMetrics = promauto.NewHistogramVec(prometheus.HistogramOpts{ ... }, []string{ ... })

+ func CollectConsumerMetric(subject, action string, err error, duration float64)

+ func CollectPublisherMetrics(subject string, err error, duration float64)

+ type Consumer struct

+ func NewConsumer[T any](ctx context.Context, conn *nats.Conn, group, subject string, ...) (*Consumer[T], error)

+ func (c *Consumer[T]) Close() error

+ type ConsumerOpt func(*nats.ConsumerConfig)

+ func WithAckPolicy(policy nats.AckPolicy) ConsumerOpt

+ func WithAckWait(wait time.Duration) ConsumerOpt

+ func WithDeliverPolicy(policy nats.DeliverPolicy) ConsumerOpt

+ func WithMaxAckPending(count int) ConsumerOpt

+ func WithRateLimit(limit uint64) ConsumerOpt

+ type Producer struct

+ func NewProducer(conn *nats.Conn, subject string) (*Producer, error)

+ func (p *Producer) PublishData(ctx context.Context, data []byte) error

+ func (p *Producer) PublishJSON(ctx context.Context, v any) error

+ type Publisher struct

+ func NewPublisher(nc *nats.Conn) (*Publisher, error)

+ func (p *Publisher) PublishJSON(ctx context.Context, subject string, obj any) error