grpc

package
v1.8.1 Latest Latest
Warning

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

 Go to latest Published: Oct 5, 2022 License: Apache-2.0 Imports: 5 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 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

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.
JackTT - Gopher 🇻🇳