Versions in this module Expand all Collapse all v0 v0.9.8 Jun 18, 2021 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 + Fetches int + Requests int + Signal chan struct{} + 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()
Go to main page