client

Documentation

Index

• type Client
  • func New(config Config, fileWatcher *fsnotify.Watcher, logger log.Logger) (*Client, error)
  • func (c *Client) AddCloseFunc(f func())
  • func (c *Client) Close()
  • func (c *Client) GetConn() *nats.Conn
• type Config
  • func (c *Config) Validate() error
• type ConfigPublisher
  • func (c *ConfigPublisher) Validate() error
• type PendingLimitsConfig
  • func (c *PendingLimitsConfig) Validate() error

Types

type Client

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

func New

func New(config Config, fileWatcher *fsnotify.Watcher, logger log.Logger) (*Client, error)

func (*Client) AddCloseFunc

func (c *Client) AddCloseFunc(f func())

func (*Client) Close

func (c *Client) Close()

func (*Client) GetConn

func (c *Client) GetConn() *nats.Conn

type Config

type Config struct {
	URL            string              `yaml:"url" json:"url"`
	FlusherTimeout time.Duration       `yaml:"flusherTimeout" json:"flusherTimeout"`
	PendingLimits  PendingLimitsConfig `yaml:"pendingLimits" json:"pendingLimits"`
	TLS            client.Config       `yaml:"tls" json:"tls"`
	Options        []nats.Option       `yaml:"-" json:"-"`
}

func (*Config) Validate

func (c *Config) Validate() error

type ConfigPublisher

type ConfigPublisher struct {
	JetStream bool `yaml:"jetstream" json:"jetstream"`
	Config    `yaml:",inline" json:",inline"`
}

func (*ConfigPublisher) Validate

func (c *ConfigPublisher) Validate() error

type PendingLimitsConfig

type PendingLimitsConfig struct {
	MsgLimit   int `yaml:"msgLimit" json:"msgLimit"`
	BytesLimit int `yaml:"bytesLimit" json:"bytesLimit"`
}

func (*PendingLimitsConfig) Validate

func (c *PendingLimitsConfig) Validate() error