v1helpers

package
v1.12.56 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 9, 2023 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ExpectCurlWithOffset added in v1.9.25

func ExpectCurlWithOffset(offset int, request CurlRequest, expectedResponse CurlResponse)

func ExpectGrpcHealthOK added in v1.2.15

func ExpectGrpcHealthOK(rootca *string, envoyPort uint32, service string)

func ExpectHttpOK added in v0.18.3

func ExpectHttpOK(body []byte, rootca *string, envoyPort uint32, response string)

func ExpectHttpOKWithOffset added in v1.5.6

func ExpectHttpOKWithOffset(offset int, body []byte, rootca *string, envoyPort uint32, response string)

func ExpectHttpStatusWithOffset added in v1.8.0

func ExpectHttpStatusWithOffset(offset int, body []byte, rootca *string, envoyPort uint32, response string, status int)

func ExpectHttpUnavailableWithOffset added in v1.8.0

func ExpectHttpUnavailableWithOffset(offset int, body []byte, rootca *string, envoyPort uint32, response string)

func StartSslProxy

func StartSslProxy(ctx context.Context, port uint32) uint32

func StartSslProxyWithHelloCB added in v1.5.5

func StartSslProxyWithHelloCB(ctx context.Context, port uint32, cb func(chi *tls.ClientHelloInfo)) uint32

func TestUpstreamReachable added in v0.14.0

func TestUpstreamReachable(envoyPort uint32, tu *TestUpstream, rootca *string)

func TestUpstreamReachableWithOffset added in v1.5.6

func TestUpstreamReachableWithOffset(offset int, envoyPort uint32, tu *TestUpstream, rootca *string)

Types

type CurlRequest added in v1.9.25

type CurlRequest struct {
	RootCA  *string
	Port    uint32
	Path    string
	Body    []byte
	Host    string
	Headers map[string]string
}

type CurlResponse added in v1.9.25

type CurlResponse struct {
	Status  int
	Message string
}

type ReceivedRequest

type ReceivedRequest struct {
	Method      string
	Headers     map[string][]string
	URL         *url.URL
	Body        []byte
	Host        string
	GRPCRequest proto.Message
	Port        uint32
}

type TestUpstream

type TestUpstream struct {
	Upstream    *gloov1.Upstream
	C           <-chan *ReceivedRequest
	Address     string
	Port        uint32
	GrpcServers []*testgrpcservice.TestGRPCServer
}

func NewTestGRPCUpstream added in v0.17.0

func NewTestGRPCUpstream(ctx context.Context, addr string, replicas int) *TestUpstream

func NewTestHttpUpstream

func NewTestHttpUpstream(ctx context.Context, addr string) *TestUpstream

func NewTestHttpUpstreamWithReply added in v0.18.29

func NewTestHttpUpstreamWithReply(ctx context.Context, addr, reply string) *TestUpstream

func NewTestHttpUpstreamWithReplyAndHealthReply added in v1.8.0

func NewTestHttpUpstreamWithReplyAndHealthReply(ctx context.Context, addr, reply, healthReply string) *TestUpstream

func NewTestHttpUpstreamWithTls added in v1.9.25

func NewTestHttpUpstreamWithTls(ctx context.Context, addr string, tlsUpstream bool) *TestUpstream

func NewTestHttpsUpstreamWithReply added in v1.4.0

func NewTestHttpsUpstreamWithReply(ctx context.Context, addr, reply string) *TestUpstream

func (*TestUpstream) FailGrpcHealthCheck added in v0.18.36

func (tu *TestUpstream) FailGrpcHealthCheck() *testgrpcservice.TestGRPCServer

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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