Documentation
¶
Index ¶
- type MockClientStream
- type MockDeltaClientStream
- type 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
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 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
Source Files
Click to show internal directories.
Click to hide internal directories.