remote

package
v0.6.1 Latest Latest
Warning

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

 Go to latest Published: Jul 31, 2023 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

Package remote is a generated GoMock package.

Package remote is a generated GoMock package.

Package remote is a generated GoMock package.

Package remote is a generated GoMock package.

Package remote is a generated GoMock package.

Package remote is a generated GoMock package.

Package remote is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockBoundHandler 

type MockBoundHandler struct {
	// contains filtered or unexported fields
}

MockBoundHandler is a mock of BoundHandler interface.

func NewMockBoundHandler 

func NewMockBoundHandler(ctrl *gomock.Controller) *MockBoundHandler

NewMockBoundHandler creates a new mock instance.

func (*MockBoundHandler) EXPECT 

func (m *MockBoundHandler) EXPECT() *MockBoundHandlerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockBoundHandlerMockRecorder 

type MockBoundHandlerMockRecorder struct {
	// contains filtered or unexported fields
}

MockBoundHandlerMockRecorder is the mock recorder for MockBoundHandler.

type MockClientTransHandler 

type MockClientTransHandler struct {
	// contains filtered or unexported fields
}

MockClientTransHandler is a mock of ClientTransHandler interface.

func NewMockClientTransHandler 

func NewMockClientTransHandler(ctrl *gomock.Controller) *MockClientTransHandler

NewMockClientTransHandler creates a new mock instance.

func (*MockClientTransHandler) EXPECT 

func (m *MockClientTransHandler) EXPECT() *MockClientTransHandlerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockClientTransHandler) OnError 

func (m *MockClientTransHandler) OnError(ctx context.Context, err error, conn net.Conn)

OnError mocks base method.

func (*MockClientTransHandler) OnInactive 

func (m *MockClientTransHandler) OnInactive(ctx context.Context, conn net.Conn)

OnInactive mocks base method.

func (*MockClientTransHandler) OnMessage 

func (m *MockClientTransHandler) OnMessage(ctx context.Context, args, result remote.Message) (context.Context, error)

OnMessage mocks base method.

func (*MockClientTransHandler) Read 

func (m *MockClientTransHandler) Read(ctx context.Context, conn net.Conn, msg remote.Message) (context.Context, error)

Read mocks base method.

func (*MockClientTransHandler) SetPipeline 

func (m *MockClientTransHandler) SetPipeline(pipeline *remote.TransPipeline)

SetPipeline mocks base method.

func (*MockClientTransHandler) Write 

func (m *MockClientTransHandler) Write(ctx context.Context, conn net.Conn, send remote.Message) (context.Context, error)

Write mocks base method.

type MockClientTransHandlerFactory 

type MockClientTransHandlerFactory struct {
	// contains filtered or unexported fields
}

MockClientTransHandlerFactory is a mock of ClientTransHandlerFactory interface.

func NewMockClientTransHandlerFactory 

func NewMockClientTransHandlerFactory(ctrl *gomock.Controller) *MockClientTransHandlerFactory

NewMockClientTransHandlerFactory creates a new mock instance.

func (*MockClientTransHandlerFactory) EXPECT 

func (m *MockClientTransHandlerFactory) EXPECT() *MockClientTransHandlerFactoryMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockClientTransHandlerFactory) NewTransHandler 

func (m *MockClientTransHandlerFactory) NewTransHandler(opt *remote.ClientOption) (remote.ClientTransHandler, error)

NewTransHandler mocks base method.

type MockClientTransHandlerFactoryMockRecorder 

type MockClientTransHandlerFactoryMockRecorder struct {
	// contains filtered or unexported fields
}

MockClientTransHandlerFactoryMockRecorder is the mock recorder for MockClientTransHandlerFactory.

func (*MockClientTransHandlerFactoryMockRecorder) NewTransHandler 

func (mr *MockClientTransHandlerFactoryMockRecorder) NewTransHandler(opt interface{}) *gomock.Call

NewTransHandler indicates an expected call of NewTransHandler.

type MockClientTransHandlerMockRecorder 

type MockClientTransHandlerMockRecorder struct {
	// contains filtered or unexported fields
}

MockClientTransHandlerMockRecorder is the mock recorder for MockClientTransHandler.

func (*MockClientTransHandlerMockRecorder) OnError 

func (mr *MockClientTransHandlerMockRecorder) OnError(ctx, err, conn interface{}) *gomock.Call

OnError indicates an expected call of OnError.

func (*MockClientTransHandlerMockRecorder) OnInactive 

func (mr *MockClientTransHandlerMockRecorder) OnInactive(ctx, conn interface{}) *gomock.Call

OnInactive indicates an expected call of OnInactive.

func (*MockClientTransHandlerMockRecorder) OnMessage 

func (mr *MockClientTransHandlerMockRecorder) OnMessage(ctx, args, result interface{}) *gomock.Call

OnMessage indicates an expected call of OnMessage.

func (*MockClientTransHandlerMockRecorder) Read 

func (mr *MockClientTransHandlerMockRecorder) Read(ctx, conn, msg interface{}) *gomock.Call

Read indicates an expected call of Read.

func (*MockClientTransHandlerMockRecorder) SetPipeline 

func (mr *MockClientTransHandlerMockRecorder) SetPipeline(pipeline interface{}) *gomock.Call

SetPipeline indicates an expected call of SetPipeline.

func (*MockClientTransHandlerMockRecorder) Write 

func (mr *MockClientTransHandlerMockRecorder) Write(ctx, conn, send interface{}) *gomock.Call

Write indicates an expected call of Write.

type MockCodec 

type MockCodec struct {
	// contains filtered or unexported fields
}

MockCodec is a mock of Codec interface.

func NewMockCodec 

func NewMockCodec(ctrl *gomock.Controller) *MockCodec

NewMockCodec creates a new mock instance.

func (*MockCodec) Decode 

func (m *MockCodec) Decode(ctx context.Context, msg remote.Message, in remote.ByteBuffer) error

Decode mocks base method.

func (*MockCodec) EXPECT 

func (m *MockCodec) EXPECT() *MockCodecMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockCodec) Encode 

func (m *MockCodec) Encode(ctx context.Context, msg remote.Message, out remote.ByteBuffer) error

Encode mocks base method.

func (*MockCodec) Name 

func (m *MockCodec) Name() string

Name mocks base method.

type MockCodecMockRecorder 

type MockCodecMockRecorder struct {
	// contains filtered or unexported fields
}

MockCodecMockRecorder is the mock recorder for MockCodec.

func (*MockCodecMockRecorder) Decode 

func (mr *MockCodecMockRecorder) Decode(ctx, msg, in interface{}) *gomock.Call

Decode indicates an expected call of Decode.

func (*MockCodecMockRecorder) Encode 

func (mr *MockCodecMockRecorder) Encode(ctx, msg, out interface{}) *gomock.Call

Encode indicates an expected call of Encode.

func (*MockCodecMockRecorder) Name 

func (mr *MockCodecMockRecorder) Name() *gomock.Call

Name indicates an expected call of Name.

type MockConnPool 

type MockConnPool struct {
	// contains filtered or unexported fields
}

MockConnPool is a mock of ConnPool interface.

func NewMockConnPool 

func NewMockConnPool(ctrl *gomock.Controller) *MockConnPool

NewMockConnPool creates a new mock instance.

func (*MockConnPool) Close 

func (m *MockConnPool) Close() error

Close mocks base method.

func (*MockConnPool) Discard 

func (m *MockConnPool) Discard(conn net.Conn) error

Discard mocks base method.

func (*MockConnPool) EXPECT 

func (m *MockConnPool) EXPECT() *MockConnPoolMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockConnPool) Get 

func (m *MockConnPool) Get(ctx context.Context, network, address string, opt remote.ConnOption) (net.Conn, error)

Get mocks base method.

func (*MockConnPool) Put 

func (m *MockConnPool) Put(conn net.Conn) error

Put mocks base method.

type MockConnPoolMockRecorder 

type MockConnPoolMockRecorder struct {
	// contains filtered or unexported fields
}

MockConnPoolMockRecorder is the mock recorder for MockConnPool.

func (*MockConnPoolMockRecorder) Close 

func (mr *MockConnPoolMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockConnPoolMockRecorder) Discard 

func (mr *MockConnPoolMockRecorder) Discard(conn interface{}) *gomock.Call

Discard indicates an expected call of Discard.

func (*MockConnPoolMockRecorder) Get 

func (mr *MockConnPoolMockRecorder) Get(ctx, network, address, opt interface{}) *gomock.Call

Get indicates an expected call of Get.

func (*MockConnPoolMockRecorder) Put 

func (mr *MockConnPoolMockRecorder) Put(conn interface{}) *gomock.Call

Put indicates an expected call of Put.

type MockConnPoolReporter 

type MockConnPoolReporter struct {
	// contains filtered or unexported fields
}

MockConnPoolReporter is a mock of ConnPoolReporter interface.

func NewMockConnPoolReporter 

func NewMockConnPoolReporter(ctrl *gomock.Controller) *MockConnPoolReporter

NewMockConnPoolReporter creates a new mock instance.

func (*MockConnPoolReporter) EXPECT 

func (m *MockConnPoolReporter) EXPECT() *MockConnPoolReporterMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockConnPoolReporter) EnableReporter 

func (m *MockConnPoolReporter) EnableReporter()

EnableReporter mocks base method.

type MockConnPoolReporterMockRecorder 

type MockConnPoolReporterMockRecorder struct {
	// contains filtered or unexported fields
}

MockConnPoolReporterMockRecorder is the mock recorder for MockConnPoolReporter.

func (*MockConnPoolReporterMockRecorder) EnableReporter 

func (mr *MockConnPoolReporterMockRecorder) EnableReporter() *gomock.Call

EnableReporter indicates an expected call of EnableReporter.

type MockDialer 

type MockDialer struct {
	// contains filtered or unexported fields
}

MockDialer is a mock of Dialer interface.

func NewMockDialer 

func NewMockDialer(ctrl *gomock.Controller) *MockDialer

NewMockDialer creates a new mock instance.

func (*MockDialer) DialTimeout 

func (m *MockDialer) DialTimeout(network, address string, timeout time.Duration) (net.Conn, error)

DialTimeout mocks base method.

func (*MockDialer) EXPECT 

func (m *MockDialer) EXPECT() *MockDialerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockDialerMockRecorder 

type MockDialerMockRecorder struct {
	// contains filtered or unexported fields
}

MockDialerMockRecorder is the mock recorder for MockDialer.

func (*MockDialerMockRecorder) DialTimeout 

func (mr *MockDialerMockRecorder) DialTimeout(network, address, timeout interface{}) *gomock.Call

DialTimeout indicates an expected call of DialTimeout.

type MockDuplexBoundHandler 

type MockDuplexBoundHandler struct {
	// contains filtered or unexported fields
}

MockDuplexBoundHandler is a mock of DuplexBoundHandler interface.

func NewMockDuplexBoundHandler 

func NewMockDuplexBoundHandler(ctrl *gomock.Controller) *MockDuplexBoundHandler

NewMockDuplexBoundHandler creates a new mock instance.

func (*MockDuplexBoundHandler) EXPECT 

func (m *MockDuplexBoundHandler) EXPECT() *MockDuplexBoundHandlerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockDuplexBoundHandler) OnActive 

func (m *MockDuplexBoundHandler) OnActive(ctx context.Context, conn net.Conn) (context.Context, error)

OnActive mocks base method.

func (*MockDuplexBoundHandler) OnInactive 

func (m *MockDuplexBoundHandler) OnInactive(ctx context.Context, conn net.Conn) context.Context

OnInactive mocks base method.

func (*MockDuplexBoundHandler) OnMessage 

func (m *MockDuplexBoundHandler) OnMessage(ctx context.Context, args, result remote.Message) (context.Context, error)

OnMessage mocks base method.

func (*MockDuplexBoundHandler) OnRead 

func (m *MockDuplexBoundHandler) OnRead(ctx context.Context, conn net.Conn) (context.Context, error)

OnRead mocks base method.

func (*MockDuplexBoundHandler) Write 

func (m *MockDuplexBoundHandler) Write(ctx context.Context, conn net.Conn, send remote.Message) (context.Context, error)

Write mocks base method.

type MockDuplexBoundHandlerMockRecorder 

type MockDuplexBoundHandlerMockRecorder struct {
	// contains filtered or unexported fields
}

MockDuplexBoundHandlerMockRecorder is the mock recorder for MockDuplexBoundHandler.

func (*MockDuplexBoundHandlerMockRecorder) OnActive 

func (mr *MockDuplexBoundHandlerMockRecorder) OnActive(ctx, conn interface{}) *gomock.Call

OnActive indicates an expected call of OnActive.

func (*MockDuplexBoundHandlerMockRecorder) OnInactive 

func (mr *MockDuplexBoundHandlerMockRecorder) OnInactive(ctx, conn interface{}) *gomock.Call

OnInactive indicates an expected call of OnInactive.

func (*MockDuplexBoundHandlerMockRecorder) OnMessage 

func (mr *MockDuplexBoundHandlerMockRecorder) OnMessage(ctx, args, result interface{}) *gomock.Call

OnMessage indicates an expected call of OnMessage.

func (*MockDuplexBoundHandlerMockRecorder) OnRead 

func (mr *MockDuplexBoundHandlerMockRecorder) OnRead(ctx, conn interface{}) *gomock.Call

OnRead indicates an expected call of OnRead.

func (*MockDuplexBoundHandlerMockRecorder) Write 

func (mr *MockDuplexBoundHandlerMockRecorder) Write(ctx, conn, send interface{}) *gomock.Call

Write indicates an expected call of Write.

type MockGracefulShutdown 

type MockGracefulShutdown struct {
	// contains filtered or unexported fields
}

MockGracefulShutdown is a mock of GracefulShutdown interface.

func NewMockGracefulShutdown 

func NewMockGracefulShutdown(ctrl *gomock.Controller) *MockGracefulShutdown

NewMockGracefulShutdown creates a new mock instance.

func (*MockGracefulShutdown) EXPECT 

func (m *MockGracefulShutdown) EXPECT() *MockGracefulShutdownMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockGracefulShutdown) GracefulShutdown 

func (m *MockGracefulShutdown) GracefulShutdown(ctx context.Context) error

GracefulShutdown mocks base method.

type MockGracefulShutdownMockRecorder 

type MockGracefulShutdownMockRecorder struct {
	// contains filtered or unexported fields
}

MockGracefulShutdownMockRecorder is the mock recorder for MockGracefulShutdown.

func (*MockGracefulShutdownMockRecorder) GracefulShutdown 

func (mr *MockGracefulShutdownMockRecorder) GracefulShutdown(ctx interface{}) *gomock.Call

GracefulShutdown indicates an expected call of GracefulShutdown.

type MockInboundHandler 

type MockInboundHandler struct {
	// contains filtered or unexported fields
}

MockInboundHandler is a mock of InboundHandler interface.

func NewMockInboundHandler 

func NewMockInboundHandler(ctrl *gomock.Controller) *MockInboundHandler

NewMockInboundHandler creates a new mock instance.

func (*MockInboundHandler) EXPECT 

func (m *MockInboundHandler) EXPECT() *MockInboundHandlerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockInboundHandler) OnActive 

func (m *MockInboundHandler) OnActive(ctx context.Context, conn net.Conn) (context.Context, error)

OnActive mocks base method.

func (*MockInboundHandler) OnInactive 

func (m *MockInboundHandler) OnInactive(ctx context.Context, conn net.Conn) context.Context

OnInactive mocks base method.

func (*MockInboundHandler) OnMessage 

func (m *MockInboundHandler) OnMessage(ctx context.Context, args, result remote.Message) (context.Context, error)

OnMessage mocks base method.

func (*MockInboundHandler) OnRead 

func (m *MockInboundHandler) OnRead(ctx context.Context, conn net.Conn) (context.Context, error)

OnRead mocks base method.

type MockInboundHandlerMockRecorder 

type MockInboundHandlerMockRecorder struct {
	// contains filtered or unexported fields
}

MockInboundHandlerMockRecorder is the mock recorder for MockInboundHandler.

func (*MockInboundHandlerMockRecorder) OnActive 

func (mr *MockInboundHandlerMockRecorder) OnActive(ctx, conn interface{}) *gomock.Call

OnActive indicates an expected call of OnActive.

func (*MockInboundHandlerMockRecorder) OnInactive 

func (mr *MockInboundHandlerMockRecorder) OnInactive(ctx, conn interface{}) *gomock.Call

OnInactive indicates an expected call of OnInactive.

func (*MockInboundHandlerMockRecorder) OnMessage 

func (mr *MockInboundHandlerMockRecorder) OnMessage(ctx, args, result interface{}) *gomock.Call

OnMessage indicates an expected call of OnMessage.

func (*MockInboundHandlerMockRecorder) OnRead 

func (mr *MockInboundHandlerMockRecorder) OnRead(ctx, conn interface{}) *gomock.Call

OnRead indicates an expected call of OnRead.

type MockInvokeHandleFuncSetter 

type MockInvokeHandleFuncSetter struct {
	// contains filtered or unexported fields
}

MockInvokeHandleFuncSetter is a mock of InvokeHandleFuncSetter interface.

func NewMockInvokeHandleFuncSetter 

func NewMockInvokeHandleFuncSetter(ctrl *gomock.Controller) *MockInvokeHandleFuncSetter

NewMockInvokeHandleFuncSetter creates a new mock instance.

func (*MockInvokeHandleFuncSetter) EXPECT 

func (m *MockInvokeHandleFuncSetter) EXPECT() *MockInvokeHandleFuncSetterMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockInvokeHandleFuncSetter) SetInvokeHandleFunc 

func (m *MockInvokeHandleFuncSetter) SetInvokeHandleFunc(inkHdlFunc endpoint.Endpoint)

SetInvokeHandleFunc mocks base method.

type MockInvokeHandleFuncSetterMockRecorder 

type MockInvokeHandleFuncSetterMockRecorder struct {
	// contains filtered or unexported fields
}

MockInvokeHandleFuncSetterMockRecorder is the mock recorder for MockInvokeHandleFuncSetter.

func (*MockInvokeHandleFuncSetterMockRecorder) SetInvokeHandleFunc 

func (mr *MockInvokeHandleFuncSetterMockRecorder) SetInvokeHandleFunc(inkHdlFunc interface{}) *gomock.Call

SetInvokeHandleFunc indicates an expected call of SetInvokeHandleFunc.

type MockIsActive 

type MockIsActive struct {
	// contains filtered or unexported fields
}

MockIsActive is a mock of IsActive interface.

func NewMockIsActive 

func NewMockIsActive(ctrl *gomock.Controller) *MockIsActive

NewMockIsActive creates a new mock instance.

func (*MockIsActive) EXPECT 

func (m *MockIsActive) EXPECT() *MockIsActiveMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockIsActive) IsActive 

func (m *MockIsActive) IsActive() bool

IsActive mocks base method.

type MockIsActiveMockRecorder 

type MockIsActiveMockRecorder struct {
	// contains filtered or unexported fields
}

MockIsActiveMockRecorder is the mock recorder for MockIsActive.

func (*MockIsActiveMockRecorder) IsActive 

func (mr *MockIsActiveMockRecorder) IsActive() *gomock.Call

IsActive indicates an expected call of IsActive.

type MockLongConnPool 

type MockLongConnPool struct {
	// contains filtered or unexported fields
}

MockLongConnPool is a mock of LongConnPool interface.

func NewMockLongConnPool 

func NewMockLongConnPool(ctrl *gomock.Controller) *MockLongConnPool

NewMockLongConnPool creates a new mock instance.

func (*MockLongConnPool) Clean 

func (m *MockLongConnPool) Clean(network, address string)

Clean mocks base method.

func (*MockLongConnPool) Close 

func (m *MockLongConnPool) Close() error

Close mocks base method.

func (*MockLongConnPool) Discard 

func (m *MockLongConnPool) Discard(conn net.Conn) error

Discard mocks base method.

func (*MockLongConnPool) EXPECT 

func (m *MockLongConnPool) EXPECT() *MockLongConnPoolMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockLongConnPool) Get 

func (m *MockLongConnPool) Get(ctx context.Context, network, address string, opt remote.ConnOption) (net.Conn, error)

Get mocks base method.

func (*MockLongConnPool) Put 

func (m *MockLongConnPool) Put(conn net.Conn) error

Put mocks base method.

type MockLongConnPoolMockRecorder 

type MockLongConnPoolMockRecorder struct {
	// contains filtered or unexported fields
}

MockLongConnPoolMockRecorder is the mock recorder for MockLongConnPool.

func (*MockLongConnPoolMockRecorder) Clean 

func (mr *MockLongConnPoolMockRecorder) Clean(network, address interface{}) *gomock.Call

Clean indicates an expected call of Clean.

func (*MockLongConnPoolMockRecorder) Close 

func (mr *MockLongConnPoolMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockLongConnPoolMockRecorder) Discard 

func (mr *MockLongConnPoolMockRecorder) Discard(conn interface{}) *gomock.Call

Discard indicates an expected call of Discard.

func (*MockLongConnPoolMockRecorder) Get 

func (mr *MockLongConnPoolMockRecorder) Get(ctx, network, address, opt interface{}) *gomock.Call

Get indicates an expected call of Get.

func (*MockLongConnPoolMockRecorder) Put 

func (mr *MockLongConnPoolMockRecorder) Put(conn interface{}) *gomock.Call

Put indicates an expected call of Put.

type MockMetaDecoder 

type MockMetaDecoder struct {
	// contains filtered or unexported fields
}

MockMetaDecoder is a mock of MetaDecoder interface.

func NewMockMetaDecoder 

func NewMockMetaDecoder(ctrl *gomock.Controller) *MockMetaDecoder

NewMockMetaDecoder creates a new mock instance.

func (*MockMetaDecoder) DecodeMeta 

func (m *MockMetaDecoder) DecodeMeta(ctx context.Context, msg remote.Message, in remote.ByteBuffer) error

DecodeMeta mocks base method.

func (*MockMetaDecoder) DecodePayload 

func (m *MockMetaDecoder) DecodePayload(ctx context.Context, msg remote.Message, in remote.ByteBuffer) error

DecodePayload mocks base method.

func (*MockMetaDecoder) EXPECT 

func (m *MockMetaDecoder) EXPECT() *MockMetaDecoderMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockMetaDecoderMockRecorder 

type MockMetaDecoderMockRecorder struct {
	// contains filtered or unexported fields
}

MockMetaDecoderMockRecorder is the mock recorder for MockMetaDecoder.

func (*MockMetaDecoderMockRecorder) DecodeMeta 

func (mr *MockMetaDecoderMockRecorder) DecodeMeta(ctx, msg, in interface{}) *gomock.Call

DecodeMeta indicates an expected call of DecodeMeta.

func (*MockMetaDecoderMockRecorder) DecodePayload 

func (mr *MockMetaDecoderMockRecorder) DecodePayload(ctx, msg, in interface{}) *gomock.Call

DecodePayload indicates an expected call of DecodePayload.

type MockMetaHandler 

type MockMetaHandler struct {
	// contains filtered or unexported fields
}

MockMetaHandler is a mock of MetaHandler interface.

func NewMockMetaHandler 

func NewMockMetaHandler(ctrl *gomock.Controller) *MockMetaHandler

NewMockMetaHandler creates a new mock instance.

func (*MockMetaHandler) EXPECT 

func (m *MockMetaHandler) EXPECT() *MockMetaHandlerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockMetaHandler) ReadMeta 

func (m *MockMetaHandler) ReadMeta(ctx context.Context, msg remote.Message) (context.Context, error)

ReadMeta mocks base method.

func (*MockMetaHandler) WriteMeta 

func (m *MockMetaHandler) WriteMeta(ctx context.Context, msg remote.Message) (context.Context, error)

WriteMeta mocks base method.

type MockMetaHandlerMockRecorder 

type MockMetaHandlerMockRecorder struct {
	// contains filtered or unexported fields
}

MockMetaHandlerMockRecorder is the mock recorder for MockMetaHandler.

func (*MockMetaHandlerMockRecorder) ReadMeta 

func (mr *MockMetaHandlerMockRecorder) ReadMeta(ctx, msg interface{}) *gomock.Call

ReadMeta indicates an expected call of ReadMeta.

func (*MockMetaHandlerMockRecorder) WriteMeta 

func (mr *MockMetaHandlerMockRecorder) WriteMeta(ctx, msg interface{}) *gomock.Call

WriteMeta indicates an expected call of WriteMeta.

type MockOutboundHandler 

type MockOutboundHandler struct {
	// contains filtered or unexported fields
}

MockOutboundHandler is a mock of OutboundHandler interface.

func NewMockOutboundHandler 

func NewMockOutboundHandler(ctrl *gomock.Controller) *MockOutboundHandler

NewMockOutboundHandler creates a new mock instance.

func (*MockOutboundHandler) EXPECT 

func (m *MockOutboundHandler) EXPECT() *MockOutboundHandlerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockOutboundHandler) Write 

func (m *MockOutboundHandler) Write(ctx context.Context, conn net.Conn, send remote.Message) (context.Context, error)

Write mocks base method.

type MockOutboundHandlerMockRecorder 

type MockOutboundHandlerMockRecorder struct {
	// contains filtered or unexported fields
}

MockOutboundHandlerMockRecorder is the mock recorder for MockOutboundHandler.

func (*MockOutboundHandlerMockRecorder) Write 

func (mr *MockOutboundHandlerMockRecorder) Write(ctx, conn, send interface{}) *gomock.Call

Write indicates an expected call of Write.

type MockPayloadCodec 

type MockPayloadCodec struct {
	// contains filtered or unexported fields
}

MockPayloadCodec is a mock of PayloadCodec interface.

func NewMockPayloadCodec 

func NewMockPayloadCodec(ctrl *gomock.Controller) *MockPayloadCodec

NewMockPayloadCodec creates a new mock instance.

func (*MockPayloadCodec) EXPECT 

func (m *MockPayloadCodec) EXPECT() *MockPayloadCodecMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockPayloadCodec) Marshal 

func (m *MockPayloadCodec) Marshal(ctx context.Context, message remote.Message, out remote.ByteBuffer) error

Marshal mocks base method.

func (*MockPayloadCodec) Name 

func (m *MockPayloadCodec) Name() string

Name mocks base method.

func (*MockPayloadCodec) Unmarshal 

func (m *MockPayloadCodec) Unmarshal(ctx context.Context, message remote.Message, in remote.ByteBuffer) error

Unmarshal mocks base method.

type MockPayloadCodecMockRecorder 

type MockPayloadCodecMockRecorder struct {
	// contains filtered or unexported fields
}

MockPayloadCodecMockRecorder is the mock recorder for MockPayloadCodec.

func (*MockPayloadCodecMockRecorder) Marshal 

func (mr *MockPayloadCodecMockRecorder) Marshal(ctx, message, out interface{}) *gomock.Call

Marshal indicates an expected call of Marshal.

func (*MockPayloadCodecMockRecorder) Name 

func (mr *MockPayloadCodecMockRecorder) Name() *gomock.Call

Name indicates an expected call of Name.

func (*MockPayloadCodecMockRecorder) Unmarshal 

func (mr *MockPayloadCodecMockRecorder) Unmarshal(ctx, message, in interface{}) *gomock.Call

Unmarshal indicates an expected call of Unmarshal.

type MockRawConn 

type MockRawConn struct {
	// contains filtered or unexported fields
}

MockRawConn is a mock of RawConn interface.

func NewMockRawConn 

func NewMockRawConn(ctrl *gomock.Controller) *MockRawConn

NewMockRawConn creates a new mock instance.

func (*MockRawConn) EXPECT 

func (m *MockRawConn) EXPECT() *MockRawConnMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockRawConn) RawConn 

func (m *MockRawConn) RawConn() net.Conn

RawConn mocks base method.

type MockRawConnMockRecorder 

type MockRawConnMockRecorder struct {
	// contains filtered or unexported fields
}

MockRawConnMockRecorder is the mock recorder for MockRawConn.

func (*MockRawConnMockRecorder) RawConn 

func (mr *MockRawConnMockRecorder) RawConn() *gomock.Call

RawConn indicates an expected call of RawConn.

type MockServerTransHandler 

type MockServerTransHandler struct {
	// contains filtered or unexported fields
}

MockServerTransHandler is a mock of ServerTransHandler interface.

func NewMockServerTransHandler 

func NewMockServerTransHandler(ctrl *gomock.Controller) *MockServerTransHandler

NewMockServerTransHandler creates a new mock instance.

func (*MockServerTransHandler) EXPECT 

func (m *MockServerTransHandler) EXPECT() *MockServerTransHandlerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockServerTransHandler) OnActive 

func (m *MockServerTransHandler) OnActive(ctx context.Context, conn net.Conn) (context.Context, error)

OnActive mocks base method.

func (*MockServerTransHandler) OnError 

func (m *MockServerTransHandler) OnError(ctx context.Context, err error, conn net.Conn)

OnError mocks base method.

func (*MockServerTransHandler) OnInactive 

func (m *MockServerTransHandler) OnInactive(ctx context.Context, conn net.Conn)

OnInactive mocks base method.

func (*MockServerTransHandler) OnMessage 

func (m *MockServerTransHandler) OnMessage(ctx context.Context, args, result remote.Message) (context.Context, error)

OnMessage mocks base method.

func (*MockServerTransHandler) OnRead 

func (m *MockServerTransHandler) OnRead(ctx context.Context, conn net.Conn) error

OnRead mocks base method.

func (*MockServerTransHandler) Read 

func (m *MockServerTransHandler) Read(ctx context.Context, conn net.Conn, msg remote.Message) (context.Context, error)

Read mocks base method.

func (*MockServerTransHandler) SetPipeline 

func (m *MockServerTransHandler) SetPipeline(pipeline *remote.TransPipeline)

SetPipeline mocks base method.

func (*MockServerTransHandler) Write 

func (m *MockServerTransHandler) Write(ctx context.Context, conn net.Conn, send remote.Message) (context.Context, error)

Write mocks base method.

type MockServerTransHandlerFactory 

type MockServerTransHandlerFactory struct {
	// contains filtered or unexported fields
}

MockServerTransHandlerFactory is a mock of ServerTransHandlerFactory interface.

func NewMockServerTransHandlerFactory 

func NewMockServerTransHandlerFactory(ctrl *gomock.Controller) *MockServerTransHandlerFactory

NewMockServerTransHandlerFactory creates a new mock instance.

func (*MockServerTransHandlerFactory) EXPECT 

func (m *MockServerTransHandlerFactory) EXPECT() *MockServerTransHandlerFactoryMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockServerTransHandlerFactory) NewTransHandler 

func (m *MockServerTransHandlerFactory) NewTransHandler(opt *remote.ServerOption) (remote.ServerTransHandler, error)

NewTransHandler mocks base method.

type MockServerTransHandlerFactoryMockRecorder 

type MockServerTransHandlerFactoryMockRecorder struct {
	// contains filtered or unexported fields
}

MockServerTransHandlerFactoryMockRecorder is the mock recorder for MockServerTransHandlerFactory.

func (*MockServerTransHandlerFactoryMockRecorder) NewTransHandler 

func (mr *MockServerTransHandlerFactoryMockRecorder) NewTransHandler(opt interface{}) *gomock.Call

NewTransHandler indicates an expected call of NewTransHandler.

type MockServerTransHandlerMockRecorder 

type MockServerTransHandlerMockRecorder struct {
	// contains filtered or unexported fields
}

MockServerTransHandlerMockRecorder is the mock recorder for MockServerTransHandler.

func (*MockServerTransHandlerMockRecorder) OnActive 

func (mr *MockServerTransHandlerMockRecorder) OnActive(ctx, conn interface{}) *gomock.Call

OnActive indicates an expected call of OnActive.

func (*MockServerTransHandlerMockRecorder) OnError 

func (mr *MockServerTransHandlerMockRecorder) OnError(ctx, err, conn interface{}) *gomock.Call

OnError indicates an expected call of OnError.

func (*MockServerTransHandlerMockRecorder) OnInactive 

func (mr *MockServerTransHandlerMockRecorder) OnInactive(ctx, conn interface{}) *gomock.Call

OnInactive indicates an expected call of OnInactive.

func (*MockServerTransHandlerMockRecorder) OnMessage 

func (mr *MockServerTransHandlerMockRecorder) OnMessage(ctx, args, result interface{}) *gomock.Call

OnMessage indicates an expected call of OnMessage.

func (*MockServerTransHandlerMockRecorder) OnRead 

func (mr *MockServerTransHandlerMockRecorder) OnRead(ctx, conn interface{}) *gomock.Call

OnRead indicates an expected call of OnRead.

func (*MockServerTransHandlerMockRecorder) Read 

func (mr *MockServerTransHandlerMockRecorder) Read(ctx, conn, msg interface{}) *gomock.Call

Read indicates an expected call of Read.

func (*MockServerTransHandlerMockRecorder) SetPipeline 

func (mr *MockServerTransHandlerMockRecorder) SetPipeline(pipeline interface{}) *gomock.Call

SetPipeline indicates an expected call of SetPipeline.

func (*MockServerTransHandlerMockRecorder) Write 

func (mr *MockServerTransHandlerMockRecorder) Write(ctx, conn, send interface{}) *gomock.Call

Write indicates an expected call of Write.

type MockStreamingMetaHandler 

type MockStreamingMetaHandler struct {
	// contains filtered or unexported fields
}

MockStreamingMetaHandler is a mock of StreamingMetaHandler interface.

func NewMockStreamingMetaHandler 

func NewMockStreamingMetaHandler(ctrl *gomock.Controller) *MockStreamingMetaHandler

NewMockStreamingMetaHandler creates a new mock instance.

func (*MockStreamingMetaHandler) EXPECT 

func (m *MockStreamingMetaHandler) EXPECT() *MockStreamingMetaHandlerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockStreamingMetaHandler) OnConnectStream 

func (m *MockStreamingMetaHandler) OnConnectStream(ctx context.Context) (context.Context, error)

OnConnectStream mocks base method.

func (*MockStreamingMetaHandler) OnReadStream 

func (m *MockStreamingMetaHandler) OnReadStream(ctx context.Context) (context.Context, error)

OnReadStream mocks base method.

type MockStreamingMetaHandlerMockRecorder 

type MockStreamingMetaHandlerMockRecorder struct {
	// contains filtered or unexported fields
}

MockStreamingMetaHandlerMockRecorder is the mock recorder for MockStreamingMetaHandler.

func (*MockStreamingMetaHandlerMockRecorder) OnConnectStream 

func (mr *MockStreamingMetaHandlerMockRecorder) OnConnectStream(ctx interface{}) *gomock.Call

OnConnectStream indicates an expected call of OnConnectStream.

func (*MockStreamingMetaHandlerMockRecorder) OnReadStream 

func (mr *MockStreamingMetaHandlerMockRecorder) OnReadStream(ctx interface{}) *gomock.Call

OnReadStream indicates an expected call of OnReadStream.

type MockTransHandler 

type MockTransHandler struct {
	// contains filtered or unexported fields
}

MockTransHandler is a mock of TransHandler interface.

func NewMockTransHandler 

func NewMockTransHandler(ctrl *gomock.Controller) *MockTransHandler

NewMockTransHandler creates a new mock instance.

func (*MockTransHandler) EXPECT 

func (m *MockTransHandler) EXPECT() *MockTransHandlerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockTransHandler) OnError 

func (m *MockTransHandler) OnError(ctx context.Context, err error, conn net.Conn)

OnError mocks base method.

func (*MockTransHandler) OnInactive 

func (m *MockTransHandler) OnInactive(ctx context.Context, conn net.Conn)

OnInactive mocks base method.

func (*MockTransHandler) OnMessage 

func (m *MockTransHandler) OnMessage(ctx context.Context, args, result remote.Message) (context.Context, error)

OnMessage mocks base method.

func (*MockTransHandler) Read 

func (m *MockTransHandler) Read(ctx context.Context, conn net.Conn, msg remote.Message) (context.Context, error)

Read mocks base method.

func (*MockTransHandler) SetPipeline 

func (m *MockTransHandler) SetPipeline(pipeline *remote.TransPipeline)

SetPipeline mocks base method.

func (*MockTransHandler) Write 

func (m *MockTransHandler) Write(ctx context.Context, conn net.Conn, send remote.Message) (context.Context, error)

Write mocks base method.

type MockTransHandlerMockRecorder 

type MockTransHandlerMockRecorder struct {
	// contains filtered or unexported fields
}

MockTransHandlerMockRecorder is the mock recorder for MockTransHandler.

func (*MockTransHandlerMockRecorder) OnError 

func (mr *MockTransHandlerMockRecorder) OnError(ctx, err, conn interface{}) *gomock.Call

OnError indicates an expected call of OnError.

func (*MockTransHandlerMockRecorder) OnInactive 

func (mr *MockTransHandlerMockRecorder) OnInactive(ctx, conn interface{}) *gomock.Call

OnInactive indicates an expected call of OnInactive.

func (*MockTransHandlerMockRecorder) OnMessage 

func (mr *MockTransHandlerMockRecorder) OnMessage(ctx, args, result interface{}) *gomock.Call

OnMessage indicates an expected call of OnMessage.

func (*MockTransHandlerMockRecorder) Read 

func (mr *MockTransHandlerMockRecorder) Read(ctx, conn, msg interface{}) *gomock.Call

Read indicates an expected call of Read.

func (*MockTransHandlerMockRecorder) SetPipeline 

func (mr *MockTransHandlerMockRecorder) SetPipeline(pipeline interface{}) *gomock.Call

SetPipeline indicates an expected call of SetPipeline.

func (*MockTransHandlerMockRecorder) Write 

func (mr *MockTransHandlerMockRecorder) Write(ctx, conn, send interface{}) *gomock.Call

Write indicates an expected call of Write.

type MockTransReadWriter 

type MockTransReadWriter struct {
	// contains filtered or unexported fields
}

MockTransReadWriter is a mock of TransReadWriter interface.

func NewMockTransReadWriter 

func NewMockTransReadWriter(ctrl *gomock.Controller) *MockTransReadWriter

NewMockTransReadWriter creates a new mock instance.

func (*MockTransReadWriter) EXPECT 

func (m *MockTransReadWriter) EXPECT() *MockTransReadWriterMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockTransReadWriter) Read 

func (m *MockTransReadWriter) Read(ctx context.Context, conn net.Conn, msg remote.Message) (context.Context, error)

Read mocks base method.

func (*MockTransReadWriter) Write 

func (m *MockTransReadWriter) Write(ctx context.Context, conn net.Conn, send remote.Message) (context.Context, error)

Write mocks base method.

type MockTransReadWriterMockRecorder 

type MockTransReadWriterMockRecorder struct {
	// contains filtered or unexported fields
}

MockTransReadWriterMockRecorder is the mock recorder for MockTransReadWriter.

func (*MockTransReadWriterMockRecorder) Read 

func (mr *MockTransReadWriterMockRecorder) Read(ctx, conn, msg interface{}) *gomock.Call

Read indicates an expected call of Read.

func (*MockTransReadWriterMockRecorder) Write 

func (mr *MockTransReadWriterMockRecorder) Write(ctx, conn, send interface{}) *gomock.Call

Write indicates an expected call of Write.

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.