Versions in this module Expand all Collapse all v0 v0.9.8 Jun 18, 2021 Changes in this version + type Callbacks interface + OnStreamClosed func(int64) + OnStreamOpen func(context.Context, int64, string) error + OnStreamRequest func(int64, *discovery.DiscoveryRequest) error + OnStreamResponse func(int64, *discovery.DiscoveryRequest, *discovery.DiscoveryResponse) + type Server interface + StreamHandler func(stream Stream, typeURL string) error + func NewServer(ctx context.Context, config cache.ConfigWatcher, callbacks Callbacks) Server + type Stream interface + Recv func() (*discovery.DiscoveryRequest, error) + Send func(*discovery.DiscoveryResponse) error
Go to main page