mocks

package
v0.3.2 Latest Latest
Warning

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

 Go to latest Published: Jun 2, 2022 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Overview

Package mocks contains mocks of interfaces.

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 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 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 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 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() (err error)
	ShutdownFunc        func() (err error)
	ConnCountFunc       func() utils.AtomicInt
	// contains filtered or unexported fields
}

MockTransServer .

func (*MockTransServer) BootstrapServer 

func (t *MockTransServer) BootstrapServer() (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 mocks is a generated GoMock package.
 Package mocks 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.