nats

Documentation

Index

• type Conf
  • func (c Conf) NewConnect() (*nats.Conn, error)
  • func (c Conf) NewJetStream() (jetstream.JetStream, error)

Types

type Conf

type Conf struct {
	// Host url example: nats://localhost:4222
	Hosts         []string `json:","`
	ReconnectWait int      `json:",optional,default=5"`
	MaxReconnect  int      `json:",optional,default=5"`
	UserCred      string   `json:",optional"`
	NkeyFile      string   `json:",optional"`
	TlsClientCert string   `json:",optional"`
	TlsClientKey  string   `json:",optional"`
	TlsCACert     string   `json:",optional"`
	UserJwt       string   `json:",optional"`
}

func (Conf) NewConnect

func (c Conf) NewConnect() (*nats.Conn, error)

NewConnect returns a nats connection

func (Conf) NewJetStream

func (c Conf) NewJetStream() (jetstream.JetStream, error)

NewJetStream returns jet stream client instance