package test

import "github.com/envoyproxy/go-control-plane/pkg/test"

Package test contains test utilities

Index ¶

• Constants
• func RunAccessLogServer(ctx context.Context, als *AccessLogService, port uint)
• func RunHTTP(ctx context.Context, upstreamPort uint)
• func RunManagementGateway(ctx context.Context, srv xds.Server, port uint)
• func RunManagementServer(ctx context.Context, server xds.Server, port uint)
• type AccessLogService
• func (svc *AccessLogService) Dump(f func(string))
• func (svc *AccessLogService) StreamAccessLogs(stream alsgrpc.AccessLogService_StreamAccessLogsServer) error

Constants ¶

const (
	// Hello is the echo message
	Hello = "Hi, there!\n"
)

Functions ¶

func RunAccessLogServer ¶

func RunAccessLogServer(ctx context.Context, als *AccessLogService, port uint)

RunAccessLogServer starts an accessloggrpc service.

func RunHTTP ¶

func RunHTTP(ctx context.Context, upstreamPort uint)

RunHTTP opens a simple listener on the port.

func RunManagementGateway ¶

func RunManagementGateway(ctx context.Context, srv xds.Server, port uint)

RunManagementGateway starts an HTTP gateway to an xDS server.

func RunManagementServer ¶

func RunManagementServer(ctx context.Context, server xds.Server, port uint)

RunManagementServer starts an xDS server at the given port.

Types ¶

type AccessLogService ¶

type AccessLogService struct {
	// contains filtered or unexported fields
}

AccessLogService buffers access logs from the remote Envoy nodes.

func (*AccessLogService) Dump ¶

func (svc *AccessLogService) Dump(f func(string))

Dump releases the collected log entries and clears the log entry list.

func (*AccessLogService) StreamAccessLogs ¶

func (svc *AccessLogService) StreamAccessLogs(stream alsgrpc.AccessLogService_StreamAccessLogsServer) error

StreamAccessLogs implements the access log service.

Source Files ¶

accesslog.go server.go

Directories ¶