mocks

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: Aug 26, 2022 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Overview

Package mocks is a generated GoMock package.

Package mocks contains mocks of interfaces.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Index

Constants

View Source 
const (
	MockServiceName            = "MockService"
	MockMethod          string = "mock"
	MockExceptionMethod string = "mockException"
	MockErrorMethod     string = "mockError"
	MockOnewayMethod    string = "mockOneway"
)

method name of mock

Variables

This section is empty.

Functions

func MockFuncHandler 

func MockFuncHandler(mf func(ctx context.Context, req *MyRequest) (r *MyResponse, err error)) interface{}

MockFuncHandler .

func MyServiceHandler 

func MyServiceHandler() interface{}

MyServiceHandler .

func NewMockArgs 

func NewMockArgs() interface{}

func NewMockCliTransHandlerFactory 

func NewMockCliTransHandlerFactory(hdrl *MockCliTransHandler) remote.ClientTransHandlerFactory

NewMockCliTransHandlerFactory .

func NewMockResult 

func NewMockResult() interface{}

func NewMockSvrTransHandlerFactory 

func NewMockSvrTransHandlerFactory(hdrl *MockSvrTransHandler) remote.ServerTransHandlerFactory

NewMockSvrTransHandlerFactory .

func NewMockTransServerFactory 

func NewMockTransServerFactory(transSvr *MockTransServer) remote.TransServerFactory

NewMockTransServerFactory .

func ServiceInfo 

func ServiceInfo() *serviceinfo.ServiceInfo

ServiceInfo return mock serviceInfo

Types

type Conn 

type Conn struct {
	ReadFunc             func(b []byte) (n int, err error)
	WriteFunc            func(b []byte) (n int, err error)
	CloseFunc            func() (e error)
	LocalAddrFunc        func() (r net.Addr)
	RemoteAddrFunc       func() (r net.Addr)
	SetDeadlineFunc      func(t time.Time) (e error)
	SetReadDeadlineFunc  func(t time.Time) (e error)
	SetWriteDeadlineFunc func(t time.Time) (e error)
}

Conn implements the net.Conn interface.

func (Conn) Close 

func (m Conn) Close() (e error)

Close implements the net.Conn interface.

func (Conn) LocalAddr 

func (m Conn) LocalAddr() (r net.Addr)

LocalAddr implements the net.Conn interface.

func (Conn) Read 

func (m Conn) Read(b []byte) (n int, err error)

Read implements the net.Conn interface.

func (Conn) RemoteAddr 

func (m Conn) RemoteAddr() (r net.Addr)

RemoteAddr implements the net.Conn interface.

func (Conn) SetDeadline 

func (m Conn) SetDeadline(t time.Time) (e error)

SetDeadline implements the net.Conn interface.

func (Conn) SetReadDeadline 

func (m Conn) SetReadDeadline(t time.Time) (e error)

SetReadDeadline implements the net.Conn interface.

func (Conn) SetWriteDeadline 

func (m Conn) SetWriteDeadline(t time.Time) (e error)

SetWriteDeadline implements the net.Conn interface.

func (Conn) Write 

func (m Conn) Write(b []byte) (n int, err error)

Write implements the net.Conn interface.

type MockBoundHandler added in v0.3.3 

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

MockBoundHandler is a mock of BoundHandler interface.

func NewMockBoundHandler added in v0.3.3 

func NewMockBoundHandler(ctrl *gomock.Controller) *MockBoundHandler

NewMockBoundHandler creates a new mock instance.

func (*MockBoundHandler) EXPECT added in v0.3.3 

func (m *MockBoundHandler) EXPECT() *MockBoundHandlerMockRecorder

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

type MockBoundHandlerMockRecorder added in v0.3.3 

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

MockBoundHandlerMockRecorder is the mock recorder for MockBoundHandler.

type MockCliTransHandler 

type MockCliTransHandler struct {
	WriteFunc func(ctx context.Context, conn net.Conn, send remote.Message) error

	ReadFunc func(ctx context.Context, conn net.Conn, msg remote.Message) error
	// contains filtered or unexported fields
}

MockCliTransHandler .

func (*MockCliTransHandler) OnActive 

func (t *MockCliTransHandler) OnActive(ctx context.Context, conn net.Conn) (context.Context, error)

OnActive implements the remote.TransHandler interface.

func (*MockCliTransHandler) OnError 

func (t *MockCliTransHandler) OnError(ctx context.Context, err error, conn net.Conn)

OnError implements the remote.TransHandler interface.

func (*MockCliTransHandler) OnInactive 

func (t *MockCliTransHandler) OnInactive(ctx context.Context, conn net.Conn)

OnInactive implements the remote.TransHandler interface.

func (*MockCliTransHandler) OnMessage 

func (t *MockCliTransHandler) OnMessage(ctx context.Context, args, result remote.Message) (context.Context, error)

OnMessage implements the remote.TransHandler interface.

func (*MockCliTransHandler) Read 

func (t *MockCliTransHandler) Read(ctx context.Context, conn net.Conn, msg remote.Message) (err error)

Read implements the remote.TransHandler interface.

func (*MockCliTransHandler) SetPipeline 

func (t *MockCliTransHandler) SetPipeline(p *remote.TransPipeline)

SetPipeline implements the remote.TransHandler interface.

func (*MockCliTransHandler) Write 

func (t *MockCliTransHandler) Write(ctx context.Context, conn net.Conn, send remote.Message) (err error)

Write implements the remote.TransHandler interface.

type MockConcurrencyLimiter added in v0.3.2 

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

MockConcurrencyLimiter is a mock of ConcurrencyLimiter interface.

func NewMockConcurrencyLimiter added in v0.3.2 

func NewMockConcurrencyLimiter(ctrl *gomock.Controller) *MockConcurrencyLimiter

NewMockConcurrencyLimiter creates a new mock instance.

func (*MockConcurrencyLimiter) Acquire added in v0.3.2 

func (m *MockConcurrencyLimiter) Acquire(ctx context.Context) bool

Acquire mocks base method.

func (*MockConcurrencyLimiter) EXPECT added in v0.3.2 

func (m *MockConcurrencyLimiter) EXPECT() *MockConcurrencyLimiterMockRecorder

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

func (*MockConcurrencyLimiter) Release added in v0.3.2 

func (m *MockConcurrencyLimiter) Release(ctx context.Context)

Release mocks base method.

func (*MockConcurrencyLimiter) Status added in v0.3.2 

func (m *MockConcurrencyLimiter) Status(ctx context.Context) (int, int)

Status mocks base method.

type MockConcurrencyLimiterMockRecorder added in v0.3.2 

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

MockConcurrencyLimiterMockRecorder is the mock recorder for MockConcurrencyLimiter.

func (*MockConcurrencyLimiterMockRecorder) Acquire added in v0.3.2 

func (mr *MockConcurrencyLimiterMockRecorder) Acquire(ctx interface{}) *gomock.Call

Acquire indicates an expected call of Acquire.

func (*MockConcurrencyLimiterMockRecorder) Release added in v0.3.2 

func (mr *MockConcurrencyLimiterMockRecorder) Release(ctx interface{}) *gomock.Call

Release indicates an expected call of Release.

func (*MockConcurrencyLimiterMockRecorder) Status added in v0.3.2 

func (mr *MockConcurrencyLimiterMockRecorder) Status(ctx interface{}) *gomock.Call

Status indicates an expected call of Status.

type MockControl added in v0.3.3 

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

MockControl is a mock of Control interface.

func NewMockControl added in v0.3.3 

func NewMockControl(ctrl *gomock.Controller) *MockControl

NewMockControl creates a new mock instance.

func (*MockControl) EXPECT added in v0.3.3 

func (m *MockControl) EXPECT() *MockControlMockRecorder

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

func (*MockControl) SetLevel added in v0.3.3 

func (m *MockControl) SetLevel(arg0 klog.Level)

SetLevel mocks base method.

func (*MockControl) SetOutput added in v0.3.3 

func (m *MockControl) SetOutput(arg0 io.Writer)

SetOutput mocks base method.

type MockControlMockRecorder added in v0.3.3 

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

MockControlMockRecorder is the mock recorder for MockControl.

func (*MockControlMockRecorder) SetLevel added in v0.3.3 

func (mr *MockControlMockRecorder) SetLevel(arg0 interface{}) *gomock.Call

SetLevel indicates an expected call of SetLevel.

func (*MockControlMockRecorder) SetOutput added in v0.3.3 

func (mr *MockControlMockRecorder) SetOutput(arg0 interface{}) *gomock.Call

SetOutput indicates an expected call of SetOutput.

type MockCtxLogger added in v0.3.3 

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

MockCtxLogger is a mock of CtxLogger interface.

func NewMockCtxLogger added in v0.3.3 

func NewMockCtxLogger(ctrl *gomock.Controller) *MockCtxLogger

NewMockCtxLogger creates a new mock instance.

func (*MockCtxLogger) CtxDebugf added in v0.3.3 

func (m *MockCtxLogger) CtxDebugf(ctx context.Context, format string, v ...interface{})

CtxDebugf mocks base method.

func (*MockCtxLogger) CtxErrorf added in v0.3.3 

func (m *MockCtxLogger) CtxErrorf(ctx context.Context, format string, v ...interface{})

CtxErrorf mocks base method.

func (*MockCtxLogger) CtxFatalf added in v0.3.3 

func (m *MockCtxLogger) CtxFatalf(ctx context.Context, format string, v ...interface{})

CtxFatalf mocks base method.

func (*MockCtxLogger) CtxInfof added in v0.3.3 

func (m *MockCtxLogger) CtxInfof(ctx context.Context, format string, v ...interface{})

CtxInfof mocks base method.

func (*MockCtxLogger) CtxNoticef added in v0.3.3 

func (m *MockCtxLogger) CtxNoticef(ctx context.Context, format string, v ...interface{})

CtxNoticef mocks base method.

func (*MockCtxLogger) CtxTracef added in v0.3.3 

func (m *MockCtxLogger) CtxTracef(ctx context.Context, format string, v ...interface{})

CtxTracef mocks base method.

func (*MockCtxLogger) CtxWarnf added in v0.3.3 

func (m *MockCtxLogger) CtxWarnf(ctx context.Context, format string, v ...interface{})

CtxWarnf mocks base method.

func (*MockCtxLogger) EXPECT added in v0.3.3 

func (m *MockCtxLogger) EXPECT() *MockCtxLoggerMockRecorder

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

type MockCtxLoggerMockRecorder added in v0.3.3 

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

MockCtxLoggerMockRecorder is the mock recorder for MockCtxLogger.

func (*MockCtxLoggerMockRecorder) CtxDebugf added in v0.3.3 

func (mr *MockCtxLoggerMockRecorder) CtxDebugf(ctx, format interface{}, v ...interface{}) *gomock.Call

CtxDebugf indicates an expected call of CtxDebugf.

func (*MockCtxLoggerMockRecorder) CtxErrorf added in v0.3.3 

func (mr *MockCtxLoggerMockRecorder) CtxErrorf(ctx, format interface{}, v ...interface{}) *gomock.Call

CtxErrorf indicates an expected call of CtxErrorf.

func (*MockCtxLoggerMockRecorder) CtxFatalf added in v0.3.3 

func (mr *MockCtxLoggerMockRecorder) CtxFatalf(ctx, format interface{}, v ...interface{}) *gomock.Call

CtxFatalf indicates an expected call of CtxFatalf.

func (*MockCtxLoggerMockRecorder) CtxInfof added in v0.3.3 

func (mr *MockCtxLoggerMockRecorder) CtxInfof(ctx, format interface{}, v ...interface{}) *gomock.Call

CtxInfof indicates an expected call of CtxInfof.

func (*MockCtxLoggerMockRecorder) CtxNoticef added in v0.3.3 

func (mr *MockCtxLoggerMockRecorder) CtxNoticef(ctx, format interface{}, v ...interface{}) *gomock.Call

CtxNoticef indicates an expected call of CtxNoticef.

func (*MockCtxLoggerMockRecorder) CtxTracef added in v0.3.3 

func (mr *MockCtxLoggerMockRecorder) CtxTracef(ctx, format interface{}, v ...interface{}) *gomock.Call

CtxTracef indicates an expected call of CtxTracef.

func (*MockCtxLoggerMockRecorder) CtxWarnf added in v0.3.3 

func (mr *MockCtxLoggerMockRecorder) CtxWarnf(ctx, format interface{}, v ...interface{}) *gomock.Call

CtxWarnf indicates an expected call of CtxWarnf.

type MockDuplexBoundHandler added in v0.3.3 

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

MockDuplexBoundHandler is a mock of DuplexBoundHandler interface.

func NewMockDuplexBoundHandler added in v0.3.3 

func NewMockDuplexBoundHandler(ctrl *gomock.Controller) *MockDuplexBoundHandler

NewMockDuplexBoundHandler creates a new mock instance.

func (*MockDuplexBoundHandler) EXPECT added in v0.3.3 

func (m *MockDuplexBoundHandler) EXPECT() *MockDuplexBoundHandlerMockRecorder

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

func (*MockDuplexBoundHandler) OnActive added in v0.3.3 

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

OnActive mocks base method.

func (*MockDuplexBoundHandler) OnInactive added in v0.3.3 

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

OnInactive mocks base method.

func (*MockDuplexBoundHandler) OnMessage added in v0.3.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.3.3 

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

OnRead mocks base method.

func (*MockDuplexBoundHandler) Write added in v0.3.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.3.3 

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

MockDuplexBoundHandlerMockRecorder is the mock recorder for MockDuplexBoundHandler.

func (*MockDuplexBoundHandlerMockRecorder) OnActive added in v0.3.3 

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

OnActive indicates an expected call of OnActive.

func (*MockDuplexBoundHandlerMockRecorder) OnInactive added in v0.3.3 

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

OnInactive indicates an expected call of OnInactive.

func (*MockDuplexBoundHandlerMockRecorder) OnMessage added in v0.3.3 

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

OnMessage indicates an expected call of OnMessage.

func (*MockDuplexBoundHandlerMockRecorder) OnRead added in v0.3.3 

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

OnRead indicates an expected call of OnRead.

func (*MockDuplexBoundHandlerMockRecorder) Write added in v0.3.3 

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

Write indicates an expected call of Write.

type MockFormatLogger added in v0.3.3 

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

MockFormatLogger is a mock of FormatLogger interface.

func NewMockFormatLogger added in v0.3.3 

func NewMockFormatLogger(ctrl *gomock.Controller) *MockFormatLogger

NewMockFormatLogger creates a new mock instance.

func (*MockFormatLogger) Debugf added in v0.3.3 

func (m *MockFormatLogger) Debugf(format string, v ...interface{})

Debugf mocks base method.

func (*MockFormatLogger) EXPECT added in v0.3.3 

func (m *MockFormatLogger) EXPECT() *MockFormatLoggerMockRecorder

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

func (*MockFormatLogger) Errorf added in v0.3.3 

func (m *MockFormatLogger) Errorf(format string, v ...interface{})

Errorf mocks base method.

func (*MockFormatLogger) Fatalf added in v0.3.3 

func (m *MockFormatLogger) Fatalf(format string, v ...interface{})

Fatalf mocks base method.

func (*MockFormatLogger) Infof added in v0.3.3 

func (m *MockFormatLogger) Infof(format string, v ...interface{})

Infof mocks base method.

func (*MockFormatLogger) Noticef added in v0.3.3 

func (m *MockFormatLogger) Noticef(format string, v ...interface{})

Noticef mocks base method.

func (*MockFormatLogger) Tracef added in v0.3.3 

func (m *MockFormatLogger) Tracef(format string, v ...interface{})

Tracef mocks base method.

func (*MockFormatLogger) Warnf added in v0.3.3 

func (m *MockFormatLogger) Warnf(format string, v ...interface{})

Warnf mocks base method.

type MockFormatLoggerMockRecorder added in v0.3.3 

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

MockFormatLoggerMockRecorder is the mock recorder for MockFormatLogger.

func (*MockFormatLoggerMockRecorder) Debugf added in v0.3.3 

func (mr *MockFormatLoggerMockRecorder) Debugf(format interface{}, v ...interface{}) *gomock.Call

Debugf indicates an expected call of Debugf.

func (*MockFormatLoggerMockRecorder) Errorf added in v0.3.3 

func (mr *MockFormatLoggerMockRecorder) Errorf(format interface{}, v ...interface{}) *gomock.Call

Errorf indicates an expected call of Errorf.

func (*MockFormatLoggerMockRecorder) Fatalf added in v0.3.3 

func (mr *MockFormatLoggerMockRecorder) Fatalf(format interface{}, v ...interface{}) *gomock.Call

Fatalf indicates an expected call of Fatalf.

func (*MockFormatLoggerMockRecorder) Infof added in v0.3.3 

func (mr *MockFormatLoggerMockRecorder) Infof(format interface{}, v ...interface{}) *gomock.Call

Infof indicates an expected call of Infof.

func (*MockFormatLoggerMockRecorder) Noticef added in v0.3.3 

func (mr *MockFormatLoggerMockRecorder) Noticef(format interface{}, v ...interface{}) *gomock.Call

Noticef indicates an expected call of Noticef.

func (*MockFormatLoggerMockRecorder) Tracef added in v0.3.3 

func (mr *MockFormatLoggerMockRecorder) Tracef(format interface{}, v ...interface{}) *gomock.Call

Tracef indicates an expected call of Tracef.

func (*MockFormatLoggerMockRecorder) Warnf added in v0.3.3 

func (mr *MockFormatLoggerMockRecorder) Warnf(format interface{}, v ...interface{}) *gomock.Call

Warnf indicates an expected call of Warnf.

type MockFullLogger added in v0.3.3 

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

MockFullLogger is a mock of FullLogger interface.

func NewMockFullLogger added in v0.3.3 

func NewMockFullLogger(ctrl *gomock.Controller) *MockFullLogger

NewMockFullLogger creates a new mock instance.

func (*MockFullLogger) CtxDebugf added in v0.3.3 

func (m *MockFullLogger) CtxDebugf(ctx context.Context, format string, v ...interface{})

CtxDebugf mocks base method.

func (*MockFullLogger) CtxErrorf added in v0.3.3 

func (m *MockFullLogger) CtxErrorf(ctx context.Context, format string, v ...interface{})

CtxErrorf mocks base method.

func (*MockFullLogger) CtxFatalf added in v0.3.3 

func (m *MockFullLogger) CtxFatalf(ctx context.Context, format string, v ...interface{})

CtxFatalf mocks base method.

func (*MockFullLogger) CtxInfof added in v0.3.3 

func (m *MockFullLogger) CtxInfof(ctx context.Context, format string, v ...interface{})

CtxInfof mocks base method.

func (*MockFullLogger) CtxNoticef added in v0.3.3 

func (m *MockFullLogger) CtxNoticef(ctx context.Context, format string, v ...interface{})

CtxNoticef mocks base method.

func (*MockFullLogger) CtxTracef added in v0.3.3 

func (m *MockFullLogger) CtxTracef(ctx context.Context, format string, v ...interface{})

CtxTracef mocks base method.

func (*MockFullLogger) CtxWarnf added in v0.3.3 

func (m *MockFullLogger) CtxWarnf(ctx context.Context, format string, v ...interface{})

CtxWarnf mocks base method.

func (*MockFullLogger) Debug added in v0.3.3 

func (m *MockFullLogger) Debug(v ...interface{})

Debug mocks base method.

func (*MockFullLogger) Debugf added in v0.3.3 

func (m *MockFullLogger) Debugf(format string, v ...interface{})

Debugf mocks base method.

func (*MockFullLogger) EXPECT added in v0.3.3 

func (m *MockFullLogger) EXPECT() *MockFullLoggerMockRecorder

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

func (*MockFullLogger) Error added in v0.3.3 

func (m *MockFullLogger) Error(v ...interface{})

Error mocks base method.

func (*MockFullLogger) Errorf added in v0.3.3 

func (m *MockFullLogger) Errorf(format string, v ...interface{})

Errorf mocks base method.

func (*MockFullLogger) Fatal added in v0.3.3 

func (m *MockFullLogger) Fatal(v ...interface{})

Fatal mocks base method.

func (*MockFullLogger) Fatalf added in v0.3.3 

func (m *MockFullLogger) Fatalf(format string, v ...interface{})

Fatalf mocks base method.

func (*MockFullLogger) Info added in v0.3.3 

func (m *MockFullLogger) Info(v ...interface{})

Info mocks base method.

func (*MockFullLogger) Infof added in v0.3.3 

func (m *MockFullLogger) Infof(format string, v ...interface{})

Infof mocks base method.

func (*MockFullLogger) Notice added in v0.3.3 

func (m *MockFullLogger) Notice(v ...interface{})

Notice mocks base method.

func (*MockFullLogger) Noticef added in v0.3.3 

func (m *MockFullLogger) Noticef(format string, v ...interface{})

Noticef mocks base method.

func (*MockFullLogger) SetLevel added in v0.3.3 

func (m *MockFullLogger) SetLevel(arg0 klog.Level)

SetLevel mocks base method.

func (*MockFullLogger) SetOutput added in v0.3.3 

func (m *MockFullLogger) SetOutput(arg0 io.Writer)

SetOutput mocks base method.

func (*MockFullLogger) Trace added in v0.3.3 

func (m *MockFullLogger) Trace(v ...interface{})

Trace mocks base method.

func (*MockFullLogger) Tracef added in v0.3.3 

func (m *MockFullLogger) Tracef(format string, v ...interface{})

Tracef mocks base method.

func (*MockFullLogger) Warn added in v0.3.3 

func (m *MockFullLogger) Warn(v ...interface{})

Warn mocks base method.

func (*MockFullLogger) Warnf added in v0.3.3 

func (m *MockFullLogger) Warnf(format string, v ...interface{})

Warnf mocks base method.

type MockFullLoggerMockRecorder added in v0.3.3 

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

MockFullLoggerMockRecorder is the mock recorder for MockFullLogger.

func (*MockFullLoggerMockRecorder) CtxDebugf added in v0.3.3 

func (mr *MockFullLoggerMockRecorder) CtxDebugf(ctx, format interface{}, v ...interface{}) *gomock.Call

CtxDebugf indicates an expected call of CtxDebugf.

func (*MockFullLoggerMockRecorder) CtxErrorf added in v0.3.3 

func (mr *MockFullLoggerMockRecorder) CtxErrorf(ctx, format interface{}, v ...interface{}) *gomock.Call

CtxErrorf indicates an expected call of CtxErrorf.

func (*MockFullLoggerMockRecorder) CtxFatalf added in v0.3.3 

func (mr *MockFullLoggerMockRecorder) CtxFatalf(ctx, format interface{}, v ...interface{}) *gomock.Call

CtxFatalf indicates an expected call of CtxFatalf.

func (*MockFullLoggerMockRecorder) CtxInfof added in v0.3.3 

func (mr *MockFullLoggerMockRecorder) CtxInfof(ctx, format interface{}, v ...interface{}) *gomock.Call

CtxInfof indicates an expected call of CtxInfof.

func (*MockFullLoggerMockRecorder) CtxNoticef added in v0.3.3 

func (mr *MockFullLoggerMockRecorder) CtxNoticef(ctx, format interface{}, v ...interface{}) *gomock.Call

CtxNoticef indicates an expected call of CtxNoticef.

func (*MockFullLoggerMockRecorder) CtxTracef added in v0.3.3 

func (mr *MockFullLoggerMockRecorder) CtxTracef(ctx, format interface{}, v ...interface{}) *gomock.Call

CtxTracef indicates an expected call of CtxTracef.

func (*MockFullLoggerMockRecorder) CtxWarnf added in v0.3.3 

func (mr *MockFullLoggerMockRecorder) CtxWarnf(ctx, format interface{}, v ...interface{}) *gomock.Call

CtxWarnf indicates an expected call of CtxWarnf.

func (*MockFullLoggerMockRecorder) Debug added in v0.3.3 

func (mr *MockFullLoggerMockRecorder) Debug(v ...interface{}) *gomock.Call

Debug indicates an expected call of Debug.

func (*MockFullLoggerMockRecorder) Debugf added in v0.3.3 

func (mr *MockFullLoggerMockRecorder) Debugf(format interface{}, v ...interface{}) *gomock.Call

Debugf indicates an expected call of Debugf.

func (*MockFullLoggerMockRecorder) Error added in v0.3.3 

func (mr *MockFullLoggerMockRecorder) Error(v ...interface{}) *gomock.Call

Error indicates an expected call of Error.

func (*MockFullLoggerMockRecorder) Errorf added in v0.3.3 

func (mr *MockFullLoggerMockRecorder) Errorf(format interface{}, v ...interface{}) *gomock.Call

Errorf indicates an expected call of Errorf.

func (*MockFullLoggerMockRecorder) Fatal added in v0.3.3 

func (mr *MockFullLoggerMockRecorder) Fatal(v ...interface{}) *gomock.Call

Fatal indicates an expected call of Fatal.

func (*MockFullLoggerMockRecorder) Fatalf added in v0.3.3 

func (mr *MockFullLoggerMockRecorder) Fatalf(format interface{}, v ...interface{}) *gomock.Call

Fatalf indicates an expected call of Fatalf.

func (*MockFullLoggerMockRecorder) Info added in v0.3.3 

func (mr *MockFullLoggerMockRecorder) Info(v ...interface{}) *gomock.Call

Info indicates an expected call of Info.

func (*MockFullLoggerMockRecorder) Infof added in v0.3.3 

func (mr *MockFullLoggerMockRecorder) Infof(format interface{}, v ...interface{}) *gomock.Call

Infof indicates an expected call of Infof.

func (*MockFullLoggerMockRecorder) Notice added in v0.3.3 

func (mr *MockFullLoggerMockRecorder) Notice(v ...interface{}) *gomock.Call

Notice indicates an expected call of Notice.

func (*MockFullLoggerMockRecorder) Noticef added in v0.3.3 

func (mr *MockFullLoggerMockRecorder) Noticef(format interface{}, v ...interface{}) *gomock.Call

Noticef indicates an expected call of Noticef.

func (*MockFullLoggerMockRecorder) SetLevel added in v0.3.3 

func (mr *MockFullLoggerMockRecorder) SetLevel(arg0 interface{}) *gomock.Call

SetLevel indicates an expected call of SetLevel.

func (*MockFullLoggerMockRecorder) SetOutput added in v0.3.3 

func (mr *MockFullLoggerMockRecorder) SetOutput(arg0 interface{}) *gomock.Call

SetOutput indicates an expected call of SetOutput.

func (*MockFullLoggerMockRecorder) Trace added in v0.3.3 

func (mr *MockFullLoggerMockRecorder) Trace(v ...interface{}) *gomock.Call

Trace indicates an expected call of Trace.

func (*MockFullLoggerMockRecorder) Tracef added in v0.3.3 

func (mr *MockFullLoggerMockRecorder) Tracef(format interface{}, v ...interface{}) *gomock.Call

Tracef indicates an expected call of Tracef.

func (*MockFullLoggerMockRecorder) Warn added in v0.3.3 

func (mr *MockFullLoggerMockRecorder) Warn(v ...interface{}) *gomock.Call

Warn indicates an expected call of Warn.

func (*MockFullLoggerMockRecorder) Warnf added in v0.3.3 

func (mr *MockFullLoggerMockRecorder) Warnf(format interface{}, v ...interface{}) *gomock.Call

Warnf indicates an expected call of Warnf.

type MockInboundHandler added in v0.3.3 

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

MockInboundHandler is a mock of InboundHandler interface.

func NewMockInboundHandler added in v0.3.3 

func NewMockInboundHandler(ctrl *gomock.Controller) *MockInboundHandler

NewMockInboundHandler creates a new mock instance.

func (*MockInboundHandler) EXPECT added in v0.3.3 

func (m *MockInboundHandler) EXPECT() *MockInboundHandlerMockRecorder

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

func (*MockInboundHandler) OnActive added in v0.3.3 

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

OnActive mocks base method.

func (*MockInboundHandler) OnInactive added in v0.3.3 

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

OnInactive mocks base method.

func (*MockInboundHandler) OnMessage added in v0.3.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.3.3 

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

OnRead mocks base method.

type MockInboundHandlerMockRecorder added in v0.3.3 

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

MockInboundHandlerMockRecorder is the mock recorder for MockInboundHandler.

func (*MockInboundHandlerMockRecorder) OnActive added in v0.3.3 

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

OnActive indicates an expected call of OnActive.

func (*MockInboundHandlerMockRecorder) OnInactive added in v0.3.3 

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

OnInactive indicates an expected call of OnInactive.

func (*MockInboundHandlerMockRecorder) OnMessage added in v0.3.3 

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

OnMessage indicates an expected call of OnMessage.

func (*MockInboundHandlerMockRecorder) OnRead added in v0.3.3 

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

OnRead indicates an expected call of OnRead.

type MockLimitReporter added in v0.3.2 

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

MockLimitReporter is a mock of LimitReporter interface.

func NewMockLimitReporter added in v0.3.2 

func NewMockLimitReporter(ctrl *gomock.Controller) *MockLimitReporter

NewMockLimitReporter creates a new mock instance.

func (*MockLimitReporter) ConnOverloadReport added in v0.3.2 

func (m *MockLimitReporter) ConnOverloadReport()

ConnOverloadReport mocks base method.

func (*MockLimitReporter) EXPECT added in v0.3.2 

func (m *MockLimitReporter) EXPECT() *MockLimitReporterMockRecorder

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

func (*MockLimitReporter) QPSOverloadReport added in v0.3.2 

func (m *MockLimitReporter) QPSOverloadReport()

QPSOverloadReport mocks base method.

type MockLimitReporterMockRecorder added in v0.3.2 

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

MockLimitReporterMockRecorder is the mock recorder for MockLimitReporter.

func (*MockLimitReporterMockRecorder) ConnOverloadReport added in v0.3.2 

func (mr *MockLimitReporterMockRecorder) ConnOverloadReport() *gomock.Call

ConnOverloadReport indicates an expected call of ConnOverloadReport.

func (*MockLimitReporterMockRecorder) QPSOverloadReport added in v0.3.2 

func (mr *MockLimitReporterMockRecorder) QPSOverloadReport() *gomock.Call

QPSOverloadReport indicates an expected call of QPSOverloadReport.

type MockLogger added in v0.3.3 

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

MockLogger is a mock of Logger interface.

func NewMockLogger added in v0.3.3 

func NewMockLogger(ctrl *gomock.Controller) *MockLogger

NewMockLogger creates a new mock instance.

func (*MockLogger) Debug added in v0.3.3 

func (m *MockLogger) Debug(v ...interface{})

Debug mocks base method.

func (*MockLogger) EXPECT added in v0.3.3 

func (m *MockLogger) EXPECT() *MockLoggerMockRecorder

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

func (*MockLogger) Error added in v0.3.3 

func (m *MockLogger) Error(v ...interface{})

Error mocks base method.

func (*MockLogger) Fatal added in v0.3.3 

func (m *MockLogger) Fatal(v ...interface{})

Fatal mocks base method.

func (*MockLogger) Info added in v0.3.3 

func (m *MockLogger) Info(v ...interface{})

Info mocks base method.

func (*MockLogger) Notice added in v0.3.3 

func (m *MockLogger) Notice(v ...interface{})

Notice mocks base method.

func (*MockLogger) Trace added in v0.3.3 

func (m *MockLogger) Trace(v ...interface{})

Trace mocks base method.

func (*MockLogger) Warn added in v0.3.3 

func (m *MockLogger) Warn(v ...interface{})

Warn mocks base method.

type MockLoggerMockRecorder added in v0.3.3 

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

MockLoggerMockRecorder is the mock recorder for MockLogger.

func (*MockLoggerMockRecorder) Debug added in v0.3.3 

func (mr *MockLoggerMockRecorder) Debug(v ...interface{}) *gomock.Call

Debug indicates an expected call of Debug.

func (*MockLoggerMockRecorder) Error added in v0.3.3 

func (mr *MockLoggerMockRecorder) Error(v ...interface{}) *gomock.Call

Error indicates an expected call of Error.

func (*MockLoggerMockRecorder) Fatal added in v0.3.3 

func (mr *MockLoggerMockRecorder) Fatal(v ...interface{}) *gomock.Call

Fatal indicates an expected call of Fatal.

func (*MockLoggerMockRecorder) Info added in v0.3.3 

func (mr *MockLoggerMockRecorder) Info(v ...interface{}) *gomock.Call

Info indicates an expected call of Info.

func (*MockLoggerMockRecorder) Notice added in v0.3.3 

func (mr *MockLoggerMockRecorder) Notice(v ...interface{}) *gomock.Call

Notice indicates an expected call of Notice.

func (*MockLoggerMockRecorder) Trace added in v0.3.3 

func (mr *MockLoggerMockRecorder) Trace(v ...interface{}) *gomock.Call

Trace indicates an expected call of Trace.

func (*MockLoggerMockRecorder) Warn added in v0.3.3 

func (mr *MockLoggerMockRecorder) Warn(v ...interface{}) *gomock.Call

Warn indicates an expected call of Warn.

type MockMetaHandler added in v0.3.2 

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

MockMetaHandler is a mock of MetaHandler interface.

func NewMockMetaHandler added in v0.3.2 

func NewMockMetaHandler(ctrl *gomock.Controller) *MockMetaHandler

NewMockMetaHandler creates a new mock instance.

func (*MockMetaHandler) EXPECT added in v0.3.2 

func (m *MockMetaHandler) EXPECT() *MockMetaHandlerMockRecorder

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

func (*MockMetaHandler) ReadMeta added in v0.3.2 

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

ReadMeta mocks base method.

func (*MockMetaHandler) WriteMeta added in v0.3.2 

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

WriteMeta mocks base method.

type MockMetaHandlerMockRecorder added in v0.3.2 

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

MockMetaHandlerMockRecorder is the mock recorder for MockMetaHandler.

func (*MockMetaHandlerMockRecorder) ReadMeta added in v0.3.2 

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

ReadMeta indicates an expected call of ReadMeta.

func (*MockMetaHandlerMockRecorder) WriteMeta added in v0.3.2 

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

WriteMeta indicates an expected call of WriteMeta.

type MockOutboundHandler added in v0.3.3 

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

MockOutboundHandler is a mock of OutboundHandler interface.

func NewMockOutboundHandler added in v0.3.3 

func NewMockOutboundHandler(ctrl *gomock.Controller) *MockOutboundHandler

NewMockOutboundHandler creates a new mock instance.

func (*MockOutboundHandler) EXPECT added in v0.3.3 

func (m *MockOutboundHandler) EXPECT() *MockOutboundHandlerMockRecorder

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

func (*MockOutboundHandler) Write added in v0.3.3 

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.3.3 

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

MockOutboundHandlerMockRecorder is the mock recorder for MockOutboundHandler.

func (*MockOutboundHandlerMockRecorder) Write added in v0.3.3 

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

Write indicates an expected call of Write.

type MockRateLimiter added in v0.3.2 

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

MockRateLimiter is a mock of RateLimiter interface.

func NewMockRateLimiter added in v0.3.2 

func NewMockRateLimiter(ctrl *gomock.Controller) *MockRateLimiter

NewMockRateLimiter creates a new mock instance.

func (*MockRateLimiter) Acquire added in v0.3.2 

func (m *MockRateLimiter) Acquire(ctx context.Context) bool

Acquire mocks base method.

func (*MockRateLimiter) EXPECT added in v0.3.2 

func (m *MockRateLimiter) EXPECT() *MockRateLimiterMockRecorder

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

func (*MockRateLimiter) Status added in v0.3.2 

func (m *MockRateLimiter) Status(ctx context.Context) (int, int, time.Duration)

Status mocks base method.

type MockRateLimiterMockRecorder added in v0.3.2 

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

MockRateLimiterMockRecorder is the mock recorder for MockRateLimiter.

func (*MockRateLimiterMockRecorder) Acquire added in v0.3.2 

func (mr *MockRateLimiterMockRecorder) Acquire(ctx interface{}) *gomock.Call

Acquire indicates an expected call of Acquire.

func (*MockRateLimiterMockRecorder) Status added in v0.3.2 

func (mr *MockRateLimiterMockRecorder) Status(ctx interface{}) *gomock.Call

Status indicates an expected call of Status.

type MockStreamingMetaHandler added in v0.3.2 

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

MockStreamingMetaHandler is a mock of StreamingMetaHandler interface.

func NewMockStreamingMetaHandler added in v0.3.2 

func NewMockStreamingMetaHandler(ctrl *gomock.Controller) *MockStreamingMetaHandler

NewMockStreamingMetaHandler creates a new mock instance.

func (*MockStreamingMetaHandler) EXPECT added in v0.3.2 

func (m *MockStreamingMetaHandler) EXPECT() *MockStreamingMetaHandlerMockRecorder

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

func (*MockStreamingMetaHandler) OnConnectStream added in v0.3.2 

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

OnConnectStream mocks base method.

func (*MockStreamingMetaHandler) OnReadStream added in v0.3.2 

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

OnReadStream mocks base method.

type MockStreamingMetaHandlerMockRecorder added in v0.3.2 

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

MockStreamingMetaHandlerMockRecorder is the mock recorder for MockStreamingMetaHandler.

func (*MockStreamingMetaHandlerMockRecorder) OnConnectStream added in v0.3.2 

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

OnConnectStream indicates an expected call of OnConnectStream.

func (*MockStreamingMetaHandlerMockRecorder) OnReadStream added in v0.3.2 

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

OnReadStream indicates an expected call of OnReadStream.

type MockSvrTransHandler 

type MockSvrTransHandler struct {
	Opt *remote.ServerOption

	OnReadFunc func(ctx context.Context, conn net.Conn) error

	WriteFunc func(ctx context.Context, conn net.Conn, send remote.Message) error

	ReadFunc func(ctx context.Context, conn net.Conn, msg remote.Message) error
	// contains filtered or unexported fields
}

MockSvrTransHandler .

func (*MockSvrTransHandler) OnActive 

func (t *MockSvrTransHandler) OnActive(ctx context.Context, conn net.Conn) (context.Context, error)

OnActive implements the remote.TransHandler interface.

func (*MockSvrTransHandler) OnError 

func (t *MockSvrTransHandler) OnError(ctx context.Context, err error, conn net.Conn)

OnError implements the remote.TransHandler interface.

func (*MockSvrTransHandler) OnInactive 

func (t *MockSvrTransHandler) OnInactive(ctx context.Context, conn net.Conn)

OnInactive implements the remote.TransHandler interface.

func (*MockSvrTransHandler) OnMessage 

func (t *MockSvrTransHandler) OnMessage(ctx context.Context, args, result remote.Message) (context.Context, error)

OnMessage implements the remote.TransHandler interface.

func (*MockSvrTransHandler) OnRead 

func (t *MockSvrTransHandler) OnRead(ctx context.Context, conn net.Conn) (err error)

OnRead implements the remote.TransHandler interface.

func (*MockSvrTransHandler) Read 

func (t *MockSvrTransHandler) Read(ctx context.Context, conn net.Conn, msg remote.Message) (err error)

Read implements the remote.TransHandler interface.

func (*MockSvrTransHandler) SetPipeline 

func (t *MockSvrTransHandler) SetPipeline(p *remote.TransPipeline)

SetPipeline implements the remote.TransHandler interface.

func (*MockSvrTransHandler) Write 

func (t *MockSvrTransHandler) Write(ctx context.Context, conn net.Conn, send remote.Message) (err error)

Write implements the remote.TransHandler interface.

type MockThriftTTransport 

type MockThriftTTransport struct {
	WriteMessageBeginFunc func(name string, typeID thrift.TMessageType, seqID int32) error
	WriteMessageEndFunc   func() error
	WriteStructBeginFunc  func(name string) error
	WriteStructEndFunc    func() error
	WriteFieldBeginFunc   func(name string, typeID thrift.TType, id int16) error
	WriteFieldEndFunc     func() error
	WriteFieldStopFunc    func() error
	WriteMapBeginFunc     func(keyType, valueType thrift.TType, size int) error
	WriteMapEndFunc       func() error
	WriteListBeginFunc    func(elemType thrift.TType, size int) error
	WriteListEndFunc      func() error
	WriteSetBeginFunc     func(elemType thrift.TType, size int) error
	WriteSetEndFunc       func() error
	WriteBoolFunc         func(value bool) error
	WriteByteFunc         func(value int8) error
	WriteI16Func          func(value int16) error
	WriteI32Func          func(value int32) error
	WriteI64Func          func(value int64) error
	WriteDoubleFunc       func(value float64) error
	WriteStringFunc       func(value string) error
	WriteBinaryFunc       func(value []byte) error
	ReadMessageBeginFunc  func() (name string, typeID thrift.TMessageType, seqID int32, err error)
	ReadMessageEndFunc    func() error
	ReadStructBeginFunc   func() (name string, err error)
	ReadStructEndFunc     func() error
	ReadFieldBeginFunc    func() (name string, typeID thrift.TType, id int16, err error)
	ReadFieldEndFunc      func() error
	ReadMapBeginFunc      func() (keyType, valueType thrift.TType, size int, err error)
	ReadMapEndFunc        func() error
	ReadListBeginFunc     func() (elemType thrift.TType, size int, err error)
	ReadListEndFunc       func() error
	ReadSetBeginFunc      func() (elemType thrift.TType, size int, err error)
	ReadSetEndFunc        func() error
	ReadBoolFunc          func() (value bool, err error)
	ReadByteFunc          func() (value int8, err error)
	ReadI16Func           func() (value int16, err error)
	ReadI32Func           func() (value int32, err error)
	ReadI64Func           func() (value int64, err error)
	ReadDoubleFunc        func() (value float64, err error)
	ReadStringFunc        func() (value string, err error)
	ReadBinaryFunc        func() (value []byte, err error)
	SkipFunc              func(fieldType thrift.TType) (err error)
	FlushFunc             func(ctx context.Context) (err error)
	TransportFunc         func() thrift.TTransport
}

func (*MockThriftTTransport) Flush 

func (m *MockThriftTTransport) Flush(ctx context.Context) (err error)

func (*MockThriftTTransport) ReadBinary 

func (m *MockThriftTTransport) ReadBinary() (value []byte, err error)

func (*MockThriftTTransport) ReadBool 

func (m *MockThriftTTransport) ReadBool() (value bool, err error)

func (*MockThriftTTransport) ReadByte 

func (m *MockThriftTTransport) ReadByte() (value int8, err error)

func (*MockThriftTTransport) ReadDouble 

func (m *MockThriftTTransport) ReadDouble() (value float64, err error)

func (*MockThriftTTransport) ReadFieldBegin 

func (m *MockThriftTTransport) ReadFieldBegin() (name string, typeID thrift.TType, id int16, err error)

func (*MockThriftTTransport) ReadFieldEnd 

func (m *MockThriftTTransport) ReadFieldEnd() error

func (*MockThriftTTransport) ReadI16 

func (m *MockThriftTTransport) ReadI16() (value int16, err error)

func (*MockThriftTTransport) ReadI32 

func (m *MockThriftTTransport) ReadI32() (value int32, err error)

func (*MockThriftTTransport) ReadI64 

func (m *MockThriftTTransport) ReadI64() (value int64, err error)

func (*MockThriftTTransport) ReadListBegin 

func (m *MockThriftTTransport) ReadListBegin() (elemType thrift.TType, size int, err error)

func (*MockThriftTTransport) ReadListEnd 

func (m *MockThriftTTransport) ReadListEnd() error

func (*MockThriftTTransport) ReadMapBegin 

func (m *MockThriftTTransport) ReadMapBegin() (keyType, valueType thrift.TType, size int, err error)

func (*MockThriftTTransport) ReadMapEnd 

func (m *MockThriftTTransport) ReadMapEnd() error

func (*MockThriftTTransport) ReadMessageBegin 

func (m *MockThriftTTransport) ReadMessageBegin() (name string, typeID thrift.TMessageType, seqID int32, err error)

func (*MockThriftTTransport) ReadMessageEnd 

func (m *MockThriftTTransport) ReadMessageEnd() error

func (*MockThriftTTransport) ReadSetBegin 

func (m *MockThriftTTransport) ReadSetBegin() (elemType thrift.TType, size int, err error)

func (*MockThriftTTransport) ReadSetEnd 

func (m *MockThriftTTransport) ReadSetEnd() error

func (*MockThriftTTransport) ReadString 

func (m *MockThriftTTransport) ReadString() (value string, err error)

func (*MockThriftTTransport) ReadStructBegin 

func (m *MockThriftTTransport) ReadStructBegin() (name string, err error)

func (*MockThriftTTransport) ReadStructEnd 

func (m *MockThriftTTransport) ReadStructEnd() error

func (*MockThriftTTransport) Skip 

func (m *MockThriftTTransport) Skip(fieldType thrift.TType) (err error)

func (*MockThriftTTransport) Transport 

func (m *MockThriftTTransport) Transport() thrift.TTransport

func (*MockThriftTTransport) WriteBinary 

func (m *MockThriftTTransport) WriteBinary(value []byte) error

func (*MockThriftTTransport) WriteBool 

func (m *MockThriftTTransport) WriteBool(value bool) error

func (*MockThriftTTransport) WriteByte 

func (m *MockThriftTTransport) WriteByte(value int8) error

func (*MockThriftTTransport) WriteDouble 

func (m *MockThriftTTransport) WriteDouble(value float64) error

func (*MockThriftTTransport) WriteFieldBegin 

func (m *MockThriftTTransport) WriteFieldBegin(name string, typeID thrift.TType, id int16) error

func (*MockThriftTTransport) WriteFieldEnd 

func (m *MockThriftTTransport) WriteFieldEnd() error

func (*MockThriftTTransport) WriteFieldStop 

func (m *MockThriftTTransport) WriteFieldStop() error

func (*MockThriftTTransport) WriteI16 

func (m *MockThriftTTransport) WriteI16(value int16) error

func (*MockThriftTTransport) WriteI32 

func (m *MockThriftTTransport) WriteI32(value int32) error

func (*MockThriftTTransport) WriteI64 

func (m *MockThriftTTransport) WriteI64(value int64) error

func (*MockThriftTTransport) WriteListBegin 

func (m *MockThriftTTransport) WriteListBegin(elemType thrift.TType, size int) error

func (*MockThriftTTransport) WriteListEnd 

func (m *MockThriftTTransport) WriteListEnd() error

func (*MockThriftTTransport) WriteMapBegin 

func (m *MockThriftTTransport) WriteMapBegin(keyType, valueType thrift.TType, size int) error

func (*MockThriftTTransport) WriteMapEnd 

func (m *MockThriftTTransport) WriteMapEnd() error

func (*MockThriftTTransport) WriteMessageBegin 

func (m *MockThriftTTransport) WriteMessageBegin(name string, typeID thrift.TMessageType, seqID int32) error

func (*MockThriftTTransport) WriteMessageEnd 

func (m *MockThriftTTransport) WriteMessageEnd() error

func (*MockThriftTTransport) WriteSetBegin 

func (m *MockThriftTTransport) WriteSetBegin(elemType thrift.TType, size int) error

func (*MockThriftTTransport) WriteSetEnd 

func (m *MockThriftTTransport) WriteSetEnd() error

func (*MockThriftTTransport) WriteString 

func (m *MockThriftTTransport) WriteString(value string) error

func (*MockThriftTTransport) WriteStructBegin 

func (m *MockThriftTTransport) WriteStructBegin(name string) error

func (*MockThriftTTransport) WriteStructEnd 

func (m *MockThriftTTransport) WriteStructEnd() error

type MockTransServer 

type MockTransServer struct {
	CreateListenerFunc  func(net.Addr) (net.Listener, error)
	BootstrapServerFunc func(net.Listener) (err error)
	ShutdownFunc        func() (err error)
	ConnCountFunc       func() utils.AtomicInt
	// contains filtered or unexported fields
}

MockTransServer .

func (*MockTransServer) BootstrapServer 

func (t *MockTransServer) BootstrapServer(ln net.Listener) (err error)

BootstrapServer .

func (*MockTransServer) ConnCount 

func (t *MockTransServer) ConnCount() (r utils.AtomicInt)

ConnCount .

func (*MockTransServer) CreateListener 

func (t *MockTransServer) CreateListener(addr net.Addr) (ln net.Listener, err error)

CreateListener .

func (*MockTransServer) Shutdown 

func (t *MockTransServer) Shutdown() (err error)

Shutdown .

type MockTransServerFactory 

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

MockTransServerFactory .

func (*MockTransServerFactory) NewTransServer 

func (t *MockTransServerFactory) NewTransServer(opt *remote.ServerOption, transHdlr remote.ServerTransHandler) remote.TransServer

NewTransServer .

type MockUpdatable added in v0.3.2 

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

MockUpdatable is a mock of Updatable interface.

func NewMockUpdatable added in v0.3.2 

func NewMockUpdatable(ctrl *gomock.Controller) *MockUpdatable

NewMockUpdatable creates a new mock instance.

func (*MockUpdatable) EXPECT added in v0.3.2 

func (m *MockUpdatable) EXPECT() *MockUpdatableMockRecorder

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

func (*MockUpdatable) UpdateLimit added in v0.3.2 

func (m *MockUpdatable) UpdateLimit(limit int)

UpdateLimit mocks base method.

type MockUpdatableMockRecorder added in v0.3.2 

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

MockUpdatableMockRecorder is the mock recorder for MockUpdatable.

func (*MockUpdatableMockRecorder) UpdateLimit added in v0.3.2 

func (mr *MockUpdatableMockRecorder) UpdateLimit(limit interface{}) *gomock.Call

UpdateLimit indicates an expected call of UpdateLimit.

type MyException 

type MyException struct {
	Message string `thrift:"message,1" json:"message"`
}

MyException .

func (*MyException) Error 

func (p *MyException) Error() string

type MyRequest 

type MyRequest struct {
	Name string `thrift:"Name,1" json:"Name"`
}

MyRequest .

type MyResponse 

type MyResponse struct {
	Name string `thrift:"Name,1" json:"Name"`
}

MyResponse .

type MyService 

type MyService interface {
	Mock(ctx context.Context, req *MyRequest) (r *MyResponse, err error)
	MockException(ctx context.Context, req *MyRequest) (r *MyResponse, err error)
	MockError(ctx context.Context, req *MyRequest) (r *MyResponse, err error)
	MockOneway(ctx context.Context, req *MyRequest) (err error)
}

MyService .

Source Files

View all Source files

Directories

Path Synopsis
Package remote is a generated GoMock package.
 Package remote is a generated GoMock package.
Package mocks is a generated GoMock package.
 Package mocks is a generated GoMock package.
Package remote is a generated GoMock package.
 Package remote is a generated GoMock package.
Package rpc_info is a generated GoMock package.
 Package rpc_info is a generated GoMock package.

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.