Versions in this module Expand all Collapse all v0 v0.15.10 Jul 31, 2024 v0.15.9 Jul 31, 2024 v0.15.8 Jul 31, 2024 Changes in this version + var ResolveChan = make(chan string, 1) + var Server *tabletserver.TabletServer + var ServerAddress string + var Target *querypb.Target + var TopoServer *topo.Server + func DebugSchema() map[string]Table + func DebugVars() map[string]any + func FetchInt(vars map[string]any, tags string) int + func FetchJSON(urlPath string) map[string]any + func FetchURL(urlPath string) string + func FetchVal(vars map[string]any, tags string) any + func IsPresent(vars map[string]any, tags string) bool + func PostJSON(urlPath string, values map[string]string) map[string]any + func QueryStats() map[string]QueryStat + func RowsToStrings(qr *sqltypes.Result) [][]string + func StartCustomServer(ctx context.Context, connParams, connAppDebugParams mysql.ConnParams, ...) error + func StartServer(ctx context.Context, connParams, connAppDebugParams mysql.ConnParams, ...) error + func StopServer() + func StreamTerminate(connID int64) error + type Event interface + EventTime func() time.Time + type EventCatcher struct + func NewEventCatcher[T Event](logger *streamlog.StreamLogger[T]) *EventCatcher[T] + func NewQueryCatcher() *EventCatcher[*tabletenv.LogStats] + func (catcher *EventCatcher[T]) Close() + func (catcher *EventCatcher[T]) Next() (T, error) + type LiveQuery struct + ConnID int64 + ContextHTML string + Duration int64 + Query string + ShowTerminateLink bool + Start time.Time + State string + Type string + func LiveQueryz() []LiveQuery + type MultiCase struct + Cases []Testable + Name string + func (mc *MultiCase) Benchmark(client *QueryClient) error + func (mc *MultiCase) Test(name string, client *QueryClient) error + type QueryClient struct + func NewClient() *QueryClient + func NewClientWithContext(ctx context.Context) *QueryClient + func NewClientWithServer(server *tabletserver.TabletServer) *QueryClient + func NewClientWithTabletType(tabletType topodatapb.TabletType) *QueryClient + func (client *QueryClient) Begin(clientFoundRows bool) error + func (client *QueryClient) BeginExecute(query string, bindvars map[string]*querypb.BindVariable, preQueries []string) (*sqltypes.Result, error) + func (client *QueryClient) Commit() error + func (client *QueryClient) CommitPrepared(dtid string) error + func (client *QueryClient) ConcludeTransaction(dtid string) error + func (client *QueryClient) CreateTransaction(dtid string, participants []*querypb.Target) error + func (client *QueryClient) Execute(query string, bindvars map[string]*querypb.BindVariable) (*sqltypes.Result, error) + func (client *QueryClient) ExecuteWithOptions(query string, bindvars map[string]*querypb.BindVariable, ...) (*sqltypes.Result, error) + func (client *QueryClient) GetSchema(tableType querypb.SchemaTableType, tableNames ...string) (schemaDef map[string]string, udfs []*querypb.UDFInfo, err error) + func (client *QueryClient) MessageAck(name string, ids []string) (int64, error) + func (client *QueryClient) MessageStream(name string, callback func(*sqltypes.Result) error) (err error) + func (client *QueryClient) Prepare(dtid string) error + func (client *QueryClient) ReadTransaction(dtid string) (*querypb.TransactionMetadata, error) + func (client *QueryClient) Release() error + func (client *QueryClient) ReserveBeginExecute(query string, preQueries []string, postBeginQueries []string, ...) (*sqltypes.Result, error) + func (client *QueryClient) ReserveBeginStreamExecute(query string, preQueries []string, postBeginQueries []string, ...) (*sqltypes.Result, error) + func (client *QueryClient) ReserveExecute(query string, preQueries []string, bindvars map[string]*querypb.BindVariable) (*sqltypes.Result, error) + func (client *QueryClient) ReserveStreamExecute(query string, preQueries []string, bindvars map[string]*querypb.BindVariable) (*sqltypes.Result, error) + func (client *QueryClient) ReservedID() int64 + func (client *QueryClient) Rollback() error + func (client *QueryClient) RollbackPrepared(dtid string, originalID int64) error + func (client *QueryClient) SetReservedID(id int64) + func (client *QueryClient) SetRollback(dtid string, transactionID int64) error + func (client *QueryClient) SetServingType(tabletType topodatapb.TabletType) error + func (client *QueryClient) SetTransactionID(id int64) + func (client *QueryClient) StartCommit(dtid string) error + func (client *QueryClient) Stream(query string, bindvars map[string]*querypb.BindVariable, ...) error + func (client *QueryClient) StreamBeginExecuteWithOptions(query string, preQueries []string, bindvars map[string]*querypb.BindVariable, ...) (*sqltypes.Result, error) + func (client *QueryClient) StreamExecute(query string, bindvars map[string]*querypb.BindVariable) (*sqltypes.Result, error) + func (client *QueryClient) StreamExecuteWithOptions(query string, bindvars map[string]*querypb.BindVariable, ...) (*sqltypes.Result, error) + func (client *QueryClient) StreamHealth(sendFunc func(*querypb.StreamHealthResponse) error) error + func (client *QueryClient) StreamHealthWithContext(ctx context.Context, sendFunc func(*querypb.StreamHealthResponse) error) error + func (client *QueryClient) TransactionID() int64 + func (client *QueryClient) UpdateContext(ctx context.Context) + type QueryStat struct + ErrorCount int + MysqlTime int + Plan string + Query string + QueryCount int + RowsAffected int + RowsReturned int + Table string + Time int + type Table struct + Columns []TableColumn + Name string + Type int + type TableColumn struct + Category int + IsAuto bool + Name string + type TestCase struct + Absent any + BindVars map[string]*querypb.BindVariable + Hits any + Invalidations any + Misses any + Name string + Plan string + Query string + Result [][]string + Rewritten []string + RowsAffected any + RowsReturned any + Table string + func (tc *TestCase) Benchmark(client *QueryClient) error + func (tc *TestCase) Test(name string, client *QueryClient) error + type TestQuery string + func (tq TestQuery) Benchmark(client *QueryClient) error + func (tq TestQuery) Test(name string, client *QueryClient) error + type Testable interface + Benchmark func(client *QueryClient) error + Test func(name string, client *QueryClient) error
Go to main page