remote

package
v0.11.3 Latest Latest
Warning

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

 Go to latest Published: Sep 11, 2024 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, methodSvcMap map[string]*serviceinfo.ServiceInfo) *MockSvcSearcher

func (*MockSvcSearcher) SearchService added in v0.10.2 

func (s *MockSvcSearcher) SearchService(svcName, methodName string, strict bool) *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.