nats

Documentation

Index

• type Config
• type Nats
  • func Provider(cfg Config) (*Nats, error)
  • func (n *Nats) Read() (map[string]interface{}, error)
  • func (n *Nats) ReadBytes() ([]byte, error)
  • func (n *Nats) Watch(cb func(event interface{}, err error)) error

Types

type Config

type Config struct {
	// nats endpoint (comma separated urls are possible, eg "nats://one, nats://two").
	URL string

	// Optional NATS options: nats.Connect(url, ...options)
	Options []nats.Option

	// Optional JetStream options: nc.JetStream(...options)
	JetStreamOptions []nats.JSOpt

	// Bucket is the Nats KV bucket.
	Bucket string

	// Prefix (optional).
	Prefix string
}

type Nats

type Nats struct {
	// contains filtered or unexported fields
}

Nats implements the nats config provider.

func Provider

func Provider(cfg Config) (*Nats, error)

Provider returns a provider that takes nats config.

func (*Nats) Read

func (n *Nats) Read() (map[string]interface{}, error)

Read returns a nested config map.

func (*Nats) ReadBytes

func (n *Nats) ReadBytes() ([]byte, error)

ReadBytes is not supported by nats provider.

func (*Nats) Watch

func (n *Nats) Watch(cb func(event interface{}, err error)) error