test

Documentation

Overview

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) OnDeltaStreamClosed(id int64, node *core.Node)
  • func (cb *Callbacks) OnDeltaStreamOpen(_ context.Context, id int64, typ string) error
  • func (cb *Callbacks) OnFetchRequest(context.Context, *discovery.DiscoveryRequest) error
  • func (cb *Callbacks) OnFetchResponse(*discovery.DiscoveryRequest, *discovery.DiscoveryResponse)
  • func (cb *Callbacks) OnStreamClosed(id int64, node *core.Node)
  • func (cb *Callbacks) OnStreamDeltaRequest(int64, *discovery.DeltaDiscoveryRequest) error
  • func (cb *Callbacks) OnStreamDeltaResponse(id int64, req *discovery.DeltaDiscoveryRequest, ...)
  • func (cb *Callbacks) OnStreamOpen(_ context.Context, id int64, typ string) error
  • func (cb *Callbacks) OnStreamRequest(id int64, req *discovery.DiscoveryRequest) error
  • func (cb *Callbacks) OnStreamResponse(ctx context.Context, id int64, req *discovery.DiscoveryRequest, ...)
  • 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 v3 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
	Responses      int
	DeltaRequests  int
	DeltaResponses int
	// contains filtered or unexported fields
}

func (*Callbacks) OnDeltaStreamClosed

func (cb *Callbacks) OnDeltaStreamClosed(id int64, node *core.Node)

func (*Callbacks) OnDeltaStreamOpen

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

func (*Callbacks) OnFetchRequest

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

func (*Callbacks) OnFetchResponse

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

func (*Callbacks) OnStreamClosed

func (cb *Callbacks) OnStreamClosed(id int64, node *core.Node)

func (*Callbacks) OnStreamDeltaRequest

func (cb *Callbacks) OnStreamDeltaRequest(int64, *discovery.DeltaDiscoveryRequest) error

func (*Callbacks) OnStreamDeltaResponse

func (cb *Callbacks) OnStreamDeltaResponse(id int64, req *discovery.DeltaDiscoveryRequest, res *discovery.DeltaDiscoveryResponse)

func (*Callbacks) OnStreamOpen

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

func (*Callbacks) OnStreamRequest

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

func (*Callbacks) OnStreamResponse

func (cb *Callbacks) OnStreamResponse(ctx context.Context, id int64, req *discovery.DiscoveryRequest, res *discovery.DiscoveryResponse)

func (*Callbacks) Report

func (cb *Callbacks) Report()