common

Documentation

Index

• func TestTcp(done <-chan bool) (string, <-chan string)
• func TestUdp(done <-chan bool) (string, <-chan string)
• type NginxApp
  • func NewNginxApp(urls []route.Uri, rPort uint16, mbusClient *nats.Conn, tags map[string]string, ...) *NginxApp
  • func (a *NginxApp) Register()
  • func (a *NginxApp) Stop()
  • func (a *NginxApp) Urls() []route.Uri
• type TcpApp
  • func NewTcpApp(urls []route.Uri, rPort uint16, mbusClient *nats.Conn, tags map[string]string, ...) *TcpApp
  • func (a *TcpApp) AppGUID() string
  • func (a *TcpApp) Endpoint() string
  • func (a *TcpApp) Listen() error
  • func (a *TcpApp) Port() uint16
  • func (a *TcpApp) Register()
  • func (a *TcpApp) RegisterAndListen()
  • func (a *TcpApp) SetHandlers(handlers []func(conn *test_util.HttpConn))
  • func (a *TcpApp) SetRouteService(routeService string)
  • func (a *TcpApp) Stop()
  • func (a *TcpApp) TlsRegister(serverCertDomainSAN string)
  • func (a *TcpApp) TlsRegisterWithIndex(serverCertDomainSAN string, index int)
  • func (a *TcpApp) Unregister()
  • func (a *TcpApp) Urls() []route.Uri
• type TestApp
  • func NewTestApp(urls []route.Uri, rPort uint16, mbusClient *nats.Conn, tags map[string]string, ...) *TestApp
  • func (a *TestApp) AddHandler(path string, handler func(http.ResponseWriter, *http.Request))
  • func (a *TestApp) AppGUID() string
  • func (a *TestApp) CheckAppStatus(status int) error
  • func (a *TestApp) CheckAppStatusWithPath(status int, path string) error
  • func (a *TestApp) Endpoint() string
  • func (a *TestApp) Listen()
  • func (a *TestApp) Port() uint16
  • func (a *TestApp) Register()
  • func (a *TestApp) RegisterAndListen()
  • func (a *TestApp) RegisterRepeatedly(duration time.Duration)
  • func (a *TestApp) SetRouteService(routeService string)
  • func (a *TestApp) Stop()
  • func (a *TestApp) TlsListen(tlsConfig *tls.Config) chan error
  • func (a *TestApp) TlsRegister(serverCertDomainSAN string)
  • func (a *TestApp) TlsRegisterWithIndex(serverCertDomainSAN string, index int)
  • func (a *TestApp) Unregister()
  • func (a *TestApp) Urls() []route.Uri
  • func (a *TestApp) VerifyAppStatus(status int)
  • func (a *TestApp) WaitUntilReady()

Functions

func TestTcp

func TestTcp(done <-chan bool) (string, <-chan string)

TestTcp sets up a TCP listener which accepts the first connection and reads individual lines sent over it into the returned channel. The channel is buffered. The listen address is returned as well.

func TestUdp

func TestUdp(done <-chan bool) (string, <-chan string)

TestUdp sets up a UDP listener which accepts the first connection and reads individual datagrams sent over it into the returned channel. The channel is buffered. The listen address is returned as well.

Types

type NginxApp

type NginxApp struct {
	GUID string
	// contains filtered or unexported fields
}

func NewNginxApp

func NewNginxApp(urls []route.Uri, rPort uint16, mbusClient *nats.Conn, tags map[string]string, routeService string) *NginxApp

func (*NginxApp) Register

func (a *NginxApp) Register()

func (*NginxApp) Stop

func (a *NginxApp) Stop()

func (*NginxApp) Urls

func (a *NginxApp) Urls() []route.Uri

type TcpApp

type TcpApp struct {
	GUID string
	// contains filtered or unexported fields
}

func NewTcpApp

func NewTcpApp(urls []route.Uri, rPort uint16, mbusClient *nats.Conn, tags map[string]string, routeService string) *TcpApp

func (*TcpApp) AppGUID

func (a *TcpApp) AppGUID() string

func (*TcpApp) Endpoint

func (a *TcpApp) Endpoint() string

func (*TcpApp) Listen

func (a *TcpApp) Listen() error

func (*TcpApp) Port

func (a *TcpApp) Port() uint16

func (*TcpApp) Register

func (a *TcpApp) Register()

func (*TcpApp) RegisterAndListen

func (a *TcpApp) RegisterAndListen()

func (*TcpApp) SetHandlers

func (a *TcpApp) SetHandlers(handlers []func(conn *test_util.HttpConn))

func (*TcpApp) SetRouteService

func (a *TcpApp) SetRouteService(routeService string)

func (*TcpApp) Stop

func (a *TcpApp) Stop()

func (*TcpApp) TlsRegister

func (a *TcpApp) TlsRegister(serverCertDomainSAN string)

func (*TcpApp) TlsRegisterWithIndex

func (a *TcpApp) TlsRegisterWithIndex(serverCertDomainSAN string, index int)

func (*TcpApp) Unregister

func (a *TcpApp) Unregister()

func (*TcpApp) Urls

func (a *TcpApp) Urls() []route.Uri

type TestApp

type TestApp struct {
	GUID string
	// contains filtered or unexported fields
}

func NewTestApp

func NewTestApp(urls []route.Uri, rPort uint16, mbusClient *nats.Conn, tags map[string]string, routeService string) *TestApp

func (*TestApp) AddHandler

func (a *TestApp) AddHandler(path string, handler func(http.ResponseWriter, *http.Request))

func (*TestApp) AppGUID

func (a *TestApp) AppGUID() string

func (*TestApp) CheckAppStatus

func (a *TestApp) CheckAppStatus(status int) error

func (*TestApp) CheckAppStatusWithPath

func (a *TestApp) CheckAppStatusWithPath(status int, path string) error

func (*TestApp) Endpoint

func (a *TestApp) Endpoint() string

func (*TestApp) Listen

func (a *TestApp) Listen()

func (*TestApp) Port

func (a *TestApp) Port() uint16

func (*TestApp) Register

func (a *TestApp) Register()

func (*TestApp) RegisterAndListen

func (a *TestApp) RegisterAndListen()

func (*TestApp) RegisterRepeatedly

func (a *TestApp) RegisterRepeatedly(duration time.Duration)

func (*TestApp) SetRouteService

func (a *TestApp) SetRouteService(routeService string)

func (*TestApp) Stop

func (a *TestApp) Stop()

func (*TestApp) TlsListen

func (a *TestApp) TlsListen(tlsConfig *tls.Config) chan error

func (*TestApp) TlsRegister

func (a *TestApp) TlsRegister(serverCertDomainSAN string)

func (*TestApp) TlsRegisterWithIndex

func (a *TestApp) TlsRegisterWithIndex(serverCertDomainSAN string, index int)

func (*TestApp) Unregister

func (a *TestApp) Unregister()

func (*TestApp) Urls

func (a *TestApp) Urls() []route.Uri

func (*TestApp) VerifyAppStatus

func (a *TestApp) VerifyAppStatus(status int)

func (*TestApp) WaitUntilReady

func (a *TestApp) WaitUntilReady()