tests

Documentation

Index

• func NewTestLogger() server.Logger
• func SetupNatsServer(t *testing.T, opts *server.Options) (*server.Server, string)
• type NatsServer
  • func NewNatsServer(t *testing.T, opts *server.Options) *NatsServer
  • func (ts *NatsServer) Connect() *nats.Conn
  • func (ts *NatsServer) MaybeConnect(options ...nats.Option) (*nats.Conn, error)
  • func (ts *NatsServer) NewKv(bucket string) jetstream.KeyValue
  • func (ts *NatsServer) Shutdown()
• type TestLogger
  • func (l *TestLogger) Debugf(format string, v ...interface{})
  • func (l *TestLogger) Errorf(format string, v ...interface{})
  • func (l *TestLogger) Fatalf(format string, v ...interface{})
  • func (l *TestLogger) Noticef(format string, v ...interface{})
  • func (l *TestLogger) Tracef(format string, v ...interface{})
  • func (l *TestLogger) Warnf(format string, v ...interface{})

Functions

func NewTestLogger

func NewTestLogger() server.Logger

func SetupNatsServer

func SetupNatsServer(t *testing.T, opts *server.Options) (*server.Server, string)

Types

type NatsServer

type NatsServer struct {
	sync.Mutex

	Server *server.Server
	Url    string
	Conns  []*nats.Conn
	// contains filtered or unexported fields
}

func NewNatsServer

func NewNatsServer(t *testing.T, opts *server.Options) *NatsServer

func (*NatsServer) Connect

func (ts *NatsServer) Connect() *nats.Conn

func (*NatsServer) MaybeConnect

func (ts *NatsServer) MaybeConnect(options ...nats.Option) (*nats.Conn, error)

func (*NatsServer) NewKv

func (ts *NatsServer) NewKv(bucket string) jetstream.KeyValue

func (*NatsServer) Shutdown

func (ts *NatsServer) Shutdown()

type TestLogger

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

func (*TestLogger) Debugf

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

func (*TestLogger) Errorf

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

func (*TestLogger) Fatalf

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

func (*TestLogger) Noticef

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

func (*TestLogger) Tracef

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

func (*TestLogger) Warnf

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