nats_connector

Documentation

Index

• Constants
• func Module(scope string) fx.Option
• type NATSConnector
  • func (c *NATSConnector) GetConnection() *nats.Conn
  • func (c *NATSConnector) GetJetStreamContext() nats.JetStreamContext
• type Params

Constants

const (
	DefaultHost                = "0.0.0.0:32803"
	DefaultPingInterval        = 10
	DefaultMaxPingsOutstanding = 3
	DefaultMaxReconnects       = -1
	DefaultAccessKey           = ""
)

Functions

func Module

func Module(scope string) fx.Option

Types

type NATSConnector

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

func (*NATSConnector) GetConnection

func (c *NATSConnector) GetConnection() *nats.Conn

func (*NATSConnector) GetJetStreamContext

func (c *NATSConnector) GetJetStreamContext() nats.JetStreamContext

type Params

type Params struct {
	fx.In

	Lifecycle fx.Lifecycle
	Logger    *zap.Logger
}