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) 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()