nats

Documentation

Index

• func NewNats(log logger.Logger, name string, hosts string, credentials gnats.Option, ...) (*gnats.Conn, error)
• type ExactlyOnceHandler
• type ExactlyOnceSubscriber
  • func NewExactlyOnceConsumer(ctx context.Context, logger logger.Logger, js nats.JetStreamContext, ...) (*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 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 (*ExactlyOnceSubscriber) Close

func (s *ExactlyOnceSubscriber) Close()

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