Ydb_Table

package
v0.0.0-...-8dd88c8 Latest Latest
Warning

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

 Go to latest Published: Mar 9, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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",
	}
	ChangefeedFormat_Format_value = map[string]int32{
		"FORMAT_UNSPECIFIED":           0,
		"FORMAT_JSON":                  1,
		"FORMAT_DYNAMODB_STREAMS_JSON": 2,
	}
)

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 (x *BeginTransactionResponse) GetOperation() *Ydb_Operations.Operation

func (*BeginTransactionResponse) ProtoMessage 

func (*BeginTransactionResponse) ProtoMessage()

func (*BeginTransactionResponse) ProtoReflect 

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

func (*BeginTransactionResponse) Reset 

func (x *BeginTransactionResponse) Reset()

func (*BeginTransactionResponse) String 

func (x *BeginTransactionResponse) String() string

type BeginTransactionResult 

type BeginTransactionResult struct {
	TxMeta *TransactionMeta `protobuf:"bytes,1,opt,name=tx_meta,json=txMeta,proto3" json:"tx_meta,omitempty"`
	// contains filtered or unexported fields
}

func (*BeginTransactionResult) Descriptor deprecated 

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

Deprecated: Use BeginTransactionResult.ProtoReflect.Descriptor instead.

func (*BeginTransactionResult) GetTxMeta 

func (x *BeginTransactionResult) GetTxMeta() *TransactionMeta

func (*BeginTransactionResult) ProtoMessage 

func (*BeginTransactionResult) ProtoMessage()

func (*BeginTransactionResult) ProtoReflect 

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

func (*BeginTransactionResult) Reset 

func (x *BeginTransactionResult) Reset()

func (*BeginTransactionResult) String 

func (x *BeginTransactionResult) String() string

type BulkUpsertRequest 

type BulkUpsertRequest struct {
	Table string `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	// "rows" parameter must be a list of structs where each stuct represents one row.
	// It must contain all key columns but not necessarily all non-key columns.
	// Similar to UPSERT statement only values of specified columns will be updated.
	Rows            *Ydb.TypedValue                 `protobuf:"bytes,2,opt,name=rows,proto3" json:"rows,omitempty"`
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,3,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// You may set data_format + data instead of rows to insert data in serialized formats.
	//
	// Types that are assignable to DataFormat:
	//
	//	*BulkUpsertRequest_ArrowBatchSettings
	//	*BulkUpsertRequest_CsvSettings
	DataFormat isBulkUpsertRequest_DataFormat `protobuf_oneof:"data_format"`
	// It's last in the definition to help with sidecar patterns
	Data []byte `protobuf:"bytes,1000,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*BulkUpsertRequest) Descriptor deprecated 

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

Deprecated: Use BulkUpsertRequest.ProtoReflect.Descriptor instead.

func (*BulkUpsertRequest) GetArrowBatchSettings 

func (x *BulkUpsertRequest) GetArrowBatchSettings() *Ydb_Formats.ArrowBatchSettings

func (*BulkUpsertRequest) GetCsvSettings 

func (x *BulkUpsertRequest) GetCsvSettings() *Ydb_Formats.CsvSettings

func (*BulkUpsertRequest) GetData 

func (x *BulkUpsertRequest) GetData() []byte

func (*BulkUpsertRequest) GetDataFormat 

func (m *BulkUpsertRequest) GetDataFormat() isBulkUpsertRequest_DataFormat

func (*BulkUpsertRequest) GetOperationParams 

func (x *BulkUpsertRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*BulkUpsertRequest) GetRows 

func (x *BulkUpsertRequest) GetRows() *Ydb.TypedValue

func (*BulkUpsertRequest) GetTable 

func (x *BulkUpsertRequest) GetTable() string

func (*BulkUpsertRequest) ProtoMessage 

func (*BulkUpsertRequest) ProtoMessage()

func (*BulkUpsertRequest) ProtoReflect 

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

func (*BulkUpsertRequest) Reset 

func (x *BulkUpsertRequest) Reset()

func (*BulkUpsertRequest) String 

func (x *BulkUpsertRequest) String() string

type BulkUpsertRequest_ArrowBatchSettings 

type BulkUpsertRequest_ArrowBatchSettings struct {
	ArrowBatchSettings *Ydb_Formats.ArrowBatchSettings `protobuf:"bytes,7,opt,name=arrow_batch_settings,json=arrowBatchSettings,proto3,oneof"`
}

type BulkUpsertRequest_CsvSettings 

type BulkUpsertRequest_CsvSettings struct {
	CsvSettings *Ydb_Formats.CsvSettings `protobuf:"bytes,8,opt,name=csv_settings,json=csvSettings,proto3,oneof"`
}

type BulkUpsertResponse 

type BulkUpsertResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*BulkUpsertResponse) Descriptor deprecated 

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

Deprecated: Use BulkUpsertResponse.ProtoReflect.Descriptor instead.

func (*BulkUpsertResponse) GetOperation 

func (x *BulkUpsertResponse) GetOperation() *Ydb_Operations.Operation

func (*BulkUpsertResponse) ProtoMessage 

func (*BulkUpsertResponse) ProtoMessage()

func (*BulkUpsertResponse) ProtoReflect 

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

func (*BulkUpsertResponse) Reset 

func (x *BulkUpsertResponse) Reset()

func (*BulkUpsertResponse) String 

func (x *BulkUpsertResponse) String() string

type BulkUpsertResult 

type BulkUpsertResult struct {
	// contains filtered or unexported fields
}

func (*BulkUpsertResult) Descriptor deprecated 

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

Deprecated: Use BulkUpsertResult.ProtoReflect.Descriptor instead.

func (*BulkUpsertResult) ProtoMessage 

func (*BulkUpsertResult) ProtoMessage()

func (*BulkUpsertResult) ProtoReflect 

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

func (*BulkUpsertResult) Reset 

func (x *BulkUpsertResult) Reset()

func (*BulkUpsertResult) String 

func (x *BulkUpsertResult) String() string

type CachingPolicy 

type CachingPolicy struct {
	PresetName string `protobuf:"bytes,1,opt,name=preset_name,json=presetName,proto3" json:"preset_name,omitempty"`
	// contains filtered or unexported fields
}

func (*CachingPolicy) Descriptor deprecated 

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

Deprecated: Use CachingPolicy.ProtoReflect.Descriptor instead.

func (*CachingPolicy) GetPresetName 

func (x *CachingPolicy) GetPresetName() string

func (*CachingPolicy) ProtoMessage 

func (*CachingPolicy) ProtoMessage()

func (*CachingPolicy) ProtoReflect 

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

func (*CachingPolicy) Reset 

func (x *CachingPolicy) Reset()

func (*CachingPolicy) String 

func (x *CachingPolicy) String() string

type CachingPolicyDescription 

type CachingPolicyDescription struct {
	Name   string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CachingPolicyDescription) Descriptor deprecated 

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

Deprecated: Use CachingPolicyDescription.ProtoReflect.Descriptor instead.

func (*CachingPolicyDescription) GetLabels 

func (x *CachingPolicyDescription) GetLabels() map[string]string

func (*CachingPolicyDescription) GetName 

func (x *CachingPolicyDescription) GetName() string

func (*CachingPolicyDescription) ProtoMessage 

func (*CachingPolicyDescription) ProtoMessage()

func (*CachingPolicyDescription) ProtoReflect 

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

func (*CachingPolicyDescription) Reset 

func (x *CachingPolicyDescription) Reset()

func (*CachingPolicyDescription) String 

func (x *CachingPolicyDescription) String() string

type Changefeed 

type Changefeed struct {

	// Name of the feed
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Mode specifies the information that will be written to the feed
	Mode ChangefeedMode_Mode `protobuf:"varint,2,opt,name=mode,proto3,enum=Ydb.Table.ChangefeedMode_Mode" json:"mode,omitempty"`
	// Format of the data
	Format ChangefeedFormat_Format `protobuf:"varint,3,opt,name=format,proto3,enum=Ydb.Table.ChangefeedFormat_Format" json:"format,omitempty"`
	// How long data in changefeed's underlying topic should be stored
	RetentionPeriod *durationpb.Duration `protobuf:"bytes,4,opt,name=retention_period,json=retentionPeriod,proto3" json:"retention_period,omitempty"`
	// Emit virtual timestamps of changes along with data or not
	VirtualTimestamps bool `protobuf:"varint,5,opt,name=virtual_timestamps,json=virtualTimestamps,proto3" json:"virtual_timestamps,omitempty"`
	// Initial scan will output the current state of the table first
	InitialScan bool `protobuf:"varint,6,opt,name=initial_scan,json=initialScan,proto3" json:"initial_scan,omitempty"`
	// Attributes. Total size is limited to 10 KB.
	Attributes map[string]string `` /* 161-byte string literal not displayed */
	// 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) 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) GetRetentionPeriod 

func (x *Changefeed) GetRetentionPeriod() *durationpb.Duration

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 */
	// 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) GetFormat 

func (x *ChangefeedDescription) GetFormat() ChangefeedFormat_Format

func (*ChangefeedDescription) GetMode 

func (x *ChangefeedDescription) GetMode() ChangefeedMode_Mode

func (*ChangefeedDescription) GetName 

func (x *ChangefeedDescription) GetName() string

func (*ChangefeedDescription) GetState 

func (x *ChangefeedDescription) GetState() ChangefeedDescription_State

func (*ChangefeedDescription) GetVirtualTimestamps 

func (x *ChangefeedDescription) GetVirtualTimestamps() bool

func (*ChangefeedDescription) ProtoMessage 

func (*ChangefeedDescription) ProtoMessage()

func (*ChangefeedDescription) ProtoReflect 

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

func (*ChangefeedDescription) Reset 

func (x *ChangefeedDescription) Reset()

func (*ChangefeedDescription) String 

func (x *ChangefeedDescription) String() string

type ChangefeedDescription_State 

type ChangefeedDescription_State int32
const (
	ChangefeedDescription_STATE_UNSPECIFIED ChangefeedDescription_State = 0
	// Normal state, from this state changefeed can be disabled
	ChangefeedDescription_STATE_ENABLED ChangefeedDescription_State = 1
	// No new change records are generated, but the old ones remain available
	// From this state changefeed cannot be switched to any other state
	ChangefeedDescription_STATE_DISABLED ChangefeedDescription_State = 2
	// An initial scan is being performed.
	// After its completion changefeed will switch to the normal state
	ChangefeedDescription_STATE_INITIAL_SCAN ChangefeedDescription_State = 3
)

func (ChangefeedDescription_State) Descriptor 

func (ChangefeedDescription_State) Descriptor() protoreflect.EnumDescriptor

func (ChangefeedDescription_State) Enum 

func (x ChangefeedDescription_State) Enum() *ChangefeedDescription_State

func (ChangefeedDescription_State) EnumDescriptor deprecated 

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

Deprecated: Use ChangefeedDescription_State.Descriptor instead.

func (ChangefeedDescription_State) Number 

func (x ChangefeedDescription_State) Number() protoreflect.EnumNumber

func (ChangefeedDescription_State) String 

func (x ChangefeedDescription_State) String() string

func (ChangefeedDescription_State) Type 

func (ChangefeedDescription_State) Type() protoreflect.EnumType

type ChangefeedFormat 

type ChangefeedFormat struct {
	// contains filtered or unexported fields
}

func (*ChangefeedFormat) Descriptor deprecated 

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

Deprecated: Use ChangefeedFormat.ProtoReflect.Descriptor instead.

func (*ChangefeedFormat) ProtoMessage 

func (*ChangefeedFormat) ProtoMessage()

func (*ChangefeedFormat) ProtoReflect 

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

func (*ChangefeedFormat) Reset 

func (x *ChangefeedFormat) Reset()

func (*ChangefeedFormat) String 

func (x *ChangefeedFormat) String() string

type ChangefeedFormat_Format 

type ChangefeedFormat_Format int32
const (
	ChangefeedFormat_FORMAT_UNSPECIFIED           ChangefeedFormat_Format = 0
	ChangefeedFormat_FORMAT_JSON                  ChangefeedFormat_Format = 1
	ChangefeedFormat_FORMAT_DYNAMODB_STREAMS_JSON ChangefeedFormat_Format = 2
)

func (ChangefeedFormat_Format) Descriptor 

func (ChangefeedFormat_Format) Descriptor() protoreflect.EnumDescriptor

func (ChangefeedFormat_Format) Enum 

func (x ChangefeedFormat_Format) Enum() *ChangefeedFormat_Format

func (ChangefeedFormat_Format) EnumDescriptor deprecated 

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

Deprecated: Use ChangefeedFormat_Format.Descriptor instead.

func (ChangefeedFormat_Format) Number 

func (x ChangefeedFormat_Format) Number() protoreflect.EnumNumber

func (ChangefeedFormat_Format) String 

func (x ChangefeedFormat_Format) String() string

func (ChangefeedFormat_Format) Type 

func (ChangefeedFormat_Format) Type() protoreflect.EnumType

type ChangefeedMode 

type ChangefeedMode struct {
	// contains filtered or unexported fields
}

func (*ChangefeedMode) Descriptor deprecated 

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

Deprecated: Use ChangefeedMode.ProtoReflect.Descriptor instead.

func (*ChangefeedMode) ProtoMessage 

func (*ChangefeedMode) ProtoMessage()

func (*ChangefeedMode) ProtoReflect 

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

func (*ChangefeedMode) Reset 

func (x *ChangefeedMode) Reset()

func (*ChangefeedMode) String 

func (x *ChangefeedMode) String() string

type ChangefeedMode_Mode 

type ChangefeedMode_Mode int32
const (
	ChangefeedMode_MODE_UNSPECIFIED ChangefeedMode_Mode = 0
	// Only the key component of the modified row
	ChangefeedMode_MODE_KEYS_ONLY ChangefeedMode_Mode = 1
	// Updated columns
	ChangefeedMode_MODE_UPDATES ChangefeedMode_Mode = 2
	// The entire row, as it appears after it was modified
	ChangefeedMode_MODE_NEW_IMAGE ChangefeedMode_Mode = 3
	// The entire row, as it appeared before it was modified
	ChangefeedMode_MODE_OLD_IMAGE ChangefeedMode_Mode = 4
	// Both new and old images of the row
	ChangefeedMode_MODE_NEW_AND_OLD_IMAGES ChangefeedMode_Mode = 5
)

func (ChangefeedMode_Mode) Descriptor 

func (ChangefeedMode_Mode) Descriptor() protoreflect.EnumDescriptor

func (ChangefeedMode_Mode) Enum 

func (x ChangefeedMode_Mode) Enum() *ChangefeedMode_Mode

func (ChangefeedMode_Mode) EnumDescriptor deprecated 

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

Deprecated: Use ChangefeedMode_Mode.Descriptor instead.

func (ChangefeedMode_Mode) Number 

func (x ChangefeedMode_Mode) Number() protoreflect.EnumNumber

func (ChangefeedMode_Mode) String 

func (x ChangefeedMode_Mode) String() string

func (ChangefeedMode_Mode) Type 

func (ChangefeedMode_Mode) Type() protoreflect.EnumType

type ClusterReplicasSettings 

type ClusterReplicasSettings struct {

	// List of read replicas settings for each AZ
	AzReadReplicasSettings []*AzReadReplicasSettings `` /* 131-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ClusterReplicasSettings) Descriptor deprecated 

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

Deprecated: Use ClusterReplicasSettings.ProtoReflect.Descriptor instead.

func (*ClusterReplicasSettings) GetAzReadReplicasSettings 

func (x *ClusterReplicasSettings) GetAzReadReplicasSettings() []*AzReadReplicasSettings

func (*ClusterReplicasSettings) ProtoMessage 

func (*ClusterReplicasSettings) ProtoMessage()

func (*ClusterReplicasSettings) ProtoReflect 

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

func (*ClusterReplicasSettings) Reset 

func (x *ClusterReplicasSettings) Reset()

func (*ClusterReplicasSettings) String 

func (x *ClusterReplicasSettings) String() string

type ColumnFamily 

type ColumnFamily struct {

	// Name of the column family, the name "default" must be used for the
	// primary column family that contains at least primary key columns
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// This specifies data storage settings for column family
	Data *StoragePool `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// Optionally specify how data should be compressed
	Compression ColumnFamily_Compression `protobuf:"varint,3,opt,name=compression,proto3,enum=Ydb.Table.ColumnFamily_Compression" json:"compression,omitempty"`
	// When enabled table data will be kept in memory
	// WARNING: DO NOT USE
	KeepInMemory Ydb.FeatureFlag_Status `` /* 128-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ColumnFamily) Descriptor deprecated 

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

Deprecated: Use ColumnFamily.ProtoReflect.Descriptor instead.

func (*ColumnFamily) GetCompression 

func (x *ColumnFamily) GetCompression() ColumnFamily_Compression

func (*ColumnFamily) GetData 

func (x *ColumnFamily) GetData() *StoragePool

func (*ColumnFamily) GetKeepInMemory 

func (x *ColumnFamily) GetKeepInMemory() Ydb.FeatureFlag_Status

func (*ColumnFamily) GetName 

func (x *ColumnFamily) GetName() string

func (*ColumnFamily) ProtoMessage 

func (*ColumnFamily) ProtoMessage()

func (*ColumnFamily) ProtoReflect 

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

func (*ColumnFamily) Reset 

func (x *ColumnFamily) Reset()

func (*ColumnFamily) String 

func (x *ColumnFamily) String() string

type ColumnFamilyPolicy 

type ColumnFamilyPolicy struct {

	// Name of the column family, the name "default" must be used for the
	// primary column family that contains as least primary key columns
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Storage settings for the column group (default to values in storage policy)
	Data     *StoragePool `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	External *StoragePool `protobuf:"bytes,3,opt,name=external,proto3" json:"external,omitempty"`
	// When enabled table data will be kept in memory
	// WARNING: DO NOT USE
	KeepInMemory Ydb.FeatureFlag_Status `` /* 128-byte string literal not displayed */
	// Optionally specify whether data should be compressed
	Compression ColumnFamilyPolicy_Compression `protobuf:"varint,5,opt,name=compression,proto3,enum=Ydb.Table.ColumnFamilyPolicy_Compression" json:"compression,omitempty"`
	// contains filtered or unexported fields
}

func (*ColumnFamilyPolicy) Descriptor deprecated 

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

Deprecated: Use ColumnFamilyPolicy.ProtoReflect.Descriptor instead.

func (*ColumnFamilyPolicy) GetCompression 

func (x *ColumnFamilyPolicy) GetCompression() ColumnFamilyPolicy_Compression

func (*ColumnFamilyPolicy) GetData 

func (x *ColumnFamilyPolicy) GetData() *StoragePool

func (*ColumnFamilyPolicy) GetExternal 

func (x *ColumnFamilyPolicy) GetExternal() *StoragePool

func (*ColumnFamilyPolicy) GetKeepInMemory 

func (x *ColumnFamilyPolicy) GetKeepInMemory() Ydb.FeatureFlag_Status

func (*ColumnFamilyPolicy) GetName 

func (x *ColumnFamilyPolicy) GetName() string

func (*ColumnFamilyPolicy) ProtoMessage 

func (*ColumnFamilyPolicy) ProtoMessage()

func (*ColumnFamilyPolicy) ProtoReflect 

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

func (*ColumnFamilyPolicy) Reset 

func (x *ColumnFamilyPolicy) Reset()

func (*ColumnFamilyPolicy) String 

func (x *ColumnFamilyPolicy) String() string

type ColumnFamilyPolicy_Compression 

type ColumnFamilyPolicy_Compression int32
const (
	ColumnFamilyPolicy_COMPRESSION_UNSPECIFIED ColumnFamilyPolicy_Compression = 0
	ColumnFamilyPolicy_UNCOMPRESSED            ColumnFamilyPolicy_Compression = 1
	ColumnFamilyPolicy_COMPRESSED              ColumnFamilyPolicy_Compression = 2
)

func (ColumnFamilyPolicy_Compression) Descriptor 

func (ColumnFamilyPolicy_Compression) Descriptor() protoreflect.EnumDescriptor

func (ColumnFamilyPolicy_Compression) Enum 

func (x ColumnFamilyPolicy_Compression) Enum() *ColumnFamilyPolicy_Compression

func (ColumnFamilyPolicy_Compression) EnumDescriptor deprecated 

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

Deprecated: Use ColumnFamilyPolicy_Compression.Descriptor instead.

func (ColumnFamilyPolicy_Compression) Number 

func (x ColumnFamilyPolicy_Compression) Number() protoreflect.EnumNumber

func (ColumnFamilyPolicy_Compression) String 

func (x ColumnFamilyPolicy_Compression) String() string

func (ColumnFamilyPolicy_Compression) Type 

func (ColumnFamilyPolicy_Compression) Type() protoreflect.EnumType

type ColumnFamily_Compression 

type ColumnFamily_Compression int32
const (
	ColumnFamily_COMPRESSION_UNSPECIFIED ColumnFamily_Compression = 0
	ColumnFamily_COMPRESSION_NONE        ColumnFamily_Compression = 1
	ColumnFamily_COMPRESSION_LZ4         ColumnFamily_Compression = 2
)

func (ColumnFamily_Compression) Descriptor 

func (ColumnFamily_Compression) Descriptor() protoreflect.EnumDescriptor

func (ColumnFamily_Compression) Enum 

func (x ColumnFamily_Compression) Enum() *ColumnFamily_Compression

func (ColumnFamily_Compression) EnumDescriptor deprecated 

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

Deprecated: Use ColumnFamily_Compression.Descriptor instead.

func (ColumnFamily_Compression) Number 

func (x ColumnFamily_Compression) Number() protoreflect.EnumNumber

func (ColumnFamily_Compression) String 

func (x ColumnFamily_Compression) String() string

func (ColumnFamily_Compression) Type 

func (ColumnFamily_Compression) Type() protoreflect.EnumType

type ColumnMeta 

type ColumnMeta struct {

	// Name of column
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Type of column
	Type *Ydb.Type `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// Column family name of the column
	Family string `protobuf:"bytes,3,opt,name=family,proto3" json:"family,omitempty"`
	// contains filtered or unexported fields
}

func (*ColumnMeta) Descriptor deprecated 

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

Deprecated: Use ColumnMeta.ProtoReflect.Descriptor instead.

func (*ColumnMeta) GetFamily 

func (x *ColumnMeta) GetFamily() string

func (*ColumnMeta) GetName 

func (x *ColumnMeta) GetName() string

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 CommitTransactionRequest 

type CommitTransactionRequest struct {

	// Session identifier
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// Transaction identifier
	TxId            string                          `protobuf:"bytes,2,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"`
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,3,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	CollectStats    QueryStatsCollection_Mode       `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

Commit transaction with given session and tx id

func (*CommitTransactionRequest) Descriptor deprecated 

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

Deprecated: Use CommitTransactionRequest.ProtoReflect.Descriptor instead.

func (*CommitTransactionRequest) GetCollectStats 

func (x *CommitTransactionRequest) GetCollectStats() QueryStatsCollection_Mode

func (*CommitTransactionRequest) GetOperationParams 

func (x *CommitTransactionRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*CommitTransactionRequest) GetSessionId 

func (x *CommitTransactionRequest) GetSessionId() string

func (*CommitTransactionRequest) GetTxId 

func (x *CommitTransactionRequest) GetTxId() string

func (*CommitTransactionRequest) ProtoMessage 

func (*CommitTransactionRequest) ProtoMessage()

func (*CommitTransactionRequest) ProtoReflect 

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

func (*CommitTransactionRequest) Reset 

func (x *CommitTransactionRequest) Reset()

func (*CommitTransactionRequest) String 

func (x *CommitTransactionRequest) String() string

type CommitTransactionResponse 

type CommitTransactionResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*CommitTransactionResponse) Descriptor deprecated 

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

Deprecated: Use CommitTransactionResponse.ProtoReflect.Descriptor instead.

func (*CommitTransactionResponse) GetOperation 

func (x *CommitTransactionResponse) GetOperation() *Ydb_Operations.Operation

func (*CommitTransactionResponse) ProtoMessage 

func (*CommitTransactionResponse) ProtoMessage()

func (*CommitTransactionResponse) ProtoReflect 

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

func (*CommitTransactionResponse) Reset 

func (x *CommitTransactionResponse) Reset()

func (*CommitTransactionResponse) String 

func (x *CommitTransactionResponse) String() string

type CommitTransactionResult 

type CommitTransactionResult struct {
	QueryStats *Ydb_TableStats.QueryStats `protobuf:"bytes,1,opt,name=query_stats,json=queryStats,proto3" json:"query_stats,omitempty"`
	// contains filtered or unexported fields
}

func (*CommitTransactionResult) Descriptor deprecated 

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

Deprecated: Use CommitTransactionResult.ProtoReflect.Descriptor instead.

func (*CommitTransactionResult) GetQueryStats 

func (x *CommitTransactionResult) GetQueryStats() *Ydb_TableStats.QueryStats

func (*CommitTransactionResult) ProtoMessage 

func (*CommitTransactionResult) ProtoMessage()

func (*CommitTransactionResult) ProtoReflect 

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

func (*CommitTransactionResult) Reset 

func (x *CommitTransactionResult) Reset()

func (*CommitTransactionResult) String 

func (x *CommitTransactionResult) String() string

type CompactionPolicy 

type CompactionPolicy struct {
	PresetName string `protobuf:"bytes,1,opt,name=preset_name,json=presetName,proto3" json:"preset_name,omitempty"`
	// contains filtered or unexported fields
}

func (*CompactionPolicy) Descriptor deprecated 

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

Deprecated: Use CompactionPolicy.ProtoReflect.Descriptor instead.

func (*CompactionPolicy) GetPresetName 

func (x *CompactionPolicy) GetPresetName() string

func (*CompactionPolicy) ProtoMessage 

func (*CompactionPolicy) ProtoMessage()

func (*CompactionPolicy) ProtoReflect 

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

func (*CompactionPolicy) Reset 

func (x *CompactionPolicy) Reset()

func (*CompactionPolicy) String 

func (x *CompactionPolicy) String() string

type CompactionPolicyDescription 

type CompactionPolicyDescription struct {
	Name   string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CompactionPolicyDescription) Descriptor deprecated 

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

Deprecated: Use CompactionPolicyDescription.ProtoReflect.Descriptor instead.

func (*CompactionPolicyDescription) GetLabels 

func (x *CompactionPolicyDescription) GetLabels() map[string]string

func (*CompactionPolicyDescription) GetName 

func (x *CompactionPolicyDescription) GetName() string

func (*CompactionPolicyDescription) ProtoMessage 

func (*CompactionPolicyDescription) ProtoMessage()

func (*CompactionPolicyDescription) ProtoReflect 

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

func (*CompactionPolicyDescription) Reset 

func (x *CompactionPolicyDescription) Reset()

func (*CompactionPolicyDescription) String 

func (x *CompactionPolicyDescription) String() string

type CopyTableItem 

type CopyTableItem struct {

	// Copy from path
	SourcePath string `protobuf:"bytes,1,opt,name=source_path,json=sourcePath,proto3" json:"source_path,omitempty"`
	// Copy to path
	DestinationPath string `protobuf:"bytes,2,opt,name=destination_path,json=destinationPath,proto3" json:"destination_path,omitempty"`
	// Copy options
	OmitIndexes bool `protobuf:"varint,3,opt,name=omit_indexes,json=omitIndexes,proto3" json:"omit_indexes,omitempty"`
	// contains filtered or unexported fields
}

func (*CopyTableItem) Descriptor deprecated 

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

Deprecated: Use CopyTableItem.ProtoReflect.Descriptor instead.

func (*CopyTableItem) GetDestinationPath 

func (x *CopyTableItem) GetDestinationPath() string

func (*CopyTableItem) GetOmitIndexes 

func (x *CopyTableItem) GetOmitIndexes() bool

func (*CopyTableItem) GetSourcePath 

func (x *CopyTableItem) GetSourcePath() string

func (*CopyTableItem) ProtoMessage 

func (*CopyTableItem) ProtoMessage()

func (*CopyTableItem) ProtoReflect 

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

func (*CopyTableItem) Reset 

func (x *CopyTableItem) Reset()

func (*CopyTableItem) String 

func (x *CopyTableItem) String() string

type CopyTableRequest 

type CopyTableRequest struct {

	// Session identifier
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// Copy from path
	SourcePath string `protobuf:"bytes,2,opt,name=source_path,json=sourcePath,proto3" json:"source_path,omitempty"`
	// Copy to path
	DestinationPath string                          `protobuf:"bytes,3,opt,name=destination_path,json=destinationPath,proto3" json:"destination_path,omitempty"`
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,4,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// contains filtered or unexported fields
}

Copy table with given path

func (*CopyTableRequest) Descriptor deprecated 

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

Deprecated: Use CopyTableRequest.ProtoReflect.Descriptor instead.

func (*CopyTableRequest) GetDestinationPath 

func (x *CopyTableRequest) GetDestinationPath() string

func (*CopyTableRequest) GetOperationParams 

func (x *CopyTableRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*CopyTableRequest) GetSessionId 

func (x *CopyTableRequest) GetSessionId() string

func (*CopyTableRequest) GetSourcePath 

func (x *CopyTableRequest) GetSourcePath() string

func (*CopyTableRequest) ProtoMessage 

func (*CopyTableRequest) ProtoMessage()

func (*CopyTableRequest) ProtoReflect 

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

func (*CopyTableRequest) Reset 

func (x *CopyTableRequest) Reset()

func (*CopyTableRequest) String 

func (x *CopyTableRequest) String() string

type CopyTableResponse 

type CopyTableResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*CopyTableResponse) Descriptor deprecated 

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

Deprecated: Use CopyTableResponse.ProtoReflect.Descriptor instead.

func (*CopyTableResponse) GetOperation 

func (x *CopyTableResponse) GetOperation() *Ydb_Operations.Operation

func (*CopyTableResponse) ProtoMessage 

func (*CopyTableResponse) ProtoMessage()

func (*CopyTableResponse) ProtoReflect 

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

func (*CopyTableResponse) Reset 

func (x *CopyTableResponse) Reset()

func (*CopyTableResponse) String 

func (x *CopyTableResponse) String() string

type CopyTablesRequest 

type CopyTablesRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// Session identifier
	SessionId string `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// Source and destination paths which describe copies
	Tables []*CopyTableItem `protobuf:"bytes,3,rep,name=tables,proto3" json:"tables,omitempty"`
	// contains filtered or unexported fields
}

Creates consistent copy of given tables.

func (*CopyTablesRequest) Descriptor deprecated 

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

Deprecated: Use CopyTablesRequest.ProtoReflect.Descriptor instead.

func (*CopyTablesRequest) GetOperationParams 

func (x *CopyTablesRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*CopyTablesRequest) GetSessionId 

func (x *CopyTablesRequest) GetSessionId() string

func (*CopyTablesRequest) GetTables 

func (x *CopyTablesRequest) GetTables() []*CopyTableItem

func (*CopyTablesRequest) ProtoMessage 

func (*CopyTablesRequest) ProtoMessage()

func (*CopyTablesRequest) ProtoReflect 

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

func (*CopyTablesRequest) Reset 

func (x *CopyTablesRequest) Reset()

func (*CopyTablesRequest) String 

func (x *CopyTablesRequest) String() string

type CopyTablesResponse 

type CopyTablesResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*CopyTablesResponse) Descriptor deprecated 

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

Deprecated: Use CopyTablesResponse.ProtoReflect.Descriptor instead.

func (*CopyTablesResponse) GetOperation 

func (x *CopyTablesResponse) GetOperation() *Ydb_Operations.Operation

func (*CopyTablesResponse) ProtoMessage 

func (*CopyTablesResponse) ProtoMessage()

func (*CopyTablesResponse) ProtoReflect 

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

func (*CopyTablesResponse) Reset 

func (x *CopyTablesResponse) Reset()

func (*CopyTablesResponse) String 

func (x *CopyTablesResponse) String() string

type CreateSessionRequest 

type CreateSessionRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// contains filtered or unexported fields
}

Create new session

func (*CreateSessionRequest) Descriptor deprecated 

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

Deprecated: Use CreateSessionRequest.ProtoReflect.Descriptor instead.

func (*CreateSessionRequest) GetOperationParams 

func (x *CreateSessionRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*CreateSessionRequest) ProtoMessage 

func (*CreateSessionRequest) ProtoMessage()

func (*CreateSessionRequest) ProtoReflect 

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

func (*CreateSessionRequest) Reset 

func (x *CreateSessionRequest) Reset()

func (*CreateSessionRequest) String 

func (x *CreateSessionRequest) String() string

type CreateSessionResponse 

type CreateSessionResponse struct {

	// Holds CreateSessionResult in case of CreateSessionResult
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

Create new session

func (*CreateSessionResponse) Descriptor deprecated 

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

Deprecated: Use CreateSessionResponse.ProtoReflect.Descriptor instead.

func (*CreateSessionResponse) GetOperation 

func (x *CreateSessionResponse) GetOperation() *Ydb_Operations.Operation

func (*CreateSessionResponse) ProtoMessage 

func (*CreateSessionResponse) ProtoMessage()

func (*CreateSessionResponse) ProtoReflect 

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

func (*CreateSessionResponse) Reset 

func (x *CreateSessionResponse) Reset()

func (*CreateSessionResponse) String 

func (x *CreateSessionResponse) String() string

type CreateSessionResult 

type CreateSessionResult struct {

	// Session identifier
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateSessionResult) Descriptor deprecated 

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

Deprecated: Use CreateSessionResult.ProtoReflect.Descriptor instead.

func (*CreateSessionResult) GetSessionId 

func (x *CreateSessionResult) GetSessionId() string

func (*CreateSessionResult) ProtoMessage 

func (*CreateSessionResult) ProtoMessage()

func (*CreateSessionResult) ProtoReflect 

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

func (*CreateSessionResult) Reset 

func (x *CreateSessionResult) Reset()

func (*CreateSessionResult) String 

func (x *CreateSessionResult) String() string

type CreateTableRequest 

type CreateTableRequest struct {

	// Session identifier
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// Full path
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// Columns (name, type)
	Columns []*ColumnMeta `protobuf:"bytes,3,rep,name=columns,proto3" json:"columns,omitempty"`
	// List of columns used as primary key
	PrimaryKey []string `protobuf:"bytes,4,rep,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
	// Table profile
	Profile         *TableProfile                   `protobuf:"bytes,5,opt,name=profile,proto3" json:"profile,omitempty"`
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,6,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// List of secondary indexes
	Indexes []*TableIndex `protobuf:"bytes,7,rep,name=indexes,proto3" json:"indexes,omitempty"`
	// Table rows time to live settings
	TtlSettings *TtlSettings `protobuf:"bytes,8,opt,name=ttl_settings,json=ttlSettings,proto3" json:"ttl_settings,omitempty"`
	// Storage settings for table
	StorageSettings *StorageSettings `protobuf:"bytes,9,opt,name=storage_settings,json=storageSettings,proto3" json:"storage_settings,omitempty"`
	// Column families
	ColumnFamilies []*ColumnFamily `protobuf:"bytes,10,rep,name=column_families,json=columnFamilies,proto3" json:"column_families,omitempty"`
	// Attributes. Total size is limited to 10 KB.
	Attributes map[string]string `` /* 162-byte string literal not displayed */
	// Predefined named set of settings for table compaction ["default", "small_table", "log_table"].
	CompactionPolicy string `protobuf:"bytes,12,opt,name=compaction_policy,json=compactionPolicy,proto3" json:"compaction_policy,omitempty"`
	// Either one of the following partitions options can be specified
	//
	// Types that are assignable to Partitions:
	//
	//	*CreateTableRequest_UniformPartitions
	//	*CreateTableRequest_PartitionAtKeys
	Partitions isCreateTableRequest_Partitions `protobuf_oneof:"partitions"`
	// Partitioning settings for table
	PartitioningSettings *PartitioningSettings `protobuf:"bytes,15,opt,name=partitioning_settings,json=partitioningSettings,proto3" json:"partitioning_settings,omitempty"`
	// Bloom filter by key
	KeyBloomFilter Ydb.FeatureFlag_Status `` /* 135-byte string literal not displayed */
	// Read replicas settings for table
	ReadReplicasSettings *ReadReplicasSettings `protobuf:"bytes,17,opt,name=read_replicas_settings,json=readReplicasSettings,proto3" json:"read_replicas_settings,omitempty"`
	// Tiering rules name. It specifies how data migrates from one tier (logical storage) to another.
	Tiering string `protobuf:"bytes,18,opt,name=tiering,proto3" json:"tiering,omitempty"`
	// 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) GetTiering 

func (x *CreateTableRequest) GetTiering() string

func (*CreateTableRequest) GetTtlSettings 

func (x *CreateTableRequest) GetTtlSettings() *TtlSettings

func (*CreateTableRequest) GetUniformPartitions 

func (x *CreateTableRequest) GetUniformPartitions() uint64

func (*CreateTableRequest) ProtoMessage 

func (*CreateTableRequest) ProtoMessage()

func (*CreateTableRequest) ProtoReflect 

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

func (*CreateTableRequest) Reset 

func (x *CreateTableRequest) Reset()

func (*CreateTableRequest) String 

func (x *CreateTableRequest) String() string

type CreateTableRequest_PartitionAtKeys 

type CreateTableRequest_PartitionAtKeys struct {
	// Explicitly specify key values which are used as borders for created partitions.
	PartitionAtKeys *ExplicitPartitions `protobuf:"bytes,14,opt,name=partition_at_keys,json=partitionAtKeys,proto3,oneof"`
}

type CreateTableRequest_UniformPartitions 

type CreateTableRequest_UniformPartitions struct {
	// Enable uniform partitioning using given partitions count.
	// The first components of primary key must have Uint32/Uint64 type.
	UniformPartitions uint64 `protobuf:"varint,13,opt,name=uniform_partitions,json=uniformPartitions,proto3,oneof"`
}

type CreateTableResponse 

type CreateTableResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTableResponse) Descriptor deprecated 

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

Deprecated: Use CreateTableResponse.ProtoReflect.Descriptor instead.

func (*CreateTableResponse) GetOperation 

func (x *CreateTableResponse) GetOperation() *Ydb_Operations.Operation

func (*CreateTableResponse) ProtoMessage 

func (*CreateTableResponse) ProtoMessage()

func (*CreateTableResponse) ProtoReflect 

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

func (*CreateTableResponse) Reset 

func (x *CreateTableResponse) Reset()

func (*CreateTableResponse) String 

func (x *CreateTableResponse) String() string

type DateTypeColumnModeSettings 

type DateTypeColumnModeSettings struct {

	// The column type must be a date type
	ColumnName         string `protobuf:"bytes,1,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"`
	ExpireAfterSeconds uint32 `protobuf:"varint,2,opt,name=expire_after_seconds,json=expireAfterSeconds,proto3" json:"expire_after_seconds,omitempty"`
	// contains filtered or unexported fields
}

func (*DateTypeColumnModeSettings) Descriptor deprecated 

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

Deprecated: Use DateTypeColumnModeSettings.ProtoReflect.Descriptor instead.

func (*DateTypeColumnModeSettings) GetColumnName 

func (x *DateTypeColumnModeSettings) GetColumnName() string

func (*DateTypeColumnModeSettings) GetExpireAfterSeconds 

func (x *DateTypeColumnModeSettings) GetExpireAfterSeconds() uint32

func (*DateTypeColumnModeSettings) ProtoMessage 

func (*DateTypeColumnModeSettings) ProtoMessage()

func (*DateTypeColumnModeSettings) ProtoReflect 

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

func (*DateTypeColumnModeSettings) Reset 

func (x *DateTypeColumnModeSettings) Reset()

func (*DateTypeColumnModeSettings) String 

func (x *DateTypeColumnModeSettings) String() string

type DeleteSessionRequest 

type DeleteSessionRequest struct {

	// Session identifier
	SessionId       string                          `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,2,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// contains filtered or unexported fields
}

Delete session with given id string

func (*DeleteSessionRequest) Descriptor deprecated 

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

Deprecated: Use DeleteSessionRequest.ProtoReflect.Descriptor instead.

func (*DeleteSessionRequest) GetOperationParams 

func (x *DeleteSessionRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*DeleteSessionRequest) GetSessionId 

func (x *DeleteSessionRequest) GetSessionId() string

func (*DeleteSessionRequest) ProtoMessage 

func (*DeleteSessionRequest) ProtoMessage()

func (*DeleteSessionRequest) ProtoReflect 

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

func (*DeleteSessionRequest) Reset 

func (x *DeleteSessionRequest) Reset()

func (*DeleteSessionRequest) String 

func (x *DeleteSessionRequest) String() string

type DeleteSessionResponse 

type DeleteSessionResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteSessionResponse) Descriptor deprecated 

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

Deprecated: Use DeleteSessionResponse.ProtoReflect.Descriptor instead.

func (*DeleteSessionResponse) GetOperation 

func (x *DeleteSessionResponse) GetOperation() *Ydb_Operations.Operation

func (*DeleteSessionResponse) ProtoMessage 

func (*DeleteSessionResponse) ProtoMessage()

func (*DeleteSessionResponse) ProtoReflect 

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

func (*DeleteSessionResponse) Reset 

func (x *DeleteSessionResponse) Reset()

func (*DeleteSessionResponse) String 

func (x *DeleteSessionResponse) String() string

type DescribeTableOptionsRequest 

type DescribeTableOptionsRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeTableOptionsRequest) Descriptor deprecated 

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

Deprecated: Use DescribeTableOptionsRequest.ProtoReflect.Descriptor instead.

func (*DescribeTableOptionsRequest) GetOperationParams 

func (x *DescribeTableOptionsRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*DescribeTableOptionsRequest) ProtoMessage 

func (*DescribeTableOptionsRequest) ProtoMessage()

func (*DescribeTableOptionsRequest) ProtoReflect 

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

func (*DescribeTableOptionsRequest) Reset 

func (x *DescribeTableOptionsRequest) Reset()

func (*DescribeTableOptionsRequest) String 

func (x *DescribeTableOptionsRequest) String() string

type DescribeTableOptionsResponse 

type DescribeTableOptionsResponse struct {

	// operation.result holds ListTableParametersResult
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeTableOptionsResponse) Descriptor deprecated 

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

Deprecated: Use DescribeTableOptionsResponse.ProtoReflect.Descriptor instead.

func (*DescribeTableOptionsResponse) GetOperation 

func (x *DescribeTableOptionsResponse) GetOperation() *Ydb_Operations.Operation

func (*DescribeTableOptionsResponse) ProtoMessage 

func (*DescribeTableOptionsResponse) ProtoMessage()

func (*DescribeTableOptionsResponse) ProtoReflect 

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

func (*DescribeTableOptionsResponse) Reset 

func (x *DescribeTableOptionsResponse) Reset()

func (*DescribeTableOptionsResponse) String 

func (x *DescribeTableOptionsResponse) String() string

type DescribeTableOptionsResult 

type DescribeTableOptionsResult struct {
	TableProfilePresets       []*TableProfileDescription       `protobuf:"bytes,1,rep,name=table_profile_presets,json=tableProfilePresets,proto3" json:"table_profile_presets,omitempty"`
	StoragePolicyPresets      []*StoragePolicyDescription      `protobuf:"bytes,2,rep,name=storage_policy_presets,json=storagePolicyPresets,proto3" json:"storage_policy_presets,omitempty"`
	CompactionPolicyPresets   []*CompactionPolicyDescription   `` /* 132-byte string literal not displayed */
	PartitioningPolicyPresets []*PartitioningPolicyDescription `` /* 138-byte string literal not displayed */
	ExecutionPolicyPresets    []*ExecutionPolicyDescription    `` /* 129-byte string literal not displayed */
	ReplicationPolicyPresets  []*ReplicationPolicyDescription  `` /* 135-byte string literal not displayed */
	CachingPolicyPresets      []*CachingPolicyDescription      `protobuf:"bytes,7,rep,name=caching_policy_presets,json=cachingPolicyPresets,proto3" json:"caching_policy_presets,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeTableOptionsResult) Descriptor deprecated 

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

Deprecated: Use DescribeTableOptionsResult.ProtoReflect.Descriptor instead.

func (*DescribeTableOptionsResult) GetCachingPolicyPresets 

func (x *DescribeTableOptionsResult) GetCachingPolicyPresets() []*CachingPolicyDescription

func (*DescribeTableOptionsResult) GetCompactionPolicyPresets 

func (x *DescribeTableOptionsResult) GetCompactionPolicyPresets() []*CompactionPolicyDescription

func (*DescribeTableOptionsResult) GetExecutionPolicyPresets 

func (x *DescribeTableOptionsResult) GetExecutionPolicyPresets() []*ExecutionPolicyDescription

func (*DescribeTableOptionsResult) GetPartitioningPolicyPresets 

func (x *DescribeTableOptionsResult) GetPartitioningPolicyPresets() []*PartitioningPolicyDescription

func (*DescribeTableOptionsResult) GetReplicationPolicyPresets 

func (x *DescribeTableOptionsResult) GetReplicationPolicyPresets() []*ReplicationPolicyDescription

func (*DescribeTableOptionsResult) GetStoragePolicyPresets 

func (x *DescribeTableOptionsResult) GetStoragePolicyPresets() []*StoragePolicyDescription

func (*DescribeTableOptionsResult) GetTableProfilePresets 

func (x *DescribeTableOptionsResult) GetTableProfilePresets() []*TableProfileDescription

func (*DescribeTableOptionsResult) ProtoMessage 

func (*DescribeTableOptionsResult) ProtoMessage()

func (*DescribeTableOptionsResult) ProtoReflect 

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

func (*DescribeTableOptionsResult) Reset 

func (x *DescribeTableOptionsResult) Reset()

func (*DescribeTableOptionsResult) String 

func (x *DescribeTableOptionsResult) String() string

type DescribeTableRequest 

type DescribeTableRequest struct {

	// Session identifier
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// Full path
	Path            string                          `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,4,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// Includes shard key distribution info
	IncludeShardKeyBounds bool `` /* 129-byte string literal not displayed */
	// Includes table statistics
	IncludeTableStats bool `protobuf:"varint,6,opt,name=include_table_stats,json=includeTableStats,proto3" json:"include_table_stats,omitempty"`
	// Includes partition statistics (required include_table_statistics)
	IncludePartitionStats bool `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

Describe table with given path

func (*DescribeTableRequest) Descriptor deprecated 

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

Deprecated: Use DescribeTableRequest.ProtoReflect.Descriptor instead.

func (*DescribeTableRequest) GetIncludePartitionStats 

func (x *DescribeTableRequest) GetIncludePartitionStats() bool

func (*DescribeTableRequest) GetIncludeShardKeyBounds 

func (x *DescribeTableRequest) GetIncludeShardKeyBounds() bool

func (*DescribeTableRequest) GetIncludeTableStats 

func (x *DescribeTableRequest) GetIncludeTableStats() bool

func (*DescribeTableRequest) GetOperationParams 

func (x *DescribeTableRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*DescribeTableRequest) GetPath 

func (x *DescribeTableRequest) GetPath() string

func (*DescribeTableRequest) GetSessionId 

func (x *DescribeTableRequest) GetSessionId() string

func (*DescribeTableRequest) ProtoMessage 

func (*DescribeTableRequest) ProtoMessage()

func (*DescribeTableRequest) ProtoReflect 

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

func (*DescribeTableRequest) Reset 

func (x *DescribeTableRequest) Reset()

func (*DescribeTableRequest) String 

func (x *DescribeTableRequest) String() string

type DescribeTableResponse 

type DescribeTableResponse struct {

	// Holds DescribeTableResult in case of successful call
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeTableResponse) Descriptor deprecated 

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

Deprecated: Use DescribeTableResponse.ProtoReflect.Descriptor instead.

func (*DescribeTableResponse) GetOperation 

func (x *DescribeTableResponse) GetOperation() *Ydb_Operations.Operation

func (*DescribeTableResponse) ProtoMessage 

func (*DescribeTableResponse) ProtoMessage()

func (*DescribeTableResponse) ProtoReflect 

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

func (*DescribeTableResponse) Reset 

func (x *DescribeTableResponse) Reset()

func (*DescribeTableResponse) String 

func (x *DescribeTableResponse) String() string

type DescribeTableResult 

type DescribeTableResult struct {

	// Description of scheme object
	Self *Ydb_Scheme.Entry `protobuf:"bytes,1,opt,name=self,proto3" json:"self,omitempty"`
	// List of columns
	Columns []*ColumnMeta `protobuf:"bytes,2,rep,name=columns,proto3" json:"columns,omitempty"`
	// List of primary key columns
	PrimaryKey []string `protobuf:"bytes,3,rep,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
	// List of key ranges for shard
	ShardKeyBounds []*Ydb.TypedValue `protobuf:"bytes,4,rep,name=shard_key_bounds,json=shardKeyBounds,proto3" json:"shard_key_bounds,omitempty"`
	// List of indexes
	Indexes []*TableIndexDescription `protobuf:"bytes,5,rep,name=indexes,proto3" json:"indexes,omitempty"`
	// Statistics of table
	TableStats *TableStats `protobuf:"bytes,6,opt,name=table_stats,json=tableStats,proto3" json:"table_stats,omitempty"`
	// TTL params
	TtlSettings *TtlSettings `protobuf:"bytes,7,opt,name=ttl_settings,json=ttlSettings,proto3" json:"ttl_settings,omitempty"`
	// Storage settings for table
	StorageSettings *StorageSettings `protobuf:"bytes,8,opt,name=storage_settings,json=storageSettings,proto3" json:"storage_settings,omitempty"`
	// Column families
	ColumnFamilies []*ColumnFamily `protobuf:"bytes,9,rep,name=column_families,json=columnFamilies,proto3" json:"column_families,omitempty"`
	// Attributes
	Attributes map[string]string `` /* 162-byte string literal not displayed */
	// Partitioning settings for table
	PartitioningSettings *PartitioningSettings `protobuf:"bytes,12,opt,name=partitioning_settings,json=partitioningSettings,proto3" json:"partitioning_settings,omitempty"`
	// Bloom filter by key
	KeyBloomFilter Ydb.FeatureFlag_Status `` /* 135-byte string literal not displayed */
	// Read replicas settings for table
	ReadReplicasSettings *ReadReplicasSettings `protobuf:"bytes,14,opt,name=read_replicas_settings,json=readReplicasSettings,proto3" json:"read_replicas_settings,omitempty"`
	// List of changefeeds
	Changefeeds []*ChangefeedDescription `protobuf:"bytes,15,rep,name=changefeeds,proto3" json:"changefeeds,omitempty"`
	// Tiering rules name
	Tiering string `protobuf:"bytes,16,opt,name=tiering,proto3" json:"tiering,omitempty"`
	// 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) GetTableStats 

func (x *DescribeTableResult) GetTableStats() *TableStats

func (*DescribeTableResult) GetTiering 

func (x *DescribeTableResult) GetTiering() string

func (*DescribeTableResult) GetTtlSettings 

func (x *DescribeTableResult) GetTtlSettings() *TtlSettings

func (*DescribeTableResult) ProtoMessage 

func (*DescribeTableResult) ProtoMessage()

func (*DescribeTableResult) ProtoReflect 

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

func (*DescribeTableResult) Reset 

func (x *DescribeTableResult) Reset()

func (*DescribeTableResult) String 

func (x *DescribeTableResult) String() string

type DropTableRequest 

type DropTableRequest struct {

	// Session identifier
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// Full path
	Path            string                          `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,4,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// contains filtered or unexported fields
}

Drop table with given path

func (*DropTableRequest) Descriptor deprecated 

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

Deprecated: Use DropTableRequest.ProtoReflect.Descriptor instead.

func (*DropTableRequest) GetOperationParams 

func (x *DropTableRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*DropTableRequest) GetPath 

func (x *DropTableRequest) GetPath() string

func (*DropTableRequest) GetSessionId 

func (x *DropTableRequest) GetSessionId() string

func (*DropTableRequest) ProtoMessage 

func (*DropTableRequest) ProtoMessage()

func (*DropTableRequest) ProtoReflect 

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

func (*DropTableRequest) Reset 

func (x *DropTableRequest) Reset()

func (*DropTableRequest) String 

func (x *DropTableRequest) String() string

type DropTableResponse 

type DropTableResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*DropTableResponse) Descriptor deprecated 

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

Deprecated: Use DropTableResponse.ProtoReflect.Descriptor instead.

func (*DropTableResponse) GetOperation 

func (x *DropTableResponse) GetOperation() *Ydb_Operations.Operation

func (*DropTableResponse) ProtoMessage 

func (*DropTableResponse) ProtoMessage()

func (*DropTableResponse) ProtoReflect 

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

func (*DropTableResponse) Reset 

func (x *DropTableResponse) Reset()

func (*DropTableResponse) String 

func (x *DropTableResponse) String() string

type ExecuteDataQueryRequest 

type ExecuteDataQueryRequest struct {

	// Session identifier
	SessionId string              `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	TxControl *TransactionControl `protobuf:"bytes,2,opt,name=tx_control,json=txControl,proto3" json:"tx_control,omitempty"`
	Query     *Query              `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"`
	// Map of query parameters (optional)
	Parameters       map[string]*Ydb.TypedValue      `` /* 161-byte string literal not displayed */
	QueryCachePolicy *QueryCachePolicy               `protobuf:"bytes,5,opt,name=query_cache_policy,json=queryCachePolicy,proto3" json:"query_cache_policy,omitempty"`
	OperationParams  *Ydb_Operations.OperationParams `protobuf:"bytes,6,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	CollectStats     QueryStatsCollection_Mode       `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ExecuteDataQueryRequest) Descriptor deprecated 

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

Deprecated: Use ExecuteDataQueryRequest.ProtoReflect.Descriptor instead.

func (*ExecuteDataQueryRequest) GetCollectStats 

func (x *ExecuteDataQueryRequest) GetCollectStats() QueryStatsCollection_Mode

func (*ExecuteDataQueryRequest) GetOperationParams 

func (x *ExecuteDataQueryRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*ExecuteDataQueryRequest) GetParameters 

func (x *ExecuteDataQueryRequest) GetParameters() map[string]*Ydb.TypedValue

func (*ExecuteDataQueryRequest) GetQuery 

func (x *ExecuteDataQueryRequest) GetQuery() *Query

func (*ExecuteDataQueryRequest) GetQueryCachePolicy 

func (x *ExecuteDataQueryRequest) GetQueryCachePolicy() *QueryCachePolicy

func (*ExecuteDataQueryRequest) GetSessionId 

func (x *ExecuteDataQueryRequest) GetSessionId() string

func (*ExecuteDataQueryRequest) GetTxControl 

func (x *ExecuteDataQueryRequest) GetTxControl() *TransactionControl

func (*ExecuteDataQueryRequest) ProtoMessage 

func (*ExecuteDataQueryRequest) ProtoMessage()

func (*ExecuteDataQueryRequest) ProtoReflect 

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

func (*ExecuteDataQueryRequest) Reset 

func (x *ExecuteDataQueryRequest) Reset()

func (*ExecuteDataQueryRequest) String 

func (x *ExecuteDataQueryRequest) String() string

type ExecuteDataQueryResponse 

type ExecuteDataQueryResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteDataQueryResponse) Descriptor deprecated 

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

Deprecated: Use ExecuteDataQueryResponse.ProtoReflect.Descriptor instead.

func (*ExecuteDataQueryResponse) GetOperation 

func (x *ExecuteDataQueryResponse) GetOperation() *Ydb_Operations.Operation

func (*ExecuteDataQueryResponse) ProtoMessage 

func (*ExecuteDataQueryResponse) ProtoMessage()

func (*ExecuteDataQueryResponse) ProtoReflect 

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

func (*ExecuteDataQueryResponse) Reset 

func (x *ExecuteDataQueryResponse) Reset()

func (*ExecuteDataQueryResponse) String 

func (x *ExecuteDataQueryResponse) String() string

type ExecuteQueryResult 

type ExecuteQueryResult struct {

	// Result rets (for each table)
	ResultSets []*Ydb.ResultSet `protobuf:"bytes,1,rep,name=result_sets,json=resultSets,proto3" json:"result_sets,omitempty"`
	// Transaction metadata
	TxMeta *TransactionMeta `protobuf:"bytes,2,opt,name=tx_meta,json=txMeta,proto3" json:"tx_meta,omitempty"`
	// Query metadata
	QueryMeta *QueryMeta `protobuf:"bytes,3,opt,name=query_meta,json=queryMeta,proto3" json:"query_meta,omitempty"`
	// Query execution statistics
	QueryStats *Ydb_TableStats.QueryStats `protobuf:"bytes,4,opt,name=query_stats,json=queryStats,proto3" json:"query_stats,omitempty"`
	// contains filtered or unexported fields
}

One QueryResult can contain multiple tables

func (*ExecuteQueryResult) Descriptor deprecated 

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

Deprecated: Use ExecuteQueryResult.ProtoReflect.Descriptor instead.

func (*ExecuteQueryResult) GetQueryMeta 

func (x *ExecuteQueryResult) GetQueryMeta() *QueryMeta

func (*ExecuteQueryResult) GetQueryStats 

func (x *ExecuteQueryResult) GetQueryStats() *Ydb_TableStats.QueryStats

func (*ExecuteQueryResult) GetResultSets 

func (x *ExecuteQueryResult) GetResultSets() []*Ydb.ResultSet

func (*ExecuteQueryResult) GetTxMeta 

func (x *ExecuteQueryResult) GetTxMeta() *TransactionMeta

func (*ExecuteQueryResult) ProtoMessage 

func (*ExecuteQueryResult) ProtoMessage()

func (*ExecuteQueryResult) ProtoReflect 

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

func (*ExecuteQueryResult) Reset 

func (x *ExecuteQueryResult) Reset()

func (*ExecuteQueryResult) String 

func (x *ExecuteQueryResult) String() string

type ExecuteScanQueryPartialResponse 

type ExecuteScanQueryPartialResponse struct {
	Status Ydb.StatusIds_StatusCode       `protobuf:"varint,1,opt,name=status,proto3,enum=Ydb.StatusIds_StatusCode" json:"status,omitempty"`
	Issues []*Ydb_Issue.IssueMessage      `protobuf:"bytes,2,rep,name=issues,proto3" json:"issues,omitempty"`
	Result *ExecuteScanQueryPartialResult `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteScanQueryPartialResponse) Descriptor deprecated 

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

Deprecated: Use ExecuteScanQueryPartialResponse.ProtoReflect.Descriptor instead.

func (*ExecuteScanQueryPartialResponse) GetIssues 

func (x *ExecuteScanQueryPartialResponse) GetIssues() []*Ydb_Issue.IssueMessage

func (*ExecuteScanQueryPartialResponse) GetResult 

func (x *ExecuteScanQueryPartialResponse) GetResult() *ExecuteScanQueryPartialResult

func (*ExecuteScanQueryPartialResponse) GetStatus 

func (x *ExecuteScanQueryPartialResponse) GetStatus() Ydb.StatusIds_StatusCode

func (*ExecuteScanQueryPartialResponse) ProtoMessage 

func (*ExecuteScanQueryPartialResponse) ProtoMessage()

func (*ExecuteScanQueryPartialResponse) ProtoReflect 

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

func (*ExecuteScanQueryPartialResponse) Reset 

func (x *ExecuteScanQueryPartialResponse) Reset()

func (*ExecuteScanQueryPartialResponse) String 

func (x *ExecuteScanQueryPartialResponse) String() string

type ExecuteScanQueryPartialResult 

type ExecuteScanQueryPartialResult struct {
	ResultSet  *Ydb.ResultSet             `protobuf:"bytes,1,opt,name=result_set,json=resultSet,proto3" json:"result_set,omitempty"`
	QueryStats *Ydb_TableStats.QueryStats `protobuf:"bytes,6,opt,name=query_stats,json=queryStats,proto3" json:"query_stats,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteScanQueryPartialResult) Descriptor deprecated 

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

Deprecated: Use ExecuteScanQueryPartialResult.ProtoReflect.Descriptor instead.

func (*ExecuteScanQueryPartialResult) GetQueryStats 

func (x *ExecuteScanQueryPartialResult) GetQueryStats() *Ydb_TableStats.QueryStats

func (*ExecuteScanQueryPartialResult) GetResultSet 

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

func (*ExecuteScanQueryPartialResult) ProtoMessage 

func (*ExecuteScanQueryPartialResult) ProtoMessage()

func (*ExecuteScanQueryPartialResult) ProtoReflect 

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

func (*ExecuteScanQueryPartialResult) Reset 

func (x *ExecuteScanQueryPartialResult) Reset()

func (*ExecuteScanQueryPartialResult) String 

func (x *ExecuteScanQueryPartialResult) String() string

type ExecuteScanQueryRequest 

type ExecuteScanQueryRequest struct {
	Query        *Query                       `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"`
	Parameters   map[string]*Ydb.TypedValue   `` /* 161-byte string literal not displayed */
	Mode         ExecuteScanQueryRequest_Mode `protobuf:"varint,6,opt,name=mode,proto3,enum=Ydb.Table.ExecuteScanQueryRequest_Mode" json:"mode,omitempty"`
	CollectStats QueryStatsCollection_Mode    `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ExecuteScanQueryRequest) Descriptor deprecated 

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

Deprecated: Use ExecuteScanQueryRequest.ProtoReflect.Descriptor instead.

func (*ExecuteScanQueryRequest) GetCollectStats 

func (x *ExecuteScanQueryRequest) GetCollectStats() QueryStatsCollection_Mode

func (*ExecuteScanQueryRequest) GetMode 

func (x *ExecuteScanQueryRequest) GetMode() ExecuteScanQueryRequest_Mode

func (*ExecuteScanQueryRequest) GetParameters 

func (x *ExecuteScanQueryRequest) GetParameters() map[string]*Ydb.TypedValue

func (*ExecuteScanQueryRequest) GetQuery 

func (x *ExecuteScanQueryRequest) GetQuery() *Query

func (*ExecuteScanQueryRequest) ProtoMessage 

func (*ExecuteScanQueryRequest) ProtoMessage()

func (*ExecuteScanQueryRequest) ProtoReflect 

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

func (*ExecuteScanQueryRequest) Reset 

func (x *ExecuteScanQueryRequest) Reset()

func (*ExecuteScanQueryRequest) String 

func (x *ExecuteScanQueryRequest) String() string

type ExecuteScanQueryRequest_Mode 

type ExecuteScanQueryRequest_Mode int32
const (
	ExecuteScanQueryRequest_MODE_UNSPECIFIED ExecuteScanQueryRequest_Mode = 0
	ExecuteScanQueryRequest_MODE_EXPLAIN     ExecuteScanQueryRequest_Mode = 1
	// MODE_PREPARE = 2;
	ExecuteScanQueryRequest_MODE_EXEC ExecuteScanQueryRequest_Mode = 3
)

func (ExecuteScanQueryRequest_Mode) Descriptor 

func (ExecuteScanQueryRequest_Mode) Descriptor() protoreflect.EnumDescriptor

func (ExecuteScanQueryRequest_Mode) Enum 

func (x ExecuteScanQueryRequest_Mode) Enum() *ExecuteScanQueryRequest_Mode

func (ExecuteScanQueryRequest_Mode) EnumDescriptor deprecated 

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

Deprecated: Use ExecuteScanQueryRequest_Mode.Descriptor instead.

func (ExecuteScanQueryRequest_Mode) Number 

func (x ExecuteScanQueryRequest_Mode) Number() protoreflect.EnumNumber

func (ExecuteScanQueryRequest_Mode) String 

func (x ExecuteScanQueryRequest_Mode) String() string

func (ExecuteScanQueryRequest_Mode) Type 

func (ExecuteScanQueryRequest_Mode) Type() protoreflect.EnumType

type ExecuteSchemeQueryRequest 

type ExecuteSchemeQueryRequest struct {

	// Session identifier
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// SQL text
	YqlText         string                          `protobuf:"bytes,2,opt,name=yql_text,json=yqlText,proto3" json:"yql_text,omitempty"`
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,3,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteSchemeQueryRequest) Descriptor deprecated 

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

Deprecated: Use ExecuteSchemeQueryRequest.ProtoReflect.Descriptor instead.

func (*ExecuteSchemeQueryRequest) GetOperationParams 

func (x *ExecuteSchemeQueryRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*ExecuteSchemeQueryRequest) GetSessionId 

func (x *ExecuteSchemeQueryRequest) GetSessionId() string

func (*ExecuteSchemeQueryRequest) GetYqlText 

func (x *ExecuteSchemeQueryRequest) GetYqlText() string

func (*ExecuteSchemeQueryRequest) ProtoMessage 

func (*ExecuteSchemeQueryRequest) ProtoMessage()

func (*ExecuteSchemeQueryRequest) ProtoReflect 

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

func (*ExecuteSchemeQueryRequest) Reset 

func (x *ExecuteSchemeQueryRequest) Reset()

func (*ExecuteSchemeQueryRequest) String 

func (x *ExecuteSchemeQueryRequest) String() string

type ExecuteSchemeQueryResponse 

type ExecuteSchemeQueryResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteSchemeQueryResponse) Descriptor deprecated 

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

Deprecated: Use ExecuteSchemeQueryResponse.ProtoReflect.Descriptor instead.

func (*ExecuteSchemeQueryResponse) GetOperation 

func (x *ExecuteSchemeQueryResponse) GetOperation() *Ydb_Operations.Operation

func (*ExecuteSchemeQueryResponse) ProtoMessage 

func (*ExecuteSchemeQueryResponse) ProtoMessage()

func (*ExecuteSchemeQueryResponse) ProtoReflect 

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

func (*ExecuteSchemeQueryResponse) Reset 

func (x *ExecuteSchemeQueryResponse) Reset()

func (*ExecuteSchemeQueryResponse) String 

func (x *ExecuteSchemeQueryResponse) String() string

type ExecutionPolicy 

type ExecutionPolicy struct {
	PresetName string `protobuf:"bytes,1,opt,name=preset_name,json=presetName,proto3" json:"preset_name,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecutionPolicy) Descriptor deprecated 

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

Deprecated: Use ExecutionPolicy.ProtoReflect.Descriptor instead.

func (*ExecutionPolicy) GetPresetName 

func (x *ExecutionPolicy) GetPresetName() string

func (*ExecutionPolicy) ProtoMessage 

func (*ExecutionPolicy) ProtoMessage()

func (*ExecutionPolicy) ProtoReflect 

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

func (*ExecutionPolicy) Reset 

func (x *ExecutionPolicy) Reset()

func (*ExecutionPolicy) String 

func (x *ExecutionPolicy) String() string

type ExecutionPolicyDescription 

type ExecutionPolicyDescription struct {
	Name   string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ExecutionPolicyDescription) Descriptor deprecated 

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

Deprecated: Use ExecutionPolicyDescription.ProtoReflect.Descriptor instead.

func (*ExecutionPolicyDescription) GetLabels 

func (x *ExecutionPolicyDescription) GetLabels() map[string]string

func (*ExecutionPolicyDescription) GetName 

func (x *ExecutionPolicyDescription) GetName() string

func (*ExecutionPolicyDescription) ProtoMessage 

func (*ExecutionPolicyDescription) ProtoMessage()

func (*ExecutionPolicyDescription) ProtoReflect 

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

func (*ExecutionPolicyDescription) Reset 

func (x *ExecutionPolicyDescription) Reset()

func (*ExecutionPolicyDescription) String 

func (x *ExecutionPolicyDescription) String() string

type ExplainDataQueryRequest 

type ExplainDataQueryRequest struct {

	// Session identifier
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// SQL text to explain
	YqlText         string                          `protobuf:"bytes,2,opt,name=yql_text,json=yqlText,proto3" json:"yql_text,omitempty"`
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,3,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// 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) GetOperationParams 

func (x *ExplainDataQueryRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*ExplainDataQueryRequest) GetSessionId 

func (x *ExplainDataQueryRequest) GetSessionId() string

func (*ExplainDataQueryRequest) GetYqlText 

func (x *ExplainDataQueryRequest) GetYqlText() string

func (*ExplainDataQueryRequest) ProtoMessage 

func (*ExplainDataQueryRequest) ProtoMessage()

func (*ExplainDataQueryRequest) ProtoReflect 

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

func (*ExplainDataQueryRequest) Reset 

func (x *ExplainDataQueryRequest) Reset()

func (*ExplainDataQueryRequest) String 

func (x *ExplainDataQueryRequest) String() string

type ExplainDataQueryResponse 

type ExplainDataQueryResponse struct {

	// Holds ExplainQueryResult in case of successful call
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*ExplainDataQueryResponse) Descriptor deprecated 

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

Deprecated: Use ExplainDataQueryResponse.ProtoReflect.Descriptor instead.

func (*ExplainDataQueryResponse) GetOperation 

func (x *ExplainDataQueryResponse) GetOperation() *Ydb_Operations.Operation

func (*ExplainDataQueryResponse) ProtoMessage 

func (*ExplainDataQueryResponse) ProtoMessage()

func (*ExplainDataQueryResponse) ProtoReflect 

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

func (*ExplainDataQueryResponse) Reset 

func (x *ExplainDataQueryResponse) Reset()

func (*ExplainDataQueryResponse) String 

func (x *ExplainDataQueryResponse) String() string

type ExplainQueryResult 

type ExplainQueryResult struct {
	QueryAst  string `protobuf:"bytes,1,opt,name=query_ast,json=queryAst,proto3" json:"query_ast,omitempty"`
	QueryPlan string `protobuf:"bytes,2,opt,name=query_plan,json=queryPlan,proto3" json:"query_plan,omitempty"`
	// 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) 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 IndexBuildDescription 

type IndexBuildDescription struct {
	Path  string      `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Index *TableIndex `protobuf:"bytes,2,opt,name=index,proto3" json:"index,omitempty"`
	// contains filtered or unexported fields
}

Description of index building operation

func (*IndexBuildDescription) Descriptor deprecated 

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

Deprecated: Use IndexBuildDescription.ProtoReflect.Descriptor instead.

func (*IndexBuildDescription) GetIndex 

func (x *IndexBuildDescription) GetIndex() *TableIndex

func (*IndexBuildDescription) GetPath 

func (x *IndexBuildDescription) GetPath() string

func (*IndexBuildDescription) ProtoMessage 

func (*IndexBuildDescription) ProtoMessage()

func (*IndexBuildDescription) ProtoReflect 

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

func (*IndexBuildDescription) Reset 

func (x *IndexBuildDescription) Reset()

func (*IndexBuildDescription) String 

func (x *IndexBuildDescription) String() string

type IndexBuildMetadata 

type IndexBuildMetadata struct {
	Description *IndexBuildDescription `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"`
	State       IndexBuildState_State  `protobuf:"varint,2,opt,name=state,proto3,enum=Ydb.Table.IndexBuildState_State" json:"state,omitempty"`
	Progress    float32                `protobuf:"fixed32,3,opt,name=progress,proto3" json:"progress,omitempty"`
	// contains filtered or unexported fields
}

func (*IndexBuildMetadata) Descriptor deprecated 

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

Deprecated: Use IndexBuildMetadata.ProtoReflect.Descriptor instead.

func (*IndexBuildMetadata) GetDescription 

func (x *IndexBuildMetadata) GetDescription() *IndexBuildDescription

func (*IndexBuildMetadata) GetProgress 

func (x *IndexBuildMetadata) GetProgress() float32

func (*IndexBuildMetadata) GetState 

func (x *IndexBuildMetadata) GetState() IndexBuildState_State

func (*IndexBuildMetadata) ProtoMessage 

func (*IndexBuildMetadata) ProtoMessage()

func (*IndexBuildMetadata) ProtoReflect 

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

func (*IndexBuildMetadata) Reset 

func (x *IndexBuildMetadata) Reset()

func (*IndexBuildMetadata) String 

func (x *IndexBuildMetadata) String() string

type IndexBuildState 

type IndexBuildState struct {
	// contains filtered or unexported fields
}

State of index building operation

func (*IndexBuildState) Descriptor deprecated 

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

Deprecated: Use IndexBuildState.ProtoReflect.Descriptor instead.

func (*IndexBuildState) ProtoMessage 

func (*IndexBuildState) ProtoMessage()

func (*IndexBuildState) ProtoReflect 

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

func (*IndexBuildState) Reset 

func (x *IndexBuildState) Reset()

func (*IndexBuildState) String 

func (x *IndexBuildState) String() string

type IndexBuildState_State 

type IndexBuildState_State int32
const (
	IndexBuildState_STATE_UNSPECIFIED      IndexBuildState_State = 0
	IndexBuildState_STATE_PREPARING        IndexBuildState_State = 1
	IndexBuildState_STATE_TRANSFERING_DATA IndexBuildState_State = 2
	IndexBuildState_STATE_APPLYING         IndexBuildState_State = 3
	IndexBuildState_STATE_DONE             IndexBuildState_State = 4
	IndexBuildState_STATE_CANCELLATION     IndexBuildState_State = 5
	IndexBuildState_STATE_CANCELLED        IndexBuildState_State = 6
	IndexBuildState_STATE_REJECTION        IndexBuildState_State = 7
	IndexBuildState_STATE_REJECTED         IndexBuildState_State = 8
)

func (IndexBuildState_State) Descriptor 

func (IndexBuildState_State) Descriptor() protoreflect.EnumDescriptor

func (IndexBuildState_State) Enum 

func (x IndexBuildState_State) Enum() *IndexBuildState_State

func (IndexBuildState_State) EnumDescriptor deprecated 

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

Deprecated: Use IndexBuildState_State.Descriptor instead.

func (IndexBuildState_State) Number 

func (x IndexBuildState_State) Number() protoreflect.EnumNumber

func (IndexBuildState_State) String 

func (x IndexBuildState_State) String() string

func (IndexBuildState_State) Type 

func (IndexBuildState_State) Type() protoreflect.EnumType

type KeepAliveRequest 

type KeepAliveRequest struct {

	// Session identifier
	SessionId       string                          `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,2,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// contains filtered or unexported fields
}

Keep session alive

func (*KeepAliveRequest) Descriptor deprecated 

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

Deprecated: Use KeepAliveRequest.ProtoReflect.Descriptor instead.

func (*KeepAliveRequest) GetOperationParams 

func (x *KeepAliveRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*KeepAliveRequest) GetSessionId 

func (x *KeepAliveRequest) GetSessionId() string

func (*KeepAliveRequest) ProtoMessage 

func (*KeepAliveRequest) ProtoMessage()

func (*KeepAliveRequest) ProtoReflect 

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

func (*KeepAliveRequest) Reset 

func (x *KeepAliveRequest) Reset()

func (*KeepAliveRequest) String 

func (x *KeepAliveRequest) String() string

type KeepAliveResponse 

type KeepAliveResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*KeepAliveResponse) Descriptor deprecated 

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

Deprecated: Use KeepAliveResponse.ProtoReflect.Descriptor instead.

func (*KeepAliveResponse) GetOperation 

func (x *KeepAliveResponse) GetOperation() *Ydb_Operations.Operation

func (*KeepAliveResponse) ProtoMessage 

func (*KeepAliveResponse) ProtoMessage()

func (*KeepAliveResponse) ProtoReflect 

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

func (*KeepAliveResponse) Reset 

func (x *KeepAliveResponse) Reset()

func (*KeepAliveResponse) String 

func (x *KeepAliveResponse) String() string

type KeepAliveResult 

type KeepAliveResult struct {
	SessionStatus KeepAliveResult_SessionStatus `` /* 146-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*KeepAliveResult) Descriptor deprecated 

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

Deprecated: Use KeepAliveResult.ProtoReflect.Descriptor instead.

func (*KeepAliveResult) GetSessionStatus 

func (x *KeepAliveResult) GetSessionStatus() KeepAliveResult_SessionStatus

func (*KeepAliveResult) ProtoMessage 

func (*KeepAliveResult) ProtoMessage()

func (*KeepAliveResult) ProtoReflect 

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

func (*KeepAliveResult) Reset 

func (x *KeepAliveResult) Reset()

func (*KeepAliveResult) String 

func (x *KeepAliveResult) String() string

type KeepAliveResult_SessionStatus 

type KeepAliveResult_SessionStatus int32
const (
	KeepAliveResult_SESSION_STATUS_UNSPECIFIED KeepAliveResult_SessionStatus = 0
	KeepAliveResult_SESSION_STATUS_READY       KeepAliveResult_SessionStatus = 1
	KeepAliveResult_SESSION_STATUS_BUSY        KeepAliveResult_SessionStatus = 2
)

func (KeepAliveResult_SessionStatus) Descriptor 

func (KeepAliveResult_SessionStatus) Descriptor() protoreflect.EnumDescriptor

func (KeepAliveResult_SessionStatus) Enum 

func (x KeepAliveResult_SessionStatus) Enum() *KeepAliveResult_SessionStatus

func (KeepAliveResult_SessionStatus) EnumDescriptor deprecated 

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

Deprecated: Use KeepAliveResult_SessionStatus.Descriptor instead.

func (KeepAliveResult_SessionStatus) Number 

func (x KeepAliveResult_SessionStatus) Number() protoreflect.EnumNumber

func (KeepAliveResult_SessionStatus) String 

func (x KeepAliveResult_SessionStatus) String() string

func (KeepAliveResult_SessionStatus) Type 

func (KeepAliveResult_SessionStatus) Type() protoreflect.EnumType

type KeyRange 

type KeyRange struct {

	// Left border
	//
	// Types that are assignable to FromBound:
	//
	//	*KeyRange_Greater
	//	*KeyRange_GreaterOrEqual
	FromBound isKeyRange_FromBound `protobuf_oneof:"from_bound"`
	// Right border
	//
	// Types that are assignable to ToBound:
	//
	//	*KeyRange_Less
	//	*KeyRange_LessOrEqual
	ToBound isKeyRange_ToBound `protobuf_oneof:"to_bound"`
	// contains filtered or unexported fields
}

func (*KeyRange) Descriptor deprecated 

func (*KeyRange) 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"`
	// contains filtered or unexported fields
}

func (*PartitionStats) Descriptor deprecated 

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

Deprecated: Use PartitionStats.ProtoReflect.Descriptor instead.

func (*PartitionStats) GetRowsEstimate 

func (x *PartitionStats) GetRowsEstimate() uint64

func (*PartitionStats) GetStoreSize 

func (x *PartitionStats) GetStoreSize() uint64

func (*PartitionStats) ProtoMessage 

func (*PartitionStats) ProtoMessage()

func (*PartitionStats) ProtoReflect 

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

func (*PartitionStats) Reset 

func (x *PartitionStats) Reset()

func (*PartitionStats) String 

func (x *PartitionStats) String() string

type PartitioningPolicy 

type PartitioningPolicy struct {
	PresetName       string                                    `protobuf:"bytes,1,opt,name=preset_name,json=presetName,proto3" json:"preset_name,omitempty"`
	AutoPartitioning PartitioningPolicy_AutoPartitioningPolicy `` /* 167-byte string literal not displayed */
	// Types that are assignable to Partitions:
	//
	//	*PartitioningPolicy_UniformPartitions
	//	*PartitioningPolicy_ExplicitPartitions
	Partitions isPartitioningPolicy_Partitions `protobuf_oneof:"partitions"`
	// contains filtered or unexported fields
}

func (*PartitioningPolicy) Descriptor deprecated 

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

Deprecated: Use PartitioningPolicy.ProtoReflect.Descriptor instead.

func (*PartitioningPolicy) GetAutoPartitioning 

func (x *PartitioningPolicy) GetAutoPartitioning() PartitioningPolicy_AutoPartitioningPolicy

func (*PartitioningPolicy) GetExplicitPartitions 

func (x *PartitioningPolicy) GetExplicitPartitions() *ExplicitPartitions

func (*PartitioningPolicy) GetPartitions 

func (m *PartitioningPolicy) GetPartitions() isPartitioningPolicy_Partitions

func (*PartitioningPolicy) GetPresetName 

func (x *PartitioningPolicy) GetPresetName() string

func (*PartitioningPolicy) GetUniformPartitions 

func (x *PartitioningPolicy) GetUniformPartitions() uint64

func (*PartitioningPolicy) ProtoMessage 

func (*PartitioningPolicy) ProtoMessage()

func (*PartitioningPolicy) ProtoReflect 

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

func (*PartitioningPolicy) Reset 

func (x *PartitioningPolicy) Reset()

func (*PartitioningPolicy) String 

func (x *PartitioningPolicy) String() string

type PartitioningPolicyDescription 

type PartitioningPolicyDescription struct {
	Name   string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PartitioningPolicyDescription) Descriptor deprecated 

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

Deprecated: Use PartitioningPolicyDescription.ProtoReflect.Descriptor instead.

func (*PartitioningPolicyDescription) GetLabels 

func (x *PartitioningPolicyDescription) GetLabels() map[string]string

func (*PartitioningPolicyDescription) GetName 

func (x *PartitioningPolicyDescription) GetName() string

func (*PartitioningPolicyDescription) ProtoMessage 

func (*PartitioningPolicyDescription) ProtoMessage()

func (*PartitioningPolicyDescription) ProtoReflect 

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

func (*PartitioningPolicyDescription) Reset 

func (x *PartitioningPolicyDescription) Reset()

func (*PartitioningPolicyDescription) String 

func (x *PartitioningPolicyDescription) String() string

type PartitioningPolicy_AutoPartitioningPolicy 

type PartitioningPolicy_AutoPartitioningPolicy int32
const (
	PartitioningPolicy_AUTO_PARTITIONING_POLICY_UNSPECIFIED PartitioningPolicy_AutoPartitioningPolicy = 0
	PartitioningPolicy_DISABLED                             PartitioningPolicy_AutoPartitioningPolicy = 1
	PartitioningPolicy_AUTO_SPLIT                           PartitioningPolicy_AutoPartitioningPolicy = 2
	PartitioningPolicy_AUTO_SPLIT_MERGE                     PartitioningPolicy_AutoPartitioningPolicy = 3
)

func (PartitioningPolicy_AutoPartitioningPolicy) Descriptor 

func (PartitioningPolicy_AutoPartitioningPolicy) Descriptor() protoreflect.EnumDescriptor

func (PartitioningPolicy_AutoPartitioningPolicy) Enum 

func (x PartitioningPolicy_AutoPartitioningPolicy) Enum() *PartitioningPolicy_AutoPartitioningPolicy

func (PartitioningPolicy_AutoPartitioningPolicy) EnumDescriptor deprecated 

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

Deprecated: Use PartitioningPolicy_AutoPartitioningPolicy.Descriptor instead.

func (PartitioningPolicy_AutoPartitioningPolicy) Number 

func (x PartitioningPolicy_AutoPartitioningPolicy) Number() protoreflect.EnumNumber

func (PartitioningPolicy_AutoPartitioningPolicy) String 

func (x PartitioningPolicy_AutoPartitioningPolicy) String() string

func (PartitioningPolicy_AutoPartitioningPolicy) Type 

func (PartitioningPolicy_AutoPartitioningPolicy) Type() protoreflect.EnumType

type PartitioningPolicy_ExplicitPartitions 

type PartitioningPolicy_ExplicitPartitions struct {
	// Explicitly specify key values which are used as borders for
	// created partitions.
	ExplicitPartitions *ExplicitPartitions `protobuf:"bytes,4,opt,name=explicit_partitions,json=explicitPartitions,proto3,oneof"`
}

type PartitioningPolicy_UniformPartitions 

type PartitioningPolicy_UniformPartitions struct {
	// Allows to enable uniform sharding using given shards number.
	// The first components of primary key must have Uint32/Uint64 type.
	UniformPartitions uint64 `protobuf:"varint,3,opt,name=uniform_partitions,json=uniformPartitions,proto3,oneof"`
}

type PartitioningSettings 

type PartitioningSettings struct {

	// List of columns to partition by
	PartitionBy []string `protobuf:"bytes,1,rep,name=partition_by,json=partitionBy,proto3" json:"partition_by,omitempty"`
	// Enable auto partitioning on reaching upper or lower partition size bound
	PartitioningBySize Ydb.FeatureFlag_Status `` /* 146-byte string literal not displayed */
	// Preferred partition size for auto partitioning by size, Mb
	PartitionSizeMb uint64 `protobuf:"varint,3,opt,name=partition_size_mb,json=partitionSizeMb,proto3" json:"partition_size_mb,omitempty"`
	// Enable auto partitioning based on load on each partition
	PartitioningByLoad Ydb.FeatureFlag_Status `` /* 146-byte string literal not displayed */
	// Minimum partitions count auto merge would stop working at
	MinPartitionsCount uint64 `protobuf:"varint,6,opt,name=min_partitions_count,json=minPartitionsCount,proto3" json:"min_partitions_count,omitempty"`
	// Maximum partitions count auto split would stop working at
	MaxPartitionsCount uint64 `protobuf:"varint,7,opt,name=max_partitions_count,json=maxPartitionsCount,proto3" json:"max_partitions_count,omitempty"`
	// contains filtered or unexported fields
}

func (*PartitioningSettings) Descriptor deprecated 

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

Deprecated: Use PartitioningSettings.ProtoReflect.Descriptor instead.

func (*PartitioningSettings) GetMaxPartitionsCount 

func (x *PartitioningSettings) GetMaxPartitionsCount() uint64

func (*PartitioningSettings) GetMinPartitionsCount 

func (x *PartitioningSettings) GetMinPartitionsCount() uint64

func (*PartitioningSettings) GetPartitionBy 

func (x *PartitioningSettings) GetPartitionBy() []string

func (*PartitioningSettings) GetPartitionSizeMb 

func (x *PartitioningSettings) GetPartitionSizeMb() uint64

func (*PartitioningSettings) GetPartitioningByLoad 

func (x *PartitioningSettings) GetPartitioningByLoad() Ydb.FeatureFlag_Status

func (*PartitioningSettings) GetPartitioningBySize 

func (x *PartitioningSettings) GetPartitioningBySize() Ydb.FeatureFlag_Status

func (*PartitioningSettings) ProtoMessage 

func (*PartitioningSettings) ProtoMessage()

func (*PartitioningSettings) ProtoReflect 

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

func (*PartitioningSettings) Reset 

func (x *PartitioningSettings) Reset()

func (*PartitioningSettings) String 

func (x *PartitioningSettings) String() string

type PrepareDataQueryRequest 

type PrepareDataQueryRequest struct {

	// Session identifier
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// SQL text
	YqlText         string                          `protobuf:"bytes,2,opt,name=yql_text,json=yqlText,proto3" json:"yql_text,omitempty"`
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,3,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// contains filtered or unexported fields
}

Prepare given program to execute

func (*PrepareDataQueryRequest) Descriptor deprecated 

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

Deprecated: Use PrepareDataQueryRequest.ProtoReflect.Descriptor instead.

func (*PrepareDataQueryRequest) GetOperationParams 

func (x *PrepareDataQueryRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*PrepareDataQueryRequest) GetSessionId 

func (x *PrepareDataQueryRequest) GetSessionId() string

func (*PrepareDataQueryRequest) GetYqlText 

func (x *PrepareDataQueryRequest) GetYqlText() string

func (*PrepareDataQueryRequest) ProtoMessage 

func (*PrepareDataQueryRequest) ProtoMessage()

func (*PrepareDataQueryRequest) ProtoReflect 

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

func (*PrepareDataQueryRequest) Reset 

func (x *PrepareDataQueryRequest) Reset()

func (*PrepareDataQueryRequest) String 

func (x *PrepareDataQueryRequest) String() string

type PrepareDataQueryResponse 

type PrepareDataQueryResponse struct {

	// Holds PrepareQueryResult in case of successful call
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*PrepareDataQueryResponse) Descriptor deprecated 

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

Deprecated: Use PrepareDataQueryResponse.ProtoReflect.Descriptor instead.

func (*PrepareDataQueryResponse) GetOperation 

func (x *PrepareDataQueryResponse) GetOperation() *Ydb_Operations.Operation

func (*PrepareDataQueryResponse) ProtoMessage 

func (*PrepareDataQueryResponse) ProtoMessage()

func (*PrepareDataQueryResponse) ProtoReflect 

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

func (*PrepareDataQueryResponse) Reset 

func (x *PrepareDataQueryResponse) Reset()

func (*PrepareDataQueryResponse) String 

func (x *PrepareDataQueryResponse) String() string

type PrepareQueryResult 

type PrepareQueryResult struct {

	// Query id, used to perform ExecuteDataQuery
	QueryId string `protobuf:"bytes,1,opt,name=query_id,json=queryId,proto3" json:"query_id,omitempty"`
	// Parameters type, used to fill in parameter values
	ParametersTypes map[string]*Ydb.Type `` /* 194-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PrepareQueryResult) Descriptor deprecated 

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

Deprecated: Use PrepareQueryResult.ProtoReflect.Descriptor instead.

func (*PrepareQueryResult) GetParametersTypes 

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

func (*PrepareQueryResult) GetQueryId 

func (x *PrepareQueryResult) GetQueryId() string

func (*PrepareQueryResult) ProtoMessage 

func (*PrepareQueryResult) ProtoMessage()

func (*PrepareQueryResult) ProtoReflect 

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

func (*PrepareQueryResult) Reset 

func (x *PrepareQueryResult) Reset()

func (*PrepareQueryResult) String 

func (x *PrepareQueryResult) String() string

type Query 

type Query struct {

	// Text of query or id prepared query
	//
	// Types that are assignable to Query:
	//
	//	*Query_YqlText
	//	*Query_Id
	Query isQuery_Query `protobuf_oneof:"query"`
	// contains filtered or unexported fields
}

func (*Query) Descriptor deprecated 

func (*Query) 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) Descriptor() protoreflect.EnumDescriptor

func (QueryStatsCollection_Mode) Enum 

func (x QueryStatsCollection_Mode) Enum() *QueryStatsCollection_Mode

func (QueryStatsCollection_Mode) EnumDescriptor deprecated 

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

Deprecated: Use QueryStatsCollection_Mode.Descriptor instead.

func (QueryStatsCollection_Mode) Number 

func (x QueryStatsCollection_Mode) Number() protoreflect.EnumNumber

func (QueryStatsCollection_Mode) String 

func (x QueryStatsCollection_Mode) String() string

func (QueryStatsCollection_Mode) Type 

func (QueryStatsCollection_Mode) Type() protoreflect.EnumType

type Query_Id 

type Query_Id struct {
	// Prepared query id
	Id string `protobuf:"bytes,2,opt,name=id,proto3,oneof"`
}

type Query_YqlText 

type Query_YqlText struct {
	// SQL program
	YqlText string `protobuf:"bytes,1,opt,name=yql_text,json=yqlText,proto3,oneof"`
}

type ReadReplicasSettings 

type ReadReplicasSettings struct {

	// Types that are assignable to Settings:
	//
	//	*ReadReplicasSettings_PerAzReadReplicasCount
	//	*ReadReplicasSettings_AnyAzReadReplicasCount
	Settings isReadReplicasSettings_Settings `protobuf_oneof:"settings"`
	// contains filtered or unexported fields
}

func (*ReadReplicasSettings) Descriptor deprecated 

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

Deprecated: Use ReadReplicasSettings.ProtoReflect.Descriptor instead.

func (*ReadReplicasSettings) GetAnyAzReadReplicasCount 

func (x *ReadReplicasSettings) GetAnyAzReadReplicasCount() uint64

func (*ReadReplicasSettings) GetPerAzReadReplicasCount 

func (x *ReadReplicasSettings) GetPerAzReadReplicasCount() uint64

func (*ReadReplicasSettings) GetSettings 

func (m *ReadReplicasSettings) GetSettings() isReadReplicasSettings_Settings

func (*ReadReplicasSettings) ProtoMessage 

func (*ReadReplicasSettings) ProtoMessage()

func (*ReadReplicasSettings) ProtoReflect 

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

func (*ReadReplicasSettings) Reset 

func (x *ReadReplicasSettings) Reset()

func (*ReadReplicasSettings) String 

func (x *ReadReplicasSettings) String() string

type ReadReplicasSettings_AnyAzReadReplicasCount 

type ReadReplicasSettings_AnyAzReadReplicasCount struct {
	// Set total replicas count between all AZs
	AnyAzReadReplicasCount uint64 `protobuf:"varint,2,opt,name=any_az_read_replicas_count,json=anyAzReadReplicasCount,proto3,oneof"`
}

type ReadReplicasSettings_PerAzReadReplicasCount 

type ReadReplicasSettings_PerAzReadReplicasCount struct {
	// Set equal read replicas count for every AZ
	PerAzReadReplicasCount uint64 `protobuf:"varint,1,opt,name=per_az_read_replicas_count,json=perAzReadReplicasCount,proto3,oneof"`
}

type ReadRowsRequest 

type ReadRowsRequest struct {

	// Session identifier
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// Path to table to read
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// Keys to read. Must be a list of structs where each stuct is a key
	// for one requested row and should contain all key columns
	Keys *Ydb.TypedValue `protobuf:"bytes,3,opt,name=keys,proto3" json:"keys,omitempty"`
	// Output columns. If empty all columns will be requested
	Columns []string `protobuf:"bytes,4,rep,name=columns,proto3" json:"columns,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadRowsRequest) Descriptor deprecated 

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

Deprecated: Use ReadRowsRequest.ProtoReflect.Descriptor instead.

func (*ReadRowsRequest) GetColumns 

func (x *ReadRowsRequest) GetColumns() []string

func (*ReadRowsRequest) GetKeys 

func (x *ReadRowsRequest) GetKeys() *Ydb.TypedValue

func (*ReadRowsRequest) GetPath 

func (x *ReadRowsRequest) GetPath() string

func (*ReadRowsRequest) GetSessionId 

func (x *ReadRowsRequest) GetSessionId() string

func (*ReadRowsRequest) ProtoMessage 

func (*ReadRowsRequest) ProtoMessage()

func (*ReadRowsRequest) ProtoReflect 

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

func (*ReadRowsRequest) Reset 

func (x *ReadRowsRequest) Reset()

func (*ReadRowsRequest) String 

func (x *ReadRowsRequest) String() string

type ReadRowsResponse 

type ReadRowsResponse struct {

	// Status of request (same as other statuses)
	Status Ydb.StatusIds_StatusCode `protobuf:"varint,1,opt,name=status,proto3,enum=Ydb.StatusIds_StatusCode" json:"status,omitempty"`
	// Issues
	Issues []*Ydb_Issue.IssueMessage `protobuf:"bytes,2,rep,name=issues,proto3" json:"issues,omitempty"`
	// Result set (same as result of sql request)
	ResultSet *Ydb.ResultSet `protobuf:"bytes,3,opt,name=result_set,json=resultSet,proto3" json:"result_set,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadRowsResponse) Descriptor deprecated 

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

Deprecated: Use ReadRowsResponse.ProtoReflect.Descriptor instead.

func (*ReadRowsResponse) GetIssues 

func (x *ReadRowsResponse) GetIssues() []*Ydb_Issue.IssueMessage

func (*ReadRowsResponse) GetResultSet 

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

func (*ReadRowsResponse) GetStatus 

func (x *ReadRowsResponse) GetStatus() Ydb.StatusIds_StatusCode

func (*ReadRowsResponse) ProtoMessage 

func (*ReadRowsResponse) ProtoMessage()

func (*ReadRowsResponse) ProtoReflect 

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

func (*ReadRowsResponse) Reset 

func (x *ReadRowsResponse) Reset()

func (*ReadRowsResponse) String 

func (x *ReadRowsResponse) String() string

type ReadTableRequest 

type ReadTableRequest struct {

	// Session identifier
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// Path to table to read
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// Primary key range to read
	KeyRange *KeyRange `protobuf:"bytes,3,opt,name=key_range,json=keyRange,proto3" json:"key_range,omitempty"`
	// Output columns
	Columns []string `protobuf:"bytes,4,rep,name=columns,proto3" json:"columns,omitempty"`
	// Require ordered reading
	Ordered bool `protobuf:"varint,5,opt,name=ordered,proto3" json:"ordered,omitempty"`
	// Limits row count to read
	RowLimit uint64 `protobuf:"varint,6,opt,name=row_limit,json=rowLimit,proto3" json:"row_limit,omitempty"`
	// Use a server-side snapshot
	UseSnapshot Ydb.FeatureFlag_Status `protobuf:"varint,7,opt,name=use_snapshot,json=useSnapshot,proto3,enum=Ydb.FeatureFlag_Status" json:"use_snapshot,omitempty"`
	// Server-side best-effort policy. Can be used as a hint to limit the size
	// of batches sent from a server. If both are specified, the server chooses
	// the smaller one. The limits are not strict, so batch size can be slightly
	// greater than any of the limits
	BatchLimitBytes uint64 `protobuf:"varint,8,opt,name=batch_limit_bytes,json=batchLimitBytes,proto3" json:"batch_limit_bytes,omitempty"`
	BatchLimitRows  uint64 `protobuf:"varint,9,opt,name=batch_limit_rows,json=batchLimitRows,proto3" json:"batch_limit_rows,omitempty"`
	// 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) GetRowLimit 

func (x *ReadTableRequest) GetRowLimit() uint64

func (*ReadTableRequest) GetSessionId 

func (x *ReadTableRequest) GetSessionId() string

func (*ReadTableRequest) GetUseSnapshot 

func (x *ReadTableRequest) GetUseSnapshot() Ydb.FeatureFlag_Status

func (*ReadTableRequest) ProtoMessage 

func (*ReadTableRequest) ProtoMessage()

func (*ReadTableRequest) ProtoReflect 

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

func (*ReadTableRequest) Reset 

func (x *ReadTableRequest) Reset()

func (*ReadTableRequest) String 

func (x *ReadTableRequest) String() string

type ReadTableResponse 

type ReadTableResponse struct {

	// Status of request (same as other statuses)
	Status Ydb.StatusIds_StatusCode `protobuf:"varint,1,opt,name=status,proto3,enum=Ydb.StatusIds_StatusCode" json:"status,omitempty"`
	// Issues
	Issues []*Ydb_Issue.IssueMessage `protobuf:"bytes,2,rep,name=issues,proto3" json:"issues,omitempty"`
	// Optional snapshot that corresponds to the returned data
	Snapshot *Ydb.VirtualTimestamp `protobuf:"bytes,4,opt,name=snapshot,proto3" json:"snapshot,omitempty"`
	// Read table result
	Result *ReadTableResult `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

ReadTable doesn't use Operation, returns result directly

func (*ReadTableResponse) Descriptor deprecated 

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

Deprecated: Use ReadTableResponse.ProtoReflect.Descriptor instead.

func (*ReadTableResponse) GetIssues 

func (x *ReadTableResponse) GetIssues() []*Ydb_Issue.IssueMessage

func (*ReadTableResponse) GetResult 

func (x *ReadTableResponse) GetResult() *ReadTableResult

func (*ReadTableResponse) GetSnapshot 

func (x *ReadTableResponse) GetSnapshot() *Ydb.VirtualTimestamp

func (*ReadTableResponse) GetStatus 

func (x *ReadTableResponse) GetStatus() Ydb.StatusIds_StatusCode

func (*ReadTableResponse) ProtoMessage 

func (*ReadTableResponse) ProtoMessage()

func (*ReadTableResponse) ProtoReflect 

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

func (*ReadTableResponse) Reset 

func (x *ReadTableResponse) Reset()

func (*ReadTableResponse) String 

func (x *ReadTableResponse) String() string

type ReadTableResult 

type ReadTableResult struct {

	// Result set (same as result of sql request)
	ResultSet *Ydb.ResultSet `protobuf:"bytes,1,opt,name=result_set,json=resultSet,proto3" json:"result_set,omitempty"`
	// contains filtered or unexported fields
}

Result of read table request

func (*ReadTableResult) Descriptor deprecated 

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

Deprecated: Use ReadTableResult.ProtoReflect.Descriptor instead.

func (*ReadTableResult) GetResultSet 

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

func (*ReadTableResult) ProtoMessage 

func (*ReadTableResult) ProtoMessage()

func (*ReadTableResult) ProtoReflect 

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

func (*ReadTableResult) Reset 

func (x *ReadTableResult) Reset()

func (*ReadTableResult) String 

func (x *ReadTableResult) String() string

type RenameIndexItem 

type RenameIndexItem struct {

	// Index name to rename
	SourceName string `protobuf:"bytes,1,opt,name=source_name,json=sourceName,proto3" json:"source_name,omitempty"`
	// Target index name
	DestinationName string `protobuf:"bytes,2,opt,name=destination_name,json=destinationName,proto3" json:"destination_name,omitempty"`
	// Move options
	ReplaceDestination bool `protobuf:"varint,3,opt,name=replace_destination,json=replaceDestination,proto3" json:"replace_destination,omitempty"`
	// contains filtered or unexported fields
}

func (*RenameIndexItem) Descriptor deprecated 

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

Deprecated: Use RenameIndexItem.ProtoReflect.Descriptor instead.

func (*RenameIndexItem) GetDestinationName 

func (x *RenameIndexItem) GetDestinationName() string

func (*RenameIndexItem) GetReplaceDestination 

func (x *RenameIndexItem) GetReplaceDestination() bool

func (*RenameIndexItem) GetSourceName 

func (x *RenameIndexItem) GetSourceName() string

func (*RenameIndexItem) ProtoMessage 

func (*RenameIndexItem) ProtoMessage()

func (*RenameIndexItem) ProtoReflect 

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

func (*RenameIndexItem) Reset 

func (x *RenameIndexItem) Reset()

func (*RenameIndexItem) String 

func (x *RenameIndexItem) String() string

type RenameTableItem 

type RenameTableItem struct {

	// Full path
	SourcePath string `protobuf:"bytes,1,opt,name=source_path,json=sourcePath,proto3" json:"source_path,omitempty"`
	// Full path
	DestinationPath string `protobuf:"bytes,2,opt,name=destination_path,json=destinationPath,proto3" json:"destination_path,omitempty"`
	// Move options
	ReplaceDestination bool `protobuf:"varint,3,opt,name=replace_destination,json=replaceDestination,proto3" json:"replace_destination,omitempty"`
	// contains filtered or unexported fields
}

func (*RenameTableItem) Descriptor deprecated 

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

Deprecated: Use RenameTableItem.ProtoReflect.Descriptor instead.

func (*RenameTableItem) GetDestinationPath 

func (x *RenameTableItem) GetDestinationPath() string

func (*RenameTableItem) GetReplaceDestination 

func (x *RenameTableItem) GetReplaceDestination() bool

func (*RenameTableItem) GetSourcePath 

func (x *RenameTableItem) GetSourcePath() string

func (*RenameTableItem) ProtoMessage 

func (*RenameTableItem) ProtoMessage()

func (*RenameTableItem) ProtoReflect 

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

func (*RenameTableItem) Reset 

func (x *RenameTableItem) Reset()

func (*RenameTableItem) String 

func (x *RenameTableItem) String() string

type RenameTablesRequest 

type RenameTablesRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// Session identifier
	SessionId string `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// Source and destination paths inside RenameTableItem describe rename actions
	Tables []*RenameTableItem `protobuf:"bytes,3,rep,name=tables,proto3" json:"tables,omitempty"`
	// contains filtered or unexported fields
}

Moves given tables

func (*RenameTablesRequest) Descriptor deprecated 

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

Deprecated: Use RenameTablesRequest.ProtoReflect.Descriptor instead.

func (*RenameTablesRequest) GetOperationParams 

func (x *RenameTablesRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*RenameTablesRequest) GetSessionId 

func (x *RenameTablesRequest) GetSessionId() string

func (*RenameTablesRequest) GetTables 

func (x *RenameTablesRequest) GetTables() []*RenameTableItem

func (*RenameTablesRequest) ProtoMessage 

func (*RenameTablesRequest) ProtoMessage()

func (*RenameTablesRequest) ProtoReflect 

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

func (*RenameTablesRequest) Reset 

func (x *RenameTablesRequest) Reset()

func (*RenameTablesRequest) String 

func (x *RenameTablesRequest) String() string

type RenameTablesResponse 

type RenameTablesResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*RenameTablesResponse) Descriptor deprecated 

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

Deprecated: Use RenameTablesResponse.ProtoReflect.Descriptor instead.

func (*RenameTablesResponse) GetOperation 

func (x *RenameTablesResponse) GetOperation() *Ydb_Operations.Operation

func (*RenameTablesResponse) ProtoMessage 

func (*RenameTablesResponse) ProtoMessage()

func (*RenameTablesResponse) ProtoReflect 

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

func (*RenameTablesResponse) Reset 

func (x *RenameTablesResponse) Reset()

func (*RenameTablesResponse) String 

func (x *RenameTablesResponse) String() string

type ReplicationPolicy 

type ReplicationPolicy struct {
	PresetName string `protobuf:"bytes,1,opt,name=preset_name,json=presetName,proto3" json:"preset_name,omitempty"`
	// If value is non-zero then it specifies a number of read-only
	// replicas to create for a table. Zero value means preset
	// setting usage.
	ReplicasCount uint32 `protobuf:"varint,2,opt,name=replicas_count,json=replicasCount,proto3" json:"replicas_count,omitempty"`
	// If this feature in enabled then requested number of replicas
	// will be created in each availability zone.
	CreatePerAvailabilityZone Ydb.FeatureFlag_Status `` /* 169-byte string literal not displayed */
	// If this feature in enabled then read-only replicas can be promoted
	// to leader.
	AllowPromotion Ydb.FeatureFlag_Status `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ReplicationPolicy) Descriptor deprecated 

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

Deprecated: Use ReplicationPolicy.ProtoReflect.Descriptor instead.

func (*ReplicationPolicy) GetAllowPromotion 

func (x *ReplicationPolicy) GetAllowPromotion() Ydb.FeatureFlag_Status

func (*ReplicationPolicy) GetCreatePerAvailabilityZone 

func (x *ReplicationPolicy) GetCreatePerAvailabilityZone() Ydb.FeatureFlag_Status

func (*ReplicationPolicy) GetPresetName 

func (x *ReplicationPolicy) GetPresetName() string

func (*ReplicationPolicy) GetReplicasCount 

func (x *ReplicationPolicy) GetReplicasCount() uint32

func (*ReplicationPolicy) ProtoMessage 

func (*ReplicationPolicy) ProtoMessage()

func (*ReplicationPolicy) ProtoReflect 

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

func (*ReplicationPolicy) Reset 

func (x *ReplicationPolicy) Reset()

func (*ReplicationPolicy) String 

func (x *ReplicationPolicy) String() string

type ReplicationPolicyDescription 

type ReplicationPolicyDescription struct {
	Name   string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ReplicationPolicyDescription) Descriptor deprecated 

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

Deprecated: Use ReplicationPolicyDescription.ProtoReflect.Descriptor instead.

func (*ReplicationPolicyDescription) GetLabels 

func (x *ReplicationPolicyDescription) GetLabels() map[string]string

func (*ReplicationPolicyDescription) GetName 

func (x *ReplicationPolicyDescription) GetName() string

func (*ReplicationPolicyDescription) ProtoMessage 

func (*ReplicationPolicyDescription) ProtoMessage()

func (*ReplicationPolicyDescription) ProtoReflect 

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

func (*ReplicationPolicyDescription) Reset 

func (x *ReplicationPolicyDescription) Reset()

func (*ReplicationPolicyDescription) String 

func (x *ReplicationPolicyDescription) String() string

type RollbackTransactionRequest 

type RollbackTransactionRequest struct {

	// Session identifier
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// Transaction identifier
	TxId            string                          `protobuf:"bytes,2,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"`
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,3,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// contains filtered or unexported fields
}

Rollback transaction with given session and tx id

func (*RollbackTransactionRequest) Descriptor deprecated 

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

Deprecated: Use RollbackTransactionRequest.ProtoReflect.Descriptor instead.

func (*RollbackTransactionRequest) GetOperationParams 

func (x *RollbackTransactionRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*RollbackTransactionRequest) GetSessionId 

func (x *RollbackTransactionRequest) GetSessionId() string

func (*RollbackTransactionRequest) GetTxId 

func (x *RollbackTransactionRequest) GetTxId() string

func (*RollbackTransactionRequest) ProtoMessage 

func (*RollbackTransactionRequest) ProtoMessage()

func (*RollbackTransactionRequest) ProtoReflect 

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

func (*RollbackTransactionRequest) Reset 

func (x *RollbackTransactionRequest) Reset()

func (*RollbackTransactionRequest) String 

func (x *RollbackTransactionRequest) String() string

type RollbackTransactionResponse 

type RollbackTransactionResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*RollbackTransactionResponse) Descriptor deprecated 

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

Deprecated: Use RollbackTransactionResponse.ProtoReflect.Descriptor instead.

func (*RollbackTransactionResponse) GetOperation 

func (x *RollbackTransactionResponse) GetOperation() *Ydb_Operations.Operation

func (*RollbackTransactionResponse) ProtoMessage 

func (*RollbackTransactionResponse) ProtoMessage()

func (*RollbackTransactionResponse) ProtoReflect 

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

func (*RollbackTransactionResponse) Reset 

func (x *RollbackTransactionResponse) Reset()

func (*RollbackTransactionResponse) String 

func (x *RollbackTransactionResponse) String() string

type 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 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
	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) 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
	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) GetIndexColumns 

func (x *TableIndexDescription) GetIndexColumns() []string

func (*TableIndexDescription) GetName 

func (x *TableIndexDescription) GetName() string

func (*TableIndexDescription) GetSizeBytes 

func (x *TableIndexDescription) GetSizeBytes() uint64

func (*TableIndexDescription) GetStatus 

func (x *TableIndexDescription) GetStatus() TableIndexDescription_Status

func (*TableIndexDescription) GetType 

func (m *TableIndexDescription) GetType() isTableIndexDescription_Type

func (*TableIndexDescription) ProtoMessage 

func (*TableIndexDescription) ProtoMessage()

func (*TableIndexDescription) ProtoReflect 

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

func (*TableIndexDescription) Reset 

func (x *TableIndexDescription) Reset()

func (*TableIndexDescription) String 

func (x *TableIndexDescription) String() string

type TableIndexDescription_GlobalAsyncIndex 

type TableIndexDescription_GlobalAsyncIndex struct {
	GlobalAsyncIndex *GlobalAsyncIndex `protobuf:"bytes,5,opt,name=global_async_index,json=globalAsyncIndex,proto3,oneof"`
}

type TableIndexDescription_GlobalIndex 

type TableIndexDescription_GlobalIndex struct {
	GlobalIndex *GlobalIndex `protobuf:"bytes,3,opt,name=global_index,json=globalIndex,proto3,oneof"`
}

type TableIndexDescription_Status 

type TableIndexDescription_Status int32
const (
	TableIndexDescription_STATUS_UNSPECIFIED TableIndexDescription_Status = 0
	// Index is ready to use
	TableIndexDescription_STATUS_READY TableIndexDescription_Status = 1
	// index is being built
	TableIndexDescription_STATUS_BUILDING TableIndexDescription_Status = 2
)

func (TableIndexDescription_Status) Descriptor 

func (TableIndexDescription_Status) Descriptor() protoreflect.EnumDescriptor

func (TableIndexDescription_Status) Enum 

func (x TableIndexDescription_Status) Enum() *TableIndexDescription_Status

func (TableIndexDescription_Status) EnumDescriptor deprecated 

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

Deprecated: Use TableIndexDescription_Status.Descriptor instead.

func (TableIndexDescription_Status) Number 

func (x TableIndexDescription_Status) Number() protoreflect.EnumNumber

func (TableIndexDescription_Status) String 

func (x TableIndexDescription_Status) String() string

func (TableIndexDescription_Status) Type 

func (TableIndexDescription_Status) Type() protoreflect.EnumType

type TableIndex_GlobalAsyncIndex 

type TableIndex_GlobalAsyncIndex struct {
	GlobalAsyncIndex *GlobalAsyncIndex `protobuf:"bytes,4,opt,name=global_async_index,json=globalAsyncIndex,proto3,oneof"`
}

type TableIndex_GlobalIndex 

type TableIndex_GlobalIndex struct {
	GlobalIndex *GlobalIndex `protobuf:"bytes,3,opt,name=global_index,json=globalIndex,proto3,oneof"`
}

type TableProfile 

type TableProfile struct {
	PresetName         string              `protobuf:"bytes,1,opt,name=preset_name,json=presetName,proto3" json:"preset_name,omitempty"`
	StoragePolicy      *StoragePolicy      `protobuf:"bytes,2,opt,name=storage_policy,json=storagePolicy,proto3" json:"storage_policy,omitempty"`
	CompactionPolicy   *CompactionPolicy   `protobuf:"bytes,3,opt,name=compaction_policy,json=compactionPolicy,proto3" json:"compaction_policy,omitempty"`
	PartitioningPolicy *PartitioningPolicy `protobuf:"bytes,4,opt,name=partitioning_policy,json=partitioningPolicy,proto3" json:"partitioning_policy,omitempty"`
	ExecutionPolicy    *ExecutionPolicy    `protobuf:"bytes,5,opt,name=execution_policy,json=executionPolicy,proto3" json:"execution_policy,omitempty"`
	ReplicationPolicy  *ReplicationPolicy  `protobuf:"bytes,6,opt,name=replication_policy,json=replicationPolicy,proto3" json:"replication_policy,omitempty"`
	CachingPolicy      *CachingPolicy      `protobuf:"bytes,7,opt,name=caching_policy,json=cachingPolicy,proto3" json:"caching_policy,omitempty"`
	// contains filtered or unexported fields
}

func (*TableProfile) Descriptor deprecated 

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

Deprecated: Use TableProfile.ProtoReflect.Descriptor instead.

func (*TableProfile) GetCachingPolicy 

func (x *TableProfile) GetCachingPolicy() *CachingPolicy

func (*TableProfile) GetCompactionPolicy 

func (x *TableProfile) GetCompactionPolicy() *CompactionPolicy

func (*TableProfile) GetExecutionPolicy 

func (x *TableProfile) GetExecutionPolicy() *ExecutionPolicy

func (*TableProfile) GetPartitioningPolicy 

func (x *TableProfile) GetPartitioningPolicy() *PartitioningPolicy

func (*TableProfile) GetPresetName 

func (x *TableProfile) GetPresetName() string

func (*TableProfile) GetReplicationPolicy 

func (x *TableProfile) GetReplicationPolicy() *ReplicationPolicy

func (*TableProfile) GetStoragePolicy 

func (x *TableProfile) GetStoragePolicy() *StoragePolicy

func (*TableProfile) ProtoMessage 

func (*TableProfile) ProtoMessage()

func (*TableProfile) ProtoReflect 

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

func (*TableProfile) Reset 

func (x *TableProfile) Reset()

func (*TableProfile) String 

func (x *TableProfile) String() string

type TableProfileDescription 

type TableProfileDescription struct {
	Name                        string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Labels                      map[string]string `` /* 153-byte string literal not displayed */
	DefaultStoragePolicy        string            `protobuf:"bytes,3,opt,name=default_storage_policy,json=defaultStoragePolicy,proto3" json:"default_storage_policy,omitempty"`
	AllowedStoragePolicies      []string          `` /* 129-byte string literal not displayed */
	DefaultCompactionPolicy     string            `` /* 132-byte string literal not displayed */
	AllowedCompactionPolicies   []string          `` /* 138-byte string literal not displayed */
	DefaultPartitioningPolicy   string            `` /* 138-byte string literal not displayed */
	AllowedPartitioningPolicies []string          `` /* 144-byte string literal not displayed */
	DefaultExecutionPolicy      string            `` /* 129-byte string literal not displayed */
	AllowedExecutionPolicies    []string          `` /* 136-byte string literal not displayed */
	DefaultReplicationPolicy    string            `` /* 136-byte string literal not displayed */
	AllowedReplicationPolicies  []string          `` /* 142-byte string literal not displayed */
	DefaultCachingPolicy        string            `protobuf:"bytes,13,opt,name=default_caching_policy,json=defaultCachingPolicy,proto3" json:"default_caching_policy,omitempty"`
	AllowedCachingPolicies      []string          `` /* 130-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TableProfileDescription) Descriptor deprecated 

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

Deprecated: Use TableProfileDescription.ProtoReflect.Descriptor instead.

func (*TableProfileDescription) GetAllowedCachingPolicies 

func (x *TableProfileDescription) GetAllowedCachingPolicies() []string

func (*TableProfileDescription) GetAllowedCompactionPolicies 

func (x *TableProfileDescription) GetAllowedCompactionPolicies() []string

func (*TableProfileDescription) GetAllowedExecutionPolicies 

func (x *TableProfileDescription) GetAllowedExecutionPolicies() []string

func (*TableProfileDescription) GetAllowedPartitioningPolicies 

func (x *TableProfileDescription) GetAllowedPartitioningPolicies() []string

func (*TableProfileDescription) GetAllowedReplicationPolicies 

func (x *TableProfileDescription) GetAllowedReplicationPolicies() []string

func (*TableProfileDescription) GetAllowedStoragePolicies 

func (x *TableProfileDescription) GetAllowedStoragePolicies() []string

func (*TableProfileDescription) GetDefaultCachingPolicy 

func (x *TableProfileDescription) GetDefaultCachingPolicy() string

func (*TableProfileDescription) GetDefaultCompactionPolicy 

func (x *TableProfileDescription) GetDefaultCompactionPolicy() string

func (*TableProfileDescription) GetDefaultExecutionPolicy 

func (x *TableProfileDescription) GetDefaultExecutionPolicy() string

func (*TableProfileDescription) GetDefaultPartitioningPolicy 

func (x *TableProfileDescription) GetDefaultPartitioningPolicy() string

func (*TableProfileDescription) GetDefaultReplicationPolicy 

func (x *TableProfileDescription) GetDefaultReplicationPolicy() string

func (*TableProfileDescription) GetDefaultStoragePolicy 

func (x *TableProfileDescription) GetDefaultStoragePolicy() string

func (*TableProfileDescription) GetLabels 

func (x *TableProfileDescription) GetLabels() map[string]string

func (*TableProfileDescription) GetName 

func (x *TableProfileDescription) GetName() string

func (*TableProfileDescription) ProtoMessage 

func (*TableProfileDescription) ProtoMessage()

func (*TableProfileDescription) ProtoReflect 

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

func (*TableProfileDescription) Reset 

func (x *TableProfileDescription) Reset()

func (*TableProfileDescription) String 

func (x *TableProfileDescription) String() string

type TableStats 

type TableStats struct {

	// Stats for each partition
	PartitionStats []*PartitionStats `protobuf:"bytes,1,rep,name=partition_stats,json=partitionStats,proto3" json:"partition_stats,omitempty"`
	// Approximate number of rows in table
	RowsEstimate uint64 `protobuf:"varint,2,opt,name=rows_estimate,json=rowsEstimate,proto3" json:"rows_estimate,omitempty"`
	// Approximate size of table (bytes)
	StoreSize uint64 `protobuf:"varint,3,opt,name=store_size,json=storeSize,proto3" json:"store_size,omitempty"`
	// Number of partitions in table
	Partitions uint64 `protobuf:"varint,4,opt,name=partitions,proto3" json:"partitions,omitempty"`
	// Timestamp of table creation
	CreationTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=creation_time,json=creationTime,proto3" json:"creation_time,omitempty"`
	// Timestamp of last modification
	ModificationTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=modification_time,json=modificationTime,proto3" json:"modification_time,omitempty"`
	// contains filtered or unexported fields
}

func (*TableStats) Descriptor deprecated 

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

Deprecated: Use TableStats.ProtoReflect.Descriptor instead.

func (*TableStats) GetCreationTime 

func (x *TableStats) GetCreationTime() *timestamppb.Timestamp

func (*TableStats) GetModificationTime 

func (x *TableStats) GetModificationTime() *timestamppb.Timestamp

func (*TableStats) GetPartitionStats 

func (x *TableStats) GetPartitionStats() []*PartitionStats

func (*TableStats) GetPartitions 

func (x *TableStats) GetPartitions() uint64

func (*TableStats) GetRowsEstimate 

func (x *TableStats) GetRowsEstimate() uint64

func (*TableStats) GetStoreSize 

func (x *TableStats) GetStoreSize() uint64

func (*TableStats) ProtoMessage 

func (*TableStats) ProtoMessage()

func (*TableStats) ProtoReflect 

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

func (*TableStats) Reset 

func (x *TableStats) Reset()

func (*TableStats) String 

func (x *TableStats) String() string

type TransactionControl 

type TransactionControl struct {

	// Types that are assignable to TxSelector:
	//
	//	*TransactionControl_TxId
	//	*TransactionControl_BeginTx
	TxSelector isTransactionControl_TxSelector `protobuf_oneof:"tx_selector"`
	CommitTx   bool                            `protobuf:"varint,10,opt,name=commit_tx,json=commitTx,proto3" json:"commit_tx,omitempty"`
	// contains filtered or unexported fields
}

func (*TransactionControl) Descriptor deprecated 

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

Deprecated: Use TransactionControl.ProtoReflect.Descriptor instead.

func (*TransactionControl) GetBeginTx 

func (x *TransactionControl) GetBeginTx() *TransactionSettings

func (*TransactionControl) GetCommitTx 

func (x *TransactionControl) GetCommitTx() bool

func (*TransactionControl) GetTxId 

func (x *TransactionControl) GetTxId() string

func (*TransactionControl) GetTxSelector 

func (m *TransactionControl) GetTxSelector() isTransactionControl_TxSelector

func (*TransactionControl) ProtoMessage 

func (*TransactionControl) ProtoMessage()

func (*TransactionControl) ProtoReflect 

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

func (*TransactionControl) Reset 

func (x *TransactionControl) Reset()

func (*TransactionControl) String 

func (x *TransactionControl) String() string

type TransactionControl_BeginTx 

type TransactionControl_BeginTx struct {
	BeginTx *TransactionSettings `protobuf:"bytes,2,opt,name=begin_tx,json=beginTx,proto3,oneof"`
}

type TransactionControl_TxId 

type TransactionControl_TxId struct {
	TxId string `protobuf:"bytes,1,opt,name=tx_id,json=txId,proto3,oneof"`
}

type TransactionMeta 

type TransactionMeta struct {

	// Transaction identifier
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

Holds transaction id

func (*TransactionMeta) Descriptor deprecated 

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

Deprecated: Use TransactionMeta.ProtoReflect.Descriptor instead.

func (*TransactionMeta) GetId 

func (x *TransactionMeta) GetId() string

func (*TransactionMeta) ProtoMessage 

func (*TransactionMeta) ProtoMessage()

func (*TransactionMeta) ProtoReflect 

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

func (*TransactionMeta) Reset 

func (x *TransactionMeta) Reset()

func (*TransactionMeta) String 

func (x *TransactionMeta) String() string

type TransactionSettings 

type TransactionSettings struct {

	// Types that are assignable to TxMode:
	//
	//	*TransactionSettings_SerializableReadWrite
	//	*TransactionSettings_OnlineReadOnly
	//	*TransactionSettings_StaleReadOnly
	//	*TransactionSettings_SnapshotReadOnly
	TxMode isTransactionSettings_TxMode `protobuf_oneof:"tx_mode"`
	// contains filtered or unexported fields
}

func (*TransactionSettings) Descriptor deprecated 

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

Deprecated: Use TransactionSettings.ProtoReflect.Descriptor instead.

func (*TransactionSettings) GetOnlineReadOnly 

func (x *TransactionSettings) GetOnlineReadOnly() *OnlineModeSettings

func (*TransactionSettings) GetSerializableReadWrite 

func (x *TransactionSettings) GetSerializableReadWrite() *SerializableModeSettings

func (*TransactionSettings) GetSnapshotReadOnly 

func (x *TransactionSettings) GetSnapshotReadOnly() *SnapshotModeSettings

func (*TransactionSettings) GetStaleReadOnly 

func (x *TransactionSettings) GetStaleReadOnly() *StaleModeSettings

func (*TransactionSettings) GetTxMode 

func (m *TransactionSettings) GetTxMode() isTransactionSettings_TxMode

func (*TransactionSettings) ProtoMessage 

func (*TransactionSettings) ProtoMessage()

func (*TransactionSettings) ProtoReflect 

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

func (*TransactionSettings) Reset 

func (x *TransactionSettings) Reset()

func (*TransactionSettings) String 

func (x *TransactionSettings) String() string

type TransactionSettings_OnlineReadOnly 

type TransactionSettings_OnlineReadOnly struct {
	OnlineReadOnly *OnlineModeSettings `protobuf:"bytes,2,opt,name=online_read_only,json=onlineReadOnly,proto3,oneof"`
}

type TransactionSettings_SerializableReadWrite 

type TransactionSettings_SerializableReadWrite struct {
	SerializableReadWrite *SerializableModeSettings `protobuf:"bytes,1,opt,name=serializable_read_write,json=serializableReadWrite,proto3,oneof"`
}

type TransactionSettings_SnapshotReadOnly 

type TransactionSettings_SnapshotReadOnly struct {
	SnapshotReadOnly *SnapshotModeSettings `protobuf:"bytes,4,opt,name=snapshot_read_only,json=snapshotReadOnly,proto3,oneof"`
}

type TransactionSettings_StaleReadOnly 

type TransactionSettings_StaleReadOnly struct {
	StaleReadOnly *StaleModeSettings `protobuf:"bytes,3,opt,name=stale_read_only,json=staleReadOnly,proto3,oneof"`
}

type TtlSettings 

type TtlSettings struct {

	// Types that are assignable to Mode:
	//
	//	*TtlSettings_DateTypeColumn
	//	*TtlSettings_ValueSinceUnixEpoch
	Mode isTtlSettings_Mode `protobuf_oneof:"mode"`
	// How often to run BRO on the same partition.
	// BRO will not be started more often, but may be started less often.
	RunIntervalSeconds uint32 `protobuf:"varint,3,opt,name=run_interval_seconds,json=runIntervalSeconds,proto3" json:"run_interval_seconds,omitempty"`
	// contains filtered or unexported fields
}

func (*TtlSettings) Descriptor deprecated 

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

Deprecated: Use TtlSettings.ProtoReflect.Descriptor instead.

func (*TtlSettings) GetDateTypeColumn 

func (x *TtlSettings) GetDateTypeColumn() *DateTypeColumnModeSettings

func (*TtlSettings) GetMode 

func (m *TtlSettings) GetMode() isTtlSettings_Mode

func (*TtlSettings) GetRunIntervalSeconds 

func (x *TtlSettings) GetRunIntervalSeconds() uint32

func (*TtlSettings) GetValueSinceUnixEpoch 

func (x *TtlSettings) GetValueSinceUnixEpoch() *ValueSinceUnixEpochModeSettings

func (*TtlSettings) ProtoMessage 

func (*TtlSettings) ProtoMessage()

func (*TtlSettings) ProtoReflect 

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

func (*TtlSettings) Reset 

func (x *TtlSettings) Reset()

func (*TtlSettings) String 

func (x *TtlSettings) String() string

type TtlSettings_DateTypeColumn 

type TtlSettings_DateTypeColumn struct {
	DateTypeColumn *DateTypeColumnModeSettings `protobuf:"bytes,1,opt,name=date_type_column,json=dateTypeColumn,proto3,oneof"`
}

type TtlSettings_ValueSinceUnixEpoch 

type TtlSettings_ValueSinceUnixEpoch struct {
	ValueSinceUnixEpoch *ValueSinceUnixEpochModeSettings `protobuf:"bytes,2,opt,name=value_since_unix_epoch,json=valueSinceUnixEpoch,proto3,oneof"`
}

type ValueSinceUnixEpochModeSettings 

type ValueSinceUnixEpochModeSettings struct {

	// The column type must be one of:
	// - Uint32
	// - Uint64
	// - DyNumber
	ColumnName string `protobuf:"bytes,1,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"`
	// Interpretation of the value stored in <column_name>
	ColumnUnit ValueSinceUnixEpochModeSettings_Unit `` /* 144-byte string literal not displayed */
	// This option is always interpreted as seconds regardless of the
	// <column_unit> value.
	ExpireAfterSeconds uint32 `protobuf:"varint,3,opt,name=expire_after_seconds,json=expireAfterSeconds,proto3" json:"expire_after_seconds,omitempty"`
	// contains filtered or unexported fields
}

func (*ValueSinceUnixEpochModeSettings) Descriptor deprecated 

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

Deprecated: Use ValueSinceUnixEpochModeSettings.ProtoReflect.Descriptor instead.

func (*ValueSinceUnixEpochModeSettings) GetColumnName 

func (x *ValueSinceUnixEpochModeSettings) GetColumnName() string

func (*ValueSinceUnixEpochModeSettings) GetColumnUnit 

func (x *ValueSinceUnixEpochModeSettings) GetColumnUnit() ValueSinceUnixEpochModeSettings_Unit

func (*ValueSinceUnixEpochModeSettings) GetExpireAfterSeconds 

func (x *ValueSinceUnixEpochModeSettings) GetExpireAfterSeconds() uint32

func (*ValueSinceUnixEpochModeSettings) ProtoMessage 

func (*ValueSinceUnixEpochModeSettings) ProtoMessage()

func (*ValueSinceUnixEpochModeSettings) ProtoReflect 

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

func (*ValueSinceUnixEpochModeSettings) Reset 

func (x *ValueSinceUnixEpochModeSettings) Reset()

func (*ValueSinceUnixEpochModeSettings) String 

func (x *ValueSinceUnixEpochModeSettings) String() string

type ValueSinceUnixEpochModeSettings_Unit 

type ValueSinceUnixEpochModeSettings_Unit int32
const (
	ValueSinceUnixEpochModeSettings_UNIT_UNSPECIFIED  ValueSinceUnixEpochModeSettings_Unit = 0
	ValueSinceUnixEpochModeSettings_UNIT_SECONDS      ValueSinceUnixEpochModeSettings_Unit = 1
	ValueSinceUnixEpochModeSettings_UNIT_MILLISECONDS ValueSinceUnixEpochModeSettings_Unit = 2
	ValueSinceUnixEpochModeSettings_UNIT_MICROSECONDS ValueSinceUnixEpochModeSettings_Unit = 3
	ValueSinceUnixEpochModeSettings_UNIT_NANOSECONDS  ValueSinceUnixEpochModeSettings_Unit = 4
)

func (ValueSinceUnixEpochModeSettings_Unit) Descriptor 

func (ValueSinceUnixEpochModeSettings_Unit) Descriptor() protoreflect.EnumDescriptor

func (ValueSinceUnixEpochModeSettings_Unit) Enum 

func (x ValueSinceUnixEpochModeSettings_Unit) Enum() *ValueSinceUnixEpochModeSettings_Unit

func (ValueSinceUnixEpochModeSettings_Unit) EnumDescriptor deprecated 

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

Deprecated: Use ValueSinceUnixEpochModeSettings_Unit.Descriptor instead.

func (ValueSinceUnixEpochModeSettings_Unit) Number 

func (x ValueSinceUnixEpochModeSettings_Unit) Number() protoreflect.EnumNumber

func (ValueSinceUnixEpochModeSettings_Unit) String 

func (x ValueSinceUnixEpochModeSettings_Unit) String() string

func (ValueSinceUnixEpochModeSettings_Unit) Type 

func (ValueSinceUnixEpochModeSettings_Unit) Type() protoreflect.EnumType

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.