remote

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Mar 8, 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 added in v0.4.3 

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

MockBoundHandler is a mock of BoundHandler interface.

func NewMockBoundHandler added in v0.4.3 

func NewMockBoundHandler(ctrl *gomock.Controller) *MockBoundHandler

NewMockBoundHandler creates a new mock instance.

func (*MockBoundHandler) EXPECT added in v0.4.3 

func (m *MockBoundHandler) EXPECT() *MockBoundHandlerMockRecorder

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

type MockBoundHandlerMockRecorder added in v0.4.3 

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

MockBoundHandlerMockRecorder is the mock recorder for MockBoundHandler.

type MockClientTransHandler added in v0.4.3 

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

MockClientTransHandler is a mock of ClientTransHandler interface.

func NewMockClientTransHandler added in v0.4.3 

func NewMockClientTransHandler(ctrl *gomock.Controller) *MockClientTransHandler

NewMockClientTransHandler creates a new mock instance.

func (*MockClientTransHandler) EXPECT added in v0.4.3 

func (m *MockClientTransHandler) EXPECT() *MockClientTransHandlerMockRecorder

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

func (*MockClientTransHandler) OnError added in v0.4.3 

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

OnError mocks base method.

func (*MockClientTransHandler) OnInactive added in v0.4.3 

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

OnInactive mocks base method.

func (*MockClientTransHandler) OnMessage added in v0.4.3 

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

OnMessage mocks base method.

func (*MockClientTransHandler) Read added in v0.4.3 

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

Read mocks base method.

func (*MockClientTransHandler) SetPipeline added in v0.4.3 

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

SetPipeline mocks base method.

func (*MockClientTransHandler) Write added in v0.4.3 

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

Write mocks base method.

type MockClientTransHandlerFactory added in v0.4.3 

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

MockClientTransHandlerFactory is a mock of ClientTransHandlerFactory interface.

func NewMockClientTransHandlerFactory added in v0.4.3 

func NewMockClientTransHandlerFactory(ctrl *gomock.Controller) *MockClientTransHandlerFactory

NewMockClientTransHandlerFactory creates a new mock instance.

func (*MockClientTransHandlerFactory) EXPECT added in v0.4.3 

func (m *MockClientTransHandlerFactory) EXPECT() *MockClientTransHandlerFactoryMockRecorder

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

func (*MockClientTransHandlerFactory) NewTransHandler added in v0.4.3 

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

NewTransHandler mocks base method.

type MockClientTransHandlerFactoryMockRecorder added in v0.4.3 

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

MockClientTransHandlerFactoryMockRecorder is the mock recorder for MockClientTransHandlerFactory.

func (*MockClientTransHandlerFactoryMockRecorder) NewTransHandler added in v0.4.3 

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

NewTransHandler indicates an expected call of NewTransHandler.

type MockClientTransHandlerMockRecorder added in v0.4.3 

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

MockClientTransHandlerMockRecorder is the mock recorder for MockClientTransHandler.

func (*MockClientTransHandlerMockRecorder) OnError added in v0.4.3 

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

OnError indicates an expected call of OnError.

func (*MockClientTransHandlerMockRecorder) OnInactive added in v0.4.3 

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

OnInactive indicates an expected call of OnInactive.

func (*MockClientTransHandlerMockRecorder) OnMessage added in v0.4.3 

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

OnMessage indicates an expected call of OnMessage.

func (*MockClientTransHandlerMockRecorder) Read added in v0.4.3 

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

Read indicates an expected call of Read.

func (*MockClientTransHandlerMockRecorder) SetPipeline added in v0.4.3 

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

SetPipeline indicates an expected call of SetPipeline.

func (*MockClientTransHandlerMockRecorder) Write added in v0.4.3 

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

Write indicates an expected call of Write.

type MockCodec added in v0.4.0 

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

MockCodec is a mock of Codec interface.

func NewMockCodec added in v0.4.0 

func NewMockCodec(ctrl *gomock.Controller) *MockCodec

NewMockCodec creates a new mock instance.

func (*MockCodec) Decode added in v0.4.0 

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

Decode mocks base method.

func (*MockCodec) EXPECT added in v0.4.0 

func (m *MockCodec) EXPECT() *MockCodecMockRecorder

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

func (*MockCodec) Encode added in v0.4.0 

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

Encode mocks base method.

func (*MockCodec) Name added in v0.4.0 

func (m *MockCodec) Name() string

Name mocks base method.

type MockCodecMockRecorder added in v0.4.0 

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

MockCodecMockRecorder is the mock recorder for MockCodec.

func (*MockCodecMockRecorder) Decode added in v0.4.0 

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

Decode indicates an expected call of Decode.

func (*MockCodecMockRecorder) Encode added in v0.4.0 

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

Encode indicates an expected call of Encode.

func (*MockCodecMockRecorder) Name added in v0.4.0 

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

Name indicates an expected call of Name.

type MockConnPool added in v0.4.0 

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

MockConnPool is a mock of ConnPool interface.

func NewMockConnPool added in v0.4.0 

func NewMockConnPool(ctrl *gomock.Controller) *MockConnPool

NewMockConnPool creates a new mock instance.

func (*MockConnPool) Close added in v0.4.0 

func (m *MockConnPool) Close() error

Close mocks base method.

func (*MockConnPool) Discard added in v0.4.0 

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

Discard mocks base method.

func (*MockConnPool) EXPECT added in v0.4.0 

func (m *MockConnPool) EXPECT() *MockConnPoolMockRecorder

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

func (*MockConnPool) Get added in v0.4.0 

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

Get mocks base method.

func (*MockConnPool) Put added in v0.4.0 

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

Put mocks base method.

type MockConnPoolMockRecorder added in v0.4.0 

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

MockConnPoolMockRecorder is the mock recorder for MockConnPool.

func (*MockConnPoolMockRecorder) Close added in v0.4.0 

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

Close indicates an expected call of Close.

func (*MockConnPoolMockRecorder) Discard added in v0.4.0 

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

Discard indicates an expected call of Discard.

func (*MockConnPoolMockRecorder) Get added in v0.4.0 

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

Get indicates an expected call of Get.

func (*MockConnPoolMockRecorder) Put added in v0.4.0 

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

Put indicates an expected call of Put.

type MockConnPoolReporter added in v0.4.3 

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

MockConnPoolReporter is a mock of ConnPoolReporter interface.

func NewMockConnPoolReporter added in v0.4.3 

func NewMockConnPoolReporter(ctrl *gomock.Controller) *MockConnPoolReporter

NewMockConnPoolReporter creates a new mock instance.

func (*MockConnPoolReporter) EXPECT added in v0.4.3 

func (m *MockConnPoolReporter) EXPECT() *MockConnPoolReporterMockRecorder

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

func (*MockConnPoolReporter) EnableReporter added in v0.4.3 

func (m *MockConnPoolReporter) EnableReporter()

EnableReporter mocks base method.

type MockConnPoolReporterMockRecorder added in v0.4.3 

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

MockConnPoolReporterMockRecorder is the mock recorder for MockConnPoolReporter.

func (*MockConnPoolReporterMockRecorder) EnableReporter added in v0.4.3 

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

EnableReporter indicates an expected call of EnableReporter.

type MockDialer added in v0.4.3 

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

MockDialer is a mock of Dialer interface.

func NewMockDialer added in v0.4.3 

func NewMockDialer(ctrl *gomock.Controller) *MockDialer

NewMockDialer creates a new mock instance.

func (*MockDialer) DialTimeout added in v0.4.3 

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

DialTimeout mocks base method.

func (*MockDialer) EXPECT added in v0.4.3 

func (m *MockDialer) EXPECT() *MockDialerMockRecorder

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

type MockDialerMockRecorder added in v0.4.3 

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

MockDialerMockRecorder is the mock recorder for MockDialer.

func (*MockDialerMockRecorder) DialTimeout added in v0.4.3 

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

DialTimeout indicates an expected call of DialTimeout.

type MockDuplexBoundHandler added in v0.4.3 

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

MockDuplexBoundHandler is a mock of DuplexBoundHandler interface.

func NewMockDuplexBoundHandler added in v0.4.3 

func NewMockDuplexBoundHandler(ctrl *gomock.Controller) *MockDuplexBoundHandler

NewMockDuplexBoundHandler creates a new mock instance.

func (*MockDuplexBoundHandler) EXPECT added in v0.4.3 

func (m *MockDuplexBoundHandler) EXPECT() *MockDuplexBoundHandlerMockRecorder

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

func (*MockDuplexBoundHandler) OnActive added in v0.4.3 

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

OnActive mocks base method.

func (*MockDuplexBoundHandler) OnInactive added in v0.4.3 

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

OnInactive mocks base method.

func (*MockDuplexBoundHandler) OnMessage added in v0.4.3 

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

OnMessage mocks base method.

func (*MockDuplexBoundHandler) OnRead added in v0.4.3 

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

OnRead mocks base method.

func (*MockDuplexBoundHandler) Write added in v0.4.3 

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

Write mocks base method.

type MockDuplexBoundHandlerMockRecorder added in v0.4.3 

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

MockDuplexBoundHandlerMockRecorder is the mock recorder for MockDuplexBoundHandler.

func (*MockDuplexBoundHandlerMockRecorder) OnActive added in v0.4.3 

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

OnActive indicates an expected call of OnActive.

func (*MockDuplexBoundHandlerMockRecorder) OnInactive added in v0.4.3 

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

OnInactive indicates an expected call of OnInactive.

func (*MockDuplexBoundHandlerMockRecorder) OnMessage added in v0.4.3 

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

OnMessage indicates an expected call of OnMessage.

func (*MockDuplexBoundHandlerMockRecorder) OnRead added in v0.4.3 

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

OnRead indicates an expected call of OnRead.

func (*MockDuplexBoundHandlerMockRecorder) Write added in v0.4.3 

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

Write indicates an expected call of Write.

type MockGracefulShutdown added in v0.4.3 

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

MockGracefulShutdown is a mock of GracefulShutdown interface.

func NewMockGracefulShutdown added in v0.4.3 

func NewMockGracefulShutdown(ctrl *gomock.Controller) *MockGracefulShutdown

NewMockGracefulShutdown creates a new mock instance.

func (*MockGracefulShutdown) EXPECT added in v0.4.3 

func (m *MockGracefulShutdown) EXPECT() *MockGracefulShutdownMockRecorder

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

func (*MockGracefulShutdown) GracefulShutdown added in v0.4.3 

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

GracefulShutdown mocks base method.

type MockGracefulShutdownMockRecorder added in v0.4.3 

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

MockGracefulShutdownMockRecorder is the mock recorder for MockGracefulShutdown.

func (*MockGracefulShutdownMockRecorder) GracefulShutdown added in v0.4.3 

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

GracefulShutdown indicates an expected call of GracefulShutdown.

type MockInboundHandler added in v0.4.3 

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

MockInboundHandler is a mock of InboundHandler interface.

func NewMockInboundHandler added in v0.4.3 

func NewMockInboundHandler(ctrl *gomock.Controller) *MockInboundHandler

NewMockInboundHandler creates a new mock instance.

func (*MockInboundHandler) EXPECT added in v0.4.3 

func (m *MockInboundHandler) EXPECT() *MockInboundHandlerMockRecorder

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

func (*MockInboundHandler) OnActive added in v0.4.3 

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

OnActive mocks base method.

func (*MockInboundHandler) OnInactive added in v0.4.3 

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

OnInactive mocks base method.

func (*MockInboundHandler) OnMessage added in v0.4.3 

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

OnMessage mocks base method.

func (*MockInboundHandler) OnRead added in v0.4.3 

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

OnRead mocks base method.

type MockInboundHandlerMockRecorder added in v0.4.3 

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

MockInboundHandlerMockRecorder is the mock recorder for MockInboundHandler.

func (*MockInboundHandlerMockRecorder) OnActive added in v0.4.3 

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

OnActive indicates an expected call of OnActive.

func (*MockInboundHandlerMockRecorder) OnInactive added in v0.4.3 

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

OnInactive indicates an expected call of OnInactive.

func (*MockInboundHandlerMockRecorder) OnMessage added in v0.4.3 

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

OnMessage indicates an expected call of OnMessage.

func (*MockInboundHandlerMockRecorder) OnRead added in v0.4.3 

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

OnRead indicates an expected call of OnRead.

type MockInvokeHandleFuncSetter added in v0.4.3 

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

MockInvokeHandleFuncSetter is a mock of InvokeHandleFuncSetter interface.

func NewMockInvokeHandleFuncSetter added in v0.4.3 

func NewMockInvokeHandleFuncSetter(ctrl *gomock.Controller) *MockInvokeHandleFuncSetter

NewMockInvokeHandleFuncSetter creates a new mock instance.

func (*MockInvokeHandleFuncSetter) EXPECT added in v0.4.3 

func (m *MockInvokeHandleFuncSetter) EXPECT() *MockInvokeHandleFuncSetterMockRecorder

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

func (*MockInvokeHandleFuncSetter) SetInvokeHandleFunc added in v0.4.3 

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

SetInvokeHandleFunc mocks base method.

type MockInvokeHandleFuncSetterMockRecorder added in v0.4.3 

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

MockInvokeHandleFuncSetterMockRecorder is the mock recorder for MockInvokeHandleFuncSetter.

func (*MockInvokeHandleFuncSetterMockRecorder) SetInvokeHandleFunc added in v0.4.3 

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

SetInvokeHandleFunc indicates an expected call of SetInvokeHandleFunc.

type MockIsActive added in v0.4.3 

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

MockIsActive is a mock of IsActive interface.

func NewMockIsActive added in v0.4.3 

func NewMockIsActive(ctrl *gomock.Controller) *MockIsActive

NewMockIsActive creates a new mock instance.

func (*MockIsActive) EXPECT added in v0.4.3 

func (m *MockIsActive) EXPECT() *MockIsActiveMockRecorder

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

func (*MockIsActive) IsActive added in v0.4.3 

func (m *MockIsActive) IsActive() bool

IsActive mocks base method.

type MockIsActiveMockRecorder added in v0.4.3 

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

MockIsActiveMockRecorder is the mock recorder for MockIsActive.

func (*MockIsActiveMockRecorder) IsActive added in v0.4.3 

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

IsActive indicates an expected call of IsActive.

type MockLongConnPool added in v0.4.3 

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

MockLongConnPool is a mock of LongConnPool interface.

func NewMockLongConnPool added in v0.4.3 

func NewMockLongConnPool(ctrl *gomock.Controller) *MockLongConnPool

NewMockLongConnPool creates a new mock instance.

func (*MockLongConnPool) Clean added in v0.4.3 

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

Clean mocks base method.

func (*MockLongConnPool) Close added in v0.4.3 

func (m *MockLongConnPool) Close() error

Close mocks base method.

func (*MockLongConnPool) Discard added in v0.4.3 

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

Discard mocks base method.

func (*MockLongConnPool) EXPECT added in v0.4.3 

func (m *MockLongConnPool) EXPECT() *MockLongConnPoolMockRecorder

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

func (*MockLongConnPool) Get added in v0.4.3 

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

Get mocks base method.

func (*MockLongConnPool) Put added in v0.4.3 

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

Put mocks base method.

type MockLongConnPoolMockRecorder added in v0.4.3 

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

MockLongConnPoolMockRecorder is the mock recorder for MockLongConnPool.

func (*MockLongConnPoolMockRecorder) Clean added in v0.4.3 

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

Clean indicates an expected call of Clean.

func (*MockLongConnPoolMockRecorder) Close added in v0.4.3 

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

Close indicates an expected call of Close.

func (*MockLongConnPoolMockRecorder) Discard added in v0.4.3 

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

Discard indicates an expected call of Discard.

func (*MockLongConnPoolMockRecorder) Get added in v0.4.3 

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

Get indicates an expected call of Get.

func (*MockLongConnPoolMockRecorder) Put added in v0.4.3 

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

Put indicates an expected call of Put.

type MockMetaDecoder added in v0.4.3 

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

MockMetaDecoder is a mock of MetaDecoder interface.

func NewMockMetaDecoder added in v0.4.3 

func NewMockMetaDecoder(ctrl *gomock.Controller) *MockMetaDecoder

NewMockMetaDecoder creates a new mock instance.

func (*MockMetaDecoder) DecodeMeta added in v0.4.3 

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

DecodeMeta mocks base method.

func (*MockMetaDecoder) DecodePayload added in v0.4.3 

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

DecodePayload mocks base method.

func (*MockMetaDecoder) EXPECT added in v0.4.3 

func (m *MockMetaDecoder) EXPECT() *MockMetaDecoderMockRecorder

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

type MockMetaDecoderMockRecorder added in v0.4.3 

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

MockMetaDecoderMockRecorder is the mock recorder for MockMetaDecoder.

func (*MockMetaDecoderMockRecorder) DecodeMeta added in v0.4.3 

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

DecodeMeta indicates an expected call of DecodeMeta.

func (*MockMetaDecoderMockRecorder) DecodePayload added in v0.4.3 

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

DecodePayload indicates an expected call of DecodePayload.

type MockMetaHandler added in v0.4.0 

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

MockMetaHandler is a mock of MetaHandler interface.

func NewMockMetaHandler added in v0.4.0 

func NewMockMetaHandler(ctrl *gomock.Controller) *MockMetaHandler

NewMockMetaHandler creates a new mock instance.

func (*MockMetaHandler) EXPECT added in v0.4.0 

func (m *MockMetaHandler) EXPECT() *MockMetaHandlerMockRecorder

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

func (*MockMetaHandler) ReadMeta added in v0.4.0 

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

ReadMeta mocks base method.

func (*MockMetaHandler) WriteMeta added in v0.4.0 

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

WriteMeta mocks base method.

type MockMetaHandlerMockRecorder added in v0.4.0 

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

MockMetaHandlerMockRecorder is the mock recorder for MockMetaHandler.

func (*MockMetaHandlerMockRecorder) ReadMeta added in v0.4.0 

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

ReadMeta indicates an expected call of ReadMeta.

func (*MockMetaHandlerMockRecorder) WriteMeta added in v0.4.0 

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

WriteMeta indicates an expected call of WriteMeta.

type MockOutboundHandler added in v0.4.0 

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

MockOutboundHandler is a mock of OutboundHandler interface.

func NewMockOutboundHandler added in v0.4.0 

func NewMockOutboundHandler(ctrl *gomock.Controller) *MockOutboundHandler

NewMockOutboundHandler creates a new mock instance.

func (*MockOutboundHandler) EXPECT added in v0.4.0 

func (m *MockOutboundHandler) EXPECT() *MockOutboundHandlerMockRecorder

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

func (*MockOutboundHandler) Write added in v0.4.0 

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

Write mocks base method.

type MockOutboundHandlerMockRecorder added in v0.4.0 

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

MockOutboundHandlerMockRecorder is the mock recorder for MockOutboundHandler.

func (*MockOutboundHandlerMockRecorder) Write added in v0.4.0 

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

Write indicates an expected call of Write.

type MockPayloadCodec added in v0.4.0 

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

MockPayloadCodec is a mock of PayloadCodec interface.

func NewMockPayloadCodec added in v0.4.0 

func NewMockPayloadCodec(ctrl *gomock.Controller) *MockPayloadCodec

NewMockPayloadCodec creates a new mock instance.

func (*MockPayloadCodec) EXPECT added in v0.4.0 

func (m *MockPayloadCodec) EXPECT() *MockPayloadCodecMockRecorder

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

func (*MockPayloadCodec) Marshal added in v0.4.0 

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

Marshal mocks base method.

func (*MockPayloadCodec) Name added in v0.4.0 

func (m *MockPayloadCodec) Name() string

Name mocks base method.

func (*MockPayloadCodec) Unmarshal added in v0.4.0 

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

Unmarshal mocks base method.

type MockPayloadCodecMockRecorder added in v0.4.0 

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

MockPayloadCodecMockRecorder is the mock recorder for MockPayloadCodec.

func (*MockPayloadCodecMockRecorder) Marshal added in v0.4.0 

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

Marshal indicates an expected call of Marshal.

func (*MockPayloadCodecMockRecorder) Name added in v0.4.0 

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

Name indicates an expected call of Name.

func (*MockPayloadCodecMockRecorder) Unmarshal added in v0.4.0 

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

Unmarshal indicates an expected call of Unmarshal.

type MockRawConn added in v0.4.3 

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

MockRawConn is a mock of RawConn interface.

func NewMockRawConn added in v0.4.3 

func NewMockRawConn(ctrl *gomock.Controller) *MockRawConn

NewMockRawConn creates a new mock instance.

func (*MockRawConn) EXPECT added in v0.4.3 

func (m *MockRawConn) EXPECT() *MockRawConnMockRecorder

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

func (*MockRawConn) RawConn added in v0.4.3 

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

RawConn mocks base method.

type MockRawConnMockRecorder added in v0.4.3 

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

MockRawConnMockRecorder is the mock recorder for MockRawConn.

func (*MockRawConnMockRecorder) RawConn added in v0.4.3 

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

RawConn indicates an expected call of RawConn.

type MockServerTransHandler added in v0.4.3 

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

MockServerTransHandler is a mock of ServerTransHandler interface.

func NewMockServerTransHandler added in v0.4.3 

func NewMockServerTransHandler(ctrl *gomock.Controller) *MockServerTransHandler

NewMockServerTransHandler creates a new mock instance.

func (*MockServerTransHandler) EXPECT added in v0.4.3 

func (m *MockServerTransHandler) EXPECT() *MockServerTransHandlerMockRecorder

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

func (*MockServerTransHandler) OnActive added in v0.4.3 

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

OnActive mocks base method.

func (*MockServerTransHandler) OnError added in v0.4.3 

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

OnError mocks base method.

func (*MockServerTransHandler) OnInactive added in v0.4.3 

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

OnInactive mocks base method.

func (*MockServerTransHandler) OnMessage added in v0.4.3 

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

OnMessage mocks base method.

func (*MockServerTransHandler) OnRead added in v0.4.3 

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

OnRead mocks base method.

func (*MockServerTransHandler) Read added in v0.4.3 

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

Read mocks base method.

func (*MockServerTransHandler) SetPipeline added in v0.4.3 

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

SetPipeline mocks base method.

func (*MockServerTransHandler) Write added in v0.4.3 

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

Write mocks base method.

type MockServerTransHandlerFactory added in v0.4.3 

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

MockServerTransHandlerFactory is a mock of ServerTransHandlerFactory interface.

func NewMockServerTransHandlerFactory added in v0.4.3 

func NewMockServerTransHandlerFactory(ctrl *gomock.Controller) *MockServerTransHandlerFactory

NewMockServerTransHandlerFactory creates a new mock instance.

func (*MockServerTransHandlerFactory) EXPECT added in v0.4.3 

func (m *MockServerTransHandlerFactory) EXPECT() *MockServerTransHandlerFactoryMockRecorder

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

func (*MockServerTransHandlerFactory) NewTransHandler added in v0.4.3 

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

NewTransHandler mocks base method.

type MockServerTransHandlerFactoryMockRecorder added in v0.4.3 

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

MockServerTransHandlerFactoryMockRecorder is the mock recorder for MockServerTransHandlerFactory.

func (*MockServerTransHandlerFactoryMockRecorder) NewTransHandler added in v0.4.3 

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

NewTransHandler indicates an expected call of NewTransHandler.

type MockServerTransHandlerMockRecorder added in v0.4.3 

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

MockServerTransHandlerMockRecorder is the mock recorder for MockServerTransHandler.

func (*MockServerTransHandlerMockRecorder) OnActive added in v0.4.3 

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

OnActive indicates an expected call of OnActive.

func (*MockServerTransHandlerMockRecorder) OnError added in v0.4.3 

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

OnError indicates an expected call of OnError.

func (*MockServerTransHandlerMockRecorder) OnInactive added in v0.4.3 

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

OnInactive indicates an expected call of OnInactive.

func (*MockServerTransHandlerMockRecorder) OnMessage added in v0.4.3 

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

OnMessage indicates an expected call of OnMessage.

func (*MockServerTransHandlerMockRecorder) OnRead added in v0.4.3 

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

OnRead indicates an expected call of OnRead.

func (*MockServerTransHandlerMockRecorder) Read added in v0.4.3 

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

Read indicates an expected call of Read.

func (*MockServerTransHandlerMockRecorder) SetPipeline added in v0.4.3 

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

SetPipeline indicates an expected call of SetPipeline.

func (*MockServerTransHandlerMockRecorder) Write added in v0.4.3 

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

Write indicates an expected call of Write.

type MockStreamingMetaHandler added in v0.4.3 

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

MockStreamingMetaHandler is a mock of StreamingMetaHandler interface.

func NewMockStreamingMetaHandler added in v0.4.3 

func NewMockStreamingMetaHandler(ctrl *gomock.Controller) *MockStreamingMetaHandler

NewMockStreamingMetaHandler creates a new mock instance.

func (*MockStreamingMetaHandler) EXPECT added in v0.4.3 

func (m *MockStreamingMetaHandler) EXPECT() *MockStreamingMetaHandlerMockRecorder

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

func (*MockStreamingMetaHandler) OnConnectStream added in v0.4.3 

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

OnConnectStream mocks base method.

func (*MockStreamingMetaHandler) OnReadStream added in v0.4.3 

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

OnReadStream mocks base method.

type MockStreamingMetaHandlerMockRecorder added in v0.4.3 

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

MockStreamingMetaHandlerMockRecorder is the mock recorder for MockStreamingMetaHandler.

func (*MockStreamingMetaHandlerMockRecorder) OnConnectStream added in v0.4.3 

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

OnConnectStream indicates an expected call of OnConnectStream.

func (*MockStreamingMetaHandlerMockRecorder) OnReadStream added in v0.4.3 

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

OnReadStream indicates an expected call of OnReadStream.

type MockTransHandler added in v0.4.3 

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

MockTransHandler is a mock of TransHandler interface.

func NewMockTransHandler added in v0.4.3 

func NewMockTransHandler(ctrl *gomock.Controller) *MockTransHandler

NewMockTransHandler creates a new mock instance.

func (*MockTransHandler) EXPECT added in v0.4.3 

func (m *MockTransHandler) EXPECT() *MockTransHandlerMockRecorder

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

func (*MockTransHandler) OnError added in v0.4.3 

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

OnError mocks base method.

func (*MockTransHandler) OnInactive added in v0.4.3 

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

OnInactive mocks base method.

func (*MockTransHandler) OnMessage added in v0.4.3 

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

OnMessage mocks base method.

func (*MockTransHandler) Read added in v0.4.3 

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

Read mocks base method.

func (*MockTransHandler) SetPipeline added in v0.4.3 

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

SetPipeline mocks base method.

func (*MockTransHandler) Write added in v0.4.3 

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

Write mocks base method.

type MockTransHandlerMockRecorder added in v0.4.3 

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

MockTransHandlerMockRecorder is the mock recorder for MockTransHandler.

func (*MockTransHandlerMockRecorder) OnError added in v0.4.3 

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

OnError indicates an expected call of OnError.

func (*MockTransHandlerMockRecorder) OnInactive added in v0.4.3 

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

OnInactive indicates an expected call of OnInactive.

func (*MockTransHandlerMockRecorder) OnMessage added in v0.4.3 

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

OnMessage indicates an expected call of OnMessage.

func (*MockTransHandlerMockRecorder) Read added in v0.4.3 

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

Read indicates an expected call of Read.

func (*MockTransHandlerMockRecorder) SetPipeline added in v0.4.3 

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

SetPipeline indicates an expected call of SetPipeline.

func (*MockTransHandlerMockRecorder) Write added in v0.4.3 

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

Write indicates an expected call of Write.

type MockTransReadWriter added in v0.4.3 

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

MockTransReadWriter is a mock of TransReadWriter interface.

func NewMockTransReadWriter added in v0.4.3 

func NewMockTransReadWriter(ctrl *gomock.Controller) *MockTransReadWriter

NewMockTransReadWriter creates a new mock instance.

func (*MockTransReadWriter) EXPECT added in v0.4.3 

func (m *MockTransReadWriter) EXPECT() *MockTransReadWriterMockRecorder

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

func (*MockTransReadWriter) Read added in v0.4.3 

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

Read mocks base method.

func (*MockTransReadWriter) Write added in v0.4.3 

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

Write mocks base method.

type MockTransReadWriterMockRecorder added in v0.4.3 

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

MockTransReadWriterMockRecorder is the mock recorder for MockTransReadWriter.

func (*MockTransReadWriterMockRecorder) Read added in v0.4.3 

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

Read indicates an expected call of Read.

func (*MockTransReadWriterMockRecorder) Write added in v0.4.3 

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.