queryservice_testing

Documentation

Index

• type MockQueryService
  • func NewMockQueryService(ctrl *gomock.Controller) *MockQueryService
  • func (_m *MockQueryService) Begin(ctx context.Context, target *query.Target) (int64, error)
  • func (_m *MockQueryService) BeginExecute(ctx context.Context, target *query.Target, sql string, ...) (*sqltypes.Result, int64, error)
  • func (_m *MockQueryService) BeginExecuteBatch(ctx context.Context, target *query.Target, queries []querytypes.BoundQuery, ...) ([]sqltypes.Result, int64, error)
  • func (_m *MockQueryService) Commit(ctx context.Context, target *query.Target, transactionID int64) error
  • func (_m *MockQueryService) CommitPrepared(ctx context.Context, target *query.Target, dtid string) error
  • func (_m *MockQueryService) CreateTransaction(ctx context.Context, target *query.Target, dtid string, ...) error
  • func (_m *MockQueryService) EXPECT() *_MockQueryServiceRecorder
  • func (_m *MockQueryService) Execute(ctx context.Context, target *query.Target, sql string, ...) (*sqltypes.Result, error)
  • func (_m *MockQueryService) ExecuteBatch(ctx context.Context, target *query.Target, queries []querytypes.BoundQuery, ...) ([]sqltypes.Result, error)
  • func (_m *MockQueryService) HandlePanic(_param0 *error)
  • func (_m *MockQueryService) Prepare(ctx context.Context, target *query.Target, transactionID int64, dtid string) error
  • func (_m *MockQueryService) ReadTransaction(ctx context.Context, target *query.Target, dtid string) (*query.TransactionMetadata, error)
  • func (_m *MockQueryService) ResolveTransaction(ctx context.Context, target *query.Target, dtid string) error
  • func (_m *MockQueryService) Rollback(ctx context.Context, target *query.Target, transactionID int64) error
  • func (_m *MockQueryService) RollbackPrepared(ctx context.Context, target *query.Target, dtid string, originalID int64) error
  • func (_m *MockQueryService) SetRollback(ctx context.Context, target *query.Target, dtid string, transactionID int64) error
  • func (_m *MockQueryService) SplitQuery(ctx context.Context, target *query.Target, sql string, ...) ([]querytypes.QuerySplit, error)
  • func (_m *MockQueryService) StartCommit(ctx context.Context, target *query.Target, transactionID int64, dtid string) error
  • func (_m *MockQueryService) StreamExecute(ctx context.Context, target *query.Target, sql string, ...) error
  • func (_m *MockQueryService) StreamHealthRegister(_param0 chan<- *query.StreamHealthResponse) (int, error)
  • func (_m *MockQueryService) StreamHealthUnregister(_param0 int) error
  • func (_m *MockQueryService) UpdateStream(ctx context.Context, target *query.Target, position string, timestamp int64, ...) error

Types

type MockQueryService

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

Mock of QueryService interface

func NewMockQueryService

func NewMockQueryService(ctrl *gomock.Controller) *MockQueryService

func (*MockQueryService) Begin

func (_m *MockQueryService) Begin(ctx context.Context, target *query.Target) (int64, error)

func (*MockQueryService) BeginExecute

func (_m *MockQueryService) BeginExecute(ctx context.Context, target *query.Target, sql string, bindVariables map[string]interface{}, options *query.ExecuteOptions) (*sqltypes.Result, int64, error)

func (*MockQueryService) BeginExecuteBatch

func (_m *MockQueryService) BeginExecuteBatch(ctx context.Context, target *query.Target, queries []querytypes.BoundQuery, asTransaction bool, options *query.ExecuteOptions) ([]sqltypes.Result, int64, error)

func (*MockQueryService) Commit

func (_m *MockQueryService) Commit(ctx context.Context, target *query.Target, transactionID int64) error

func (*MockQueryService) CommitPrepared

func (_m *MockQueryService) CommitPrepared(ctx context.Context, target *query.Target, dtid string) error

func (*MockQueryService) CreateTransaction

func (_m *MockQueryService) CreateTransaction(ctx context.Context, target *query.Target, dtid string, participants []*query.Target) error

func (*MockQueryService) EXPECT

func (_m *MockQueryService) EXPECT() *_MockQueryServiceRecorder

func (*MockQueryService) Execute

func (_m *MockQueryService) Execute(ctx context.Context, target *query.Target, sql string, bindVariables map[string]interface{}, transactionID int64, options *query.ExecuteOptions) (*sqltypes.Result, error)

func (*MockQueryService) ExecuteBatch

func (_m *MockQueryService) ExecuteBatch(ctx context.Context, target *query.Target, queries []querytypes.BoundQuery, asTransaction bool, transactionID int64, options *query.ExecuteOptions) ([]sqltypes.Result, error)

func (*MockQueryService) HandlePanic

func (_m *MockQueryService) HandlePanic(_param0 *error)

func (*MockQueryService) Prepare

func (_m *MockQueryService) Prepare(ctx context.Context, target *query.Target, transactionID int64, dtid string) error

func (*MockQueryService) ReadTransaction

func (_m *MockQueryService) ReadTransaction(ctx context.Context, target *query.Target, dtid string) (*query.TransactionMetadata, error)

func (*MockQueryService) ResolveTransaction

func (_m *MockQueryService) ResolveTransaction(ctx context.Context, target *query.Target, dtid string) error

func (*MockQueryService) Rollback

func (_m *MockQueryService) Rollback(ctx context.Context, target *query.Target, transactionID int64) error

func (*MockQueryService) RollbackPrepared

func (_m *MockQueryService) RollbackPrepared(ctx context.Context, target *query.Target, dtid string, originalID int64) error

func (*MockQueryService) SetRollback

func (_m *MockQueryService) SetRollback(ctx context.Context, target *query.Target, dtid string, transactionID int64) error

func (*MockQueryService) SplitQuery

func (_m *MockQueryService) SplitQuery(ctx context.Context, target *query.Target, sql string, bindVariables map[string]interface{}, splitColumns []string, splitCount int64, numRowsPerQueryPart int64, algorithm query.SplitQueryRequest_Algorithm) ([]querytypes.QuerySplit, error)

func (*MockQueryService) StartCommit

func (_m *MockQueryService) StartCommit(ctx context.Context, target *query.Target, transactionID int64, dtid string) error

func (*MockQueryService) StreamExecute

func (_m *MockQueryService) StreamExecute(ctx context.Context, target *query.Target, sql string, bindVariables map[string]interface{}, options *query.ExecuteOptions, sendReply func(*sqltypes.Result) error) error

func (*MockQueryService) StreamHealthRegister

func (_m *MockQueryService) StreamHealthRegister(_param0 chan<- *query.StreamHealthResponse) (int, error)

func (*MockQueryService) StreamHealthUnregister

func (_m *MockQueryService) StreamHealthUnregister(_param0 int) error

func (*MockQueryService) UpdateStream

func (_m *MockQueryService) UpdateStream(ctx context.Context, target *query.Target, position string, timestamp int64, sendReply func(*query.StreamEvent) error) error