vtgateservice_testing

Documentation

Index

• type MockVTGateService
  • func NewMockVTGateService(ctrl *gomock.Controller) *MockVTGateService
  • func (_m *MockVTGateService) Begin(ctx context.Context) (*vtgate.Session, error)
  • func (_m *MockVTGateService) Commit(ctx context.Context, session *vtgate.Session) error
  • func (_m *MockVTGateService) EXPECT() *_MockVTGateServiceRecorder
  • func (_m *MockVTGateService) Execute(ctx context.Context, sql string, bindVariables map[string]interface{}, ...) (*sqltypes.Result, 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]interface{}, ...) (*sqltypes.Result, error)
  • func (_m *MockVTGateService) ExecuteKeyRanges(ctx context.Context, sql string, bindVariables map[string]interface{}, ...) (*sqltypes.Result, error)
  • func (_m *MockVTGateService) ExecuteKeyspaceIds(ctx context.Context, sql string, bindVariables map[string]interface{}, ...) (*sqltypes.Result, error)
  • func (_m *MockVTGateService) ExecuteShards(ctx context.Context, sql string, bindVariables map[string]interface{}, ...) (*sqltypes.Result, error)
  • func (_m *MockVTGateService) GetSrvKeyspace(ctx context.Context, keyspace string) (*topodata.SrvKeyspace, error)
  • func (_m *MockVTGateService) HandlePanic(err *error)
  • func (_m *MockVTGateService) Rollback(ctx context.Context, session *vtgate.Session) error
  • func (_m *MockVTGateService) SplitQuery(ctx context.Context, keyspace string, sql string, ...) ([]*vtgate.SplitQueryResponse_Part, error)
  • func (_m *MockVTGateService) StreamExecute(ctx context.Context, sql string, bindVariables map[string]interface{}, ...) error
  • func (_m *MockVTGateService) StreamExecuteKeyRanges(ctx context.Context, sql string, bindVariables map[string]interface{}, ...) error
  • func (_m *MockVTGateService) StreamExecuteKeyspaceIds(ctx context.Context, sql string, bindVariables map[string]interface{}, ...) error
  • func (_m *MockVTGateService) StreamExecuteShards(ctx context.Context, sql string, bindVariables map[string]interface{}, ...) error
  • func (_m *MockVTGateService) UpdateStream(ctx context.Context, keyspace string, shard string, ...) error

Types

type MockVTGateService

type MockVTGateService struct {
	// contains filtered or unexported fields
}

Mock of VTGateService interface

func NewMockVTGateService

func NewMockVTGateService(ctrl *gomock.Controller) *MockVTGateService

func (*MockVTGateService) Begin

func (_m *MockVTGateService) Begin(ctx context.Context) (*vtgate.Session, error)

func (*MockVTGateService) Commit

func (_m *MockVTGateService) Commit(ctx context.Context, session *vtgate.Session) error

func (*MockVTGateService) EXPECT

func (_m *MockVTGateService) EXPECT() *_MockVTGateServiceRecorder

func (*MockVTGateService) Execute

func (_m *MockVTGateService) Execute(ctx context.Context, sql string, bindVariables map[string]interface{}, keyspace string, tabletType topodata.TabletType, session *vtgate.Session, notInTransaction bool, options *query.ExecuteOptions) (*sqltypes.Result, error)

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)

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)

func (*MockVTGateService) ExecuteEntityIds

func (_m *MockVTGateService) ExecuteEntityIds(ctx context.Context, sql string, bindVariables map[string]interface{}, keyspace string, entityColumnName string, entityKeyspaceIDs []*vtgate.ExecuteEntityIdsRequest_EntityId, tabletType topodata.TabletType, session *vtgate.Session, notInTransaction bool, options *query.ExecuteOptions) (*sqltypes.Result, error)

func (*MockVTGateService) ExecuteKeyRanges

func (_m *MockVTGateService) ExecuteKeyRanges(ctx context.Context, sql string, bindVariables map[string]interface{}, keyspace string, keyRanges []*topodata.KeyRange, tabletType topodata.TabletType, session *vtgate.Session, notInTransaction bool, options *query.ExecuteOptions) (*sqltypes.Result, error)

func (*MockVTGateService) ExecuteKeyspaceIds

func (_m *MockVTGateService) ExecuteKeyspaceIds(ctx context.Context, sql string, bindVariables map[string]interface{}, keyspace string, keyspaceIds [][]byte, tabletType topodata.TabletType, session *vtgate.Session, notInTransaction bool, options *query.ExecuteOptions) (*sqltypes.Result, error)

func (*MockVTGateService) ExecuteShards

func (_m *MockVTGateService) ExecuteShards(ctx context.Context, sql string, bindVariables map[string]interface{}, keyspace string, shards []string, tabletType topodata.TabletType, session *vtgate.Session, notInTransaction bool, options *query.ExecuteOptions) (*sqltypes.Result, error)

func (*MockVTGateService) GetSrvKeyspace

func (_m *MockVTGateService) GetSrvKeyspace(ctx context.Context, keyspace string) (*topodata.SrvKeyspace, error)

func (*MockVTGateService) HandlePanic

func (_m *MockVTGateService) HandlePanic(err *error)

func (*MockVTGateService) Rollback

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

func (*MockVTGateService) SplitQuery

func (_m *MockVTGateService) SplitQuery(ctx context.Context, keyspace string, sql string, bindVariables map[string]interface{}, splitColumns []string, splitCount int64, numRowsPerQueryPart int64, algorithm query.SplitQueryRequest_Algorithm) ([]*vtgate.SplitQueryResponse_Part, error)

func (*MockVTGateService) StreamExecute

func (_m *MockVTGateService) StreamExecute(ctx context.Context, sql string, bindVariables map[string]interface{}, keyspace string, tabletType topodata.TabletType, options *query.ExecuteOptions, sendReply func(*sqltypes.Result) error) error

func (*MockVTGateService) StreamExecuteKeyRanges

func (_m *MockVTGateService) StreamExecuteKeyRanges(ctx context.Context, sql string, bindVariables map[string]interface{}, keyspace string, keyRanges []*topodata.KeyRange, tabletType topodata.TabletType, options *query.ExecuteOptions, sendReply func(*sqltypes.Result) error) error

func (*MockVTGateService) StreamExecuteKeyspaceIds

func (_m *MockVTGateService) StreamExecuteKeyspaceIds(ctx context.Context, sql string, bindVariables map[string]interface{}, keyspace string, keyspaceIds [][]byte, tabletType topodata.TabletType, options *query.ExecuteOptions, sendReply func(*sqltypes.Result) error) error

func (*MockVTGateService) StreamExecuteShards

func (_m *MockVTGateService) StreamExecuteShards(ctx context.Context, sql string, bindVariables map[string]interface{}, keyspace string, shards []string, tabletType topodata.TabletType, options *query.ExecuteOptions, sendReply func(*sqltypes.Result) error) error

func (*MockVTGateService) UpdateStream

func (_m *MockVTGateService) UpdateStream(ctx context.Context, keyspace string, shard string, keyRange *topodata.KeyRange, tabletType topodata.TabletType, timestamp int64, event *query.EventToken, sendReply func(*query.StreamEvent, int64) error) error