Versions in this module Expand all Collapse all v0 v0.10.5 Jan 12, 2023 Changes in this version + type DeltaStream interface + Recv func() (*discovery.DeltaDiscoveryRequest, error) + Send func(*discovery.DeltaDiscoveryResponse) error + type Stream interface + Recv func() (*discovery.DiscoveryRequest, error) + Send func(*discovery.DiscoveryResponse) error + type StreamState struct + func NewStreamState(wildcard bool, initialResourceVersions map[string]string) StreamState + func (s *StreamState) GetKnownResourceNames(url string) map[string]struct{} + func (s *StreamState) GetResourceVersions() map[string]string + func (s *StreamState) IsFirst() bool + func (s *StreamState) IsWildcard() bool + func (s *StreamState) SetKnownResourceNames(url string, names map[string]struct{}) + func (s *StreamState) SetKnownResourceNamesAsList(url string, names []string) + func (s *StreamState) SetResourceVersions(resourceVersions map[string]string)