connection

Documentation

Index

• func NatsDefaultConnectionOptions(cfg *pubsub.Config, logger log.Logger) []nats.Option
• type NatsConnection
  • func NewNatsConnection(cfg *pubsub.Config, logger log.Logger, options ...nats.Option) (*NatsConnection, error)
  • func (c NatsConnection) Close() error
  • func (c NatsConnection) Ping(_ context.Context) error

Functions

func NatsDefaultConnectionOptions

func NatsDefaultConnectionOptions(cfg *pubsub.Config, logger log.Logger) []nats.Option

Types

type NatsConnection

type NatsConnection struct {
	Connection *nats.Conn
	Logger     log.Logger
}

func NewNatsConnection

func NewNatsConnection(cfg *pubsub.Config, logger log.Logger, options ...nats.Option) (*NatsConnection, error)

func (NatsConnection) Close

func (c NatsConnection) Close() error

func (NatsConnection) Ping

func (c NatsConnection) Ping(_ context.Context) error