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
- 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, req *discovery.DiscoveryRequest) error
- func (cb *Callbacks) OnFetchResponse(*discovery.DiscoveryRequest, *discovery.DiscoveryResponse)
- func (cb *Callbacks) OnStreamClosed(id int64, node *core.Node)
- func (cb *Callbacks) OnStreamDeltaRequest(id int64, req *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(int64, *discovery.DiscoveryRequest) error
- func (cb *Callbacks) OnStreamResponse(context.Context, int64, *discovery.DiscoveryRequest, ...)
- func (cb *Callbacks) Report()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterAccessLogServer ¶
func RegisterAccessLogServer(grpcServer *grpc.Server, als *AccessLogService)
RegisterAccessLogServer starts an accessloggrpc service.
func RegisterServer ¶
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 DeltaRequests int DeltaResponses int // contains filtered or unexported fields }
func (*Callbacks) OnDeltaStreamClosed ¶
func (*Callbacks) OnDeltaStreamOpen ¶
func (*Callbacks) OnFetchRequest ¶
func (*Callbacks) OnFetchResponse ¶
func (cb *Callbacks) OnFetchResponse(*discovery.DiscoveryRequest, *discovery.DiscoveryResponse)
func (*Callbacks) OnStreamDeltaRequest ¶
func (cb *Callbacks) OnStreamDeltaRequest(id int64, req *discovery.DeltaDiscoveryRequest) error
func (*Callbacks) OnStreamDeltaResponse ¶
func (cb *Callbacks) OnStreamDeltaResponse(id int64, req *discovery.DeltaDiscoveryRequest, res *discovery.DeltaDiscoveryResponse)
func (*Callbacks) OnStreamOpen ¶
func (*Callbacks) OnStreamRequest ¶
func (cb *Callbacks) OnStreamRequest(int64, *discovery.DiscoveryRequest) error
func (*Callbacks) OnStreamResponse ¶
func (cb *Callbacks) OnStreamResponse(context.Context, int64, *discovery.DiscoveryRequest, *discovery.DiscoveryResponse)
Click to show internal directories.
Click to hide internal directories.