embeddednats

Documentation

Index

• type Option
  • func WithDirectory(dir string) Option
  • func WithLogging(trace bool, debug bool) Option
  • func WithNATSServerOptions(natsServerOptions *server.Options) Option
  • func WithShouldClearData(shouldClearData bool) Option
• type Server
  • func New(ctx context.Context, opts ...Option) (*Server, error)
  • func (n *Server) Client() (*nats.Conn, error)
  • func (n *Server) Close() error
  • func (n *Server) WaitForServer()

Types

type Option

type Option func(*options)

func WithDirectory

func WithDirectory(dir string) Option

func WithLogging

func WithLogging(trace bool, debug bool) Option

func WithNATSServerOptions

func WithNATSServerOptions(natsServerOptions *server.Options) Option

func WithShouldClearData

func WithShouldClearData(shouldClearData bool) Option

type Server

type Server struct {
	NatsServer *server.Server
}

func New

func New(ctx context.Context, opts ...Option) (*Server, error)

New creates a new embedded NATS server. Will automatically start the server and clean up when the context is cancelled.

func (*Server) Client

func (n *Server) Client() (*nats.Conn, error)

func (*Server) Close

func (n *Server) Close() error

func (*Server) WaitForServer

func (n *Server) WaitForServer()