Documentation ¶
Index ¶
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 ¶
func NewStreamState(wildcard bool, initialResourceVersions map[string]string) StreamState
NewStreamState initializes a stream state.
func (*StreamState) GetResourceVersions ¶
func (s *StreamState) GetResourceVersions() map[string]string
func (*StreamState) IsFirst ¶
func (s *StreamState) IsFirst() bool
func (*StreamState) IsWildcard ¶
func (s *StreamState) IsWildcard() bool
func (*StreamState) SetResourceVersions ¶
func (s *StreamState) SetResourceVersions(resourceVersions map[string]string)
Click to show internal directories.
Click to hide internal directories.