mq

Documentation

Index

• type JetstreamClient
  • func NewJetstreamClient(cfg config.JetstreamConfig, logger logging.Logger) (*JetstreamClient, error)
  • func (c *JetstreamClient) Close()

Types

type JetstreamClient

type JetstreamClient struct {
	nats.JetStreamContext
	// contains filtered or unexported fields
}

JetstreamClient

Wrapper for nats.JetstreamContext to handle errors,
closure of the server connection and stream initialization.

func NewJetstreamClient

func NewJetstreamClient(cfg config.JetstreamConfig, logger logging.Logger) (*JetstreamClient, error)

NewJetstreamClient

Create a net NewJetstreamClient

func (*JetstreamClient) Close

func (c *JetstreamClient) Close()

Close

Closes the internal connection to the jetstream server.