Documentation ¶
Index ¶
- Variables
- type AlterTableRequest
- func (*AlterTableRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AlterTableRequest) GetAddChangefeeds() []*Changefeed
- func (x *AlterTableRequest) GetAddColumnFamilies() []*ColumnFamily
- func (x *AlterTableRequest) GetAddColumns() []*ColumnMeta
- func (x *AlterTableRequest) GetAddIndexes() []*TableIndex
- func (x *AlterTableRequest) GetAlterAttributes() map[string]string
- func (x *AlterTableRequest) GetAlterColumnFamilies() []*ColumnFamily
- func (x *AlterTableRequest) GetAlterColumns() []*ColumnMeta
- func (x *AlterTableRequest) GetAlterPartitioningSettings() *PartitioningSettings
- func (x *AlterTableRequest) GetAlterStorageSettings() *StorageSettings
- func (x *AlterTableRequest) GetDropChangefeeds() []string
- func (x *AlterTableRequest) GetDropColumns() []string
- func (x *AlterTableRequest) GetDropIndexes() []string
- func (x *AlterTableRequest) GetDropTiering() *emptypb.Empty
- func (x *AlterTableRequest) GetDropTtlSettings() *emptypb.Empty
- func (x *AlterTableRequest) GetOperationParams() *Ydb_Operations.OperationParams
- func (x *AlterTableRequest) GetPath() string
- func (x *AlterTableRequest) GetRenameIndexes() []*RenameIndexItem
- func (x *AlterTableRequest) GetSessionId() string
- func (x *AlterTableRequest) GetSetCompactionPolicy() string
- func (x *AlterTableRequest) GetSetKeyBloomFilter() Ydb.FeatureFlag_Status
- func (x *AlterTableRequest) GetSetReadReplicasSettings() *ReadReplicasSettings
- func (x *AlterTableRequest) GetSetTiering() string
- func (x *AlterTableRequest) GetSetTtlSettings() *TtlSettings
- func (m *AlterTableRequest) GetTieringAction() isAlterTableRequest_TieringAction
- func (m *AlterTableRequest) GetTtlAction() isAlterTableRequest_TtlAction
- func (*AlterTableRequest) ProtoMessage()
- func (x *AlterTableRequest) ProtoReflect() protoreflect.Message
- func (x *AlterTableRequest) Reset()
- func (x *AlterTableRequest) String() string
- type AlterTableRequest_DropTiering
- type AlterTableRequest_DropTtlSettings
- type AlterTableRequest_SetTiering
- type AlterTableRequest_SetTtlSettings
- type AlterTableResponse
- func (*AlterTableResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AlterTableResponse) GetOperation() *Ydb_Operations.Operation
- func (*AlterTableResponse) ProtoMessage()
- func (x *AlterTableResponse) ProtoReflect() protoreflect.Message
- func (x *AlterTableResponse) Reset()
- func (x *AlterTableResponse) String() string
- type AzReadReplicasSettings
- func (*AzReadReplicasSettings) Descriptor() ([]byte, []int)deprecated
- func (x *AzReadReplicasSettings) GetName() string
- func (x *AzReadReplicasSettings) GetReadReplicasCount() uint64
- func (*AzReadReplicasSettings) ProtoMessage()
- func (x *AzReadReplicasSettings) ProtoReflect() protoreflect.Message
- func (x *AzReadReplicasSettings) Reset()
- func (x *AzReadReplicasSettings) String() string
- type BeginTransactionRequest
- func (*BeginTransactionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *BeginTransactionRequest) GetOperationParams() *Ydb_Operations.OperationParams
- func (x *BeginTransactionRequest) GetSessionId() string
- func (x *BeginTransactionRequest) GetTxSettings() *TransactionSettings
- func (*BeginTransactionRequest) ProtoMessage()
- func (x *BeginTransactionRequest) ProtoReflect() protoreflect.Message
- func (x *BeginTransactionRequest) Reset()
- func (x *BeginTransactionRequest) String() string
- type BeginTransactionResponse
- func (*BeginTransactionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *BeginTransactionResponse) GetOperation() *Ydb_Operations.Operation
- func (*BeginTransactionResponse) ProtoMessage()
- func (x *BeginTransactionResponse) ProtoReflect() protoreflect.Message
- func (x *BeginTransactionResponse) Reset()
- func (x *BeginTransactionResponse) String() string
- type BeginTransactionResult
- func (*BeginTransactionResult) Descriptor() ([]byte, []int)deprecated
- func (x *BeginTransactionResult) GetTxMeta() *TransactionMeta
- func (*BeginTransactionResult) ProtoMessage()
- func (x *BeginTransactionResult) ProtoReflect() protoreflect.Message
- func (x *BeginTransactionResult) Reset()
- func (x *BeginTransactionResult) String() string
- type BulkUpsertRequest
- func (*BulkUpsertRequest) Descriptor() ([]byte, []int)deprecated
- func (x *BulkUpsertRequest) GetArrowBatchSettings() *Ydb_Formats.ArrowBatchSettings
- func (x *BulkUpsertRequest) GetCsvSettings() *Ydb_Formats.CsvSettings
- func (x *BulkUpsertRequest) GetData() []byte
- func (m *BulkUpsertRequest) GetDataFormat() isBulkUpsertRequest_DataFormat
- func (x *BulkUpsertRequest) GetOperationParams() *Ydb_Operations.OperationParams
- func (x *BulkUpsertRequest) GetRows() *Ydb.TypedValue
- func (x *BulkUpsertRequest) GetTable() string
- func (*BulkUpsertRequest) ProtoMessage()
- func (x *BulkUpsertRequest) ProtoReflect() protoreflect.Message
- func (x *BulkUpsertRequest) Reset()
- func (x *BulkUpsertRequest) String() string
- type BulkUpsertRequest_ArrowBatchSettings
- type BulkUpsertRequest_CsvSettings
- type BulkUpsertResponse
- func (*BulkUpsertResponse) Descriptor() ([]byte, []int)deprecated
- func (x *BulkUpsertResponse) GetOperation() *Ydb_Operations.Operation
- func (*BulkUpsertResponse) ProtoMessage()
- func (x *BulkUpsertResponse) ProtoReflect() protoreflect.Message
- func (x *BulkUpsertResponse) Reset()
- func (x *BulkUpsertResponse) String() string
- type BulkUpsertResult
- type CachingPolicy
- type CachingPolicyDescription
- func (*CachingPolicyDescription) Descriptor() ([]byte, []int)deprecated
- func (x *CachingPolicyDescription) GetLabels() map[string]string
- func (x *CachingPolicyDescription) GetName() string
- func (*CachingPolicyDescription) ProtoMessage()
- func (x *CachingPolicyDescription) ProtoReflect() protoreflect.Message
- func (x *CachingPolicyDescription) Reset()
- func (x *CachingPolicyDescription) String() string
- type Changefeed
- func (*Changefeed) Descriptor() ([]byte, []int)deprecated
- func (x *Changefeed) GetAttributes() map[string]string
- func (x *Changefeed) GetAwsRegion() string
- func (x *Changefeed) GetFormat() ChangefeedFormat_Format
- func (x *Changefeed) GetInitialScan() bool
- func (x *Changefeed) GetMode() ChangefeedMode_Mode
- func (x *Changefeed) GetName() string
- func (x *Changefeed) GetResolvedTimestampsInterval() *durationpb.Duration
- func (x *Changefeed) GetRetentionPeriod() *durationpb.Duration
- func (x *Changefeed) GetTopicPartitioningSettings() *Ydb_Topic.PartitioningSettings
- func (x *Changefeed) GetVirtualTimestamps() bool
- func (*Changefeed) ProtoMessage()
- func (x *Changefeed) ProtoReflect() protoreflect.Message
- func (x *Changefeed) Reset()
- func (x *Changefeed) String() string
- type ChangefeedDescription
- func (*ChangefeedDescription) Descriptor() ([]byte, []int)deprecated
- func (x *ChangefeedDescription) GetAttributes() map[string]string
- func (x *ChangefeedDescription) GetAwsRegion() string
- func (x *ChangefeedDescription) GetFormat() ChangefeedFormat_Format
- func (x *ChangefeedDescription) GetMode() ChangefeedMode_Mode
- func (x *ChangefeedDescription) GetName() string
- func (x *ChangefeedDescription) GetResolvedTimestampsInterval() *durationpb.Duration
- func (x *ChangefeedDescription) GetState() ChangefeedDescription_State
- func (x *ChangefeedDescription) GetVirtualTimestamps() bool
- func (*ChangefeedDescription) ProtoMessage()
- func (x *ChangefeedDescription) ProtoReflect() protoreflect.Message
- func (x *ChangefeedDescription) Reset()
- func (x *ChangefeedDescription) String() string
- type ChangefeedDescription_State
- func (ChangefeedDescription_State) Descriptor() protoreflect.EnumDescriptor
- func (x ChangefeedDescription_State) Enum() *ChangefeedDescription_State
- func (ChangefeedDescription_State) EnumDescriptor() ([]byte, []int)deprecated
- func (x ChangefeedDescription_State) Number() protoreflect.EnumNumber
- func (x ChangefeedDescription_State) String() string
- func (ChangefeedDescription_State) Type() protoreflect.EnumType
- type ChangefeedFormat
- type ChangefeedFormat_Format
- func (ChangefeedFormat_Format) Descriptor() protoreflect.EnumDescriptor
- func (x ChangefeedFormat_Format) Enum() *ChangefeedFormat_Format
- func (ChangefeedFormat_Format) EnumDescriptor() ([]byte, []int)deprecated
- func (x ChangefeedFormat_Format) Number() protoreflect.EnumNumber
- func (x ChangefeedFormat_Format) String() string
- func (ChangefeedFormat_Format) Type() protoreflect.EnumType
- type ChangefeedMode
- type ChangefeedMode_Mode
- func (ChangefeedMode_Mode) Descriptor() protoreflect.EnumDescriptor
- func (x ChangefeedMode_Mode) Enum() *ChangefeedMode_Mode
- func (ChangefeedMode_Mode) EnumDescriptor() ([]byte, []int)deprecated
- func (x ChangefeedMode_Mode) Number() protoreflect.EnumNumber
- func (x ChangefeedMode_Mode) String() string
- func (ChangefeedMode_Mode) Type() protoreflect.EnumType
- type ClusterReplicasSettings
- func (*ClusterReplicasSettings) Descriptor() ([]byte, []int)deprecated
- func (x *ClusterReplicasSettings) GetAzReadReplicasSettings() []*AzReadReplicasSettings
- func (*ClusterReplicasSettings) ProtoMessage()
- func (x *ClusterReplicasSettings) ProtoReflect() protoreflect.Message
- func (x *ClusterReplicasSettings) Reset()
- func (x *ClusterReplicasSettings) String() string
- type ColumnFamily
- func (*ColumnFamily) Descriptor() ([]byte, []int)deprecated
- func (x *ColumnFamily) GetCompression() ColumnFamily_Compression
- func (x *ColumnFamily) GetData() *StoragePool
- func (x *ColumnFamily) GetKeepInMemory() Ydb.FeatureFlag_Status
- func (x *ColumnFamily) GetName() string
- func (*ColumnFamily) ProtoMessage()
- func (x *ColumnFamily) ProtoReflect() protoreflect.Message
- func (x *ColumnFamily) Reset()
- func (x *ColumnFamily) String() string
- type ColumnFamilyPolicy
- func (*ColumnFamilyPolicy) Descriptor() ([]byte, []int)deprecated
- func (x *ColumnFamilyPolicy) GetCompression() ColumnFamilyPolicy_Compression
- func (x *ColumnFamilyPolicy) GetData() *StoragePool
- func (x *ColumnFamilyPolicy) GetExternal() *StoragePool
- func (x *ColumnFamilyPolicy) GetKeepInMemory() Ydb.FeatureFlag_Status
- func (x *ColumnFamilyPolicy) GetName() string
- func (*ColumnFamilyPolicy) ProtoMessage()
- func (x *ColumnFamilyPolicy) ProtoReflect() protoreflect.Message
- func (x *ColumnFamilyPolicy) Reset()
- func (x *ColumnFamilyPolicy) String() string
- type ColumnFamilyPolicy_Compression
- func (ColumnFamilyPolicy_Compression) Descriptor() protoreflect.EnumDescriptor
- func (x ColumnFamilyPolicy_Compression) Enum() *ColumnFamilyPolicy_Compression
- func (ColumnFamilyPolicy_Compression) EnumDescriptor() ([]byte, []int)deprecated
- func (x ColumnFamilyPolicy_Compression) Number() protoreflect.EnumNumber
- func (x ColumnFamilyPolicy_Compression) String() string
- func (ColumnFamilyPolicy_Compression) Type() protoreflect.EnumType
- type ColumnFamily_Compression
- func (ColumnFamily_Compression) Descriptor() protoreflect.EnumDescriptor
- func (x ColumnFamily_Compression) Enum() *ColumnFamily_Compression
- func (ColumnFamily_Compression) EnumDescriptor() ([]byte, []int)deprecated
- func (x ColumnFamily_Compression) Number() protoreflect.EnumNumber
- func (x ColumnFamily_Compression) String() string
- func (ColumnFamily_Compression) Type() protoreflect.EnumType
- type ColumnMeta
- func (*ColumnMeta) Descriptor() ([]byte, []int)deprecated
- func (m *ColumnMeta) GetDefaultValue() isColumnMeta_DefaultValue
- func (x *ColumnMeta) GetFamily() string
- func (x *ColumnMeta) GetFromLiteral() *Ydb.TypedValue
- func (x *ColumnMeta) GetFromSequence() *SequenceDescription
- func (x *ColumnMeta) GetName() string
- func (x *ColumnMeta) GetNotNull() bool
- func (x *ColumnMeta) GetType() *Ydb.Type
- func (*ColumnMeta) ProtoMessage()
- func (x *ColumnMeta) ProtoReflect() protoreflect.Message
- func (x *ColumnMeta) Reset()
- func (x *ColumnMeta) String() string
- type ColumnMeta_FromLiteral
- type ColumnMeta_FromSequence
- type CommitTransactionRequest
- func (*CommitTransactionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CommitTransactionRequest) GetCollectStats() QueryStatsCollection_Mode
- func (x *CommitTransactionRequest) GetOperationParams() *Ydb_Operations.OperationParams
- func (x *CommitTransactionRequest) GetSessionId() string
- func (x *CommitTransactionRequest) GetTxId() string
- func (*CommitTransactionRequest) ProtoMessage()
- func (x *CommitTransactionRequest) ProtoReflect() protoreflect.Message
- func (x *CommitTransactionRequest) Reset()
- func (x *CommitTransactionRequest) String() string
- type CommitTransactionResponse
- func (*CommitTransactionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CommitTransactionResponse) GetOperation() *Ydb_Operations.Operation
- func (*CommitTransactionResponse) ProtoMessage()
- func (x *CommitTransactionResponse) ProtoReflect() protoreflect.Message
- func (x *CommitTransactionResponse) Reset()
- func (x *CommitTransactionResponse) String() string
- type CommitTransactionResult
- func (*CommitTransactionResult) Descriptor() ([]byte, []int)deprecated
- func (x *CommitTransactionResult) GetQueryStats() *Ydb_TableStats.QueryStats
- func (*CommitTransactionResult) ProtoMessage()
- func (x *CommitTransactionResult) ProtoReflect() protoreflect.Message
- func (x *CommitTransactionResult) Reset()
- func (x *CommitTransactionResult) String() string
- type CompactionPolicy
- type CompactionPolicyDescription
- func (*CompactionPolicyDescription) Descriptor() ([]byte, []int)deprecated
- func (x *CompactionPolicyDescription) GetLabels() map[string]string
- func (x *CompactionPolicyDescription) GetName() string
- func (*CompactionPolicyDescription) ProtoMessage()
- func (x *CompactionPolicyDescription) ProtoReflect() protoreflect.Message
- func (x *CompactionPolicyDescription) Reset()
- func (x *CompactionPolicyDescription) String() string
- type CopyTableItem
- func (*CopyTableItem) Descriptor() ([]byte, []int)deprecated
- func (x *CopyTableItem) GetDestinationPath() string
- func (x *CopyTableItem) GetOmitIndexes() bool
- func (x *CopyTableItem) GetSourcePath() string
- func (*CopyTableItem) ProtoMessage()
- func (x *CopyTableItem) ProtoReflect() protoreflect.Message
- func (x *CopyTableItem) Reset()
- func (x *CopyTableItem) String() string
- type CopyTableRequest
- func (*CopyTableRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CopyTableRequest) GetDestinationPath() string
- func (x *CopyTableRequest) GetOperationParams() *Ydb_Operations.OperationParams
- func (x *CopyTableRequest) GetSessionId() string
- func (x *CopyTableRequest) GetSourcePath() string
- func (*CopyTableRequest) ProtoMessage()
- func (x *CopyTableRequest) ProtoReflect() protoreflect.Message
- func (x *CopyTableRequest) Reset()
- func (x *CopyTableRequest) String() string
- type CopyTableResponse
- func (*CopyTableResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CopyTableResponse) GetOperation() *Ydb_Operations.Operation
- func (*CopyTableResponse) ProtoMessage()
- func (x *CopyTableResponse) ProtoReflect() protoreflect.Message
- func (x *CopyTableResponse) Reset()
- func (x *CopyTableResponse) String() string
- type CopyTablesRequest
- func (*CopyTablesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CopyTablesRequest) GetOperationParams() *Ydb_Operations.OperationParams
- func (x *CopyTablesRequest) GetSessionId() string
- func (x *CopyTablesRequest) GetTables() []*CopyTableItem
- func (*CopyTablesRequest) ProtoMessage()
- func (x *CopyTablesRequest) ProtoReflect() protoreflect.Message
- func (x *CopyTablesRequest) Reset()
- func (x *CopyTablesRequest) String() string
- type CopyTablesResponse
- func (*CopyTablesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CopyTablesResponse) GetOperation() *Ydb_Operations.Operation
- func (*CopyTablesResponse) ProtoMessage()
- func (x *CopyTablesResponse) ProtoReflect() protoreflect.Message
- func (x *CopyTablesResponse) Reset()
- func (x *CopyTablesResponse) String() string
- type CreateSessionRequest
- func (*CreateSessionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateSessionRequest) GetOperationParams() *Ydb_Operations.OperationParams
- func (*CreateSessionRequest) ProtoMessage()
- func (x *CreateSessionRequest) ProtoReflect() protoreflect.Message
- func (x *CreateSessionRequest) Reset()
- func (x *CreateSessionRequest) String() string
- type CreateSessionResponse
- func (*CreateSessionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateSessionResponse) GetOperation() *Ydb_Operations.Operation
- func (*CreateSessionResponse) ProtoMessage()
- func (x *CreateSessionResponse) ProtoReflect() protoreflect.Message
- func (x *CreateSessionResponse) Reset()
- func (x *CreateSessionResponse) String() string
- type CreateSessionResult
- func (*CreateSessionResult) Descriptor() ([]byte, []int)deprecated
- func (x *CreateSessionResult) GetSessionId() string
- func (*CreateSessionResult) ProtoMessage()
- func (x *CreateSessionResult) ProtoReflect() protoreflect.Message
- func (x *CreateSessionResult) Reset()
- func (x *CreateSessionResult) String() string
- type CreateTableRequest
- func (*CreateTableRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateTableRequest) GetAttributes() map[string]string
- func (x *CreateTableRequest) GetColumnFamilies() []*ColumnFamily
- func (x *CreateTableRequest) GetColumns() []*ColumnMeta
- func (x *CreateTableRequest) GetCompactionPolicy() string
- func (x *CreateTableRequest) GetIndexes() []*TableIndex
- func (x *CreateTableRequest) GetKeyBloomFilter() Ydb.FeatureFlag_Status
- func (x *CreateTableRequest) GetOperationParams() *Ydb_Operations.OperationParams
- func (x *CreateTableRequest) GetPartitionAtKeys() *ExplicitPartitions
- func (x *CreateTableRequest) GetPartitioningSettings() *PartitioningSettings
- func (m *CreateTableRequest) GetPartitions() isCreateTableRequest_Partitions
- func (x *CreateTableRequest) GetPath() string
- func (x *CreateTableRequest) GetPrimaryKey() []string
- func (x *CreateTableRequest) GetProfile() *TableProfile
- func (x *CreateTableRequest) GetReadReplicasSettings() *ReadReplicasSettings
- func (x *CreateTableRequest) GetSessionId() string
- func (x *CreateTableRequest) GetStorageSettings() *StorageSettings
- func (x *CreateTableRequest) GetStoreType() StoreType
- func (x *CreateTableRequest) GetTemporary() bool
- func (x *CreateTableRequest) GetTiering() string
- func (x *CreateTableRequest) GetTtlSettings() *TtlSettings
- func (x *CreateTableRequest) GetUniformPartitions() uint64
- func (*CreateTableRequest) ProtoMessage()
- func (x *CreateTableRequest) ProtoReflect() protoreflect.Message
- func (x *CreateTableRequest) Reset()
- func (x *CreateTableRequest) String() string
- type CreateTableRequest_PartitionAtKeys
- type CreateTableRequest_UniformPartitions
- type CreateTableResponse
- func (*CreateTableResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateTableResponse) GetOperation() *Ydb_Operations.Operation
- func (*CreateTableResponse) ProtoMessage()
- func (x *CreateTableResponse) ProtoReflect() protoreflect.Message
- func (x *CreateTableResponse) Reset()
- func (x *CreateTableResponse) String() string
- type DateTypeColumnModeSettings
- func (*DateTypeColumnModeSettings) Descriptor() ([]byte, []int)deprecated
- func (x *DateTypeColumnModeSettings) GetColumnName() string
- func (x *DateTypeColumnModeSettings) GetExpireAfterSeconds() uint32
- func (*DateTypeColumnModeSettings) ProtoMessage()
- func (x *DateTypeColumnModeSettings) ProtoReflect() protoreflect.Message
- func (x *DateTypeColumnModeSettings) Reset()
- func (x *DateTypeColumnModeSettings) String() string
- type DeleteSessionRequest
- func (*DeleteSessionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteSessionRequest) GetOperationParams() *Ydb_Operations.OperationParams
- func (x *DeleteSessionRequest) GetSessionId() string
- func (*DeleteSessionRequest) ProtoMessage()
- func (x *DeleteSessionRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteSessionRequest) Reset()
- func (x *DeleteSessionRequest) String() string
- type DeleteSessionResponse
- func (*DeleteSessionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteSessionResponse) GetOperation() *Ydb_Operations.Operation
- func (*DeleteSessionResponse) ProtoMessage()
- func (x *DeleteSessionResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteSessionResponse) Reset()
- func (x *DeleteSessionResponse) String() string
- type DescribeTableOptionsRequest
- func (*DescribeTableOptionsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DescribeTableOptionsRequest) GetOperationParams() *Ydb_Operations.OperationParams
- func (*DescribeTableOptionsRequest) ProtoMessage()
- func (x *DescribeTableOptionsRequest) ProtoReflect() protoreflect.Message
- func (x *DescribeTableOptionsRequest) Reset()
- func (x *DescribeTableOptionsRequest) String() string
- type DescribeTableOptionsResponse
- func (*DescribeTableOptionsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DescribeTableOptionsResponse) GetOperation() *Ydb_Operations.Operation
- func (*DescribeTableOptionsResponse) ProtoMessage()
- func (x *DescribeTableOptionsResponse) ProtoReflect() protoreflect.Message
- func (x *DescribeTableOptionsResponse) Reset()
- func (x *DescribeTableOptionsResponse) String() string
- type DescribeTableOptionsResult
- func (*DescribeTableOptionsResult) Descriptor() ([]byte, []int)deprecated
- func (x *DescribeTableOptionsResult) GetCachingPolicyPresets() []*CachingPolicyDescription
- func (x *DescribeTableOptionsResult) GetCompactionPolicyPresets() []*CompactionPolicyDescription
- func (x *DescribeTableOptionsResult) GetExecutionPolicyPresets() []*ExecutionPolicyDescription
- func (x *DescribeTableOptionsResult) GetPartitioningPolicyPresets() []*PartitioningPolicyDescription
- func (x *DescribeTableOptionsResult) GetReplicationPolicyPresets() []*ReplicationPolicyDescription
- func (x *DescribeTableOptionsResult) GetStoragePolicyPresets() []*StoragePolicyDescription
- func (x *DescribeTableOptionsResult) GetTableProfilePresets() []*TableProfileDescription
- func (*DescribeTableOptionsResult) ProtoMessage()
- func (x *DescribeTableOptionsResult) ProtoReflect() protoreflect.Message
- func (x *DescribeTableOptionsResult) Reset()
- func (x *DescribeTableOptionsResult) String() string
- type DescribeTableRequest
- func (*DescribeTableRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DescribeTableRequest) GetIncludePartitionStats() bool
- func (x *DescribeTableRequest) GetIncludeShardKeyBounds() bool
- func (x *DescribeTableRequest) GetIncludeTableStats() bool
- func (x *DescribeTableRequest) GetOperationParams() *Ydb_Operations.OperationParams
- func (x *DescribeTableRequest) GetPath() string
- func (x *DescribeTableRequest) GetSessionId() string
- func (*DescribeTableRequest) ProtoMessage()
- func (x *DescribeTableRequest) ProtoReflect() protoreflect.Message
- func (x *DescribeTableRequest) Reset()
- func (x *DescribeTableRequest) String() string
- type DescribeTableResponse
- func (*DescribeTableResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DescribeTableResponse) GetOperation() *Ydb_Operations.Operation
- func (*DescribeTableResponse) ProtoMessage()
- func (x *DescribeTableResponse) ProtoReflect() protoreflect.Message
- func (x *DescribeTableResponse) Reset()
- func (x *DescribeTableResponse) String() string
- type DescribeTableResult
- func (*DescribeTableResult) Descriptor() ([]byte, []int)deprecated
- func (x *DescribeTableResult) GetAttributes() map[string]string
- func (x *DescribeTableResult) GetChangefeeds() []*ChangefeedDescription
- func (x *DescribeTableResult) GetColumnFamilies() []*ColumnFamily
- func (x *DescribeTableResult) GetColumns() []*ColumnMeta
- func (x *DescribeTableResult) GetIndexes() []*TableIndexDescription
- func (x *DescribeTableResult) GetKeyBloomFilter() Ydb.FeatureFlag_Status
- func (x *DescribeTableResult) GetPartitioningSettings() *PartitioningSettings
- func (x *DescribeTableResult) GetPrimaryKey() []string
- func (x *DescribeTableResult) GetReadReplicasSettings() *ReadReplicasSettings
- func (x *DescribeTableResult) GetSelf() *Ydb_Scheme.Entry
- func (x *DescribeTableResult) GetShardKeyBounds() []*Ydb.TypedValue
- func (x *DescribeTableResult) GetStorageSettings() *StorageSettings
- func (x *DescribeTableResult) GetStoreType() StoreType
- func (x *DescribeTableResult) GetTableStats() *TableStats
- func (x *DescribeTableResult) GetTemporary() bool
- func (x *DescribeTableResult) GetTiering() string
- func (x *DescribeTableResult) GetTtlSettings() *TtlSettings
- func (*DescribeTableResult) ProtoMessage()
- func (x *DescribeTableResult) ProtoReflect() protoreflect.Message
- func (x *DescribeTableResult) Reset()
- func (x *DescribeTableResult) String() string
- type DropTableRequest
- func (*DropTableRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DropTableRequest) GetOperationParams() *Ydb_Operations.OperationParams
- func (x *DropTableRequest) GetPath() string
- func (x *DropTableRequest) GetSessionId() string
- func (*DropTableRequest) ProtoMessage()
- func (x *DropTableRequest) ProtoReflect() protoreflect.Message
- func (x *DropTableRequest) Reset()
- func (x *DropTableRequest) String() string
- type DropTableResponse
- func (*DropTableResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DropTableResponse) GetOperation() *Ydb_Operations.Operation
- func (*DropTableResponse) ProtoMessage()
- func (x *DropTableResponse) ProtoReflect() protoreflect.Message
- func (x *DropTableResponse) Reset()
- func (x *DropTableResponse) String() string
- type ExecuteDataQueryRequest
- func (*ExecuteDataQueryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ExecuteDataQueryRequest) GetCollectStats() QueryStatsCollection_Mode
- func (x *ExecuteDataQueryRequest) GetOperationParams() *Ydb_Operations.OperationParams
- func (x *ExecuteDataQueryRequest) GetParameters() map[string]*Ydb.TypedValue
- func (x *ExecuteDataQueryRequest) GetQuery() *Query
- func (x *ExecuteDataQueryRequest) GetQueryCachePolicy() *QueryCachePolicy
- func (x *ExecuteDataQueryRequest) GetSessionId() string
- func (x *ExecuteDataQueryRequest) GetTxControl() *TransactionControl
- func (*ExecuteDataQueryRequest) ProtoMessage()
- func (x *ExecuteDataQueryRequest) ProtoReflect() protoreflect.Message
- func (x *ExecuteDataQueryRequest) Reset()
- func (x *ExecuteDataQueryRequest) String() string
- type ExecuteDataQueryResponse
- func (*ExecuteDataQueryResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ExecuteDataQueryResponse) GetOperation() *Ydb_Operations.Operation
- func (*ExecuteDataQueryResponse) ProtoMessage()
- func (x *ExecuteDataQueryResponse) ProtoReflect() protoreflect.Message
- func (x *ExecuteDataQueryResponse) Reset()
- func (x *ExecuteDataQueryResponse) String() string
- type ExecuteQueryResult
- func (*ExecuteQueryResult) Descriptor() ([]byte, []int)deprecated
- func (x *ExecuteQueryResult) GetQueryMeta() *QueryMeta
- func (x *ExecuteQueryResult) GetQueryStats() *Ydb_TableStats.QueryStats
- func (x *ExecuteQueryResult) GetResultSets() []*Ydb.ResultSet
- func (x *ExecuteQueryResult) GetTxMeta() *TransactionMeta
- func (*ExecuteQueryResult) ProtoMessage()
- func (x *ExecuteQueryResult) ProtoReflect() protoreflect.Message
- func (x *ExecuteQueryResult) Reset()
- func (x *ExecuteQueryResult) String() string
- type ExecuteScanQueryPartialResponse
- func (*ExecuteScanQueryPartialResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ExecuteScanQueryPartialResponse) GetIssues() []*Ydb_Issue.IssueMessage
- func (x *ExecuteScanQueryPartialResponse) GetResult() *ExecuteScanQueryPartialResult
- func (x *ExecuteScanQueryPartialResponse) GetStatus() Ydb.StatusIds_StatusCode
- func (*ExecuteScanQueryPartialResponse) ProtoMessage()
- func (x *ExecuteScanQueryPartialResponse) ProtoReflect() protoreflect.Message
- func (x *ExecuteScanQueryPartialResponse) Reset()
- func (x *ExecuteScanQueryPartialResponse) String() string
- type ExecuteScanQueryPartialResult
- func (*ExecuteScanQueryPartialResult) Descriptor() ([]byte, []int)deprecated
- func (x *ExecuteScanQueryPartialResult) GetQueryFullDiagnostics() string
- func (x *ExecuteScanQueryPartialResult) GetQueryStats() *Ydb_TableStats.QueryStats
- func (x *ExecuteScanQueryPartialResult) GetResultSet() *Ydb.ResultSet
- func (*ExecuteScanQueryPartialResult) ProtoMessage()
- func (x *ExecuteScanQueryPartialResult) ProtoReflect() protoreflect.Message
- func (x *ExecuteScanQueryPartialResult) Reset()
- func (x *ExecuteScanQueryPartialResult) String() string
- type ExecuteScanQueryRequest
- func (*ExecuteScanQueryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ExecuteScanQueryRequest) GetCollectFullDiagnostics() bool
- func (x *ExecuteScanQueryRequest) GetCollectStats() QueryStatsCollection_Mode
- func (x *ExecuteScanQueryRequest) GetMode() ExecuteScanQueryRequest_Mode
- func (x *ExecuteScanQueryRequest) GetParameters() map[string]*Ydb.TypedValue
- func (x *ExecuteScanQueryRequest) GetQuery() *Query
- func (*ExecuteScanQueryRequest) ProtoMessage()
- func (x *ExecuteScanQueryRequest) ProtoReflect() protoreflect.Message
- func (x *ExecuteScanQueryRequest) Reset()
- func (x *ExecuteScanQueryRequest) String() string
- type ExecuteScanQueryRequest_Mode
- func (ExecuteScanQueryRequest_Mode) Descriptor() protoreflect.EnumDescriptor
- func (x ExecuteScanQueryRequest_Mode) Enum() *ExecuteScanQueryRequest_Mode
- func (ExecuteScanQueryRequest_Mode) EnumDescriptor() ([]byte, []int)deprecated
- func (x ExecuteScanQueryRequest_Mode) Number() protoreflect.EnumNumber
- func (x ExecuteScanQueryRequest_Mode) String() string
- func (ExecuteScanQueryRequest_Mode) Type() protoreflect.EnumType
- type ExecuteSchemeQueryRequest
- func (*ExecuteSchemeQueryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ExecuteSchemeQueryRequest) GetOperationParams() *Ydb_Operations.OperationParams
- func (x *ExecuteSchemeQueryRequest) GetSessionId() string
- func (x *ExecuteSchemeQueryRequest) GetYqlText() string
- func (*ExecuteSchemeQueryRequest) ProtoMessage()
- func (x *ExecuteSchemeQueryRequest) ProtoReflect() protoreflect.Message
- func (x *ExecuteSchemeQueryRequest) Reset()
- func (x *ExecuteSchemeQueryRequest) String() string
- type ExecuteSchemeQueryResponse
- func (*ExecuteSchemeQueryResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ExecuteSchemeQueryResponse) GetOperation() *Ydb_Operations.Operation
- func (*ExecuteSchemeQueryResponse) ProtoMessage()
- func (x *ExecuteSchemeQueryResponse) ProtoReflect() protoreflect.Message
- func (x *ExecuteSchemeQueryResponse) Reset()
- func (x *ExecuteSchemeQueryResponse) String() string
- type ExecutionPolicy
- type ExecutionPolicyDescription
- func (*ExecutionPolicyDescription) Descriptor() ([]byte, []int)deprecated
- func (x *ExecutionPolicyDescription) GetLabels() map[string]string
- func (x *ExecutionPolicyDescription) GetName() string
- func (*ExecutionPolicyDescription) ProtoMessage()
- func (x *ExecutionPolicyDescription) ProtoReflect() protoreflect.Message
- func (x *ExecutionPolicyDescription) Reset()
- func (x *ExecutionPolicyDescription) String() string
- type ExplainDataQueryRequest
- func (*ExplainDataQueryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ExplainDataQueryRequest) GetCollectFullDiagnostics() bool
- func (x *ExplainDataQueryRequest) GetOperationParams() *Ydb_Operations.OperationParams
- func (x *ExplainDataQueryRequest) GetSessionId() string
- func (x *ExplainDataQueryRequest) GetYqlText() string
- func (*ExplainDataQueryRequest) ProtoMessage()
- func (x *ExplainDataQueryRequest) ProtoReflect() protoreflect.Message
- func (x *ExplainDataQueryRequest) Reset()
- func (x *ExplainDataQueryRequest) String() string
- type ExplainDataQueryResponse
- func (*ExplainDataQueryResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ExplainDataQueryResponse) GetOperation() *Ydb_Operations.Operation
- func (*ExplainDataQueryResponse) ProtoMessage()
- func (x *ExplainDataQueryResponse) ProtoReflect() protoreflect.Message
- func (x *ExplainDataQueryResponse) Reset()
- func (x *ExplainDataQueryResponse) String() string
- type ExplainQueryResult
- func (*ExplainQueryResult) Descriptor() ([]byte, []int)deprecated
- func (x *ExplainQueryResult) GetQueryAst() string
- func (x *ExplainQueryResult) GetQueryFullDiagnostics() string
- func (x *ExplainQueryResult) GetQueryPlan() string
- func (*ExplainQueryResult) ProtoMessage()
- func (x *ExplainQueryResult) ProtoReflect() protoreflect.Message
- func (x *ExplainQueryResult) Reset()
- func (x *ExplainQueryResult) String() string
- type ExplicitPartitions
- func (*ExplicitPartitions) Descriptor() ([]byte, []int)deprecated
- func (x *ExplicitPartitions) GetSplitPoints() []*Ydb.TypedValue
- func (*ExplicitPartitions) ProtoMessage()
- func (x *ExplicitPartitions) ProtoReflect() protoreflect.Message
- func (x *ExplicitPartitions) Reset()
- func (x *ExplicitPartitions) String() string
- type GlobalAsyncIndex
- type GlobalIndex
- type GlobalUniqueIndex
- type IndexBuildDescription
- func (*IndexBuildDescription) Descriptor() ([]byte, []int)deprecated
- func (x *IndexBuildDescription) GetIndex() *TableIndex
- func (x *IndexBuildDescription) GetPath() string
- func (*IndexBuildDescription) ProtoMessage()
- func (x *IndexBuildDescription) ProtoReflect() protoreflect.Message
- func (x *IndexBuildDescription) Reset()
- func (x *IndexBuildDescription) String() string
- type IndexBuildMetadata
- func (*IndexBuildMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *IndexBuildMetadata) GetDescription() *IndexBuildDescription
- func (x *IndexBuildMetadata) GetProgress() float32
- func (x *IndexBuildMetadata) GetState() IndexBuildState_State
- func (*IndexBuildMetadata) ProtoMessage()
- func (x *IndexBuildMetadata) ProtoReflect() protoreflect.Message
- func (x *IndexBuildMetadata) Reset()
- func (x *IndexBuildMetadata) String() string
- type IndexBuildState
- type IndexBuildState_State
- func (IndexBuildState_State) Descriptor() protoreflect.EnumDescriptor
- func (x IndexBuildState_State) Enum() *IndexBuildState_State
- func (IndexBuildState_State) EnumDescriptor() ([]byte, []int)deprecated
- func (x IndexBuildState_State) Number() protoreflect.EnumNumber
- func (x IndexBuildState_State) String() string
- func (IndexBuildState_State) Type() protoreflect.EnumType
- type KeepAliveRequest
- func (*KeepAliveRequest) Descriptor() ([]byte, []int)deprecated
- func (x *KeepAliveRequest) GetOperationParams() *Ydb_Operations.OperationParams
- func (x *KeepAliveRequest) GetSessionId() string
- func (*KeepAliveRequest) ProtoMessage()
- func (x *KeepAliveRequest) ProtoReflect() protoreflect.Message
- func (x *KeepAliveRequest) Reset()
- func (x *KeepAliveRequest) String() string
- type KeepAliveResponse
- func (*KeepAliveResponse) Descriptor() ([]byte, []int)deprecated
- func (x *KeepAliveResponse) GetOperation() *Ydb_Operations.Operation
- func (*KeepAliveResponse) ProtoMessage()
- func (x *KeepAliveResponse) ProtoReflect() protoreflect.Message
- func (x *KeepAliveResponse) Reset()
- func (x *KeepAliveResponse) String() string
- type KeepAliveResult
- func (*KeepAliveResult) Descriptor() ([]byte, []int)deprecated
- func (x *KeepAliveResult) GetSessionStatus() KeepAliveResult_SessionStatus
- func (*KeepAliveResult) ProtoMessage()
- func (x *KeepAliveResult) ProtoReflect() protoreflect.Message
- func (x *KeepAliveResult) Reset()
- func (x *KeepAliveResult) String() string
- type KeepAliveResult_SessionStatus
- func (KeepAliveResult_SessionStatus) Descriptor() protoreflect.EnumDescriptor
- func (x KeepAliveResult_SessionStatus) Enum() *KeepAliveResult_SessionStatus
- func (KeepAliveResult_SessionStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x KeepAliveResult_SessionStatus) Number() protoreflect.EnumNumber
- func (x KeepAliveResult_SessionStatus) String() string
- func (KeepAliveResult_SessionStatus) Type() protoreflect.EnumType
- type KeyRange
- func (*KeyRange) Descriptor() ([]byte, []int)deprecated
- func (m *KeyRange) GetFromBound() isKeyRange_FromBound
- func (x *KeyRange) GetGreater() *Ydb.TypedValue
- func (x *KeyRange) GetGreaterOrEqual() *Ydb.TypedValue
- func (x *KeyRange) GetLess() *Ydb.TypedValue
- func (x *KeyRange) GetLessOrEqual() *Ydb.TypedValue
- func (m *KeyRange) GetToBound() isKeyRange_ToBound
- func (*KeyRange) ProtoMessage()
- func (x *KeyRange) ProtoReflect() protoreflect.Message
- func (x *KeyRange) Reset()
- func (x *KeyRange) String() string
- type KeyRange_Greater
- type KeyRange_GreaterOrEqual
- type KeyRange_Less
- type KeyRange_LessOrEqual
- type OnlineModeSettings
- func (*OnlineModeSettings) Descriptor() ([]byte, []int)deprecated
- func (x *OnlineModeSettings) GetAllowInconsistentReads() bool
- func (*OnlineModeSettings) ProtoMessage()
- func (x *OnlineModeSettings) ProtoReflect() protoreflect.Message
- func (x *OnlineModeSettings) Reset()
- func (x *OnlineModeSettings) String() string
- type PartitionStats
- func (*PartitionStats) Descriptor() ([]byte, []int)deprecated
- func (x *PartitionStats) GetRowsEstimate() uint64
- func (x *PartitionStats) GetStoreSize() uint64
- func (*PartitionStats) ProtoMessage()
- func (x *PartitionStats) ProtoReflect() protoreflect.Message
- func (x *PartitionStats) Reset()
- func (x *PartitionStats) String() string
- type PartitioningPolicy
- func (*PartitioningPolicy) Descriptor() ([]byte, []int)deprecated
- func (x *PartitioningPolicy) GetAutoPartitioning() PartitioningPolicy_AutoPartitioningPolicy
- func (x *PartitioningPolicy) GetExplicitPartitions() *ExplicitPartitions
- func (m *PartitioningPolicy) GetPartitions() isPartitioningPolicy_Partitions
- func (x *PartitioningPolicy) GetPresetName() string
- func (x *PartitioningPolicy) GetUniformPartitions() uint64
- func (*PartitioningPolicy) ProtoMessage()
- func (x *PartitioningPolicy) ProtoReflect() protoreflect.Message
- func (x *PartitioningPolicy) Reset()
- func (x *PartitioningPolicy) String() string
- type PartitioningPolicyDescription
- func (*PartitioningPolicyDescription) Descriptor() ([]byte, []int)deprecated
- func (x *PartitioningPolicyDescription) GetLabels() map[string]string
- func (x *PartitioningPolicyDescription) GetName() string
- func (*PartitioningPolicyDescription) ProtoMessage()
- func (x *PartitioningPolicyDescription) ProtoReflect() protoreflect.Message
- func (x *PartitioningPolicyDescription) Reset()
- func (x *PartitioningPolicyDescription) String() string
- type PartitioningPolicy_AutoPartitioningPolicy
- func (PartitioningPolicy_AutoPartitioningPolicy) Descriptor() protoreflect.EnumDescriptor
- func (x PartitioningPolicy_AutoPartitioningPolicy) Enum() *PartitioningPolicy_AutoPartitioningPolicy
- func (PartitioningPolicy_AutoPartitioningPolicy) EnumDescriptor() ([]byte, []int)deprecated
- func (x PartitioningPolicy_AutoPartitioningPolicy) Number() protoreflect.EnumNumber
- func (x PartitioningPolicy_AutoPartitioningPolicy) String() string
- func (PartitioningPolicy_AutoPartitioningPolicy) Type() protoreflect.EnumType
- type PartitioningPolicy_ExplicitPartitions
- type PartitioningPolicy_UniformPartitions
- type PartitioningSettings
- func (*PartitioningSettings) Descriptor() ([]byte, []int)deprecated
- func (x *PartitioningSettings) GetMaxPartitionsCount() uint64
- func (x *PartitioningSettings) GetMinPartitionsCount() uint64
- func (x *PartitioningSettings) GetPartitionBy() []string
- func (x *PartitioningSettings) GetPartitionSizeMb() uint64
- func (x *PartitioningSettings) GetPartitioningByLoad() Ydb.FeatureFlag_Status
- func (x *PartitioningSettings) GetPartitioningBySize() Ydb.FeatureFlag_Status
- func (*PartitioningSettings) ProtoMessage()
- func (x *PartitioningSettings) ProtoReflect() protoreflect.Message
- func (x *PartitioningSettings) Reset()
- func (x *PartitioningSettings) String() string
- type PrepareDataQueryRequest
- func (*PrepareDataQueryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PrepareDataQueryRequest) GetOperationParams() *Ydb_Operations.OperationParams
- func (x *PrepareDataQueryRequest) GetSessionId() string
- func (x *PrepareDataQueryRequest) GetYqlText() string
- func (*PrepareDataQueryRequest) ProtoMessage()
- func (x *PrepareDataQueryRequest) ProtoReflect() protoreflect.Message
- func (x *PrepareDataQueryRequest) Reset()
- func (x *PrepareDataQueryRequest) String() string
- type PrepareDataQueryResponse
- func (*PrepareDataQueryResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PrepareDataQueryResponse) GetOperation() *Ydb_Operations.Operation
- func (*PrepareDataQueryResponse) ProtoMessage()
- func (x *PrepareDataQueryResponse) ProtoReflect() protoreflect.Message
- func (x *PrepareDataQueryResponse) Reset()
- func (x *PrepareDataQueryResponse) String() string
- type PrepareQueryResult
- func (*PrepareQueryResult) Descriptor() ([]byte, []int)deprecated
- func (x *PrepareQueryResult) GetParametersTypes() map[string]*Ydb.Type
- func (x *PrepareQueryResult) GetQueryId() string
- func (*PrepareQueryResult) ProtoMessage()
- func (x *PrepareQueryResult) ProtoReflect() protoreflect.Message
- func (x *PrepareQueryResult) Reset()
- func (x *PrepareQueryResult) String() string
- type Query
- type QueryCachePolicy
- type QueryMeta
- func (*QueryMeta) Descriptor() ([]byte, []int)deprecated
- func (x *QueryMeta) GetId() string
- func (x *QueryMeta) GetParametersTypes() map[string]*Ydb.Type
- func (*QueryMeta) ProtoMessage()
- func (x *QueryMeta) ProtoReflect() protoreflect.Message
- func (x *QueryMeta) Reset()
- func (x *QueryMeta) String() string
- type QueryStatsCollection
- type QueryStatsCollection_Mode
- func (QueryStatsCollection_Mode) Descriptor() protoreflect.EnumDescriptor
- func (x QueryStatsCollection_Mode) Enum() *QueryStatsCollection_Mode
- func (QueryStatsCollection_Mode) EnumDescriptor() ([]byte, []int)deprecated
- func (x QueryStatsCollection_Mode) Number() protoreflect.EnumNumber
- func (x QueryStatsCollection_Mode) String() string
- func (QueryStatsCollection_Mode) Type() protoreflect.EnumType
- type Query_Id
- type Query_YqlText
- type ReadReplicasSettings
- func (*ReadReplicasSettings) Descriptor() ([]byte, []int)deprecated
- func (x *ReadReplicasSettings) GetAnyAzReadReplicasCount() uint64
- func (x *ReadReplicasSettings) GetPerAzReadReplicasCount() uint64
- func (m *ReadReplicasSettings) GetSettings() isReadReplicasSettings_Settings
- func (*ReadReplicasSettings) ProtoMessage()
- func (x *ReadReplicasSettings) ProtoReflect() protoreflect.Message
- func (x *ReadReplicasSettings) Reset()
- func (x *ReadReplicasSettings) String() string
- type ReadReplicasSettings_AnyAzReadReplicasCount
- type ReadReplicasSettings_PerAzReadReplicasCount
- type ReadRowsRequest
- func (*ReadRowsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReadRowsRequest) GetColumns() []string
- func (x *ReadRowsRequest) GetKeys() *Ydb.TypedValue
- func (x *ReadRowsRequest) GetPath() string
- func (x *ReadRowsRequest) GetSessionId() string
- func (*ReadRowsRequest) ProtoMessage()
- func (x *ReadRowsRequest) ProtoReflect() protoreflect.Message
- func (x *ReadRowsRequest) Reset()
- func (x *ReadRowsRequest) String() string
- type ReadRowsResponse
- func (*ReadRowsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ReadRowsResponse) GetIssues() []*Ydb_Issue.IssueMessage
- func (x *ReadRowsResponse) GetResultSet() *Ydb.ResultSet
- func (x *ReadRowsResponse) GetStatus() Ydb.StatusIds_StatusCode
- func (*ReadRowsResponse) ProtoMessage()
- func (x *ReadRowsResponse) ProtoReflect() protoreflect.Message
- func (x *ReadRowsResponse) Reset()
- func (x *ReadRowsResponse) String() string
- type ReadTableRequest
- func (*ReadTableRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReadTableRequest) GetBatchLimitBytes() uint64
- func (x *ReadTableRequest) GetBatchLimitRows() uint64
- func (x *ReadTableRequest) GetColumns() []string
- func (x *ReadTableRequest) GetKeyRange() *KeyRange
- func (x *ReadTableRequest) GetOrdered() bool
- func (x *ReadTableRequest) GetPath() string
- func (x *ReadTableRequest) GetReturnNotNullDataAsOptional() Ydb.FeatureFlag_Status
- func (x *ReadTableRequest) GetRowLimit() uint64
- func (x *ReadTableRequest) GetSessionId() string
- func (x *ReadTableRequest) GetUseSnapshot() Ydb.FeatureFlag_Status
- func (*ReadTableRequest) ProtoMessage()
- func (x *ReadTableRequest) ProtoReflect() protoreflect.Message
- func (x *ReadTableRequest) Reset()
- func (x *ReadTableRequest) String() string
- type ReadTableResponse
- func (*ReadTableResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ReadTableResponse) GetIssues() []*Ydb_Issue.IssueMessage
- func (x *ReadTableResponse) GetResult() *ReadTableResult
- func (x *ReadTableResponse) GetSnapshot() *Ydb.VirtualTimestamp
- func (x *ReadTableResponse) GetStatus() Ydb.StatusIds_StatusCode
- func (*ReadTableResponse) ProtoMessage()
- func (x *ReadTableResponse) ProtoReflect() protoreflect.Message
- func (x *ReadTableResponse) Reset()
- func (x *ReadTableResponse) String() string
- type ReadTableResult
- type RenameIndexItem
- func (*RenameIndexItem) Descriptor() ([]byte, []int)deprecated
- func (x *RenameIndexItem) GetDestinationName() string
- func (x *RenameIndexItem) GetReplaceDestination() bool
- func (x *RenameIndexItem) GetSourceName() string
- func (*RenameIndexItem) ProtoMessage()
- func (x *RenameIndexItem) ProtoReflect() protoreflect.Message
- func (x *RenameIndexItem) Reset()
- func (x *RenameIndexItem) String() string
- type RenameTableItem
- func (*RenameTableItem) Descriptor() ([]byte, []int)deprecated
- func (x *RenameTableItem) GetDestinationPath() string
- func (x *RenameTableItem) GetReplaceDestination() bool
- func (x *RenameTableItem) GetSourcePath() string
- func (*RenameTableItem) ProtoMessage()
- func (x *RenameTableItem) ProtoReflect() protoreflect.Message
- func (x *RenameTableItem) Reset()
- func (x *RenameTableItem) String() string
- type RenameTablesRequest
- func (*RenameTablesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RenameTablesRequest) GetOperationParams() *Ydb_Operations.OperationParams
- func (x *RenameTablesRequest) GetSessionId() string
- func (x *RenameTablesRequest) GetTables() []*RenameTableItem
- func (*RenameTablesRequest) ProtoMessage()
- func (x *RenameTablesRequest) ProtoReflect() protoreflect.Message
- func (x *RenameTablesRequest) Reset()
- func (x *RenameTablesRequest) String() string
- type RenameTablesResponse
- func (*RenameTablesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RenameTablesResponse) GetOperation() *Ydb_Operations.Operation
- func (*RenameTablesResponse) ProtoMessage()
- func (x *RenameTablesResponse) ProtoReflect() protoreflect.Message
- func (x *RenameTablesResponse) Reset()
- func (x *RenameTablesResponse) String() string
- type ReplicationPolicy
- func (*ReplicationPolicy) Descriptor() ([]byte, []int)deprecated
- func (x *ReplicationPolicy) GetAllowPromotion() Ydb.FeatureFlag_Status
- func (x *ReplicationPolicy) GetCreatePerAvailabilityZone() Ydb.FeatureFlag_Status
- func (x *ReplicationPolicy) GetPresetName() string
- func (x *ReplicationPolicy) GetReplicasCount() uint32
- func (*ReplicationPolicy) ProtoMessage()
- func (x *ReplicationPolicy) ProtoReflect() protoreflect.Message
- func (x *ReplicationPolicy) Reset()
- func (x *ReplicationPolicy) String() string
- type ReplicationPolicyDescription
- func (*ReplicationPolicyDescription) Descriptor() ([]byte, []int)deprecated
- func (x *ReplicationPolicyDescription) GetLabels() map[string]string
- func (x *ReplicationPolicyDescription) GetName() string
- func (*ReplicationPolicyDescription) ProtoMessage()
- func (x *ReplicationPolicyDescription) ProtoReflect() protoreflect.Message
- func (x *ReplicationPolicyDescription) Reset()
- func (x *ReplicationPolicyDescription) String() string
- type RollbackTransactionRequest
- func (*RollbackTransactionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RollbackTransactionRequest) GetOperationParams() *Ydb_Operations.OperationParams
- func (x *RollbackTransactionRequest) GetSessionId() string
- func (x *RollbackTransactionRequest) GetTxId() string
- func (*RollbackTransactionRequest) ProtoMessage()
- func (x *RollbackTransactionRequest) ProtoReflect() protoreflect.Message
- func (x *RollbackTransactionRequest) Reset()
- func (x *RollbackTransactionRequest) String() string
- type RollbackTransactionResponse
- func (*RollbackTransactionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RollbackTransactionResponse) GetOperation() *Ydb_Operations.Operation
- func (*RollbackTransactionResponse) ProtoMessage()
- func (x *RollbackTransactionResponse) ProtoReflect() protoreflect.Message
- func (x *RollbackTransactionResponse) Reset()
- func (x *RollbackTransactionResponse) String() string
- type SequenceDescription
- func (*SequenceDescription) Descriptor() ([]byte, []int)deprecated
- func (x *SequenceDescription) GetCache() uint64
- func (x *SequenceDescription) GetCycle() bool
- func (x *SequenceDescription) GetIncrement() int64
- func (x *SequenceDescription) GetMaxValue() int64
- func (x *SequenceDescription) GetMinValue() int64
- func (x *SequenceDescription) GetName() string
- func (x *SequenceDescription) GetSetVal() *SequenceDescription_SetVal
- func (x *SequenceDescription) GetStartValue() int64
- func (*SequenceDescription) ProtoMessage()
- func (x *SequenceDescription) ProtoReflect() protoreflect.Message
- func (x *SequenceDescription) Reset()
- func (x *SequenceDescription) String() string
- type SequenceDescription_SetVal
- func (*SequenceDescription_SetVal) Descriptor() ([]byte, []int)deprecated
- func (x *SequenceDescription_SetVal) GetNextUsed() bool
- func (x *SequenceDescription_SetVal) GetNextValue() int64
- func (*SequenceDescription_SetVal) ProtoMessage()
- func (x *SequenceDescription_SetVal) ProtoReflect() protoreflect.Message
- func (x *SequenceDescription_SetVal) Reset()
- func (x *SequenceDescription_SetVal) String() string
- type SerializableModeSettings
- type SnapshotModeSettings
- type StaleModeSettings
- type StoragePolicy
- func (*StoragePolicy) Descriptor() ([]byte, []int)deprecated
- func (x *StoragePolicy) GetColumnFamilies() []*ColumnFamilyPolicy
- func (x *StoragePolicy) GetData() *StoragePool
- func (x *StoragePolicy) GetExternal() *StoragePool
- func (x *StoragePolicy) GetKeepInMemory() Ydb.FeatureFlag_Status
- func (x *StoragePolicy) GetLog() *StoragePool
- func (x *StoragePolicy) GetPresetName() string
- func (x *StoragePolicy) GetSyslog() *StoragePool
- func (*StoragePolicy) ProtoMessage()
- func (x *StoragePolicy) ProtoReflect() protoreflect.Message
- func (x *StoragePolicy) Reset()
- func (x *StoragePolicy) String() string
- type StoragePolicyDescription
- func (*StoragePolicyDescription) Descriptor() ([]byte, []int)deprecated
- func (x *StoragePolicyDescription) GetLabels() map[string]string
- func (x *StoragePolicyDescription) GetName() string
- func (*StoragePolicyDescription) ProtoMessage()
- func (x *StoragePolicyDescription) ProtoReflect() protoreflect.Message
- func (x *StoragePolicyDescription) Reset()
- func (x *StoragePolicyDescription) String() string
- type StoragePool
- type StorageSettings
- func (*StorageSettings) Descriptor() ([]byte, []int)deprecated
- func (x *StorageSettings) GetExternal() *StoragePool
- func (x *StorageSettings) GetStoreExternalBlobs() Ydb.FeatureFlag_Status
- func (x *StorageSettings) GetTabletCommitLog0() *StoragePool
- func (x *StorageSettings) GetTabletCommitLog1() *StoragePool
- func (*StorageSettings) ProtoMessage()
- func (x *StorageSettings) ProtoReflect() protoreflect.Message
- func (x *StorageSettings) Reset()
- func (x *StorageSettings) String() string
- type StoreType
- type TableIndex
- func (*TableIndex) Descriptor() ([]byte, []int)deprecated
- func (x *TableIndex) GetDataColumns() []string
- func (x *TableIndex) GetGlobalAsyncIndex() *GlobalAsyncIndex
- func (x *TableIndex) GetGlobalIndex() *GlobalIndex
- func (x *TableIndex) GetGlobalUniqueIndex() *GlobalUniqueIndex
- func (x *TableIndex) GetIndexColumns() []string
- func (x *TableIndex) GetName() string
- func (m *TableIndex) GetType() isTableIndex_Type
- func (*TableIndex) ProtoMessage()
- func (x *TableIndex) ProtoReflect() protoreflect.Message
- func (x *TableIndex) Reset()
- func (x *TableIndex) String() string
- type TableIndexDescription
- func (*TableIndexDescription) Descriptor() ([]byte, []int)deprecated
- func (x *TableIndexDescription) GetDataColumns() []string
- func (x *TableIndexDescription) GetGlobalAsyncIndex() *GlobalAsyncIndex
- func (x *TableIndexDescription) GetGlobalIndex() *GlobalIndex
- func (x *TableIndexDescription) GetGlobalUniqueIndex() *GlobalUniqueIndex
- func (x *TableIndexDescription) GetIndexColumns() []string
- func (x *TableIndexDescription) GetName() string
- func (x *TableIndexDescription) GetSizeBytes() uint64
- func (x *TableIndexDescription) GetStatus() TableIndexDescription_Status
- func (m *TableIndexDescription) GetType() isTableIndexDescription_Type
- func (*TableIndexDescription) ProtoMessage()
- func (x *TableIndexDescription) ProtoReflect() protoreflect.Message
- func (x *TableIndexDescription) Reset()
- func (x *TableIndexDescription) String() string
- type TableIndexDescription_GlobalAsyncIndex
- type TableIndexDescription_GlobalIndex
- type TableIndexDescription_GlobalUniqueIndex
- type TableIndexDescription_Status
- func (TableIndexDescription_Status) Descriptor() protoreflect.EnumDescriptor
- func (x TableIndexDescription_Status) Enum() *TableIndexDescription_Status
- func (TableIndexDescription_Status) EnumDescriptor() ([]byte, []int)deprecated
- func (x TableIndexDescription_Status) Number() protoreflect.EnumNumber
- func (x TableIndexDescription_Status) String() string
- func (TableIndexDescription_Status) Type() protoreflect.EnumType
- type TableIndex_GlobalAsyncIndex
- type TableIndex_GlobalIndex
- type TableIndex_GlobalUniqueIndex
- type TableProfile
- func (*TableProfile) Descriptor() ([]byte, []int)deprecated
- func (x *TableProfile) GetCachingPolicy() *CachingPolicy
- func (x *TableProfile) GetCompactionPolicy() *CompactionPolicy
- func (x *TableProfile) GetExecutionPolicy() *ExecutionPolicy
- func (x *TableProfile) GetPartitioningPolicy() *PartitioningPolicy
- func (x *TableProfile) GetPresetName() string
- func (x *TableProfile) GetReplicationPolicy() *ReplicationPolicy
- func (x *TableProfile) GetStoragePolicy() *StoragePolicy
- func (*TableProfile) ProtoMessage()
- func (x *TableProfile) ProtoReflect() protoreflect.Message
- func (x *TableProfile) Reset()
- func (x *TableProfile) String() string
- type TableProfileDescription
- func (*TableProfileDescription) Descriptor() ([]byte, []int)deprecated
- func (x *TableProfileDescription) GetAllowedCachingPolicies() []string
- func (x *TableProfileDescription) GetAllowedCompactionPolicies() []string
- func (x *TableProfileDescription) GetAllowedExecutionPolicies() []string
- func (x *TableProfileDescription) GetAllowedPartitioningPolicies() []string
- func (x *TableProfileDescription) GetAllowedReplicationPolicies() []string
- func (x *TableProfileDescription) GetAllowedStoragePolicies() []string
- func (x *TableProfileDescription) GetDefaultCachingPolicy() string
- func (x *TableProfileDescription) GetDefaultCompactionPolicy() string
- func (x *TableProfileDescription) GetDefaultExecutionPolicy() string
- func (x *TableProfileDescription) GetDefaultPartitioningPolicy() string
- func (x *TableProfileDescription) GetDefaultReplicationPolicy() string
- func (x *TableProfileDescription) GetDefaultStoragePolicy() string
- func (x *TableProfileDescription) GetLabels() map[string]string
- func (x *TableProfileDescription) GetName() string
- func (*TableProfileDescription) ProtoMessage()
- func (x *TableProfileDescription) ProtoReflect() protoreflect.Message
- func (x *TableProfileDescription) Reset()
- func (x *TableProfileDescription) String() string
- type TableStats
- func (*TableStats) Descriptor() ([]byte, []int)deprecated
- func (x *TableStats) GetCreationTime() *timestamppb.Timestamp
- func (x *TableStats) GetModificationTime() *timestamppb.Timestamp
- func (x *TableStats) GetPartitionStats() []*PartitionStats
- func (x *TableStats) GetPartitions() uint64
- func (x *TableStats) GetRowsEstimate() uint64
- func (x *TableStats) GetStoreSize() uint64
- func (*TableStats) ProtoMessage()
- func (x *TableStats) ProtoReflect() protoreflect.Message
- func (x *TableStats) Reset()
- func (x *TableStats) String() string
- type TransactionControl
- func (*TransactionControl) Descriptor() ([]byte, []int)deprecated
- func (x *TransactionControl) GetBeginTx() *TransactionSettings
- func (x *TransactionControl) GetCommitTx() bool
- func (x *TransactionControl) GetTxId() string
- func (m *TransactionControl) GetTxSelector() isTransactionControl_TxSelector
- func (*TransactionControl) ProtoMessage()
- func (x *TransactionControl) ProtoReflect() protoreflect.Message
- func (x *TransactionControl) Reset()
- func (x *TransactionControl) String() string
- type TransactionControl_BeginTx
- type TransactionControl_TxId
- type TransactionMeta
- type TransactionSettings
- func (*TransactionSettings) Descriptor() ([]byte, []int)deprecated
- func (x *TransactionSettings) GetOnlineReadOnly() *OnlineModeSettings
- func (x *TransactionSettings) GetSerializableReadWrite() *SerializableModeSettings
- func (x *TransactionSettings) GetSnapshotReadOnly() *SnapshotModeSettings
- func (x *TransactionSettings) GetStaleReadOnly() *StaleModeSettings
- func (m *TransactionSettings) GetTxMode() isTransactionSettings_TxMode
- func (*TransactionSettings) ProtoMessage()
- func (x *TransactionSettings) ProtoReflect() protoreflect.Message
- func (x *TransactionSettings) Reset()
- func (x *TransactionSettings) String() string
- type TransactionSettings_OnlineReadOnly
- type TransactionSettings_SerializableReadWrite
- type TransactionSettings_SnapshotReadOnly
- type TransactionSettings_StaleReadOnly
- type TtlSettings
- func (*TtlSettings) Descriptor() ([]byte, []int)deprecated
- func (x *TtlSettings) GetDateTypeColumn() *DateTypeColumnModeSettings
- func (m *TtlSettings) GetMode() isTtlSettings_Mode
- func (x *TtlSettings) GetRunIntervalSeconds() uint32
- func (x *TtlSettings) GetValueSinceUnixEpoch() *ValueSinceUnixEpochModeSettings
- func (*TtlSettings) ProtoMessage()
- func (x *TtlSettings) ProtoReflect() protoreflect.Message
- func (x *TtlSettings) Reset()
- func (x *TtlSettings) String() string
- type TtlSettings_DateTypeColumn
- type TtlSettings_ValueSinceUnixEpoch
- type ValueSinceUnixEpochModeSettings
- func (*ValueSinceUnixEpochModeSettings) Descriptor() ([]byte, []int)deprecated
- func (x *ValueSinceUnixEpochModeSettings) GetColumnName() string
- func (x *ValueSinceUnixEpochModeSettings) GetColumnUnit() ValueSinceUnixEpochModeSettings_Unit
- func (x *ValueSinceUnixEpochModeSettings) GetExpireAfterSeconds() uint32
- func (*ValueSinceUnixEpochModeSettings) ProtoMessage()
- func (x *ValueSinceUnixEpochModeSettings) ProtoReflect() protoreflect.Message
- func (x *ValueSinceUnixEpochModeSettings) Reset()
- func (x *ValueSinceUnixEpochModeSettings) String() string
- type ValueSinceUnixEpochModeSettings_Unit
- func (ValueSinceUnixEpochModeSettings_Unit) Descriptor() protoreflect.EnumDescriptor
- func (x ValueSinceUnixEpochModeSettings_Unit) Enum() *ValueSinceUnixEpochModeSettings_Unit
- func (ValueSinceUnixEpochModeSettings_Unit) EnumDescriptor() ([]byte, []int)deprecated
- func (x ValueSinceUnixEpochModeSettings_Unit) Number() protoreflect.EnumNumber
- func (x ValueSinceUnixEpochModeSettings_Unit) String() string
- func (ValueSinceUnixEpochModeSettings_Unit) Type() protoreflect.EnumType
Constants ¶
This section is empty.
Variables ¶
var ( StoreType_name = map[int32]string{ 0: "STORE_TYPE_UNSPECIFIED", 1: "STORE_TYPE_ROW", 2: "STORE_TYPE_COLUMN", } StoreType_value = map[string]int32{ "STORE_TYPE_UNSPECIFIED": 0, "STORE_TYPE_ROW": 1, "STORE_TYPE_COLUMN": 2, } )
Enum value maps for StoreType.
var ( TableIndexDescription_Status_name = map[int32]string{ 0: "STATUS_UNSPECIFIED", 1: "STATUS_READY", 2: "STATUS_BUILDING", } TableIndexDescription_Status_value = map[string]int32{ "STATUS_UNSPECIFIED": 0, "STATUS_READY": 1, "STATUS_BUILDING": 2, } )
Enum value maps for TableIndexDescription_Status.
var ( IndexBuildState_State_name = map[int32]string{ 0: "STATE_UNSPECIFIED", 1: "STATE_PREPARING", 2: "STATE_TRANSFERING_DATA", 3: "STATE_APPLYING", 4: "STATE_DONE", 5: "STATE_CANCELLATION", 6: "STATE_CANCELLED", 7: "STATE_REJECTION", 8: "STATE_REJECTED", } IndexBuildState_State_value = map[string]int32{ "STATE_UNSPECIFIED": 0, "STATE_PREPARING": 1, "STATE_TRANSFERING_DATA": 2, "STATE_APPLYING": 3, "STATE_DONE": 4, "STATE_CANCELLATION": 5, "STATE_CANCELLED": 6, "STATE_REJECTION": 7, "STATE_REJECTED": 8, } )
Enum value maps for IndexBuildState_State.
var ( ChangefeedMode_Mode_name = map[int32]string{ 0: "MODE_UNSPECIFIED", 1: "MODE_KEYS_ONLY", 2: "MODE_UPDATES", 3: "MODE_NEW_IMAGE", 4: "MODE_OLD_IMAGE", 5: "MODE_NEW_AND_OLD_IMAGES", } ChangefeedMode_Mode_value = map[string]int32{ "MODE_UNSPECIFIED": 0, "MODE_KEYS_ONLY": 1, "MODE_UPDATES": 2, "MODE_NEW_IMAGE": 3, "MODE_OLD_IMAGE": 4, "MODE_NEW_AND_OLD_IMAGES": 5, } )
Enum value maps for ChangefeedMode_Mode.
var ( ChangefeedFormat_Format_name = map[int32]string{ 0: "FORMAT_UNSPECIFIED", 1: "FORMAT_JSON", 2: "FORMAT_DYNAMODB_STREAMS_JSON", 3: "FORMAT_DEBEZIUM_JSON", } ChangefeedFormat_Format_value = map[string]int32{ "FORMAT_UNSPECIFIED": 0, "FORMAT_JSON": 1, "FORMAT_DYNAMODB_STREAMS_JSON": 2, "FORMAT_DEBEZIUM_JSON": 3, } )
Enum value maps for ChangefeedFormat_Format.
var ( ChangefeedDescription_State_name = map[int32]string{ 0: "STATE_UNSPECIFIED", 1: "STATE_ENABLED", 2: "STATE_DISABLED", 3: "STATE_INITIAL_SCAN", } ChangefeedDescription_State_value = map[string]int32{ "STATE_UNSPECIFIED": 0, "STATE_ENABLED": 1, "STATE_DISABLED": 2, "STATE_INITIAL_SCAN": 3, } )
Enum value maps for ChangefeedDescription_State.
var ( ColumnFamilyPolicy_Compression_name = map[int32]string{ 0: "COMPRESSION_UNSPECIFIED", 1: "UNCOMPRESSED", 2: "COMPRESSED", } ColumnFamilyPolicy_Compression_value = map[string]int32{ "COMPRESSION_UNSPECIFIED": 0, "UNCOMPRESSED": 1, "COMPRESSED": 2, } )
Enum value maps for ColumnFamilyPolicy_Compression.
var ( PartitioningPolicy_AutoPartitioningPolicy_name = map[int32]string{ 0: "AUTO_PARTITIONING_POLICY_UNSPECIFIED", 1: "DISABLED", 2: "AUTO_SPLIT", 3: "AUTO_SPLIT_MERGE", } PartitioningPolicy_AutoPartitioningPolicy_value = map[string]int32{ "AUTO_PARTITIONING_POLICY_UNSPECIFIED": 0, "DISABLED": 1, "AUTO_SPLIT": 2, "AUTO_SPLIT_MERGE": 3, } )
Enum value maps for PartitioningPolicy_AutoPartitioningPolicy.
var ( ValueSinceUnixEpochModeSettings_Unit_name = map[int32]string{ 0: "UNIT_UNSPECIFIED", 1: "UNIT_SECONDS", 2: "UNIT_MILLISECONDS", 3: "UNIT_MICROSECONDS", 4: "UNIT_NANOSECONDS", } ValueSinceUnixEpochModeSettings_Unit_value = map[string]int32{ "UNIT_UNSPECIFIED": 0, "UNIT_SECONDS": 1, "UNIT_MILLISECONDS": 2, "UNIT_MICROSECONDS": 3, "UNIT_NANOSECONDS": 4, } )
Enum value maps for ValueSinceUnixEpochModeSettings_Unit.
var ( ColumnFamily_Compression_name = map[int32]string{ 0: "COMPRESSION_UNSPECIFIED", 1: "COMPRESSION_NONE", 2: "COMPRESSION_LZ4", } ColumnFamily_Compression_value = map[string]int32{ "COMPRESSION_UNSPECIFIED": 0, "COMPRESSION_NONE": 1, "COMPRESSION_LZ4": 2, } )
Enum value maps for ColumnFamily_Compression.
var ( QueryStatsCollection_Mode_name = map[int32]string{ 0: "STATS_COLLECTION_UNSPECIFIED", 1: "STATS_COLLECTION_NONE", 2: "STATS_COLLECTION_BASIC", 3: "STATS_COLLECTION_FULL", 4: "STATS_COLLECTION_PROFILE", } QueryStatsCollection_Mode_value = map[string]int32{ "STATS_COLLECTION_UNSPECIFIED": 0, "STATS_COLLECTION_NONE": 1, "STATS_COLLECTION_BASIC": 2, "STATS_COLLECTION_FULL": 3, "STATS_COLLECTION_PROFILE": 4, } )
Enum value maps for QueryStatsCollection_Mode.
var ( KeepAliveResult_SessionStatus_name = map[int32]string{ 0: "SESSION_STATUS_UNSPECIFIED", 1: "SESSION_STATUS_READY", 2: "SESSION_STATUS_BUSY", } KeepAliveResult_SessionStatus_value = map[string]int32{ "SESSION_STATUS_UNSPECIFIED": 0, "SESSION_STATUS_READY": 1, "SESSION_STATUS_BUSY": 2, } )
Enum value maps for KeepAliveResult_SessionStatus.
var ( ExecuteScanQueryRequest_Mode_name = map[int32]string{ 0: "MODE_UNSPECIFIED", 1: "MODE_EXPLAIN", 3: "MODE_EXEC", } ExecuteScanQueryRequest_Mode_value = map[string]int32{ "MODE_UNSPECIFIED": 0, "MODE_EXPLAIN": 1, "MODE_EXEC": 3, } )
Enum value maps for ExecuteScanQueryRequest_Mode.
var File_protos_ydb_table_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type AlterTableRequest ¶
type AlterTableRequest struct { // Session identifier SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` // Full path Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` // Columns (name, type) to add AddColumns []*ColumnMeta `protobuf:"bytes,3,rep,name=add_columns,json=addColumns,proto3" json:"add_columns,omitempty"` // Columns to remove DropColumns []string `protobuf:"bytes,4,rep,name=drop_columns,json=dropColumns,proto3" json:"drop_columns,omitempty"` OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,5,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"` // Columns to alter AlterColumns []*ColumnMeta `protobuf:"bytes,6,rep,name=alter_columns,json=alterColumns,proto3" json:"alter_columns,omitempty"` // Setup or remove time to live settings // // Types that are assignable to TtlAction: // // *AlterTableRequest_SetTtlSettings // *AlterTableRequest_DropTtlSettings TtlAction isAlterTableRequest_TtlAction `protobuf_oneof:"ttl_action"` // Add secondary indexes AddIndexes []*TableIndex `protobuf:"bytes,9,rep,name=add_indexes,json=addIndexes,proto3" json:"add_indexes,omitempty"` // Remove secondary indexes DropIndexes []string `protobuf:"bytes,10,rep,name=drop_indexes,json=dropIndexes,proto3" json:"drop_indexes,omitempty"` // Change table storage settings AlterStorageSettings *StorageSettings `protobuf:"bytes,11,opt,name=alter_storage_settings,json=alterStorageSettings,proto3" json:"alter_storage_settings,omitempty"` // Add/alter column families AddColumnFamilies []*ColumnFamily `protobuf:"bytes,12,rep,name=add_column_families,json=addColumnFamilies,proto3" json:"add_column_families,omitempty"` AlterColumnFamilies []*ColumnFamily `protobuf:"bytes,13,rep,name=alter_column_families,json=alterColumnFamilies,proto3" json:"alter_column_families,omitempty"` // Alter attributes. Leave the value blank to drop an attribute. // Cannot be used in combination with other fields (except session_id and path) at the moment. AlterAttributes map[string]string `` /* 195-byte string literal not displayed */ // Set predefined named set of settings for table compaction ["default", "small_table", "log_table"]. // Set "default" to use default preset. SetCompactionPolicy string `protobuf:"bytes,15,opt,name=set_compaction_policy,json=setCompactionPolicy,proto3" json:"set_compaction_policy,omitempty"` // Change table partitioning settings AlterPartitioningSettings *PartitioningSettings `` /* 139-byte string literal not displayed */ // Enable/disable bloom filter by key SetKeyBloomFilter Ydb.FeatureFlag_Status `` /* 146-byte string literal not displayed */ // Set read replicas settings for table SetReadReplicasSettings *ReadReplicasSettings `` /* 135-byte string literal not displayed */ // Add change feeds AddChangefeeds []*Changefeed `protobuf:"bytes,19,rep,name=add_changefeeds,json=addChangefeeds,proto3" json:"add_changefeeds,omitempty"` // Remove change feeds (by its names) DropChangefeeds []string `protobuf:"bytes,20,rep,name=drop_changefeeds,json=dropChangefeeds,proto3" json:"drop_changefeeds,omitempty"` // Rename existed index RenameIndexes []*RenameIndexItem `protobuf:"bytes,21,rep,name=rename_indexes,json=renameIndexes,proto3" json:"rename_indexes,omitempty"` // Setup or remove tiering // // Types that are assignable to TieringAction: // // *AlterTableRequest_SetTiering // *AlterTableRequest_DropTiering TieringAction isAlterTableRequest_TieringAction `protobuf_oneof:"tiering_action"` // contains filtered or unexported fields }
Alter table with given path
func (*AlterTableRequest) Descriptor
deprecated
func (*AlterTableRequest) Descriptor() ([]byte, []int)
Deprecated: Use AlterTableRequest.ProtoReflect.Descriptor instead.
func (*AlterTableRequest) GetAddChangefeeds ¶
func (x *AlterTableRequest) GetAddChangefeeds() []*Changefeed
func (*AlterTableRequest) GetAddColumnFamilies ¶
func (x *AlterTableRequest) GetAddColumnFamilies() []*ColumnFamily
func (*AlterTableRequest) GetAddColumns ¶
func (x *AlterTableRequest) GetAddColumns() []*ColumnMeta
func (*AlterTableRequest) GetAddIndexes ¶
func (x *AlterTableRequest) GetAddIndexes() []*TableIndex
func (*AlterTableRequest) GetAlterAttributes ¶
func (x *AlterTableRequest) GetAlterAttributes() map[string]string
func (*AlterTableRequest) GetAlterColumnFamilies ¶
func (x *AlterTableRequest) GetAlterColumnFamilies() []*ColumnFamily
func (*AlterTableRequest) GetAlterColumns ¶
func (x *AlterTableRequest) GetAlterColumns() []*ColumnMeta
func (*AlterTableRequest) GetAlterPartitioningSettings ¶
func (x *AlterTableRequest) GetAlterPartitioningSettings() *PartitioningSettings
func (*AlterTableRequest) GetAlterStorageSettings ¶
func (x *AlterTableRequest) GetAlterStorageSettings() *StorageSettings
func (*AlterTableRequest) GetDropChangefeeds ¶
func (x *AlterTableRequest) GetDropChangefeeds() []string
func (*AlterTableRequest) GetDropColumns ¶
func (x *AlterTableRequest) GetDropColumns() []string
func (*AlterTableRequest) GetDropIndexes ¶
func (x *AlterTableRequest) GetDropIndexes() []string
func (*AlterTableRequest) GetDropTiering ¶
func (x *AlterTableRequest) GetDropTiering() *emptypb.Empty
func (*AlterTableRequest) GetDropTtlSettings ¶
func (x *AlterTableRequest) GetDropTtlSettings() *emptypb.Empty
func (*AlterTableRequest) GetOperationParams ¶
func (x *AlterTableRequest) GetOperationParams() *Ydb_Operations.OperationParams
func (*AlterTableRequest) GetPath ¶
func (x *AlterTableRequest) GetPath() string
func (*AlterTableRequest) GetRenameIndexes ¶
func (x *AlterTableRequest) GetRenameIndexes() []*RenameIndexItem
func (*AlterTableRequest) GetSessionId ¶
func (x *AlterTableRequest) GetSessionId() string
func (*AlterTableRequest) GetSetCompactionPolicy ¶
func (x *AlterTableRequest) GetSetCompactionPolicy() string
func (*AlterTableRequest) GetSetKeyBloomFilter ¶
func (x *AlterTableRequest) GetSetKeyBloomFilter() Ydb.FeatureFlag_Status
func (*AlterTableRequest) GetSetReadReplicasSettings ¶
func (x *AlterTableRequest) GetSetReadReplicasSettings() *ReadReplicasSettings
func (*AlterTableRequest) GetSetTiering ¶
func (x *AlterTableRequest) GetSetTiering() string
func (*AlterTableRequest) GetSetTtlSettings ¶
func (x *AlterTableRequest) GetSetTtlSettings() *TtlSettings
func (*AlterTableRequest) GetTieringAction ¶
func (m *AlterTableRequest) GetTieringAction() isAlterTableRequest_TieringAction
func (*AlterTableRequest) GetTtlAction ¶
func (m *AlterTableRequest) GetTtlAction() isAlterTableRequest_TtlAction
func (*AlterTableRequest) ProtoMessage ¶
func (*AlterTableRequest) ProtoMessage()
func (*AlterTableRequest) ProtoReflect ¶
func (x *AlterTableRequest) ProtoReflect() protoreflect.Message
func (*AlterTableRequest) Reset ¶
func (x *AlterTableRequest) Reset()
func (*AlterTableRequest) String ¶
func (x *AlterTableRequest) String() string
type AlterTableRequest_SetTiering ¶
type AlterTableRequest_SetTiering struct {
SetTiering string `protobuf:"bytes,22,opt,name=set_tiering,json=setTiering,proto3,oneof"`
}
type AlterTableRequest_SetTtlSettings ¶
type AlterTableRequest_SetTtlSettings struct {
SetTtlSettings *TtlSettings `protobuf:"bytes,7,opt,name=set_ttl_settings,json=setTtlSettings,proto3,oneof"`
}
type AlterTableResponse ¶
type AlterTableResponse struct { Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // contains filtered or unexported fields }
func (*AlterTableResponse) Descriptor
deprecated
func (*AlterTableResponse) Descriptor() ([]byte, []int)
Deprecated: Use AlterTableResponse.ProtoReflect.Descriptor instead.
func (*AlterTableResponse) GetOperation ¶
func (x *AlterTableResponse) GetOperation() *Ydb_Operations.Operation
func (*AlterTableResponse) ProtoMessage ¶
func (*AlterTableResponse) ProtoMessage()
func (*AlterTableResponse) ProtoReflect ¶
func (x *AlterTableResponse) ProtoReflect() protoreflect.Message
func (*AlterTableResponse) Reset ¶
func (x *AlterTableResponse) Reset()
func (*AlterTableResponse) String ¶
func (x *AlterTableResponse) String() string
type AzReadReplicasSettings ¶
type AzReadReplicasSettings struct { // AZ name Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Read replicas count in this AZ ReadReplicasCount uint64 `protobuf:"varint,2,opt,name=read_replicas_count,json=readReplicasCount,proto3" json:"read_replicas_count,omitempty"` // contains filtered or unexported fields }
func (*AzReadReplicasSettings) Descriptor
deprecated
func (*AzReadReplicasSettings) Descriptor() ([]byte, []int)
Deprecated: Use AzReadReplicasSettings.ProtoReflect.Descriptor instead.
func (*AzReadReplicasSettings) GetName ¶
func (x *AzReadReplicasSettings) GetName() string
func (*AzReadReplicasSettings) GetReadReplicasCount ¶
func (x *AzReadReplicasSettings) GetReadReplicasCount() uint64
func (*AzReadReplicasSettings) ProtoMessage ¶
func (*AzReadReplicasSettings) ProtoMessage()
func (*AzReadReplicasSettings) ProtoReflect ¶
func (x *AzReadReplicasSettings) ProtoReflect() protoreflect.Message
func (*AzReadReplicasSettings) Reset ¶
func (x *AzReadReplicasSettings) Reset()
func (*AzReadReplicasSettings) String ¶
func (x *AzReadReplicasSettings) String() string
type BeginTransactionRequest ¶
type BeginTransactionRequest struct { // Session identifier SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` TxSettings *TransactionSettings `protobuf:"bytes,2,opt,name=tx_settings,json=txSettings,proto3" json:"tx_settings,omitempty"` OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,3,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"` // contains filtered or unexported fields }
Begin transaction on given session with given settings
func (*BeginTransactionRequest) Descriptor
deprecated
func (*BeginTransactionRequest) Descriptor() ([]byte, []int)
Deprecated: Use BeginTransactionRequest.ProtoReflect.Descriptor instead.
func (*BeginTransactionRequest) GetOperationParams ¶
func (x *BeginTransactionRequest) GetOperationParams() *Ydb_Operations.OperationParams
func (*BeginTransactionRequest) GetSessionId ¶
func (x *BeginTransactionRequest) GetSessionId() string
func (*BeginTransactionRequest) GetTxSettings ¶
func (x *BeginTransactionRequest) GetTxSettings() *TransactionSettings
func (*BeginTransactionRequest) ProtoMessage ¶
func (*BeginTransactionRequest) ProtoMessage()
func (*BeginTransactionRequest) ProtoReflect ¶
func (x *BeginTransactionRequest) ProtoReflect() protoreflect.Message
func (*BeginTransactionRequest) Reset ¶
func (x *BeginTransactionRequest) Reset()
func (*BeginTransactionRequest) String ¶
func (x *BeginTransactionRequest) String() string
type BeginTransactionResponse ¶
type BeginTransactionResponse struct { // Holds BeginTransactionResult in case of successful call Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // contains filtered or unexported fields }
func (*BeginTransactionResponse) Descriptor
deprecated
func (*BeginTransactionResponse) Descriptor() ([]byte, []int)
Deprecated: Use BeginTransactionResponse.ProtoReflect.Descriptor instead.
func (*BeginTransactionResponse) GetOperation ¶
func (x *BeginTransactionResponse) GetOperation() *Ydb_Operations.Operation
func (*BeginTransactionResponse) ProtoMessage ¶
func (*BeginTransactionResponse) ProtoMessage()
func (*BeginTransactionResponse) ProtoReflect ¶
func (x *BeginTransactionResponse) ProtoReflect() protoreflect.Message
func (*BeginTransactionResponse) Reset ¶
func (x *BeginTransactionResponse) Reset()
func (*BeginTransactionResponse) String ¶
func (x *BeginTransactionResponse) String() string
type BeginTransactionResult ¶
type BeginTransactionResult struct { TxMeta *TransactionMeta `protobuf:"bytes,1,opt,name=tx_meta,json=txMeta,proto3" json:"tx_meta,omitempty"` // contains filtered or unexported fields }
func (*BeginTransactionResult) Descriptor
deprecated
func (*BeginTransactionResult) Descriptor() ([]byte, []int)
Deprecated: Use BeginTransactionResult.ProtoReflect.Descriptor instead.
func (*BeginTransactionResult) GetTxMeta ¶
func (x *BeginTransactionResult) GetTxMeta() *TransactionMeta
func (*BeginTransactionResult) ProtoMessage ¶
func (*BeginTransactionResult) ProtoMessage()
func (*BeginTransactionResult) ProtoReflect ¶
func (x *BeginTransactionResult) ProtoReflect() protoreflect.Message
func (*BeginTransactionResult) Reset ¶
func (x *BeginTransactionResult) Reset()
func (*BeginTransactionResult) String ¶
func (x *BeginTransactionResult) String() string
type BulkUpsertRequest ¶
type BulkUpsertRequest struct { Table string `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"` // "rows" parameter must be a list of structs where each stuct represents one row. // It must contain all key columns but not necessarily all non-key columns. // Similar to UPSERT statement only values of specified columns will be updated. Rows *Ydb.TypedValue `protobuf:"bytes,2,opt,name=rows,proto3" json:"rows,omitempty"` OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,3,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"` // You may set data_format + data instead of rows to insert data in serialized formats. // // Types that are assignable to DataFormat: // // *BulkUpsertRequest_ArrowBatchSettings // *BulkUpsertRequest_CsvSettings DataFormat isBulkUpsertRequest_DataFormat `protobuf_oneof:"data_format"` // It's last in the definition to help with sidecar patterns Data []byte `protobuf:"bytes,1000,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*BulkUpsertRequest) Descriptor
deprecated
func (*BulkUpsertRequest) Descriptor() ([]byte, []int)
Deprecated: Use BulkUpsertRequest.ProtoReflect.Descriptor instead.
func (*BulkUpsertRequest) GetArrowBatchSettings ¶
func (x *BulkUpsertRequest) GetArrowBatchSettings() *Ydb_Formats.ArrowBatchSettings
func (*BulkUpsertRequest) GetCsvSettings ¶
func (x *BulkUpsertRequest) GetCsvSettings() *Ydb_Formats.CsvSettings
func (*BulkUpsertRequest) GetData ¶
func (x *BulkUpsertRequest) GetData() []byte
func (*BulkUpsertRequest) GetDataFormat ¶
func (m *BulkUpsertRequest) GetDataFormat() isBulkUpsertRequest_DataFormat
func (*BulkUpsertRequest) GetOperationParams ¶
func (x *BulkUpsertRequest) GetOperationParams() *Ydb_Operations.OperationParams
func (*BulkUpsertRequest) GetRows ¶
func (x *BulkUpsertRequest) GetRows() *Ydb.TypedValue
func (*BulkUpsertRequest) GetTable ¶
func (x *BulkUpsertRequest) GetTable() string
func (*BulkUpsertRequest) ProtoMessage ¶
func (*BulkUpsertRequest) ProtoMessage()
func (*BulkUpsertRequest) ProtoReflect ¶
func (x *BulkUpsertRequest) ProtoReflect() protoreflect.Message
func (*BulkUpsertRequest) Reset ¶
func (x *BulkUpsertRequest) Reset()
func (*BulkUpsertRequest) String ¶
func (x *BulkUpsertRequest) String() string
type BulkUpsertRequest_ArrowBatchSettings ¶
type BulkUpsertRequest_ArrowBatchSettings struct {
ArrowBatchSettings *Ydb_Formats.ArrowBatchSettings `protobuf:"bytes,7,opt,name=arrow_batch_settings,json=arrowBatchSettings,proto3,oneof"`
}
type BulkUpsertRequest_CsvSettings ¶
type BulkUpsertRequest_CsvSettings struct {
CsvSettings *Ydb_Formats.CsvSettings `protobuf:"bytes,8,opt,name=csv_settings,json=csvSettings,proto3,oneof"`
}
type BulkUpsertResponse ¶
type BulkUpsertResponse struct { Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // contains filtered or unexported fields }
func (*BulkUpsertResponse) Descriptor
deprecated
func (*BulkUpsertResponse) Descriptor() ([]byte, []int)
Deprecated: Use BulkUpsertResponse.ProtoReflect.Descriptor instead.
func (*BulkUpsertResponse) GetOperation ¶
func (x *BulkUpsertResponse) GetOperation() *Ydb_Operations.Operation
func (*BulkUpsertResponse) ProtoMessage ¶
func (*BulkUpsertResponse) ProtoMessage()
func (*BulkUpsertResponse) ProtoReflect ¶
func (x *BulkUpsertResponse) ProtoReflect() protoreflect.Message
func (*BulkUpsertResponse) Reset ¶
func (x *BulkUpsertResponse) Reset()
func (*BulkUpsertResponse) String ¶
func (x *BulkUpsertResponse) String() string
type BulkUpsertResult ¶
type BulkUpsertResult struct {
// contains filtered or unexported fields
}
func (*BulkUpsertResult) Descriptor
deprecated
func (*BulkUpsertResult) Descriptor() ([]byte, []int)
Deprecated: Use BulkUpsertResult.ProtoReflect.Descriptor instead.
func (*BulkUpsertResult) ProtoMessage ¶
func (*BulkUpsertResult) ProtoMessage()
func (*BulkUpsertResult) ProtoReflect ¶
func (x *BulkUpsertResult) ProtoReflect() protoreflect.Message
func (*BulkUpsertResult) Reset ¶
func (x *BulkUpsertResult) Reset()
func (*BulkUpsertResult) String ¶
func (x *BulkUpsertResult) String() string
type CachingPolicy ¶
type CachingPolicy struct { PresetName string `protobuf:"bytes,1,opt,name=preset_name,json=presetName,proto3" json:"preset_name,omitempty"` // contains filtered or unexported fields }
func (*CachingPolicy) Descriptor
deprecated
func (*CachingPolicy) Descriptor() ([]byte, []int)
Deprecated: Use CachingPolicy.ProtoReflect.Descriptor instead.
func (*CachingPolicy) GetPresetName ¶
func (x *CachingPolicy) GetPresetName() string
func (*CachingPolicy) ProtoMessage ¶
func (*CachingPolicy) ProtoMessage()
func (*CachingPolicy) ProtoReflect ¶
func (x *CachingPolicy) ProtoReflect() protoreflect.Message
func (*CachingPolicy) Reset ¶
func (x *CachingPolicy) Reset()
func (*CachingPolicy) String ¶
func (x *CachingPolicy) String() string
type CachingPolicyDescription ¶
type CachingPolicyDescription struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Labels map[string]string `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
func (*CachingPolicyDescription) Descriptor
deprecated
func (*CachingPolicyDescription) Descriptor() ([]byte, []int)
Deprecated: Use CachingPolicyDescription.ProtoReflect.Descriptor instead.
func (*CachingPolicyDescription) GetLabels ¶
func (x *CachingPolicyDescription) GetLabels() map[string]string
func (*CachingPolicyDescription) GetName ¶
func (x *CachingPolicyDescription) GetName() string
func (*CachingPolicyDescription) ProtoMessage ¶
func (*CachingPolicyDescription) ProtoMessage()
func (*CachingPolicyDescription) ProtoReflect ¶
func (x *CachingPolicyDescription) ProtoReflect() protoreflect.Message
func (*CachingPolicyDescription) Reset ¶
func (x *CachingPolicyDescription) Reset()
func (*CachingPolicyDescription) String ¶
func (x *CachingPolicyDescription) String() string
type Changefeed ¶
type Changefeed struct { // Name of the feed Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Mode specifies the information that will be written to the feed Mode ChangefeedMode_Mode `protobuf:"varint,2,opt,name=mode,proto3,enum=Ydb.Table.ChangefeedMode_Mode" json:"mode,omitempty"` // Format of the data Format ChangefeedFormat_Format `protobuf:"varint,3,opt,name=format,proto3,enum=Ydb.Table.ChangefeedFormat_Format" json:"format,omitempty"` // How long data in changefeed's underlying topic should be stored RetentionPeriod *durationpb.Duration `protobuf:"bytes,4,opt,name=retention_period,json=retentionPeriod,proto3" json:"retention_period,omitempty"` // Emit virtual timestamps of changes along with data or not VirtualTimestamps bool `protobuf:"varint,5,opt,name=virtual_timestamps,json=virtualTimestamps,proto3" json:"virtual_timestamps,omitempty"` // Initial scan will output the current state of the table first InitialScan bool `protobuf:"varint,6,opt,name=initial_scan,json=initialScan,proto3" json:"initial_scan,omitempty"` // Attributes. Total size is limited to 10 KB. Attributes map[string]string `` /* 161-byte string literal not displayed */ // Value that will be emitted in the `awsRegion` field of the record in DYNAMODB_STREAMS_JSON format AwsRegion string `protobuf:"bytes,8,opt,name=aws_region,json=awsRegion,proto3" json:"aws_region,omitempty"` // Periodically emit resolved timestamps. If unspecified, resolved timestamps are not emitted. ResolvedTimestampsInterval *durationpb.Duration `` /* 141-byte string literal not displayed */ // Partitioning settings of underlying topic. TopicPartitioningSettings *Ydb_Topic.PartitioningSettings `` /* 139-byte string literal not displayed */ // contains filtered or unexported fields }
func (*Changefeed) Descriptor
deprecated
func (*Changefeed) Descriptor() ([]byte, []int)
Deprecated: Use Changefeed.ProtoReflect.Descriptor instead.
func (*Changefeed) GetAttributes ¶
func (x *Changefeed) GetAttributes() map[string]string
func (*Changefeed) GetAwsRegion ¶
func (x *Changefeed) GetAwsRegion() string
func (*Changefeed) GetFormat ¶
func (x *Changefeed) GetFormat() ChangefeedFormat_Format
func (*Changefeed) GetInitialScan ¶
func (x *Changefeed) GetInitialScan() bool
func (*Changefeed) GetMode ¶
func (x *Changefeed) GetMode() ChangefeedMode_Mode
func (*Changefeed) GetName ¶
func (x *Changefeed) GetName() string
func (*Changefeed) GetResolvedTimestampsInterval ¶
func (x *Changefeed) GetResolvedTimestampsInterval() *durationpb.Duration
func (*Changefeed) GetRetentionPeriod ¶
func (x *Changefeed) GetRetentionPeriod() *durationpb.Duration
func (*Changefeed) GetTopicPartitioningSettings ¶
func (x *Changefeed) GetTopicPartitioningSettings() *Ydb_Topic.PartitioningSettings
func (*Changefeed) GetVirtualTimestamps ¶
func (x *Changefeed) GetVirtualTimestamps() bool
func (*Changefeed) ProtoMessage ¶
func (*Changefeed) ProtoMessage()
func (*Changefeed) ProtoReflect ¶
func (x *Changefeed) ProtoReflect() protoreflect.Message
func (*Changefeed) Reset ¶
func (x *Changefeed) Reset()
func (*Changefeed) String ¶
func (x *Changefeed) String() string
type ChangefeedDescription ¶
type ChangefeedDescription struct { // Name of the feed Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Mode specifies the information that will be written to the feed Mode ChangefeedMode_Mode `protobuf:"varint,2,opt,name=mode,proto3,enum=Ydb.Table.ChangefeedMode_Mode" json:"mode,omitempty"` // Format of the data Format ChangefeedFormat_Format `protobuf:"varint,3,opt,name=format,proto3,enum=Ydb.Table.ChangefeedFormat_Format" json:"format,omitempty"` // State of the feed State ChangefeedDescription_State `protobuf:"varint,4,opt,name=state,proto3,enum=Ydb.Table.ChangefeedDescription_State" json:"state,omitempty"` // State of emitting of virtual timestamps along with data VirtualTimestamps bool `protobuf:"varint,5,opt,name=virtual_timestamps,json=virtualTimestamps,proto3" json:"virtual_timestamps,omitempty"` // Attributes Attributes map[string]string `` /* 161-byte string literal not displayed */ // Value that will be emitted in the `awsRegion` field of the record in DYNAMODB_STREAMS_JSON format AwsRegion string `protobuf:"bytes,7,opt,name=aws_region,json=awsRegion,proto3" json:"aws_region,omitempty"` // Interval of emitting of resolved timestamps. If unspecified, resolved timestamps are not emitted. ResolvedTimestampsInterval *durationpb.Duration `` /* 141-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ChangefeedDescription) Descriptor
deprecated
func (*ChangefeedDescription) Descriptor() ([]byte, []int)
Deprecated: Use ChangefeedDescription.ProtoReflect.Descriptor instead.
func (*ChangefeedDescription) GetAttributes ¶
func (x *ChangefeedDescription) GetAttributes() map[string]string
func (*ChangefeedDescription) GetAwsRegion ¶
func (x *ChangefeedDescription) GetAwsRegion() string
func (*ChangefeedDescription) GetFormat ¶
func (x *ChangefeedDescription) GetFormat() ChangefeedFormat_Format
func (*ChangefeedDescription) GetMode ¶
func (x *ChangefeedDescription) GetMode() ChangefeedMode_Mode
func (*ChangefeedDescription) GetName ¶
func (x *ChangefeedDescription) GetName() string
func (*ChangefeedDescription) GetResolvedTimestampsInterval ¶
func (x *ChangefeedDescription) GetResolvedTimestampsInterval() *durationpb.Duration
func (*ChangefeedDescription) GetState ¶
func (x *ChangefeedDescription) GetState() ChangefeedDescription_State
func (*ChangefeedDescription) GetVirtualTimestamps ¶
func (x *ChangefeedDescription) GetVirtualTimestamps() bool
func (*ChangefeedDescription) ProtoMessage ¶
func (*ChangefeedDescription) ProtoMessage()
func (*ChangefeedDescription) ProtoReflect ¶
func (x *ChangefeedDescription) ProtoReflect() protoreflect.Message
func (*ChangefeedDescription) Reset ¶
func (x *ChangefeedDescription) Reset()
func (*ChangefeedDescription) String ¶
func (x *ChangefeedDescription) String() string
type ChangefeedDescription_State ¶
type ChangefeedDescription_State int32
const ( ChangefeedDescription_STATE_UNSPECIFIED ChangefeedDescription_State = 0 // Normal state, from this state changefeed can be disabled ChangefeedDescription_STATE_ENABLED ChangefeedDescription_State = 1 // No new change records are generated, but the old ones remain available // From this state changefeed cannot be switched to any other state ChangefeedDescription_STATE_DISABLED ChangefeedDescription_State = 2 // An initial scan is being performed. // After its completion changefeed will switch to the normal state ChangefeedDescription_STATE_INITIAL_SCAN ChangefeedDescription_State = 3 )
func (ChangefeedDescription_State) Descriptor ¶
func (ChangefeedDescription_State) Descriptor() protoreflect.EnumDescriptor
func (ChangefeedDescription_State) Enum ¶
func (x ChangefeedDescription_State) Enum() *ChangefeedDescription_State
func (ChangefeedDescription_State) EnumDescriptor
deprecated
func (ChangefeedDescription_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use ChangefeedDescription_State.Descriptor instead.
func (ChangefeedDescription_State) Number ¶
func (x ChangefeedDescription_State) Number() protoreflect.EnumNumber
func (ChangefeedDescription_State) String ¶
func (x ChangefeedDescription_State) String() string
func (ChangefeedDescription_State) Type ¶
func (ChangefeedDescription_State) Type() protoreflect.EnumType
type ChangefeedFormat ¶
type ChangefeedFormat struct {
// contains filtered or unexported fields
}
func (*ChangefeedFormat) Descriptor
deprecated
func (*ChangefeedFormat) Descriptor() ([]byte, []int)
Deprecated: Use ChangefeedFormat.ProtoReflect.Descriptor instead.
func (*ChangefeedFormat) ProtoMessage ¶
func (*ChangefeedFormat) ProtoMessage()
func (*ChangefeedFormat) ProtoReflect ¶
func (x *ChangefeedFormat) ProtoReflect() protoreflect.Message
func (*ChangefeedFormat) Reset ¶
func (x *ChangefeedFormat) Reset()
func (*ChangefeedFormat) String ¶
func (x *ChangefeedFormat) String() string
type ChangefeedFormat_Format ¶
type ChangefeedFormat_Format int32
const ( ChangefeedFormat_FORMAT_UNSPECIFIED ChangefeedFormat_Format = 0 // Change record in JSON format for common (row oriented) tables ChangefeedFormat_FORMAT_JSON ChangefeedFormat_Format = 1 // Change record in JSON format for document (DynamoDB-compatible) tables ChangefeedFormat_FORMAT_DYNAMODB_STREAMS_JSON ChangefeedFormat_Format = 2 // Debezium-like change record JSON format for common (row oriented) tables ChangefeedFormat_FORMAT_DEBEZIUM_JSON ChangefeedFormat_Format = 3 )
func (ChangefeedFormat_Format) Descriptor ¶
func (ChangefeedFormat_Format) Descriptor() protoreflect.EnumDescriptor
func (ChangefeedFormat_Format) Enum ¶
func (x ChangefeedFormat_Format) Enum() *ChangefeedFormat_Format
func (ChangefeedFormat_Format) EnumDescriptor
deprecated
func (ChangefeedFormat_Format) EnumDescriptor() ([]byte, []int)
Deprecated: Use ChangefeedFormat_Format.Descriptor instead.
func (ChangefeedFormat_Format) Number ¶
func (x ChangefeedFormat_Format) Number() protoreflect.EnumNumber
func (ChangefeedFormat_Format) String ¶
func (x ChangefeedFormat_Format) String() string
func (ChangefeedFormat_Format) Type ¶
func (ChangefeedFormat_Format) Type() protoreflect.EnumType
type ChangefeedMode ¶
type ChangefeedMode struct {
// contains filtered or unexported fields
}
func (*ChangefeedMode) Descriptor
deprecated
func (*ChangefeedMode) Descriptor() ([]byte, []int)
Deprecated: Use ChangefeedMode.ProtoReflect.Descriptor instead.
func (*ChangefeedMode) ProtoMessage ¶
func (*ChangefeedMode) ProtoMessage()
func (*ChangefeedMode) ProtoReflect ¶
func (x *ChangefeedMode) ProtoReflect() protoreflect.Message
func (*ChangefeedMode) Reset ¶
func (x *ChangefeedMode) Reset()
func (*ChangefeedMode) String ¶
func (x *ChangefeedMode) String() string
type ChangefeedMode_Mode ¶
type ChangefeedMode_Mode int32
const ( ChangefeedMode_MODE_UNSPECIFIED ChangefeedMode_Mode = 0 // Only the key component of the modified row ChangefeedMode_MODE_KEYS_ONLY ChangefeedMode_Mode = 1 // Updated columns ChangefeedMode_MODE_UPDATES ChangefeedMode_Mode = 2 // The entire row, as it appears after it was modified ChangefeedMode_MODE_NEW_IMAGE ChangefeedMode_Mode = 3 // The entire row, as it appeared before it was modified ChangefeedMode_MODE_OLD_IMAGE ChangefeedMode_Mode = 4 // Both new and old images of the row ChangefeedMode_MODE_NEW_AND_OLD_IMAGES ChangefeedMode_Mode = 5 )
func (ChangefeedMode_Mode) Descriptor ¶
func (ChangefeedMode_Mode) Descriptor() protoreflect.EnumDescriptor
func (ChangefeedMode_Mode) Enum ¶
func (x ChangefeedMode_Mode) Enum() *ChangefeedMode_Mode
func (ChangefeedMode_Mode) EnumDescriptor
deprecated
func (ChangefeedMode_Mode) EnumDescriptor() ([]byte, []int)
Deprecated: Use ChangefeedMode_Mode.Descriptor instead.
func (ChangefeedMode_Mode) Number ¶
func (x ChangefeedMode_Mode) Number() protoreflect.EnumNumber
func (ChangefeedMode_Mode) String ¶
func (x ChangefeedMode_Mode) String() string
func (ChangefeedMode_Mode) Type ¶
func (ChangefeedMode_Mode) Type() protoreflect.EnumType
type ClusterReplicasSettings ¶
type ClusterReplicasSettings struct { // List of read replicas settings for each AZ AzReadReplicasSettings []*AzReadReplicasSettings `` /* 131-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ClusterReplicasSettings) Descriptor
deprecated
func (*ClusterReplicasSettings) Descriptor() ([]byte, []int)
Deprecated: Use ClusterReplicasSettings.ProtoReflect.Descriptor instead.
func (*ClusterReplicasSettings) GetAzReadReplicasSettings ¶
func (x *ClusterReplicasSettings) GetAzReadReplicasSettings() []*AzReadReplicasSettings
func (*ClusterReplicasSettings) ProtoMessage ¶
func (*ClusterReplicasSettings) ProtoMessage()
func (*ClusterReplicasSettings) ProtoReflect ¶
func (x *ClusterReplicasSettings) ProtoReflect() protoreflect.Message
func (*ClusterReplicasSettings) Reset ¶
func (x *ClusterReplicasSettings) Reset()
func (*ClusterReplicasSettings) String ¶
func (x *ClusterReplicasSettings) String() string
type ColumnFamily ¶
type ColumnFamily struct { // Name of the column family, the name "default" must be used for the // primary column family that contains at least primary key columns Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // This specifies data storage settings for column family Data *StoragePool `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // Optionally specify how data should be compressed Compression ColumnFamily_Compression `protobuf:"varint,3,opt,name=compression,proto3,enum=Ydb.Table.ColumnFamily_Compression" json:"compression,omitempty"` // When enabled table data will be kept in memory // WARNING: DO NOT USE KeepInMemory Ydb.FeatureFlag_Status `` /* 128-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ColumnFamily) Descriptor
deprecated
func (*ColumnFamily) Descriptor() ([]byte, []int)
Deprecated: Use ColumnFamily.ProtoReflect.Descriptor instead.
func (*ColumnFamily) GetCompression ¶
func (x *ColumnFamily) GetCompression() ColumnFamily_Compression
func (*ColumnFamily) GetData ¶
func (x *ColumnFamily) GetData() *StoragePool
func (*ColumnFamily) GetKeepInMemory ¶
func (x *ColumnFamily) GetKeepInMemory() Ydb.FeatureFlag_Status
func (*ColumnFamily) GetName ¶
func (x *ColumnFamily) GetName() string
func (*ColumnFamily) ProtoMessage ¶
func (*ColumnFamily) ProtoMessage()
func (*ColumnFamily) ProtoReflect ¶
func (x *ColumnFamily) ProtoReflect() protoreflect.Message
func (*ColumnFamily) Reset ¶
func (x *ColumnFamily) Reset()
func (*ColumnFamily) String ¶
func (x *ColumnFamily) String() string
type ColumnFamilyPolicy ¶
type ColumnFamilyPolicy struct { // Name of the column family, the name "default" must be used for the // primary column family that contains as least primary key columns Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Storage settings for the column group (default to values in storage policy) Data *StoragePool `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` External *StoragePool `protobuf:"bytes,3,opt,name=external,proto3" json:"external,omitempty"` // When enabled table data will be kept in memory // WARNING: DO NOT USE KeepInMemory Ydb.FeatureFlag_Status `` /* 128-byte string literal not displayed */ // Optionally specify whether data should be compressed Compression ColumnFamilyPolicy_Compression `protobuf:"varint,5,opt,name=compression,proto3,enum=Ydb.Table.ColumnFamilyPolicy_Compression" json:"compression,omitempty"` // contains filtered or unexported fields }
func (*ColumnFamilyPolicy) Descriptor
deprecated
func (*ColumnFamilyPolicy) Descriptor() ([]byte, []int)
Deprecated: Use ColumnFamilyPolicy.ProtoReflect.Descriptor instead.
func (*ColumnFamilyPolicy) GetCompression ¶
func (x *ColumnFamilyPolicy) GetCompression() ColumnFamilyPolicy_Compression
func (*ColumnFamilyPolicy) GetData ¶
func (x *ColumnFamilyPolicy) GetData() *StoragePool
func (*ColumnFamilyPolicy) GetExternal ¶
func (x *ColumnFamilyPolicy) GetExternal() *StoragePool
func (*ColumnFamilyPolicy) GetKeepInMemory ¶
func (x *ColumnFamilyPolicy) GetKeepInMemory() Ydb.FeatureFlag_Status
func (*ColumnFamilyPolicy) GetName ¶
func (x *ColumnFamilyPolicy) GetName() string
func (*ColumnFamilyPolicy) ProtoMessage ¶
func (*ColumnFamilyPolicy) ProtoMessage()
func (*ColumnFamilyPolicy) ProtoReflect ¶
func (x *ColumnFamilyPolicy) ProtoReflect() protoreflect.Message
func (*ColumnFamilyPolicy) Reset ¶
func (x *ColumnFamilyPolicy) Reset()
func (*ColumnFamilyPolicy) String ¶
func (x *ColumnFamilyPolicy) String() string
type ColumnFamilyPolicy_Compression ¶
type ColumnFamilyPolicy_Compression int32
const ( ColumnFamilyPolicy_COMPRESSION_UNSPECIFIED ColumnFamilyPolicy_Compression = 0 ColumnFamilyPolicy_UNCOMPRESSED ColumnFamilyPolicy_Compression = 1 ColumnFamilyPolicy_COMPRESSED ColumnFamilyPolicy_Compression = 2 )
func (ColumnFamilyPolicy_Compression) Descriptor ¶
func (ColumnFamilyPolicy_Compression) Descriptor() protoreflect.EnumDescriptor
func (ColumnFamilyPolicy_Compression) Enum ¶
func (x ColumnFamilyPolicy_Compression) Enum() *ColumnFamilyPolicy_Compression
func (ColumnFamilyPolicy_Compression) EnumDescriptor
deprecated
func (ColumnFamilyPolicy_Compression) EnumDescriptor() ([]byte, []int)
Deprecated: Use ColumnFamilyPolicy_Compression.Descriptor instead.
func (ColumnFamilyPolicy_Compression) Number ¶
func (x ColumnFamilyPolicy_Compression) Number() protoreflect.EnumNumber
func (ColumnFamilyPolicy_Compression) String ¶
func (x ColumnFamilyPolicy_Compression) String() string
func (ColumnFamilyPolicy_Compression) Type ¶
func (ColumnFamilyPolicy_Compression) Type() protoreflect.EnumType
type ColumnFamily_Compression ¶
type ColumnFamily_Compression int32
const ( ColumnFamily_COMPRESSION_UNSPECIFIED ColumnFamily_Compression = 0 ColumnFamily_COMPRESSION_NONE ColumnFamily_Compression = 1 ColumnFamily_COMPRESSION_LZ4 ColumnFamily_Compression = 2 )
func (ColumnFamily_Compression) Descriptor ¶
func (ColumnFamily_Compression) Descriptor() protoreflect.EnumDescriptor
func (ColumnFamily_Compression) Enum ¶
func (x ColumnFamily_Compression) Enum() *ColumnFamily_Compression
func (ColumnFamily_Compression) EnumDescriptor
deprecated
func (ColumnFamily_Compression) EnumDescriptor() ([]byte, []int)
Deprecated: Use ColumnFamily_Compression.Descriptor instead.
func (ColumnFamily_Compression) Number ¶
func (x ColumnFamily_Compression) Number() protoreflect.EnumNumber
func (ColumnFamily_Compression) String ¶
func (x ColumnFamily_Compression) String() string
func (ColumnFamily_Compression) Type ¶
func (ColumnFamily_Compression) Type() protoreflect.EnumType
type ColumnMeta ¶
type ColumnMeta struct { // Name of column Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Type of column Type *Ydb.Type `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` // Column family name of the column Family string `protobuf:"bytes,3,opt,name=family,proto3" json:"family,omitempty"` // Column nullability NotNull *bool `protobuf:"varint,4,opt,name=not_null,json=notNull,proto3,oneof" json:"not_null,omitempty"` // Column default value option // // Types that are assignable to DefaultValue: // // *ColumnMeta_FromLiteral // *ColumnMeta_FromSequence DefaultValue isColumnMeta_DefaultValue `protobuf_oneof:"default_value"` // contains filtered or unexported fields }
func (*ColumnMeta) Descriptor
deprecated
func (*ColumnMeta) Descriptor() ([]byte, []int)
Deprecated: Use ColumnMeta.ProtoReflect.Descriptor instead.
func (*ColumnMeta) GetDefaultValue ¶
func (m *ColumnMeta) GetDefaultValue() isColumnMeta_DefaultValue
func (*ColumnMeta) GetFamily ¶
func (x *ColumnMeta) GetFamily() string
func (*ColumnMeta) GetFromLiteral ¶
func (x *ColumnMeta) GetFromLiteral() *Ydb.TypedValue
func (*ColumnMeta) GetFromSequence ¶
func (x *ColumnMeta) GetFromSequence() *SequenceDescription
func (*ColumnMeta) GetName ¶
func (x *ColumnMeta) GetName() string
func (*ColumnMeta) GetNotNull ¶
func (x *ColumnMeta) GetNotNull() bool
func (*ColumnMeta) GetType ¶
func (x *ColumnMeta) GetType() *Ydb.Type
func (*ColumnMeta) ProtoMessage ¶
func (*ColumnMeta) ProtoMessage()
func (*ColumnMeta) ProtoReflect ¶
func (x *ColumnMeta) ProtoReflect() protoreflect.Message
func (*ColumnMeta) Reset ¶
func (x *ColumnMeta) Reset()
func (*ColumnMeta) String ¶
func (x *ColumnMeta) String() string
type ColumnMeta_FromLiteral ¶
type ColumnMeta_FromLiteral struct {
FromLiteral *Ydb.TypedValue `protobuf:"bytes,5,opt,name=from_literal,json=fromLiteral,proto3,oneof"`
}
type ColumnMeta_FromSequence ¶
type ColumnMeta_FromSequence struct {
FromSequence *SequenceDescription `protobuf:"bytes,6,opt,name=from_sequence,json=fromSequence,proto3,oneof"`
}
type CommitTransactionRequest ¶
type CommitTransactionRequest struct { // Session identifier SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` // Transaction identifier TxId string `protobuf:"bytes,2,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"` OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,3,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"` CollectStats QueryStatsCollection_Mode `` /* 139-byte string literal not displayed */ // contains filtered or unexported fields }
Commit transaction with given session and tx id
func (*CommitTransactionRequest) Descriptor
deprecated
func (*CommitTransactionRequest) Descriptor() ([]byte, []int)
Deprecated: Use CommitTransactionRequest.ProtoReflect.Descriptor instead.
func (*CommitTransactionRequest) GetCollectStats ¶
func (x *CommitTransactionRequest) GetCollectStats() QueryStatsCollection_Mode
func (*CommitTransactionRequest) GetOperationParams ¶
func (x *CommitTransactionRequest) GetOperationParams() *Ydb_Operations.OperationParams
func (*CommitTransactionRequest) GetSessionId ¶
func (x *CommitTransactionRequest) GetSessionId() string
func (*CommitTransactionRequest) GetTxId ¶
func (x *CommitTransactionRequest) GetTxId() string
func (*CommitTransactionRequest) ProtoMessage ¶
func (*CommitTransactionRequest) ProtoMessage()
func (*CommitTransactionRequest) ProtoReflect ¶
func (x *CommitTransactionRequest) ProtoReflect() protoreflect.Message
func (*CommitTransactionRequest) Reset ¶
func (x *CommitTransactionRequest) Reset()
func (*CommitTransactionRequest) String ¶
func (x *CommitTransactionRequest) String() string
type CommitTransactionResponse ¶
type CommitTransactionResponse struct { Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // contains filtered or unexported fields }
func (*CommitTransactionResponse) Descriptor
deprecated
func (*CommitTransactionResponse) Descriptor() ([]byte, []int)
Deprecated: Use CommitTransactionResponse.ProtoReflect.Descriptor instead.
func (*CommitTransactionResponse) GetOperation ¶
func (x *CommitTransactionResponse) GetOperation() *Ydb_Operations.Operation
func (*CommitTransactionResponse) ProtoMessage ¶
func (*CommitTransactionResponse) ProtoMessage()
func (*CommitTransactionResponse) ProtoReflect ¶
func (x *CommitTransactionResponse) ProtoReflect() protoreflect.Message
func (*CommitTransactionResponse) Reset ¶
func (x *CommitTransactionResponse) Reset()
func (*CommitTransactionResponse) String ¶
func (x *CommitTransactionResponse) String() string
type CommitTransactionResult ¶
type CommitTransactionResult struct { QueryStats *Ydb_TableStats.QueryStats `protobuf:"bytes,1,opt,name=query_stats,json=queryStats,proto3" json:"query_stats,omitempty"` // contains filtered or unexported fields }
func (*CommitTransactionResult) Descriptor
deprecated
func (*CommitTransactionResult) Descriptor() ([]byte, []int)
Deprecated: Use CommitTransactionResult.ProtoReflect.Descriptor instead.
func (*CommitTransactionResult) GetQueryStats ¶
func (x *CommitTransactionResult) GetQueryStats() *Ydb_TableStats.QueryStats
func (*CommitTransactionResult) ProtoMessage ¶
func (*CommitTransactionResult) ProtoMessage()
func (*CommitTransactionResult) ProtoReflect ¶
func (x *CommitTransactionResult) ProtoReflect() protoreflect.Message
func (*CommitTransactionResult) Reset ¶
func (x *CommitTransactionResult) Reset()
func (*CommitTransactionResult) String ¶
func (x *CommitTransactionResult) String() string
type CompactionPolicy ¶
type CompactionPolicy struct { PresetName string `protobuf:"bytes,1,opt,name=preset_name,json=presetName,proto3" json:"preset_name,omitempty"` // contains filtered or unexported fields }
func (*CompactionPolicy) Descriptor
deprecated
func (*CompactionPolicy) Descriptor() ([]byte, []int)
Deprecated: Use CompactionPolicy.ProtoReflect.Descriptor instead.
func (*CompactionPolicy) GetPresetName ¶
func (x *CompactionPolicy) GetPresetName() string
func (*CompactionPolicy) ProtoMessage ¶
func (*CompactionPolicy) ProtoMessage()
func (*CompactionPolicy) ProtoReflect ¶
func (x *CompactionPolicy) ProtoReflect() protoreflect.Message
func (*CompactionPolicy) Reset ¶
func (x *CompactionPolicy) Reset()
func (*CompactionPolicy) String ¶
func (x *CompactionPolicy) String() string
type CompactionPolicyDescription ¶
type CompactionPolicyDescription struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Labels map[string]string `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
func (*CompactionPolicyDescription) Descriptor
deprecated
func (*CompactionPolicyDescription) Descriptor() ([]byte, []int)
Deprecated: Use CompactionPolicyDescription.ProtoReflect.Descriptor instead.
func (*CompactionPolicyDescription) GetLabels ¶
func (x *CompactionPolicyDescription) GetLabels() map[string]string
func (*CompactionPolicyDescription) GetName ¶
func (x *CompactionPolicyDescription) GetName() string
func (*CompactionPolicyDescription) ProtoMessage ¶
func (*CompactionPolicyDescription) ProtoMessage()
func (*CompactionPolicyDescription) ProtoReflect ¶
func (x *CompactionPolicyDescription) ProtoReflect() protoreflect.Message
func (*CompactionPolicyDescription) Reset ¶
func (x *CompactionPolicyDescription) Reset()
func (*CompactionPolicyDescription) String ¶
func (x *CompactionPolicyDescription) String() string
type CopyTableItem ¶
type CopyTableItem struct { // Copy from path SourcePath string `protobuf:"bytes,1,opt,name=source_path,json=sourcePath,proto3" json:"source_path,omitempty"` // Copy to path DestinationPath string `protobuf:"bytes,2,opt,name=destination_path,json=destinationPath,proto3" json:"destination_path,omitempty"` // Copy options OmitIndexes bool `protobuf:"varint,3,opt,name=omit_indexes,json=omitIndexes,proto3" json:"omit_indexes,omitempty"` // contains filtered or unexported fields }
func (*CopyTableItem) Descriptor
deprecated
func (*CopyTableItem) Descriptor() ([]byte, []int)
Deprecated: Use CopyTableItem.ProtoReflect.Descriptor instead.
func (*CopyTableItem) GetDestinationPath ¶
func (x *CopyTableItem) GetDestinationPath() string
func (*CopyTableItem) GetOmitIndexes ¶
func (x *CopyTableItem) GetOmitIndexes() bool
func (*CopyTableItem) GetSourcePath ¶
func (x *CopyTableItem) GetSourcePath() string
func (*CopyTableItem) ProtoMessage ¶
func (*CopyTableItem) ProtoMessage()
func (*CopyTableItem) ProtoReflect ¶
func (x *CopyTableItem) ProtoReflect() protoreflect.Message
func (*CopyTableItem) Reset ¶
func (x *CopyTableItem) Reset()
func (*CopyTableItem) String ¶
func (x *CopyTableItem) String() string
type CopyTableRequest ¶
type CopyTableRequest struct { // Session identifier SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` // Copy from path SourcePath string `protobuf:"bytes,2,opt,name=source_path,json=sourcePath,proto3" json:"source_path,omitempty"` // Copy to path DestinationPath string `protobuf:"bytes,3,opt,name=destination_path,json=destinationPath,proto3" json:"destination_path,omitempty"` OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,4,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"` // contains filtered or unexported fields }
Copy table with given path
func (*CopyTableRequest) Descriptor
deprecated
func (*CopyTableRequest) Descriptor() ([]byte, []int)
Deprecated: Use CopyTableRequest.ProtoReflect.Descriptor instead.
func (*CopyTableRequest) GetDestinationPath ¶
func (x *CopyTableRequest) GetDestinationPath() string
func (*CopyTableRequest) GetOperationParams ¶
func (x *CopyTableRequest) GetOperationParams() *Ydb_Operations.OperationParams
func (*CopyTableRequest) GetSessionId ¶
func (x *CopyTableRequest) GetSessionId() string
func (*CopyTableRequest) GetSourcePath ¶
func (x *CopyTableRequest) GetSourcePath() string
func (*CopyTableRequest) ProtoMessage ¶
func (*CopyTableRequest) ProtoMessage()
func (*CopyTableRequest) ProtoReflect ¶
func (x *CopyTableRequest) ProtoReflect() protoreflect.Message
func (*CopyTableRequest) Reset ¶
func (x *CopyTableRequest) Reset()
func (*CopyTableRequest) String ¶
func (x *CopyTableRequest) String() string
type CopyTableResponse ¶
type CopyTableResponse struct { Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // contains filtered or unexported fields }
func (*CopyTableResponse) Descriptor
deprecated
func (*CopyTableResponse) Descriptor() ([]byte, []int)
Deprecated: Use CopyTableResponse.ProtoReflect.Descriptor instead.
func (*CopyTableResponse) GetOperation ¶
func (x *CopyTableResponse) GetOperation() *Ydb_Operations.Operation
func (*CopyTableResponse) ProtoMessage ¶
func (*CopyTableResponse) ProtoMessage()
func (*CopyTableResponse) ProtoReflect ¶
func (x *CopyTableResponse) ProtoReflect() protoreflect.Message
func (*CopyTableResponse) Reset ¶
func (x *CopyTableResponse) Reset()
func (*CopyTableResponse) String ¶
func (x *CopyTableResponse) String() string
type CopyTablesRequest ¶
type CopyTablesRequest struct { OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"` // Session identifier SessionId string `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` // Source and destination paths which describe copies Tables []*CopyTableItem `protobuf:"bytes,3,rep,name=tables,proto3" json:"tables,omitempty"` // contains filtered or unexported fields }
Creates consistent copy of given tables.
func (*CopyTablesRequest) Descriptor
deprecated
func (*CopyTablesRequest) Descriptor() ([]byte, []int)
Deprecated: Use CopyTablesRequest.ProtoReflect.Descriptor instead.
func (*CopyTablesRequest) GetOperationParams ¶
func (x *CopyTablesRequest) GetOperationParams() *Ydb_Operations.OperationParams
func (*CopyTablesRequest) GetSessionId ¶
func (x *CopyTablesRequest) GetSessionId() string
func (*CopyTablesRequest) GetTables ¶
func (x *CopyTablesRequest) GetTables() []*CopyTableItem
func (*CopyTablesRequest) ProtoMessage ¶
func (*CopyTablesRequest) ProtoMessage()
func (*CopyTablesRequest) ProtoReflect ¶
func (x *CopyTablesRequest) ProtoReflect() protoreflect.Message
func (*CopyTablesRequest) Reset ¶
func (x *CopyTablesRequest) Reset()
func (*CopyTablesRequest) String ¶
func (x *CopyTablesRequest) String() string
type CopyTablesResponse ¶
type CopyTablesResponse struct { Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // contains filtered or unexported fields }
func (*CopyTablesResponse) Descriptor
deprecated
func (*CopyTablesResponse) Descriptor() ([]byte, []int)
Deprecated: Use CopyTablesResponse.ProtoReflect.Descriptor instead.
func (*CopyTablesResponse) GetOperation ¶
func (x *CopyTablesResponse) GetOperation() *Ydb_Operations.Operation
func (*CopyTablesResponse) ProtoMessage ¶
func (*CopyTablesResponse) ProtoMessage()
func (*CopyTablesResponse) ProtoReflect ¶
func (x *CopyTablesResponse) ProtoReflect() protoreflect.Message
func (*CopyTablesResponse) Reset ¶
func (x *CopyTablesResponse) Reset()
func (*CopyTablesResponse) String ¶
func (x *CopyTablesResponse) String() string
type CreateSessionRequest ¶
type CreateSessionRequest struct { OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"` // contains filtered or unexported fields }
Create new session
func (*CreateSessionRequest) Descriptor
deprecated
func (*CreateSessionRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateSessionRequest.ProtoReflect.Descriptor instead.
func (*CreateSessionRequest) GetOperationParams ¶
func (x *CreateSessionRequest) GetOperationParams() *Ydb_Operations.OperationParams
func (*CreateSessionRequest) ProtoMessage ¶
func (*CreateSessionRequest) ProtoMessage()
func (*CreateSessionRequest) ProtoReflect ¶
func (x *CreateSessionRequest) ProtoReflect() protoreflect.Message
func (*CreateSessionRequest) Reset ¶
func (x *CreateSessionRequest) Reset()
func (*CreateSessionRequest) String ¶
func (x *CreateSessionRequest) String() string
type CreateSessionResponse ¶
type CreateSessionResponse struct { // Holds CreateSessionResult in case of CreateSessionResult Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // contains filtered or unexported fields }
Create new session
func (*CreateSessionResponse) Descriptor
deprecated
func (*CreateSessionResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateSessionResponse.ProtoReflect.Descriptor instead.
func (*CreateSessionResponse) GetOperation ¶
func (x *CreateSessionResponse) GetOperation() *Ydb_Operations.Operation
func (*CreateSessionResponse) ProtoMessage ¶
func (*CreateSessionResponse) ProtoMessage()
func (*CreateSessionResponse) ProtoReflect ¶
func (x *CreateSessionResponse) ProtoReflect() protoreflect.Message
func (*CreateSessionResponse) Reset ¶
func (x *CreateSessionResponse) Reset()
func (*CreateSessionResponse) String ¶
func (x *CreateSessionResponse) String() string
type CreateSessionResult ¶
type CreateSessionResult struct { // Session identifier SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` // contains filtered or unexported fields }
func (*CreateSessionResult) Descriptor
deprecated
func (*CreateSessionResult) Descriptor() ([]byte, []int)
Deprecated: Use CreateSessionResult.ProtoReflect.Descriptor instead.
func (*CreateSessionResult) GetSessionId ¶
func (x *CreateSessionResult) GetSessionId() string
func (*CreateSessionResult) ProtoMessage ¶
func (*CreateSessionResult) ProtoMessage()
func (*CreateSessionResult) ProtoReflect ¶
func (x *CreateSessionResult) ProtoReflect() protoreflect.Message
func (*CreateSessionResult) Reset ¶
func (x *CreateSessionResult) Reset()
func (*CreateSessionResult) String ¶
func (x *CreateSessionResult) String() string
type CreateTableRequest ¶
type CreateTableRequest struct { // Session identifier SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` // Full path Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` // Columns (name, type) Columns []*ColumnMeta `protobuf:"bytes,3,rep,name=columns,proto3" json:"columns,omitempty"` // List of columns used as primary key PrimaryKey []string `protobuf:"bytes,4,rep,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"` // Table profile Profile *TableProfile `protobuf:"bytes,5,opt,name=profile,proto3" json:"profile,omitempty"` OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,6,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"` // List of secondary indexes Indexes []*TableIndex `protobuf:"bytes,7,rep,name=indexes,proto3" json:"indexes,omitempty"` // Table rows time to live settings TtlSettings *TtlSettings `protobuf:"bytes,8,opt,name=ttl_settings,json=ttlSettings,proto3" json:"ttl_settings,omitempty"` // Storage settings for table StorageSettings *StorageSettings `protobuf:"bytes,9,opt,name=storage_settings,json=storageSettings,proto3" json:"storage_settings,omitempty"` // Column families ColumnFamilies []*ColumnFamily `protobuf:"bytes,10,rep,name=column_families,json=columnFamilies,proto3" json:"column_families,omitempty"` // Attributes. Total size is limited to 10 KB. Attributes map[string]string `` /* 162-byte string literal not displayed */ // Predefined named set of settings for table compaction ["default", "small_table", "log_table"]. CompactionPolicy string `protobuf:"bytes,12,opt,name=compaction_policy,json=compactionPolicy,proto3" json:"compaction_policy,omitempty"` // Either one of the following partitions options can be specified // // Types that are assignable to Partitions: // // *CreateTableRequest_UniformPartitions // *CreateTableRequest_PartitionAtKeys Partitions isCreateTableRequest_Partitions `protobuf_oneof:"partitions"` // Partitioning settings for table PartitioningSettings *PartitioningSettings `protobuf:"bytes,15,opt,name=partitioning_settings,json=partitioningSettings,proto3" json:"partitioning_settings,omitempty"` // Bloom filter by key KeyBloomFilter Ydb.FeatureFlag_Status `` /* 135-byte string literal not displayed */ // Read replicas settings for table ReadReplicasSettings *ReadReplicasSettings `protobuf:"bytes,17,opt,name=read_replicas_settings,json=readReplicasSettings,proto3" json:"read_replicas_settings,omitempty"` // Tiering rules name. It specifies how data migrates from one tier (logical storage) to another. Tiering string `protobuf:"bytes,18,opt,name=tiering,proto3" json:"tiering,omitempty"` // Is temporary table Temporary bool `protobuf:"varint,19,opt,name=temporary,proto3" json:"temporary,omitempty"` // Is table column or row oriented StoreType StoreType `protobuf:"varint,20,opt,name=store_type,json=storeType,proto3,enum=Ydb.Table.StoreType" json:"store_type,omitempty"` // contains filtered or unexported fields }
func (*CreateTableRequest) Descriptor
deprecated
func (*CreateTableRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateTableRequest.ProtoReflect.Descriptor instead.
func (*CreateTableRequest) GetAttributes ¶
func (x *CreateTableRequest) GetAttributes() map[string]string
func (*CreateTableRequest) GetColumnFamilies ¶
func (x *CreateTableRequest) GetColumnFamilies() []*ColumnFamily
func (*CreateTableRequest) GetColumns ¶
func (x *CreateTableRequest) GetColumns() []*ColumnMeta
func (*CreateTableRequest) GetCompactionPolicy ¶
func (x *CreateTableRequest) GetCompactionPolicy() string
func (*CreateTableRequest) GetIndexes ¶
func (x *CreateTableRequest) GetIndexes() []*TableIndex
func (*CreateTableRequest) GetKeyBloomFilter ¶
func (x *CreateTableRequest) GetKeyBloomFilter() Ydb.FeatureFlag_Status
func (*CreateTableRequest) GetOperationParams ¶
func (x *CreateTableRequest) GetOperationParams() *Ydb_Operations.OperationParams
func (*CreateTableRequest) GetPartitionAtKeys ¶
func (x *CreateTableRequest) GetPartitionAtKeys() *ExplicitPartitions
func (*CreateTableRequest) GetPartitioningSettings ¶
func (x *CreateTableRequest) GetPartitioningSettings() *PartitioningSettings
func (*CreateTableRequest) GetPartitions ¶
func (m *CreateTableRequest) GetPartitions() isCreateTableRequest_Partitions
func (*CreateTableRequest) GetPath ¶
func (x *CreateTableRequest) GetPath() string
func (*CreateTableRequest) GetPrimaryKey ¶
func (x *CreateTableRequest) GetPrimaryKey() []string
func (*CreateTableRequest) GetProfile ¶
func (x *CreateTableRequest) GetProfile() *TableProfile
func (*CreateTableRequest) GetReadReplicasSettings ¶
func (x *CreateTableRequest) GetReadReplicasSettings() *ReadReplicasSettings
func (*CreateTableRequest) GetSessionId ¶
func (x *CreateTableRequest) GetSessionId() string
func (*CreateTableRequest) GetStorageSettings ¶
func (x *CreateTableRequest) GetStorageSettings() *StorageSettings
func (*CreateTableRequest) GetStoreType ¶
func (x *CreateTableRequest) GetStoreType() StoreType
func (*CreateTableRequest) GetTemporary ¶
func (x *CreateTableRequest) GetTemporary() bool
func (*CreateTableRequest) GetTiering ¶
func (x *CreateTableRequest) GetTiering() string
func (*CreateTableRequest) GetTtlSettings ¶
func (x *CreateTableRequest) GetTtlSettings() *TtlSettings
func (*CreateTableRequest) GetUniformPartitions ¶
func (x *CreateTableRequest) GetUniformPartitions() uint64
func (*CreateTableRequest) ProtoMessage ¶
func (*CreateTableRequest) ProtoMessage()
func (*CreateTableRequest) ProtoReflect ¶
func (x *CreateTableRequest) ProtoReflect() protoreflect.Message
func (*CreateTableRequest) Reset ¶
func (x *CreateTableRequest) Reset()
func (*CreateTableRequest) String ¶
func (x *CreateTableRequest) String() string
type CreateTableRequest_PartitionAtKeys ¶
type CreateTableRequest_PartitionAtKeys struct { // Explicitly specify key values which are used as borders for created partitions. PartitionAtKeys *ExplicitPartitions `protobuf:"bytes,14,opt,name=partition_at_keys,json=partitionAtKeys,proto3,oneof"` }
type CreateTableRequest_UniformPartitions ¶
type CreateTableRequest_UniformPartitions struct { // Enable uniform partitioning using given partitions count. // The first components of primary key must have Uint32/Uint64 type. UniformPartitions uint64 `protobuf:"varint,13,opt,name=uniform_partitions,json=uniformPartitions,proto3,oneof"` }
type CreateTableResponse ¶
type CreateTableResponse struct { Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // contains filtered or unexported fields }
func (*CreateTableResponse) Descriptor
deprecated
func (*CreateTableResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateTableResponse.ProtoReflect.Descriptor instead.
func (*CreateTableResponse) GetOperation ¶
func (x *CreateTableResponse) GetOperation() *Ydb_Operations.Operation
func (*CreateTableResponse) ProtoMessage ¶
func (*CreateTableResponse) ProtoMessage()
func (*CreateTableResponse) ProtoReflect ¶
func (x *CreateTableResponse) ProtoReflect() protoreflect.Message
func (*CreateTableResponse) Reset ¶
func (x *CreateTableResponse) Reset()
func (*CreateTableResponse) String ¶
func (x *CreateTableResponse) String() string
type DateTypeColumnModeSettings ¶
type DateTypeColumnModeSettings struct { // The column type must be a date type ColumnName string `protobuf:"bytes,1,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"` ExpireAfterSeconds uint32 `protobuf:"varint,2,opt,name=expire_after_seconds,json=expireAfterSeconds,proto3" json:"expire_after_seconds,omitempty"` // contains filtered or unexported fields }
func (*DateTypeColumnModeSettings) Descriptor
deprecated
func (*DateTypeColumnModeSettings) Descriptor() ([]byte, []int)
Deprecated: Use DateTypeColumnModeSettings.ProtoReflect.Descriptor instead.
func (*DateTypeColumnModeSettings) GetColumnName ¶
func (x *DateTypeColumnModeSettings) GetColumnName() string
func (*DateTypeColumnModeSettings) GetExpireAfterSeconds ¶
func (x *DateTypeColumnModeSettings) GetExpireAfterSeconds() uint32
func (*DateTypeColumnModeSettings) ProtoMessage ¶
func (*DateTypeColumnModeSettings) ProtoMessage()
func (*DateTypeColumnModeSettings) ProtoReflect ¶
func (x *DateTypeColumnModeSettings) ProtoReflect() protoreflect.Message
func (*DateTypeColumnModeSettings) Reset ¶
func (x *DateTypeColumnModeSettings) Reset()
func (*DateTypeColumnModeSettings) String ¶
func (x *DateTypeColumnModeSettings) String() string
type DeleteSessionRequest ¶
type DeleteSessionRequest struct { // Session identifier SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,2,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"` // contains filtered or unexported fields }
Delete session with given id string
func (*DeleteSessionRequest) Descriptor
deprecated
func (*DeleteSessionRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteSessionRequest.ProtoReflect.Descriptor instead.
func (*DeleteSessionRequest) GetOperationParams ¶
func (x *DeleteSessionRequest) GetOperationParams() *Ydb_Operations.OperationParams
func (*DeleteSessionRequest) GetSessionId ¶
func (x *DeleteSessionRequest) GetSessionId() string
func (*DeleteSessionRequest) ProtoMessage ¶
func (*DeleteSessionRequest) ProtoMessage()
func (*DeleteSessionRequest) ProtoReflect ¶
func (x *DeleteSessionRequest) ProtoReflect() protoreflect.Message
func (*DeleteSessionRequest) Reset ¶
func (x *DeleteSessionRequest) Reset()
func (*DeleteSessionRequest) String ¶
func (x *DeleteSessionRequest) String() string
type DeleteSessionResponse ¶
type DeleteSessionResponse struct { Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // contains filtered or unexported fields }
func (*DeleteSessionResponse) Descriptor
deprecated
func (*DeleteSessionResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteSessionResponse.ProtoReflect.Descriptor instead.
func (*DeleteSessionResponse) GetOperation ¶
func (x *DeleteSessionResponse) GetOperation() *Ydb_Operations.Operation
func (*DeleteSessionResponse) ProtoMessage ¶
func (*DeleteSessionResponse) ProtoMessage()
func (*DeleteSessionResponse) ProtoReflect ¶
func (x *DeleteSessionResponse) ProtoReflect() protoreflect.Message
func (*DeleteSessionResponse) Reset ¶
func (x *DeleteSessionResponse) Reset()
func (*DeleteSessionResponse) String ¶
func (x *DeleteSessionResponse) String() string
type DescribeTableOptionsRequest ¶
type DescribeTableOptionsRequest struct { OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"` // contains filtered or unexported fields }
func (*DescribeTableOptionsRequest) Descriptor
deprecated
func (*DescribeTableOptionsRequest) Descriptor() ([]byte, []int)
Deprecated: Use DescribeTableOptionsRequest.ProtoReflect.Descriptor instead.
func (*DescribeTableOptionsRequest) GetOperationParams ¶
func (x *DescribeTableOptionsRequest) GetOperationParams() *Ydb_Operations.OperationParams
func (*DescribeTableOptionsRequest) ProtoMessage ¶
func (*DescribeTableOptionsRequest) ProtoMessage()
func (*DescribeTableOptionsRequest) ProtoReflect ¶
func (x *DescribeTableOptionsRequest) ProtoReflect() protoreflect.Message
func (*DescribeTableOptionsRequest) Reset ¶
func (x *DescribeTableOptionsRequest) Reset()
func (*DescribeTableOptionsRequest) String ¶
func (x *DescribeTableOptionsRequest) String() string
type DescribeTableOptionsResponse ¶
type DescribeTableOptionsResponse struct { // operation.result holds ListTableParametersResult Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // contains filtered or unexported fields }
func (*DescribeTableOptionsResponse) Descriptor
deprecated
func (*DescribeTableOptionsResponse) Descriptor() ([]byte, []int)
Deprecated: Use DescribeTableOptionsResponse.ProtoReflect.Descriptor instead.
func (*DescribeTableOptionsResponse) GetOperation ¶
func (x *DescribeTableOptionsResponse) GetOperation() *Ydb_Operations.Operation
func (*DescribeTableOptionsResponse) ProtoMessage ¶
func (*DescribeTableOptionsResponse) ProtoMessage()
func (*DescribeTableOptionsResponse) ProtoReflect ¶
func (x *DescribeTableOptionsResponse) ProtoReflect() protoreflect.Message
func (*DescribeTableOptionsResponse) Reset ¶
func (x *DescribeTableOptionsResponse) Reset()
func (*DescribeTableOptionsResponse) String ¶
func (x *DescribeTableOptionsResponse) String() string
type DescribeTableOptionsResult ¶
type DescribeTableOptionsResult struct { TableProfilePresets []*TableProfileDescription `protobuf:"bytes,1,rep,name=table_profile_presets,json=tableProfilePresets,proto3" json:"table_profile_presets,omitempty"` StoragePolicyPresets []*StoragePolicyDescription `protobuf:"bytes,2,rep,name=storage_policy_presets,json=storagePolicyPresets,proto3" json:"storage_policy_presets,omitempty"` CompactionPolicyPresets []*CompactionPolicyDescription `` /* 132-byte string literal not displayed */ PartitioningPolicyPresets []*PartitioningPolicyDescription `` /* 138-byte string literal not displayed */ ExecutionPolicyPresets []*ExecutionPolicyDescription `` /* 129-byte string literal not displayed */ ReplicationPolicyPresets []*ReplicationPolicyDescription `` /* 135-byte string literal not displayed */ CachingPolicyPresets []*CachingPolicyDescription `protobuf:"bytes,7,rep,name=caching_policy_presets,json=cachingPolicyPresets,proto3" json:"caching_policy_presets,omitempty"` // contains filtered or unexported fields }
func (*DescribeTableOptionsResult) Descriptor
deprecated
func (*DescribeTableOptionsResult) Descriptor() ([]byte, []int)
Deprecated: Use DescribeTableOptionsResult.ProtoReflect.Descriptor instead.
func (*DescribeTableOptionsResult) GetCachingPolicyPresets ¶
func (x *DescribeTableOptionsResult) GetCachingPolicyPresets() []*CachingPolicyDescription
func (*DescribeTableOptionsResult) GetCompactionPolicyPresets ¶
func (x *DescribeTableOptionsResult) GetCompactionPolicyPresets() []*CompactionPolicyDescription
func (*DescribeTableOptionsResult) GetExecutionPolicyPresets ¶
func (x *DescribeTableOptionsResult) GetExecutionPolicyPresets() []*ExecutionPolicyDescription
func (*DescribeTableOptionsResult) GetPartitioningPolicyPresets ¶
func (x *DescribeTableOptionsResult) GetPartitioningPolicyPresets() []*PartitioningPolicyDescription
func (*DescribeTableOptionsResult) GetReplicationPolicyPresets ¶
func (x *DescribeTableOptionsResult) GetReplicationPolicyPresets() []*ReplicationPolicyDescription
func (*DescribeTableOptionsResult) GetStoragePolicyPresets ¶
func (x *DescribeTableOptionsResult) GetStoragePolicyPresets() []*StoragePolicyDescription
func (*DescribeTableOptionsResult) GetTableProfilePresets ¶
func (x *DescribeTableOptionsResult) GetTableProfilePresets() []*TableProfileDescription
func (*DescribeTableOptionsResult) ProtoMessage ¶
func (*DescribeTableOptionsResult) ProtoMessage()
func (*DescribeTableOptionsResult) ProtoReflect ¶
func (x *DescribeTableOptionsResult) ProtoReflect() protoreflect.Message
func (*DescribeTableOptionsResult) Reset ¶
func (x *DescribeTableOptionsResult) Reset()
func (*DescribeTableOptionsResult) String ¶
func (x *DescribeTableOptionsResult) String() string
type DescribeTableRequest ¶
type DescribeTableRequest struct { // Session identifier SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` // Full path Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,4,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"` // Includes shard key distribution info IncludeShardKeyBounds bool `` /* 129-byte string literal not displayed */ // Includes table statistics IncludeTableStats bool `protobuf:"varint,6,opt,name=include_table_stats,json=includeTableStats,proto3" json:"include_table_stats,omitempty"` // Includes partition statistics (required include_table_statistics) IncludePartitionStats bool `` /* 127-byte string literal not displayed */ // contains filtered or unexported fields }
Describe table with given path
func (*DescribeTableRequest) Descriptor
deprecated
func (*DescribeTableRequest) Descriptor() ([]byte, []int)
Deprecated: Use DescribeTableRequest.ProtoReflect.Descriptor instead.
func (*DescribeTableRequest) GetIncludePartitionStats ¶
func (x *DescribeTableRequest) GetIncludePartitionStats() bool
func (*DescribeTableRequest) GetIncludeShardKeyBounds ¶
func (x *DescribeTableRequest) GetIncludeShardKeyBounds() bool
func (*DescribeTableRequest) GetIncludeTableStats ¶
func (x *DescribeTableRequest) GetIncludeTableStats() bool
func (*DescribeTableRequest) GetOperationParams ¶
func (x *DescribeTableRequest) GetOperationParams() *Ydb_Operations.OperationParams
func (*DescribeTableRequest) GetPath ¶
func (x *DescribeTableRequest) GetPath() string
func (*DescribeTableRequest) GetSessionId ¶
func (x *DescribeTableRequest) GetSessionId() string
func (*DescribeTableRequest) ProtoMessage ¶
func (*DescribeTableRequest) ProtoMessage()
func (*DescribeTableRequest) ProtoReflect ¶
func (x *DescribeTableRequest) ProtoReflect() protoreflect.Message
func (*DescribeTableRequest) Reset ¶
func (x *DescribeTableRequest) Reset()
func (*DescribeTableRequest) String ¶
func (x *DescribeTableRequest) String() string
type DescribeTableResponse ¶
type DescribeTableResponse struct { // Holds DescribeTableResult in case of successful call Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // contains filtered or unexported fields }
func (*DescribeTableResponse) Descriptor
deprecated
func (*DescribeTableResponse) Descriptor() ([]byte, []int)
Deprecated: Use DescribeTableResponse.ProtoReflect.Descriptor instead.
func (*DescribeTableResponse) GetOperation ¶
func (x *DescribeTableResponse) GetOperation() *Ydb_Operations.Operation
func (*DescribeTableResponse) ProtoMessage ¶
func (*DescribeTableResponse) ProtoMessage()
func (*DescribeTableResponse) ProtoReflect ¶
func (x *DescribeTableResponse) ProtoReflect() protoreflect.Message
func (*DescribeTableResponse) Reset ¶
func (x *DescribeTableResponse) Reset()
func (*DescribeTableResponse) String ¶
func (x *DescribeTableResponse) String() string
type DescribeTableResult ¶
type DescribeTableResult struct { // Description of scheme object Self *Ydb_Scheme.Entry `protobuf:"bytes,1,opt,name=self,proto3" json:"self,omitempty"` // List of columns Columns []*ColumnMeta `protobuf:"bytes,2,rep,name=columns,proto3" json:"columns,omitempty"` // List of primary key columns PrimaryKey []string `protobuf:"bytes,3,rep,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"` // List of key ranges for shard ShardKeyBounds []*Ydb.TypedValue `protobuf:"bytes,4,rep,name=shard_key_bounds,json=shardKeyBounds,proto3" json:"shard_key_bounds,omitempty"` // List of indexes Indexes []*TableIndexDescription `protobuf:"bytes,5,rep,name=indexes,proto3" json:"indexes,omitempty"` // Statistics of table TableStats *TableStats `protobuf:"bytes,6,opt,name=table_stats,json=tableStats,proto3" json:"table_stats,omitempty"` // TTL params TtlSettings *TtlSettings `protobuf:"bytes,7,opt,name=ttl_settings,json=ttlSettings,proto3" json:"ttl_settings,omitempty"` // Storage settings for table StorageSettings *StorageSettings `protobuf:"bytes,8,opt,name=storage_settings,json=storageSettings,proto3" json:"storage_settings,omitempty"` // Column families ColumnFamilies []*ColumnFamily `protobuf:"bytes,9,rep,name=column_families,json=columnFamilies,proto3" json:"column_families,omitempty"` // Attributes Attributes map[string]string `` /* 162-byte string literal not displayed */ // Partitioning settings for table PartitioningSettings *PartitioningSettings `protobuf:"bytes,12,opt,name=partitioning_settings,json=partitioningSettings,proto3" json:"partitioning_settings,omitempty"` // Bloom filter by key KeyBloomFilter Ydb.FeatureFlag_Status `` /* 135-byte string literal not displayed */ // Read replicas settings for table ReadReplicasSettings *ReadReplicasSettings `protobuf:"bytes,14,opt,name=read_replicas_settings,json=readReplicasSettings,proto3" json:"read_replicas_settings,omitempty"` // List of changefeeds Changefeeds []*ChangefeedDescription `protobuf:"bytes,15,rep,name=changefeeds,proto3" json:"changefeeds,omitempty"` // Tiering rules name Tiering string `protobuf:"bytes,16,opt,name=tiering,proto3" json:"tiering,omitempty"` // Is temporary table Temporary bool `protobuf:"varint,17,opt,name=temporary,proto3" json:"temporary,omitempty"` // Is table column or row oriented StoreType StoreType `protobuf:"varint,18,opt,name=store_type,json=storeType,proto3,enum=Ydb.Table.StoreType" json:"store_type,omitempty"` // contains filtered or unexported fields }
func (*DescribeTableResult) Descriptor
deprecated
func (*DescribeTableResult) Descriptor() ([]byte, []int)
Deprecated: Use DescribeTableResult.ProtoReflect.Descriptor instead.
func (*DescribeTableResult) GetAttributes ¶
func (x *DescribeTableResult) GetAttributes() map[string]string
func (*DescribeTableResult) GetChangefeeds ¶
func (x *DescribeTableResult) GetChangefeeds() []*ChangefeedDescription
func (*DescribeTableResult) GetColumnFamilies ¶
func (x *DescribeTableResult) GetColumnFamilies() []*ColumnFamily
func (*DescribeTableResult) GetColumns ¶
func (x *DescribeTableResult) GetColumns() []*ColumnMeta
func (*DescribeTableResult) GetIndexes ¶
func (x *DescribeTableResult) GetIndexes() []*TableIndexDescription
func (*DescribeTableResult) GetKeyBloomFilter ¶
func (x *DescribeTableResult) GetKeyBloomFilter() Ydb.FeatureFlag_Status
func (*DescribeTableResult) GetPartitioningSettings ¶
func (x *DescribeTableResult) GetPartitioningSettings() *PartitioningSettings
func (*DescribeTableResult) GetPrimaryKey ¶
func (x *DescribeTableResult) GetPrimaryKey() []string
func (*DescribeTableResult) GetReadReplicasSettings ¶
func (x *DescribeTableResult) GetReadReplicasSettings() *ReadReplicasSettings
func (*DescribeTableResult) GetSelf ¶
func (x *DescribeTableResult) GetSelf() *Ydb_Scheme.Entry
func (*DescribeTableResult) GetShardKeyBounds ¶
func (x *DescribeTableResult) GetShardKeyBounds() []*Ydb.TypedValue
func (*DescribeTableResult) GetStorageSettings ¶
func (x *DescribeTableResult) GetStorageSettings() *StorageSettings
func (*DescribeTableResult) GetStoreType ¶
func (x *DescribeTableResult) GetStoreType() StoreType
func (*DescribeTableResult) GetTableStats ¶
func (x *DescribeTableResult) GetTableStats() *TableStats
func (*DescribeTableResult) GetTemporary ¶
func (x *DescribeTableResult) GetTemporary() bool
func (*DescribeTableResult) GetTiering ¶
func (x *DescribeTableResult) GetTiering() string
func (*DescribeTableResult) GetTtlSettings ¶
func (x *DescribeTableResult) GetTtlSettings() *TtlSettings
func (*DescribeTableResult) ProtoMessage ¶
func (*DescribeTableResult) ProtoMessage()
func (*DescribeTableResult) ProtoReflect ¶
func (x *DescribeTableResult) ProtoReflect() protoreflect.Message
func (*DescribeTableResult) Reset ¶
func (x *DescribeTableResult) Reset()
func (*DescribeTableResult) String ¶
func (x *DescribeTableResult) String() string
type DropTableRequest ¶
type DropTableRequest struct { // Session identifier SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` // Full path Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,4,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"` // contains filtered or unexported fields }
Drop table with given path
func (*DropTableRequest) Descriptor
deprecated
func (*DropTableRequest) Descriptor() ([]byte, []int)
Deprecated: Use DropTableRequest.ProtoReflect.Descriptor instead.
func (*DropTableRequest) GetOperationParams ¶
func (x *DropTableRequest) GetOperationParams() *Ydb_Operations.OperationParams
func (*DropTableRequest) GetPath ¶
func (x *DropTableRequest) GetPath() string
func (*DropTableRequest) GetSessionId ¶
func (x *DropTableRequest) GetSessionId() string
func (*DropTableRequest) ProtoMessage ¶
func (*DropTableRequest) ProtoMessage()
func (*DropTableRequest) ProtoReflect ¶
func (x *DropTableRequest) ProtoReflect() protoreflect.Message
func (*DropTableRequest) Reset ¶
func (x *DropTableRequest) Reset()
func (*DropTableRequest) String ¶
func (x *DropTableRequest) String() string
type DropTableResponse ¶
type DropTableResponse struct { Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // contains filtered or unexported fields }
func (*DropTableResponse) Descriptor
deprecated
func (*DropTableResponse) Descriptor() ([]byte, []int)
Deprecated: Use DropTableResponse.ProtoReflect.Descriptor instead.
func (*DropTableResponse) GetOperation ¶
func (x *DropTableResponse) GetOperation() *Ydb_Operations.Operation
func (*DropTableResponse) ProtoMessage ¶
func (*DropTableResponse) ProtoMessage()
func (*DropTableResponse) ProtoReflect ¶
func (x *DropTableResponse) ProtoReflect() protoreflect.Message
func (*DropTableResponse) Reset ¶
func (x *DropTableResponse) Reset()
func (*DropTableResponse) String ¶
func (x *DropTableResponse) String() string
type ExecuteDataQueryRequest ¶
type ExecuteDataQueryRequest struct { // Session identifier SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` TxControl *TransactionControl `protobuf:"bytes,2,opt,name=tx_control,json=txControl,proto3" json:"tx_control,omitempty"` Query *Query `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"` // Map of query parameters (optional) Parameters map[string]*Ydb.TypedValue `` /* 161-byte string literal not displayed */ QueryCachePolicy *QueryCachePolicy `protobuf:"bytes,5,opt,name=query_cache_policy,json=queryCachePolicy,proto3" json:"query_cache_policy,omitempty"` OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,6,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"` CollectStats QueryStatsCollection_Mode `` /* 139-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ExecuteDataQueryRequest) Descriptor
deprecated
func (*ExecuteDataQueryRequest) Descriptor() ([]byte, []int)
Deprecated: Use ExecuteDataQueryRequest.ProtoReflect.Descriptor instead.
func (*ExecuteDataQueryRequest) GetCollectStats ¶
func (x *ExecuteDataQueryRequest) GetCollectStats() QueryStatsCollection_Mode
func (*ExecuteDataQueryRequest) GetOperationParams ¶
func (x *ExecuteDataQueryRequest) GetOperationParams() *Ydb_Operations.OperationParams
func (*ExecuteDataQueryRequest) GetParameters ¶
func (x *ExecuteDataQueryRequest) GetParameters() map[string]*Ydb.TypedValue
func (*ExecuteDataQueryRequest) GetQuery ¶
func (x *ExecuteDataQueryRequest) GetQuery() *Query
func (*ExecuteDataQueryRequest) GetQueryCachePolicy ¶
func (x *ExecuteDataQueryRequest) GetQueryCachePolicy() *QueryCachePolicy
func (*ExecuteDataQueryRequest) GetSessionId ¶
func (x *ExecuteDataQueryRequest) GetSessionId() string
func (*ExecuteDataQueryRequest) GetTxControl ¶
func (x *ExecuteDataQueryRequest) GetTxControl() *TransactionControl
func (*ExecuteDataQueryRequest) ProtoMessage ¶
func (*ExecuteDataQueryRequest) ProtoMessage()
func (*ExecuteDataQueryRequest) ProtoReflect ¶
func (x *ExecuteDataQueryRequest) ProtoReflect() protoreflect.Message
func (*ExecuteDataQueryRequest) Reset ¶
func (x *ExecuteDataQueryRequest) Reset()
func (*ExecuteDataQueryRequest) String ¶
func (x *ExecuteDataQueryRequest) String() string
type ExecuteDataQueryResponse ¶
type ExecuteDataQueryResponse struct { Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // contains filtered or unexported fields }
func (*ExecuteDataQueryResponse) Descriptor
deprecated
func (*ExecuteDataQueryResponse) Descriptor() ([]byte, []int)
Deprecated: Use ExecuteDataQueryResponse.ProtoReflect.Descriptor instead.
func (*ExecuteDataQueryResponse) GetOperation ¶
func (x *ExecuteDataQueryResponse) GetOperation() *Ydb_Operations.Operation
func (*ExecuteDataQueryResponse) ProtoMessage ¶
func (*ExecuteDataQueryResponse) ProtoMessage()
func (*ExecuteDataQueryResponse) ProtoReflect ¶
func (x *ExecuteDataQueryResponse) ProtoReflect() protoreflect.Message
func (*ExecuteDataQueryResponse) Reset ¶
func (x *ExecuteDataQueryResponse) Reset()
func (*ExecuteDataQueryResponse) String ¶
func (x *ExecuteDataQueryResponse) String() string
type ExecuteQueryResult ¶
type ExecuteQueryResult struct { // Result rets (for each table) ResultSets []*Ydb.ResultSet `protobuf:"bytes,1,rep,name=result_sets,json=resultSets,proto3" json:"result_sets,omitempty"` // Transaction metadata TxMeta *TransactionMeta `protobuf:"bytes,2,opt,name=tx_meta,json=txMeta,proto3" json:"tx_meta,omitempty"` // Query metadata QueryMeta *QueryMeta `protobuf:"bytes,3,opt,name=query_meta,json=queryMeta,proto3" json:"query_meta,omitempty"` // Query execution statistics QueryStats *Ydb_TableStats.QueryStats `protobuf:"bytes,4,opt,name=query_stats,json=queryStats,proto3" json:"query_stats,omitempty"` // contains filtered or unexported fields }
One QueryResult can contain multiple tables
func (*ExecuteQueryResult) Descriptor
deprecated
func (*ExecuteQueryResult) Descriptor() ([]byte, []int)
Deprecated: Use ExecuteQueryResult.ProtoReflect.Descriptor instead.
func (*ExecuteQueryResult) GetQueryMeta ¶
func (x *ExecuteQueryResult) GetQueryMeta() *QueryMeta
func (*ExecuteQueryResult) GetQueryStats ¶
func (x *ExecuteQueryResult) GetQueryStats() *Ydb_TableStats.QueryStats
func (*ExecuteQueryResult) GetResultSets ¶
func (x *ExecuteQueryResult) GetResultSets() []*Ydb.ResultSet
func (*ExecuteQueryResult) GetTxMeta ¶
func (x *ExecuteQueryResult) GetTxMeta() *TransactionMeta
func (*ExecuteQueryResult) ProtoMessage ¶
func (*ExecuteQueryResult) ProtoMessage()
func (*ExecuteQueryResult) ProtoReflect ¶
func (x *ExecuteQueryResult) ProtoReflect() protoreflect.Message
func (*ExecuteQueryResult) Reset ¶
func (x *ExecuteQueryResult) Reset()
func (*ExecuteQueryResult) String ¶
func (x *ExecuteQueryResult) String() string
type ExecuteScanQueryPartialResponse ¶
type ExecuteScanQueryPartialResponse struct { Status Ydb.StatusIds_StatusCode `protobuf:"varint,1,opt,name=status,proto3,enum=Ydb.StatusIds_StatusCode" json:"status,omitempty"` Issues []*Ydb_Issue.IssueMessage `protobuf:"bytes,2,rep,name=issues,proto3" json:"issues,omitempty"` Result *ExecuteScanQueryPartialResult `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
func (*ExecuteScanQueryPartialResponse) Descriptor
deprecated
func (*ExecuteScanQueryPartialResponse) Descriptor() ([]byte, []int)
Deprecated: Use ExecuteScanQueryPartialResponse.ProtoReflect.Descriptor instead.
func (*ExecuteScanQueryPartialResponse) GetIssues ¶
func (x *ExecuteScanQueryPartialResponse) GetIssues() []*Ydb_Issue.IssueMessage
func (*ExecuteScanQueryPartialResponse) GetResult ¶
func (x *ExecuteScanQueryPartialResponse) GetResult() *ExecuteScanQueryPartialResult
func (*ExecuteScanQueryPartialResponse) GetStatus ¶
func (x *ExecuteScanQueryPartialResponse) GetStatus() Ydb.StatusIds_StatusCode
func (*ExecuteScanQueryPartialResponse) ProtoMessage ¶
func (*ExecuteScanQueryPartialResponse) ProtoMessage()
func (*ExecuteScanQueryPartialResponse) ProtoReflect ¶
func (x *ExecuteScanQueryPartialResponse) ProtoReflect() protoreflect.Message
func (*ExecuteScanQueryPartialResponse) Reset ¶
func (x *ExecuteScanQueryPartialResponse) Reset()
func (*ExecuteScanQueryPartialResponse) String ¶
func (x *ExecuteScanQueryPartialResponse) String() string
type ExecuteScanQueryPartialResult ¶
type ExecuteScanQueryPartialResult struct { ResultSet *Ydb.ResultSet `protobuf:"bytes,1,opt,name=result_set,json=resultSet,proto3" json:"result_set,omitempty"` QueryStats *Ydb_TableStats.QueryStats `protobuf:"bytes,6,opt,name=query_stats,json=queryStats,proto3" json:"query_stats,omitempty"` // works only in mode: MODE_EXPLAIN, // collects additional diagnostics about query compilation, including query plan and scheme QueryFullDiagnostics string `protobuf:"bytes,7,opt,name=query_full_diagnostics,json=queryFullDiagnostics,proto3" json:"query_full_diagnostics,omitempty"` // contains filtered or unexported fields }
func (*ExecuteScanQueryPartialResult) Descriptor
deprecated
func (*ExecuteScanQueryPartialResult) Descriptor() ([]byte, []int)
Deprecated: Use ExecuteScanQueryPartialResult.ProtoReflect.Descriptor instead.
func (*ExecuteScanQueryPartialResult) GetQueryFullDiagnostics ¶
func (x *ExecuteScanQueryPartialResult) GetQueryFullDiagnostics() string
func (*ExecuteScanQueryPartialResult) GetQueryStats ¶
func (x *ExecuteScanQueryPartialResult) GetQueryStats() *Ydb_TableStats.QueryStats
func (*ExecuteScanQueryPartialResult) GetResultSet ¶
func (x *ExecuteScanQueryPartialResult) GetResultSet() *Ydb.ResultSet
func (*ExecuteScanQueryPartialResult) ProtoMessage ¶
func (*ExecuteScanQueryPartialResult) ProtoMessage()
func (*ExecuteScanQueryPartialResult) ProtoReflect ¶
func (x *ExecuteScanQueryPartialResult) ProtoReflect() protoreflect.Message
func (*ExecuteScanQueryPartialResult) Reset ¶
func (x *ExecuteScanQueryPartialResult) Reset()
func (*ExecuteScanQueryPartialResult) String ¶
func (x *ExecuteScanQueryPartialResult) String() string
type ExecuteScanQueryRequest ¶
type ExecuteScanQueryRequest struct { Query *Query `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"` Parameters map[string]*Ydb.TypedValue `` /* 161-byte string literal not displayed */ Mode ExecuteScanQueryRequest_Mode `protobuf:"varint,6,opt,name=mode,proto3,enum=Ydb.Table.ExecuteScanQueryRequest_Mode" json:"mode,omitempty"` CollectStats QueryStatsCollection_Mode `` /* 139-byte string literal not displayed */ // works only in mode: MODE_EXPLAIN, // collects additional diagnostics about query compilation, including query plan and scheme CollectFullDiagnostics bool `` /* 130-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ExecuteScanQueryRequest) Descriptor
deprecated
func (*ExecuteScanQueryRequest) Descriptor() ([]byte, []int)
Deprecated: Use ExecuteScanQueryRequest.ProtoReflect.Descriptor instead.
func (*ExecuteScanQueryRequest) GetCollectFullDiagnostics ¶
func (x *ExecuteScanQueryRequest) GetCollectFullDiagnostics() bool
func (*ExecuteScanQueryRequest) GetCollectStats ¶
func (x *ExecuteScanQueryRequest) GetCollectStats() QueryStatsCollection_Mode
func (*ExecuteScanQueryRequest) GetMode ¶
func (x *ExecuteScanQueryRequest) GetMode() ExecuteScanQueryRequest_Mode
func (*ExecuteScanQueryRequest) GetParameters ¶
func (x *ExecuteScanQueryRequest) GetParameters() map[string]*Ydb.TypedValue
func (*ExecuteScanQueryRequest) GetQuery ¶
func (x *ExecuteScanQueryRequest) GetQuery() *Query
func (*ExecuteScanQueryRequest) ProtoMessage ¶
func (*ExecuteScanQueryRequest) ProtoMessage()
func (*ExecuteScanQueryRequest) ProtoReflect ¶
func (x *ExecuteScanQueryRequest) ProtoReflect() protoreflect.Message
func (*ExecuteScanQueryRequest) Reset ¶
func (x *ExecuteScanQueryRequest) Reset()
func (*ExecuteScanQueryRequest) String ¶
func (x *ExecuteScanQueryRequest) String() string
type ExecuteScanQueryRequest_Mode ¶
type ExecuteScanQueryRequest_Mode int32
const ( ExecuteScanQueryRequest_MODE_UNSPECIFIED ExecuteScanQueryRequest_Mode = 0 ExecuteScanQueryRequest_MODE_EXPLAIN ExecuteScanQueryRequest_Mode = 1 // MODE_PREPARE = 2; ExecuteScanQueryRequest_MODE_EXEC ExecuteScanQueryRequest_Mode = 3 )
func (ExecuteScanQueryRequest_Mode) Descriptor ¶
func (ExecuteScanQueryRequest_Mode) Descriptor() protoreflect.EnumDescriptor
func (ExecuteScanQueryRequest_Mode) Enum ¶
func (x ExecuteScanQueryRequest_Mode) Enum() *ExecuteScanQueryRequest_Mode
func (ExecuteScanQueryRequest_Mode) EnumDescriptor
deprecated
func (ExecuteScanQueryRequest_Mode) EnumDescriptor() ([]byte, []int)
Deprecated: Use ExecuteScanQueryRequest_Mode.Descriptor instead.
func (ExecuteScanQueryRequest_Mode) Number ¶
func (x ExecuteScanQueryRequest_Mode) Number() protoreflect.EnumNumber
func (ExecuteScanQueryRequest_Mode) String ¶
func (x ExecuteScanQueryRequest_Mode) String() string
func (ExecuteScanQueryRequest_Mode) Type ¶
func (ExecuteScanQueryRequest_Mode) Type() protoreflect.EnumType
type ExecuteSchemeQueryRequest ¶
type ExecuteSchemeQueryRequest struct { // Session identifier SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` // SQL text YqlText string `protobuf:"bytes,2,opt,name=yql_text,json=yqlText,proto3" json:"yql_text,omitempty"` OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,3,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"` // contains filtered or unexported fields }
func (*ExecuteSchemeQueryRequest) Descriptor
deprecated
func (*ExecuteSchemeQueryRequest) Descriptor() ([]byte, []int)
Deprecated: Use ExecuteSchemeQueryRequest.ProtoReflect.Descriptor instead.
func (*ExecuteSchemeQueryRequest) GetOperationParams ¶
func (x *ExecuteSchemeQueryRequest) GetOperationParams() *Ydb_Operations.OperationParams
func (*ExecuteSchemeQueryRequest) GetSessionId ¶
func (x *ExecuteSchemeQueryRequest) GetSessionId() string
func (*ExecuteSchemeQueryRequest) GetYqlText ¶
func (x *ExecuteSchemeQueryRequest) GetYqlText() string
func (*ExecuteSchemeQueryRequest) ProtoMessage ¶
func (*ExecuteSchemeQueryRequest) ProtoMessage()
func (*ExecuteSchemeQueryRequest) ProtoReflect ¶
func (x *ExecuteSchemeQueryRequest) ProtoReflect() protoreflect.Message
func (*ExecuteSchemeQueryRequest) Reset ¶
func (x *ExecuteSchemeQueryRequest) Reset()
func (*ExecuteSchemeQueryRequest) String ¶
func (x *ExecuteSchemeQueryRequest) String() string
type ExecuteSchemeQueryResponse ¶
type ExecuteSchemeQueryResponse struct { Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // contains filtered or unexported fields }
func (*ExecuteSchemeQueryResponse) Descriptor
deprecated
func (*ExecuteSchemeQueryResponse) Descriptor() ([]byte, []int)
Deprecated: Use ExecuteSchemeQueryResponse.ProtoReflect.Descriptor instead.
func (*ExecuteSchemeQueryResponse) GetOperation ¶
func (x *ExecuteSchemeQueryResponse) GetOperation() *Ydb_Operations.Operation
func (*ExecuteSchemeQueryResponse) ProtoMessage ¶
func (*ExecuteSchemeQueryResponse) ProtoMessage()
func (*ExecuteSchemeQueryResponse) ProtoReflect ¶
func (x *ExecuteSchemeQueryResponse) ProtoReflect() protoreflect.Message
func (*ExecuteSchemeQueryResponse) Reset ¶
func (x *ExecuteSchemeQueryResponse) Reset()
func (*ExecuteSchemeQueryResponse) String ¶
func (x *ExecuteSchemeQueryResponse) String() string
type ExecutionPolicy ¶
type ExecutionPolicy struct { PresetName string `protobuf:"bytes,1,opt,name=preset_name,json=presetName,proto3" json:"preset_name,omitempty"` // contains filtered or unexported fields }
func (*ExecutionPolicy) Descriptor
deprecated
func (*ExecutionPolicy) Descriptor() ([]byte, []int)
Deprecated: Use ExecutionPolicy.ProtoReflect.Descriptor instead.
func (*ExecutionPolicy) GetPresetName ¶
func (x *ExecutionPolicy) GetPresetName() string
func (*ExecutionPolicy) ProtoMessage ¶
func (*ExecutionPolicy) ProtoMessage()
func (*ExecutionPolicy) ProtoReflect ¶
func (x *ExecutionPolicy) ProtoReflect() protoreflect.Message
func (*ExecutionPolicy) Reset ¶
func (x *ExecutionPolicy) Reset()
func (*ExecutionPolicy) String ¶
func (x *ExecutionPolicy) String() string
type ExecutionPolicyDescription ¶
type ExecutionPolicyDescription struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Labels map[string]string `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ExecutionPolicyDescription) Descriptor
deprecated
func (*ExecutionPolicyDescription) Descriptor() ([]byte, []int)
Deprecated: Use ExecutionPolicyDescription.ProtoReflect.Descriptor instead.
func (*ExecutionPolicyDescription) GetLabels ¶
func (x *ExecutionPolicyDescription) GetLabels() map[string]string
func (*ExecutionPolicyDescription) GetName ¶
func (x *ExecutionPolicyDescription) GetName() string
func (*ExecutionPolicyDescription) ProtoMessage ¶
func (*ExecutionPolicyDescription) ProtoMessage()
func (*ExecutionPolicyDescription) ProtoReflect ¶
func (x *ExecutionPolicyDescription) ProtoReflect() protoreflect.Message
func (*ExecutionPolicyDescription) Reset ¶
func (x *ExecutionPolicyDescription) Reset()
func (*ExecutionPolicyDescription) String ¶
func (x *ExecutionPolicyDescription) String() string
type ExplainDataQueryRequest ¶
type ExplainDataQueryRequest struct { // Session identifier SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` // SQL text to explain YqlText string `protobuf:"bytes,2,opt,name=yql_text,json=yqlText,proto3" json:"yql_text,omitempty"` OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,3,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"` CollectFullDiagnostics bool `` /* 130-byte string literal not displayed */ // contains filtered or unexported fields }
Explain data query
func (*ExplainDataQueryRequest) Descriptor
deprecated
func (*ExplainDataQueryRequest) Descriptor() ([]byte, []int)
Deprecated: Use ExplainDataQueryRequest.ProtoReflect.Descriptor instead.
func (*ExplainDataQueryRequest) GetCollectFullDiagnostics ¶
func (x *ExplainDataQueryRequest) GetCollectFullDiagnostics() bool
func (*ExplainDataQueryRequest) GetOperationParams ¶
func (x *ExplainDataQueryRequest) GetOperationParams() *Ydb_Operations.OperationParams
func (*ExplainDataQueryRequest) GetSessionId ¶
func (x *ExplainDataQueryRequest) GetSessionId() string
func (*ExplainDataQueryRequest) GetYqlText ¶
func (x *ExplainDataQueryRequest) GetYqlText() string
func (*ExplainDataQueryRequest) ProtoMessage ¶
func (*ExplainDataQueryRequest) ProtoMessage()
func (*ExplainDataQueryRequest) ProtoReflect ¶
func (x *ExplainDataQueryRequest) ProtoReflect() protoreflect.Message
func (*ExplainDataQueryRequest) Reset ¶
func (x *ExplainDataQueryRequest) Reset()
func (*ExplainDataQueryRequest) String ¶
func (x *ExplainDataQueryRequest) String() string
type ExplainDataQueryResponse ¶
type ExplainDataQueryResponse struct { // Holds ExplainQueryResult in case of successful call Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // contains filtered or unexported fields }
func (*ExplainDataQueryResponse) Descriptor
deprecated
func (*ExplainDataQueryResponse) Descriptor() ([]byte, []int)
Deprecated: Use ExplainDataQueryResponse.ProtoReflect.Descriptor instead.
func (*ExplainDataQueryResponse) GetOperation ¶
func (x *ExplainDataQueryResponse) GetOperation() *Ydb_Operations.Operation
func (*ExplainDataQueryResponse) ProtoMessage ¶
func (*ExplainDataQueryResponse) ProtoMessage()
func (*ExplainDataQueryResponse) ProtoReflect ¶
func (x *ExplainDataQueryResponse) ProtoReflect() protoreflect.Message
func (*ExplainDataQueryResponse) Reset ¶
func (x *ExplainDataQueryResponse) Reset()
func (*ExplainDataQueryResponse) String ¶
func (x *ExplainDataQueryResponse) String() string
type ExplainQueryResult ¶
type ExplainQueryResult struct { QueryAst string `protobuf:"bytes,1,opt,name=query_ast,json=queryAst,proto3" json:"query_ast,omitempty"` QueryPlan string `protobuf:"bytes,2,opt,name=query_plan,json=queryPlan,proto3" json:"query_plan,omitempty"` QueryFullDiagnostics string `protobuf:"bytes,3,opt,name=query_full_diagnostics,json=queryFullDiagnostics,proto3" json:"query_full_diagnostics,omitempty"` // contains filtered or unexported fields }
func (*ExplainQueryResult) Descriptor
deprecated
func (*ExplainQueryResult) Descriptor() ([]byte, []int)
Deprecated: Use ExplainQueryResult.ProtoReflect.Descriptor instead.
func (*ExplainQueryResult) GetQueryAst ¶
func (x *ExplainQueryResult) GetQueryAst() string
func (*ExplainQueryResult) GetQueryFullDiagnostics ¶
func (x *ExplainQueryResult) GetQueryFullDiagnostics() string
func (*ExplainQueryResult) GetQueryPlan ¶
func (x *ExplainQueryResult) GetQueryPlan() string
func (*ExplainQueryResult) ProtoMessage ¶
func (*ExplainQueryResult) ProtoMessage()
func (*ExplainQueryResult) ProtoReflect ¶
func (x *ExplainQueryResult) ProtoReflect() protoreflect.Message
func (*ExplainQueryResult) Reset ¶
func (x *ExplainQueryResult) Reset()
func (*ExplainQueryResult) String ¶
func (x *ExplainQueryResult) String() string
type ExplicitPartitions ¶
type ExplicitPartitions struct { // Specify key values used to split table into partitions. // Each value becomes the first key of a new partition. // Key values should go in ascending order. // Total number of created partitions is number of specified // keys + 1. SplitPoints []*Ydb.TypedValue `protobuf:"bytes,1,rep,name=split_points,json=splitPoints,proto3" json:"split_points,omitempty"` // contains filtered or unexported fields }
func (*ExplicitPartitions) Descriptor
deprecated
func (*ExplicitPartitions) Descriptor() ([]byte, []int)
Deprecated: Use ExplicitPartitions.ProtoReflect.Descriptor instead.
func (*ExplicitPartitions) GetSplitPoints ¶
func (x *ExplicitPartitions) GetSplitPoints() []*Ydb.TypedValue
func (*ExplicitPartitions) ProtoMessage ¶
func (*ExplicitPartitions) ProtoMessage()
func (*ExplicitPartitions) ProtoReflect ¶
func (x *ExplicitPartitions) ProtoReflect() protoreflect.Message
func (*ExplicitPartitions) Reset ¶
func (x *ExplicitPartitions) Reset()
func (*ExplicitPartitions) String ¶
func (x *ExplicitPartitions) String() string
type GlobalAsyncIndex ¶
type GlobalAsyncIndex struct {
// contains filtered or unexported fields
}
func (*GlobalAsyncIndex) Descriptor
deprecated
func (*GlobalAsyncIndex) Descriptor() ([]byte, []int)
Deprecated: Use GlobalAsyncIndex.ProtoReflect.Descriptor instead.
func (*GlobalAsyncIndex) ProtoMessage ¶
func (*GlobalAsyncIndex) ProtoMessage()
func (*GlobalAsyncIndex) ProtoReflect ¶
func (x *GlobalAsyncIndex) ProtoReflect() protoreflect.Message
func (*GlobalAsyncIndex) Reset ¶
func (x *GlobalAsyncIndex) Reset()
func (*GlobalAsyncIndex) String ¶
func (x *GlobalAsyncIndex) String() string
type GlobalIndex ¶
type GlobalIndex struct {
// contains filtered or unexported fields
}
func (*GlobalIndex) Descriptor
deprecated
func (*GlobalIndex) Descriptor() ([]byte, []int)
Deprecated: Use GlobalIndex.ProtoReflect.Descriptor instead.
func (*GlobalIndex) ProtoMessage ¶
func (*GlobalIndex) ProtoMessage()
func (*GlobalIndex) ProtoReflect ¶
func (x *GlobalIndex) ProtoReflect() protoreflect.Message
func (*GlobalIndex) Reset ¶
func (x *GlobalIndex) Reset()
func (*GlobalIndex) String ¶
func (x *GlobalIndex) String() string
type GlobalUniqueIndex ¶
type GlobalUniqueIndex struct {
// contains filtered or unexported fields
}
func (*GlobalUniqueIndex) Descriptor
deprecated
func (*GlobalUniqueIndex) Descriptor() ([]byte, []int)
Deprecated: Use GlobalUniqueIndex.ProtoReflect.Descriptor instead.
func (*GlobalUniqueIndex) ProtoMessage ¶
func (*GlobalUniqueIndex) ProtoMessage()
func (*GlobalUniqueIndex) ProtoReflect ¶
func (x *GlobalUniqueIndex) ProtoReflect() protoreflect.Message
func (*GlobalUniqueIndex) Reset ¶
func (x *GlobalUniqueIndex) Reset()
func (*GlobalUniqueIndex) String ¶
func (x *GlobalUniqueIndex) String() string
type IndexBuildDescription ¶
type IndexBuildDescription struct { Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` Index *TableIndex `protobuf:"bytes,2,opt,name=index,proto3" json:"index,omitempty"` // contains filtered or unexported fields }
Description of index building operation
func (*IndexBuildDescription) Descriptor
deprecated
func (*IndexBuildDescription) Descriptor() ([]byte, []int)
Deprecated: Use IndexBuildDescription.ProtoReflect.Descriptor instead.
func (*IndexBuildDescription) GetIndex ¶
func (x *IndexBuildDescription) GetIndex() *TableIndex
func (*IndexBuildDescription) GetPath ¶
func (x *IndexBuildDescription) GetPath() string
func (*IndexBuildDescription) ProtoMessage ¶
func (*IndexBuildDescription) ProtoMessage()
func (*IndexBuildDescription) ProtoReflect ¶
func (x *IndexBuildDescription) ProtoReflect() protoreflect.Message
func (*IndexBuildDescription) Reset ¶
func (x *IndexBuildDescription) Reset()
func (*IndexBuildDescription) String ¶
func (x *IndexBuildDescription) String() string
type IndexBuildMetadata ¶
type IndexBuildMetadata struct { Description *IndexBuildDescription `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"` State IndexBuildState_State `protobuf:"varint,2,opt,name=state,proto3,enum=Ydb.Table.IndexBuildState_State" json:"state,omitempty"` Progress float32 `protobuf:"fixed32,3,opt,name=progress,proto3" json:"progress,omitempty"` // contains filtered or unexported fields }
func (*IndexBuildMetadata) Descriptor
deprecated
func (*IndexBuildMetadata) Descriptor() ([]byte, []int)
Deprecated: Use IndexBuildMetadata.ProtoReflect.Descriptor instead.
func (*IndexBuildMetadata) GetDescription ¶
func (x *IndexBuildMetadata) GetDescription() *IndexBuildDescription
func (*IndexBuildMetadata) GetProgress ¶
func (x *IndexBuildMetadata) GetProgress() float32
func (*IndexBuildMetadata) GetState ¶
func (x *IndexBuildMetadata) GetState() IndexBuildState_State
func (*IndexBuildMetadata) ProtoMessage ¶
func (*IndexBuildMetadata) ProtoMessage()
func (*IndexBuildMetadata) ProtoReflect ¶
func (x *IndexBuildMetadata) ProtoReflect() protoreflect.Message
func (*IndexBuildMetadata) Reset ¶
func (x *IndexBuildMetadata) Reset()
func (*IndexBuildMetadata) String ¶
func (x *IndexBuildMetadata) String() string
type IndexBuildState ¶
type IndexBuildState struct {
// contains filtered or unexported fields
}
State of index building operation
func (*IndexBuildState) Descriptor
deprecated
func (*IndexBuildState) Descriptor() ([]byte, []int)
Deprecated: Use IndexBuildState.ProtoReflect.Descriptor instead.
func (*IndexBuildState) ProtoMessage ¶
func (*IndexBuildState) ProtoMessage()
func (*IndexBuildState) ProtoReflect ¶
func (x *IndexBuildState) ProtoReflect() protoreflect.Message
func (*IndexBuildState) Reset ¶
func (x *IndexBuildState) Reset()
func (*IndexBuildState) String ¶
func (x *IndexBuildState) String() string
type IndexBuildState_State ¶
type IndexBuildState_State int32
const ( IndexBuildState_STATE_UNSPECIFIED IndexBuildState_State = 0 IndexBuildState_STATE_PREPARING IndexBuildState_State = 1 IndexBuildState_STATE_TRANSFERING_DATA IndexBuildState_State = 2 IndexBuildState_STATE_APPLYING IndexBuildState_State = 3 IndexBuildState_STATE_DONE IndexBuildState_State = 4 IndexBuildState_STATE_CANCELLATION IndexBuildState_State = 5 IndexBuildState_STATE_CANCELLED IndexBuildState_State = 6 IndexBuildState_STATE_REJECTION IndexBuildState_State = 7 IndexBuildState_STATE_REJECTED IndexBuildState_State = 8 )
func (IndexBuildState_State) Descriptor ¶
func (IndexBuildState_State) Descriptor() protoreflect.EnumDescriptor
func (IndexBuildState_State) Enum ¶
func (x IndexBuildState_State) Enum() *IndexBuildState_State
func (IndexBuildState_State) EnumDescriptor
deprecated
func (IndexBuildState_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use IndexBuildState_State.Descriptor instead.
func (IndexBuildState_State) Number ¶
func (x IndexBuildState_State) Number() protoreflect.EnumNumber
func (IndexBuildState_State) String ¶
func (x IndexBuildState_State) String() string
func (IndexBuildState_State) Type ¶
func (IndexBuildState_State) Type() protoreflect.EnumType
type KeepAliveRequest ¶
type KeepAliveRequest struct { // Session identifier SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,2,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"` // contains filtered or unexported fields }
Keep session alive
func (*KeepAliveRequest) Descriptor
deprecated
func (*KeepAliveRequest) Descriptor() ([]byte, []int)
Deprecated: Use KeepAliveRequest.ProtoReflect.Descriptor instead.
func (*KeepAliveRequest) GetOperationParams ¶
func (x *KeepAliveRequest) GetOperationParams() *Ydb_Operations.OperationParams
func (*KeepAliveRequest) GetSessionId ¶
func (x *KeepAliveRequest) GetSessionId() string
func (*KeepAliveRequest) ProtoMessage ¶
func (*KeepAliveRequest) ProtoMessage()
func (*KeepAliveRequest) ProtoReflect ¶
func (x *KeepAliveRequest) ProtoReflect() protoreflect.Message
func (*KeepAliveRequest) Reset ¶
func (x *KeepAliveRequest) Reset()
func (*KeepAliveRequest) String ¶
func (x *KeepAliveRequest) String() string
type KeepAliveResponse ¶
type KeepAliveResponse struct { Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // contains filtered or unexported fields }
func (*KeepAliveResponse) Descriptor
deprecated
func (*KeepAliveResponse) Descriptor() ([]byte, []int)
Deprecated: Use KeepAliveResponse.ProtoReflect.Descriptor instead.
func (*KeepAliveResponse) GetOperation ¶
func (x *KeepAliveResponse) GetOperation() *Ydb_Operations.Operation
func (*KeepAliveResponse) ProtoMessage ¶
func (*KeepAliveResponse) ProtoMessage()
func (*KeepAliveResponse) ProtoReflect ¶
func (x *KeepAliveResponse) ProtoReflect() protoreflect.Message
func (*KeepAliveResponse) Reset ¶
func (x *KeepAliveResponse) Reset()
func (*KeepAliveResponse) String ¶
func (x *KeepAliveResponse) String() string
type KeepAliveResult ¶
type KeepAliveResult struct { SessionStatus KeepAliveResult_SessionStatus `` /* 146-byte string literal not displayed */ // contains filtered or unexported fields }
func (*KeepAliveResult) Descriptor
deprecated
func (*KeepAliveResult) Descriptor() ([]byte, []int)
Deprecated: Use KeepAliveResult.ProtoReflect.Descriptor instead.
func (*KeepAliveResult) GetSessionStatus ¶
func (x *KeepAliveResult) GetSessionStatus() KeepAliveResult_SessionStatus
func (*KeepAliveResult) ProtoMessage ¶
func (*KeepAliveResult) ProtoMessage()
func (*KeepAliveResult) ProtoReflect ¶
func (x *KeepAliveResult) ProtoReflect() protoreflect.Message
func (*KeepAliveResult) Reset ¶
func (x *KeepAliveResult) Reset()
func (*KeepAliveResult) String ¶
func (x *KeepAliveResult) String() string
type KeepAliveResult_SessionStatus ¶
type KeepAliveResult_SessionStatus int32
const ( KeepAliveResult_SESSION_STATUS_UNSPECIFIED KeepAliveResult_SessionStatus = 0 KeepAliveResult_SESSION_STATUS_READY KeepAliveResult_SessionStatus = 1 KeepAliveResult_SESSION_STATUS_BUSY KeepAliveResult_SessionStatus = 2 )
func (KeepAliveResult_SessionStatus) Descriptor ¶
func (KeepAliveResult_SessionStatus) Descriptor() protoreflect.EnumDescriptor
func (KeepAliveResult_SessionStatus) Enum ¶
func (x KeepAliveResult_SessionStatus) Enum() *KeepAliveResult_SessionStatus
func (KeepAliveResult_SessionStatus) EnumDescriptor
deprecated
func (KeepAliveResult_SessionStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use KeepAliveResult_SessionStatus.Descriptor instead.
func (KeepAliveResult_SessionStatus) Number ¶
func (x KeepAliveResult_SessionStatus) Number() protoreflect.EnumNumber
func (KeepAliveResult_SessionStatus) String ¶
func (x KeepAliveResult_SessionStatus) String() string
func (KeepAliveResult_SessionStatus) Type ¶
func (KeepAliveResult_SessionStatus) Type() protoreflect.EnumType
type KeyRange ¶
type KeyRange struct { // Left border // // Types that are assignable to FromBound: // // *KeyRange_Greater // *KeyRange_GreaterOrEqual FromBound isKeyRange_FromBound `protobuf_oneof:"from_bound"` // Right border // // Types that are assignable to ToBound: // // *KeyRange_Less // *KeyRange_LessOrEqual ToBound isKeyRange_ToBound `protobuf_oneof:"to_bound"` // contains filtered or unexported fields }
func (*KeyRange) Descriptor
deprecated
func (*KeyRange) GetFromBound ¶
func (m *KeyRange) GetFromBound() isKeyRange_FromBound
func (*KeyRange) GetGreater ¶
func (x *KeyRange) GetGreater() *Ydb.TypedValue
func (*KeyRange) GetGreaterOrEqual ¶
func (x *KeyRange) GetGreaterOrEqual() *Ydb.TypedValue
func (*KeyRange) GetLess ¶
func (x *KeyRange) GetLess() *Ydb.TypedValue
func (*KeyRange) GetLessOrEqual ¶
func (x *KeyRange) GetLessOrEqual() *Ydb.TypedValue
func (*KeyRange) GetToBound ¶
func (m *KeyRange) GetToBound() isKeyRange_ToBound
func (*KeyRange) ProtoMessage ¶
func (*KeyRange) ProtoMessage()
func (*KeyRange) ProtoReflect ¶
func (x *KeyRange) ProtoReflect() protoreflect.Message
type KeyRange_Greater ¶
type KeyRange_Greater struct { // Specify if we don't want to include given key Greater *Ydb.TypedValue `protobuf:"bytes,1,opt,name=greater,proto3,oneof"` }
type KeyRange_GreaterOrEqual ¶
type KeyRange_GreaterOrEqual struct { // Specify if we want to include given key GreaterOrEqual *Ydb.TypedValue `protobuf:"bytes,2,opt,name=greater_or_equal,json=greaterOrEqual,proto3,oneof"` }
type KeyRange_Less ¶
type KeyRange_Less struct { // Specify if we don't want to include given key Less *Ydb.TypedValue `protobuf:"bytes,3,opt,name=less,proto3,oneof"` }
type KeyRange_LessOrEqual ¶
type KeyRange_LessOrEqual struct { // Specify if we want to include given key LessOrEqual *Ydb.TypedValue `protobuf:"bytes,4,opt,name=less_or_equal,json=lessOrEqual,proto3,oneof"` }
type OnlineModeSettings ¶
type OnlineModeSettings struct { AllowInconsistentReads bool `` /* 130-byte string literal not displayed */ // contains filtered or unexported fields }
func (*OnlineModeSettings) Descriptor
deprecated
func (*OnlineModeSettings) Descriptor() ([]byte, []int)
Deprecated: Use OnlineModeSettings.ProtoReflect.Descriptor instead.
func (*OnlineModeSettings) GetAllowInconsistentReads ¶
func (x *OnlineModeSettings) GetAllowInconsistentReads() bool
func (*OnlineModeSettings) ProtoMessage ¶
func (*OnlineModeSettings) ProtoMessage()
func (*OnlineModeSettings) ProtoReflect ¶
func (x *OnlineModeSettings) ProtoReflect() protoreflect.Message
func (*OnlineModeSettings) Reset ¶
func (x *OnlineModeSettings) Reset()
func (*OnlineModeSettings) String ¶
func (x *OnlineModeSettings) String() string
type PartitionStats ¶
type PartitionStats struct { // Approximate number of rows in shard RowsEstimate uint64 `protobuf:"varint,1,opt,name=rows_estimate,json=rowsEstimate,proto3" json:"rows_estimate,omitempty"` // Approximate size of shard (bytes) StoreSize uint64 `protobuf:"varint,2,opt,name=store_size,json=storeSize,proto3" json:"store_size,omitempty"` // contains filtered or unexported fields }
func (*PartitionStats) Descriptor
deprecated
func (*PartitionStats) Descriptor() ([]byte, []int)
Deprecated: Use PartitionStats.ProtoReflect.Descriptor instead.
func (*PartitionStats) GetRowsEstimate ¶
func (x *PartitionStats) GetRowsEstimate() uint64
func (*PartitionStats) GetStoreSize ¶
func (x *PartitionStats) GetStoreSize() uint64
func (*PartitionStats) ProtoMessage ¶
func (*PartitionStats) ProtoMessage()
func (*PartitionStats) ProtoReflect ¶
func (x *PartitionStats) ProtoReflect() protoreflect.Message
func (*PartitionStats) Reset ¶
func (x *PartitionStats) Reset()
func (*PartitionStats) String ¶
func (x *PartitionStats) String() string
type PartitioningPolicy ¶
type PartitioningPolicy struct { PresetName string `protobuf:"bytes,1,opt,name=preset_name,json=presetName,proto3" json:"preset_name,omitempty"` AutoPartitioning PartitioningPolicy_AutoPartitioningPolicy `` /* 167-byte string literal not displayed */ // Types that are assignable to Partitions: // // *PartitioningPolicy_UniformPartitions // *PartitioningPolicy_ExplicitPartitions Partitions isPartitioningPolicy_Partitions `protobuf_oneof:"partitions"` // contains filtered or unexported fields }
func (*PartitioningPolicy) Descriptor
deprecated
func (*PartitioningPolicy) Descriptor() ([]byte, []int)
Deprecated: Use PartitioningPolicy.ProtoReflect.Descriptor instead.
func (*PartitioningPolicy) GetAutoPartitioning ¶
func (x *PartitioningPolicy) GetAutoPartitioning() PartitioningPolicy_AutoPartitioningPolicy
func (*PartitioningPolicy) GetExplicitPartitions ¶
func (x *PartitioningPolicy) GetExplicitPartitions() *ExplicitPartitions
func (*PartitioningPolicy) GetPartitions ¶
func (m *PartitioningPolicy) GetPartitions() isPartitioningPolicy_Partitions
func (*PartitioningPolicy) GetPresetName ¶
func (x *PartitioningPolicy) GetPresetName() string
func (*PartitioningPolicy) GetUniformPartitions ¶
func (x *PartitioningPolicy) GetUniformPartitions() uint64
func (*PartitioningPolicy) ProtoMessage ¶
func (*PartitioningPolicy) ProtoMessage()
func (*PartitioningPolicy) ProtoReflect ¶
func (x *PartitioningPolicy) ProtoReflect() protoreflect.Message
func (*PartitioningPolicy) Reset ¶
func (x *PartitioningPolicy) Reset()
func (*PartitioningPolicy) String ¶
func (x *PartitioningPolicy) String() string
type PartitioningPolicyDescription ¶
type PartitioningPolicyDescription struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Labels map[string]string `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
func (*PartitioningPolicyDescription) Descriptor
deprecated
func (*PartitioningPolicyDescription) Descriptor() ([]byte, []int)
Deprecated: Use PartitioningPolicyDescription.ProtoReflect.Descriptor instead.
func (*PartitioningPolicyDescription) GetLabels ¶
func (x *PartitioningPolicyDescription) GetLabels() map[string]string
func (*PartitioningPolicyDescription) GetName ¶
func (x *PartitioningPolicyDescription) GetName() string
func (*PartitioningPolicyDescription) ProtoMessage ¶
func (*PartitioningPolicyDescription) ProtoMessage()
func (*PartitioningPolicyDescription) ProtoReflect ¶
func (x *PartitioningPolicyDescription) ProtoReflect() protoreflect.Message
func (*PartitioningPolicyDescription) Reset ¶
func (x *PartitioningPolicyDescription) Reset()
func (*PartitioningPolicyDescription) String ¶
func (x *PartitioningPolicyDescription) String() string
type PartitioningPolicy_AutoPartitioningPolicy ¶
type PartitioningPolicy_AutoPartitioningPolicy int32
const ( PartitioningPolicy_AUTO_PARTITIONING_POLICY_UNSPECIFIED PartitioningPolicy_AutoPartitioningPolicy = 0 PartitioningPolicy_DISABLED PartitioningPolicy_AutoPartitioningPolicy = 1 PartitioningPolicy_AUTO_SPLIT PartitioningPolicy_AutoPartitioningPolicy = 2 PartitioningPolicy_AUTO_SPLIT_MERGE PartitioningPolicy_AutoPartitioningPolicy = 3 )
func (PartitioningPolicy_AutoPartitioningPolicy) Descriptor ¶
func (PartitioningPolicy_AutoPartitioningPolicy) Descriptor() protoreflect.EnumDescriptor
func (PartitioningPolicy_AutoPartitioningPolicy) EnumDescriptor
deprecated
func (PartitioningPolicy_AutoPartitioningPolicy) EnumDescriptor() ([]byte, []int)
Deprecated: Use PartitioningPolicy_AutoPartitioningPolicy.Descriptor instead.
func (PartitioningPolicy_AutoPartitioningPolicy) Number ¶
func (x PartitioningPolicy_AutoPartitioningPolicy) Number() protoreflect.EnumNumber
func (PartitioningPolicy_AutoPartitioningPolicy) String ¶
func (x PartitioningPolicy_AutoPartitioningPolicy) String() string
func (PartitioningPolicy_AutoPartitioningPolicy) Type ¶
func (PartitioningPolicy_AutoPartitioningPolicy) Type() protoreflect.EnumType
type PartitioningPolicy_ExplicitPartitions ¶
type PartitioningPolicy_ExplicitPartitions struct { // Explicitly specify key values which are used as borders for // created partitions. ExplicitPartitions *ExplicitPartitions `protobuf:"bytes,4,opt,name=explicit_partitions,json=explicitPartitions,proto3,oneof"` }
type PartitioningPolicy_UniformPartitions ¶
type PartitioningPolicy_UniformPartitions struct { // Allows to enable uniform sharding using given shards number. // The first components of primary key must have Uint32/Uint64 type. UniformPartitions uint64 `protobuf:"varint,3,opt,name=uniform_partitions,json=uniformPartitions,proto3,oneof"` }
type PartitioningSettings ¶
type PartitioningSettings struct { // List of columns to partition by PartitionBy []string `protobuf:"bytes,1,rep,name=partition_by,json=partitionBy,proto3" json:"partition_by,omitempty"` // Enable auto partitioning on reaching upper or lower partition size bound PartitioningBySize Ydb.FeatureFlag_Status `` /* 146-byte string literal not displayed */ // Preferred partition size for auto partitioning by size, Mb PartitionSizeMb uint64 `protobuf:"varint,3,opt,name=partition_size_mb,json=partitionSizeMb,proto3" json:"partition_size_mb,omitempty"` // Enable auto partitioning based on load on each partition PartitioningByLoad Ydb.FeatureFlag_Status `` /* 146-byte string literal not displayed */ // Minimum partitions count auto merge would stop working at MinPartitionsCount uint64 `protobuf:"varint,6,opt,name=min_partitions_count,json=minPartitionsCount,proto3" json:"min_partitions_count,omitempty"` // Maximum partitions count auto split would stop working at MaxPartitionsCount uint64 `protobuf:"varint,7,opt,name=max_partitions_count,json=maxPartitionsCount,proto3" json:"max_partitions_count,omitempty"` // contains filtered or unexported fields }
func (*PartitioningSettings) Descriptor
deprecated
func (*PartitioningSettings) Descriptor() ([]byte, []int)
Deprecated: Use PartitioningSettings.ProtoReflect.Descriptor instead.
func (*PartitioningSettings) GetMaxPartitionsCount ¶
func (x *PartitioningSettings) GetMaxPartitionsCount() uint64
func (*PartitioningSettings) GetMinPartitionsCount ¶
func (x *PartitioningSettings) GetMinPartitionsCount() uint64
func (*PartitioningSettings) GetPartitionBy ¶
func (x *PartitioningSettings) GetPartitionBy() []string
func (*PartitioningSettings) GetPartitionSizeMb ¶
func (x *PartitioningSettings) GetPartitionSizeMb() uint64
func (*PartitioningSettings) GetPartitioningByLoad ¶
func (x *PartitioningSettings) GetPartitioningByLoad() Ydb.FeatureFlag_Status
func (*PartitioningSettings) GetPartitioningBySize ¶
func (x *PartitioningSettings) GetPartitioningBySize() Ydb.FeatureFlag_Status
func (*PartitioningSettings) ProtoMessage ¶
func (*PartitioningSettings) ProtoMessage()
func (*PartitioningSettings) ProtoReflect ¶
func (x *PartitioningSettings) ProtoReflect() protoreflect.Message
func (*PartitioningSettings) Reset ¶
func (x *PartitioningSettings) Reset()
func (*PartitioningSettings) String ¶
func (x *PartitioningSettings) String() string
type PrepareDataQueryRequest ¶
type PrepareDataQueryRequest struct { // Session identifier SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` // SQL text YqlText string `protobuf:"bytes,2,opt,name=yql_text,json=yqlText,proto3" json:"yql_text,omitempty"` OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,3,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"` // contains filtered or unexported fields }
Prepare given program to execute
func (*PrepareDataQueryRequest) Descriptor
deprecated
func (*PrepareDataQueryRequest) Descriptor() ([]byte, []int)
Deprecated: Use PrepareDataQueryRequest.ProtoReflect.Descriptor instead.
func (*PrepareDataQueryRequest) GetOperationParams ¶
func (x *PrepareDataQueryRequest) GetOperationParams() *Ydb_Operations.OperationParams
func (*PrepareDataQueryRequest) GetSessionId ¶
func (x *PrepareDataQueryRequest) GetSessionId() string
func (*PrepareDataQueryRequest) GetYqlText ¶
func (x *PrepareDataQueryRequest) GetYqlText() string
func (*PrepareDataQueryRequest) ProtoMessage ¶
func (*PrepareDataQueryRequest) ProtoMessage()
func (*PrepareDataQueryRequest) ProtoReflect ¶
func (x *PrepareDataQueryRequest) ProtoReflect() protoreflect.Message
func (*PrepareDataQueryRequest) Reset ¶
func (x *PrepareDataQueryRequest) Reset()
func (*PrepareDataQueryRequest) String ¶
func (x *PrepareDataQueryRequest) String() string
type PrepareDataQueryResponse ¶
type PrepareDataQueryResponse struct { // Holds PrepareQueryResult in case of successful call Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // contains filtered or unexported fields }
func (*PrepareDataQueryResponse) Descriptor
deprecated
func (*PrepareDataQueryResponse) Descriptor() ([]byte, []int)
Deprecated: Use PrepareDataQueryResponse.ProtoReflect.Descriptor instead.
func (*PrepareDataQueryResponse) GetOperation ¶
func (x *PrepareDataQueryResponse) GetOperation() *Ydb_Operations.Operation
func (*PrepareDataQueryResponse) ProtoMessage ¶
func (*PrepareDataQueryResponse) ProtoMessage()
func (*PrepareDataQueryResponse) ProtoReflect ¶
func (x *PrepareDataQueryResponse) ProtoReflect() protoreflect.Message
func (*PrepareDataQueryResponse) Reset ¶
func (x *PrepareDataQueryResponse) Reset()
func (*PrepareDataQueryResponse) String ¶
func (x *PrepareDataQueryResponse) String() string
type PrepareQueryResult ¶
type PrepareQueryResult struct { // Query id, used to perform ExecuteDataQuery QueryId string `protobuf:"bytes,1,opt,name=query_id,json=queryId,proto3" json:"query_id,omitempty"` // Parameters type, used to fill in parameter values ParametersTypes map[string]*Ydb.Type `` /* 194-byte string literal not displayed */ // contains filtered or unexported fields }
func (*PrepareQueryResult) Descriptor
deprecated
func (*PrepareQueryResult) Descriptor() ([]byte, []int)
Deprecated: Use PrepareQueryResult.ProtoReflect.Descriptor instead.
func (*PrepareQueryResult) GetParametersTypes ¶
func (x *PrepareQueryResult) GetParametersTypes() map[string]*Ydb.Type
func (*PrepareQueryResult) GetQueryId ¶
func (x *PrepareQueryResult) GetQueryId() string
func (*PrepareQueryResult) ProtoMessage ¶
func (*PrepareQueryResult) ProtoMessage()
func (*PrepareQueryResult) ProtoReflect ¶
func (x *PrepareQueryResult) ProtoReflect() protoreflect.Message
func (*PrepareQueryResult) Reset ¶
func (x *PrepareQueryResult) Reset()
func (*PrepareQueryResult) String ¶
func (x *PrepareQueryResult) String() string
type Query ¶
type Query struct { // Text of query or id prepared query // // Types that are assignable to Query: // // *Query_YqlText // *Query_Id Query isQuery_Query `protobuf_oneof:"query"` // contains filtered or unexported fields }
func (*Query) Descriptor
deprecated
func (*Query) GetYqlText ¶
func (*Query) ProtoMessage ¶
func (*Query) ProtoMessage()
func (*Query) ProtoReflect ¶
func (x *Query) ProtoReflect() protoreflect.Message
type QueryCachePolicy ¶
type QueryCachePolicy struct { KeepInCache bool `protobuf:"varint,1,opt,name=keep_in_cache,json=keepInCache,proto3" json:"keep_in_cache,omitempty"` // contains filtered or unexported fields }
func (*QueryCachePolicy) Descriptor
deprecated
func (*QueryCachePolicy) Descriptor() ([]byte, []int)
Deprecated: Use QueryCachePolicy.ProtoReflect.Descriptor instead.
func (*QueryCachePolicy) GetKeepInCache ¶
func (x *QueryCachePolicy) GetKeepInCache() bool
func (*QueryCachePolicy) ProtoMessage ¶
func (*QueryCachePolicy) ProtoMessage()
func (*QueryCachePolicy) ProtoReflect ¶
func (x *QueryCachePolicy) ProtoReflect() protoreflect.Message
func (*QueryCachePolicy) Reset ¶
func (x *QueryCachePolicy) Reset()
func (*QueryCachePolicy) String ¶
func (x *QueryCachePolicy) String() string
type QueryMeta ¶
type QueryMeta struct { // Query identifier Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Type of parameters ParametersTypes map[string]*Ydb.Type `` /* 194-byte string literal not displayed */ // contains filtered or unexported fields }
Holds query id and type of parameters
func (*QueryMeta) Descriptor
deprecated
func (*QueryMeta) GetParametersTypes ¶
func (*QueryMeta) ProtoMessage ¶
func (*QueryMeta) ProtoMessage()
func (*QueryMeta) ProtoReflect ¶
func (x *QueryMeta) ProtoReflect() protoreflect.Message
type QueryStatsCollection ¶
type QueryStatsCollection struct {
// contains filtered or unexported fields
}
Collect and return query execution stats
func (*QueryStatsCollection) Descriptor
deprecated
func (*QueryStatsCollection) Descriptor() ([]byte, []int)
Deprecated: Use QueryStatsCollection.ProtoReflect.Descriptor instead.
func (*QueryStatsCollection) ProtoMessage ¶
func (*QueryStatsCollection) ProtoMessage()
func (*QueryStatsCollection) ProtoReflect ¶
func (x *QueryStatsCollection) ProtoReflect() protoreflect.Message
func (*QueryStatsCollection) Reset ¶
func (x *QueryStatsCollection) Reset()
func (*QueryStatsCollection) String ¶
func (x *QueryStatsCollection) String() string
type QueryStatsCollection_Mode ¶
type QueryStatsCollection_Mode int32
const ( QueryStatsCollection_STATS_COLLECTION_UNSPECIFIED QueryStatsCollection_Mode = 0 QueryStatsCollection_STATS_COLLECTION_NONE QueryStatsCollection_Mode = 1 // Stats collection is disabled QueryStatsCollection_STATS_COLLECTION_BASIC QueryStatsCollection_Mode = 2 // Aggregated stats of reads, updates and deletes per table QueryStatsCollection_STATS_COLLECTION_FULL QueryStatsCollection_Mode = 3 // Add execution stats and plan on top of STATS_COLLECTION_BASIC QueryStatsCollection_STATS_COLLECTION_PROFILE QueryStatsCollection_Mode = 4 // Detailed execution stats including stats for individual tasks and channels )
func (QueryStatsCollection_Mode) Descriptor ¶
func (QueryStatsCollection_Mode) Descriptor() protoreflect.EnumDescriptor
func (QueryStatsCollection_Mode) Enum ¶
func (x QueryStatsCollection_Mode) Enum() *QueryStatsCollection_Mode
func (QueryStatsCollection_Mode) EnumDescriptor
deprecated
func (QueryStatsCollection_Mode) EnumDescriptor() ([]byte, []int)
Deprecated: Use QueryStatsCollection_Mode.Descriptor instead.
func (QueryStatsCollection_Mode) Number ¶
func (x QueryStatsCollection_Mode) Number() protoreflect.EnumNumber
func (QueryStatsCollection_Mode) String ¶
func (x QueryStatsCollection_Mode) String() string
func (QueryStatsCollection_Mode) Type ¶
func (QueryStatsCollection_Mode) Type() protoreflect.EnumType
type Query_Id ¶
type Query_Id struct { // Prepared query id Id string `protobuf:"bytes,2,opt,name=id,proto3,oneof"` }
type Query_YqlText ¶
type Query_YqlText struct { // SQL program YqlText string `protobuf:"bytes,1,opt,name=yql_text,json=yqlText,proto3,oneof"` }
type ReadReplicasSettings ¶
type ReadReplicasSettings struct { // Types that are assignable to Settings: // // *ReadReplicasSettings_PerAzReadReplicasCount // *ReadReplicasSettings_AnyAzReadReplicasCount Settings isReadReplicasSettings_Settings `protobuf_oneof:"settings"` // contains filtered or unexported fields }
func (*ReadReplicasSettings) Descriptor
deprecated
func (*ReadReplicasSettings) Descriptor() ([]byte, []int)
Deprecated: Use ReadReplicasSettings.ProtoReflect.Descriptor instead.
func (*ReadReplicasSettings) GetAnyAzReadReplicasCount ¶
func (x *ReadReplicasSettings) GetAnyAzReadReplicasCount() uint64
func (*ReadReplicasSettings) GetPerAzReadReplicasCount ¶
func (x *ReadReplicasSettings) GetPerAzReadReplicasCount() uint64
func (*ReadReplicasSettings) GetSettings ¶
func (m *ReadReplicasSettings) GetSettings() isReadReplicasSettings_Settings
func (*ReadReplicasSettings) ProtoMessage ¶
func (*ReadReplicasSettings) ProtoMessage()
func (*ReadReplicasSettings) ProtoReflect ¶
func (x *ReadReplicasSettings) ProtoReflect() protoreflect.Message
func (*ReadReplicasSettings) Reset ¶
func (x *ReadReplicasSettings) Reset()
func (*ReadReplicasSettings) String ¶
func (x *ReadReplicasSettings) String() string
type ReadReplicasSettings_AnyAzReadReplicasCount ¶
type ReadReplicasSettings_AnyAzReadReplicasCount struct { // Set total replicas count between all AZs AnyAzReadReplicasCount uint64 `protobuf:"varint,2,opt,name=any_az_read_replicas_count,json=anyAzReadReplicasCount,proto3,oneof"` }
type ReadReplicasSettings_PerAzReadReplicasCount ¶
type ReadReplicasSettings_PerAzReadReplicasCount struct { // Set equal read replicas count for every AZ PerAzReadReplicasCount uint64 `protobuf:"varint,1,opt,name=per_az_read_replicas_count,json=perAzReadReplicasCount,proto3,oneof"` }
type ReadRowsRequest ¶
type ReadRowsRequest struct { // Session identifier SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` // Path to table to read Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` // Keys to read. Must be a list of structs where each stuct is a key // for one requested row and should contain all key columns Keys *Ydb.TypedValue `protobuf:"bytes,3,opt,name=keys,proto3" json:"keys,omitempty"` // Output columns. If empty all columns will be requested Columns []string `protobuf:"bytes,4,rep,name=columns,proto3" json:"columns,omitempty"` // contains filtered or unexported fields }
func (*ReadRowsRequest) Descriptor
deprecated
func (*ReadRowsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReadRowsRequest.ProtoReflect.Descriptor instead.
func (*ReadRowsRequest) GetColumns ¶
func (x *ReadRowsRequest) GetColumns() []string
func (*ReadRowsRequest) GetKeys ¶
func (x *ReadRowsRequest) GetKeys() *Ydb.TypedValue
func (*ReadRowsRequest) GetPath ¶
func (x *ReadRowsRequest) GetPath() string
func (*ReadRowsRequest) GetSessionId ¶
func (x *ReadRowsRequest) GetSessionId() string
func (*ReadRowsRequest) ProtoMessage ¶
func (*ReadRowsRequest) ProtoMessage()
func (*ReadRowsRequest) ProtoReflect ¶
func (x *ReadRowsRequest) ProtoReflect() protoreflect.Message
func (*ReadRowsRequest) Reset ¶
func (x *ReadRowsRequest) Reset()
func (*ReadRowsRequest) String ¶
func (x *ReadRowsRequest) String() string
type ReadRowsResponse ¶
type ReadRowsResponse struct { // Status of request (same as other statuses) Status Ydb.StatusIds_StatusCode `protobuf:"varint,1,opt,name=status,proto3,enum=Ydb.StatusIds_StatusCode" json:"status,omitempty"` // Issues Issues []*Ydb_Issue.IssueMessage `protobuf:"bytes,2,rep,name=issues,proto3" json:"issues,omitempty"` // Result set (same as result of sql request) ResultSet *Ydb.ResultSet `protobuf:"bytes,3,opt,name=result_set,json=resultSet,proto3" json:"result_set,omitempty"` // contains filtered or unexported fields }
func (*ReadRowsResponse) Descriptor
deprecated
func (*ReadRowsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReadRowsResponse.ProtoReflect.Descriptor instead.
func (*ReadRowsResponse) GetIssues ¶
func (x *ReadRowsResponse) GetIssues() []*Ydb_Issue.IssueMessage
func (*ReadRowsResponse) GetResultSet ¶
func (x *ReadRowsResponse) GetResultSet() *Ydb.ResultSet
func (*ReadRowsResponse) GetStatus ¶
func (x *ReadRowsResponse) GetStatus() Ydb.StatusIds_StatusCode
func (*ReadRowsResponse) ProtoMessage ¶
func (*ReadRowsResponse) ProtoMessage()
func (*ReadRowsResponse) ProtoReflect ¶
func (x *ReadRowsResponse) ProtoReflect() protoreflect.Message
func (*ReadRowsResponse) Reset ¶
func (x *ReadRowsResponse) Reset()
func (*ReadRowsResponse) String ¶
func (x *ReadRowsResponse) String() string
type ReadTableRequest ¶
type ReadTableRequest struct { // Session identifier SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` // Path to table to read Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` // Primary key range to read KeyRange *KeyRange `protobuf:"bytes,3,opt,name=key_range,json=keyRange,proto3" json:"key_range,omitempty"` // Output columns Columns []string `protobuf:"bytes,4,rep,name=columns,proto3" json:"columns,omitempty"` // Require ordered reading Ordered bool `protobuf:"varint,5,opt,name=ordered,proto3" json:"ordered,omitempty"` // Limits row count to read RowLimit uint64 `protobuf:"varint,6,opt,name=row_limit,json=rowLimit,proto3" json:"row_limit,omitempty"` // Use a server-side snapshot UseSnapshot Ydb.FeatureFlag_Status `protobuf:"varint,7,opt,name=use_snapshot,json=useSnapshot,proto3,enum=Ydb.FeatureFlag_Status" json:"use_snapshot,omitempty"` // Server-side best-effort policy. Can be used as a hint to limit the size // of batches sent from a server. If both are specified, the server chooses // the smaller one. The limits are not strict, so batch size can be slightly // greater than any of the limits BatchLimitBytes uint64 `protobuf:"varint,8,opt,name=batch_limit_bytes,json=batchLimitBytes,proto3" json:"batch_limit_bytes,omitempty"` BatchLimitRows uint64 `protobuf:"varint,9,opt,name=batch_limit_rows,json=batchLimitRows,proto3" json:"batch_limit_rows,omitempty"` ReturnNotNullDataAsOptional Ydb.FeatureFlag_Status `` /* 180-byte string literal not displayed */ // contains filtered or unexported fields }
Request to read table (without SQL)
func (*ReadTableRequest) Descriptor
deprecated
func (*ReadTableRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReadTableRequest.ProtoReflect.Descriptor instead.
func (*ReadTableRequest) GetBatchLimitBytes ¶
func (x *ReadTableRequest) GetBatchLimitBytes() uint64
func (*ReadTableRequest) GetBatchLimitRows ¶
func (x *ReadTableRequest) GetBatchLimitRows() uint64
func (*ReadTableRequest) GetColumns ¶
func (x *ReadTableRequest) GetColumns() []string
func (*ReadTableRequest) GetKeyRange ¶
func (x *ReadTableRequest) GetKeyRange() *KeyRange
func (*ReadTableRequest) GetOrdered ¶
func (x *ReadTableRequest) GetOrdered() bool
func (*ReadTableRequest) GetPath ¶
func (x *ReadTableRequest) GetPath() string
func (*ReadTableRequest) GetReturnNotNullDataAsOptional ¶
func (x *ReadTableRequest) GetReturnNotNullDataAsOptional() Ydb.FeatureFlag_Status
func (*ReadTableRequest) GetRowLimit ¶
func (x *ReadTableRequest) GetRowLimit() uint64
func (*ReadTableRequest) GetSessionId ¶
func (x *ReadTableRequest) GetSessionId() string
func (*ReadTableRequest) GetUseSnapshot ¶
func (x *ReadTableRequest) GetUseSnapshot() Ydb.FeatureFlag_Status
func (*ReadTableRequest) ProtoMessage ¶
func (*ReadTableRequest) ProtoMessage()
func (*ReadTableRequest) ProtoReflect ¶
func (x *ReadTableRequest) ProtoReflect() protoreflect.Message
func (*ReadTableRequest) Reset ¶
func (x *ReadTableRequest) Reset()
func (*ReadTableRequest) String ¶
func (x *ReadTableRequest) String() string
type ReadTableResponse ¶
type ReadTableResponse struct { // Status of request (same as other statuses) Status Ydb.StatusIds_StatusCode `protobuf:"varint,1,opt,name=status,proto3,enum=Ydb.StatusIds_StatusCode" json:"status,omitempty"` // Issues Issues []*Ydb_Issue.IssueMessage `protobuf:"bytes,2,rep,name=issues,proto3" json:"issues,omitempty"` // Optional snapshot that corresponds to the returned data Snapshot *Ydb.VirtualTimestamp `protobuf:"bytes,4,opt,name=snapshot,proto3" json:"snapshot,omitempty"` // Read table result Result *ReadTableResult `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
ReadTable doesn't use Operation, returns result directly
func (*ReadTableResponse) Descriptor
deprecated
func (*ReadTableResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReadTableResponse.ProtoReflect.Descriptor instead.
func (*ReadTableResponse) GetIssues ¶
func (x *ReadTableResponse) GetIssues() []*Ydb_Issue.IssueMessage
func (*ReadTableResponse) GetResult ¶
func (x *ReadTableResponse) GetResult() *ReadTableResult
func (*ReadTableResponse) GetSnapshot ¶
func (x *ReadTableResponse) GetSnapshot() *Ydb.VirtualTimestamp
func (*ReadTableResponse) GetStatus ¶
func (x *ReadTableResponse) GetStatus() Ydb.StatusIds_StatusCode
func (*ReadTableResponse) ProtoMessage ¶
func (*ReadTableResponse) ProtoMessage()
func (*ReadTableResponse) ProtoReflect ¶
func (x *ReadTableResponse) ProtoReflect() protoreflect.Message
func (*ReadTableResponse) Reset ¶
func (x *ReadTableResponse) Reset()
func (*ReadTableResponse) String ¶
func (x *ReadTableResponse) String() string
type ReadTableResult ¶
type ReadTableResult struct { // Result set (same as result of sql request) ResultSet *Ydb.ResultSet `protobuf:"bytes,1,opt,name=result_set,json=resultSet,proto3" json:"result_set,omitempty"` // contains filtered or unexported fields }
Result of read table request
func (*ReadTableResult) Descriptor
deprecated
func (*ReadTableResult) Descriptor() ([]byte, []int)
Deprecated: Use ReadTableResult.ProtoReflect.Descriptor instead.
func (*ReadTableResult) GetResultSet ¶
func (x *ReadTableResult) GetResultSet() *Ydb.ResultSet
func (*ReadTableResult) ProtoMessage ¶
func (*ReadTableResult) ProtoMessage()
func (*ReadTableResult) ProtoReflect ¶
func (x *ReadTableResult) ProtoReflect() protoreflect.Message
func (*ReadTableResult) Reset ¶
func (x *ReadTableResult) Reset()
func (*ReadTableResult) String ¶
func (x *ReadTableResult) String() string
type RenameIndexItem ¶
type RenameIndexItem struct { // Index name to rename SourceName string `protobuf:"bytes,1,opt,name=source_name,json=sourceName,proto3" json:"source_name,omitempty"` // Target index name DestinationName string `protobuf:"bytes,2,opt,name=destination_name,json=destinationName,proto3" json:"destination_name,omitempty"` // Move options ReplaceDestination bool `protobuf:"varint,3,opt,name=replace_destination,json=replaceDestination,proto3" json:"replace_destination,omitempty"` // contains filtered or unexported fields }
func (*RenameIndexItem) Descriptor
deprecated
func (*RenameIndexItem) Descriptor() ([]byte, []int)
Deprecated: Use RenameIndexItem.ProtoReflect.Descriptor instead.
func (*RenameIndexItem) GetDestinationName ¶
func (x *RenameIndexItem) GetDestinationName() string
func (*RenameIndexItem) GetReplaceDestination ¶
func (x *RenameIndexItem) GetReplaceDestination() bool
func (*RenameIndexItem) GetSourceName ¶
func (x *RenameIndexItem) GetSourceName() string
func (*RenameIndexItem) ProtoMessage ¶
func (*RenameIndexItem) ProtoMessage()
func (*RenameIndexItem) ProtoReflect ¶
func (x *RenameIndexItem) ProtoReflect() protoreflect.Message
func (*RenameIndexItem) Reset ¶
func (x *RenameIndexItem) Reset()
func (*RenameIndexItem) String ¶
func (x *RenameIndexItem) String() string
type RenameTableItem ¶
type RenameTableItem struct { // Full path SourcePath string `protobuf:"bytes,1,opt,name=source_path,json=sourcePath,proto3" json:"source_path,omitempty"` // Full path DestinationPath string `protobuf:"bytes,2,opt,name=destination_path,json=destinationPath,proto3" json:"destination_path,omitempty"` // Move options ReplaceDestination bool `protobuf:"varint,3,opt,name=replace_destination,json=replaceDestination,proto3" json:"replace_destination,omitempty"` // contains filtered or unexported fields }
func (*RenameTableItem) Descriptor
deprecated
func (*RenameTableItem) Descriptor() ([]byte, []int)
Deprecated: Use RenameTableItem.ProtoReflect.Descriptor instead.
func (*RenameTableItem) GetDestinationPath ¶
func (x *RenameTableItem) GetDestinationPath() string
func (*RenameTableItem) GetReplaceDestination ¶
func (x *RenameTableItem) GetReplaceDestination() bool
func (*RenameTableItem) GetSourcePath ¶
func (x *RenameTableItem) GetSourcePath() string
func (*RenameTableItem) ProtoMessage ¶
func (*RenameTableItem) ProtoMessage()
func (*RenameTableItem) ProtoReflect ¶
func (x *RenameTableItem) ProtoReflect() protoreflect.Message
func (*RenameTableItem) Reset ¶
func (x *RenameTableItem) Reset()
func (*RenameTableItem) String ¶
func (x *RenameTableItem) String() string
type RenameTablesRequest ¶
type RenameTablesRequest struct { OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"` // Session identifier SessionId string `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` // Source and destination paths inside RenameTableItem describe rename actions Tables []*RenameTableItem `protobuf:"bytes,3,rep,name=tables,proto3" json:"tables,omitempty"` // contains filtered or unexported fields }
Moves given tables
func (*RenameTablesRequest) Descriptor
deprecated
func (*RenameTablesRequest) Descriptor() ([]byte, []int)
Deprecated: Use RenameTablesRequest.ProtoReflect.Descriptor instead.
func (*RenameTablesRequest) GetOperationParams ¶
func (x *RenameTablesRequest) GetOperationParams() *Ydb_Operations.OperationParams
func (*RenameTablesRequest) GetSessionId ¶
func (x *RenameTablesRequest) GetSessionId() string
func (*RenameTablesRequest) GetTables ¶
func (x *RenameTablesRequest) GetTables() []*RenameTableItem
func (*RenameTablesRequest) ProtoMessage ¶
func (*RenameTablesRequest) ProtoMessage()
func (*RenameTablesRequest) ProtoReflect ¶
func (x *RenameTablesRequest) ProtoReflect() protoreflect.Message
func (*RenameTablesRequest) Reset ¶
func (x *RenameTablesRequest) Reset()
func (*RenameTablesRequest) String ¶
func (x *RenameTablesRequest) String() string
type RenameTablesResponse ¶
type RenameTablesResponse struct { Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // contains filtered or unexported fields }
func (*RenameTablesResponse) Descriptor
deprecated
func (*RenameTablesResponse) Descriptor() ([]byte, []int)
Deprecated: Use RenameTablesResponse.ProtoReflect.Descriptor instead.
func (*RenameTablesResponse) GetOperation ¶
func (x *RenameTablesResponse) GetOperation() *Ydb_Operations.Operation
func (*RenameTablesResponse) ProtoMessage ¶
func (*RenameTablesResponse) ProtoMessage()
func (*RenameTablesResponse) ProtoReflect ¶
func (x *RenameTablesResponse) ProtoReflect() protoreflect.Message
func (*RenameTablesResponse) Reset ¶
func (x *RenameTablesResponse) Reset()
func (*RenameTablesResponse) String ¶
func (x *RenameTablesResponse) String() string
type ReplicationPolicy ¶
type ReplicationPolicy struct { PresetName string `protobuf:"bytes,1,opt,name=preset_name,json=presetName,proto3" json:"preset_name,omitempty"` // If value is non-zero then it specifies a number of read-only // replicas to create for a table. Zero value means preset // setting usage. ReplicasCount uint32 `protobuf:"varint,2,opt,name=replicas_count,json=replicasCount,proto3" json:"replicas_count,omitempty"` // If this feature in enabled then requested number of replicas // will be created in each availability zone. CreatePerAvailabilityZone Ydb.FeatureFlag_Status `` /* 169-byte string literal not displayed */ // If this feature in enabled then read-only replicas can be promoted // to leader. AllowPromotion Ydb.FeatureFlag_Status `` /* 132-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ReplicationPolicy) Descriptor
deprecated
func (*ReplicationPolicy) Descriptor() ([]byte, []int)
Deprecated: Use ReplicationPolicy.ProtoReflect.Descriptor instead.
func (*ReplicationPolicy) GetAllowPromotion ¶
func (x *ReplicationPolicy) GetAllowPromotion() Ydb.FeatureFlag_Status
func (*ReplicationPolicy) GetCreatePerAvailabilityZone ¶
func (x *ReplicationPolicy) GetCreatePerAvailabilityZone() Ydb.FeatureFlag_Status
func (*ReplicationPolicy) GetPresetName ¶
func (x *ReplicationPolicy) GetPresetName() string
func (*ReplicationPolicy) GetReplicasCount ¶
func (x *ReplicationPolicy) GetReplicasCount() uint32
func (*ReplicationPolicy) ProtoMessage ¶
func (*ReplicationPolicy) ProtoMessage()
func (*ReplicationPolicy) ProtoReflect ¶
func (x *ReplicationPolicy) ProtoReflect() protoreflect.Message
func (*ReplicationPolicy) Reset ¶
func (x *ReplicationPolicy) Reset()
func (*ReplicationPolicy) String ¶
func (x *ReplicationPolicy) String() string
type ReplicationPolicyDescription ¶
type ReplicationPolicyDescription struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Labels map[string]string `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ReplicationPolicyDescription) Descriptor
deprecated
func (*ReplicationPolicyDescription) Descriptor() ([]byte, []int)
Deprecated: Use ReplicationPolicyDescription.ProtoReflect.Descriptor instead.
func (*ReplicationPolicyDescription) GetLabels ¶
func (x *ReplicationPolicyDescription) GetLabels() map[string]string
func (*ReplicationPolicyDescription) GetName ¶
func (x *ReplicationPolicyDescription) GetName() string
func (*ReplicationPolicyDescription) ProtoMessage ¶
func (*ReplicationPolicyDescription) ProtoMessage()
func (*ReplicationPolicyDescription) ProtoReflect ¶
func (x *ReplicationPolicyDescription) ProtoReflect() protoreflect.Message
func (*ReplicationPolicyDescription) Reset ¶
func (x *ReplicationPolicyDescription) Reset()
func (*ReplicationPolicyDescription) String ¶
func (x *ReplicationPolicyDescription) String() string
type RollbackTransactionRequest ¶
type RollbackTransactionRequest struct { // Session identifier SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` // Transaction identifier TxId string `protobuf:"bytes,2,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"` OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,3,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"` // contains filtered or unexported fields }
Rollback transaction with given session and tx id
func (*RollbackTransactionRequest) Descriptor
deprecated
func (*RollbackTransactionRequest) Descriptor() ([]byte, []int)
Deprecated: Use RollbackTransactionRequest.ProtoReflect.Descriptor instead.
func (*RollbackTransactionRequest) GetOperationParams ¶
func (x *RollbackTransactionRequest) GetOperationParams() *Ydb_Operations.OperationParams
func (*RollbackTransactionRequest) GetSessionId ¶
func (x *RollbackTransactionRequest) GetSessionId() string
func (*RollbackTransactionRequest) GetTxId ¶
func (x *RollbackTransactionRequest) GetTxId() string
func (*RollbackTransactionRequest) ProtoMessage ¶
func (*RollbackTransactionRequest) ProtoMessage()
func (*RollbackTransactionRequest) ProtoReflect ¶
func (x *RollbackTransactionRequest) ProtoReflect() protoreflect.Message
func (*RollbackTransactionRequest) Reset ¶
func (x *RollbackTransactionRequest) Reset()
func (*RollbackTransactionRequest) String ¶
func (x *RollbackTransactionRequest) String() string
type RollbackTransactionResponse ¶
type RollbackTransactionResponse struct { Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // contains filtered or unexported fields }
func (*RollbackTransactionResponse) Descriptor
deprecated
func (*RollbackTransactionResponse) Descriptor() ([]byte, []int)
Deprecated: Use RollbackTransactionResponse.ProtoReflect.Descriptor instead.
func (*RollbackTransactionResponse) GetOperation ¶
func (x *RollbackTransactionResponse) GetOperation() *Ydb_Operations.Operation
func (*RollbackTransactionResponse) ProtoMessage ¶
func (*RollbackTransactionResponse) ProtoMessage()
func (*RollbackTransactionResponse) ProtoReflect ¶
func (x *RollbackTransactionResponse) ProtoReflect() protoreflect.Message
func (*RollbackTransactionResponse) Reset ¶
func (x *RollbackTransactionResponse) Reset()
func (*RollbackTransactionResponse) String ¶
func (x *RollbackTransactionResponse) String() string
type SequenceDescription ¶
type SequenceDescription struct { Name *string `protobuf:"bytes,1,opt,name=name,proto3,oneof" json:"name,omitempty"` // mandatorys MinValue *int64 `protobuf:"zigzag64,2,opt,name=min_value,json=minValue,proto3,oneof" json:"min_value,omitempty"` // minimum value, defaults to 1 or Min<i64> MaxValue *int64 `protobuf:"zigzag64,3,opt,name=max_value,json=maxValue,proto3,oneof" json:"max_value,omitempty"` // maximum value, defaults to Max<i64> or -1 StartValue *int64 `protobuf:"zigzag64,4,opt,name=start_value,json=startValue,proto3,oneof" json:"start_value,omitempty"` // start value, defaults to min_value Cache *uint64 `protobuf:"varint,5,opt,name=cache,proto3,oneof" json:"cache,omitempty"` // number of items to cache, defaults to 1 Increment *int64 `protobuf:"zigzag64,6,opt,name=increment,proto3,oneof" json:"increment,omitempty"` // increment at each call, defaults to 1 Cycle *bool `protobuf:"varint,7,opt,name=cycle,proto3,oneof" json:"cycle,omitempty"` // true when cycle on overflow is allowed SetVal *SequenceDescription_SetVal `protobuf:"bytes,8,opt,name=set_val,json=setVal,proto3,oneof" json:"set_val,omitempty"` // set_val(next_value, next_used) is executed atomically when creating // contains filtered or unexported fields }
func (*SequenceDescription) Descriptor
deprecated
func (*SequenceDescription) Descriptor() ([]byte, []int)
Deprecated: Use SequenceDescription.ProtoReflect.Descriptor instead.
func (*SequenceDescription) GetCache ¶
func (x *SequenceDescription) GetCache() uint64
func (*SequenceDescription) GetCycle ¶
func (x *SequenceDescription) GetCycle() bool
func (*SequenceDescription) GetIncrement ¶
func (x *SequenceDescription) GetIncrement() int64
func (*SequenceDescription) GetMaxValue ¶
func (x *SequenceDescription) GetMaxValue() int64
func (*SequenceDescription) GetMinValue ¶
func (x *SequenceDescription) GetMinValue() int64
func (*SequenceDescription) GetName ¶
func (x *SequenceDescription) GetName() string
func (*SequenceDescription) GetSetVal ¶
func (x *SequenceDescription) GetSetVal() *SequenceDescription_SetVal
func (*SequenceDescription) GetStartValue ¶
func (x *SequenceDescription) GetStartValue() int64
func (*SequenceDescription) ProtoMessage ¶
func (*SequenceDescription) ProtoMessage()
func (*SequenceDescription) ProtoReflect ¶
func (x *SequenceDescription) ProtoReflect() protoreflect.Message
func (*SequenceDescription) Reset ¶
func (x *SequenceDescription) Reset()
func (*SequenceDescription) String ¶
func (x *SequenceDescription) String() string
type SequenceDescription_SetVal ¶
type SequenceDescription_SetVal struct { NextValue *int64 `protobuf:"zigzag64,1,opt,name=next_value,json=nextValue,proto3,oneof" json:"next_value,omitempty"` NextUsed *bool `protobuf:"varint,2,opt,name=next_used,json=nextUsed,proto3,oneof" json:"next_used,omitempty"` // contains filtered or unexported fields }
func (*SequenceDescription_SetVal) Descriptor
deprecated
func (*SequenceDescription_SetVal) Descriptor() ([]byte, []int)
Deprecated: Use SequenceDescription_SetVal.ProtoReflect.Descriptor instead.
func (*SequenceDescription_SetVal) GetNextUsed ¶
func (x *SequenceDescription_SetVal) GetNextUsed() bool
func (*SequenceDescription_SetVal) GetNextValue ¶
func (x *SequenceDescription_SetVal) GetNextValue() int64
func (*SequenceDescription_SetVal) ProtoMessage ¶
func (*SequenceDescription_SetVal) ProtoMessage()
func (*SequenceDescription_SetVal) ProtoReflect ¶
func (x *SequenceDescription_SetVal) ProtoReflect() protoreflect.Message
func (*SequenceDescription_SetVal) Reset ¶
func (x *SequenceDescription_SetVal) Reset()
func (*SequenceDescription_SetVal) String ¶
func (x *SequenceDescription_SetVal) String() string
type SerializableModeSettings ¶
type SerializableModeSettings struct {
// contains filtered or unexported fields
}
func (*SerializableModeSettings) Descriptor
deprecated
func (*SerializableModeSettings) Descriptor() ([]byte, []int)
Deprecated: Use SerializableModeSettings.ProtoReflect.Descriptor instead.
func (*SerializableModeSettings) ProtoMessage ¶
func (*SerializableModeSettings) ProtoMessage()
func (*SerializableModeSettings) ProtoReflect ¶
func (x *SerializableModeSettings) ProtoReflect() protoreflect.Message
func (*SerializableModeSettings) Reset ¶
func (x *SerializableModeSettings) Reset()
func (*SerializableModeSettings) String ¶
func (x *SerializableModeSettings) String() string
type SnapshotModeSettings ¶
type SnapshotModeSettings struct {
// contains filtered or unexported fields
}
func (*SnapshotModeSettings) Descriptor
deprecated
func (*SnapshotModeSettings) Descriptor() ([]byte, []int)
Deprecated: Use SnapshotModeSettings.ProtoReflect.Descriptor instead.
func (*SnapshotModeSettings) ProtoMessage ¶
func (*SnapshotModeSettings) ProtoMessage()
func (*SnapshotModeSettings) ProtoReflect ¶
func (x *SnapshotModeSettings) ProtoReflect() protoreflect.Message
func (*SnapshotModeSettings) Reset ¶
func (x *SnapshotModeSettings) Reset()
func (*SnapshotModeSettings) String ¶
func (x *SnapshotModeSettings) String() string
type StaleModeSettings ¶
type StaleModeSettings struct {
// contains filtered or unexported fields
}
func (*StaleModeSettings) Descriptor
deprecated
func (*StaleModeSettings) Descriptor() ([]byte, []int)
Deprecated: Use StaleModeSettings.ProtoReflect.Descriptor instead.
func (*StaleModeSettings) ProtoMessage ¶
func (*StaleModeSettings) ProtoMessage()
func (*StaleModeSettings) ProtoReflect ¶
func (x *StaleModeSettings) ProtoReflect() protoreflect.Message
func (*StaleModeSettings) Reset ¶
func (x *StaleModeSettings) Reset()
func (*StaleModeSettings) String ¶
func (x *StaleModeSettings) String() string
type StoragePolicy ¶
type StoragePolicy struct { PresetName string `protobuf:"bytes,1,opt,name=preset_name,json=presetName,proto3" json:"preset_name,omitempty"` Syslog *StoragePool `protobuf:"bytes,2,opt,name=syslog,proto3" json:"syslog,omitempty"` Log *StoragePool `protobuf:"bytes,3,opt,name=log,proto3" json:"log,omitempty"` Data *StoragePool `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"` External *StoragePool `protobuf:"bytes,5,opt,name=external,proto3" json:"external,omitempty"` KeepInMemory Ydb.FeatureFlag_Status `` /* 128-byte string literal not displayed */ ColumnFamilies []*ColumnFamilyPolicy `protobuf:"bytes,7,rep,name=column_families,json=columnFamilies,proto3" json:"column_families,omitempty"` // contains filtered or unexported fields }
func (*StoragePolicy) Descriptor
deprecated
func (*StoragePolicy) Descriptor() ([]byte, []int)
Deprecated: Use StoragePolicy.ProtoReflect.Descriptor instead.
func (*StoragePolicy) GetColumnFamilies ¶
func (x *StoragePolicy) GetColumnFamilies() []*ColumnFamilyPolicy
func (*StoragePolicy) GetData ¶
func (x *StoragePolicy) GetData() *StoragePool
func (*StoragePolicy) GetExternal ¶
func (x *StoragePolicy) GetExternal() *StoragePool
func (*StoragePolicy) GetKeepInMemory ¶
func (x *StoragePolicy) GetKeepInMemory() Ydb.FeatureFlag_Status
func (*StoragePolicy) GetLog ¶
func (x *StoragePolicy) GetLog() *StoragePool
func (*StoragePolicy) GetPresetName ¶
func (x *StoragePolicy) GetPresetName() string
func (*StoragePolicy) GetSyslog ¶
func (x *StoragePolicy) GetSyslog() *StoragePool
func (*StoragePolicy) ProtoMessage ¶
func (*StoragePolicy) ProtoMessage()
func (*StoragePolicy) ProtoReflect ¶
func (x *StoragePolicy) ProtoReflect() protoreflect.Message
func (*StoragePolicy) Reset ¶
func (x *StoragePolicy) Reset()
func (*StoragePolicy) String ¶
func (x *StoragePolicy) String() string
type StoragePolicyDescription ¶
type StoragePolicyDescription struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Labels map[string]string `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
func (*StoragePolicyDescription) Descriptor
deprecated
func (*StoragePolicyDescription) Descriptor() ([]byte, []int)
Deprecated: Use StoragePolicyDescription.ProtoReflect.Descriptor instead.
func (*StoragePolicyDescription) GetLabels ¶
func (x *StoragePolicyDescription) GetLabels() map[string]string
func (*StoragePolicyDescription) GetName ¶
func (x *StoragePolicyDescription) GetName() string
func (*StoragePolicyDescription) ProtoMessage ¶
func (*StoragePolicyDescription) ProtoMessage()
func (*StoragePolicyDescription) ProtoReflect ¶
func (x *StoragePolicyDescription) ProtoReflect() protoreflect.Message
func (*StoragePolicyDescription) Reset ¶
func (x *StoragePolicyDescription) Reset()
func (*StoragePolicyDescription) String ¶
func (x *StoragePolicyDescription) String() string
type StoragePool ¶
type StoragePool struct { Media string `protobuf:"bytes,1,opt,name=media,proto3" json:"media,omitempty"` // contains filtered or unexported fields }
func (*StoragePool) Descriptor
deprecated
func (*StoragePool) Descriptor() ([]byte, []int)
Deprecated: Use StoragePool.ProtoReflect.Descriptor instead.
func (*StoragePool) GetMedia ¶
func (x *StoragePool) GetMedia() string
func (*StoragePool) ProtoMessage ¶
func (*StoragePool) ProtoMessage()
func (*StoragePool) ProtoReflect ¶
func (x *StoragePool) ProtoReflect() protoreflect.Message
func (*StoragePool) Reset ¶
func (x *StoragePool) Reset()
func (*StoragePool) String ¶
func (x *StoragePool) String() string
type StorageSettings ¶
type StorageSettings struct { // This specifies internal channel 0 commit log storage pool // Fastest available storage recommended, negligible amounts of short-lived data TabletCommitLog0 *StoragePool `protobuf:"bytes,1,opt,name=tablet_commit_log0,json=tabletCommitLog0,proto3" json:"tablet_commit_log0,omitempty"` // This specifies internal channel 1 commit log storage pool // Fastest available storage recommended, small amounts of short-lived data TabletCommitLog1 *StoragePool `protobuf:"bytes,2,opt,name=tablet_commit_log1,json=tabletCommitLog1,proto3" json:"tablet_commit_log1,omitempty"` // This specifies external blobs storage pool External *StoragePool `protobuf:"bytes,4,opt,name=external,proto3" json:"external,omitempty"` // Optionally store large values in "external blobs" // WARNING: DO NOT USE // This feature is experimental and should not be used, restrictions apply: // * Table cannot split/merge when this is enabled // * Table cannot be copied or backed up when this is enabled // * This feature cannot be disabled once enabled for a table StoreExternalBlobs Ydb.FeatureFlag_Status `` /* 146-byte string literal not displayed */ // contains filtered or unexported fields }
func (*StorageSettings) Descriptor
deprecated
func (*StorageSettings) Descriptor() ([]byte, []int)
Deprecated: Use StorageSettings.ProtoReflect.Descriptor instead.
func (*StorageSettings) GetExternal ¶
func (x *StorageSettings) GetExternal() *StoragePool
func (*StorageSettings) GetStoreExternalBlobs ¶
func (x *StorageSettings) GetStoreExternalBlobs() Ydb.FeatureFlag_Status
func (*StorageSettings) GetTabletCommitLog0 ¶
func (x *StorageSettings) GetTabletCommitLog0() *StoragePool
func (*StorageSettings) GetTabletCommitLog1 ¶
func (x *StorageSettings) GetTabletCommitLog1() *StoragePool
func (*StorageSettings) ProtoMessage ¶
func (*StorageSettings) ProtoMessage()
func (*StorageSettings) ProtoReflect ¶
func (x *StorageSettings) ProtoReflect() protoreflect.Message
func (*StorageSettings) Reset ¶
func (x *StorageSettings) Reset()
func (*StorageSettings) String ¶
func (x *StorageSettings) String() string
type StoreType ¶
type StoreType int32
func (StoreType) Descriptor ¶
func (StoreType) Descriptor() protoreflect.EnumDescriptor
func (StoreType) EnumDescriptor
deprecated
func (StoreType) Number ¶
func (x StoreType) Number() protoreflect.EnumNumber
func (StoreType) Type ¶
func (StoreType) Type() protoreflect.EnumType
type TableIndex ¶
type TableIndex struct { // Name of index Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // list of columns IndexColumns []string `protobuf:"bytes,2,rep,name=index_columns,json=indexColumns,proto3" json:"index_columns,omitempty"` // Type of index // // Types that are assignable to Type: // // *TableIndex_GlobalIndex // *TableIndex_GlobalAsyncIndex // *TableIndex_GlobalUniqueIndex Type isTableIndex_Type `protobuf_oneof:"type"` // list of columns content to be copied in to index table DataColumns []string `protobuf:"bytes,5,rep,name=data_columns,json=dataColumns,proto3" json:"data_columns,omitempty"` // contains filtered or unexported fields }
Represent secondary index
func (*TableIndex) Descriptor
deprecated
func (*TableIndex) Descriptor() ([]byte, []int)
Deprecated: Use TableIndex.ProtoReflect.Descriptor instead.
func (*TableIndex) GetDataColumns ¶
func (x *TableIndex) GetDataColumns() []string
func (*TableIndex) GetGlobalAsyncIndex ¶
func (x *TableIndex) GetGlobalAsyncIndex() *GlobalAsyncIndex
func (*TableIndex) GetGlobalIndex ¶
func (x *TableIndex) GetGlobalIndex() *GlobalIndex
func (*TableIndex) GetGlobalUniqueIndex ¶
func (x *TableIndex) GetGlobalUniqueIndex() *GlobalUniqueIndex
func (*TableIndex) GetIndexColumns ¶
func (x *TableIndex) GetIndexColumns() []string
func (*TableIndex) GetName ¶
func (x *TableIndex) GetName() string
func (*TableIndex) GetType ¶
func (m *TableIndex) GetType() isTableIndex_Type
func (*TableIndex) ProtoMessage ¶
func (*TableIndex) ProtoMessage()
func (*TableIndex) ProtoReflect ¶
func (x *TableIndex) ProtoReflect() protoreflect.Message
func (*TableIndex) Reset ¶
func (x *TableIndex) Reset()
func (*TableIndex) String ¶
func (x *TableIndex) String() string
type TableIndexDescription ¶
type TableIndexDescription struct { // Name of index Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // list of columns IndexColumns []string `protobuf:"bytes,2,rep,name=index_columns,json=indexColumns,proto3" json:"index_columns,omitempty"` // Type of index // // Types that are assignable to Type: // // *TableIndexDescription_GlobalIndex // *TableIndexDescription_GlobalAsyncIndex // *TableIndexDescription_GlobalUniqueIndex Type isTableIndexDescription_Type `protobuf_oneof:"type"` Status TableIndexDescription_Status `protobuf:"varint,4,opt,name=status,proto3,enum=Ydb.Table.TableIndexDescription_Status" json:"status,omitempty"` // list of columns content to be copied in to index table DataColumns []string `protobuf:"bytes,6,rep,name=data_columns,json=dataColumns,proto3" json:"data_columns,omitempty"` // Size of index data in bytes SizeBytes uint64 `protobuf:"varint,7,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"` // contains filtered or unexported fields }
Represent secondary index with index state
func (*TableIndexDescription) Descriptor
deprecated
func (*TableIndexDescription) Descriptor() ([]byte, []int)
Deprecated: Use TableIndexDescription.ProtoReflect.Descriptor instead.
func (*TableIndexDescription) GetDataColumns ¶
func (x *TableIndexDescription) GetDataColumns() []string
func (*TableIndexDescription) GetGlobalAsyncIndex ¶
func (x *TableIndexDescription) GetGlobalAsyncIndex() *GlobalAsyncIndex
func (*TableIndexDescription) GetGlobalIndex ¶
func (x *TableIndexDescription) GetGlobalIndex() *GlobalIndex
func (*TableIndexDescription) GetGlobalUniqueIndex ¶
func (x *TableIndexDescription) GetGlobalUniqueIndex() *GlobalUniqueIndex
func (*TableIndexDescription) GetIndexColumns ¶
func (x *TableIndexDescription) GetIndexColumns() []string
func (*TableIndexDescription) GetName ¶
func (x *TableIndexDescription) GetName() string
func (*TableIndexDescription) GetSizeBytes ¶
func (x *TableIndexDescription) GetSizeBytes() uint64
func (*TableIndexDescription) GetStatus ¶
func (x *TableIndexDescription) GetStatus() TableIndexDescription_Status
func (*TableIndexDescription) GetType ¶
func (m *TableIndexDescription) GetType() isTableIndexDescription_Type
func (*TableIndexDescription) ProtoMessage ¶
func (*TableIndexDescription) ProtoMessage()
func (*TableIndexDescription) ProtoReflect ¶
func (x *TableIndexDescription) ProtoReflect() protoreflect.Message
func (*TableIndexDescription) Reset ¶
func (x *TableIndexDescription) Reset()
func (*TableIndexDescription) String ¶
func (x *TableIndexDescription) String() string
type TableIndexDescription_GlobalAsyncIndex ¶
type TableIndexDescription_GlobalAsyncIndex struct {
GlobalAsyncIndex *GlobalAsyncIndex `protobuf:"bytes,5,opt,name=global_async_index,json=globalAsyncIndex,proto3,oneof"`
}
type TableIndexDescription_GlobalIndex ¶
type TableIndexDescription_GlobalIndex struct {
GlobalIndex *GlobalIndex `protobuf:"bytes,3,opt,name=global_index,json=globalIndex,proto3,oneof"`
}
type TableIndexDescription_GlobalUniqueIndex ¶
type TableIndexDescription_GlobalUniqueIndex struct {
GlobalUniqueIndex *GlobalUniqueIndex `protobuf:"bytes,8,opt,name=global_unique_index,json=globalUniqueIndex,proto3,oneof"`
}
type TableIndexDescription_Status ¶
type TableIndexDescription_Status int32
const ( TableIndexDescription_STATUS_UNSPECIFIED TableIndexDescription_Status = 0 // Index is ready to use TableIndexDescription_STATUS_READY TableIndexDescription_Status = 1 // index is being built TableIndexDescription_STATUS_BUILDING TableIndexDescription_Status = 2 )
func (TableIndexDescription_Status) Descriptor ¶
func (TableIndexDescription_Status) Descriptor() protoreflect.EnumDescriptor
func (TableIndexDescription_Status) Enum ¶
func (x TableIndexDescription_Status) Enum() *TableIndexDescription_Status
func (TableIndexDescription_Status) EnumDescriptor
deprecated
func (TableIndexDescription_Status) EnumDescriptor() ([]byte, []int)
Deprecated: Use TableIndexDescription_Status.Descriptor instead.
func (TableIndexDescription_Status) Number ¶
func (x TableIndexDescription_Status) Number() protoreflect.EnumNumber
func (TableIndexDescription_Status) String ¶
func (x TableIndexDescription_Status) String() string
func (TableIndexDescription_Status) Type ¶
func (TableIndexDescription_Status) Type() protoreflect.EnumType
type TableIndex_GlobalAsyncIndex ¶
type TableIndex_GlobalAsyncIndex struct {
GlobalAsyncIndex *GlobalAsyncIndex `protobuf:"bytes,4,opt,name=global_async_index,json=globalAsyncIndex,proto3,oneof"`
}
type TableIndex_GlobalIndex ¶
type TableIndex_GlobalIndex struct {
GlobalIndex *GlobalIndex `protobuf:"bytes,3,opt,name=global_index,json=globalIndex,proto3,oneof"`
}
type TableIndex_GlobalUniqueIndex ¶
type TableIndex_GlobalUniqueIndex struct {
GlobalUniqueIndex *GlobalUniqueIndex `protobuf:"bytes,6,opt,name=global_unique_index,json=globalUniqueIndex,proto3,oneof"`
}
type TableProfile ¶
type TableProfile struct { PresetName string `protobuf:"bytes,1,opt,name=preset_name,json=presetName,proto3" json:"preset_name,omitempty"` StoragePolicy *StoragePolicy `protobuf:"bytes,2,opt,name=storage_policy,json=storagePolicy,proto3" json:"storage_policy,omitempty"` CompactionPolicy *CompactionPolicy `protobuf:"bytes,3,opt,name=compaction_policy,json=compactionPolicy,proto3" json:"compaction_policy,omitempty"` PartitioningPolicy *PartitioningPolicy `protobuf:"bytes,4,opt,name=partitioning_policy,json=partitioningPolicy,proto3" json:"partitioning_policy,omitempty"` ExecutionPolicy *ExecutionPolicy `protobuf:"bytes,5,opt,name=execution_policy,json=executionPolicy,proto3" json:"execution_policy,omitempty"` ReplicationPolicy *ReplicationPolicy `protobuf:"bytes,6,opt,name=replication_policy,json=replicationPolicy,proto3" json:"replication_policy,omitempty"` CachingPolicy *CachingPolicy `protobuf:"bytes,7,opt,name=caching_policy,json=cachingPolicy,proto3" json:"caching_policy,omitempty"` // contains filtered or unexported fields }
func (*TableProfile) Descriptor
deprecated
func (*TableProfile) Descriptor() ([]byte, []int)
Deprecated: Use TableProfile.ProtoReflect.Descriptor instead.
func (*TableProfile) GetCachingPolicy ¶
func (x *TableProfile) GetCachingPolicy() *CachingPolicy
func (*TableProfile) GetCompactionPolicy ¶
func (x *TableProfile) GetCompactionPolicy() *CompactionPolicy
func (*TableProfile) GetExecutionPolicy ¶
func (x *TableProfile) GetExecutionPolicy() *ExecutionPolicy
func (*TableProfile) GetPartitioningPolicy ¶
func (x *TableProfile) GetPartitioningPolicy() *PartitioningPolicy
func (*TableProfile) GetPresetName ¶
func (x *TableProfile) GetPresetName() string
func (*TableProfile) GetReplicationPolicy ¶
func (x *TableProfile) GetReplicationPolicy() *ReplicationPolicy
func (*TableProfile) GetStoragePolicy ¶
func (x *TableProfile) GetStoragePolicy() *StoragePolicy
func (*TableProfile) ProtoMessage ¶
func (*TableProfile) ProtoMessage()
func (*TableProfile) ProtoReflect ¶
func (x *TableProfile) ProtoReflect() protoreflect.Message
func (*TableProfile) Reset ¶
func (x *TableProfile) Reset()
func (*TableProfile) String ¶
func (x *TableProfile) String() string
type TableProfileDescription ¶
type TableProfileDescription struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Labels map[string]string `` /* 153-byte string literal not displayed */ DefaultStoragePolicy string `protobuf:"bytes,3,opt,name=default_storage_policy,json=defaultStoragePolicy,proto3" json:"default_storage_policy,omitempty"` AllowedStoragePolicies []string `` /* 129-byte string literal not displayed */ DefaultCompactionPolicy string `` /* 132-byte string literal not displayed */ AllowedCompactionPolicies []string `` /* 138-byte string literal not displayed */ DefaultPartitioningPolicy string `` /* 138-byte string literal not displayed */ AllowedPartitioningPolicies []string `` /* 144-byte string literal not displayed */ DefaultExecutionPolicy string `` /* 129-byte string literal not displayed */ AllowedExecutionPolicies []string `` /* 136-byte string literal not displayed */ DefaultReplicationPolicy string `` /* 136-byte string literal not displayed */ AllowedReplicationPolicies []string `` /* 142-byte string literal not displayed */ DefaultCachingPolicy string `protobuf:"bytes,13,opt,name=default_caching_policy,json=defaultCachingPolicy,proto3" json:"default_caching_policy,omitempty"` AllowedCachingPolicies []string `` /* 130-byte string literal not displayed */ // contains filtered or unexported fields }
func (*TableProfileDescription) Descriptor
deprecated
func (*TableProfileDescription) Descriptor() ([]byte, []int)
Deprecated: Use TableProfileDescription.ProtoReflect.Descriptor instead.
func (*TableProfileDescription) GetAllowedCachingPolicies ¶
func (x *TableProfileDescription) GetAllowedCachingPolicies() []string
func (*TableProfileDescription) GetAllowedCompactionPolicies ¶
func (x *TableProfileDescription) GetAllowedCompactionPolicies() []string
func (*TableProfileDescription) GetAllowedExecutionPolicies ¶
func (x *TableProfileDescription) GetAllowedExecutionPolicies() []string
func (*TableProfileDescription) GetAllowedPartitioningPolicies ¶
func (x *TableProfileDescription) GetAllowedPartitioningPolicies() []string
func (*TableProfileDescription) GetAllowedReplicationPolicies ¶
func (x *TableProfileDescription) GetAllowedReplicationPolicies() []string
func (*TableProfileDescription) GetAllowedStoragePolicies ¶
func (x *TableProfileDescription) GetAllowedStoragePolicies() []string
func (*TableProfileDescription) GetDefaultCachingPolicy ¶
func (x *TableProfileDescription) GetDefaultCachingPolicy() string
func (*TableProfileDescription) GetDefaultCompactionPolicy ¶
func (x *TableProfileDescription) GetDefaultCompactionPolicy() string
func (*TableProfileDescription) GetDefaultExecutionPolicy ¶
func (x *TableProfileDescription) GetDefaultExecutionPolicy() string
func (*TableProfileDescription) GetDefaultPartitioningPolicy ¶
func (x *TableProfileDescription) GetDefaultPartitioningPolicy() string
func (*TableProfileDescription) GetDefaultReplicationPolicy ¶
func (x *TableProfileDescription) GetDefaultReplicationPolicy() string
func (*TableProfileDescription) GetDefaultStoragePolicy ¶
func (x *TableProfileDescription) GetDefaultStoragePolicy() string
func (*TableProfileDescription) GetLabels ¶
func (x *TableProfileDescription) GetLabels() map[string]string
func (*TableProfileDescription) GetName ¶
func (x *TableProfileDescription) GetName() string
func (*TableProfileDescription) ProtoMessage ¶
func (*TableProfileDescription) ProtoMessage()
func (*TableProfileDescription) ProtoReflect ¶
func (x *TableProfileDescription) ProtoReflect() protoreflect.Message
func (*TableProfileDescription) Reset ¶
func (x *TableProfileDescription) Reset()
func (*TableProfileDescription) String ¶
func (x *TableProfileDescription) String() string
type TableStats ¶
type TableStats struct { // Stats for each partition PartitionStats []*PartitionStats `protobuf:"bytes,1,rep,name=partition_stats,json=partitionStats,proto3" json:"partition_stats,omitempty"` // Approximate number of rows in table RowsEstimate uint64 `protobuf:"varint,2,opt,name=rows_estimate,json=rowsEstimate,proto3" json:"rows_estimate,omitempty"` // Approximate size of table (bytes) StoreSize uint64 `protobuf:"varint,3,opt,name=store_size,json=storeSize,proto3" json:"store_size,omitempty"` // Number of partitions in table Partitions uint64 `protobuf:"varint,4,opt,name=partitions,proto3" json:"partitions,omitempty"` // Timestamp of table creation CreationTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=creation_time,json=creationTime,proto3" json:"creation_time,omitempty"` // Timestamp of last modification ModificationTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=modification_time,json=modificationTime,proto3" json:"modification_time,omitempty"` // contains filtered or unexported fields }
func (*TableStats) Descriptor
deprecated
func (*TableStats) Descriptor() ([]byte, []int)
Deprecated: Use TableStats.ProtoReflect.Descriptor instead.
func (*TableStats) GetCreationTime ¶
func (x *TableStats) GetCreationTime() *timestamppb.Timestamp
func (*TableStats) GetModificationTime ¶
func (x *TableStats) GetModificationTime() *timestamppb.Timestamp
func (*TableStats) GetPartitionStats ¶
func (x *TableStats) GetPartitionStats() []*PartitionStats
func (*TableStats) GetPartitions ¶
func (x *TableStats) GetPartitions() uint64
func (*TableStats) GetRowsEstimate ¶
func (x *TableStats) GetRowsEstimate() uint64
func (*TableStats) GetStoreSize ¶
func (x *TableStats) GetStoreSize() uint64
func (*TableStats) ProtoMessage ¶
func (*TableStats) ProtoMessage()
func (*TableStats) ProtoReflect ¶
func (x *TableStats) ProtoReflect() protoreflect.Message
func (*TableStats) Reset ¶
func (x *TableStats) Reset()
func (*TableStats) String ¶
func (x *TableStats) String() string
type TransactionControl ¶
type TransactionControl struct { // Types that are assignable to TxSelector: // // *TransactionControl_TxId // *TransactionControl_BeginTx TxSelector isTransactionControl_TxSelector `protobuf_oneof:"tx_selector"` CommitTx bool `protobuf:"varint,10,opt,name=commit_tx,json=commitTx,proto3" json:"commit_tx,omitempty"` // contains filtered or unexported fields }
func (*TransactionControl) Descriptor
deprecated
func (*TransactionControl) Descriptor() ([]byte, []int)
Deprecated: Use TransactionControl.ProtoReflect.Descriptor instead.
func (*TransactionControl) GetBeginTx ¶
func (x *TransactionControl) GetBeginTx() *TransactionSettings
func (*TransactionControl) GetCommitTx ¶
func (x *TransactionControl) GetCommitTx() bool
func (*TransactionControl) GetTxId ¶
func (x *TransactionControl) GetTxId() string
func (*TransactionControl) GetTxSelector ¶
func (m *TransactionControl) GetTxSelector() isTransactionControl_TxSelector
func (*TransactionControl) ProtoMessage ¶
func (*TransactionControl) ProtoMessage()
func (*TransactionControl) ProtoReflect ¶
func (x *TransactionControl) ProtoReflect() protoreflect.Message
func (*TransactionControl) Reset ¶
func (x *TransactionControl) Reset()
func (*TransactionControl) String ¶
func (x *TransactionControl) String() string
type TransactionControl_BeginTx ¶
type TransactionControl_BeginTx struct {
BeginTx *TransactionSettings `protobuf:"bytes,2,opt,name=begin_tx,json=beginTx,proto3,oneof"`
}
type TransactionControl_TxId ¶
type TransactionControl_TxId struct {
TxId string `protobuf:"bytes,1,opt,name=tx_id,json=txId,proto3,oneof"`
}
type TransactionMeta ¶
type TransactionMeta struct { // Transaction identifier Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
Holds transaction id
func (*TransactionMeta) Descriptor
deprecated
func (*TransactionMeta) Descriptor() ([]byte, []int)
Deprecated: Use TransactionMeta.ProtoReflect.Descriptor instead.
func (*TransactionMeta) GetId ¶
func (x *TransactionMeta) GetId() string
func (*TransactionMeta) ProtoMessage ¶
func (*TransactionMeta) ProtoMessage()
func (*TransactionMeta) ProtoReflect ¶
func (x *TransactionMeta) ProtoReflect() protoreflect.Message
func (*TransactionMeta) Reset ¶
func (x *TransactionMeta) Reset()
func (*TransactionMeta) String ¶
func (x *TransactionMeta) String() string
type TransactionSettings ¶
type TransactionSettings struct { // Types that are assignable to TxMode: // // *TransactionSettings_SerializableReadWrite // *TransactionSettings_OnlineReadOnly // *TransactionSettings_StaleReadOnly // *TransactionSettings_SnapshotReadOnly TxMode isTransactionSettings_TxMode `protobuf_oneof:"tx_mode"` // contains filtered or unexported fields }
func (*TransactionSettings) Descriptor
deprecated
func (*TransactionSettings) Descriptor() ([]byte, []int)
Deprecated: Use TransactionSettings.ProtoReflect.Descriptor instead.
func (*TransactionSettings) GetOnlineReadOnly ¶
func (x *TransactionSettings) GetOnlineReadOnly() *OnlineModeSettings
func (*TransactionSettings) GetSerializableReadWrite ¶
func (x *TransactionSettings) GetSerializableReadWrite() *SerializableModeSettings
func (*TransactionSettings) GetSnapshotReadOnly ¶
func (x *TransactionSettings) GetSnapshotReadOnly() *SnapshotModeSettings
func (*TransactionSettings) GetStaleReadOnly ¶
func (x *TransactionSettings) GetStaleReadOnly() *StaleModeSettings
func (*TransactionSettings) GetTxMode ¶
func (m *TransactionSettings) GetTxMode() isTransactionSettings_TxMode
func (*TransactionSettings) ProtoMessage ¶
func (*TransactionSettings) ProtoMessage()
func (*TransactionSettings) ProtoReflect ¶
func (x *TransactionSettings) ProtoReflect() protoreflect.Message
func (*TransactionSettings) Reset ¶
func (x *TransactionSettings) Reset()
func (*TransactionSettings) String ¶
func (x *TransactionSettings) String() string
type TransactionSettings_OnlineReadOnly ¶
type TransactionSettings_OnlineReadOnly struct {
OnlineReadOnly *OnlineModeSettings `protobuf:"bytes,2,opt,name=online_read_only,json=onlineReadOnly,proto3,oneof"`
}
type TransactionSettings_SerializableReadWrite ¶
type TransactionSettings_SerializableReadWrite struct {
SerializableReadWrite *SerializableModeSettings `protobuf:"bytes,1,opt,name=serializable_read_write,json=serializableReadWrite,proto3,oneof"`
}
type TransactionSettings_SnapshotReadOnly ¶
type TransactionSettings_SnapshotReadOnly struct {
SnapshotReadOnly *SnapshotModeSettings `protobuf:"bytes,4,opt,name=snapshot_read_only,json=snapshotReadOnly,proto3,oneof"`
}
type TransactionSettings_StaleReadOnly ¶
type TransactionSettings_StaleReadOnly struct {
StaleReadOnly *StaleModeSettings `protobuf:"bytes,3,opt,name=stale_read_only,json=staleReadOnly,proto3,oneof"`
}
type TtlSettings ¶
type TtlSettings struct { // Types that are assignable to Mode: // // *TtlSettings_DateTypeColumn // *TtlSettings_ValueSinceUnixEpoch Mode isTtlSettings_Mode `protobuf_oneof:"mode"` // How often to run BRO on the same partition. // BRO will not be started more often, but may be started less often. RunIntervalSeconds uint32 `protobuf:"varint,3,opt,name=run_interval_seconds,json=runIntervalSeconds,proto3" json:"run_interval_seconds,omitempty"` // contains filtered or unexported fields }
func (*TtlSettings) Descriptor
deprecated
func (*TtlSettings) Descriptor() ([]byte, []int)
Deprecated: Use TtlSettings.ProtoReflect.Descriptor instead.
func (*TtlSettings) GetDateTypeColumn ¶
func (x *TtlSettings) GetDateTypeColumn() *DateTypeColumnModeSettings
func (*TtlSettings) GetMode ¶
func (m *TtlSettings) GetMode() isTtlSettings_Mode
func (*TtlSettings) GetRunIntervalSeconds ¶
func (x *TtlSettings) GetRunIntervalSeconds() uint32
func (*TtlSettings) GetValueSinceUnixEpoch ¶
func (x *TtlSettings) GetValueSinceUnixEpoch() *ValueSinceUnixEpochModeSettings
func (*TtlSettings) ProtoMessage ¶
func (*TtlSettings) ProtoMessage()
func (*TtlSettings) ProtoReflect ¶
func (x *TtlSettings) ProtoReflect() protoreflect.Message
func (*TtlSettings) Reset ¶
func (x *TtlSettings) Reset()
func (*TtlSettings) String ¶
func (x *TtlSettings) String() string
type TtlSettings_DateTypeColumn ¶
type TtlSettings_DateTypeColumn struct {
DateTypeColumn *DateTypeColumnModeSettings `protobuf:"bytes,1,opt,name=date_type_column,json=dateTypeColumn,proto3,oneof"`
}
type TtlSettings_ValueSinceUnixEpoch ¶
type TtlSettings_ValueSinceUnixEpoch struct {
ValueSinceUnixEpoch *ValueSinceUnixEpochModeSettings `protobuf:"bytes,2,opt,name=value_since_unix_epoch,json=valueSinceUnixEpoch,proto3,oneof"`
}
type ValueSinceUnixEpochModeSettings ¶
type ValueSinceUnixEpochModeSettings struct { // The column type must be one of: // - Uint32 // - Uint64 // - DyNumber ColumnName string `protobuf:"bytes,1,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"` // Interpretation of the value stored in <column_name> ColumnUnit ValueSinceUnixEpochModeSettings_Unit `` /* 144-byte string literal not displayed */ // This option is always interpreted as seconds regardless of the // <column_unit> value. ExpireAfterSeconds uint32 `protobuf:"varint,3,opt,name=expire_after_seconds,json=expireAfterSeconds,proto3" json:"expire_after_seconds,omitempty"` // contains filtered or unexported fields }
func (*ValueSinceUnixEpochModeSettings) Descriptor
deprecated
func (*ValueSinceUnixEpochModeSettings) Descriptor() ([]byte, []int)
Deprecated: Use ValueSinceUnixEpochModeSettings.ProtoReflect.Descriptor instead.
func (*ValueSinceUnixEpochModeSettings) GetColumnName ¶
func (x *ValueSinceUnixEpochModeSettings) GetColumnName() string
func (*ValueSinceUnixEpochModeSettings) GetColumnUnit ¶
func (x *ValueSinceUnixEpochModeSettings) GetColumnUnit() ValueSinceUnixEpochModeSettings_Unit
func (*ValueSinceUnixEpochModeSettings) GetExpireAfterSeconds ¶
func (x *ValueSinceUnixEpochModeSettings) GetExpireAfterSeconds() uint32
func (*ValueSinceUnixEpochModeSettings) ProtoMessage ¶
func (*ValueSinceUnixEpochModeSettings) ProtoMessage()
func (*ValueSinceUnixEpochModeSettings) ProtoReflect ¶
func (x *ValueSinceUnixEpochModeSettings) ProtoReflect() protoreflect.Message
func (*ValueSinceUnixEpochModeSettings) Reset ¶
func (x *ValueSinceUnixEpochModeSettings) Reset()
func (*ValueSinceUnixEpochModeSettings) String ¶
func (x *ValueSinceUnixEpochModeSettings) String() string
type ValueSinceUnixEpochModeSettings_Unit ¶
type ValueSinceUnixEpochModeSettings_Unit int32
const ( ValueSinceUnixEpochModeSettings_UNIT_UNSPECIFIED ValueSinceUnixEpochModeSettings_Unit = 0 ValueSinceUnixEpochModeSettings_UNIT_SECONDS ValueSinceUnixEpochModeSettings_Unit = 1 ValueSinceUnixEpochModeSettings_UNIT_MILLISECONDS ValueSinceUnixEpochModeSettings_Unit = 2 ValueSinceUnixEpochModeSettings_UNIT_MICROSECONDS ValueSinceUnixEpochModeSettings_Unit = 3 ValueSinceUnixEpochModeSettings_UNIT_NANOSECONDS ValueSinceUnixEpochModeSettings_Unit = 4 )
func (ValueSinceUnixEpochModeSettings_Unit) Descriptor ¶
func (ValueSinceUnixEpochModeSettings_Unit) Descriptor() protoreflect.EnumDescriptor
func (ValueSinceUnixEpochModeSettings_Unit) Enum ¶
func (x ValueSinceUnixEpochModeSettings_Unit) Enum() *ValueSinceUnixEpochModeSettings_Unit
func (ValueSinceUnixEpochModeSettings_Unit) EnumDescriptor
deprecated
func (ValueSinceUnixEpochModeSettings_Unit) EnumDescriptor() ([]byte, []int)
Deprecated: Use ValueSinceUnixEpochModeSettings_Unit.Descriptor instead.
func (ValueSinceUnixEpochModeSettings_Unit) Number ¶
func (x ValueSinceUnixEpochModeSettings_Unit) Number() protoreflect.EnumNumber
func (ValueSinceUnixEpochModeSettings_Unit) String ¶
func (x ValueSinceUnixEpochModeSettings_Unit) String() string
func (ValueSinceUnixEpochModeSettings_Unit) Type ¶
func (ValueSinceUnixEpochModeSettings_Unit) Type() protoreflect.EnumType