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