Documentation ¶
Overview ¶
Package mock is a generated GoMock package.
Index ¶
- type MockRouterClient
- func (m *MockRouterClient) AllowMultishard() bool
- func (m *MockRouterClient) AssignRoute(r *route.Route) error
- func (m *MockRouterClient) AssignRule(rule *config.FrontendRule) error
- func (m *MockRouterClient) AssignServerConn(srv server.Server) error
- func (m *MockRouterClient) Auth(rt *route.Route) error
- func (m *MockRouterClient) AutoDistribution() string
- func (m *MockRouterClient) BindParamFormatCodes() []int16
- func (m *MockRouterClient) BindParams() [][]byte
- func (m *MockRouterClient) Cancel() error
- func (m *MockRouterClient) CancelMsg() *pgproto3.CancelRequest
- func (m *MockRouterClient) Close() error
- func (m *MockRouterClient) CommitActiveSet()
- func (m *MockRouterClient) ConstructClientParams() *pgproto3.Query
- func (m *MockRouterClient) DB() string
- func (m *MockRouterClient) DefaultReply() error
- func (m *MockRouterClient) DefaultRouteBehaviour() string
- func (m *MockRouterClient) Distribution() string
- func (m *MockRouterClient) DistributionKey() string
- func (m *MockRouterClient) EXPECT() *MockRouterClientMockRecorder
- func (m *MockRouterClient) ExecuteOn() string
- func (m *MockRouterClient) GetCancelKey() uint32
- func (m *MockRouterClient) GetCancelPid() uint32
- func (m *MockRouterClient) GetTsa() tsa.TSA
- func (m *MockRouterClient) ID() uint
- func (m *MockRouterClient) Init(cfg *tls.Config) error
- func (m *MockRouterClient) MaintainParams() bool
- func (m *MockRouterClient) Params() map[string]string
- func (m *MockRouterClient) PasswordCT() (string, error)
- func (m *MockRouterClient) PasswordMD5(salt [4]byte) (string, error)
- func (m *MockRouterClient) PreparedStatementDefinitionByName(name string) *prepstatement.PreparedStatementDefinition
- func (m *MockRouterClient) PreparedStatementQueryByName(name string) string
- func (m *MockRouterClient) PreparedStatementQueryHashByName(name string) uint64
- func (m *MockRouterClient) RLock()
- func (m *MockRouterClient) RUnlock()
- func (m *MockRouterClient) Receive() (pgproto3.FrontendMessage, error)
- func (m *MockRouterClient) ReceiveCtx(ctx context.Context) (pgproto3.FrontendMessage, error)
- func (m *MockRouterClient) Reply(msg string) error
- func (m *MockRouterClient) ReplyBindComplete() error
- func (m *MockRouterClient) ReplyCommandComplete(commandTag string) error
- func (m *MockRouterClient) ReplyDebugNotice(msg string) error
- func (m *MockRouterClient) ReplyDebugNoticef(fmt string, args ...interface{}) error
- func (m *MockRouterClient) ReplyErr(errmsg error) error
- func (m *MockRouterClient) ReplyErrMsg(e, c string) error
- func (m *MockRouterClient) ReplyErrMsgByCode(code string) error
- func (m *MockRouterClient) ReplyNotice(message string) error
- func (m *MockRouterClient) ReplyParseComplete() error
- func (m *MockRouterClient) ReplyRFQ(txstatus txstatus.TXStatus) error
- func (m *MockRouterClient) ReplyWarningMsg(msg string) error
- func (m *MockRouterClient) ReplyWarningf(fmt string, args ...interface{}) error
- func (m *MockRouterClient) Reset() error
- func (m *MockRouterClient) ResetAll()
- func (m *MockRouterClient) ResetParam(arg0 string)
- func (m *MockRouterClient) Rollback()
- func (m *MockRouterClient) RollbackToSP(arg0 string)
- func (m *MockRouterClient) Route() *route.Route
- func (m *MockRouterClient) RouteHint() routehint.RouteHint
- func (m *MockRouterClient) Rule() *config.FrontendRule
- func (m *MockRouterClient) Savepoint(arg0 string)
- func (m *MockRouterClient) Send(msg pgproto3.BackendMessage) error
- func (m *MockRouterClient) SendCtx(ctx context.Context, msg pgproto3.BackendMessage) error
- func (m *MockRouterClient) Server() server.Server
- func (m *MockRouterClient) ServerAcquireUse()
- func (m *MockRouterClient) ServerReleaseUse()
- func (m *MockRouterClient) SetAllowMultishard(arg0 bool)
- func (m *MockRouterClient) SetAuthType(arg0 uint32) error
- func (m *MockRouterClient) SetAutoDistribution(arg0 string)
- func (m *MockRouterClient) SetBindParams(arg0 [][]byte)
- func (m *MockRouterClient) SetDefaultRouteBehaviour(arg0 string)
- func (m *MockRouterClient) SetDistribution(arg0 string)
- func (m *MockRouterClient) SetDistributionKey(arg0 string)
- func (m *MockRouterClient) SetExecuteOn(arg0 string)
- func (m *MockRouterClient) SetMaintainParams(arg0 bool)
- func (m *MockRouterClient) SetParam(arg0, arg1 string)
- func (m *MockRouterClient) SetParamFormatCodes(arg0 []int16)
- func (m *MockRouterClient) SetRouteHint(arg0 routehint.RouteHint)
- func (m *MockRouterClient) SetShardingKey(arg0 string)
- func (m *MockRouterClient) SetShowNoticeMsg(arg0 bool)
- func (m *MockRouterClient) SetTsa(arg0 string)
- func (m *MockRouterClient) ShardingKey() string
- func (m *MockRouterClient) Shards() []shard.Shard
- func (m *MockRouterClient) ShowNoticeMsg() bool
- func (m *MockRouterClient) Shutdown() error
- func (m *MockRouterClient) StartTx()
- func (m *MockRouterClient) StartupMessage() *pgproto3.StartupMessage
- func (m *MockRouterClient) StorePreparedStatement(d *prepstatement.PreparedStatementDefinition)
- func (m *MockRouterClient) Unroute() error
- func (m *MockRouterClient) Usr() string
- type MockRouterClientMockRecorder
- func (mr *MockRouterClientMockRecorder) AllowMultishard() *gomock.Call
- func (mr *MockRouterClientMockRecorder) AssignRoute(r interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) AssignRule(rule interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) AssignServerConn(srv interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) Auth(rt interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) AutoDistribution() *gomock.Call
- func (mr *MockRouterClientMockRecorder) BindParamFormatCodes() *gomock.Call
- func (mr *MockRouterClientMockRecorder) BindParams() *gomock.Call
- func (mr *MockRouterClientMockRecorder) Cancel() *gomock.Call
- func (mr *MockRouterClientMockRecorder) CancelMsg() *gomock.Call
- func (mr *MockRouterClientMockRecorder) Close() *gomock.Call
- func (mr *MockRouterClientMockRecorder) CommitActiveSet() *gomock.Call
- func (mr *MockRouterClientMockRecorder) ConstructClientParams() *gomock.Call
- func (mr *MockRouterClientMockRecorder) DB() *gomock.Call
- func (mr *MockRouterClientMockRecorder) DefaultReply() *gomock.Call
- func (mr *MockRouterClientMockRecorder) DefaultRouteBehaviour() *gomock.Call
- func (mr *MockRouterClientMockRecorder) Distribution() *gomock.Call
- func (mr *MockRouterClientMockRecorder) DistributionKey() *gomock.Call
- func (mr *MockRouterClientMockRecorder) ExecuteOn() *gomock.Call
- func (mr *MockRouterClientMockRecorder) GetCancelKey() *gomock.Call
- func (mr *MockRouterClientMockRecorder) GetCancelPid() *gomock.Call
- func (mr *MockRouterClientMockRecorder) GetTsa() *gomock.Call
- func (mr *MockRouterClientMockRecorder) ID() *gomock.Call
- func (mr *MockRouterClientMockRecorder) Init(cfg interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) MaintainParams() *gomock.Call
- func (mr *MockRouterClientMockRecorder) Params() *gomock.Call
- func (mr *MockRouterClientMockRecorder) PasswordCT() *gomock.Call
- func (mr *MockRouterClientMockRecorder) PasswordMD5(salt interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) PreparedStatementDefinitionByName(name interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) PreparedStatementQueryByName(name interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) PreparedStatementQueryHashByName(name interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) RLock() *gomock.Call
- func (mr *MockRouterClientMockRecorder) RUnlock() *gomock.Call
- func (mr *MockRouterClientMockRecorder) Receive() *gomock.Call
- func (mr *MockRouterClientMockRecorder) ReceiveCtx(ctx interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) Reply(msg interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) ReplyBindComplete() *gomock.Call
- func (mr *MockRouterClientMockRecorder) ReplyCommandComplete(commandTag interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) ReplyDebugNotice(msg interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) ReplyDebugNoticef(fmt interface{}, args ...interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) ReplyErr(errmsg interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) ReplyErrMsg(e, c interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) ReplyErrMsgByCode(code interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) ReplyNotice(message interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) ReplyParseComplete() *gomock.Call
- func (mr *MockRouterClientMockRecorder) ReplyRFQ(txstatus interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) ReplyWarningMsg(msg interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) ReplyWarningf(fmt interface{}, args ...interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) Reset() *gomock.Call
- func (mr *MockRouterClientMockRecorder) ResetAll() *gomock.Call
- func (mr *MockRouterClientMockRecorder) ResetParam(arg0 interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) Rollback() *gomock.Call
- func (mr *MockRouterClientMockRecorder) RollbackToSP(arg0 interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) Route() *gomock.Call
- func (mr *MockRouterClientMockRecorder) RouteHint() *gomock.Call
- func (mr *MockRouterClientMockRecorder) Rule() *gomock.Call
- func (mr *MockRouterClientMockRecorder) Savepoint(arg0 interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) Send(msg interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) SendCtx(ctx, msg interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) Server() *gomock.Call
- func (mr *MockRouterClientMockRecorder) ServerAcquireUse() *gomock.Call
- func (mr *MockRouterClientMockRecorder) ServerReleaseUse() *gomock.Call
- func (mr *MockRouterClientMockRecorder) SetAllowMultishard(arg0 interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) SetAuthType(arg0 interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) SetAutoDistribution(arg0 interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) SetBindParams(arg0 interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) SetDefaultRouteBehaviour(arg0 interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) SetDistribution(arg0 interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) SetDistributionKey(arg0 interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) SetExecuteOn(arg0 interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) SetMaintainParams(arg0 interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) SetParam(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) SetParamFormatCodes(arg0 interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) SetRouteHint(arg0 interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) SetShardingKey(arg0 interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) SetShowNoticeMsg(arg0 interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) SetTsa(arg0 interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) ShardingKey() *gomock.Call
- func (mr *MockRouterClientMockRecorder) Shards() *gomock.Call
- func (mr *MockRouterClientMockRecorder) ShowNoticeMsg() *gomock.Call
- func (mr *MockRouterClientMockRecorder) Shutdown() *gomock.Call
- func (mr *MockRouterClientMockRecorder) StartTx() *gomock.Call
- func (mr *MockRouterClientMockRecorder) StartupMessage() *gomock.Call
- func (mr *MockRouterClientMockRecorder) StorePreparedStatement(d interface{}) *gomock.Call
- func (mr *MockRouterClientMockRecorder) Unroute() *gomock.Call
- func (mr *MockRouterClientMockRecorder) Usr() *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockRouterClient ¶
type MockRouterClient struct {
// contains filtered or unexported fields
}
MockRouterClient is a mock of RouterClient interface.
func NewMockRouterClient ¶
func NewMockRouterClient(ctrl *gomock.Controller) *MockRouterClient
NewMockRouterClient creates a new mock instance.
func (*MockRouterClient) AllowMultishard ¶
func (m *MockRouterClient) AllowMultishard() bool
AllowMultishard mocks base method.
func (*MockRouterClient) AssignRoute ¶
func (m *MockRouterClient) AssignRoute(r *route.Route) error
AssignRoute mocks base method.
func (*MockRouterClient) AssignRule ¶
func (m *MockRouterClient) AssignRule(rule *config.FrontendRule) error
AssignRule mocks base method.
func (*MockRouterClient) AssignServerConn ¶
func (m *MockRouterClient) AssignServerConn(srv server.Server) error
AssignServerConn mocks base method.
func (*MockRouterClient) Auth ¶
func (m *MockRouterClient) Auth(rt *route.Route) error
Auth mocks base method.
func (*MockRouterClient) AutoDistribution ¶
func (m *MockRouterClient) AutoDistribution() string
AutoDistribution mocks base method.
func (*MockRouterClient) BindParamFormatCodes ¶
func (m *MockRouterClient) BindParamFormatCodes() []int16
BindParamFormatCodes mocks base method.
func (*MockRouterClient) BindParams ¶
func (m *MockRouterClient) BindParams() [][]byte
BindParams mocks base method.
func (*MockRouterClient) Cancel ¶
func (m *MockRouterClient) Cancel() error
Cancel mocks base method.
func (*MockRouterClient) CancelMsg ¶
func (m *MockRouterClient) CancelMsg() *pgproto3.CancelRequest
CancelMsg mocks base method.
func (*MockRouterClient) CommitActiveSet ¶
func (m *MockRouterClient) CommitActiveSet()
CommitActiveSet mocks base method.
func (*MockRouterClient) ConstructClientParams ¶
func (m *MockRouterClient) ConstructClientParams() *pgproto3.Query
ConstructClientParams mocks base method.
func (*MockRouterClient) DefaultReply ¶
func (m *MockRouterClient) DefaultReply() error
DefaultReply mocks base method.
func (*MockRouterClient) DefaultRouteBehaviour ¶
func (m *MockRouterClient) DefaultRouteBehaviour() string
DefaultRouteBehaviour mocks base method.
func (*MockRouterClient) Distribution ¶
func (m *MockRouterClient) Distribution() string
Distribution mocks base method.
func (*MockRouterClient) DistributionKey ¶
func (m *MockRouterClient) DistributionKey() string
DistributionKey mocks base method.
func (*MockRouterClient) EXPECT ¶
func (m *MockRouterClient) EXPECT() *MockRouterClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockRouterClient) ExecuteOn ¶
func (m *MockRouterClient) ExecuteOn() string
ExecuteOn mocks base method.
func (*MockRouterClient) GetCancelKey ¶
func (m *MockRouterClient) GetCancelKey() uint32
GetCancelKey mocks base method.
func (*MockRouterClient) GetCancelPid ¶
func (m *MockRouterClient) GetCancelPid() uint32
GetCancelPid mocks base method.
func (*MockRouterClient) GetTsa ¶
func (m *MockRouterClient) GetTsa() tsa.TSA
GetTsa mocks base method.
func (*MockRouterClient) Init ¶
func (m *MockRouterClient) Init(cfg *tls.Config) error
Init mocks base method.
func (*MockRouterClient) MaintainParams ¶
func (m *MockRouterClient) MaintainParams() bool
MaintainParams mocks base method.
func (*MockRouterClient) Params ¶
func (m *MockRouterClient) Params() map[string]string
Params mocks base method.
func (*MockRouterClient) PasswordCT ¶
func (m *MockRouterClient) PasswordCT() (string, error)
PasswordCT mocks base method.
func (*MockRouterClient) PasswordMD5 ¶
func (m *MockRouterClient) PasswordMD5(salt [4]byte) (string, error)
PasswordMD5 mocks base method.
func (*MockRouterClient) PreparedStatementDefinitionByName ¶
func (m *MockRouterClient) PreparedStatementDefinitionByName(name string) *prepstatement.PreparedStatementDefinition
PreparedStatementDefinitionByName mocks base method.
func (*MockRouterClient) PreparedStatementQueryByName ¶
func (m *MockRouterClient) PreparedStatementQueryByName(name string) string
PreparedStatementQueryByName mocks base method.
func (*MockRouterClient) PreparedStatementQueryHashByName ¶
func (m *MockRouterClient) PreparedStatementQueryHashByName(name string) uint64
PreparedStatementQueryHashByName mocks base method.
func (*MockRouterClient) Receive ¶
func (m *MockRouterClient) Receive() (pgproto3.FrontendMessage, error)
Receive mocks base method.
func (*MockRouterClient) ReceiveCtx ¶
func (m *MockRouterClient) ReceiveCtx(ctx context.Context) (pgproto3.FrontendMessage, error)
ReceiveCtx mocks base method.
func (*MockRouterClient) Reply ¶
func (m *MockRouterClient) Reply(msg string) error
Reply mocks base method.
func (*MockRouterClient) ReplyBindComplete ¶
func (m *MockRouterClient) ReplyBindComplete() error
ReplyBindComplete mocks base method.
func (*MockRouterClient) ReplyCommandComplete ¶
func (m *MockRouterClient) ReplyCommandComplete(commandTag string) error
ReplyCommandComplete mocks base method.
func (*MockRouterClient) ReplyDebugNotice ¶
func (m *MockRouterClient) ReplyDebugNotice(msg string) error
ReplyDebugNotice mocks base method.
func (*MockRouterClient) ReplyDebugNoticef ¶
func (m *MockRouterClient) ReplyDebugNoticef(fmt string, args ...interface{}) error
ReplyDebugNoticef mocks base method.
func (*MockRouterClient) ReplyErr ¶
func (m *MockRouterClient) ReplyErr(errmsg error) error
ReplyErr mocks base method.
func (*MockRouterClient) ReplyErrMsg ¶
func (m *MockRouterClient) ReplyErrMsg(e, c string) error
ReplyErrMsg mocks base method.
func (*MockRouterClient) ReplyErrMsgByCode ¶
func (m *MockRouterClient) ReplyErrMsgByCode(code string) error
ReplyErrMsgByCode mocks base method.
func (*MockRouterClient) ReplyNotice ¶
func (m *MockRouterClient) ReplyNotice(message string) error
ReplyNotice mocks base method.
func (*MockRouterClient) ReplyParseComplete ¶
func (m *MockRouterClient) ReplyParseComplete() error
ReplyParseComplete mocks base method.
func (*MockRouterClient) ReplyRFQ ¶
func (m *MockRouterClient) ReplyRFQ(txstatus txstatus.TXStatus) error
ReplyRFQ mocks base method.
func (*MockRouterClient) ReplyWarningMsg ¶
func (m *MockRouterClient) ReplyWarningMsg(msg string) error
ReplyWarningMsg mocks base method.
func (*MockRouterClient) ReplyWarningf ¶
func (m *MockRouterClient) ReplyWarningf(fmt string, args ...interface{}) error
ReplyWarningf mocks base method.
func (*MockRouterClient) ResetAll ¶
func (m *MockRouterClient) ResetAll()
ResetAll mocks base method.
func (*MockRouterClient) ResetParam ¶
func (m *MockRouterClient) ResetParam(arg0 string)
ResetParam mocks base method.
func (*MockRouterClient) Rollback ¶
func (m *MockRouterClient) Rollback()
Rollback mocks base method.
func (*MockRouterClient) RollbackToSP ¶
func (m *MockRouterClient) RollbackToSP(arg0 string)
RollbackToSP mocks base method.
func (*MockRouterClient) Route ¶
func (m *MockRouterClient) Route() *route.Route
Route mocks base method.
func (*MockRouterClient) RouteHint ¶
func (m *MockRouterClient) RouteHint() routehint.RouteHint
RouteHint mocks base method.
func (*MockRouterClient) Rule ¶
func (m *MockRouterClient) Rule() *config.FrontendRule
Rule mocks base method.
func (*MockRouterClient) Savepoint ¶
func (m *MockRouterClient) Savepoint(arg0 string)
Savepoint mocks base method.
func (*MockRouterClient) Send ¶
func (m *MockRouterClient) Send(msg pgproto3.BackendMessage) error
Send mocks base method.
func (*MockRouterClient) SendCtx ¶
func (m *MockRouterClient) SendCtx(ctx context.Context, msg pgproto3.BackendMessage) error
SendCtx mocks base method.
func (*MockRouterClient) Server ¶
func (m *MockRouterClient) Server() server.Server
Server mocks base method.
func (*MockRouterClient) ServerAcquireUse ¶
func (m *MockRouterClient) ServerAcquireUse()
ServerAcquireUse mocks base method.
func (*MockRouterClient) ServerReleaseUse ¶
func (m *MockRouterClient) ServerReleaseUse()
ServerReleaseUse mocks base method.
func (*MockRouterClient) SetAllowMultishard ¶
func (m *MockRouterClient) SetAllowMultishard(arg0 bool)
SetAllowMultishard mocks base method.
func (*MockRouterClient) SetAuthType ¶
func (m *MockRouterClient) SetAuthType(arg0 uint32) error
SetAuthType mocks base method.
func (*MockRouterClient) SetAutoDistribution ¶
func (m *MockRouterClient) SetAutoDistribution(arg0 string)
SetAutoDistribution mocks base method.
func (*MockRouterClient) SetBindParams ¶
func (m *MockRouterClient) SetBindParams(arg0 [][]byte)
SetBindParams mocks base method.
func (*MockRouterClient) SetDefaultRouteBehaviour ¶
func (m *MockRouterClient) SetDefaultRouteBehaviour(arg0 string)
SetDefaultRouteBehaviour mocks base method.
func (*MockRouterClient) SetDistribution ¶
func (m *MockRouterClient) SetDistribution(arg0 string)
SetDistribution mocks base method.
func (*MockRouterClient) SetDistributionKey ¶
func (m *MockRouterClient) SetDistributionKey(arg0 string)
SetDistributionKey mocks base method.
func (*MockRouterClient) SetExecuteOn ¶
func (m *MockRouterClient) SetExecuteOn(arg0 string)
SetExecuteOn mocks base method.
func (*MockRouterClient) SetMaintainParams ¶
func (m *MockRouterClient) SetMaintainParams(arg0 bool)
SetMaintainParams mocks base method.
func (*MockRouterClient) SetParam ¶
func (m *MockRouterClient) SetParam(arg0, arg1 string)
SetParam mocks base method.
func (*MockRouterClient) SetParamFormatCodes ¶
func (m *MockRouterClient) SetParamFormatCodes(arg0 []int16)
SetParamFormatCodes mocks base method.
func (*MockRouterClient) SetRouteHint ¶
func (m *MockRouterClient) SetRouteHint(arg0 routehint.RouteHint)
SetRouteHint mocks base method.
func (*MockRouterClient) SetShardingKey ¶
func (m *MockRouterClient) SetShardingKey(arg0 string)
SetShardingKey mocks base method.
func (*MockRouterClient) SetShowNoticeMsg ¶
func (m *MockRouterClient) SetShowNoticeMsg(arg0 bool)
SetShowNoticeMsg mocks base method.
func (*MockRouterClient) SetTsa ¶
func (m *MockRouterClient) SetTsa(arg0 string)
SetTsa mocks base method.
func (*MockRouterClient) ShardingKey ¶
func (m *MockRouterClient) ShardingKey() string
ShardingKey mocks base method.
func (*MockRouterClient) Shards ¶
func (m *MockRouterClient) Shards() []shard.Shard
Shards mocks base method.
func (*MockRouterClient) ShowNoticeMsg ¶
func (m *MockRouterClient) ShowNoticeMsg() bool
ShowNoticeMsg mocks base method.
func (*MockRouterClient) Shutdown ¶
func (m *MockRouterClient) Shutdown() error
Shutdown mocks base method.
func (*MockRouterClient) StartupMessage ¶
func (m *MockRouterClient) StartupMessage() *pgproto3.StartupMessage
StartupMessage mocks base method.
func (*MockRouterClient) StorePreparedStatement ¶
func (m *MockRouterClient) StorePreparedStatement(d *prepstatement.PreparedStatementDefinition)
StorePreparedStatement mocks base method.
func (*MockRouterClient) Unroute ¶
func (m *MockRouterClient) Unroute() error
Unroute mocks base method.
type MockRouterClientMockRecorder ¶
type MockRouterClientMockRecorder struct {
// contains filtered or unexported fields
}
MockRouterClientMockRecorder is the mock recorder for MockRouterClient.
func (*MockRouterClientMockRecorder) AllowMultishard ¶
func (mr *MockRouterClientMockRecorder) AllowMultishard() *gomock.Call
AllowMultishard indicates an expected call of AllowMultishard.
func (*MockRouterClientMockRecorder) AssignRoute ¶
func (mr *MockRouterClientMockRecorder) AssignRoute(r interface{}) *gomock.Call
AssignRoute indicates an expected call of AssignRoute.
func (*MockRouterClientMockRecorder) AssignRule ¶
func (mr *MockRouterClientMockRecorder) AssignRule(rule interface{}) *gomock.Call
AssignRule indicates an expected call of AssignRule.
func (*MockRouterClientMockRecorder) AssignServerConn ¶
func (mr *MockRouterClientMockRecorder) AssignServerConn(srv interface{}) *gomock.Call
AssignServerConn indicates an expected call of AssignServerConn.
func (*MockRouterClientMockRecorder) Auth ¶
func (mr *MockRouterClientMockRecorder) Auth(rt interface{}) *gomock.Call
Auth indicates an expected call of Auth.
func (*MockRouterClientMockRecorder) AutoDistribution ¶
func (mr *MockRouterClientMockRecorder) AutoDistribution() *gomock.Call
AutoDistribution indicates an expected call of AutoDistribution.
func (*MockRouterClientMockRecorder) BindParamFormatCodes ¶
func (mr *MockRouterClientMockRecorder) BindParamFormatCodes() *gomock.Call
BindParamFormatCodes indicates an expected call of BindParamFormatCodes.
func (*MockRouterClientMockRecorder) BindParams ¶
func (mr *MockRouterClientMockRecorder) BindParams() *gomock.Call
BindParams indicates an expected call of BindParams.
func (*MockRouterClientMockRecorder) Cancel ¶
func (mr *MockRouterClientMockRecorder) Cancel() *gomock.Call
Cancel indicates an expected call of Cancel.
func (*MockRouterClientMockRecorder) CancelMsg ¶
func (mr *MockRouterClientMockRecorder) CancelMsg() *gomock.Call
CancelMsg indicates an expected call of CancelMsg.
func (*MockRouterClientMockRecorder) Close ¶
func (mr *MockRouterClientMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockRouterClientMockRecorder) CommitActiveSet ¶
func (mr *MockRouterClientMockRecorder) CommitActiveSet() *gomock.Call
CommitActiveSet indicates an expected call of CommitActiveSet.
func (*MockRouterClientMockRecorder) ConstructClientParams ¶
func (mr *MockRouterClientMockRecorder) ConstructClientParams() *gomock.Call
ConstructClientParams indicates an expected call of ConstructClientParams.
func (*MockRouterClientMockRecorder) DB ¶
func (mr *MockRouterClientMockRecorder) DB() *gomock.Call
DB indicates an expected call of DB.
func (*MockRouterClientMockRecorder) DefaultReply ¶
func (mr *MockRouterClientMockRecorder) DefaultReply() *gomock.Call
DefaultReply indicates an expected call of DefaultReply.
func (*MockRouterClientMockRecorder) DefaultRouteBehaviour ¶
func (mr *MockRouterClientMockRecorder) DefaultRouteBehaviour() *gomock.Call
DefaultRouteBehaviour indicates an expected call of DefaultRouteBehaviour.
func (*MockRouterClientMockRecorder) Distribution ¶
func (mr *MockRouterClientMockRecorder) Distribution() *gomock.Call
Distribution indicates an expected call of Distribution.
func (*MockRouterClientMockRecorder) DistributionKey ¶
func (mr *MockRouterClientMockRecorder) DistributionKey() *gomock.Call
DistributionKey indicates an expected call of DistributionKey.
func (*MockRouterClientMockRecorder) ExecuteOn ¶
func (mr *MockRouterClientMockRecorder) ExecuteOn() *gomock.Call
ExecuteOn indicates an expected call of ExecuteOn.
func (*MockRouterClientMockRecorder) GetCancelKey ¶
func (mr *MockRouterClientMockRecorder) GetCancelKey() *gomock.Call
GetCancelKey indicates an expected call of GetCancelKey.
func (*MockRouterClientMockRecorder) GetCancelPid ¶
func (mr *MockRouterClientMockRecorder) GetCancelPid() *gomock.Call
GetCancelPid indicates an expected call of GetCancelPid.
func (*MockRouterClientMockRecorder) GetTsa ¶
func (mr *MockRouterClientMockRecorder) GetTsa() *gomock.Call
GetTsa indicates an expected call of GetTsa.
func (*MockRouterClientMockRecorder) ID ¶
func (mr *MockRouterClientMockRecorder) ID() *gomock.Call
ID indicates an expected call of ID.
func (*MockRouterClientMockRecorder) Init ¶
func (mr *MockRouterClientMockRecorder) Init(cfg interface{}) *gomock.Call
Init indicates an expected call of Init.
func (*MockRouterClientMockRecorder) MaintainParams ¶
func (mr *MockRouterClientMockRecorder) MaintainParams() *gomock.Call
MaintainParams indicates an expected call of MaintainParams.
func (*MockRouterClientMockRecorder) Params ¶
func (mr *MockRouterClientMockRecorder) Params() *gomock.Call
Params indicates an expected call of Params.
func (*MockRouterClientMockRecorder) PasswordCT ¶
func (mr *MockRouterClientMockRecorder) PasswordCT() *gomock.Call
PasswordCT indicates an expected call of PasswordCT.
func (*MockRouterClientMockRecorder) PasswordMD5 ¶
func (mr *MockRouterClientMockRecorder) PasswordMD5(salt interface{}) *gomock.Call
PasswordMD5 indicates an expected call of PasswordMD5.
func (*MockRouterClientMockRecorder) PreparedStatementDefinitionByName ¶
func (mr *MockRouterClientMockRecorder) PreparedStatementDefinitionByName(name interface{}) *gomock.Call
PreparedStatementDefinitionByName indicates an expected call of PreparedStatementDefinitionByName.
func (*MockRouterClientMockRecorder) PreparedStatementQueryByName ¶
func (mr *MockRouterClientMockRecorder) PreparedStatementQueryByName(name interface{}) *gomock.Call
PreparedStatementQueryByName indicates an expected call of PreparedStatementQueryByName.
func (*MockRouterClientMockRecorder) PreparedStatementQueryHashByName ¶
func (mr *MockRouterClientMockRecorder) PreparedStatementQueryHashByName(name interface{}) *gomock.Call
PreparedStatementQueryHashByName indicates an expected call of PreparedStatementQueryHashByName.
func (*MockRouterClientMockRecorder) RLock ¶
func (mr *MockRouterClientMockRecorder) RLock() *gomock.Call
RLock indicates an expected call of RLock.
func (*MockRouterClientMockRecorder) RUnlock ¶
func (mr *MockRouterClientMockRecorder) RUnlock() *gomock.Call
RUnlock indicates an expected call of RUnlock.
func (*MockRouterClientMockRecorder) Receive ¶
func (mr *MockRouterClientMockRecorder) Receive() *gomock.Call
Receive indicates an expected call of Receive.
func (*MockRouterClientMockRecorder) ReceiveCtx ¶
func (mr *MockRouterClientMockRecorder) ReceiveCtx(ctx interface{}) *gomock.Call
ReceiveCtx indicates an expected call of ReceiveCtx.
func (*MockRouterClientMockRecorder) Reply ¶
func (mr *MockRouterClientMockRecorder) Reply(msg interface{}) *gomock.Call
Reply indicates an expected call of Reply.
func (*MockRouterClientMockRecorder) ReplyBindComplete ¶
func (mr *MockRouterClientMockRecorder) ReplyBindComplete() *gomock.Call
ReplyBindComplete indicates an expected call of ReplyBindComplete.
func (*MockRouterClientMockRecorder) ReplyCommandComplete ¶
func (mr *MockRouterClientMockRecorder) ReplyCommandComplete(commandTag interface{}) *gomock.Call
ReplyCommandComplete indicates an expected call of ReplyCommandComplete.
func (*MockRouterClientMockRecorder) ReplyDebugNotice ¶
func (mr *MockRouterClientMockRecorder) ReplyDebugNotice(msg interface{}) *gomock.Call
ReplyDebugNotice indicates an expected call of ReplyDebugNotice.
func (*MockRouterClientMockRecorder) ReplyDebugNoticef ¶
func (mr *MockRouterClientMockRecorder) ReplyDebugNoticef(fmt interface{}, args ...interface{}) *gomock.Call
ReplyDebugNoticef indicates an expected call of ReplyDebugNoticef.
func (*MockRouterClientMockRecorder) ReplyErr ¶
func (mr *MockRouterClientMockRecorder) ReplyErr(errmsg interface{}) *gomock.Call
ReplyErr indicates an expected call of ReplyErr.
func (*MockRouterClientMockRecorder) ReplyErrMsg ¶
func (mr *MockRouterClientMockRecorder) ReplyErrMsg(e, c interface{}) *gomock.Call
ReplyErrMsg indicates an expected call of ReplyErrMsg.
func (*MockRouterClientMockRecorder) ReplyErrMsgByCode ¶
func (mr *MockRouterClientMockRecorder) ReplyErrMsgByCode(code interface{}) *gomock.Call
ReplyErrMsgByCode indicates an expected call of ReplyErrMsgByCode.
func (*MockRouterClientMockRecorder) ReplyNotice ¶
func (mr *MockRouterClientMockRecorder) ReplyNotice(message interface{}) *gomock.Call
ReplyNotice indicates an expected call of ReplyNotice.
func (*MockRouterClientMockRecorder) ReplyParseComplete ¶
func (mr *MockRouterClientMockRecorder) ReplyParseComplete() *gomock.Call
ReplyParseComplete indicates an expected call of ReplyParseComplete.
func (*MockRouterClientMockRecorder) ReplyRFQ ¶
func (mr *MockRouterClientMockRecorder) ReplyRFQ(txstatus interface{}) *gomock.Call
ReplyRFQ indicates an expected call of ReplyRFQ.
func (*MockRouterClientMockRecorder) ReplyWarningMsg ¶
func (mr *MockRouterClientMockRecorder) ReplyWarningMsg(msg interface{}) *gomock.Call
ReplyWarningMsg indicates an expected call of ReplyWarningMsg.
func (*MockRouterClientMockRecorder) ReplyWarningf ¶
func (mr *MockRouterClientMockRecorder) ReplyWarningf(fmt interface{}, args ...interface{}) *gomock.Call
ReplyWarningf indicates an expected call of ReplyWarningf.
func (*MockRouterClientMockRecorder) Reset ¶
func (mr *MockRouterClientMockRecorder) Reset() *gomock.Call
Reset indicates an expected call of Reset.
func (*MockRouterClientMockRecorder) ResetAll ¶
func (mr *MockRouterClientMockRecorder) ResetAll() *gomock.Call
ResetAll indicates an expected call of ResetAll.
func (*MockRouterClientMockRecorder) ResetParam ¶
func (mr *MockRouterClientMockRecorder) ResetParam(arg0 interface{}) *gomock.Call
ResetParam indicates an expected call of ResetParam.
func (*MockRouterClientMockRecorder) Rollback ¶
func (mr *MockRouterClientMockRecorder) Rollback() *gomock.Call
Rollback indicates an expected call of Rollback.
func (*MockRouterClientMockRecorder) RollbackToSP ¶
func (mr *MockRouterClientMockRecorder) RollbackToSP(arg0 interface{}) *gomock.Call
RollbackToSP indicates an expected call of RollbackToSP.
func (*MockRouterClientMockRecorder) Route ¶
func (mr *MockRouterClientMockRecorder) Route() *gomock.Call
Route indicates an expected call of Route.
func (*MockRouterClientMockRecorder) RouteHint ¶
func (mr *MockRouterClientMockRecorder) RouteHint() *gomock.Call
RouteHint indicates an expected call of RouteHint.
func (*MockRouterClientMockRecorder) Rule ¶
func (mr *MockRouterClientMockRecorder) Rule() *gomock.Call
Rule indicates an expected call of Rule.
func (*MockRouterClientMockRecorder) Savepoint ¶
func (mr *MockRouterClientMockRecorder) Savepoint(arg0 interface{}) *gomock.Call
Savepoint indicates an expected call of Savepoint.
func (*MockRouterClientMockRecorder) Send ¶
func (mr *MockRouterClientMockRecorder) Send(msg interface{}) *gomock.Call
Send indicates an expected call of Send.
func (*MockRouterClientMockRecorder) SendCtx ¶
func (mr *MockRouterClientMockRecorder) SendCtx(ctx, msg interface{}) *gomock.Call
SendCtx indicates an expected call of SendCtx.
func (*MockRouterClientMockRecorder) Server ¶
func (mr *MockRouterClientMockRecorder) Server() *gomock.Call
Server indicates an expected call of Server.
func (*MockRouterClientMockRecorder) ServerAcquireUse ¶
func (mr *MockRouterClientMockRecorder) ServerAcquireUse() *gomock.Call
ServerAcquireUse indicates an expected call of ServerAcquireUse.
func (*MockRouterClientMockRecorder) ServerReleaseUse ¶
func (mr *MockRouterClientMockRecorder) ServerReleaseUse() *gomock.Call
ServerReleaseUse indicates an expected call of ServerReleaseUse.
func (*MockRouterClientMockRecorder) SetAllowMultishard ¶
func (mr *MockRouterClientMockRecorder) SetAllowMultishard(arg0 interface{}) *gomock.Call
SetAllowMultishard indicates an expected call of SetAllowMultishard.
func (*MockRouterClientMockRecorder) SetAuthType ¶
func (mr *MockRouterClientMockRecorder) SetAuthType(arg0 interface{}) *gomock.Call
SetAuthType indicates an expected call of SetAuthType.
func (*MockRouterClientMockRecorder) SetAutoDistribution ¶
func (mr *MockRouterClientMockRecorder) SetAutoDistribution(arg0 interface{}) *gomock.Call
SetAutoDistribution indicates an expected call of SetAutoDistribution.
func (*MockRouterClientMockRecorder) SetBindParams ¶
func (mr *MockRouterClientMockRecorder) SetBindParams(arg0 interface{}) *gomock.Call
SetBindParams indicates an expected call of SetBindParams.
func (*MockRouterClientMockRecorder) SetDefaultRouteBehaviour ¶
func (mr *MockRouterClientMockRecorder) SetDefaultRouteBehaviour(arg0 interface{}) *gomock.Call
SetDefaultRouteBehaviour indicates an expected call of SetDefaultRouteBehaviour.
func (*MockRouterClientMockRecorder) SetDistribution ¶
func (mr *MockRouterClientMockRecorder) SetDistribution(arg0 interface{}) *gomock.Call
SetDistribution indicates an expected call of SetDistribution.
func (*MockRouterClientMockRecorder) SetDistributionKey ¶
func (mr *MockRouterClientMockRecorder) SetDistributionKey(arg0 interface{}) *gomock.Call
SetDistributionKey indicates an expected call of SetDistributionKey.
func (*MockRouterClientMockRecorder) SetExecuteOn ¶
func (mr *MockRouterClientMockRecorder) SetExecuteOn(arg0 interface{}) *gomock.Call
SetExecuteOn indicates an expected call of SetExecuteOn.
func (*MockRouterClientMockRecorder) SetMaintainParams ¶
func (mr *MockRouterClientMockRecorder) SetMaintainParams(arg0 interface{}) *gomock.Call
SetMaintainParams indicates an expected call of SetMaintainParams.
func (*MockRouterClientMockRecorder) SetParam ¶
func (mr *MockRouterClientMockRecorder) SetParam(arg0, arg1 interface{}) *gomock.Call
SetParam indicates an expected call of SetParam.
func (*MockRouterClientMockRecorder) SetParamFormatCodes ¶
func (mr *MockRouterClientMockRecorder) SetParamFormatCodes(arg0 interface{}) *gomock.Call
SetParamFormatCodes indicates an expected call of SetParamFormatCodes.
func (*MockRouterClientMockRecorder) SetRouteHint ¶
func (mr *MockRouterClientMockRecorder) SetRouteHint(arg0 interface{}) *gomock.Call
SetRouteHint indicates an expected call of SetRouteHint.
func (*MockRouterClientMockRecorder) SetShardingKey ¶
func (mr *MockRouterClientMockRecorder) SetShardingKey(arg0 interface{}) *gomock.Call
SetShardingKey indicates an expected call of SetShardingKey.
func (*MockRouterClientMockRecorder) SetShowNoticeMsg ¶
func (mr *MockRouterClientMockRecorder) SetShowNoticeMsg(arg0 interface{}) *gomock.Call
SetShowNoticeMsg indicates an expected call of SetShowNoticeMsg.
func (*MockRouterClientMockRecorder) SetTsa ¶
func (mr *MockRouterClientMockRecorder) SetTsa(arg0 interface{}) *gomock.Call
SetTsa indicates an expected call of SetTsa.
func (*MockRouterClientMockRecorder) ShardingKey ¶
func (mr *MockRouterClientMockRecorder) ShardingKey() *gomock.Call
ShardingKey indicates an expected call of ShardingKey.
func (*MockRouterClientMockRecorder) Shards ¶
func (mr *MockRouterClientMockRecorder) Shards() *gomock.Call
Shards indicates an expected call of Shards.
func (*MockRouterClientMockRecorder) ShowNoticeMsg ¶
func (mr *MockRouterClientMockRecorder) ShowNoticeMsg() *gomock.Call
ShowNoticeMsg indicates an expected call of ShowNoticeMsg.
func (*MockRouterClientMockRecorder) Shutdown ¶
func (mr *MockRouterClientMockRecorder) Shutdown() *gomock.Call
Shutdown indicates an expected call of Shutdown.
func (*MockRouterClientMockRecorder) StartTx ¶
func (mr *MockRouterClientMockRecorder) StartTx() *gomock.Call
StartTx indicates an expected call of StartTx.
func (*MockRouterClientMockRecorder) StartupMessage ¶
func (mr *MockRouterClientMockRecorder) StartupMessage() *gomock.Call
StartupMessage indicates an expected call of StartupMessage.
func (*MockRouterClientMockRecorder) StorePreparedStatement ¶
func (mr *MockRouterClientMockRecorder) StorePreparedStatement(d interface{}) *gomock.Call
StorePreparedStatement indicates an expected call of StorePreparedStatement.
func (*MockRouterClientMockRecorder) Unroute ¶
func (mr *MockRouterClientMockRecorder) Unroute() *gomock.Call
Unroute indicates an expected call of Unroute.
func (*MockRouterClientMockRecorder) Usr ¶
func (mr *MockRouterClientMockRecorder) Usr() *gomock.Call
Usr indicates an expected call of Usr.