sql

package

Go to main page

Versions in this module

v1

v1.1.2

Oct 26, 2017

v1.1.1

Oct 16, 2017

v1.1.0

Oct 4, 2017

Changes in this version

+ const MaxSQLBytes

+ var ClusterOrganization = settings.RegisterStringSetting("cluster.organization", "organization name", "")

+ func CheckPrivilege(user string, descriptor sqlbase.DescriptorProto, privilege privilege.Kind) error

+ func DropTableDesc(ctx context.Context, tableDesc *sqlbase.TableDescriptor, db *client.DB, ...) error

+ func DropTableName(ctx context.Context, tableDesc *sqlbase.TableDescriptor, db *client.DB, ...) error

+ func HoistConstraints(n *parser.CreateTable)

+ func MustGetDatabaseDescByID(ctx context.Context, txn *client.Txn, id sqlbase.ID) (*sqlbase.DatabaseDescriptor, error)

+ func MustGetTableDesc(ctx context.Context, txn *client.Txn, vt VirtualTabler, tn *parser.TableName, ...) (*sqlbase.TableDescriptor, error)

+ func MustGetTableOrViewDesc(ctx context.Context, txn *client.Txn, vt VirtualTabler, tn *parser.TableName, ...) (*sqlbase.TableDescriptor, error)

+ func NewWireFailureError(err error) error

+ func RecomputeViewDependencies(ctx context.Context, txn *client.Txn, e *Executor) error

type DependencyAnalyzer

+ Analyze func(runParams, planNode) error

+ type DistLoader struct

+ func (l *DistLoader) LoadCSV(ctx context.Context, job *jobs.Job, db *client.DB, evalCtx parser.EvalContext, ...) error

+ type DistSQLPlannerTestingKnobs struct

+ OverrideHealthCheck func(node roachpb.NodeID, addrString string) error

type EventLogType

+ const EventLogSetClusterSetting

type Executor

+ func (e *Executor) ExecutePreparedStatement(session *Session, stmt *PreparedStatement, pinfo *parser.PlaceholderInfo) error

+ func (e *Executor) ExecuteStatementsBuffered(session *Session, stmts string, pinfo *parser.PlaceholderInfo, ...) (StatementResults, error)

+ func (e *Executor) FillUnimplementedErrorCounts(fill map[string]int64)

+ func (e *Executor) GetVirtualTabler() VirtualTabler

+ func (e *Executor) PrepareStmt(session *Session, s *parser.Prepare) error

+ func (e *Executor) ResetUnimplementedCounts()

type ExecutorConfig

+ JobRegistry *jobs.Registry

+ SessionRegistry *SessionRegistry

+ Settings *cluster.Settings

+ StatusServer serverpb.StatusServer

+ func (ec *ExecutorConfig) Organization() string

type ExecutorTestingKnobs

+ AfterExecute func(ctx context.Context, stmt string, res StatementResult, err error)

+ BeforeAutoCommit func(ctx context.Context, stmt string) error

+ BeforeExecute func(ctx context.Context, stmt string, isParallel bool)

+ DistSQLPlannerKnobs DistSQLPlannerTestingKnobs

type InternalExecutor

+ func (ie InternalExecutor) QueryRowsInTransaction(ctx context.Context, opName string, txn *client.Txn, statement string, ...) ([]parser.Datums, error)

+ type NodeInfo struct

+ AdminURL func() *url.URL

+ ClusterID func() uuid.UUID

+ NodeID *base.NodeIDContainer

+ PGURL func(*url.Userinfo) (*url.URL, error)

type ParallelizeQueue

+ func (pq *ParallelizeQueue) Errs() []error

type PlanHookState

+ DistLoader func() *DistLoader

+ EvalContext func() parser.EvalContext

+ TypeAsStringOpts func(opts parser.KVOptions, valuelessOpts map[string]bool) (func() (map[string]string, error), error)

type PreparedStatement

+ Statement parser.Statement

+ Str string

+ TypeHints parser.PlaceholderTypes

+ Types parser.PlaceholderTypes

type PreparedStatements

+ func (ps PreparedStatements) NewFromString(e *Executor, name, query string, placeholderHints parser.PlaceholderTypes) (*PreparedStatement, error)

+ type ResultsGroup interface

+ Close func()

+ Flush func(context.Context) error

+ NewStatementResult func() StatementResult

+ Reset func(context.Context)

+ ResultsSentToClient func() bool

+ type ResultsWriter interface

+ NewResultsGroup func() ResultsGroup

+ SetEmptyQuery func()

+ type RowResultWriter struct

+ func NewRowResultWriter(statementType parser.StatementType, rowContainer *sqlbase.RowContainer) *RowResultWriter

+ func (b *RowResultWriter) AddRow(ctx context.Context, row parser.Datums) error

+ func (b *RowResultWriter) IncrementRowsAffected(n int)

+ func (b *RowResultWriter) StatementType() parser.StatementType

type SchemaChangerTestingKnobs

+ RunBeforeIndexBackfill func()

+ RunBeforePublishWriteAndDelete func()

type Session

+ ActiveSyncQueries []uint128.Uint128

+ ClientAddr string

+ ResultsWriter ResultsWriter

+ SafeUpdates bool

+ Tracing SessionTracing

+ func (s *Session) EmergencyClose()

+ func (s *Session) FinishPlan()

+ type SessionRegistry struct

+ func MakeSessionRegistry() *SessionRegistry

+ func (r *SessionRegistry) CancelQuery(queryIDStr string, username string) (bool, error)

+ func (r *SessionRegistry) SerializeAll() []serverpb.Session

+ type SessionTracing struct

+ func (st *SessionTracing) Enabled() bool

+ func (st *SessionTracing) KVTracingEnabled() bool

+ func (st *SessionTracing) RecordingType() tracing.RecordingType

+ func (st *SessionTracing) StartTracing(recType tracing.RecordingType, traceKV bool) error

+ func (st *SessionTracing) StopTracing() error

+ type Statement struct

+ AST parser.Statement

+ ExpectedTypes sqlbase.ResultColumns

+ func (s Statement) String() string

+ type StatementList []Statement

+ func NewStatementList(stmts parser.StatementList) StatementList

+ func (l StatementList) Format(buf *bytes.Buffer, f parser.FmtFlags)

+ func (l StatementList) String() string

+ type StatementResult interface

+ AddRow func(ctx context.Context, row parser.Datums) error

+ BeginResult func(stmt parser.Statement)

+ CloseResult func() error

+ IncrementRowsAffected func(n int)

+ PGTag func() string

+ RowsAffected func() int

+ SetColumns func(columns sqlbase.ResultColumns)

+ StatementType func() parser.StatementType

+ type TableCollection struct

type TxnStateEnum

+ const AutoRetry

+ type WireFailureError struct

+ func (e WireFailureError) Error() string

v1.1.0-rc.1

Oct 4, 2017

v1.0.7

Feb 11, 2018

v1.0.6

Sep 9, 2017

Changes in this version

+ func TestingEnableParallelStmts() func()

v1.0.5

Aug 17, 2017

v1.0.4

Jul 20, 2017

v1.0.3

Jul 6, 2017

v1.0.2

Jun 7, 2017

v1.0.1

May 18, 2017

Changes in this version

+ const JobTypeBackup

+ const JobTypeRestore

+ const PgServerVersion

+ const TableTruncateChunkSize

+ var DistSQLClusterExecMode = settings.RegisterEnumSetting("sql.defaults.distsql", "Default distributed SQL execution mode", "Auto", ...)

+ var ErrIntOverflowJobs = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthJobs = fmt.Errorf("proto: negative length found during unmarshaling")

+ var LeaseDuration = 5 * time.Minute

+ var MetaDdl = metric.Metadata

+ var MetaDelete = metric.Metadata

+ var MetaDistSQLExecLatency = metric.Metadata

+ var MetaDistSQLSelect = metric.Metadata

+ var MetaDistSQLServiceLatency = metric.Metadata

+ var MetaInsert = metric.Metadata

+ var MetaMisc = metric.Metadata

+ var MetaQuery = metric.Metadata

+ var MetaSQLExecLatency = metric.Metadata

+ var MetaSQLServiceLatency = metric.Metadata

+ var MetaSelect = metric.Metadata

+ var MetaTxnAbort = metric.Metadata

+ var MetaTxnBegin = metric.Metadata

+ var MetaTxnCommit = metric.Metadata

+ var MetaTxnRollback = metric.Metadata

+ var MetaUpdate = metric.Metadata

+ var MinLeaseDuration = time.Minute

+ var MinSchemaChangeLeaseDuration = time.Minute

+ var NilVirtualTabler nilVirtualTabler

+ var SQLStatsCollectionLatencyThreshold = settings.RegisterDurationSetting("sql.metrics.statement_details.threshold", ...)

+ var SchemaChangeLeaseDuration = 5 * time.Minute

+ var StmtStatsEnable = settings.RegisterBoolSetting("sql.metrics.statement_details.enabled", ...)

+ func AddPlanHook(f planHookFn)

+ func EvalAsOfTimestamp(evalCtx *parser.EvalContext, asOf parser.AsOfClause, max hlc.Timestamp) (hlc.Timestamp, error)

+ func GenerateInsertRow(defaultExprs []parser.TypedExpr, ...) (parser.Datums, error)

+ func GenerateUniqueDescID(ctx context.Context, txn *client.Txn) (sqlbase.ID, error)

+ func GetKeysForTableDescriptor(tableDesc *sqlbase.TableDescriptor) (zoneKey roachpb.Key, nameKey roachpb.Key, descKey roachpb.Key)

+ func GetTableDesc(cfg config.SystemConfig, id sqlbase.ID) (*sqlbase.TableDescriptor, error)

+ func GetUserHashedPassword(ctx context.Context, executor *Executor, metrics *MemoryMetrics, ...) ([]byte, error)

+ func GetZoneConfig(cfg config.SystemConfig, id uint32) (config.ZoneConfig, bool, error)

+ func HashAppName(appName string) string

+ func IsStmtParallelized(stmt parser.Statement) bool

+ func MakeTableDesc(ctx context.Context, txn *client.Txn, vt VirtualTabler, ...) (sqlbase.TableDescriptor, error)

+ func MustGetDatabaseDesc(ctx context.Context, txn *client.Txn, vt VirtualTabler, name string) (*sqlbase.DatabaseDescriptor, error)

+ func NormalizeAndValidateUsername(username string) (string, error)

+ func ProcessDefaultColumns(cols []sqlbase.ColumnDescriptor, tableDesc *sqlbase.TableDescriptor, ...) ([]sqlbase.ColumnDescriptor, []parser.TypedExpr, error)

+ func SetTxnTimestamps(txn *client.Txn, ts hlc.Timestamp)

+ func TestDisableTableLeases() func()

+ type AppStatementStatistics map[string]map[string]roachpb.StatementStatistics

+ type AuthorizationAccessor interface

+ CheckPrivilege func(descriptor sqlbase.DescriptorProto, privilege privilege.Kind) error

+ RequireSuperUser func(action string) error

+ type BackupJobDetails struct

+ func (*BackupJobDetails) Descriptor() ([]byte, []int)

+ func (*BackupJobDetails) ProtoMessage()

+ func (m *BackupJobDetails) Marshal() (dAtA []byte, err error)

+ func (m *BackupJobDetails) MarshalTo(dAtA []byte) (int, error)

+ func (m *BackupJobDetails) Reset()

+ func (m *BackupJobDetails) Size() (n int)

+ func (m *BackupJobDetails) String() string

+ func (m *BackupJobDetails) Unmarshal(dAtA []byte) error

+ type CopyDataBlock struct

+ Done bool

+ func (CopyDataBlock) Format(buf *bytes.Buffer, f parser.FmtFlags)

+ func (CopyDataBlock) StatementTag() string

+ func (CopyDataBlock) StatementType() parser.StatementType

+ func (CopyDataBlock) String() string

+ type DatabaseAccessor interface

+ type DependencyAnalyzer interface

+ Clear func(planNode)

+ Independent func(context.Context, planNode, planNode) bool

+ var NoDependenciesAnalyzer DependencyAnalyzer = dependencyAnalyzerFunc(func(_ planNode, _ planNode) bool { ... })

+ func NewSpanBasedDependencyAnalyzer() DependencyAnalyzer

+ type DescriptorAccessor interface

+ type DistSQLExecMode int64

+ const DistSQLAlways

+ const DistSQLAuto

+ const DistSQLOff

+ const DistSQLOn

+ func DistSQLExecModeFromInt(val int64) DistSQLExecMode

+ func DistSQLExecModeFromString(val string) DistSQLExecMode

+ func (m DistSQLExecMode) String() string

+ type EventLogType string

+ const EventLogAlterTable

+ const EventLogCreateDatabase

+ const EventLogCreateIndex

+ const EventLogCreateTable

+ const EventLogCreateView

+ const EventLogDropDatabase

+ const EventLogDropIndex

+ const EventLogDropTable

+ const EventLogDropView

+ const EventLogFinishSchemaChange

+ const EventLogNodeJoin

+ const EventLogNodeRestart

+ const EventLogReverseSchemaChange

+ type EventLogger struct

+ func MakeEventLogger(leaseMgr *LeaseManager) EventLogger

+ func (ev EventLogger) InsertEventRecord(ctx context.Context, txn *client.Txn, eventType EventLogType, ...) error

+ type Executor struct

+ DdlCount *metric.Counter

+ DeleteCount *metric.Counter

+ DistSQLExecLatency *metric.Histogram

+ DistSQLSelectCount *metric.Counter

+ DistSQLServiceLatency *metric.Histogram

+ InsertCount *metric.Counter

+ MiscCount *metric.Counter

+ QueryCount *metric.Counter

+ SQLExecLatency *metric.Histogram

+ SQLServiceLatency *metric.Histogram

+ SelectCount *metric.Counter

+ TxnAbortCount *metric.Counter

+ TxnBeginCount *metric.Counter

+ TxnCommitCount *metric.Counter

+ TxnRollbackCount *metric.Counter

+ UpdateCount *metric.Counter

+ func NewExecutor(cfg ExecutorConfig, stopper *stop.Stopper) *Executor

+ func (e *Executor) AnnotateCtx(ctx context.Context) context.Context

+ func (e *Executor) CopyData(session *Session, data string) StatementResults

+ func (e *Executor) CopyDone(session *Session) StatementResults

+ func (e *Executor) ExecuteStatements(session *Session, stmts string, pinfo *parser.PlaceholderInfo) StatementResults

+ func (e *Executor) GetScrubbedStmtStats() AppStatementStatistics

+ func (e *Executor) IsVirtualDatabase(name string) bool

+ func (e *Executor) Prepare(query string, session *Session, pinfo parser.PlaceholderTypes) (*PreparedStatement, error)

+ func (e *Executor) ResetStatementStats(ctx context.Context)

+ func (e *Executor) SetDistSQLSpanResolver(spanResolver distsqlplan.SpanResolver)

+ func (e *Executor) Start(ctx context.Context, startupMemMetrics *MemoryMetrics, ...)

+ type ExecutorConfig struct

+ AmbientCtx log.AmbientContext

+ Clock *hlc.Clock

+ ClusterID func() uuid.UUID

+ DB *client.DB

+ DistSQLSrv *distsqlrun.ServerImpl

+ DistSender *kv.DistSender

+ Gossip *gossip.Gossip

+ HistogramWindowInterval time.Duration

+ LeaseHolderCache *kv.LeaseHolderCache

+ LeaseManager *LeaseManager

+ NodeID *base.NodeIDContainer

+ RPCContext *rpc.Context

+ RangeDescriptorCache *kv.RangeDescriptorCache

+ SchemaChangerTestingKnobs *SchemaChangerTestingKnobs

+ TestingKnobs *ExecutorTestingKnobs

+ type ExecutorTestingKnobs struct

+ BeforePrepare func(ctx context.Context, stmt string, planner *planner) (*PreparedStatement, error)

+ CheckStmtStringChange bool

+ DisableAutoCommit bool

+ OverrideDistSQLMode *settings.EnumSetting

+ StatementFilter StatementFilter

+ WaitForGossipUpdate bool

+ func (*ExecutorTestingKnobs) ModuleTestingKnobs()

+ type InternalExecutor struct

+ LeaseManager *LeaseManager

+ func (ie InternalExecutor) ExecuteStatementInTransaction(ctx context.Context, opName string, txn *client.Txn, statement string, ...) (int, error)

+ func (ie InternalExecutor) GetTableSpan(ctx context.Context, user string, txn *client.Txn, dbName, tableName string) (roachpb.Span, error)

+ func (ie InternalExecutor) QueryRowInTransaction(ctx context.Context, opName string, txn *client.Txn, statement string, ...) (parser.Datums, error)

+ type JobLogger struct

+ Job JobRecord

+ func NewJobLogger(db *client.DB, leaseMgr *LeaseManager, job JobRecord) JobLogger

+ func (jl *JobLogger) Created(ctx context.Context) error

+ func (jl *JobLogger) Failed(ctx context.Context, err error)

+ func (jl *JobLogger) JobID() *int64

+ func (jl *JobLogger) Progressed(ctx context.Context, fractionCompleted float32) error

+ func (jl *JobLogger) Started(ctx context.Context) error

+ func (jl *JobLogger) Succeeded(ctx context.Context) error

+ type JobPayload struct

+ Description string

+ DescriptorIDs []github_com_cockroachdb_cockroach_pkg_sql_sqlbase.ID

+ Details isJobPayload_Details

+ Error string

+ FinishedMicros int64

+ FractionCompleted float32

+ ModifiedMicros int64

+ StartedMicros int64

+ Username string

+ func (*JobPayload) Descriptor() ([]byte, []int)

+ func (*JobPayload) ProtoMessage()

+ func (*JobPayload) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *JobPayload) GetBackup() *BackupJobDetails

+ func (m *JobPayload) GetDetails() isJobPayload_Details

+ func (m *JobPayload) GetRestore() *RestoreJobDetails

+ func (m *JobPayload) Marshal() (dAtA []byte, err error)

+ func (m *JobPayload) MarshalTo(dAtA []byte) (int, error)

+ func (m *JobPayload) Reset()

+ func (m *JobPayload) Size() (n int)

+ func (m *JobPayload) String() string

+ func (m *JobPayload) Unmarshal(dAtA []byte) error

+ type JobPayload_Backup struct

+ Backup *BackupJobDetails

+ func (m *JobPayload_Backup) MarshalTo(dAtA []byte) (int, error)

+ func (m *JobPayload_Backup) Size() (n int)

+ type JobPayload_Restore struct

+ Restore *RestoreJobDetails

+ func (m *JobPayload_Restore) MarshalTo(dAtA []byte) (int, error)

+ func (m *JobPayload_Restore) Size() (n int)

+ type JobRecord struct

+ Description string

+ DescriptorIDs sqlbase.IDs

+ Details interface{}

+ Username string

+ type JobStatus string

+ const JobStatusFailed

+ const JobStatusPending

+ const JobStatusRunning

+ const JobStatusSucceeded

+ type LeaseCollection struct

+ type LeaseManager struct

+ func NewLeaseManager(nodeID *base.NodeIDContainer, db client.DB, clock *hlc.Clock, ...) *LeaseManager

+ func (m *LeaseManager) Acquire(ctx context.Context, txn *client.Txn, tableID sqlbase.ID, ...) (*LeaseState, error)

+ func (m *LeaseManager) AcquireByName(ctx context.Context, txn *client.Txn, dbID sqlbase.ID, tableName string) (*LeaseState, error)

+ func (m *LeaseManager) RefreshLeases(s *stop.Stopper, db *client.DB, gossip *gossip.Gossip)

+ func (m *LeaseManager) Release(lease *LeaseState) error

+ func (m *LeaseManager) SetDraining(drain bool)

+ type LeaseManagerTestingKnobs struct

+ GossipUpdateEvent func(config.SystemConfig)

+ LeaseStoreTestingKnobs LeaseStoreTestingKnobs

+ TestingLeasesRefreshedEvent func(config.SystemConfig)

+ func (*LeaseManagerTestingKnobs) ModuleTestingKnobs()

+ type LeaseState struct

+ func (s *LeaseState) Expiration() time.Time

+ func (s *LeaseState) Refcount() int

+ func (s *LeaseState) String() string

+ type LeaseStore struct

+ func (s LeaseStore) Acquire(ctx context.Context, txn *client.Txn, tableID sqlbase.ID, ...) (*LeaseState, error)

+ func (s LeaseStore) Publish(ctx context.Context, tableID sqlbase.ID, ...) (*sqlbase.Descriptor, error)

+ func (s LeaseStore) Release(ctx context.Context, stopper *stop.Stopper, lease *LeaseState)

+ func (s LeaseStore) WaitForOneVersion(ctx context.Context, tableID sqlbase.ID, retryOpts retry.Options) (sqlbase.DescriptorVersion, error)

+ type LeaseStoreTestingKnobs struct

+ CanUseExpiredLeases bool

+ LeaseAcquiredEvent func(lease *LeaseState, err error)

+ LeaseAcquiringEvent func(tableID sqlbase.ID, txn *client.Txn)

+ LeaseReleasedEvent func(lease *LeaseState, err error)

+ RemoveOnceDereferenced bool

+ func (*LeaseStoreTestingKnobs) ModuleTestingKnobs()

+ type MemoryMetrics struct

+ CurBytesCount *metric.Counter

+ MaxBytesHist *metric.Histogram

+ SessionCurBytesCount *metric.Counter

+ SessionMaxBytesHist *metric.Histogram

+ TxnCurBytesCount *metric.Counter

+ TxnMaxBytesHist *metric.Histogram

+ func MakeMemMetrics(endpoint string, histogramWindow time.Duration) MemoryMetrics

+ func (MemoryMetrics) MetricStruct()

+ type ParallelizeQueue struct

+ func MakeParallelizeQueue(analyzer DependencyAnalyzer) ParallelizeQueue

+ func (pq *ParallelizeQueue) Add(ctx context.Context, plan planNode, exec func(planNode) error)

+ func (pq *ParallelizeQueue) Err() error

+ func (pq *ParallelizeQueue) Len() int

+ func (pq *ParallelizeQueue) Wait() error

+ type PlanHookState interface

+ ExecCfg func() *ExecutorConfig

+ LeaseMgr func() *LeaseManager

+ TypeAsString func(e *parser.Expr) (func() string, error)

+ TypeAsStringArray func(e *parser.Exprs) (func() []string, error)

+ User func() string

+ type PreparedPortal struct

+ ProtocolMeta interface{}

+ Qargs parser.QueryArguments

+ Stmt *PreparedStatement

+ type PreparedPortals struct

+ func (pp PreparedPortals) Delete(ctx context.Context, name string) bool

+ func (pp PreparedPortals) Exists(name string) bool

+ func (pp PreparedPortals) Get(name string) (*PreparedPortal, bool)

+ func (pp PreparedPortals) New(ctx context.Context, name string, stmt *PreparedStatement, ...) (*PreparedPortal, error)

+ type PreparedStatement struct

+ Columns sqlbase.ResultColumns

+ ProtocolMeta interface{}

+ Query string

+ SQLTypes parser.PlaceholderTypes

+ Type parser.StatementType

+ type PreparedStatements struct

+ func (ps *PreparedStatements) DeleteAll(ctx context.Context)

+ func (ps PreparedStatements) Delete(ctx context.Context, name string) bool

+ func (ps PreparedStatements) Exists(name string) bool

+ func (ps PreparedStatements) Get(name string) (*PreparedStatement, bool)

+ func (ps PreparedStatements) New(e *Executor, name, query string, placeholderHints parser.PlaceholderTypes) (*PreparedStatement, error)

+ type RestoreJobDetails struct

+ func (*RestoreJobDetails) Descriptor() ([]byte, []int)

+ func (*RestoreJobDetails) ProtoMessage()

+ func (m *RestoreJobDetails) Marshal() (dAtA []byte, err error)

+ func (m *RestoreJobDetails) MarshalTo(dAtA []byte) (int, error)

+ func (m *RestoreJobDetails) Reset()

+ func (m *RestoreJobDetails) Size() (n int)

+ func (m *RestoreJobDetails) String() string

+ func (m *RestoreJobDetails) Unmarshal(dAtA []byte) error

+ type Result struct

+ Columns sqlbase.ResultColumns

+ Err error

+ PGTag string

+ Rows *sqlbase.RowContainer

+ RowsAffected int

+ Type parser.StatementType

+ func (r *Result) Close(ctx context.Context)

+ type ResultList []Result

+ func (rl ResultList) Close(ctx context.Context)

+ type RowBuffer struct

+ func (rb *RowBuffer) Next() bool

+ func (rb *RowBuffer) Values() parser.Datums

+ type SchemaAccessor interface

+ type SchemaChangeManager struct

+ func NewSchemaChangeManager(testingKnobs *SchemaChangerTestingKnobs, db client.DB, ...) *SchemaChangeManager

+ func (s *SchemaChangeManager) Start(stopper *stop.Stopper)

+ type SchemaChanger struct

+ func NewSchemaChangerForTesting(tableID sqlbase.ID, mutationID sqlbase.MutationID, nodeID roachpb.NodeID, ...) SchemaChanger

+ func (sc *SchemaChanger) AcquireLease(ctx context.Context) (sqlbase.TableDescriptor_SchemaChangeLease, error)

+ func (sc *SchemaChanger) ExtendLease(ctx context.Context, existingLease *sqlbase.TableDescriptor_SchemaChangeLease) error

+ func (sc *SchemaChanger) MaybeIncrementVersion(ctx context.Context) (*sqlbase.Descriptor, error)

+ func (sc *SchemaChanger) ReleaseLease(ctx context.Context, lease sqlbase.TableDescriptor_SchemaChangeLease) error

+ func (sc *SchemaChanger) RunStateMachineBeforeBackfill(ctx context.Context) error

+ type SchemaChangerTestingKnobs struct

+ AsyncExecNotification func() error

+ AsyncExecQuickly bool

+ BackfillChunkSize int64

+ RenameOldNameNotInUseNotification func()

+ RunAfterBackfillChunk func()

+ RunAfterTableNameDropped func() error

+ RunBeforeBackfill func() error

+ RunBeforeBackfillChunk func(sp roachpb.Span) error

+ SyncFilter SyncSchemaChangersFilter

+ WriteCheckpointInterval time.Duration

+ func (*SchemaChangerTestingKnobs) ModuleTestingKnobs()

+ type Session struct

+ ApplicationName string

+ Database string

+ DefaultIsolationLevel enginepb.IsolationType

+ DistSQLMode DistSQLExecMode

+ Location *time.Location

+ PreparedPortals PreparedPortals

+ PreparedStatements PreparedStatements

+ SearchPath parser.SearchPath

+ TxnState txnState

+ User string

+ func NewSession(ctx context.Context, args SessionArgs, e *Executor, remote net.Addr, ...) *Session

+ func (s *Session) ClearStatementsAndPortals(ctx context.Context)

+ func (s *Session) Ctx() context.Context

+ func (s *Session) Finish(e *Executor)

+ func (s *Session) OpenAccount() WrappableMemoryAccount

+ func (s *Session) ProcessCopyData(ctx context.Context, data string, msg copyMsg) (parser.StatementList, error)

+ func (s *Session) StartMonitor(pool *mon.MemoryMonitor, reserved mon.BoundAccount)

+ func (s *Session) StartUnlimitedMonitor()

+ func (session *Session) CopyEnd(ctx context.Context)

+ type SessionArgs struct

+ ApplicationName string

+ Database string

+ User string

+ type StatementFilter func(context.Context, string, *Result)

+ type StatementResults struct

+ Empty bool

+ func (s *StatementResults) Close(ctx context.Context)

+ type SyncSchemaChangersFilter func(TestingSchemaChangerCollection)

+ type TestingSchemaChangerCollection struct

+ func (tscc TestingSchemaChangerCollection) ClearSchemaChangers()

+ type TxnStateEnum int

+ const Aborted

+ const CommitWait

+ const NoTxn

+ const Open

+ const RestartWait

+ func (i TxnStateEnum) String() string

+ type VirtualTabler interface

+ type WrappableMemoryAccount struct

+ func (w *WrappableMemoryAccount) Wsession(s *Session) WrappedMemoryAccount

+ func (w *WrappableMemoryAccount) Wtxn(s *Session) WrappedMemoryAccount

+ type WrappedMemoryAccount struct

+ func (w WrappedMemoryAccount) Clear(ctx context.Context)

+ func (w WrappedMemoryAccount) Close(ctx context.Context)

+ func (w WrappedMemoryAccount) Grow(ctx context.Context, extraSize int64) error

+ func (w WrappedMemoryAccount) OpenAndInit(ctx context.Context, initialAllocation int64) error

+ func (w WrappedMemoryAccount) ResizeItem(ctx context.Context, oldSize, newSize int64) error

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