nats

Documentation

Index

• Constants
• func RoutesFromSlice(routes []string, allowLocal bool) ([]*url.URL, error)
• func RoutesFromStr(routesStr string, allowLocal bool) ([]*url.URL, error)
• type ClientManager
  • func NewClientManager(ctx context.Context, servers string, options ...nats.Option) (*ClientManager, error)
  • func (cm *ClientManager) GetDebugInfo(ctx context.Context) (models.DebugInfo, error)
  • func (cm *ClientManager) Stop()
• type ServerManager
  • func NewServerManager(ctx context.Context, params ServerManagerParams) (*ServerManager, error)
  • func (sm *ServerManager) GetDebugInfo(ctx context.Context) (models.DebugInfo, error)
  • func (sm *ServerManager) Stop()
• type ServerManagerParams
• type ZeroLogger
  • func NewZeroLogger(logger zerolog.Logger, serverID string) ZeroLogger
  • func (l ZeroLogger) Debugf(format string, v ...interface{})
  • func (l ZeroLogger) Errorf(format string, v ...interface{})
  • func (l ZeroLogger) Fatalf(format string, v ...interface{})
  • func (l ZeroLogger) Noticef(format string, v ...interface{})
  • func (l ZeroLogger) Tracef(format string, v ...interface{})
  • func (l ZeroLogger) Warnf(format string, v ...interface{})

Constants

const ReadyForConnectionsTimeout = 5 * time.Second

Functions

func RoutesFromSlice

func RoutesFromSlice(routes []string, allowLocal bool) ([]*url.URL, error)

RoutesFromSlice parses route URLs from a slice of strings

func RoutesFromStr

func RoutesFromStr(routesStr string, allowLocal bool) ([]*url.URL, error)

RoutesFromStr parses route URLs from a string e.g. "nats://localhost:4222,nats://localhost:4223"

Types

type ClientManager

type ClientManager struct {
	Client *nats.Conn
}

func NewClientManager

func NewClientManager(ctx context.Context, servers string, options ...nats.Option) (*ClientManager, error)

NewClientManager is a helper function to create a NATS client connection with a given name and servers string

func (*ClientManager) GetDebugInfo

func (cm *ClientManager) GetDebugInfo(ctx context.Context) (models.DebugInfo, error)

DebugInfo returns the debug info of the NATS client

func (*ClientManager) Stop

func (cm *ClientManager) Stop()

Stop stops the NATS client

type ServerManager

type ServerManager struct {
	Server *server.Server
}

ServerManager is a helper struct to manage a NATS server

func NewServerManager

func NewServerManager(ctx context.Context, params ServerManagerParams) (*ServerManager, error)

NewServerManager is a helper function to create a NATS server with a given options

func (*ServerManager) GetDebugInfo

func (sm *ServerManager) GetDebugInfo(ctx context.Context) (models.DebugInfo, error)

GetDebugInfo returns the debug info of the NATS server

func (*ServerManager) Stop

func (sm *ServerManager) Stop()

Stop stops the NATS server

type ServerManagerParams

type ServerManagerParams struct {
	Options           *server.Options
	ConnectionTimeout time.Duration
}

type ZeroLogger

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

ZeroLogger is a wrapper around zerolog.Logger to implement the NATS Logger interface

func NewZeroLogger

func NewZeroLogger(logger zerolog.Logger, serverID string) ZeroLogger

NewZeroLogger creates a new ZeroLogger

func (ZeroLogger) Debugf

func (l ZeroLogger) Debugf(format string, v ...interface{})

func (ZeroLogger) Errorf

func (l ZeroLogger) Errorf(format string, v ...interface{})

func (ZeroLogger) Fatalf

func (l ZeroLogger) Fatalf(format string, v ...interface{})

func (ZeroLogger) Noticef

func (l ZeroLogger) Noticef(format string, v ...interface{})

func (ZeroLogger) Tracef

func (l ZeroLogger) Tracef(format string, v ...interface{})

func (ZeroLogger) Warnf

func (l ZeroLogger) Warnf(format string, v ...interface{})