Versions in this module Expand all Collapse all v0 v0.1.0 May 5, 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