common

package

v0.0.0-...-a602bb6 Latest Latest Go to latest Published: Apr 29, 2025 License: Apache-2.0, BSD-2-Clause-Views, BSD-3-Clause, + 1 more Imports: 22 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

ghproxy-9d2.pages.dev/cloudfoundry/gorouter

Links

Open Source Insights

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
type TcpApp
- func NewTcpApp(urls []route.Uri, rPort uint16, mbusClient *nats.Conn, tags map[string]string, ...) *TcpApp
type TestApp
- func NewTestApp(urls []route.Uri, rPort uint16, mbusClient *nats.Conn, tags map[string]string, ...) *TestApp

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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()

Source Files ¶

app.go
network.go
nginx_app.go
tcp_app.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL