vtgateservice_testing

package
v1.0.10 Latest Latest
Warning

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

 Go to latest Published: Apr 21, 2020 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 

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

Source Files

View all Source files

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.