test

Documentation

Index

• func JetStreamClient(t *testing.T, s *server.Server) nats.JetStreamClient
• func RunJetStreamServer(t *testing.T) *server.Server
• func RunNatsServer(t *testing.T) *server.Server
• func ShutdownJetStreamServer(t *testing.T, s *server.Server)

Functions

func JetStreamClient

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

JetStreamClient is used to get a testing JetStream client instance

func RunJetStreamServer

func RunJetStreamServer(t *testing.T) *server.Server

RunJetStreamServer starts a jetstream server

func RunNatsServer

func RunNatsServer(t *testing.T) *server.Server

RunNatsServer starts a nats server

func ShutdownJetStreamServer

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

ShutdownJetStreamServer shuts down the jetstream server and clean up resources