stream

Documentation

Index

• type DeltaStream
• type Stream
• type StreamState
  • 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)

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) GetKnownResourceNames

func (s *StreamState) GetKnownResourceNames(url string) map[string]struct{}

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) SetKnownResourceNames

func (s *StreamState) SetKnownResourceNames(url string, names map[string]struct{})

func (*StreamState) SetKnownResourceNamesAsList

func (s *StreamState) SetKnownResourceNamesAsList(url string, names []string)

func (*StreamState) SetResourceVersions

func (s *StreamState) SetResourceVersions(resourceVersions map[string]string)