queryservice_testing

package
v2.0.0-rc.2+incompatible Latest Latest
Warning

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

Go to latest
Published: Jun 22, 2016 License: BSD-3-Clause Imports: 5 Imported by: 0

Documentation

Index

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL