grpc

package
v0.0.0-...-b6b2d9b Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 14, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

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 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 (*MockDeltaClientStream) Send

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 (*MockDeltaServerStream) Send

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL