Documentation ¶
Index ¶
- func GrpcConn(lis net.Listener, t TestingT) *grpc.ClientConn
- func JsClient(t TestingT, s *server.Server, opts ...nats.Option) (*nats.Conn, nats.JetStreamContext)
- func NatsConn(t TestingT, s *server.Server, opts ...nats.Option) *nats.Conn
- func RunBasicJetStreamServer(t TestingT) *server.Server
- func RunBasicServer(t TestingT) *server.Server
- func ShutdownJSServerAndRemoveStorage(t TestingT, s *server.Server)
- func ShutdownServer(t TestingT, s *server.Server)
- type LogAdapter
- func (l *LogAdapter) Debugf(format string, v ...interface{})
- func (l *LogAdapter) Errorf(format string, v ...interface{})
- func (l *LogAdapter) Fatalf(format string, v ...interface{})
- func (l *LogAdapter) Noticef(format string, v ...interface{})
- func (l *LogAdapter) Tracef(format string, v ...interface{})
- func (l *LogAdapter) Warnf(format string, v ...interface{})
- type TestingT
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RunBasicJetStreamServer ¶
func RunBasicServer ¶
func ShutdownServer ¶
Types ¶
type LogAdapter ¶
type LogAdapter struct{}
func (*LogAdapter) Debugf ¶
func (l *LogAdapter) Debugf(format string, v ...interface{})
func (*LogAdapter) Errorf ¶
func (l *LogAdapter) Errorf(format string, v ...interface{})
func (*LogAdapter) Fatalf ¶
func (l *LogAdapter) Fatalf(format string, v ...interface{})
func (*LogAdapter) Noticef ¶
func (l *LogAdapter) Noticef(format string, v ...interface{})
func (*LogAdapter) Tracef ¶
func (l *LogAdapter) Tracef(format string, v ...interface{})
func (*LogAdapter) Warnf ¶
func (l *LogAdapter) Warnf(format string, v ...interface{})
Click to show internal directories.
Click to hide internal directories.