nats

Documentation

Index

• func NewNats(log logger.Logger, name string, hosts string, credentials gnats.Option, ...) (*gnats.Conn, error)
• type ExactlyOnceConsumerConfig
• type ExactlyOnceHandler
• type ExactlyOnceSubscriber
  • func NewExactlyOnceConsumer(ctx context.Context, logger logger.Logger, js nats.JetStreamContext, ...) (*ExactlyOnceSubscriber, error)
  • func NewExactlyOnceConsumerWithConfig(config ExactlyOnceConsumerConfig) (*ExactlyOnceSubscriber, error)
  • func (s *ExactlyOnceSubscriber) Close()

Functions

func NewNats

func NewNats(log logger.Logger, name string, hosts string, credentials gnats.Option, opts ...gnats.Option) (*gnats.Conn, error)

NewNats will return a new nats connections

Types

type ExactlyOnceConsumerConfig

type ExactlyOnceConsumerConfig struct {
	Context             context.Context
	Logger              logger.Logger
	JetStream           nats.JetStreamContext
	StreamName          string
	DurableName         string
	ConsumerDescription string
	FilterSubject       string
	Handler             ExactlyOnceHandler
	DeliverPolicy       nats.DeliverPolicy
	Deliver             nats.SubOpt
	MaxAckPending       int
}

type ExactlyOnceHandler

type ExactlyOnceHandler func(ctx context.Context, payload []byte, msg *nats.Msg) error

type ExactlyOnceSubscriber

type ExactlyOnceSubscriber struct {
	// contains filtered or unexported fields
}

func NewExactlyOnceConsumer

func NewExactlyOnceConsumer(ctx context.Context, logger logger.Logger, js nats.JetStreamContext, stream string, durable string, description string, subject string, handler ExactlyOnceHandler) (*ExactlyOnceSubscriber, error)

NewExactlyOnceConsumer will create (or reuse) an exactly once durable consumer

func NewExactlyOnceConsumerWithConfig

func NewExactlyOnceConsumerWithConfig(config ExactlyOnceConsumerConfig) (*ExactlyOnceSubscriber, error)

NewExactlyOnceConsumer will create (or reuse) an exactly once durable consumer

func (*ExactlyOnceSubscriber) Close

func (s *ExactlyOnceSubscriber) Close()

Close will shutdown subscriptions and wait for the subscriber to be shutdown