Versions in this module Expand all Collapse all v0 v0.16.3 Nov 29, 2024 Changes in this version + const BeginTransactionID + const CommitTransactionID + const Dtid + const ExecuteBatchTransactionID + const ExecuteQuery + const ExecuteTransactionID + const RollbackTransactionID + const StreamExecuteQuery + const TestAsTransaction + var ExecuteBatchQueries = []*querypb.BoundQuery + var ExecuteBatchQueryResultList = []sqltypes.Result + var ExecuteBindVars = map[string]*querypb.BindVariable + var ExecuteQueryResult = sqltypes.Result + var MessageIDs = []*querypb.Value + var MessageName = "vitess_message" + var MessageStreamResult = &sqltypes.Result + var Metadata = &querypb.TransactionMetadata + var Participants = []*querypb.Target + var StreamExecuteBindVars = map[string]*querypb.BindVariable + var StreamExecuteQueryResult1 = sqltypes.Result + var StreamExecuteQueryResult2 = sqltypes.Result + var TestCallerID = &vtrpcpb.CallerID + var TestExecuteOptions = &querypb.ExecuteOptions + var TestStreamHealthErrorMsg = "to trigger a server error" + var TestStreamHealthStreamHealthResponse = &querypb.StreamHealthResponse + var TestTarget = &querypb.Target + var TestVTGateCallerID = &querypb.VTGateCallerID + func TargetsEqual(t1, t2 []*querypb.Target) bool + func TestSuite(t *testing.T, protocol string, tablet *topodatapb.Tablet, ...) + type FakeQueryService struct + ErrorWait chan struct{} + ExpectedTransactionID int64 + HasBeginError bool + HasError bool + PanicWait chan struct{} + Panics bool + StreamExecutePanicsEarly bool + StreamHealthResponse *querypb.StreamHealthResponse + TabletError error + TestingGateway bool + func CreateFakeServer(t *testing.T) *FakeQueryService + func (f *FakeQueryService) Begin(ctx context.Context, target *querypb.Target, options *querypb.ExecuteOptions) (int64, error) + func (f *FakeQueryService) BeginExecute(ctx context.Context, target *querypb.Target, sql string, ...) (*sqltypes.Result, int64, error) + func (f *FakeQueryService) BeginExecuteBatch(ctx context.Context, target *querypb.Target, queries []*querypb.BoundQuery, ...) ([]sqltypes.Result, int64, error) + func (f *FakeQueryService) Close(ctx context.Context) error + func (f *FakeQueryService) Commit(ctx context.Context, target *querypb.Target, transactionID int64) error + func (f *FakeQueryService) CommitPrepared(ctx context.Context, target *querypb.Target, dtid string) (err error) + func (f *FakeQueryService) ConcludeTransaction(ctx context.Context, target *querypb.Target, dtid string) (err error) + func (f *FakeQueryService) CreateTransaction(ctx context.Context, target *querypb.Target, dtid string, ...) (err error) + func (f *FakeQueryService) Execute(ctx context.Context, target *querypb.Target, sql string, ...) (*sqltypes.Result, error) + func (f *FakeQueryService) ExecuteBatch(ctx context.Context, target *querypb.Target, queries []*querypb.BoundQuery, ...) ([]sqltypes.Result, error) + func (f *FakeQueryService) HandlePanic(err *error) + func (f *FakeQueryService) MessageAck(ctx context.Context, target *querypb.Target, name string, ids []*querypb.Value) (count int64, err error) + func (f *FakeQueryService) MessageStream(ctx context.Context, target *querypb.Target, name string, ...) (err error) + func (f *FakeQueryService) Prepare(ctx context.Context, target *querypb.Target, transactionID int64, dtid string) (err error) + func (f *FakeQueryService) ReadTransaction(ctx context.Context, target *querypb.Target, dtid string) (metadata *querypb.TransactionMetadata, err error) + func (f *FakeQueryService) Rollback(ctx context.Context, target *querypb.Target, transactionID int64) error + func (f *FakeQueryService) RollbackPrepared(ctx context.Context, target *querypb.Target, dtid string, originalID int64) (err error) + func (f *FakeQueryService) SetRollback(ctx context.Context, target *querypb.Target, dtid string, transactionID int64) (err error) + func (f *FakeQueryService) StartCommit(ctx context.Context, target *querypb.Target, transactionID int64, dtid string) (err error) + func (f *FakeQueryService) StreamExecute(ctx context.Context, target *querypb.Target, sql string, ...) error + func (f *FakeQueryService) StreamHealth(ctx context.Context, callback func(*querypb.StreamHealthResponse) error) error + func (f *FakeQueryService) VStream(ctx context.Context, target *querypb.Target, position string, ...) error + func (f *FakeQueryService) VStreamResults(ctx context.Context, target *querypb.Target, query string, ...) error + func (f *FakeQueryService) VStreamRows(ctx context.Context, target *querypb.Target, query string, ...) error
Go to main page