Versions in this module Expand all Collapse all v0 v0.9.7 Sep 1, 2020 Changes in this version + type CallbackFuncs struct + FetchRequestFunc func(context.Context, *discovery.DiscoveryRequest) error + FetchResponseFunc func(*discovery.DiscoveryRequest, *discovery.DiscoveryResponse) + StreamClosedFunc func(int64) + StreamOpenFunc func(context.Context, int64, string) error + StreamRequestFunc func(int64, *discovery.DiscoveryRequest) error + StreamResponseFunc func(int64, *discovery.DiscoveryRequest, *discovery.DiscoveryResponse) + func (c CallbackFuncs) OnFetchRequest(ctx context.Context, req *discovery.DiscoveryRequest) error + func (c CallbackFuncs) OnFetchResponse(req *discovery.DiscoveryRequest, resp *discovery.DiscoveryResponse) + func (c CallbackFuncs) OnStreamClosed(streamID int64) + func (c CallbackFuncs) OnStreamOpen(ctx context.Context, streamID int64, typeURL string) error + func (c CallbackFuncs) OnStreamRequest(streamID int64, req *discovery.DiscoveryRequest) error + func (c CallbackFuncs) OnStreamResponse(streamID int64, req *discovery.DiscoveryRequest, ...) + type Callbacks interface + OnFetchRequest func(context.Context, *discovery.DiscoveryRequest) error + OnFetchResponse func(*discovery.DiscoveryRequest, *discovery.DiscoveryResponse) + OnStreamClosed func(int64) + OnStreamOpen func(context.Context, int64, string) error + OnStreamRequest func(int64, *discovery.DiscoveryRequest) error + OnStreamResponse func(int64, *discovery.DiscoveryRequest, *discovery.DiscoveryResponse) + type HTTPGateway struct + Log log.Logger + Server Server + func (h *HTTPGateway) ServeHTTP(req *http.Request) ([]byte, int, error) + type Server interface + Fetch func(context.Context, *discovery.DiscoveryRequest) (*discovery.DiscoveryResponse, error) + StreamHandler func(stream Stream, typeURL string) error + func NewServer(ctx context.Context, config cache.Cache, callbacks Callbacks) Server + type Stream interface + Recv func() (*discovery.DiscoveryRequest, error) + Send func(*discovery.DiscoveryResponse) error