Documentation ¶
Index ¶
- type MockQueryService
- func (_m *MockQueryService) Begin(ctx context.Context, target *query.Target, sessionID int64) (int64, error)
- func (_m *MockQueryService) Commit(ctx context.Context, target *query.Target, sessionID 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) GetSessionId(keyspace string, shard string) (int64, error)
- func (_m *MockQueryService) HandlePanic(_param0 *error)
- func (_m *MockQueryService) Rollback(ctx context.Context, target *query.Target, sessionID 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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) EXPECT ¶
func (_m *MockQueryService) EXPECT() *_MockQueryServiceRecorder
func (*MockQueryService) ExecuteBatch ¶
func (_m *MockQueryService) ExecuteBatch(ctx context.Context, target *query.Target, queries []querytypes.BoundQuery, sessionID int64, asTransaction bool, transactionID int64) ([]sqltypes.Result, error)
func (*MockQueryService) GetSessionId ¶
func (_m *MockQueryService) GetSessionId(keyspace string, shard string) (int64, error)
func (*MockQueryService) HandlePanic ¶
func (_m *MockQueryService) HandlePanic(_param0 *error)
func (*MockQueryService) SplitQuery ¶
func (_m *MockQueryService) SplitQuery(ctx context.Context, target *query.Target, sql string, bindVariables map[string]interface{}, splitColumn string, splitCount int64, sessionID 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, sessionID int64) ([]querytypes.QuerySplit, error)
func (*MockQueryService) StreamExecute ¶
func (*MockQueryService) StreamHealthRegister ¶
func (_m *MockQueryService) StreamHealthRegister(_param0 chan<- *query.StreamHealthResponse) (int, error)
func (*MockQueryService) StreamHealthUnregister ¶
func (_m *MockQueryService) StreamHealthUnregister(_param0 int) error
Click to show internal directories.
Click to hide internal directories.