vtgateservice_testing

package
v3.0.0-rc.2+incompatible Latest Latest
Warning

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

Go to latest
Published: Dec 9, 2018 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

Package vtgateservice_testing is a generated GoMock package.

Index

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) Begin

func (m *MockVTGateService) Begin(ctx context.Context, singledb bool) (*vtgate.Session, error)

Begin mocks base method

func (*MockVTGateService) Commit

func (m *MockVTGateService) Commit(ctx context.Context, twopc bool, session *vtgate.Session) error

Commit mocks base method

func (*MockVTGateService) EXPECT

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) Rollback

func (m *MockVTGateService) Rollback(ctx context.Context, session *vtgate.Session) error

Rollback 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL