testhelper

Documentation

Index

• func NewConnection(t tLogger, port int) *nats.Conn
• func RunDefaultServer() (*server.Server, int)
• func RunServerOnPort(port int) *server.Server
• func RunServerWithOptions(opts server.Options) *server.Server
• func WaitTime(ch chan bool, timeout time.Duration) error

Functions

func NewConnection

func NewConnection(t tLogger, port int) *nats.Conn

NewConnection forms connection on a given port.

func RunDefaultServer

func RunDefaultServer() (*server.Server, int)

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 RunServerWithOptions

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

RunServerWithOptions will run a server with the given options.

func WaitTime

func WaitTime(ch chan bool, timeout time.Duration) error

WaitTime for a chan with a timeout.