stream

Documentation

Index

• type ClusterDiscoveryResponseStream
• type ConsulEDS
  • func New(hub pubsub.Hub, service eds.Endpoint) *ConsulEDS
  • func (e *ConsulEDS) StreamAggregatedResources(s cp.AggregatedDiscoveryService_StreamAggregatedResourcesServer) error
• type DiscoveryResponseStream
  • func NewDiscoveryResponseStream(stream dis.AggregatedDiscoveryService_StreamAggregatedResourcesServer) DiscoveryResponseStream
• type DiscoveryStream
• type EndpointDiscoveryResponseStream
• type MockXDSStream
  • func (s *MockXDSStream) Capture() *cp.DiscoveryResponse
  • func (s *MockXDSStream) Context() context.Context
  • func (s *MockXDSStream) Recv() (req *cp.DiscoveryRequest, err error)
  • func (*MockXDSStream) RecvMsg(m interface{}) error
  • func (s *MockXDSStream) Send(r *cp.DiscoveryResponse) error
  • func (*MockXDSStream) SendHeader(metadata.MD) error
  • func (*MockXDSStream) SendMsg(m interface{}) error
  • func (*MockXDSStream) SetHeader(metadata.MD) error
  • func (*MockXDSStream) SetTrailer(metadata.MD)
• type RouteDiscoveryResponseStream
• type SubscriptionStream
  • func NewSubscriptionStream(stream cp.AggregatedDiscoveryService_StreamAggregatedResourcesServer, ...) SubscriptionStream

Types

type ClusterDiscoveryResponseStream

type ClusterDiscoveryResponseStream interface {
	SendCDS([]*cp.Cluster) error
}

type ConsulEDS

type ConsulEDS struct {
	// contains filtered or unexported fields
}

ConsulEDS is an implementation of envoy EDS grpc api via envoy go control plan api contract.

func New

func New(hub pubsub.Hub, service eds.Endpoint) *ConsulEDS

func (*ConsulEDS) StreamAggregatedResources

func (e *ConsulEDS) StreamAggregatedResources(s cp.AggregatedDiscoveryService_StreamAggregatedResourcesServer) error

StreamAggregatedResources is a grpc streaming api for streaming Discovery responses

type DiscoveryResponseStream

type DiscoveryResponseStream interface {
	ClusterDiscoveryResponseStream
	EndpointDiscoveryResponseStream
	RouteDiscoveryResponseStream
}

DiscoveryResponseStream is an xDS Stream wrapper and wraps grpc stream API and pipes DiscoveryResponse events to it.

func NewDiscoveryResponseStream

func NewDiscoveryResponseStream(stream dis.AggregatedDiscoveryService_StreamAggregatedResourcesServer) DiscoveryResponseStream

NewDiscoveryResponseStream creates a DiscoveryResponseStream

type DiscoveryStream

type DiscoveryStream interface {
	Send(*cp.DiscoveryResponse) error
	Recv() (*cp.DiscoveryRequest, error)
	grpc.ServerStream
}

type EndpointDiscoveryResponseStream

type EndpointDiscoveryResponseStream interface {
	SendEDS([]*cp.ClusterLoadAssignment) error
}

type MockXDSStream

type MockXDSStream struct {
	mock.Mock
	Ctx context.Context
}

func (*MockXDSStream) Capture

func (s *MockXDSStream) Capture() *cp.DiscoveryResponse

func (*MockXDSStream) Context

func (s *MockXDSStream) Context() context.Context

func (*MockXDSStream) Recv

func (s *MockXDSStream) Recv() (req *cp.DiscoveryRequest, err error)

func (*MockXDSStream) RecvMsg

func (*MockXDSStream) RecvMsg(m interface{}) error

func (*MockXDSStream) Send

func (s *MockXDSStream) Send(r *cp.DiscoveryResponse) error

func (*MockXDSStream) SendHeader

func (*MockXDSStream) SendHeader(metadata.MD) error

func (*MockXDSStream) SendMsg

func (*MockXDSStream) SendMsg(m interface{}) error

func (*MockXDSStream) SetHeader

func (*MockXDSStream) SetHeader(metadata.MD) error

func (*MockXDSStream) SetTrailer

func (*MockXDSStream) SetTrailer(metadata.MD)

type RouteDiscoveryResponseStream

type RouteDiscoveryResponseStream interface {
	SendRDS([]*cp.RouteConfiguration) error
}

type SubscriptionStream

type SubscriptionStream interface {
	Stream() error
}

SubscriptionStream is stream of stream of x discovery responses

func NewSubscriptionStream

func NewSubscriptionStream(stream cp.AggregatedDiscoveryService_StreamAggregatedResourcesServer, subscription *pubsub.Subscription, service eds.Endpoint, hub pubsub.Hub) SubscriptionStream