Versions in this module Expand all Collapse all v1 v1.0.0 Jan 25, 2023 Changes in this version + type Callbacks interface + OnDeltaStreamClosed func(int64, *core.Node) + OnDeltaStreamOpen func(context.Context, int64, string) error + OnStreamDeltaRequest func(int64, *discovery.DeltaDiscoveryRequest) error + OnStreamDeltaResponse func(int64, *discovery.DeltaDiscoveryRequest, *discovery.DeltaDiscoveryResponse) + type Server interface + DeltaStreamHandler func(stream stream.DeltaStream, typeURL string) error + func NewServer(ctx context.Context, config cache.ConfigWatcher, callbacks Callbacks) Server
Go to main page