vtgate

package

Go to main page

Versions in this module

v1

v1.8.0

Jun 2, 2019

v1.7.0

May 23, 2019

Changes in this version

type SafeSession

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

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

v1.6.0

Apr 24, 2019

v1.5.0

Feb 12, 2019

Changes in this version

type VSchemaKeyspaceStats

+ Error string

v1.4.0

Nov 13, 2018

v1.3.0

Oct 31, 2018

Changes in this version

+ const ExecutorTemplate

+ const VSchemaTemplate

+ var QueryLogHandler = "/debug/querylog"

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

+ var QueryLogzHandler = "/debug/querylogz"

+ var QueryzHandler = "/debug/queryz"

+ var RegisterL2VTGates []RegisterL2VTGate

+ var RegisterVTGates []RegisterVTGate

+ func RegisterPluginInitializer(initializer func())

+ func StrsEquals(a, b []string) bool

+ type Executor struct

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

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

+ func (e *Executor) IsKeyspaceRangeBasedSharded(keyspace string) bool

+ func (e *Executor) MessageAck(ctx context.Context, keyspace, name string, ids []*querypb.Value) (int64, 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) 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) VSchema() *vindexes.VSchema

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

+ type L2VTGate struct

+ type LogStats struct

+ BindVariables map[string]*querypb.BindVariable

+ CommitTime time.Duration

+ Ctx context.Context

+ EndTime time.Time

+ Error error

+ ExecuteTime time.Duration

+ Method string

+ PlanTime time.Duration

+ RowsAffected uint64

+ SQL string

+ ShardQueries uint32

+ StartTime time.Time

+ StmtType string

+ Target *querypb.Target

+ 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 RegisterL2VTGate func(queryservice.QueryService)

+ 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) ExecuteBatch(ctx context.Context, tabletType topodatapb.TabletType, asTransaction bool, ...) ([]sqltypes.Result, error)

+ func (res *Resolver) ExecuteEntityIds(ctx context.Context, sql string, ...) (*sqltypes.Result, error)

+ func (res *Resolver) GetGatewayCacheStatus() gateway.TabletCacheStatusList

+ func (res *Resolver) MessageAckKeyspaceIds(ctx context.Context, keyspace, name string, ...) (int64, error)

+ 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

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

+ type SafeSession struct

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

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

+ func (session *SafeSession) Append(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) int64

+ func (session *SafeSession) InTransaction() bool

+ func (session *SafeSession) MustRollback() bool

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

+ func (session *SafeSession) Reset()

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

+ func (session *SafeSession) SetRollback()

+ type ScatterConn struct

+ func NewScatterConn(statsName string, txConn *TxConn, gw gateway.Gateway, hc discovery.HealthCheck) *ScatterConn

+ func (stc *ScatterConn) Close() error

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

+ func (stc *ScatterConn) ExecuteBatch(ctx context.Context, batchRequest *scatterBatchRequest, ...) (qrs []sqltypes.Result, err error)

+ func (stc *ScatterConn) ExecuteEntityIds(ctx context.Context, rss []*srvtopo.ResolvedShard, sqls []string, ...) (*sqltypes.Result, error)

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

+ func (stc *ScatterConn) GetGatewayCacheStatus() gateway.TabletCacheStatusList

+ func (stc *ScatterConn) MessageAck(ctx context.Context, rss []*srvtopo.ResolvedShard, values [][]*querypb.Value, ...) (int64, error)

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

+ func (stc *ScatterConn) SplitQuery(ctx context.Context, sql string, ...) ([]*vtgatepb.SplitQueryResponse_Part, 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

+ func (stc *ScatterConn) UpdateStream(ctx context.Context, rs *srvtopo.ResolvedShard, timestamp int64, ...) error

+ type TxConn struct

+ func NewTxConn(gw gateway.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) Resolve(ctx context.Context, dtid string) error

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

+ type VSchemaKeyspaceStats struct

+ Keyspace string

+ Sharded bool

+ TableCount int

+ VindexCount int

+ type VSchemaManager struct

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

+ func (vm *VSchemaManager) UpdateVSchema(ctx context.Context, keyspace 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, hc discovery.HealthCheck, serv srvtopo.Server, ...) *VTGate

+ func (vtg *VTGate) Begin(ctx context.Context, singledb bool) (*vtgatepb.Session, error)

+ func (vtg *VTGate) Commit(ctx context.Context, twopc bool, 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) ExecuteBatchKeyspaceIds(ctx context.Context, queries []*vtgatepb.BoundKeyspaceIdQuery, ...) ([]sqltypes.Result, error)

+ func (vtg *VTGate) ExecuteBatchShards(ctx context.Context, queries []*vtgatepb.BoundShardQuery, ...) ([]sqltypes.Result, error)

+ func (vtg *VTGate) ExecuteEntityIds(ctx context.Context, sql string, ...) (*sqltypes.Result, error)

+ func (vtg *VTGate) ExecuteKeyRanges(ctx context.Context, sql string, ...) (*sqltypes.Result, error)

+ func (vtg *VTGate) ExecuteKeyspaceIds(ctx context.Context, sql string, ...) (*sqltypes.Result, error)

+ func (vtg *VTGate) ExecuteShards(ctx context.Context, sql string, ...) (*sqltypes.Result, error)

+ func (vtg *VTGate) Gateway() gateway.Gateway

+ func (vtg *VTGate) GetGatewayCacheStatus() gateway.TabletCacheStatusList

+ func (vtg *VTGate) GetSrvKeyspace(ctx context.Context, keyspace string) (*topodatapb.SrvKeyspace, error)

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

+ func (vtg *VTGate) IsHealthy() error

+ func (vtg *VTGate) L2VTGate() *L2VTGate

+ func (vtg *VTGate) MessageAck(ctx context.Context, keyspace string, name string, ids []*querypb.Value) (int64, error)

+ func (vtg *VTGate) MessageAckKeyspaceIds(ctx context.Context, keyspace string, name string, ...) (int64, error)

+ func (vtg *VTGate) MessageStream(ctx context.Context, keyspace string, shard string, ...) error

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

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

+ func (vtg *VTGate) SplitQuery(ctx context.Context, keyspace string, sql string, ...) ([]*vtgatepb.SplitQueryResponse_Part, error)

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

+ func (vtg *VTGate) StreamExecuteKeyRanges(ctx context.Context, sql string, ...) error

+ func (vtg *VTGate) StreamExecuteKeyspaceIds(ctx context.Context, sql string, ...) error

+ func (vtg *VTGate) StreamExecuteShards(ctx context.Context, sql string, ...) error

+ func (vtg *VTGate) UpdateStream(ctx context.Context, keyspace string, shard string, ...) error

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

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