Ydb_Table

package
v0.0.0-...-ea1f632 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 12, 2024 License: Apache-2.0 Imports: 14 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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_DropTiering

type AlterTableRequest_DropTiering struct {
	DropTiering *emptypb.Empty `protobuf:"bytes,23,opt,name=drop_tiering,json=dropTiering,proto3,oneof"`
}

type AlterTableRequest_DropTtlSettings

type AlterTableRequest_DropTtlSettings struct {
	DropTtlSettings *emptypb.Empty `protobuf:"bytes,8,opt,name=drop_ttl_settings,json=dropTtlSettings,proto3,oneof"`
}

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 (*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 (*ChangefeedDescription) GetMode

func (*ChangefeedDescription) GetName

func (x *ChangefeedDescription) GetName() string

func (*ChangefeedDescription) GetResolvedTimestampsInterval

func (x *ChangefeedDescription) GetResolvedTimestampsInterval() *durationpb.Duration

func (*ChangefeedDescription) GetState

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) Enum

func (ChangefeedDescription_State) EnumDescriptor deprecated

func (ChangefeedDescription_State) EnumDescriptor() ([]byte, []int)

Deprecated: Use ChangefeedDescription_State.Descriptor instead.

func (ChangefeedDescription_State) Number

func (ChangefeedDescription_State) String

func (ChangefeedDescription_State) Type

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) Enum

func (ChangefeedFormat_Format) EnumDescriptor deprecated

func (ChangefeedFormat_Format) EnumDescriptor() ([]byte, []int)

Deprecated: Use ChangefeedFormat_Format.Descriptor instead.

func (ChangefeedFormat_Format) Number

func (ChangefeedFormat_Format) String

func (x ChangefeedFormat_Format) String() string

func (ChangefeedFormat_Format) Type

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) Enum

func (ChangefeedMode_Mode) EnumDescriptor deprecated

func (ChangefeedMode_Mode) EnumDescriptor() ([]byte, []int)

Deprecated: Use ChangefeedMode_Mode.Descriptor instead.

func (ChangefeedMode_Mode) Number

func (ChangefeedMode_Mode) String

func (x ChangefeedMode_Mode) String() string

func (ChangefeedMode_Mode) Type

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 (*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) Enum

func (ColumnFamilyPolicy_Compression) EnumDescriptor deprecated

func (ColumnFamilyPolicy_Compression) EnumDescriptor() ([]byte, []int)

Deprecated: Use ColumnFamilyPolicy_Compression.Descriptor instead.

func (ColumnFamilyPolicy_Compression) Number

func (ColumnFamilyPolicy_Compression) String

func (ColumnFamilyPolicy_Compression) Type

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) Enum

func (ColumnFamily_Compression) EnumDescriptor deprecated

func (ColumnFamily_Compression) EnumDescriptor() ([]byte, []int)

Deprecated: Use ColumnFamily_Compression.Descriptor instead.

func (ColumnFamily_Compression) Number

func (ColumnFamily_Compression) String

func (x ColumnFamily_Compression) String() string

func (ColumnFamily_Compression) Type

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 (*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 (*CommitTransactionResponse) ProtoMessage

func (*CommitTransactionResponse) ProtoMessage()

func (*CommitTransactionResponse) ProtoReflect

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 (*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 (*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 (*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 (*DescribeTableOptionsRequest) ProtoMessage

func (*DescribeTableOptionsRequest) ProtoMessage()

func (*DescribeTableOptionsRequest) ProtoReflect

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 (*DescribeTableOptionsResponse) ProtoMessage

func (*DescribeTableOptionsResponse) ProtoMessage()

func (*DescribeTableOptionsResponse) ProtoReflect

func (*DescribeTableOptionsResponse) Reset

func (x *DescribeTableOptionsResponse) Reset()

func (*DescribeTableOptionsResponse) 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 (*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 */
	// Includes shard -> node id maping (required include_partition_stats)
	IncludeShardNodesInfo bool `` /* 129-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) GetIncludeShardNodesInfo

func (x *DescribeTableRequest) GetIncludeShardNodesInfo() 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 (*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 (*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 (*ExecuteScanQueryPartialResponse) GetResult

func (*ExecuteScanQueryPartialResponse) GetStatus

func (*ExecuteScanQueryPartialResponse) ProtoMessage

func (*ExecuteScanQueryPartialResponse) ProtoMessage()

func (*ExecuteScanQueryPartialResponse) ProtoReflect

func (*ExecuteScanQueryPartialResponse) Reset

func (*ExecuteScanQueryPartialResponse) 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 (*ExecuteScanQueryPartialResult) GetResultSet

func (x *ExecuteScanQueryPartialResult) GetResultSet() *Ydb.ResultSet

func (*ExecuteScanQueryPartialResult) ProtoMessage

func (*ExecuteScanQueryPartialResult) ProtoMessage()

func (*ExecuteScanQueryPartialResult) ProtoReflect

func (*ExecuteScanQueryPartialResult) Reset

func (x *ExecuteScanQueryPartialResult) Reset()

func (*ExecuteScanQueryPartialResult) 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 (*ExecuteScanQueryRequest) GetMode

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) Enum

func (ExecuteScanQueryRequest_Mode) EnumDescriptor deprecated

func (ExecuteScanQueryRequest_Mode) EnumDescriptor() ([]byte, []int)

Deprecated: Use ExecuteScanQueryRequest_Mode.Descriptor instead.

func (ExecuteScanQueryRequest_Mode) Number

func (ExecuteScanQueryRequest_Mode) String

func (ExecuteScanQueryRequest_Mode) Type

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 (*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 (*ExecuteSchemeQueryResponse) ProtoMessage

func (*ExecuteSchemeQueryResponse) ProtoMessage()

func (*ExecuteSchemeQueryResponse) ProtoReflect

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 (*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 (*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 (*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) Enum

func (IndexBuildState_State) EnumDescriptor deprecated

func (IndexBuildState_State) EnumDescriptor() ([]byte, []int)

Deprecated: Use IndexBuildState_State.Descriptor instead.

func (IndexBuildState_State) Number

func (IndexBuildState_State) String

func (x IndexBuildState_State) String() string

func (IndexBuildState_State) Type

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) Enum

func (KeepAliveResult_SessionStatus) EnumDescriptor deprecated

func (KeepAliveResult_SessionStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use KeepAliveResult_SessionStatus.Descriptor instead.

func (KeepAliveResult_SessionStatus) Number

func (KeepAliveResult_SessionStatus) String

func (KeepAliveResult_SessionStatus) Type

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) Descriptor() ([]byte, []int)

Deprecated: Use KeyRange.ProtoReflect.Descriptor instead.

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

func (*KeyRange) Reset

func (x *KeyRange) Reset()

func (*KeyRange) String

func (x *KeyRange) String() string

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"`
	// id of node that serve shard key range
	LeaderNodeId uint32 `protobuf:"varint,3,opt,name=leader_node_id,json=leaderNodeId,proto3" json:"leader_node_id,omitempty"`
	// contains filtered or unexported fields
}

func (*PartitionStats) Descriptor deprecated

func (*PartitionStats) Descriptor() ([]byte, []int)

Deprecated: Use PartitionStats.ProtoReflect.Descriptor instead.

func (*PartitionStats) GetLeaderNodeId

func (x *PartitionStats) GetLeaderNodeId() uint32

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 (*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 (*PartitioningPolicyDescription) ProtoMessage

func (*PartitioningPolicyDescription) ProtoMessage()

func (*PartitioningPolicyDescription) ProtoReflect

func (*PartitioningPolicyDescription) Reset

func (x *PartitioningPolicyDescription) Reset()

func (*PartitioningPolicyDescription) 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) Enum

func (PartitioningPolicy_AutoPartitioningPolicy) EnumDescriptor deprecated

func (PartitioningPolicy_AutoPartitioningPolicy) EnumDescriptor() ([]byte, []int)

Deprecated: Use PartitioningPolicy_AutoPartitioningPolicy.Descriptor instead.

func (PartitioningPolicy_AutoPartitioningPolicy) Number

func (PartitioningPolicy_AutoPartitioningPolicy) String

func (PartitioningPolicy_AutoPartitioningPolicy) Type

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 (*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) Descriptor() ([]byte, []int)

Deprecated: Use Query.ProtoReflect.Descriptor instead.

func (*Query) GetId

func (x *Query) GetId() string

func (*Query) GetQuery

func (m *Query) GetQuery() isQuery_Query

func (*Query) GetYqlText

func (x *Query) GetYqlText() string

func (*Query) ProtoMessage

func (*Query) ProtoMessage()

func (*Query) ProtoReflect

func (x *Query) ProtoReflect() protoreflect.Message

func (*Query) Reset

func (x *Query) Reset()

func (*Query) String

func (x *Query) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use QueryMeta.ProtoReflect.Descriptor instead.

func (*QueryMeta) GetId

func (x *QueryMeta) GetId() string

func (*QueryMeta) GetParametersTypes

func (x *QueryMeta) GetParametersTypes() map[string]*Ydb.Type

func (*QueryMeta) ProtoMessage

func (*QueryMeta) ProtoMessage()

func (*QueryMeta) ProtoReflect

func (x *QueryMeta) ProtoReflect() protoreflect.Message

func (*QueryMeta) Reset

func (x *QueryMeta) Reset()

func (*QueryMeta) String

func (x *QueryMeta) String() string

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) Enum

func (QueryStatsCollection_Mode) EnumDescriptor deprecated

func (QueryStatsCollection_Mode) EnumDescriptor() ([]byte, []int)

Deprecated: Use QueryStatsCollection_Mode.Descriptor instead.

func (QueryStatsCollection_Mode) Number

func (QueryStatsCollection_Mode) String

func (x QueryStatsCollection_Mode) String() string

func (QueryStatsCollection_Mode) Type

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 (*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 (*ReplicationPolicyDescription) Reset

func (x *ReplicationPolicyDescription) Reset()

func (*ReplicationPolicyDescription) 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 (*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 (*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 (*RollbackTransactionResponse) ProtoMessage

func (*RollbackTransactionResponse) ProtoMessage()

func (*RollbackTransactionResponse) ProtoReflect

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 (*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 (*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
const (
	StoreType_STORE_TYPE_UNSPECIFIED StoreType = 0
	StoreType_STORE_TYPE_ROW         StoreType = 1
	StoreType_STORE_TYPE_COLUMN      StoreType = 2
)

func (StoreType) Descriptor

func (StoreType) Descriptor() protoreflect.EnumDescriptor

func (StoreType) Enum

func (x StoreType) Enum() *StoreType

func (StoreType) EnumDescriptor deprecated

func (StoreType) EnumDescriptor() ([]byte, []int)

Deprecated: Use StoreType.Descriptor instead.

func (StoreType) Number

func (x StoreType) Number() protoreflect.EnumNumber

func (StoreType) String

func (x StoreType) String() string

func (StoreType) Type

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 (*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) Enum

func (TableIndexDescription_Status) EnumDescriptor deprecated

func (TableIndexDescription_Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use TableIndexDescription_Status.Descriptor instead.

func (TableIndexDescription_Status) Number

func (TableIndexDescription_Status) String

func (TableIndexDescription_Status) Type

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 (*ValueSinceUnixEpochModeSettings) GetExpireAfterSeconds

func (x *ValueSinceUnixEpochModeSettings) GetExpireAfterSeconds() uint32

func (*ValueSinceUnixEpochModeSettings) ProtoMessage

func (*ValueSinceUnixEpochModeSettings) ProtoMessage()

func (*ValueSinceUnixEpochModeSettings) ProtoReflect

func (*ValueSinceUnixEpochModeSettings) Reset

func (*ValueSinceUnixEpochModeSettings) 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) Enum

func (ValueSinceUnixEpochModeSettings_Unit) EnumDescriptor deprecated

func (ValueSinceUnixEpochModeSettings_Unit) EnumDescriptor() ([]byte, []int)

Deprecated: Use ValueSinceUnixEpochModeSettings_Unit.Descriptor instead.

func (ValueSinceUnixEpochModeSettings_Unit) Number

func (ValueSinceUnixEpochModeSettings_Unit) String

func (ValueSinceUnixEpochModeSettings_Unit) Type

Jump to

Keyboard shortcuts

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