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, *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()
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
Responses int
DeltaRequests int
DeltaResponses int
// contains filtered or unexported fields
}
func (*Callbacks) OnDeltaStreamClosed ¶ added in v0.9.9
func (*Callbacks) OnDeltaStreamOpen ¶ added in v0.9.9
func (*Callbacks) OnFetchRequest ¶
func (*Callbacks) OnFetchResponse ¶
func (cb *Callbacks) OnFetchResponse(*discovery.DiscoveryRequest, *discovery.DiscoveryResponse)
func (*Callbacks) OnStreamDeltaRequest ¶ added in v0.9.9
func (cb *Callbacks) OnStreamDeltaRequest(int64, *discovery.DeltaDiscoveryRequest) error
func (*Callbacks) OnStreamDeltaResponse ¶ added in v0.9.9
func (cb *Callbacks) OnStreamDeltaResponse(id int64, req *discovery.DeltaDiscoveryRequest, res *discovery.DeltaDiscoveryResponse)
func (*Callbacks) OnStreamOpen ¶
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)
Source Files
Click to show internal directories.
Click to hide internal directories.