Documentation ¶
Index ¶
- type DeltaStream
- type Stream
- type 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DeltaStream ¶
type DeltaStream interface { grpc.ServerStream Send(*discovery.DeltaDiscoveryResponse) error Recv() (*discovery.DeltaDiscoveryRequest, error) }
type Stream ¶
type Stream interface { grpc.ServerStream Send(*discovery.DiscoveryResponse) error Recv() (*discovery.DiscoveryRequest, error) }
Generic RPC stream.
type StreamState ¶
type StreamState struct {
// contains filtered or unexported fields
}
StreamState will keep track of resource state per type on a stream.
func NewStreamState ¶ added in v0.10.0
func NewStreamState(wildcard bool, initialResourceVersions map[string]string) StreamState
NewStreamState initializes a stream state.
func (*StreamState) GetKnownResourceNames ¶ added in v0.10.0
func (s *StreamState) GetKnownResourceNames(url string) map[string]struct{}
func (*StreamState) GetResourceVersions ¶ added in v0.10.0
func (s *StreamState) GetResourceVersions() map[string]string
func (*StreamState) IsFirst ¶ added in v0.10.0
func (s *StreamState) IsFirst() bool
func (*StreamState) IsWildcard ¶
func (s *StreamState) IsWildcard() bool
func (*StreamState) SetKnownResourceNames ¶ added in v0.10.0
func (s *StreamState) SetKnownResourceNames(url string, names map[string]struct{})
func (*StreamState) SetKnownResourceNamesAsList ¶ added in v0.10.0
func (s *StreamState) SetKnownResourceNamesAsList(url string, names []string)
func (*StreamState) SetResourceVersions ¶ added in v0.10.0
func (s *StreamState) SetResourceVersions(resourceVersions map[string]string)
Click to show internal directories.
Click to hide internal directories.