nats

Sep 22, 2023

Changes in this version

type Client

+ ConsumersExist func(streamName string) (bool, error)

+ GetStreams func() ([]*nats.StreamInfo, error)

Jul 19, 2023

Changes in this version

+ type Client interface

+ Close func()

+ Init func() error

+ StreamExists func() (bool, error)

+ func NewNatsClient(natsConfig *Config) Client

+ type Config struct

+ Timeout time.Duration

+ URL string

+ type Conn interface

+ Close func()

+ IsConnected func() bool

+ JetStream func() (nats.JetStreamContext, error)

+ Status func() nats.Status