Documentation
¶
Overview ¶
Package mock is a generated GoMock package.
Index ¶
- type MockServer
- func (m *MockServer) AddDataShard(clid uint, shardKey kr.ShardKey, tsa string) error
- func (m *MockServer) Cancel() error
- func (m *MockServer) Datashards() []shard.Shard
- func (m *MockServer) EXPECT() *MockServerMockRecorder
- func (m *MockServer) HasPrepareStatement(hash uint64) (bool, *shard.PreparedStatementDescriptor)
- func (m *MockServer) Name() string
- func (m *MockServer) PrepareStatement(hash uint64, rd *shard.PreparedStatementDescriptor)
- func (m *MockServer) Receive() (pgproto3.BackendMessage, error)
- func (m *MockServer) Reset() error
- func (m *MockServer) Send(query pgproto3.FrontendMessage) error
- func (m *MockServer) SetTxStatus(status txstatus.TXStatus)
- func (m *MockServer) Sync() int64
- func (m *MockServer) TxStatus() txstatus.TXStatus
- func (m *MockServer) UnRouteShard(sh kr.ShardKey, rule *config.FrontendRule) error
- type MockServerMockRecorder
- func (mr *MockServerMockRecorder) AddDataShard(clid, shardKey, tsa interface{}) *gomock.Call
- func (mr *MockServerMockRecorder) Cancel() *gomock.Call
- func (mr *MockServerMockRecorder) Datashards() *gomock.Call
- func (mr *MockServerMockRecorder) HasPrepareStatement(hash interface{}) *gomock.Call
- func (mr *MockServerMockRecorder) Name() *gomock.Call
- func (mr *MockServerMockRecorder) PrepareStatement(hash, rd interface{}) *gomock.Call
- func (mr *MockServerMockRecorder) Receive() *gomock.Call
- func (mr *MockServerMockRecorder) Reset() *gomock.Call
- func (mr *MockServerMockRecorder) Send(query interface{}) *gomock.Call
- func (mr *MockServerMockRecorder) SetTxStatus(status interface{}) *gomock.Call
- func (mr *MockServerMockRecorder) Sync() *gomock.Call
- func (mr *MockServerMockRecorder) TxStatus() *gomock.Call
- func (mr *MockServerMockRecorder) UnRouteShard(sh, rule interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockServer ¶
type MockServer struct {
// contains filtered or unexported fields
}
MockServer is a mock of Server interface.
func NewMockServer ¶
func NewMockServer(ctrl *gomock.Controller) *MockServer
NewMockServer creates a new mock instance.
func (*MockServer) AddDataShard ¶
AddDataShard mocks base method.
func (*MockServer) Datashards ¶
func (m *MockServer) Datashards() []shard.Shard
Datashards mocks base method.
func (*MockServer) EXPECT ¶
func (m *MockServer) EXPECT() *MockServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockServer) HasPrepareStatement ¶
func (m *MockServer) HasPrepareStatement(hash uint64) (bool, *shard.PreparedStatementDescriptor)
HasPrepareStatement mocks base method.
func (*MockServer) PrepareStatement ¶
func (m *MockServer) PrepareStatement(hash uint64, rd *shard.PreparedStatementDescriptor)
PrepareStatement mocks base method.
func (*MockServer) Receive ¶
func (m *MockServer) Receive() (pgproto3.BackendMessage, error)
Receive mocks base method.
func (*MockServer) Send ¶
func (m *MockServer) Send(query pgproto3.FrontendMessage) error
Send mocks base method.
func (*MockServer) SetTxStatus ¶
func (m *MockServer) SetTxStatus(status txstatus.TXStatus)
SetTxStatus mocks base method.
func (*MockServer) TxStatus ¶
func (m *MockServer) TxStatus() txstatus.TXStatus
TxStatus mocks base method.
func (*MockServer) UnRouteShard ¶
func (m *MockServer) UnRouteShard(sh kr.ShardKey, rule *config.FrontendRule) error
UnRouteShard mocks base method.
type MockServerMockRecorder ¶
type MockServerMockRecorder struct {
// contains filtered or unexported fields
}
MockServerMockRecorder is the mock recorder for MockServer.
func (*MockServerMockRecorder) AddDataShard ¶
func (mr *MockServerMockRecorder) AddDataShard(clid, shardKey, tsa interface{}) *gomock.Call
AddDataShard indicates an expected call of AddDataShard.
func (*MockServerMockRecorder) Cancel ¶
func (mr *MockServerMockRecorder) Cancel() *gomock.Call
Cancel indicates an expected call of Cancel.
func (*MockServerMockRecorder) Datashards ¶
func (mr *MockServerMockRecorder) Datashards() *gomock.Call
Datashards indicates an expected call of Datashards.
func (*MockServerMockRecorder) HasPrepareStatement ¶
func (mr *MockServerMockRecorder) HasPrepareStatement(hash interface{}) *gomock.Call
HasPrepareStatement indicates an expected call of HasPrepareStatement.
func (*MockServerMockRecorder) Name ¶
func (mr *MockServerMockRecorder) Name() *gomock.Call
Name indicates an expected call of Name.
func (*MockServerMockRecorder) PrepareStatement ¶
func (mr *MockServerMockRecorder) PrepareStatement(hash, rd interface{}) *gomock.Call
PrepareStatement indicates an expected call of PrepareStatement.
func (*MockServerMockRecorder) Receive ¶
func (mr *MockServerMockRecorder) Receive() *gomock.Call
Receive indicates an expected call of Receive.
func (*MockServerMockRecorder) Reset ¶
func (mr *MockServerMockRecorder) Reset() *gomock.Call
Reset indicates an expected call of Reset.
func (*MockServerMockRecorder) Send ¶
func (mr *MockServerMockRecorder) Send(query interface{}) *gomock.Call
Send indicates an expected call of Send.
func (*MockServerMockRecorder) SetTxStatus ¶
func (mr *MockServerMockRecorder) SetTxStatus(status interface{}) *gomock.Call
SetTxStatus indicates an expected call of SetTxStatus.
func (*MockServerMockRecorder) Sync ¶
func (mr *MockServerMockRecorder) Sync() *gomock.Call
Sync indicates an expected call of Sync.
func (*MockServerMockRecorder) TxStatus ¶
func (mr *MockServerMockRecorder) TxStatus() *gomock.Call
TxStatus indicates an expected call of TxStatus.
func (*MockServerMockRecorder) UnRouteShard ¶
func (mr *MockServerMockRecorder) UnRouteShard(sh, rule interface{}) *gomock.Call
UnRouteShard indicates an expected call of UnRouteShard.
Source Files