test

Documentation

Index

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

Functions

func NewConnection

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

func NewDefaultConnection

func NewDefaultConnection(t tLogger) *nats.Conn

func NewEConn

func NewEConn(t tLogger) *nats.EncodedConn

func RunDefaultServer

func RunDefaultServer() *server.Server

func RunServerOnPort

func RunServerOnPort(port int) *server.Server

func RunServerWithOptions

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

func Wait

func Wait(ch chan bool) error

Dumb wait program to sync on callbacks, etc... Will timeout

func WaitTime

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