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
• func RunStreamingServerWithPorts(clusterID string, port, monitorPort int) *nss.StanServer
• func RunTestReplicator(monitorPort, natsServerPort1, natsServerPort2 int) (*rcore.NATSReplicator, error)

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.

func RunStreamingServerWithPorts

func RunStreamingServerWithPorts(clusterID string, port, monitorPort int) *nss.StanServer

RunStreamingServerWithPorts runs the STAN server in a go routine allowing the clusterID and ports to be specified..

func RunTestReplicator

func RunTestReplicator(monitorPort, natsServerPort1, natsServerPort2 int) (*rcore.NATSReplicator, error)

RunTestReplicator starts an instance of the replicator