vtgate

Jun 27, 2024

Changes in this version

type SchemaInfo

+ UDFs func(ks string) []string

Apr 4, 2024 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Apr 4, 2024 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Mar 14, 2024 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Mar 6, 2024 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Changes in this version

type SafeSession

+ func (session *SafeSession) ForeignKeyChecks() *bool

type TabletGateway

+ func (gw *TabletGateway) TabletsHealthyStatus() discovery.TabletsCacheStatusList

Apr 4, 2024 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Mar 14, 2024 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Dec 20, 2023 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Nov 22, 2023 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Nov 6, 2023 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Changes in this version

type Executor

+ func (e *Executor) ClearPlans()

+ func (e *Executor) Close()

+ func (e *Executor) ForEachPlan(each func(plan *engine.Plan) bool)

+ func (e *Executor) SetQueryLogger(ql *streamlog.StreamLogger[*logstats.LogStats])

+ type PlanCache = theine.Store[PlanCacheKey, *engine.Plan]

+ func DefaultPlanCache() *PlanCache

+ type PlanCacheKey = theine.HashKey256

type SafeSession

+ func (session *SafeSession) GetMigrationContext() string

+ func (session *SafeSession) SetMigrationContext(migrationContext string)

type TabletGateway

+ func (gw *TabletGateway) GetServingKeyspaces() []string

type VSchemaKeyspaceStats

+ VindexUnknownParamsCount int

Mar 14, 2024 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Dec 20, 2023 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Nov 13, 2023 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Oct 3, 2023 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Aug 18, 2023 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Jul 28, 2023 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Jun 27, 2023 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Changes in this version

type SafeSession

+ func (session *SafeSession) GetPrepareData(name string) *vtgatepb.PrepareData

+ func (session *SafeSession) GetUDV(name string) *querypb.BindVariable

+ func (session *SafeSession) StorePrepareData(key string, value *vtgatepb.PrepareData)

+ func (session *SafeSession) TimeZone() *time.Location

Jun 13, 2023 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Jun 6, 2023 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Dec 20, 2023 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Nov 13, 2023 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Oct 3, 2023 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Aug 18, 2023 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Jul 28, 2023 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

May 9, 2023 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Mar 30, 2023 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Feb 28, 2023 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Changes in this version

+ func SetQueryLogger(logger *streamlog.StreamLogger)

type SafeSession

+ func (session *SafeSession) GetQueryTimeout() int64

+ func (session *SafeSession) SetQueryTimeout(queryTimeout int64)

type SchemaInfo

+ Views func(ks string) map[string]sqlparser.SelectStatement

Feb 8, 2023 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Oct 3, 2023 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Jul 28, 2023 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Mar 30, 2023 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Dec 14, 2022 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Nov 29, 2022 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Oct 25, 2022 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Changes in this version

type SafeSession

+ func (session *SafeSession) EnableLogging()

+ func (session *SafeSession) FindAndChangeSessionIfInSingleTxMode(keyspace, shard string, tabletType topodatapb.TabletType, ...) (int64, int64, *topodatapb.TabletAlias, error)

Mar 30, 2023 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Nov 29, 2022 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Sep 1, 2022 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Jul 26, 2022 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Jun 28, 2022 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Changes in this version

type Executor

+ func (e *Executor) ReleaseLock(ctx context.Context, session *SafeSession) error

type SafeSession

+ func (session *SafeSession) AddAdvisoryLock(name string)

+ func (session *SafeSession) ClearAdvisoryLock()

+ func (session *SafeSession) GetSystemVariables(f func(k string, v string))

+ func (session *SafeSession) HasAdvisoryLock() bool

+ func (session *SafeSession) HasSystemVariables() bool

+ func (session *SafeSession) RemoveAdvisoryLock(name string)

+ func (session *SafeSession) RemoveInternalSavepoint()

Sep 1, 2022 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Jul 26, 2022 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Changes in this version

type SafeSession

+ func (session *SafeSession) CanAddSavepoint() bool

+ func (session *SafeSession) IsRollbackSet() bool

+ func (session *SafeSession) SavepointRollback()

+ func (session *SafeSession) SetRollbackCommand()

+ func (session *SafeSession) SetSavepoint(name string)

Apr 14, 2022 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Feb 22, 2022 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Changes in this version

type SafeSession

+ func (session *SafeSession) InsertSavepoints() bool

+ func (session *SafeSession) SavePoints() []string

+ func (session *SafeSession) SetSavepointState(spNeed bool)

type TabletGateway

+ func (gw *TabletGateway) DefaultConnCollation() collations.ID

Sep 1, 2022 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Jul 27, 2022 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

May 20, 2022 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Jan 10, 2022 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Dec 17, 2021 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Dec 14, 2021 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Oct 26, 2021 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Changes in this version

+ const MaxBufferingRetries

Jan 10, 2022 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Dec 17, 2021 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Dec 14, 2021 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Sep 9, 2021 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Jul 27, 2021 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Changes in this version

type Executor

+ func (e *Executor) ExecuteMessageStream(ctx context.Context, rss []*srvtopo.ResolvedShard, tableName string, ...) error

+ func (e *Executor) ExecuteVStream(ctx context.Context, rss []*srvtopo.ResolvedShard, filter *binlogdatapb.Filter, ...) error

+ type SchemaInfo interface

+ Tables func(ks string) map[string][]vindexes.Column

type VSchemaManager

+ func (vm *VSchemaManager) Rebuild()

+ func (vm *VSchemaManager) VSchemaUpdate(v *vschemapb.SrvVSchema, err error)

Jan 10, 2022 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Dec 17, 2021 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Dec 14, 2021 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

May 27, 2021 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

May 4, 2021 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Apr 27, 2021 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Changes in this version

+ const MaxSkew

type LogStats

+ RowsReturned uint64

type SafeSession

+ func (session *SafeSession) GetSessionEnableSystemSettings() bool

+ func (session *SafeSession) SetSessionEnableSystemSettings(allow bool)

May 25, 2021 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

May 6, 2021 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Jan 25, 2021 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Changes in this version

type SafeSession

+ func (session *SafeSession) GetDDLStrategy() string

+ func (session *SafeSession) GetSessionUUID() string

+ func (session *SafeSession) SetDDLStrategy(strategy string)

+ func (session *SafeSession) SetReadAfterWriteGTID(vtgtid string)

+ func (session *SafeSession) SetReadAfterWriteTimeout(timeout float64)

+ func (session *SafeSession) SetSessionTrackGtids(enable bool)

Oct 27, 2020 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Changes in this version

type Executor

+ func (e *Executor) Commit(ctx context.Context, safeSession *SafeSession) error

+ func (e *Executor) ExecuteLock(ctx context.Context, rs *srvtopo.ResolvedShard, query *querypb.BoundQuery, ...) (*sqltypes.Result, error)

type SafeSession

+ func (session *SafeSession) GetOrCreateOptions() *querypb.ExecuteOptions

+ func (session *SafeSession) InLockSession() bool

+ func (session *SafeSession) ResetAll()

+ func (session *SafeSession) ResetLock()

+ func (session *SafeSession) ResetShard(tabletAlias *topodatapb.TabletAlias) error

+ func (session *SafeSession) SetLockSession(lockSession *vtgatepb.Session_ShardSession)

+ func (session *SafeSession) TriggerLockHeartBeat() bool

+ func (session *SafeSession) UpdateLockHeartbeat()

type ScatterConn

+ func (stc *ScatterConn) ExecuteLock(ctx context.Context, rs *srvtopo.ResolvedShard, query *querypb.BoundQuery, ...) (*sqltypes.Result, error)

type TxConn

+ func (txc *TxConn) ReleaseAll(ctx context.Context, session *SafeSession) error

+ func (txc *TxConn) ReleaseLock(ctx context.Context, session *SafeSession) error

Jul 28, 2020 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Changes in this version

+ const ExecutorTemplate

+ const GatewayImplementationDiscovery

+ const StatusTemplate

+ const VSchemaTemplate

+ var CellsToWatch = flag.String("cells_to_watch", "", "comma-separated list of cells for watching tablets")

+ var GatewayImplementation = flag.String("gateway_implementation", "tabletgateway", ...)

+ var HealthCheckRetryDelay = flag.Duration("healthcheck_retry_delay", 2 * time.Millisecond, "health check retry delay")

+ var HealthCheckTimeout = flag.Duration("healthcheck_timeout", time.Minute, "the health check timeout period")

+ var QueryLogHandler = "/debug/querylog"

+ var QueryLogger = streamlog.New("VTGate", 10)

+ var QueryLogzHandler = "/debug/querylogz"

+ var QueryzHandler = "/debug/queryz"

+ var RegisterVTGates []RegisterVTGate

+ var RetryCount = flag.Int("retry-count", 2, "retry count")

+ func CreateFakeServers(t *testing.T) (*tabletconntest.FakeQueryService, *topo.Server, string)

+ func NewShardError(in error, target *querypb.Target, tablet *topodatapb.Tablet) error

+ func RegisterGatewayCreator(name string, gc Creator)

+ func RegisterPluginInitializer(initializer func())

+ func TestSuite(t *testing.T, name string, g Gateway, f *tabletconntest.FakeQueryService)

+ func UsingLegacyGateway() bool

+ func WaitForTablets(gw Gateway, tabletTypesToWait []topodatapb.TabletType) error

+ type Creator func(ctx context.Context, hc discovery.LegacyHealthCheck, serv srvtopo.Server, ...) Gateway

+ func GatewayCreator() Creator

+ type DiscoveryGateway struct

+ func NewDiscoveryGateway(ctx context.Context, hc discovery.LegacyHealthCheck, serv srvtopo.Server, ...) *DiscoveryGateway

+ func (dg *DiscoveryGateway) CacheStatus() TabletCacheStatusList

+ func (dg *DiscoveryGateway) Close(ctx context.Context) error

+ func (dg *DiscoveryGateway) QueryServiceByAlias(_ *topodatapb.TabletAlias) (queryservice.QueryService, error)

+ func (dg *DiscoveryGateway) RegisterStats()

+ func (dg *DiscoveryGateway) StatsUpdate(ts *discovery.LegacyTabletStats)

+ func (dg *DiscoveryGateway) TabletsCacheStatus() discovery.TabletsCacheStatusList

+ func (dg *DiscoveryGateway) WaitForTablets(ctx context.Context, tabletTypesToWait []topodatapb.TabletType) error

+ type Executor struct

+ func NewExecutor(ctx context.Context, serv srvtopo.Server, cell string, resolver *Resolver, ...) *Executor

+ func (e *Executor) CloseSession(ctx context.Context, safeSession *SafeSession) error

+ func (e *Executor) Execute(ctx context.Context, method string, safeSession *SafeSession, sql string, ...) (result *sqltypes.Result, err error)

+ func (e *Executor) ExecuteMultiShard(ctx context.Context, rss []*srvtopo.ResolvedShard, ...) (qr *sqltypes.Result, errs []error)

+ func (e *Executor) MessageStream(ctx context.Context, keyspace string, shard string, ...) error

+ func (e *Executor) ParseDestinationTarget(targetString string) (string, topodatapb.TabletType, key.Destination, error)

+ func (e *Executor) Plans() *cache.LRUCache

+ func (e *Executor) Prepare(ctx context.Context, method string, safeSession *SafeSession, sql string, ...) (fld []*querypb.Field, err error)

+ func (e *Executor) SaveVSchema(vschema *vindexes.VSchema, stats *VSchemaStats)

+ func (e *Executor) ServeHTTP(response http.ResponseWriter, request *http.Request)

+ func (e *Executor) StreamExecute(ctx context.Context, method string, safeSession *SafeSession, sql string, ...) (err error)

+ func (e *Executor) StreamExecuteMulti(ctx context.Context, query string, rss []*srvtopo.ResolvedShard, ...) error

+ func (e *Executor) VSchema() *vindexes.VSchema

+ func (e *Executor) VSchemaStats() *VSchemaStats

+ func (e *Executor) WriteScatterStats(w http.ResponseWriter)

+ type Gateway interface

+ CacheStatus func() TabletCacheStatusList

+ QueryServiceByAlias func(alias *topodatapb.TabletAlias) (queryservice.QueryService, error)

+ RegisterStats func()

+ TabletsCacheStatus func() discovery.TabletsCacheStatusList

+ WaitForTablets func(ctx context.Context, tabletTypesToWait []topodatapb.TabletType) error

+ type LogStats struct

+ BindVariables map[string]*querypb.BindVariable

+ CommitTime time.Duration

+ Ctx context.Context

+ EndTime time.Time

+ Error error

+ ExecuteTime time.Duration

+ Keyspace string

+ Method string

+ PlanTime time.Duration

+ RowsAffected uint64

+ SQL string

+ ShardQueries uint32

+ StartTime time.Time

+ StmtType string

+ Table string

+ TabletType string

+ func NewLogStats(ctx context.Context, methodName, sql string, ...) *LogStats

+ func (stats *LogStats) Context() context.Context

+ func (stats *LogStats) ContextHTML() template.HTML

+ func (stats *LogStats) EffectiveCaller() string

+ func (stats *LogStats) ErrorStr() string

+ func (stats *LogStats) EventTime() time.Time

+ func (stats *LogStats) ImmediateCaller() string

+ func (stats *LogStats) Logf(w io.Writer, params url.Values) error

+ func (stats *LogStats) RemoteAddrUsername() (string, string)

+ func (stats *LogStats) Send()

+ func (stats *LogStats) TotalTime() time.Duration

+ type RegisterVTGate func(vtgateservice.VTGateService)

+ type Resolver struct

+ func NewResolver(resolver *srvtopo.Resolver, serv srvtopo.Server, cell string, sc *ScatterConn) *Resolver

+ func (res *Resolver) Execute(ctx context.Context, sql string, bindVars map[string]*querypb.BindVariable, ...) (*sqltypes.Result, error)

+ func (res *Resolver) GetGatewayCacheStatus() TabletCacheStatusList

+ func (res *Resolver) MessageStream(ctx context.Context, keyspace string, shard string, ...) error

+ func (res *Resolver) StreamExecute(ctx context.Context, sql string, bindVars map[string]*querypb.BindVariable, ...) error

+ type SafeSession struct

+ func NewAutocommitSession(sessn *vtgatepb.Session) *SafeSession

+ func NewSafeSession(sessn *vtgatepb.Session) *SafeSession

+ func (session *SafeSession) AppendOrUpdate(shardSession *vtgatepb.Session_ShardSession, txMode vtgatepb.TransactionMode) error

+ func (session *SafeSession) AutocommitApproval() bool

+ func (session *SafeSession) ClearWarnings()

+ func (session *SafeSession) Find(keyspace, shard string, tabletType topodatapb.TabletType) (transactionID int64, reservedID int64, alias *topodatapb.TabletAlias)

+ func (session *SafeSession) InReservedConn() bool

+ func (session *SafeSession) InTransaction() bool

+ func (session *SafeSession) MustRollback() bool

+ func (session *SafeSession) RecordWarning(warning *querypb.QueryWarning)

+ func (session *SafeSession) Reset()

+ func (session *SafeSession) ResetTx()

+ func (session *SafeSession) SetAutocommittable(flag bool)

+ func (session *SafeSession) SetCommitOrder(co vtgatepb.CommitOrder)

+ func (session *SafeSession) SetOptions(options *querypb.ExecuteOptions)

+ func (session *SafeSession) SetPreQueries() []string

+ func (session *SafeSession) SetReservedConn(reservedConn bool)

+ func (session *SafeSession) SetRollback()

+ func (session *SafeSession) SetSystemVariable(name string, expr string)

+ func (session *SafeSession) SetTargetString(target string)

+ func (session *SafeSession) SetUserDefinedVariable(key string, value *querypb.BindVariable)

+ func (session *SafeSession) StoreSavepoint(sql string)

+ type ScatterConn struct

+ func NewLegacyScatterConn(statsName string, txConn *TxConn, gw Gateway, hc discovery.LegacyHealthCheck) *ScatterConn

+ func NewScatterConn(statsName string, txConn *TxConn, gw *TabletGateway) *ScatterConn

+ func (stc *ScatterConn) Close() error

+ func (stc *ScatterConn) ExecuteMultiShard(ctx context.Context, rss []*srvtopo.ResolvedShard, ...) (qr *sqltypes.Result, errs []error)

+ func (stc *ScatterConn) GetGatewayCacheStatus() TabletCacheStatusList

+ func (stc *ScatterConn) GetHealthCheckCacheStatus() discovery.TabletsCacheStatusList

+ func (stc *ScatterConn) GetLegacyHealthCheckCacheStatus() discovery.LegacyTabletsCacheStatusList

+ func (stc *ScatterConn) MessageStream(ctx context.Context, rss []*srvtopo.ResolvedShard, name string, ...) error

+ func (stc *ScatterConn) StreamExecute(ctx context.Context, query string, bindVars map[string]*querypb.BindVariable, ...) error

+ func (stc *ScatterConn) StreamExecuteMulti(ctx context.Context, query string, rss []*srvtopo.ResolvedShard, ...) error

+ type TabletCacheStatus struct

+ Addr string

+ AvgLatency float64

+ Keyspace string

+ Name string

+ QPS float64

+ QueryCount uint64

+ QueryError uint64

+ Shard string

+ TabletType topodatapb.TabletType

+ func (tcs *TabletCacheStatus) FormattedQPS() string

+ type TabletCacheStatusList []*TabletCacheStatus

+ func (gtcsl TabletCacheStatusList) Len() int

+ func (gtcsl TabletCacheStatusList) Less(i, j int) bool

+ func (gtcsl TabletCacheStatusList) Swap(i, j int)

+ type TabletGateway struct

+ func NewTabletGateway(ctx context.Context, hc discovery.HealthCheck, serv srvtopo.Server, ...) *TabletGateway

+ func (gw *TabletGateway) CacheStatus() TabletCacheStatusList

+ func (gw *TabletGateway) Close(_ context.Context) error

+ func (gw *TabletGateway) QueryServiceByAlias(alias *topodatapb.TabletAlias) (queryservice.QueryService, error)

+ func (gw *TabletGateway) RegisterStats()

+ func (gw *TabletGateway) TabletsCacheStatus() discovery.TabletsCacheStatusList

+ func (gw *TabletGateway) WaitForTablets(ctx context.Context, tabletTypesToWait []topodatapb.TabletType) error

+ type TabletStatusAggregator struct

+ Addr string

+ Keyspace string

+ Name string

+ QueryCount uint64

+ QueryError uint64

+ Shard string

+ TabletType topodatapb.TabletType

+ func NewTabletStatusAggregator(keyspace, shard string, tabletType topodatapb.TabletType, name string) *TabletStatusAggregator

+ func (tsa *TabletStatusAggregator) GetCacheStatus() *TabletCacheStatus

+ func (tsa *TabletStatusAggregator) UpdateQueryInfo(addr string, tabletType topodatapb.TabletType, elapsed time.Duration, ...)

+ type TxConn struct

+ func NewTxConn(gw Gateway, txMode vtgatepb.TransactionMode) *TxConn

+ func (txc *TxConn) Begin(ctx context.Context, session *SafeSession) error

+ func (txc *TxConn) Commit(ctx context.Context, session *SafeSession) error

+ func (txc *TxConn) Release(ctx context.Context, session *SafeSession) error

+ func (txc *TxConn) Resolve(ctx context.Context, dtid string) error

+ func (txc *TxConn) Rollback(ctx context.Context, session *SafeSession) error

+ type VSchemaKeyspaceStats struct

+ Error string

+ Keyspace string

+ Sharded bool

+ TableCount int

+ VindexCount int

+ type VSchemaManager struct

+ func (vm *VSchemaManager) GetCurrentSrvVschema() *vschemapb.SrvVSchema

+ func (vm *VSchemaManager) GetCurrentVschema() (*vindexes.VSchema, error)

+ func (vm *VSchemaManager) UpdateVSchema(ctx context.Context, ksName string, vschema *vschemapb.SrvVSchema) error

+ type VSchemaOperator interface

+ GetCurrentSrvVschema func() *vschemapb.SrvVSchema

+ GetCurrentVschema func() (*vindexes.VSchema, error)

+ UpdateVSchema func(ctx context.Context, ksName string, vschema *vschemapb.SrvVSchema) error

+ type VSchemaStats struct

+ Error string

+ Keyspaces []*VSchemaKeyspaceStats

+ func NewVSchemaStats(vschema *vindexes.VSchema, errorMessage string) *VSchemaStats

+ type VTGate struct

+ func Init(ctx context.Context, serv srvtopo.Server, cell string, ...) *VTGate

+ func LegacyInit(ctx context.Context, hc discovery.LegacyHealthCheck, serv srvtopo.Server, ...) *VTGate

+ func (vtg *VTGate) CloseSession(ctx context.Context, session *vtgatepb.Session) error

+ func (vtg *VTGate) Execute(ctx context.Context, session *vtgatepb.Session, sql string, ...) (newSession *vtgatepb.Session, qr *sqltypes.Result, err error)

+ func (vtg *VTGate) ExecuteBatch(ctx context.Context, session *vtgatepb.Session, sqlList []string, ...) (*vtgatepb.Session, []sqltypes.QueryResponse, error)

+ func (vtg *VTGate) Gateway() Gateway

+ func (vtg *VTGate) GetGatewayCacheStatus() TabletCacheStatusList

+ func (vtg *VTGate) HandlePanic(err *error)

+ func (vtg *VTGate) IsHealthy() error

+ func (vtg *VTGate) Prepare(ctx context.Context, session *vtgatepb.Session, sql string, ...) (newSession *vtgatepb.Session, fld []*querypb.Field, err error)

+ func (vtg *VTGate) ResolveTransaction(ctx context.Context, dtid string) error

+ func (vtg *VTGate) StreamExecute(ctx context.Context, session *vtgatepb.Session, sql string, ...) error

+ func (vtg *VTGate) VSchemaStats() *VSchemaStats

+ func (vtg *VTGate) VStream(ctx context.Context, tabletType topodatapb.TabletType, ...) error