test

package

v0.9.8 Latest Latest Go to latest Published: Dec 7, 2020 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Package test contains test utilities

This section is empty.

This section is empty.

func RegisterAccessLogServer(grpcServer *grpc.Server, als *AccessLogService)

RegisterAccessLogServer starts an accessloggrpc service.

func RegisterServer(grpcServer *grpc.Server, server server.Server)

RegisterServer registers with v2 services.

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

AccessLogService buffers access logs from the remote Envoy nodes.

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

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

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

StreamAccessLogs implements the access log service.

type Callbacks struct {
	Signal   chan struct{}
	Debug    bool
	Fetches  int
	Requests int
	// contains filtered or unexported fields
}

func (cb *Callbacks) OnFetchRequest(_ context.Context, req *discovery.DiscoveryRequest) error

func (cb *Callbacks) OnFetchResponse(*discovery.DiscoveryRequest, *discovery.DiscoveryResponse)

func (cb *Callbacks) OnStreamClosed(id int64)

func (cb *Callbacks) OnStreamOpen(_ context.Context, id int64, typ string) error

func (cb *Callbacks) OnStreamRequest(int64, *discovery.DiscoveryRequest) error

func (cb *Callbacks) OnStreamResponse(int64, *discovery.DiscoveryRequest, *discovery.DiscoveryResponse)

func (cb *Callbacks) Report()