Documentation ¶
Overview ¶
Package vtgateservice_testing is a generated GoMock package.
Index ¶
- type MockVTGateService
- func (m *MockVTGateService) Begin(ctx context.Context, singledb bool) (*vtgate.Session, error)
- func (m *MockVTGateService) Commit(ctx context.Context, twopc bool, session *vtgate.Session) error
- func (m *MockVTGateService) EXPECT() *MockVTGateServiceMockRecorder
- func (m *MockVTGateService) Execute(ctx context.Context, session *vtgate.Session, sql string, ...) (*vtgate.Session, *sqltypes.Result, error)
- func (m *MockVTGateService) ExecuteBatch(ctx context.Context, session *vtgate.Session, sqlList []string, ...) (*vtgate.Session, []sqltypes.QueryResponse, error)
- func (m *MockVTGateService) ExecuteBatchKeyspaceIds(ctx context.Context, queries []*vtgate.BoundKeyspaceIdQuery, ...) ([]sqltypes.Result, error)
- func (m *MockVTGateService) ExecuteBatchShards(ctx context.Context, queries []*vtgate.BoundShardQuery, ...) ([]sqltypes.Result, error)
- func (m *MockVTGateService) ExecuteEntityIds(ctx context.Context, sql string, bindVariables map[string]*query.BindVariable, ...) (*sqltypes.Result, error)
- func (m *MockVTGateService) ExecuteKeyRanges(ctx context.Context, sql string, bindVariables map[string]*query.BindVariable, ...) (*sqltypes.Result, error)
- func (m *MockVTGateService) ExecuteKeyspaceIds(ctx context.Context, sql string, bindVariables map[string]*query.BindVariable, ...) (*sqltypes.Result, error)
- func (m *MockVTGateService) ExecuteShards(ctx context.Context, sql string, bindVariables map[string]*query.BindVariable, ...) (*sqltypes.Result, error)
- func (m *MockVTGateService) GetSrvKeyspace(ctx context.Context, keyspace string) (*topodata.SrvKeyspace, error)
- func (m *MockVTGateService) HandlePanic(err *error)
- func (m *MockVTGateService) MessageAck(ctx context.Context, keyspace, name string, ids []*query.Value) (int64, error)
- func (m *MockVTGateService) MessageAckKeyspaceIds(ctx context.Context, keyspace, name string, ...) (int64, error)
- func (m *MockVTGateService) MessageStream(ctx context.Context, keyspace, shard string, keyRange *topodata.KeyRange, ...) error
- func (m *MockVTGateService) ResolveTransaction(ctx context.Context, dtid string) error
- func (m *MockVTGateService) Rollback(ctx context.Context, session *vtgate.Session) error
- func (m *MockVTGateService) SplitQuery(ctx context.Context, keyspace, sql string, ...) ([]*vtgate.SplitQueryResponse_Part, error)
- func (m *MockVTGateService) StreamExecute(ctx context.Context, session *vtgate.Session, sql string, ...) error
- func (m *MockVTGateService) StreamExecuteKeyRanges(ctx context.Context, sql string, bindVariables map[string]*query.BindVariable, ...) error
- func (m *MockVTGateService) StreamExecuteKeyspaceIds(ctx context.Context, sql string, bindVariables map[string]*query.BindVariable, ...) error
- func (m *MockVTGateService) StreamExecuteShards(ctx context.Context, sql string, bindVariables map[string]*query.BindVariable, ...) error
- func (m *MockVTGateService) UpdateStream(ctx context.Context, keyspace, shard string, keyRange *topodata.KeyRange, ...) error
- type MockVTGateServiceMockRecorder
- func (mr *MockVTGateServiceMockRecorder) Begin(ctx, singledb interface{}) *gomock.Call
- func (mr *MockVTGateServiceMockRecorder) Commit(ctx, twopc, session interface{}) *gomock.Call
- func (mr *MockVTGateServiceMockRecorder) Execute(ctx, session, sql, bindVariables interface{}) *gomock.Call
- func (mr *MockVTGateServiceMockRecorder) ExecuteBatch(ctx, session, sqlList, bindVariablesList interface{}) *gomock.Call
- func (mr *MockVTGateServiceMockRecorder) ExecuteBatchKeyspaceIds(ctx, queries, tabletType, asTransaction, session, options interface{}) *gomock.Call
- func (mr *MockVTGateServiceMockRecorder) ExecuteBatchShards(ctx, queries, tabletType, asTransaction, session, options interface{}) *gomock.Call
- func (mr *MockVTGateServiceMockRecorder) ExecuteEntityIds(...) *gomock.Call
- func (mr *MockVTGateServiceMockRecorder) ExecuteKeyRanges(...) *gomock.Call
- func (mr *MockVTGateServiceMockRecorder) ExecuteKeyspaceIds(...) *gomock.Call
- func (mr *MockVTGateServiceMockRecorder) ExecuteShards(...) *gomock.Call
- func (mr *MockVTGateServiceMockRecorder) GetSrvKeyspace(ctx, keyspace interface{}) *gomock.Call
- func (mr *MockVTGateServiceMockRecorder) HandlePanic(err interface{}) *gomock.Call
- func (mr *MockVTGateServiceMockRecorder) MessageAck(ctx, keyspace, name, ids interface{}) *gomock.Call
- func (mr *MockVTGateServiceMockRecorder) MessageAckKeyspaceIds(ctx, keyspace, name, idKeyspaceIDs interface{}) *gomock.Call
- func (mr *MockVTGateServiceMockRecorder) MessageStream(ctx, keyspace, shard, keyRange, name, callback interface{}) *gomock.Call
- func (mr *MockVTGateServiceMockRecorder) ResolveTransaction(ctx, dtid interface{}) *gomock.Call
- func (mr *MockVTGateServiceMockRecorder) Rollback(ctx, session interface{}) *gomock.Call
- func (mr *MockVTGateServiceMockRecorder) SplitQuery(ctx, keyspace, sql, bindVariables, splitColumns, splitCount, ... interface{}) *gomock.Call
- func (mr *MockVTGateServiceMockRecorder) StreamExecute(ctx, session, sql, bindVariables, callback interface{}) *gomock.Call
- func (mr *MockVTGateServiceMockRecorder) StreamExecuteKeyRanges(...) *gomock.Call
- func (mr *MockVTGateServiceMockRecorder) StreamExecuteKeyspaceIds(...) *gomock.Call
- func (mr *MockVTGateServiceMockRecorder) StreamExecuteShards(...) *gomock.Call
- func (mr *MockVTGateServiceMockRecorder) UpdateStream(...) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockVTGateService ¶
type MockVTGateService struct {
// contains filtered or unexported fields
}
MockVTGateService is a mock of VTGateService interface
func NewMockVTGateService ¶
func NewMockVTGateService(ctrl *gomock.Controller) *MockVTGateService
NewMockVTGateService creates a new mock instance
func (*MockVTGateService) EXPECT ¶
func (m *MockVTGateService) EXPECT() *MockVTGateServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockVTGateService) Execute ¶
func (m *MockVTGateService) Execute(ctx context.Context, session *vtgate.Session, sql string, bindVariables map[string]*query.BindVariable) (*vtgate.Session, *sqltypes.Result, error)
Execute mocks base method
func (*MockVTGateService) ExecuteBatch ¶
func (m *MockVTGateService) ExecuteBatch(ctx context.Context, session *vtgate.Session, sqlList []string, bindVariablesList []map[string]*query.BindVariable) (*vtgate.Session, []sqltypes.QueryResponse, error)
ExecuteBatch mocks base method
func (*MockVTGateService) ExecuteBatchKeyspaceIds ¶
func (m *MockVTGateService) ExecuteBatchKeyspaceIds(ctx context.Context, queries []*vtgate.BoundKeyspaceIdQuery, tabletType topodata.TabletType, asTransaction bool, session *vtgate.Session, options *query.ExecuteOptions) ([]sqltypes.Result, error)
ExecuteBatchKeyspaceIds mocks base method
func (*MockVTGateService) ExecuteBatchShards ¶
func (m *MockVTGateService) ExecuteBatchShards(ctx context.Context, queries []*vtgate.BoundShardQuery, tabletType topodata.TabletType, asTransaction bool, session *vtgate.Session, options *query.ExecuteOptions) ([]sqltypes.Result, error)
ExecuteBatchShards mocks base method
func (*MockVTGateService) ExecuteEntityIds ¶
func (m *MockVTGateService) ExecuteEntityIds(ctx context.Context, sql string, bindVariables map[string]*query.BindVariable, keyspace, entityColumnName string, entityKeyspaceIDs []*vtgate.ExecuteEntityIdsRequest_EntityId, tabletType topodata.TabletType, session *vtgate.Session, notInTransaction bool, options *query.ExecuteOptions) (*sqltypes.Result, error)
ExecuteEntityIds mocks base method
func (*MockVTGateService) ExecuteKeyRanges ¶
func (m *MockVTGateService) ExecuteKeyRanges(ctx context.Context, sql string, bindVariables map[string]*query.BindVariable, keyspace string, keyRanges []*topodata.KeyRange, tabletType topodata.TabletType, session *vtgate.Session, notInTransaction bool, options *query.ExecuteOptions) (*sqltypes.Result, error)
ExecuteKeyRanges mocks base method
func (*MockVTGateService) ExecuteKeyspaceIds ¶
func (m *MockVTGateService) ExecuteKeyspaceIds(ctx context.Context, sql string, bindVariables map[string]*query.BindVariable, keyspace string, keyspaceIds [][]byte, tabletType topodata.TabletType, session *vtgate.Session, notInTransaction bool, options *query.ExecuteOptions) (*sqltypes.Result, error)
ExecuteKeyspaceIds mocks base method
func (*MockVTGateService) ExecuteShards ¶
func (m *MockVTGateService) ExecuteShards(ctx context.Context, sql string, bindVariables map[string]*query.BindVariable, keyspace string, shards []string, tabletType topodata.TabletType, session *vtgate.Session, notInTransaction bool, options *query.ExecuteOptions) (*sqltypes.Result, error)
ExecuteShards mocks base method
func (*MockVTGateService) GetSrvKeyspace ¶
func (m *MockVTGateService) GetSrvKeyspace(ctx context.Context, keyspace string) (*topodata.SrvKeyspace, error)
GetSrvKeyspace mocks base method
func (*MockVTGateService) HandlePanic ¶
func (m *MockVTGateService) HandlePanic(err *error)
HandlePanic mocks base method
func (*MockVTGateService) MessageAck ¶
func (m *MockVTGateService) MessageAck(ctx context.Context, keyspace, name string, ids []*query.Value) (int64, error)
MessageAck mocks base method
func (*MockVTGateService) MessageAckKeyspaceIds ¶
func (m *MockVTGateService) MessageAckKeyspaceIds(ctx context.Context, keyspace, name string, idKeyspaceIDs []*vtgate.IdKeyspaceId) (int64, error)
MessageAckKeyspaceIds mocks base method
func (*MockVTGateService) MessageStream ¶
func (m *MockVTGateService) MessageStream(ctx context.Context, keyspace, shard string, keyRange *topodata.KeyRange, name string, callback func(*sqltypes.Result) error) error
MessageStream mocks base method
func (*MockVTGateService) ResolveTransaction ¶
func (m *MockVTGateService) ResolveTransaction(ctx context.Context, dtid string) error
ResolveTransaction mocks base method
func (*MockVTGateService) SplitQuery ¶
func (m *MockVTGateService) SplitQuery(ctx context.Context, keyspace, sql string, bindVariables map[string]*query.BindVariable, splitColumns []string, splitCount, numRowsPerQueryPart int64, algorithm query.SplitQueryRequest_Algorithm) ([]*vtgate.SplitQueryResponse_Part, error)
SplitQuery mocks base method
func (*MockVTGateService) StreamExecute ¶
func (m *MockVTGateService) StreamExecute(ctx context.Context, session *vtgate.Session, sql string, bindVariables map[string]*query.BindVariable, callback func(*sqltypes.Result) error) error
StreamExecute mocks base method
func (*MockVTGateService) StreamExecuteKeyRanges ¶
func (m *MockVTGateService) StreamExecuteKeyRanges(ctx context.Context, sql string, bindVariables map[string]*query.BindVariable, keyspace string, keyRanges []*topodata.KeyRange, tabletType topodata.TabletType, options *query.ExecuteOptions, callback func(*sqltypes.Result) error) error
StreamExecuteKeyRanges mocks base method
func (*MockVTGateService) StreamExecuteKeyspaceIds ¶
func (m *MockVTGateService) StreamExecuteKeyspaceIds(ctx context.Context, sql string, bindVariables map[string]*query.BindVariable, keyspace string, keyspaceIds [][]byte, tabletType topodata.TabletType, options *query.ExecuteOptions, callback func(*sqltypes.Result) error) error
StreamExecuteKeyspaceIds mocks base method
func (*MockVTGateService) StreamExecuteShards ¶
func (m *MockVTGateService) StreamExecuteShards(ctx context.Context, sql string, bindVariables map[string]*query.BindVariable, keyspace string, shards []string, tabletType topodata.TabletType, options *query.ExecuteOptions, callback func(*sqltypes.Result) error) error
StreamExecuteShards mocks base method
func (*MockVTGateService) UpdateStream ¶
func (m *MockVTGateService) UpdateStream(ctx context.Context, keyspace, shard string, keyRange *topodata.KeyRange, tabletType topodata.TabletType, timestamp int64, event *query.EventToken, callback func(*query.StreamEvent, int64) error) error
UpdateStream mocks base method
type MockVTGateServiceMockRecorder ¶
type MockVTGateServiceMockRecorder struct {
// contains filtered or unexported fields
}
MockVTGateServiceMockRecorder is the mock recorder for MockVTGateService
func (*MockVTGateServiceMockRecorder) Begin ¶
func (mr *MockVTGateServiceMockRecorder) Begin(ctx, singledb interface{}) *gomock.Call
Begin indicates an expected call of Begin
func (*MockVTGateServiceMockRecorder) Commit ¶
func (mr *MockVTGateServiceMockRecorder) Commit(ctx, twopc, session interface{}) *gomock.Call
Commit indicates an expected call of Commit
func (*MockVTGateServiceMockRecorder) Execute ¶
func (mr *MockVTGateServiceMockRecorder) Execute(ctx, session, sql, bindVariables interface{}) *gomock.Call
Execute indicates an expected call of Execute
func (*MockVTGateServiceMockRecorder) ExecuteBatch ¶
func (mr *MockVTGateServiceMockRecorder) ExecuteBatch(ctx, session, sqlList, bindVariablesList interface{}) *gomock.Call
ExecuteBatch indicates an expected call of ExecuteBatch
func (*MockVTGateServiceMockRecorder) ExecuteBatchKeyspaceIds ¶
func (mr *MockVTGateServiceMockRecorder) ExecuteBatchKeyspaceIds(ctx, queries, tabletType, asTransaction, session, options interface{}) *gomock.Call
ExecuteBatchKeyspaceIds indicates an expected call of ExecuteBatchKeyspaceIds
func (*MockVTGateServiceMockRecorder) ExecuteBatchShards ¶
func (mr *MockVTGateServiceMockRecorder) ExecuteBatchShards(ctx, queries, tabletType, asTransaction, session, options interface{}) *gomock.Call
ExecuteBatchShards indicates an expected call of ExecuteBatchShards
func (*MockVTGateServiceMockRecorder) ExecuteEntityIds ¶
func (mr *MockVTGateServiceMockRecorder) ExecuteEntityIds(ctx, sql, bindVariables, keyspace, entityColumnName, entityKeyspaceIDs, tabletType, session, notInTransaction, options interface{}) *gomock.Call
ExecuteEntityIds indicates an expected call of ExecuteEntityIds
func (*MockVTGateServiceMockRecorder) ExecuteKeyRanges ¶
func (mr *MockVTGateServiceMockRecorder) ExecuteKeyRanges(ctx, sql, bindVariables, keyspace, keyRanges, tabletType, session, notInTransaction, options interface{}) *gomock.Call
ExecuteKeyRanges indicates an expected call of ExecuteKeyRanges
func (*MockVTGateServiceMockRecorder) ExecuteKeyspaceIds ¶
func (mr *MockVTGateServiceMockRecorder) ExecuteKeyspaceIds(ctx, sql, bindVariables, keyspace, keyspaceIds, tabletType, session, notInTransaction, options interface{}) *gomock.Call
ExecuteKeyspaceIds indicates an expected call of ExecuteKeyspaceIds
func (*MockVTGateServiceMockRecorder) ExecuteShards ¶
func (mr *MockVTGateServiceMockRecorder) ExecuteShards(ctx, sql, bindVariables, keyspace, shards, tabletType, session, notInTransaction, options interface{}) *gomock.Call
ExecuteShards indicates an expected call of ExecuteShards
func (*MockVTGateServiceMockRecorder) GetSrvKeyspace ¶
func (mr *MockVTGateServiceMockRecorder) GetSrvKeyspace(ctx, keyspace interface{}) *gomock.Call
GetSrvKeyspace indicates an expected call of GetSrvKeyspace
func (*MockVTGateServiceMockRecorder) HandlePanic ¶
func (mr *MockVTGateServiceMockRecorder) HandlePanic(err interface{}) *gomock.Call
HandlePanic indicates an expected call of HandlePanic
func (*MockVTGateServiceMockRecorder) MessageAck ¶
func (mr *MockVTGateServiceMockRecorder) MessageAck(ctx, keyspace, name, ids interface{}) *gomock.Call
MessageAck indicates an expected call of MessageAck
func (*MockVTGateServiceMockRecorder) MessageAckKeyspaceIds ¶
func (mr *MockVTGateServiceMockRecorder) MessageAckKeyspaceIds(ctx, keyspace, name, idKeyspaceIDs interface{}) *gomock.Call
MessageAckKeyspaceIds indicates an expected call of MessageAckKeyspaceIds
func (*MockVTGateServiceMockRecorder) MessageStream ¶
func (mr *MockVTGateServiceMockRecorder) MessageStream(ctx, keyspace, shard, keyRange, name, callback interface{}) *gomock.Call
MessageStream indicates an expected call of MessageStream
func (*MockVTGateServiceMockRecorder) ResolveTransaction ¶
func (mr *MockVTGateServiceMockRecorder) ResolveTransaction(ctx, dtid interface{}) *gomock.Call
ResolveTransaction indicates an expected call of ResolveTransaction
func (*MockVTGateServiceMockRecorder) Rollback ¶
func (mr *MockVTGateServiceMockRecorder) Rollback(ctx, session interface{}) *gomock.Call
Rollback indicates an expected call of Rollback
func (*MockVTGateServiceMockRecorder) SplitQuery ¶
func (mr *MockVTGateServiceMockRecorder) SplitQuery(ctx, keyspace, sql, bindVariables, splitColumns, splitCount, numRowsPerQueryPart, algorithm interface{}) *gomock.Call
SplitQuery indicates an expected call of SplitQuery
func (*MockVTGateServiceMockRecorder) StreamExecute ¶
func (mr *MockVTGateServiceMockRecorder) StreamExecute(ctx, session, sql, bindVariables, callback interface{}) *gomock.Call
StreamExecute indicates an expected call of StreamExecute
func (*MockVTGateServiceMockRecorder) StreamExecuteKeyRanges ¶
func (mr *MockVTGateServiceMockRecorder) StreamExecuteKeyRanges(ctx, sql, bindVariables, keyspace, keyRanges, tabletType, options, callback interface{}) *gomock.Call
StreamExecuteKeyRanges indicates an expected call of StreamExecuteKeyRanges
func (*MockVTGateServiceMockRecorder) StreamExecuteKeyspaceIds ¶
func (mr *MockVTGateServiceMockRecorder) StreamExecuteKeyspaceIds(ctx, sql, bindVariables, keyspace, keyspaceIds, tabletType, options, callback interface{}) *gomock.Call
StreamExecuteKeyspaceIds indicates an expected call of StreamExecuteKeyspaceIds
func (*MockVTGateServiceMockRecorder) StreamExecuteShards ¶
func (mr *MockVTGateServiceMockRecorder) StreamExecuteShards(ctx, sql, bindVariables, keyspace, shards, tabletType, options, callback interface{}) *gomock.Call
StreamExecuteShards indicates an expected call of StreamExecuteShards
func (*MockVTGateServiceMockRecorder) UpdateStream ¶
func (mr *MockVTGateServiceMockRecorder) UpdateStream(ctx, keyspace, shard, keyRange, tabletType, timestamp, event, callback interface{}) *gomock.Call
UpdateStream indicates an expected call of UpdateStream