test

Documentation

Index

• func JsClient(t *testing.T, s *server.Server, opts ...nats.Option) (*nats.Conn, nats.JetStreamContext)
• func RunBasicJetStreamServer() *server.Server
• func RunDefaultServer() *server.Server
• func RunServerOnPort(port int) *server.Server
• func RunServerWithConfig(configFile string) (*server.Server, *server.Options)
• func RunServerWithOptions(opts server.Options) *server.Server
• func ShutdownJSServerAndRemoveStorage(t *testing.T, s *server.Server)

Functions

func JsClient

func JsClient(t *testing.T, s *server.Server, opts ...nats.Option) (*nats.Conn, nats.JetStreamContext)

func RunBasicJetStreamServer

func RunBasicJetStreamServer() *server.Server

func RunDefaultServer

func RunDefaultServer() *server.Server

RunDefaultServer will run a server on the default port.

func RunServerOnPort

func RunServerOnPort(port int) *server.Server

RunServerOnPort will run a server on the given port.

func RunServerWithConfig

func RunServerWithConfig(configFile string) (*server.Server, *server.Options)

RunServerWithConfig will run a server with the given configuration file.

func RunServerWithOptions

func RunServerWithOptions(opts server.Options) *server.Server

RunServerWithOptions will run a server with the given options.

func ShutdownJSServerAndRemoveStorage

func ShutdownJSServerAndRemoveStorage(t *testing.T, s *server.Server)