nats

package

v0.14.0 Latest Latest Go to latest Published: Aug 5, 2026 License: MIT Imports: 1 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Client struct {
	*nats.Conn
	Conf Config
}

func (db *Client) Close() error

Close drains the NATS connection to flush pending messages before disconnecting.

func (db *Client) Config() any

Config returns the embedded Conf as the configuration for injection.

func (db *Client) Init() error

Init creates the NATS connection and stores it in Conn.

type Config nats.Options

func (c *Config) AfterInject()

AfterInject calls Init after config fields are populated.

func (c *Config) BeforeInject()

BeforeInject is a no-op satisfying the Config interface.

func (c *Config) Build() (*nats.Conn, error)

Build connects to NATS using the stored options.

func (c *Config) Init()

Init is a no-op placeholder for future default initialization.