sql

package

Go to main page

Versions in this module

v1

v1.1.9

Oct 1, 2018

v1.1.9-rc.1

Sep 24, 2018

v1.1.7

Mar 20, 2018

v1.1.6

Mar 2, 2018

v1.1.5

Jan 29, 2018

v1.1.4

Jan 1, 2018

v1.1.3

Nov 21, 2017

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

Incompatible versions in this module

v20.1.17+incompatible

May 11, 2021

v20.1.16+incompatible

May 3, 2021

v20.1.15+incompatible

Apr 20, 2021

v20.1.14+incompatible

Apr 12, 2021

v20.1.13+incompatible

Mar 4, 2021

v20.1.12+incompatible

Jan 25, 2021

v20.1.11+incompatible

Jan 20, 2021

v20.1.10+incompatible

Dec 15, 2020

v20.1.4-sjdebug+incompatible

Aug 17, 2020

v20.1.3+incompatible

Jun 23, 2020

v20.1.3-fix-52147+incompatible

Jul 31, 2020

v20.1.2+incompatible

Jun 8, 2020

v20.1.0+incompatible

May 4, 2020

v19.2.12+incompatible

Jan 12, 2021

v19.2.6+incompatible

Apr 3, 2020

v19.2.5+incompatible

Mar 16, 2020

v19.2.3+incompatible

Jan 29, 2020

v19.2.1+incompatible

Nov 18, 2019

v19.1.4+incompatible

Aug 2, 2019

v19.1.3+incompatible

Jul 4, 2019

v19.1.0-rc.3+incompatible

Apr 11, 2019

v19.1.0-rc.2+incompatible

Apr 4, 2019

v19.1.0-rc.1+incompatible

Mar 31, 2019

v19.1.0-beta.20190318+incompatible

Mar 12, 2019

v19.1.0-beta.20190304+incompatible

Feb 27, 2019

v19.1.0-beta.20190225+incompatible

Feb 19, 2019

v2.1.0-alpha.20180507+incompatible

Apr 30, 2018

v2.1.0-alpha.20180416+incompatible

Apr 10, 2018

v2.0.7+incompatible

Nov 28, 2018

v2.0.6+incompatible

Oct 1, 2018

v2.0.6-rc.1+incompatible

Sep 24, 2018

v2.0.5+incompatible

Aug 6, 2018

v2.0.4+incompatible

Jul 10, 2018

v2.0.3+incompatible

Jun 13, 2018

v2.0.2+incompatible

May 14, 2018

v2.0.1+incompatible

Apr 16, 2018

v2.0.0+incompatible

Apr 3, 2018

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