nats

package

v1.3.2 Latest Latest Go to latest Published: Jun 4, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/bacalhau-project/bacalhau

Links

Open Source Insights

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) (model.DebugInfo, error)
- func (cm *ClientManager) Stop()
type ServerManager
- func NewServerManager(ctx context.Context, params ServerManagerParams) (*ServerManager, error)
- func (sm *ServerManager) GetDebugInfo(ctx context.Context) (model.DebugInfo, error)
- func (sm *ServerManager) Stop()
type ServerManagerParams
type ZeroLogger
- func NewZeroLogger(logger zerolog.Logger, serverID string) ZeroLogger

Constants ¶

View Source

const ReadyForConnectionsTimeout = 5 * time.Second

Variables ¶

This section is empty.

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) (model.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) (model.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{})

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
proxy
pubsub
stream Package stream provides a NATS client for streaming records between clients with asynchronous response handling.	Package stream provides a NATS client for streaming records between clients with asynchronous response handling.
transport

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL