Help us shape the future of Go! Take the 2026 Go Developer Survey

remote

package
v0.16.4 Latest Latest
Warning

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

 Go to latest Published: Sep 22, 2026 License: Apache-2.0 Imports: 10 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.

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 MockByteBuffer added in v0.9.0 

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

MockByteBuffer is a mock of ByteBuffer interface.

func NewMockByteBuffer added in v0.9.0 

func NewMockByteBuffer(ctrl *gomock.Controller) *MockByteBuffer

NewMockByteBuffer creates a new mock instance.

func (*MockByteBuffer) AppendBuffer added in v0.9.0 

func (m *MockByteBuffer) AppendBuffer(buf remote.ByteBuffer) error

AppendBuffer mocks base method.

func (*MockByteBuffer) Bytes added in v0.9.0 

func (m *MockByteBuffer) Bytes() ([]byte, error)

Bytes mocks base method.

func (*MockByteBuffer) EXPECT added in v0.9.0 

func (m *MockByteBuffer) EXPECT() *MockByteBufferMockRecorder

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

func (*MockByteBuffer) Flush added in v0.9.0 

func (m *MockByteBuffer) Flush() error

Flush mocks base method.

func (*MockByteBuffer) Malloc added in v0.9.0 

func (m *MockByteBuffer) Malloc(n int) ([]byte, error)

Malloc mocks base method.

func (*MockByteBuffer) NewBuffer added in v0.9.0 

func (m *MockByteBuffer) NewBuffer() remote.ByteBuffer

NewBuffer mocks base method.

func (*MockByteBuffer) Next added in v0.9.0 

func (m *MockByteBuffer) Next(n int) ([]byte, error)

Next mocks base method.

func (*MockByteBuffer) Peek added in v0.9.0 

func (m *MockByteBuffer) Peek(n int) ([]byte, error)

Peek mocks base method.

func (*MockByteBuffer) Read added in v0.9.0 

func (m *MockByteBuffer) Read(p []byte) (int, error)

Read mocks base method.

func (*MockByteBuffer) ReadBinary added in v0.9.0 

func (m *MockByteBuffer) ReadBinary(p []byte) (int, error)

ReadBinary mocks base method.

func (*MockByteBuffer) ReadLen added in v0.9.0 

func (m *MockByteBuffer) ReadLen() int

ReadLen mocks base method.

func (*MockByteBuffer) ReadString added in v0.9.0 

func (m *MockByteBuffer) ReadString(n int) (string, error)

ReadString mocks base method.

func (*MockByteBuffer) ReadableLen added in v0.9.0 

func (m *MockByteBuffer) ReadableLen() int

ReadableLen mocks base method.

func (*MockByteBuffer) Release added in v0.9.0 

func (m *MockByteBuffer) Release(e error) error

Release mocks base method.

func (*MockByteBuffer) Skip added in v0.9.0 

func (m *MockByteBuffer) Skip(n int) error

Skip mocks base method.

func (*MockByteBuffer) Write added in v0.9.0 

func (m *MockByteBuffer) Write(p []byte) (int, error)

Write mocks base method.

func (*MockByteBuffer) WriteBinary added in v0.9.0 

func (m *MockByteBuffer) WriteBinary(b []byte) (int, error)

WriteBinary mocks base method.

func (*MockByteBuffer) WriteString added in v0.9.0 

func (m *MockByteBuffer) WriteString(s string) (int, error)

WriteString mocks base method.

func (*MockByteBuffer) WrittenLen added in v0.11.0 

func (m *MockByteBuffer) WrittenLen() int

WrittenLen mocks base method.

type MockByteBufferFactory added in v0.9.0 

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

MockByteBufferFactory is a mock of ByteBufferFactory interface.

func NewMockByteBufferFactory added in v0.9.0 

func NewMockByteBufferFactory(ctrl *gomock.Controller) *MockByteBufferFactory

NewMockByteBufferFactory creates a new mock instance.

func (*MockByteBufferFactory) EXPECT added in v0.9.0 

func (m *MockByteBufferFactory) EXPECT() *MockByteBufferFactoryMockRecorder

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

func (*MockByteBufferFactory) NewByteBuffer added in v0.9.0 

func (m *MockByteBufferFactory) NewByteBuffer(conn net.Conn) (remote.ByteBuffer, error)

NewByteBuffer mocks base method.

type MockByteBufferFactoryMockRecorder added in v0.9.0 

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

MockByteBufferFactoryMockRecorder is the mock recorder for MockByteBufferFactory.

func (*MockByteBufferFactoryMockRecorder) NewByteBuffer added in v0.9.0 

func (mr *MockByteBufferFactoryMockRecorder) NewByteBuffer(conn interface{}) *gomock.Call

NewByteBuffer indicates an expected call of NewByteBuffer.

type MockByteBufferMockRecorder added in v0.9.0 

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

MockByteBufferMockRecorder is the mock recorder for MockByteBuffer.

func (*MockByteBufferMockRecorder) AppendBuffer added in v0.9.0 

func (mr *MockByteBufferMockRecorder) AppendBuffer(buf interface{}) *gomock.Call

AppendBuffer indicates an expected call of AppendBuffer.

func (*MockByteBufferMockRecorder) Bytes added in v0.9.0 

func (mr *MockByteBufferMockRecorder) Bytes() *gomock.Call

Bytes indicates an expected call of Bytes.

func (*MockByteBufferMockRecorder) Flush added in v0.9.0 

func (mr *MockByteBufferMockRecorder) Flush() *gomock.Call

Flush indicates an expected call of Flush.

func (*MockByteBufferMockRecorder) Malloc added in v0.9.0 

func (mr *MockByteBufferMockRecorder) Malloc(n interface{}) *gomock.Call

Malloc indicates an expected call of Malloc.

func (*MockByteBufferMockRecorder) NewBuffer added in v0.9.0 

func (mr *MockByteBufferMockRecorder) NewBuffer() *gomock.Call

NewBuffer indicates an expected call of NewBuffer.

func (*MockByteBufferMockRecorder) Next added in v0.9.0 

func (mr *MockByteBufferMockRecorder) Next(n interface{}) *gomock.Call

Next indicates an expected call of Next.

func (*MockByteBufferMockRecorder) Peek added in v0.9.0 

func (mr *MockByteBufferMockRecorder) Peek(n interface{}) *gomock.Call

Peek indicates an expected call of Peek.

func (*MockByteBufferMockRecorder) Read added in v0.9.0 

func (mr *MockByteBufferMockRecorder) Read(p interface{}) *gomock.Call

Read indicates an expected call of Read.

func (*MockByteBufferMockRecorder) ReadBinary added in v0.9.0 

func (mr *MockByteBufferMockRecorder) ReadBinary(p interface{}) *gomock.Call

ReadBinary indicates an expected call of ReadBinary.

func (*MockByteBufferMockRecorder) ReadLen added in v0.9.0 

func (mr *MockByteBufferMockRecorder) ReadLen() *gomock.Call

ReadLen indicates an expected call of ReadLen.

func (*MockByteBufferMockRecorder) ReadString added in v0.9.0 

func (mr *MockByteBufferMockRecorder) ReadString(n interface{}) *gomock.Call

ReadString indicates an expected call of ReadString.

func (*MockByteBufferMockRecorder) ReadableLen added in v0.9.0 

func (mr *MockByteBufferMockRecorder) ReadableLen() *gomock.Call

ReadableLen indicates an expected call of ReadableLen.

func (*MockByteBufferMockRecorder) Release added in v0.9.0 

func (mr *MockByteBufferMockRecorder) Release(e interface{}) *gomock.Call

Release indicates an expected call of Release.

func (*MockByteBufferMockRecorder) Skip added in v0.9.0 

func (mr *MockByteBufferMockRecorder) Skip(n interface{}) *gomock.Call

Skip indicates an expected call of Skip.

func (*MockByteBufferMockRecorder) Write added in v0.9.0 

func (mr *MockByteBufferMockRecorder) Write(p interface{}) *gomock.Call

Write indicates an expected call of Write.

func (*MockByteBufferMockRecorder) WriteBinary added in v0.9.0 

func (mr *MockByteBufferMockRecorder) WriteBinary(b interface{}) *gomock.Call

WriteBinary indicates an expected call of WriteBinary.

func (*MockByteBufferMockRecorder) WriteString added in v0.9.0 

func (mr *MockByteBufferMockRecorder) WriteString(s interface{}) *gomock.Call

WriteString indicates an expected call of WriteString.

func (*MockByteBufferMockRecorder) WrittenLen added in v0.11.0 

func (mr *MockByteBufferMockRecorder) WrittenLen() *gomock.Call

WrittenLen indicates an expected call of WrittenLen.

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 MockConnReleaser added in v0.10.0 

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

MockConnReleaser is a mock of ConnReleaser interface.

func NewMockConnReleaser added in v0.10.0 

func NewMockConnReleaser(ctrl *gomock.Controller) *MockConnReleaser

NewMockConnReleaser creates a new mock instance.

func (*MockConnReleaser) EXPECT added in v0.10.0 

func (m *MockConnReleaser) EXPECT() *MockConnReleaserMockRecorder

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

func (*MockConnReleaser) ReleaseConn added in v0.10.0 

func (m *MockConnReleaser) ReleaseConn(err error, ri rpcinfo.RPCInfo)

ReleaseConn mocks base method.

type MockConnReleaserMockRecorder added in v0.10.0 

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

MockConnReleaserMockRecorder is the mock recorder for MockConnReleaser.

func (*MockConnReleaserMockRecorder) ReleaseConn added in v0.10.0 

func (mr *MockConnReleaserMockRecorder) ReleaseConn(err, ri interface{}) *gomock.Call

ReleaseConn indicates an expected call of ReleaseConn.

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 MockFrameWrite added in v0.9.0 

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

MockFrameWrite is a mock of FrameWrite interface.

func NewMockFrameWrite added in v0.9.0 

func NewMockFrameWrite(ctrl *gomock.Controller) *MockFrameWrite

NewMockFrameWrite creates a new mock instance.

func (*MockFrameWrite) EXPECT added in v0.9.0 

func (m *MockFrameWrite) EXPECT() *MockFrameWriteMockRecorder

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

func (*MockFrameWrite) WriteData added in v0.9.0 

func (m *MockFrameWrite) WriteData(buf []byte) error

WriteData mocks base method.

func (*MockFrameWrite) WriteHeader added in v0.9.0 

func (m *MockFrameWrite) WriteHeader(buf []byte) error

WriteHeader mocks base method.

type MockFrameWriteMockRecorder added in v0.9.0 

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

MockFrameWriteMockRecorder is the mock recorder for MockFrameWrite.

func (*MockFrameWriteMockRecorder) WriteData added in v0.9.0 

func (mr *MockFrameWriteMockRecorder) WriteData(buf interface{}) *gomock.Call

WriteData indicates an expected call of WriteData.

func (*MockFrameWriteMockRecorder) WriteHeader added in v0.9.0 

func (mr *MockFrameWriteMockRecorder) WriteHeader(buf interface{}) *gomock.Call

WriteHeader indicates an expected call of WriteHeader.

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 MockMetaEncoder added in v0.9.0 

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

MockMetaEncoder is a mock of MetaEncoder interface.

func NewMockMetaEncoder added in v0.9.0 

func NewMockMetaEncoder(ctrl *gomock.Controller) *MockMetaEncoder

NewMockMetaEncoder creates a new mock instance.

func (*MockMetaEncoder) EXPECT added in v0.9.0 

func (m *MockMetaEncoder) EXPECT() *MockMetaEncoderMockRecorder

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

func (*MockMetaEncoder) EncodeMetaAndPayload added in v0.9.0 

func (m *MockMetaEncoder) EncodeMetaAndPayload(ctx context.Context, msg remote.Message, out remote.ByteBuffer, me remote.MetaEncoder) error

EncodeMetaAndPayload mocks base method.

func (*MockMetaEncoder) EncodePayload added in v0.9.0 

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

EncodePayload mocks base method.

type MockMetaEncoderMockRecorder added in v0.9.0 

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

MockMetaEncoderMockRecorder is the mock recorder for MockMetaEncoder.

func (*MockMetaEncoderMockRecorder) EncodeMetaAndPayload added in v0.9.0 

func (mr *MockMetaEncoderMockRecorder) EncodeMetaAndPayload(ctx, msg, out, me interface{}) *gomock.Call

EncodeMetaAndPayload indicates an expected call of EncodeMetaAndPayload.

func (*MockMetaEncoderMockRecorder) EncodePayload added in v0.9.0 

func (mr *MockMetaEncoderMockRecorder) EncodePayload(ctx, msg, out interface{}) *gomock.Call

EncodePayload indicates an expected call of EncodePayload.

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 MockNocopyWrite added in v0.9.0 

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

MockNocopyWrite is a mock of NocopyWrite interface.

func NewMockNocopyWrite added in v0.9.0 

func NewMockNocopyWrite(ctrl *gomock.Controller) *MockNocopyWrite

NewMockNocopyWrite creates a new mock instance.

func (*MockNocopyWrite) EXPECT added in v0.9.0 

func (m *MockNocopyWrite) EXPECT() *MockNocopyWriteMockRecorder

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

func (*MockNocopyWrite) MallocAck added in v0.11.0 

func (m *MockNocopyWrite) MallocAck(n int) error

MallocAck mocks base method.

func (*MockNocopyWrite) WriteDirect added in v0.9.0 

func (m *MockNocopyWrite) WriteDirect(buf []byte, remainCap int) error

WriteDirect mocks base method.

type MockNocopyWriteMockRecorder added in v0.9.0 

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

MockNocopyWriteMockRecorder is the mock recorder for MockNocopyWrite.

func (*MockNocopyWriteMockRecorder) MallocAck added in v0.11.0 

func (mr *MockNocopyWriteMockRecorder) MallocAck(n interface{}) *gomock.Call

MallocAck indicates an expected call of MallocAck.

func (*MockNocopyWriteMockRecorder) WriteDirect added in v0.9.0 

func (mr *MockNocopyWriteMockRecorder) WriteDirect(buf, remainCap interface{}) *gomock.Call

WriteDirect indicates an expected call of WriteDirect.

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 MockSvcSearcher added in v0.10.2 

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

func NewDefaultSvcSearcher added in v0.10.2 

func NewDefaultSvcSearcher() *MockSvcSearcher

func NewMockSvcSearcher added in v0.10.2 

func NewMockSvcSearcher(svcMap map[string]*serviceinfo.ServiceInfo) *MockSvcSearcher

func (*MockSvcSearcher) SearchService added in v0.10.2 

func (s *MockSvcSearcher) SearchService(svcName, methodName string, strict bool, codecType serviceinfo.PayloadCodec) *serviceinfo.ServiceInfo

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.