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) Commit(ctx context.Context, target *query.Target, transactionID int64) 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) Rollback(ctx context.Context, target *query.Target, transactionID int64) error
  • func (_m *MockQueryService) SplitQuery(ctx context.Context, target *query.Target, sql string, ...) ([]querytypes.QuerySplit, error)
  • func (_m *MockQueryService) SplitQueryV2(ctx context.Context, target *query.Target, sql string, ...) ([]querytypes.QuerySplit, 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

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

func (_m *MockQueryService) Commit(ctx context.Context, target *query.Target, transactionID int64) 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) (*sqltypes.Result, error)

func (*MockQueryService) ExecuteBatch

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

func (*MockQueryService) HandlePanic

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

func (*MockQueryService) Rollback

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

func (*MockQueryService) SplitQuery

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

func (*MockQueryService) SplitQueryV2

func (_m *MockQueryService) SplitQueryV2(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) StreamExecute

func (_m *MockQueryService) StreamExecute(ctx context.Context, target *query.Target, sql string, bindVariables map[string]interface{}, 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