Versions in this module Expand all Collapse all v0 v0.23.2 Feb 12, 2024 Changes in this version + const LockingHigh + const LockingHighName + const LockingNormal + const LockingNormalName + const Normal + const NormalName + const SystemHigh + const SystemHighName + const SystemLow + const SystemLowName + const TTLLow + const TTLLowName + const TTLStatsLow + const UserHigh + const UserHighName + const UserLow + const UserLowName + var ErrIntOverflowLocalOnlySessionData = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowSessionData = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowSessionMigration = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowSessionRevivalToken = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthLocalOnlySessionData = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthSessionData = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthSessionMigration = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthSessionRevivalToken = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupLocalOnlySessionData = fmt.Errorf("proto: unexpected end of group") + var ErrUnexpectedEndOfGroupSessionData = fmt.Errorf("proto: unexpected end of group") + var ErrUnexpectedEndOfGroupSessionMigration = fmt.Errorf("proto: unexpected end of group") + var ErrUnexpectedEndOfGroupSessionRevivalToken = fmt.Errorf("proto: unexpected end of group") + var ReplicationMode_name = map[int32]string + var ReplicationMode_value = map[string]int32 + var VectorizeExecMode_name = map[int32]string + var VectorizeExecMode_value = map[string]int32 + func ToQoSLevelString(value int32) string + type DataConversionConfig struct + BytesEncodeFormat lex.BytesEncodeFormat + DateStyle pgdate.DateStyle + ExtraFloatDigits int32 + IntervalStyle duration.IntervalStyle + func (*DataConversionConfig) Descriptor() ([]byte, []int) + func (*DataConversionConfig) ProtoMessage() + func (c DataConversionConfig) GetFloatPrec(typ *types.T) int + func (m *DataConversionConfig) Marshal() (dAtA []byte, err error) + func (m *DataConversionConfig) MarshalTo(dAtA []byte) (int, error) + func (m *DataConversionConfig) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DataConversionConfig) Reset() + func (m *DataConversionConfig) Size() (n int) + func (m *DataConversionConfig) String() string + func (m *DataConversionConfig) Unmarshal(dAtA []byte) error + func (m *DataConversionConfig) XXX_DiscardUnknown() + func (m *DataConversionConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DataConversionConfig) XXX_Merge(src proto.Message) + func (m *DataConversionConfig) XXX_Size() int + func (m *DataConversionConfig) XXX_Unmarshal(b []byte) error + type DescriptorValidationMode int64 + const DescriptorValidationOff + const DescriptorValidationOn + const DescriptorValidationReadOnly + func DescriptorValidationModeFromString(val string) (_ DescriptorValidationMode, ok bool) + func (m DescriptorValidationMode) String() string + type DistSQLExecMode int64 + const DistSQLAlways + const DistSQLAuto + const DistSQLOff + const DistSQLOn + func DistSQLExecModeFromString(val string) (_ DistSQLExecMode, ok bool) + func (m DistSQLExecMode) String() string + type ExperimentalDistSQLPlanningMode int64 + const ExperimentalDistSQLPlanningAlways + const ExperimentalDistSQLPlanningOff + const ExperimentalDistSQLPlanningOn + func ExperimentalDistSQLPlanningModeFromString(val string) (ExperimentalDistSQLPlanningMode, bool) + func (m ExperimentalDistSQLPlanningMode) String() string + type LocalOnlySessionData struct + AllowOrdinalColumnReferences bool + AllowPrepareAsOptPlan bool + AllowRoleMembershipsToChangeDuringTransaction bool + AlterColumnTypeGeneralEnabled bool + AutoRehomingEnabled bool + AvoidBuffering bool + CheckFunctionBodies bool + CopyFastPathEnabled bool + CopyFromAtomicEnabled bool + CopyFromRetriesEnabled bool + CopyNumRetriesPerBatch int32 + CopyTxnQualityOfService QoSLevel + CopyWritePipeliningEnabled bool + CostScansWithDefaultColSize bool + CustomOptions map[string]string + DeclareCursorStatementTimeoutEnabled bool + DefaultTxnIsolationLevel int64 + DefaultTxnPriority int64 + DefaultTxnQualityOfService QoSLevel + DefaultTxnReadOnly bool + DefaultTxnUseFollowerReads bool + DescriptorValidationMode DescriptorValidationMode + DisableChangefeedReplication bool + DisableDropVirtualCluster bool + DisableHoistProjectionInJoinLimitation bool + DisablePlanGists bool + DisallowFullTableScans bool + DistSQLMode DistSQLExecMode + DurableLockingForSerializable bool + EnableCreateStatsUsingExtremes bool + EnableImplicitTransactionForBatchStatements bool + EnableSeqScan bool + EnableStreamReplication bool + EnableSuperRegions bool + EnableUniqueWithoutIndexConstraints bool + EnforceHomeRegion bool + EnforceHomeRegionFollowerReadsEnabled bool + ExpectAndIgnoreNotVisibleColumnsInCopy bool + ExperimentalComputedColumnRewrites string + ExperimentalDistSQLPlanningMode ExperimentalDistSQLPlanningMode + ExperimentalHashGroupJoinEnabled bool + ForceSavepointRestart bool + IdleInSessionTimeout time.Duration + IdleInTransactionSessionTimeout time.Duration + ImplicitColumnPartitioningEnabled bool + ImplicitFKLockingForSerializable bool + ImplicitSelectForUpdate bool + IndexRecommendationsEnabled bool + InjectRetryErrorsEnabled bool + InjectRetryErrorsOnCommitEnabled bool + InsertFastPath bool + IsSuperuser bool + LargeFullScanRows float64 + LocalityOptimizedSearch bool + MaxRetriesForReadCommitted int32 + MultipleActivePortalsEnabled bool + MultipleModificationsOfTable bool + NewSchemaChangerMode NewSchemaChangerMode + NoticeDisplaySeverity uint32 + NullOrderedLast bool + OptSplitScanLimit int32 + OptimizerAlwaysUseHistograms bool + OptimizerFKCascadesLimit int64 + OptimizerHoistUncorrelatedEqualitySubqueries bool + OptimizerUseForecasts bool + OptimizerUseHistograms bool + OptimizerUseImprovedComputedColumnFiltersDerivation bool + OptimizerUseImprovedDisjunctionStats bool + OptimizerUseImprovedJoinElimination bool + OptimizerUseImprovedSplitDisjunctionForJoins bool + OptimizerUseLimitOrderingForStreamingGroupBy bool + OptimizerUseLockOpForSerializable bool + OptimizerUseMultiColStats bool + OptimizerUseNotVisibleIndexes bool + OptimizerUseProvidedOrderingFix bool + OverrideAlterPrimaryRegionInSuperRegion bool + OverrideMultiRegionZoneConfigEnabled bool + PartiallyDistributedPlansDisabled bool + PlacementEnabled bool + PreferLookupJoinsForFKs bool + PreparedStatementsCacheSize int64 + PropagateInputOrdering bool + ReorderJoinsLimit int64 + ReplicationMode ReplicationMode + RequireExplicitPrimaryKeys bool + ResultsBufferSize int64 + SafeUpdates bool + SaveTablesPrefix string + SequenceCache SequenceCache + SerialNormalizationMode SerialNormalizationMode + SessionUserProto github_com_cockroachdb_cockroach_pkg_security_username.SQLUsernameProto + SharedLockingForSerializable bool + ShowPrimaryKeyConstraintOnNotVisibleColumns bool + StmtTimeout time.Duration + StreamerEnabled bool + StrictDDLAtomicity bool + StubCatalogTablesEnabled bool + SynchronousCommit bool + SystemIdentityProto github_com_cockroachdb_cockroach_pkg_security_username.SQLUsernameProto + TempTablesEnabled bool + TestingOptimizerCostPerturbation float64 + TestingOptimizerDisableRuleProbability float64 + TestingOptimizerInjectPanics bool + TestingOptimizerRandomSeed int64 + TransactionTimeout time.Duration + TxnRowsReadErr int64 + TxnRowsReadLog int64 + TxnRowsWrittenErr int64 + TxnRowsWrittenLog int64 + UnboundedParallelScans bool + UnconstrainedNonCoveringIndexScanEnabled bool + UnsafeSettingInterlockKey string + VariableInequalityLookupJoinEnabled bool + ZigzagJoinEnabled bool + func (*LocalOnlySessionData) Descriptor() ([]byte, []int) + func (*LocalOnlySessionData) ProtoMessage() + func (m *LocalOnlySessionData) Marshal() (dAtA []byte, err error) + func (m *LocalOnlySessionData) MarshalTo(dAtA []byte) (int, error) + func (m *LocalOnlySessionData) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *LocalOnlySessionData) Reset() + func (m *LocalOnlySessionData) Size() (n int) + func (m *LocalOnlySessionData) String() string + func (m *LocalOnlySessionData) Unmarshal(dAtA []byte) error + func (m *LocalOnlySessionData) XXX_DiscardUnknown() + func (m *LocalOnlySessionData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LocalOnlySessionData) XXX_Merge(src proto.Message) + func (m *LocalOnlySessionData) XXX_Size() int + func (m *LocalOnlySessionData) XXX_Unmarshal(b []byte) error + func (s *LocalOnlySessionData) SystemIdentity() username.SQLUsername + type MigratableSession struct + LocalOnlySessionData LocalOnlySessionData + PreparedStatements []MigratableSession_PreparedStatement + SessionData SessionData + func (*MigratableSession) Descriptor() ([]byte, []int) + func (*MigratableSession) ProtoMessage() + func (m *MigratableSession) Marshal() (dAtA []byte, err error) + func (m *MigratableSession) MarshalTo(dAtA []byte) (int, error) + func (m *MigratableSession) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MigratableSession) Reset() + func (m *MigratableSession) Size() (n int) + func (m *MigratableSession) String() string + func (m *MigratableSession) Unmarshal(dAtA []byte) error + func (m *MigratableSession) XXX_DiscardUnknown() + func (m *MigratableSession) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MigratableSession) XXX_Merge(src proto.Message) + func (m *MigratableSession) XXX_Size() int + func (m *MigratableSession) XXX_Unmarshal(b []byte) error + type MigratableSession_PreparedStatement struct + Name string + PlaceholderTypeHints []github_com_lib_pq_oid.Oid + SQL string + func (*MigratableSession_PreparedStatement) Descriptor() ([]byte, []int) + func (*MigratableSession_PreparedStatement) ProtoMessage() + func (m *MigratableSession_PreparedStatement) Marshal() (dAtA []byte, err error) + func (m *MigratableSession_PreparedStatement) MarshalTo(dAtA []byte) (int, error) + func (m *MigratableSession_PreparedStatement) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MigratableSession_PreparedStatement) Reset() + func (m *MigratableSession_PreparedStatement) Size() (n int) + func (m *MigratableSession_PreparedStatement) String() string + func (m *MigratableSession_PreparedStatement) Unmarshal(dAtA []byte) error + func (m *MigratableSession_PreparedStatement) XXX_DiscardUnknown() + func (m *MigratableSession_PreparedStatement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MigratableSession_PreparedStatement) XXX_Merge(src proto.Message) + func (m *MigratableSession_PreparedStatement) XXX_Size() int + func (m *MigratableSession_PreparedStatement) XXX_Unmarshal(b []byte) error + type NewSchemaChangerMode int64 + const UseNewSchemaChangerOff + const UseNewSchemaChangerOn + const UseNewSchemaChangerUnsafe + const UseNewSchemaChangerUnsafeAlways + func NewSchemaChangerModeFromString(val string) (_ NewSchemaChangerMode, ok bool) + func (m NewSchemaChangerMode) String() string + type QoSLevel admissionpb.WorkPriority + func ParseQoSLevelFromString(val string) (_ QoSLevel, ok bool) + func (e QoSLevel) String() string + func (e QoSLevel) Validate() QoSLevel + func (e QoSLevel) ValidateInternal() QoSLevel + type ReplicationMode int32 + const ReplicationMode_REPLICATION_MODE_DATABASE + const ReplicationMode_REPLICATION_MODE_DISABLED + const ReplicationMode_REPLICATION_MODE_ENABLED + func (ReplicationMode) EnumDescriptor() ([]byte, []int) + func (x ReplicationMode) String() string + type SequenceCache map[uint32]*SequenceCacheEntry + func (sc SequenceCache) NextValue(seqID uint32, clientVersion uint32, ...) (int64, error) + type SequenceCacheEntry struct + CachedVersion uint32 + CurrentValue int64 + Increment int64 + NumValues int64 + func (*SequenceCacheEntry) Descriptor() ([]byte, []int) + func (*SequenceCacheEntry) ProtoMessage() + func (m *SequenceCacheEntry) Marshal() (dAtA []byte, err error) + func (m *SequenceCacheEntry) MarshalTo(dAtA []byte) (int, error) + func (m *SequenceCacheEntry) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SequenceCacheEntry) Reset() + func (m *SequenceCacheEntry) Size() (n int) + func (m *SequenceCacheEntry) String() string + func (m *SequenceCacheEntry) Unmarshal(dAtA []byte) error + func (m *SequenceCacheEntry) XXX_DiscardUnknown() + func (m *SequenceCacheEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SequenceCacheEntry) XXX_Merge(src proto.Message) + func (m *SequenceCacheEntry) XXX_Size() int + func (m *SequenceCacheEntry) XXX_Unmarshal(b []byte) error + type SequenceState struct + LastSeqIncremented uint32 + Seqs []*SequenceState_Seq + func (*SequenceState) Descriptor() ([]byte, []int) + func (*SequenceState) ProtoMessage() + func (m *SequenceState) Marshal() (dAtA []byte, err error) + func (m *SequenceState) MarshalTo(dAtA []byte) (int, error) + func (m *SequenceState) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SequenceState) Reset() + func (m *SequenceState) Size() (n int) + func (m *SequenceState) String() string + func (m *SequenceState) Unmarshal(dAtA []byte) error + func (m *SequenceState) XXX_DiscardUnknown() + func (m *SequenceState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SequenceState) XXX_Merge(src proto.Message) + func (m *SequenceState) XXX_Size() int + func (m *SequenceState) XXX_Unmarshal(b []byte) error + type SequenceState_Seq struct + LatestVal int64 + SeqID uint32 + func (*SequenceState_Seq) Descriptor() ([]byte, []int) + func (*SequenceState_Seq) ProtoMessage() + func (m *SequenceState_Seq) Marshal() (dAtA []byte, err error) + func (m *SequenceState_Seq) MarshalTo(dAtA []byte) (int, error) + func (m *SequenceState_Seq) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SequenceState_Seq) Reset() + func (m *SequenceState_Seq) Size() (n int) + func (m *SequenceState_Seq) String() string + func (m *SequenceState_Seq) Unmarshal(dAtA []byte) error + func (m *SequenceState_Seq) XXX_DiscardUnknown() + func (m *SequenceState_Seq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SequenceState_Seq) XXX_Merge(src proto.Message) + func (m *SequenceState_Seq) XXX_Size() int + func (m *SequenceState_Seq) XXX_Unmarshal(b []byte) error + type SerialNormalizationMode int64 + const SerialUsesCachedSQLSequences + const SerialUsesRowID + const SerialUsesSQLSequences + const SerialUsesUnorderedRowID + const SerialUsesVirtualSequences + func SerialNormalizationModeFromString(val string) (_ SerialNormalizationMode, ok bool) + func (m SerialNormalizationMode) String() string + type SessionData struct + ApplicationName string + DataConversionConfig DataConversionConfig + Database string + DefaultIntSize int32 + DefaultTextSearchConfig string + DirectColumnarScansEnabled bool + DistsqlPlanGatewayBias int64 + IndexJoinStreamerBatchSize int64 + Internal bool + JoinReaderIndexJoinStrategyBatchSize int64 + JoinReaderNoOrderingStrategyBatchSize int64 + JoinReaderOrderingStrategyBatchSize int64 + Location string + LockTimeout time.Duration + OnUpdateRehomeRowEnabled bool + ParallelizeMultiKeyLookupJoinsEnabled bool + SearchPath []string + SeqState SequenceState + StreamerAlwaysMaintainOrdering bool + StreamerHeadOfLineOnlyFraction float64 + StreamerInOrderEagerMemoryUsageFraction float64 + StreamerOutOfOrderEagerMemoryUsageFraction float64 + TemporarySchemaName string + TestingVectorizeInjectPanics bool + TrigramSimilarityThreshold float64 + TroubleshootingMode bool + UserProto github_com_cockroachdb_cockroach_pkg_security_username.SQLUsernameProto + VectorizeMode VectorizeExecMode + WorkMemLimit int64 + func (*SessionData) Descriptor() ([]byte, []int) + func (*SessionData) ProtoMessage() + func (m *SessionData) Marshal() (dAtA []byte, err error) + func (m *SessionData) MarshalTo(dAtA []byte) (int, error) + func (m *SessionData) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SessionData) Reset() + func (m *SessionData) Size() (n int) + func (m *SessionData) String() string + func (m *SessionData) Unmarshal(dAtA []byte) error + func (m *SessionData) XXX_DiscardUnknown() + func (m *SessionData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SessionData) XXX_Merge(src proto.Message) + func (m *SessionData) XXX_Size() int + func (m *SessionData) XXX_Unmarshal(b []byte) error + func (s *SessionData) User() username.SQLUsername + type SessionRevivalToken struct + Payload []byte + Signature []byte + func (*SessionRevivalToken) Descriptor() ([]byte, []int) + func (*SessionRevivalToken) ProtoMessage() + func (m *SessionRevivalToken) Marshal() (dAtA []byte, err error) + func (m *SessionRevivalToken) MarshalTo(dAtA []byte) (int, error) + func (m *SessionRevivalToken) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SessionRevivalToken) Reset() + func (m *SessionRevivalToken) Size() (n int) + func (m *SessionRevivalToken) String() string + func (m *SessionRevivalToken) Unmarshal(dAtA []byte) error + func (m *SessionRevivalToken) XXX_DiscardUnknown() + func (m *SessionRevivalToken) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SessionRevivalToken) XXX_Merge(src proto.Message) + func (m *SessionRevivalToken) XXX_Size() int + func (m *SessionRevivalToken) XXX_Unmarshal(b []byte) error + type SessionRevivalToken_Payload struct + Algorithm string + ExpiresAt *types.Timestamp + IssuedAt *types.Timestamp + User string + func (*SessionRevivalToken_Payload) Descriptor() ([]byte, []int) + func (*SessionRevivalToken_Payload) ProtoMessage() + func (m *SessionRevivalToken_Payload) Marshal() (dAtA []byte, err error) + func (m *SessionRevivalToken_Payload) MarshalTo(dAtA []byte) (int, error) + func (m *SessionRevivalToken_Payload) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SessionRevivalToken_Payload) Reset() + func (m *SessionRevivalToken_Payload) Size() (n int) + func (m *SessionRevivalToken_Payload) String() string + func (m *SessionRevivalToken_Payload) Unmarshal(dAtA []byte) error + func (m *SessionRevivalToken_Payload) XXX_DiscardUnknown() + func (m *SessionRevivalToken_Payload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SessionRevivalToken_Payload) XXX_Merge(src proto.Message) + func (m *SessionRevivalToken_Payload) XXX_Size() int + func (m *SessionRevivalToken_Payload) XXX_Unmarshal(b []byte) error + type VectorizeExecMode int32 + const VectorizeExperimentalAlways + const VectorizeOff + const VectorizeOn + const VectorizeUnset + func VectorizeExecModeFromString(val string) (VectorizeExecMode, bool) + func (VectorizeExecMode) EnumDescriptor() ([]byte, []int) + func (m VectorizeExecMode) String() string