test

Documentation

Index

• Constants
• func CreateClientConnSubscribeAndPublish(t *testing.T) *nats.Conn
• func RunServer() *server.Server
• func RunServerWithPorts(cport, mport int) *server.Server
• func RunStreamingServer() *nss.StanServer

Constants

const ClientPort = 11224

ClientPort is the default port for clients to connect

const MonitorPort = 11424

MonitorPort is the default monitor port

Functions

func CreateClientConnSubscribeAndPublish

func CreateClientConnSubscribeAndPublish(t *testing.T) *nats.Conn

CreateClientConnSubscribeAndPublish creates a conn and publishes

func RunServer

func RunServer() *server.Server

RunServer runs the NATS server in a go routine

func RunServerWithPorts

func RunServerWithPorts(cport, mport int) *server.Server

RunServerWithPorts runs the NATS server with a monitor port in a go routine

func RunStreamingServer

func RunStreamingServer() *nss.StanServer

RunStreamingServer runs the STAN server in a go routine.