package test

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

Code generated by create_version. DO NOT EDIT.

Code generated by create_version. DO NOT EDIT.

Package test contains test utilities

Index ¶

• func RegisterAccessLogServer(grpcServer *grpc.Server, als *AccessLogService)
• func RegisterServer(grpcServer *grpc.Server, server server.Server)
• type AccessLogService
• func (svc *AccessLogService) Dump(f func(string))
• func (svc *AccessLogService) StreamAccessLogs(stream accessloggrpc.AccessLogService_StreamAccessLogsServer) error
• type Callbacks
• 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()

Functions ¶

func RegisterAccessLogServer ¶

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

RegisterAccessLogServer starts an accessloggrpc service.

func RegisterServer ¶

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

RegisterServer registers with v2 services.

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 accessloggrpc.AccessLogService_StreamAccessLogsServer) error

StreamAccessLogs implements the access log service.

type Callbacks ¶

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

func (*Callbacks) OnFetchRequest ¶

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

func (*Callbacks) OnFetchResponse ¶

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

func (*Callbacks) OnStreamClosed ¶

func (cb *Callbacks) OnStreamClosed(id int64)

func (*Callbacks) OnStreamOpen ¶

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

func (*Callbacks) OnStreamRequest ¶

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

func (*Callbacks) OnStreamResponse ¶

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

func (*Callbacks) Report ¶

func (cb *Callbacks) Report()

Source Files ¶

accesslog.go callbacks.go register.go