Versions in this module Expand all Collapse all v0 v0.11.3 Jun 6, 2023 v0.11.2 Jun 6, 2023 Changes in this version + func RegisterAccessLogServer(grpcServer *grpc.Server, als *AccessLogService) + func RegisterServer(grpcServer *grpc.Server, server server.Server) + type AccessLogService struct + func (svc *AccessLogService) Dump(f func(string)) + func (svc *AccessLogService) StreamAccessLogs(stream accessloggrpc.AccessLogService_StreamAccessLogsServer) error + type Callbacks struct + Debug bool + DeltaRequests int + DeltaResponses int + Fetches int + Requests int + Responses int + Signal chan struct{} + 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()
Go to main page