js

Documentation

Index

• func NewPublisher(connection *connection.NatsConnection) (pubsub.Publisher, error)
• func NewSubscriber(connection *connection.NatsConnection, batchCount int, opts ...Option) (pubsub.Subscriber, error)
• type Option
  • func WithAckWait(ackWait time.Duration) Option
  • func WithMeterSubscriberOption(meter metric.Meter) Option
  • func WithTracer(tracer tracing.Tracer) Option

Functions

func NewPublisher

func NewPublisher(connection *connection.NatsConnection) (pubsub.Publisher, error)

func NewSubscriber

func NewSubscriber(
	connection *connection.NatsConnection,
	batchCount int,
	opts ...Option,
) (pubsub.Subscriber, error)

Types

type Option

type Option func(s *subscriber)

func WithAckWait

func WithAckWait(ackWait time.Duration) Option

func WithMeterSubscriberOption

func WithMeterSubscriberOption(meter metric.Meter) Option

func WithTracer

func WithTracer(tracer tracing.Tracer) Option