Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 MakeMockClientStream ¶
func MakeMockClientStream() *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 MockServerStream ¶
type MockServerStream struct {
Ctx context.Context
RecvCh chan *envoy_sd.DiscoveryRequest
SentCh chan *envoy_sd.DiscoveryResponse
Nonce int
grpc.ServerStream
}
func MakeMockStream ¶
func MakeMockStream() *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
Source Files
Click to show internal directories.
Click to hide internal directories.