grpc

Documentation

Index

• type MockClientStream
  • func NewMockClientStream() *MockClientStream
  • func (stream *MockClientStream) CloseSend() error
  • func (stream *MockClientStream) Context() context.Context
  • func (stream *MockClientStream) Recv() (*envoy_sd.DiscoveryResponse, error)
  • func (stream *MockClientStream) Send(resp *envoy_sd.DiscoveryRequest) error
• type MockDeltaClientStream
  • func NewMockDeltaClientStream() *MockDeltaClientStream
  • func (stream *MockDeltaClientStream) CloseSend() error
  • func (stream *MockDeltaClientStream) Context() context.Context
  • func (stream *MockDeltaClientStream) Recv() (*envoy_sd.DeltaDiscoveryResponse, error)
  • func (stream *MockDeltaClientStream) Send(resp *envoy_sd.DeltaDiscoveryRequest) error
• type MockDeltaServerStream
  • func NewMockDeltaServerStream() *MockDeltaServerStream
  • func (stream *MockDeltaServerStream) ClientStream(stopCh chan struct{}) *MockDeltaClientStream
  • func (stream *MockDeltaServerStream) Context() context.Context
  • func (stream *MockDeltaServerStream) Recv() (*envoy_sd.DeltaDiscoveryRequest, error)
  • func (stream *MockDeltaServerStream) Send(resp *envoy_sd.DeltaDiscoveryResponse) error
• type MockServerStream
  • func NewMockServerStream() *MockServerStream
  • func (stream *MockServerStream) ClientStream(stopCh chan struct{}) *MockClientStream
  • func (stream *MockServerStream) Context() context.Context
  • func (stream *MockServerStream) Recv() (*envoy_sd.DiscoveryRequest, error)
  • func (stream *MockServerStream) Send(resp *envoy_sd.DiscoveryResponse) error

Types

type MockClientStream

type MockClientStream struct {
	Ctx    context.Context
	SentCh chan *envoy_sd.DiscoveryRequest
	RecvCh chan *envoy_sd.DiscoveryResponse
	grpc.ClientStream

	sync.RWMutex
	// contains filtered or unexported fields
}

func NewMockClientStream

func NewMockClientStream() *MockClientStream

func (*MockClientStream) CloseSend

func (stream *MockClientStream) CloseSend() error

func (*MockClientStream) Context

func (stream *MockClientStream) Context() context.Context

func (*MockClientStream) Recv

func (stream *MockClientStream) Recv() (*envoy_sd.DiscoveryResponse, error)

func (*MockClientStream) Send

func (stream *MockClientStream) Send(resp *envoy_sd.DiscoveryRequest) error

type MockDeltaClientStream

type MockDeltaClientStream struct {
	Ctx    context.Context
	SentCh chan *envoy_sd.DeltaDiscoveryRequest
	RecvCh chan *envoy_sd.DeltaDiscoveryResponse
	grpc.ClientStream

	sync.RWMutex
	// contains filtered or unexported fields
}

func NewMockDeltaClientStream

func NewMockDeltaClientStream() *MockDeltaClientStream

func (*MockDeltaClientStream) CloseSend

func (stream *MockDeltaClientStream) CloseSend() error

func (*MockDeltaClientStream) Context

func (stream *MockDeltaClientStream) Context() context.Context

func (*MockDeltaClientStream) Recv

func (stream *MockDeltaClientStream) Recv() (*envoy_sd.DeltaDiscoveryResponse, error)

func (*MockDeltaClientStream) Send

func (stream *MockDeltaClientStream) Send(resp *envoy_sd.DeltaDiscoveryRequest) error

type MockDeltaServerStream

type MockDeltaServerStream struct {
	Ctx    context.Context
	RecvCh chan *envoy_sd.DeltaDiscoveryRequest
	SentCh chan *envoy_sd.DeltaDiscoveryResponse
	Nonce  int
	grpc.ServerStream
}

func NewMockDeltaServerStream

func NewMockDeltaServerStream() *MockDeltaServerStream

func (*MockDeltaServerStream) ClientStream

func (stream *MockDeltaServerStream) ClientStream(stopCh chan struct{}) *MockDeltaClientStream

func (*MockDeltaServerStream) Context

func (stream *MockDeltaServerStream) Context() context.Context

func (*MockDeltaServerStream) Recv

func (stream *MockDeltaServerStream) Recv() (*envoy_sd.DeltaDiscoveryRequest, error)

func (*MockDeltaServerStream) Send

func (stream *MockDeltaServerStream) Send(resp *envoy_sd.DeltaDiscoveryResponse) error

type MockServerStream

type MockServerStream struct {
	Ctx    context.Context
	RecvCh chan *envoy_sd.DiscoveryRequest
	SentCh chan *envoy_sd.DiscoveryResponse
	Nonce  int
	grpc.ServerStream
}

func NewMockServerStream

func NewMockServerStream() *MockServerStream

func (*MockServerStream) ClientStream

func (stream *MockServerStream) ClientStream(stopCh chan struct{}) *MockClientStream

func (*MockServerStream) Context

func (stream *MockServerStream) Context() context.Context

func (*MockServerStream) Recv

func (stream *MockServerStream) Recv() (*envoy_sd.DiscoveryRequest, error)

func (*MockServerStream) Send

func (stream *MockServerStream) Send(resp *envoy_sd.DiscoveryResponse) error