Ydb_Table

package
v2.10.8 Latest Latest
Warning

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

 Go to latest Published: Nov 29, 2021 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ColumnFamilyPolicy_Compression_name = map[int32]string{
	0: "COMPRESSION_UNSPECIFIED",
	1: "UNCOMPRESSED",
	2: "COMPRESSED",
}
View Source 
var ColumnFamilyPolicy_Compression_value = map[string]int32{
	"COMPRESSION_UNSPECIFIED": 0,
	"UNCOMPRESSED":            1,
	"COMPRESSED":              2,
}
View Source 
var ColumnFamily_Compression_name = map[int32]string{
	0: "COMPRESSION_UNSPECIFIED",
	1: "COMPRESSION_NONE",
	2: "COMPRESSION_LZ4",
}
View Source 
var ColumnFamily_Compression_value = map[string]int32{
	"COMPRESSION_UNSPECIFIED": 0,
	"COMPRESSION_NONE":        1,
	"COMPRESSION_LZ4":         2,
}
View Source 
var ExecuteScanQueryRequest_Mode_name = map[int32]string{
	0: "MODE_UNSPECIFIED",
	1: "MODE_EXPLAIN",
	3: "MODE_EXEC",
}
View Source 
var ExecuteScanQueryRequest_Mode_value = map[string]int32{
	"MODE_UNSPECIFIED": 0,
	"MODE_EXPLAIN":     1,
	"MODE_EXEC":        3,
}
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",
}
View Source 
var 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,
}
View Source 
var KeepAliveResult_SessionStatus_name = map[int32]string{
	0: "SESSION_STATUS_UNSPECIFIED",
	1: "SESSION_STATUS_READY",
	2: "SESSION_STATUS_BUSY",
}
View Source 
var KeepAliveResult_SessionStatus_value = map[string]int32{
	"SESSION_STATUS_UNSPECIFIED": 0,
	"SESSION_STATUS_READY":       1,
	"SESSION_STATUS_BUSY":        2,
}
View Source 
var PartitioningPolicy_AutoPartitioningPolicy_name = map[int32]string{
	0: "AUTO_PARTITIONING_POLICY_UNSPECIFIED",
	1: "DISABLED",
	2: "AUTO_SPLIT",
	3: "AUTO_SPLIT_MERGE",
}
View Source 
var PartitioningPolicy_AutoPartitioningPolicy_value = map[string]int32{
	"AUTO_PARTITIONING_POLICY_UNSPECIFIED": 0,
	"DISABLED":                             1,
	"AUTO_SPLIT":                           2,
	"AUTO_SPLIT_MERGE":                     3,
}
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",
}
View Source 
var QueryStatsCollection_Mode_value = map[string]int32{
	"STATS_COLLECTION_UNSPECIFIED": 0,
	"STATS_COLLECTION_NONE":        1,
	"STATS_COLLECTION_BASIC":       2,
	"STATS_COLLECTION_FULL":        3,
}
View Source 
var TableIndexDescription_Status_name = map[int32]string{
	0: "STATUS_UNSPECIFIED",
	1: "STATUS_READY",
	2: "STATUS_BUILDING",
}
View Source 
var TableIndexDescription_Status_value = map[string]int32{
	"STATUS_UNSPECIFIED": 0,
	"STATUS_READY":       1,
	"STATUS_BUILDING":    2,
}
View Source 
var ValueSinceUnixEpochModeSettings_Unit_name = map[int32]string{
	0: "UNIT_UNSPECIFIED",
	1: "UNIT_SECONDS",
	2: "UNIT_MILLISECONDS",
	3: "UNIT_MICROSECONDS",
	4: "UNIT_NANOSECONDS",
}
View Source 
var ValueSinceUnixEpochModeSettings_Unit_value = map[string]int32{
	"UNIT_UNSPECIFIED":  0,
	"UNIT_SECONDS":      1,
	"UNIT_MILLISECONDS": 2,
	"UNIT_MICROSECONDS": 3,
	"UNIT_NANOSECONDS":  4,
}

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 valid to be assigned 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 */
	XXX_NoUnkeyedLiteral    struct{}              `json:"-"`
	XXX_unrecognized        []byte                `json:"-"`
	XXX_sizecache           int32                 `json:"-"`
}

Alter table with given path

func (*AlterTableRequest) Descriptor 

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

func (*AlterTableRequest) GetAddColumnFamilies 

func (m *AlterTableRequest) GetAddColumnFamilies() []*ColumnFamily

func (*AlterTableRequest) GetAddColumns 

func (m *AlterTableRequest) GetAddColumns() []*ColumnMeta

func (*AlterTableRequest) GetAddIndexes 

func (m *AlterTableRequest) GetAddIndexes() []*TableIndex

func (*AlterTableRequest) GetAlterAttributes 

func (m *AlterTableRequest) GetAlterAttributes() map[string]string

func (*AlterTableRequest) GetAlterColumnFamilies 

func (m *AlterTableRequest) GetAlterColumnFamilies() []*ColumnFamily

func (*AlterTableRequest) GetAlterColumns 

func (m *AlterTableRequest) GetAlterColumns() []*ColumnMeta

func (*AlterTableRequest) GetAlterPartitioningSettings 

func (m *AlterTableRequest) GetAlterPartitioningSettings() *PartitioningSettings

func (*AlterTableRequest) GetAlterStorageSettings 

func (m *AlterTableRequest) GetAlterStorageSettings() *StorageSettings

func (*AlterTableRequest) GetDropColumns 

func (m *AlterTableRequest) GetDropColumns() []string

func (*AlterTableRequest) GetDropIndexes 

func (m *AlterTableRequest) GetDropIndexes() []string

func (*AlterTableRequest) GetDropTtlSettings 

func (m *AlterTableRequest) GetDropTtlSettings() *emptypb.Empty

func (*AlterTableRequest) GetOperationParams 

func (m *AlterTableRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*AlterTableRequest) GetPath 

func (m *AlterTableRequest) GetPath() string

func (*AlterTableRequest) GetSessionId 

func (m *AlterTableRequest) GetSessionId() string

func (*AlterTableRequest) GetSetCompactionPolicy 

func (m *AlterTableRequest) GetSetCompactionPolicy() string

func (*AlterTableRequest) GetSetKeyBloomFilter 

func (m *AlterTableRequest) GetSetKeyBloomFilter() Ydb.FeatureFlag_Status

func (*AlterTableRequest) GetSetReadReplicasSettings 

func (m *AlterTableRequest) GetSetReadReplicasSettings() *ReadReplicasSettings

func (*AlterTableRequest) GetSetTtlSettings 

func (m *AlterTableRequest) GetSetTtlSettings() *TtlSettings

func (*AlterTableRequest) GetTtlAction 

func (m *AlterTableRequest) GetTtlAction() isAlterTableRequest_TtlAction

func (*AlterTableRequest) ProtoMessage 

func (*AlterTableRequest) ProtoMessage()

func (*AlterTableRequest) Reset 

func (m *AlterTableRequest) Reset()

func (*AlterTableRequest) SetOperationParams 

func (m *AlterTableRequest) SetOperationParams(v *Ydb_Operations.OperationParams)

SetOperationParams implements ydb generic interface for setting operation parameters inside driver implementation.

func (*AlterTableRequest) String 

func (m *AlterTableRequest) String() string

func (*AlterTableRequest) XXX_DiscardUnknown 

func (m *AlterTableRequest) XXX_DiscardUnknown()

func (*AlterTableRequest) XXX_Marshal 

func (m *AlterTableRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AlterTableRequest) XXX_Merge 

func (m *AlterTableRequest) XXX_Merge(src proto.Message)

func (*AlterTableRequest) XXX_OneofWrappers 

func (*AlterTableRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*AlterTableRequest) XXX_Size 

func (m *AlterTableRequest) XXX_Size() int

func (*AlterTableRequest) XXX_Unmarshal 

func (m *AlterTableRequest) XXX_Unmarshal(b []byte) error

type AlterTableRequest_DropTtlSettings 

type AlterTableRequest_DropTtlSettings struct {
	DropTtlSettings *emptypb.Empty `protobuf:"bytes,8,opt,name=drop_ttl_settings,json=dropTtlSettings,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"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*AlterTableResponse) Descriptor 

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

func (*AlterTableResponse) GetOperation 

func (m *AlterTableResponse) GetOperation() *Ydb_Operations.Operation

func (*AlterTableResponse) ProtoMessage 

func (*AlterTableResponse) ProtoMessage()

func (*AlterTableResponse) Reset 

func (m *AlterTableResponse) Reset()

func (*AlterTableResponse) String 

func (m *AlterTableResponse) String() string

func (*AlterTableResponse) XXX_DiscardUnknown 

func (m *AlterTableResponse) XXX_DiscardUnknown()

func (*AlterTableResponse) XXX_Marshal 

func (m *AlterTableResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AlterTableResponse) XXX_Merge 

func (m *AlterTableResponse) XXX_Merge(src proto.Message)

func (*AlterTableResponse) XXX_Size 

func (m *AlterTableResponse) XXX_Size() int

func (*AlterTableResponse) XXX_Unmarshal 

func (m *AlterTableResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AzReadReplicasSettings) Descriptor 

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

func (*AzReadReplicasSettings) GetName 

func (m *AzReadReplicasSettings) GetName() string

func (*AzReadReplicasSettings) GetReadReplicasCount 

func (m *AzReadReplicasSettings) GetReadReplicasCount() uint64

func (*AzReadReplicasSettings) ProtoMessage 

func (*AzReadReplicasSettings) ProtoMessage()

func (*AzReadReplicasSettings) Reset 

func (m *AzReadReplicasSettings) Reset()

func (*AzReadReplicasSettings) String 

func (m *AzReadReplicasSettings) String() string

func (*AzReadReplicasSettings) XXX_DiscardUnknown 

func (m *AzReadReplicasSettings) XXX_DiscardUnknown()

func (*AzReadReplicasSettings) XXX_Marshal 

func (m *AzReadReplicasSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AzReadReplicasSettings) XXX_Merge 

func (m *AzReadReplicasSettings) XXX_Merge(src proto.Message)

func (*AzReadReplicasSettings) XXX_Size 

func (m *AzReadReplicasSettings) XXX_Size() int

func (*AzReadReplicasSettings) XXX_Unmarshal 

func (m *AzReadReplicasSettings) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

Begin transaction on given session with given settings

func (*BeginTransactionRequest) Descriptor 

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

func (*BeginTransactionRequest) GetOperationParams 

func (m *BeginTransactionRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*BeginTransactionRequest) GetSessionId 

func (m *BeginTransactionRequest) GetSessionId() string

func (*BeginTransactionRequest) GetTxSettings 

func (m *BeginTransactionRequest) GetTxSettings() *TransactionSettings

func (*BeginTransactionRequest) ProtoMessage 

func (*BeginTransactionRequest) ProtoMessage()

func (*BeginTransactionRequest) Reset 

func (m *BeginTransactionRequest) Reset()

func (*BeginTransactionRequest) SetOperationParams 

func (m *BeginTransactionRequest) SetOperationParams(v *Ydb_Operations.OperationParams)

SetOperationParams implements ydb generic interface for setting operation parameters inside driver implementation.

func (*BeginTransactionRequest) String 

func (m *BeginTransactionRequest) String() string

func (*BeginTransactionRequest) XXX_DiscardUnknown 

func (m *BeginTransactionRequest) XXX_DiscardUnknown()

func (*BeginTransactionRequest) XXX_Marshal 

func (m *BeginTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BeginTransactionRequest) XXX_Merge 

func (m *BeginTransactionRequest) XXX_Merge(src proto.Message)

func (*BeginTransactionRequest) XXX_Size 

func (m *BeginTransactionRequest) XXX_Size() int

func (*BeginTransactionRequest) XXX_Unmarshal 

func (m *BeginTransactionRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*BeginTransactionResponse) Descriptor 

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

func (*BeginTransactionResponse) GetOperation 

func (m *BeginTransactionResponse) GetOperation() *Ydb_Operations.Operation

func (*BeginTransactionResponse) ProtoMessage 

func (*BeginTransactionResponse) ProtoMessage()

func (*BeginTransactionResponse) Reset 

func (m *BeginTransactionResponse) Reset()

func (*BeginTransactionResponse) String 

func (m *BeginTransactionResponse) String() string

func (*BeginTransactionResponse) XXX_DiscardUnknown 

func (m *BeginTransactionResponse) XXX_DiscardUnknown()

func (*BeginTransactionResponse) XXX_Marshal 

func (m *BeginTransactionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BeginTransactionResponse) XXX_Merge 

func (m *BeginTransactionResponse) XXX_Merge(src proto.Message)

func (*BeginTransactionResponse) XXX_Size 

func (m *BeginTransactionResponse) XXX_Size() int

func (*BeginTransactionResponse) XXX_Unmarshal 

func (m *BeginTransactionResponse) XXX_Unmarshal(b []byte) error

type BeginTransactionResult 

type BeginTransactionResult struct {
	TxMeta               *TransactionMeta `protobuf:"bytes,1,opt,name=tx_meta,json=txMeta,proto3" json:"tx_meta,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*BeginTransactionResult) Descriptor 

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

func (*BeginTransactionResult) GetTxMeta 

func (m *BeginTransactionResult) GetTxMeta() *TransactionMeta

func (*BeginTransactionResult) ProtoMessage 

func (*BeginTransactionResult) ProtoMessage()

func (*BeginTransactionResult) Reset 

func (m *BeginTransactionResult) Reset()

func (*BeginTransactionResult) String 

func (m *BeginTransactionResult) String() string

func (*BeginTransactionResult) XXX_DiscardUnknown 

func (m *BeginTransactionResult) XXX_DiscardUnknown()

func (*BeginTransactionResult) XXX_Marshal 

func (m *BeginTransactionResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BeginTransactionResult) XXX_Merge 

func (m *BeginTransactionResult) XXX_Merge(src proto.Message)

func (*BeginTransactionResult) XXX_Size 

func (m *BeginTransactionResult) XXX_Size() int

func (*BeginTransactionResult) XXX_Unmarshal 

func (m *BeginTransactionResult) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*BulkUpsertRequest) Descriptor 

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

func (*BulkUpsertRequest) GetOperationParams 

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

func (*BulkUpsertRequest) GetRows 

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

func (*BulkUpsertRequest) GetTable 

func (m *BulkUpsertRequest) GetTable() string

func (*BulkUpsertRequest) ProtoMessage 

func (*BulkUpsertRequest) ProtoMessage()

func (*BulkUpsertRequest) Reset 

func (m *BulkUpsertRequest) Reset()

func (*BulkUpsertRequest) SetOperationParams 

func (m *BulkUpsertRequest) SetOperationParams(v *Ydb_Operations.OperationParams)

SetOperationParams implements ydb generic interface for setting operation parameters inside driver implementation.

func (*BulkUpsertRequest) String 

func (m *BulkUpsertRequest) String() string

func (*BulkUpsertRequest) XXX_DiscardUnknown 

func (m *BulkUpsertRequest) XXX_DiscardUnknown()

func (*BulkUpsertRequest) XXX_Marshal 

func (m *BulkUpsertRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BulkUpsertRequest) XXX_Merge 

func (m *BulkUpsertRequest) XXX_Merge(src proto.Message)

func (*BulkUpsertRequest) XXX_Size 

func (m *BulkUpsertRequest) XXX_Size() int

func (*BulkUpsertRequest) XXX_Unmarshal 

func (m *BulkUpsertRequest) XXX_Unmarshal(b []byte) error

type BulkUpsertResponse 

type BulkUpsertResponse struct {
	Operation            *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*BulkUpsertResponse) Descriptor 

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

func (*BulkUpsertResponse) GetOperation 

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

func (*BulkUpsertResponse) ProtoMessage 

func (*BulkUpsertResponse) ProtoMessage()

func (*BulkUpsertResponse) Reset 

func (m *BulkUpsertResponse) Reset()

func (*BulkUpsertResponse) String 

func (m *BulkUpsertResponse) String() string

func (*BulkUpsertResponse) XXX_DiscardUnknown 

func (m *BulkUpsertResponse) XXX_DiscardUnknown()

func (*BulkUpsertResponse) XXX_Marshal 

func (m *BulkUpsertResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BulkUpsertResponse) XXX_Merge 

func (m *BulkUpsertResponse) XXX_Merge(src proto.Message)

func (*BulkUpsertResponse) XXX_Size 

func (m *BulkUpsertResponse) XXX_Size() int

func (*BulkUpsertResponse) XXX_Unmarshal 

func (m *BulkUpsertResponse) XXX_Unmarshal(b []byte) error

type BulkUpsertResult 

type BulkUpsertResult struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BulkUpsertResult) Descriptor 

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

func (*BulkUpsertResult) ProtoMessage 

func (*BulkUpsertResult) ProtoMessage()

func (*BulkUpsertResult) Reset 

func (m *BulkUpsertResult) Reset()

func (*BulkUpsertResult) String 

func (m *BulkUpsertResult) String() string

func (*BulkUpsertResult) XXX_DiscardUnknown 

func (m *BulkUpsertResult) XXX_DiscardUnknown()

func (*BulkUpsertResult) XXX_Marshal 

func (m *BulkUpsertResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BulkUpsertResult) XXX_Merge 

func (m *BulkUpsertResult) XXX_Merge(src proto.Message)

func (*BulkUpsertResult) XXX_Size 

func (m *BulkUpsertResult) XXX_Size() int

func (*BulkUpsertResult) XXX_Unmarshal 

func (m *BulkUpsertResult) XXX_Unmarshal(b []byte) error

type CachingPolicy 

type CachingPolicy struct {
	PresetName           string   `protobuf:"bytes,1,opt,name=preset_name,json=presetName,proto3" json:"preset_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CachingPolicy) Descriptor 

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

func (*CachingPolicy) GetPresetName 

func (m *CachingPolicy) GetPresetName() string

func (*CachingPolicy) ProtoMessage 

func (*CachingPolicy) ProtoMessage()

func (*CachingPolicy) Reset 

func (m *CachingPolicy) Reset()

func (*CachingPolicy) String 

func (m *CachingPolicy) String() string

func (*CachingPolicy) XXX_DiscardUnknown 

func (m *CachingPolicy) XXX_DiscardUnknown()

func (*CachingPolicy) XXX_Marshal 

func (m *CachingPolicy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CachingPolicy) XXX_Merge 

func (m *CachingPolicy) XXX_Merge(src proto.Message)

func (*CachingPolicy) XXX_Size 

func (m *CachingPolicy) XXX_Size() int

func (*CachingPolicy) XXX_Unmarshal 

func (m *CachingPolicy) XXX_Unmarshal(b []byte) error

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 */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*CachingPolicyDescription) Descriptor 

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

func (*CachingPolicyDescription) GetLabels 

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

func (*CachingPolicyDescription) GetName 

func (m *CachingPolicyDescription) GetName() string

func (*CachingPolicyDescription) ProtoMessage 

func (*CachingPolicyDescription) ProtoMessage()

func (*CachingPolicyDescription) Reset 

func (m *CachingPolicyDescription) Reset()

func (*CachingPolicyDescription) String 

func (m *CachingPolicyDescription) String() string

func (*CachingPolicyDescription) XXX_DiscardUnknown 

func (m *CachingPolicyDescription) XXX_DiscardUnknown()

func (*CachingPolicyDescription) XXX_Marshal 

func (m *CachingPolicyDescription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CachingPolicyDescription) XXX_Merge 

func (m *CachingPolicyDescription) XXX_Merge(src proto.Message)

func (*CachingPolicyDescription) XXX_Size 

func (m *CachingPolicyDescription) XXX_Size() int

func (*CachingPolicyDescription) XXX_Unmarshal 

func (m *CachingPolicyDescription) XXX_Unmarshal(b []byte) error

type ClusterReplicasSettings 

type ClusterReplicasSettings struct {
	// List of read replicas settings for each AZ
	AzReadReplicasSettings []*AzReadReplicasSettings `` /* 131-byte string literal not displayed */
	XXX_NoUnkeyedLiteral   struct{}                  `json:"-"`
	XXX_unrecognized       []byte                    `json:"-"`
	XXX_sizecache          int32                     `json:"-"`
}

func (*ClusterReplicasSettings) Descriptor 

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

func (*ClusterReplicasSettings) GetAzReadReplicasSettings 

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

func (*ClusterReplicasSettings) ProtoMessage 

func (*ClusterReplicasSettings) ProtoMessage()

func (*ClusterReplicasSettings) Reset 

func (m *ClusterReplicasSettings) Reset()

func (*ClusterReplicasSettings) String 

func (m *ClusterReplicasSettings) String() string

func (*ClusterReplicasSettings) XXX_DiscardUnknown 

func (m *ClusterReplicasSettings) XXX_DiscardUnknown()

func (*ClusterReplicasSettings) XXX_Marshal 

func (m *ClusterReplicasSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClusterReplicasSettings) XXX_Merge 

func (m *ClusterReplicasSettings) XXX_Merge(src proto.Message)

func (*ClusterReplicasSettings) XXX_Size 

func (m *ClusterReplicasSettings) XXX_Size() int

func (*ClusterReplicasSettings) XXX_Unmarshal 

func (m *ClusterReplicasSettings) XXX_Unmarshal(b []byte) error

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 keeps data pages in memory
	KeepInMemory         Ydb.FeatureFlag_Status `` /* 128-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*ColumnFamily) Descriptor 

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

func (*ColumnFamily) GetCompression 

func (m *ColumnFamily) GetCompression() ColumnFamily_Compression

func (*ColumnFamily) GetData 

func (m *ColumnFamily) GetData() *StoragePool

func (*ColumnFamily) GetKeepInMemory 

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

func (*ColumnFamily) GetName 

func (m *ColumnFamily) GetName() string

func (*ColumnFamily) ProtoMessage 

func (*ColumnFamily) ProtoMessage()

func (*ColumnFamily) Reset 

func (m *ColumnFamily) Reset()

func (*ColumnFamily) String 

func (m *ColumnFamily) String() string

func (*ColumnFamily) XXX_DiscardUnknown 

func (m *ColumnFamily) XXX_DiscardUnknown()

func (*ColumnFamily) XXX_Marshal 

func (m *ColumnFamily) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ColumnFamily) XXX_Merge 

func (m *ColumnFamily) XXX_Merge(src proto.Message)

func (*ColumnFamily) XXX_Size 

func (m *ColumnFamily) XXX_Size() int

func (*ColumnFamily) XXX_Unmarshal 

func (m *ColumnFamily) XXX_Unmarshal(b []byte) error

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"`
	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"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*ColumnFamilyPolicy) Descriptor 

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

func (*ColumnFamilyPolicy) GetCompression 

func (m *ColumnFamilyPolicy) GetCompression() ColumnFamilyPolicy_Compression

func (*ColumnFamilyPolicy) GetData 

func (m *ColumnFamilyPolicy) GetData() *StoragePool

func (*ColumnFamilyPolicy) GetExternal 

func (m *ColumnFamilyPolicy) GetExternal() *StoragePool

func (*ColumnFamilyPolicy) GetKeepInMemory 

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

func (*ColumnFamilyPolicy) GetName 

func (m *ColumnFamilyPolicy) GetName() string

func (*ColumnFamilyPolicy) ProtoMessage 

func (*ColumnFamilyPolicy) ProtoMessage()

func (*ColumnFamilyPolicy) Reset 

func (m *ColumnFamilyPolicy) Reset()

func (*ColumnFamilyPolicy) String 

func (m *ColumnFamilyPolicy) String() string

func (*ColumnFamilyPolicy) XXX_DiscardUnknown 

func (m *ColumnFamilyPolicy) XXX_DiscardUnknown()

func (*ColumnFamilyPolicy) XXX_Marshal 

func (m *ColumnFamilyPolicy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ColumnFamilyPolicy) XXX_Merge 

func (m *ColumnFamilyPolicy) XXX_Merge(src proto.Message)

func (*ColumnFamilyPolicy) XXX_Size 

func (m *ColumnFamilyPolicy) XXX_Size() int

func (*ColumnFamilyPolicy) XXX_Unmarshal 

func (m *ColumnFamilyPolicy) XXX_Unmarshal(b []byte) error

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

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

func (ColumnFamilyPolicy_Compression) String 

func (x ColumnFamilyPolicy_Compression) String() string

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

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

func (ColumnFamily_Compression) String 

func (x ColumnFamily_Compression) String() string

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ColumnMeta) Descriptor 

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

func (*ColumnMeta) GetFamily 

func (m *ColumnMeta) GetFamily() string

func (*ColumnMeta) GetName 

func (m *ColumnMeta) GetName() string

func (*ColumnMeta) GetType 

func (m *ColumnMeta) GetType() *Ydb.Type

func (*ColumnMeta) ProtoMessage 

func (*ColumnMeta) ProtoMessage()

func (*ColumnMeta) Reset 

func (m *ColumnMeta) Reset()

func (*ColumnMeta) String 

func (m *ColumnMeta) String() string

func (*ColumnMeta) XXX_DiscardUnknown 

func (m *ColumnMeta) XXX_DiscardUnknown()

func (*ColumnMeta) XXX_Marshal 

func (m *ColumnMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ColumnMeta) XXX_Merge 

func (m *ColumnMeta) XXX_Merge(src proto.Message)

func (*ColumnMeta) XXX_Size 

func (m *ColumnMeta) XXX_Size() int

func (*ColumnMeta) XXX_Unmarshal 

func (m *ColumnMeta) XXX_Unmarshal(b []byte) error

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 */
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

Commit transaction with given session and tx id

func (*CommitTransactionRequest) Descriptor 

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

func (*CommitTransactionRequest) GetCollectStats 

func (m *CommitTransactionRequest) GetCollectStats() QueryStatsCollection_Mode

func (*CommitTransactionRequest) GetOperationParams 

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

func (*CommitTransactionRequest) GetSessionId 

func (m *CommitTransactionRequest) GetSessionId() string

func (*CommitTransactionRequest) GetTxId 

func (m *CommitTransactionRequest) GetTxId() string

func (*CommitTransactionRequest) ProtoMessage 

func (*CommitTransactionRequest) ProtoMessage()

func (*CommitTransactionRequest) Reset 

func (m *CommitTransactionRequest) Reset()

func (*CommitTransactionRequest) SetOperationParams 

func (m *CommitTransactionRequest) SetOperationParams(v *Ydb_Operations.OperationParams)

SetOperationParams implements ydb generic interface for setting operation parameters inside driver implementation.

func (*CommitTransactionRequest) String 

func (m *CommitTransactionRequest) String() string

func (*CommitTransactionRequest) XXX_DiscardUnknown 

func (m *CommitTransactionRequest) XXX_DiscardUnknown()

func (*CommitTransactionRequest) XXX_Marshal 

func (m *CommitTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommitTransactionRequest) XXX_Merge 

func (m *CommitTransactionRequest) XXX_Merge(src proto.Message)

func (*CommitTransactionRequest) XXX_Size 

func (m *CommitTransactionRequest) XXX_Size() int

func (*CommitTransactionRequest) XXX_Unmarshal 

func (m *CommitTransactionRequest) XXX_Unmarshal(b []byte) error

type CommitTransactionResponse 

type CommitTransactionResponse struct {
	Operation            *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*CommitTransactionResponse) Descriptor 

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

func (*CommitTransactionResponse) GetOperation 

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

func (*CommitTransactionResponse) ProtoMessage 

func (*CommitTransactionResponse) ProtoMessage()

func (*CommitTransactionResponse) Reset 

func (m *CommitTransactionResponse) Reset()

func (*CommitTransactionResponse) String 

func (m *CommitTransactionResponse) String() string

func (*CommitTransactionResponse) XXX_DiscardUnknown 

func (m *CommitTransactionResponse) XXX_DiscardUnknown()

func (*CommitTransactionResponse) XXX_Marshal 

func (m *CommitTransactionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommitTransactionResponse) XXX_Merge 

func (m *CommitTransactionResponse) XXX_Merge(src proto.Message)

func (*CommitTransactionResponse) XXX_Size 

func (m *CommitTransactionResponse) XXX_Size() int

func (*CommitTransactionResponse) XXX_Unmarshal 

func (m *CommitTransactionResponse) XXX_Unmarshal(b []byte) error

type CommitTransactionResult 

type CommitTransactionResult struct {
	QueryStats           *Ydb_TableStats.QueryStats `protobuf:"bytes,1,opt,name=query_stats,json=queryStats,proto3" json:"query_stats,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*CommitTransactionResult) Descriptor 

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

func (*CommitTransactionResult) GetQueryStats 

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

func (*CommitTransactionResult) ProtoMessage 

func (*CommitTransactionResult) ProtoMessage()

func (*CommitTransactionResult) Reset 

func (m *CommitTransactionResult) Reset()

func (*CommitTransactionResult) String 

func (m *CommitTransactionResult) String() string

func (*CommitTransactionResult) XXX_DiscardUnknown 

func (m *CommitTransactionResult) XXX_DiscardUnknown()

func (*CommitTransactionResult) XXX_Marshal 

func (m *CommitTransactionResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommitTransactionResult) XXX_Merge 

func (m *CommitTransactionResult) XXX_Merge(src proto.Message)

func (*CommitTransactionResult) XXX_Size 

func (m *CommitTransactionResult) XXX_Size() int

func (*CommitTransactionResult) XXX_Unmarshal 

func (m *CommitTransactionResult) XXX_Unmarshal(b []byte) error

type CompactionPolicy 

type CompactionPolicy struct {
	PresetName           string   `protobuf:"bytes,1,opt,name=preset_name,json=presetName,proto3" json:"preset_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CompactionPolicy) Descriptor 

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

func (*CompactionPolicy) GetPresetName 

func (m *CompactionPolicy) GetPresetName() string

func (*CompactionPolicy) ProtoMessage 

func (*CompactionPolicy) ProtoMessage()

func (*CompactionPolicy) Reset 

func (m *CompactionPolicy) Reset()

func (*CompactionPolicy) String 

func (m *CompactionPolicy) String() string

func (*CompactionPolicy) XXX_DiscardUnknown 

func (m *CompactionPolicy) XXX_DiscardUnknown()

func (*CompactionPolicy) XXX_Marshal 

func (m *CompactionPolicy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CompactionPolicy) XXX_Merge 

func (m *CompactionPolicy) XXX_Merge(src proto.Message)

func (*CompactionPolicy) XXX_Size 

func (m *CompactionPolicy) XXX_Size() int

func (*CompactionPolicy) XXX_Unmarshal 

func (m *CompactionPolicy) XXX_Unmarshal(b []byte) error

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 */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*CompactionPolicyDescription) Descriptor 

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

func (*CompactionPolicyDescription) GetLabels 

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

func (*CompactionPolicyDescription) GetName 

func (m *CompactionPolicyDescription) GetName() string

func (*CompactionPolicyDescription) ProtoMessage 

func (*CompactionPolicyDescription) ProtoMessage()

func (*CompactionPolicyDescription) Reset 

func (m *CompactionPolicyDescription) Reset()

func (*CompactionPolicyDescription) String 

func (m *CompactionPolicyDescription) String() string

func (*CompactionPolicyDescription) XXX_DiscardUnknown 

func (m *CompactionPolicyDescription) XXX_DiscardUnknown()

func (*CompactionPolicyDescription) XXX_Marshal 

func (m *CompactionPolicyDescription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CompactionPolicyDescription) XXX_Merge 

func (m *CompactionPolicyDescription) XXX_Merge(src proto.Message)

func (*CompactionPolicyDescription) XXX_Size 

func (m *CompactionPolicyDescription) XXX_Size() int

func (*CompactionPolicyDescription) XXX_Unmarshal 

func (m *CompactionPolicyDescription) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CopyTableItem) Descriptor 

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

func (*CopyTableItem) GetDestinationPath 

func (m *CopyTableItem) GetDestinationPath() string

func (*CopyTableItem) GetOmitIndexes 

func (m *CopyTableItem) GetOmitIndexes() bool

func (*CopyTableItem) GetSourcePath 

func (m *CopyTableItem) GetSourcePath() string

func (*CopyTableItem) ProtoMessage 

func (*CopyTableItem) ProtoMessage()

func (*CopyTableItem) Reset 

func (m *CopyTableItem) Reset()

func (*CopyTableItem) String 

func (m *CopyTableItem) String() string

func (*CopyTableItem) XXX_DiscardUnknown 

func (m *CopyTableItem) XXX_DiscardUnknown()

func (*CopyTableItem) XXX_Marshal 

func (m *CopyTableItem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CopyTableItem) XXX_Merge 

func (m *CopyTableItem) XXX_Merge(src proto.Message)

func (*CopyTableItem) XXX_Size 

func (m *CopyTableItem) XXX_Size() int

func (*CopyTableItem) XXX_Unmarshal 

func (m *CopyTableItem) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

Copy table with given path

func (*CopyTableRequest) Descriptor 

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

func (*CopyTableRequest) GetDestinationPath 

func (m *CopyTableRequest) GetDestinationPath() string

func (*CopyTableRequest) GetOperationParams 

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

func (*CopyTableRequest) GetSessionId 

func (m *CopyTableRequest) GetSessionId() string

func (*CopyTableRequest) GetSourcePath 

func (m *CopyTableRequest) GetSourcePath() string

func (*CopyTableRequest) ProtoMessage 

func (*CopyTableRequest) ProtoMessage()

func (*CopyTableRequest) Reset 

func (m *CopyTableRequest) Reset()

func (*CopyTableRequest) SetOperationParams 

func (m *CopyTableRequest) SetOperationParams(v *Ydb_Operations.OperationParams)

SetOperationParams implements ydb generic interface for setting operation parameters inside driver implementation.

func (*CopyTableRequest) String 

func (m *CopyTableRequest) String() string

func (*CopyTableRequest) XXX_DiscardUnknown 

func (m *CopyTableRequest) XXX_DiscardUnknown()

func (*CopyTableRequest) XXX_Marshal 

func (m *CopyTableRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CopyTableRequest) XXX_Merge 

func (m *CopyTableRequest) XXX_Merge(src proto.Message)

func (*CopyTableRequest) XXX_Size 

func (m *CopyTableRequest) XXX_Size() int

func (*CopyTableRequest) XXX_Unmarshal 

func (m *CopyTableRequest) XXX_Unmarshal(b []byte) error

type CopyTableResponse 

type CopyTableResponse struct {
	Operation            *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*CopyTableResponse) Descriptor 

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

func (*CopyTableResponse) GetOperation 

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

func (*CopyTableResponse) ProtoMessage 

func (*CopyTableResponse) ProtoMessage()

func (*CopyTableResponse) Reset 

func (m *CopyTableResponse) Reset()

func (*CopyTableResponse) String 

func (m *CopyTableResponse) String() string

func (*CopyTableResponse) XXX_DiscardUnknown 

func (m *CopyTableResponse) XXX_DiscardUnknown()

func (*CopyTableResponse) XXX_Marshal 

func (m *CopyTableResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CopyTableResponse) XXX_Merge 

func (m *CopyTableResponse) XXX_Merge(src proto.Message)

func (*CopyTableResponse) XXX_Size 

func (m *CopyTableResponse) XXX_Size() int

func (*CopyTableResponse) XXX_Unmarshal 

func (m *CopyTableResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

Creates consistent copy of given tables.

func (*CopyTablesRequest) Descriptor 

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

func (*CopyTablesRequest) GetOperationParams 

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

func (*CopyTablesRequest) GetSessionId 

func (m *CopyTablesRequest) GetSessionId() string

func (*CopyTablesRequest) GetTables 

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

func (*CopyTablesRequest) ProtoMessage 

func (*CopyTablesRequest) ProtoMessage()

func (*CopyTablesRequest) Reset 

func (m *CopyTablesRequest) Reset()

func (*CopyTablesRequest) SetOperationParams 

func (m *CopyTablesRequest) SetOperationParams(v *Ydb_Operations.OperationParams)

SetOperationParams implements ydb generic interface for setting operation parameters inside driver implementation.

func (*CopyTablesRequest) String 

func (m *CopyTablesRequest) String() string

func (*CopyTablesRequest) XXX_DiscardUnknown 

func (m *CopyTablesRequest) XXX_DiscardUnknown()

func (*CopyTablesRequest) XXX_Marshal 

func (m *CopyTablesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CopyTablesRequest) XXX_Merge 

func (m *CopyTablesRequest) XXX_Merge(src proto.Message)

func (*CopyTablesRequest) XXX_Size 

func (m *CopyTablesRequest) XXX_Size() int

func (*CopyTablesRequest) XXX_Unmarshal 

func (m *CopyTablesRequest) XXX_Unmarshal(b []byte) error

type CopyTablesResponse 

type CopyTablesResponse struct {
	Operation            *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*CopyTablesResponse) Descriptor 

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

func (*CopyTablesResponse) GetOperation 

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

func (*CopyTablesResponse) ProtoMessage 

func (*CopyTablesResponse) ProtoMessage()

func (*CopyTablesResponse) Reset 

func (m *CopyTablesResponse) Reset()

func (*CopyTablesResponse) String 

func (m *CopyTablesResponse) String() string

func (*CopyTablesResponse) XXX_DiscardUnknown 

func (m *CopyTablesResponse) XXX_DiscardUnknown()

func (*CopyTablesResponse) XXX_Marshal 

func (m *CopyTablesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CopyTablesResponse) XXX_Merge 

func (m *CopyTablesResponse) XXX_Merge(src proto.Message)

func (*CopyTablesResponse) XXX_Size 

func (m *CopyTablesResponse) XXX_Size() int

func (*CopyTablesResponse) XXX_Unmarshal 

func (m *CopyTablesResponse) XXX_Unmarshal(b []byte) error

type CreateSessionRequest 

type CreateSessionRequest struct {
	OperationParams      *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

Create new session

func (*CreateSessionRequest) Descriptor 

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

func (*CreateSessionRequest) GetOperationParams 

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

func (*CreateSessionRequest) ProtoMessage 

func (*CreateSessionRequest) ProtoMessage()

func (*CreateSessionRequest) Reset 

func (m *CreateSessionRequest) Reset()

func (*CreateSessionRequest) SetOperationParams 

func (m *CreateSessionRequest) SetOperationParams(v *Ydb_Operations.OperationParams)

SetOperationParams implements ydb generic interface for setting operation parameters inside driver implementation.

func (*CreateSessionRequest) String 

func (m *CreateSessionRequest) String() string

func (*CreateSessionRequest) XXX_DiscardUnknown 

func (m *CreateSessionRequest) XXX_DiscardUnknown()

func (*CreateSessionRequest) XXX_Marshal 

func (m *CreateSessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateSessionRequest) XXX_Merge 

func (m *CreateSessionRequest) XXX_Merge(src proto.Message)

func (*CreateSessionRequest) XXX_Size 

func (m *CreateSessionRequest) XXX_Size() int

func (*CreateSessionRequest) XXX_Unmarshal 

func (m *CreateSessionRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

Create new session

func (*CreateSessionResponse) Descriptor 

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

func (*CreateSessionResponse) GetOperation 

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

func (*CreateSessionResponse) ProtoMessage 

func (*CreateSessionResponse) ProtoMessage()

func (*CreateSessionResponse) Reset 

func (m *CreateSessionResponse) Reset()

func (*CreateSessionResponse) String 

func (m *CreateSessionResponse) String() string

func (*CreateSessionResponse) XXX_DiscardUnknown 

func (m *CreateSessionResponse) XXX_DiscardUnknown()

func (*CreateSessionResponse) XXX_Marshal 

func (m *CreateSessionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateSessionResponse) XXX_Merge 

func (m *CreateSessionResponse) XXX_Merge(src proto.Message)

func (*CreateSessionResponse) XXX_Size 

func (m *CreateSessionResponse) XXX_Size() int

func (*CreateSessionResponse) XXX_Unmarshal 

func (m *CreateSessionResponse) XXX_Unmarshal(b []byte) error

type CreateSessionResult 

type CreateSessionResult struct {
	// Session identifier
	SessionId            string   `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateSessionResult) Descriptor 

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

func (*CreateSessionResult) GetSessionId 

func (m *CreateSessionResult) GetSessionId() string

func (*CreateSessionResult) ProtoMessage 

func (*CreateSessionResult) ProtoMessage()

func (*CreateSessionResult) Reset 

func (m *CreateSessionResult) Reset()

func (*CreateSessionResult) String 

func (m *CreateSessionResult) String() string

func (*CreateSessionResult) XXX_DiscardUnknown 

func (m *CreateSessionResult) XXX_DiscardUnknown()

func (*CreateSessionResult) XXX_Marshal 

func (m *CreateSessionResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateSessionResult) XXX_Merge 

func (m *CreateSessionResult) XXX_Merge(src proto.Message)

func (*CreateSessionResult) XXX_Size 

func (m *CreateSessionResult) XXX_Size() int

func (*CreateSessionResult) XXX_Unmarshal 

func (m *CreateSessionResult) XXX_Unmarshal(b []byte) error

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 valid to be assigned 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"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*CreateTableRequest) Descriptor 

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

func (*CreateTableRequest) GetAttributes 

func (m *CreateTableRequest) GetAttributes() map[string]string

func (*CreateTableRequest) GetColumnFamilies 

func (m *CreateTableRequest) GetColumnFamilies() []*ColumnFamily

func (*CreateTableRequest) GetColumns 

func (m *CreateTableRequest) GetColumns() []*ColumnMeta

func (*CreateTableRequest) GetCompactionPolicy 

func (m *CreateTableRequest) GetCompactionPolicy() string

func (*CreateTableRequest) GetIndexes 

func (m *CreateTableRequest) GetIndexes() []*TableIndex

func (*CreateTableRequest) GetKeyBloomFilter 

func (m *CreateTableRequest) GetKeyBloomFilter() Ydb.FeatureFlag_Status

func (*CreateTableRequest) GetOperationParams 

func (m *CreateTableRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*CreateTableRequest) GetPartitionAtKeys 

func (m *CreateTableRequest) GetPartitionAtKeys() *ExplicitPartitions

func (*CreateTableRequest) GetPartitioningSettings 

func (m *CreateTableRequest) GetPartitioningSettings() *PartitioningSettings

func (*CreateTableRequest) GetPartitions 

func (m *CreateTableRequest) GetPartitions() isCreateTableRequest_Partitions

func (*CreateTableRequest) GetPath 

func (m *CreateTableRequest) GetPath() string

func (*CreateTableRequest) GetPrimaryKey 

func (m *CreateTableRequest) GetPrimaryKey() []string

func (*CreateTableRequest) GetProfile 

func (m *CreateTableRequest) GetProfile() *TableProfile

func (*CreateTableRequest) GetReadReplicasSettings 

func (m *CreateTableRequest) GetReadReplicasSettings() *ReadReplicasSettings

func (*CreateTableRequest) GetSessionId 

func (m *CreateTableRequest) GetSessionId() string

func (*CreateTableRequest) GetStorageSettings 

func (m *CreateTableRequest) GetStorageSettings() *StorageSettings

func (*CreateTableRequest) GetTtlSettings 

func (m *CreateTableRequest) GetTtlSettings() *TtlSettings

func (*CreateTableRequest) GetUniformPartitions 

func (m *CreateTableRequest) GetUniformPartitions() uint64

func (*CreateTableRequest) ProtoMessage 

func (*CreateTableRequest) ProtoMessage()

func (*CreateTableRequest) Reset 

func (m *CreateTableRequest) Reset()

func (*CreateTableRequest) SetOperationParams 

func (m *CreateTableRequest) SetOperationParams(v *Ydb_Operations.OperationParams)

SetOperationParams implements ydb generic interface for setting operation parameters inside driver implementation.

func (*CreateTableRequest) String 

func (m *CreateTableRequest) String() string

func (*CreateTableRequest) XXX_DiscardUnknown 

func (m *CreateTableRequest) XXX_DiscardUnknown()

func (*CreateTableRequest) XXX_Marshal 

func (m *CreateTableRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateTableRequest) XXX_Merge 

func (m *CreateTableRequest) XXX_Merge(src proto.Message)

func (*CreateTableRequest) XXX_OneofWrappers 

func (*CreateTableRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*CreateTableRequest) XXX_Size 

func (m *CreateTableRequest) XXX_Size() int

func (*CreateTableRequest) XXX_Unmarshal 

func (m *CreateTableRequest) XXX_Unmarshal(b []byte) error

type CreateTableRequest_PartitionAtKeys 

type CreateTableRequest_PartitionAtKeys struct {
	PartitionAtKeys *ExplicitPartitions `protobuf:"bytes,14,opt,name=partition_at_keys,json=partitionAtKeys,proto3,oneof"`
}

type CreateTableRequest_UniformPartitions 

type CreateTableRequest_UniformPartitions struct {
	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"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*CreateTableResponse) Descriptor 

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

func (*CreateTableResponse) GetOperation 

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

func (*CreateTableResponse) ProtoMessage 

func (*CreateTableResponse) ProtoMessage()

func (*CreateTableResponse) Reset 

func (m *CreateTableResponse) Reset()

func (*CreateTableResponse) String 

func (m *CreateTableResponse) String() string

func (*CreateTableResponse) XXX_DiscardUnknown 

func (m *CreateTableResponse) XXX_DiscardUnknown()

func (*CreateTableResponse) XXX_Marshal 

func (m *CreateTableResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateTableResponse) XXX_Merge 

func (m *CreateTableResponse) XXX_Merge(src proto.Message)

func (*CreateTableResponse) XXX_Size 

func (m *CreateTableResponse) XXX_Size() int

func (*CreateTableResponse) XXX_Unmarshal 

func (m *CreateTableResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DateTypeColumnModeSettings) Descriptor 

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

func (*DateTypeColumnModeSettings) GetColumnName 

func (m *DateTypeColumnModeSettings) GetColumnName() string

func (*DateTypeColumnModeSettings) GetExpireAfterSeconds 

func (m *DateTypeColumnModeSettings) GetExpireAfterSeconds() uint32

func (*DateTypeColumnModeSettings) ProtoMessage 

func (*DateTypeColumnModeSettings) ProtoMessage()

func (*DateTypeColumnModeSettings) Reset 

func (m *DateTypeColumnModeSettings) Reset()

func (*DateTypeColumnModeSettings) String 

func (m *DateTypeColumnModeSettings) String() string

func (*DateTypeColumnModeSettings) XXX_DiscardUnknown 

func (m *DateTypeColumnModeSettings) XXX_DiscardUnknown()

func (*DateTypeColumnModeSettings) XXX_Marshal 

func (m *DateTypeColumnModeSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DateTypeColumnModeSettings) XXX_Merge 

func (m *DateTypeColumnModeSettings) XXX_Merge(src proto.Message)

func (*DateTypeColumnModeSettings) XXX_Size 

func (m *DateTypeColumnModeSettings) XXX_Size() int

func (*DateTypeColumnModeSettings) XXX_Unmarshal 

func (m *DateTypeColumnModeSettings) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

Delete session with given id string

func (*DeleteSessionRequest) Descriptor 

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

func (*DeleteSessionRequest) GetOperationParams 

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

func (*DeleteSessionRequest) GetSessionId 

func (m *DeleteSessionRequest) GetSessionId() string

func (*DeleteSessionRequest) ProtoMessage 

func (*DeleteSessionRequest) ProtoMessage()

func (*DeleteSessionRequest) Reset 

func (m *DeleteSessionRequest) Reset()

func (*DeleteSessionRequest) SetOperationParams 

func (m *DeleteSessionRequest) SetOperationParams(v *Ydb_Operations.OperationParams)

SetOperationParams implements ydb generic interface for setting operation parameters inside driver implementation.

func (*DeleteSessionRequest) String 

func (m *DeleteSessionRequest) String() string

func (*DeleteSessionRequest) XXX_DiscardUnknown 

func (m *DeleteSessionRequest) XXX_DiscardUnknown()

func (*DeleteSessionRequest) XXX_Marshal 

func (m *DeleteSessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteSessionRequest) XXX_Merge 

func (m *DeleteSessionRequest) XXX_Merge(src proto.Message)

func (*DeleteSessionRequest) XXX_Size 

func (m *DeleteSessionRequest) XXX_Size() int

func (*DeleteSessionRequest) XXX_Unmarshal 

func (m *DeleteSessionRequest) XXX_Unmarshal(b []byte) error

type DeleteSessionResponse 

type DeleteSessionResponse struct {
	Operation            *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*DeleteSessionResponse) Descriptor 

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

func (*DeleteSessionResponse) GetOperation 

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

func (*DeleteSessionResponse) ProtoMessage 

func (*DeleteSessionResponse) ProtoMessage()

func (*DeleteSessionResponse) Reset 

func (m *DeleteSessionResponse) Reset()

func (*DeleteSessionResponse) String 

func (m *DeleteSessionResponse) String() string

func (*DeleteSessionResponse) XXX_DiscardUnknown 

func (m *DeleteSessionResponse) XXX_DiscardUnknown()

func (*DeleteSessionResponse) XXX_Marshal 

func (m *DeleteSessionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteSessionResponse) XXX_Merge 

func (m *DeleteSessionResponse) XXX_Merge(src proto.Message)

func (*DeleteSessionResponse) XXX_Size 

func (m *DeleteSessionResponse) XXX_Size() int

func (*DeleteSessionResponse) XXX_Unmarshal 

func (m *DeleteSessionResponse) XXX_Unmarshal(b []byte) error

type DescribeTableOptionsRequest 

type DescribeTableOptionsRequest struct {
	OperationParams      *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*DescribeTableOptionsRequest) Descriptor 

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

func (*DescribeTableOptionsRequest) GetOperationParams 

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

func (*DescribeTableOptionsRequest) ProtoMessage 

func (*DescribeTableOptionsRequest) ProtoMessage()

func (*DescribeTableOptionsRequest) Reset 

func (m *DescribeTableOptionsRequest) Reset()

func (*DescribeTableOptionsRequest) SetOperationParams 

func (m *DescribeTableOptionsRequest) SetOperationParams(v *Ydb_Operations.OperationParams)

SetOperationParams implements ydb generic interface for setting operation parameters inside driver implementation.

func (*DescribeTableOptionsRequest) String 

func (m *DescribeTableOptionsRequest) String() string

func (*DescribeTableOptionsRequest) XXX_DiscardUnknown 

func (m *DescribeTableOptionsRequest) XXX_DiscardUnknown()

func (*DescribeTableOptionsRequest) XXX_Marshal 

func (m *DescribeTableOptionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DescribeTableOptionsRequest) XXX_Merge 

func (m *DescribeTableOptionsRequest) XXX_Merge(src proto.Message)

func (*DescribeTableOptionsRequest) XXX_Size 

func (m *DescribeTableOptionsRequest) XXX_Size() int

func (*DescribeTableOptionsRequest) XXX_Unmarshal 

func (m *DescribeTableOptionsRequest) XXX_Unmarshal(b []byte) error

type DescribeTableOptionsResponse 

type DescribeTableOptionsResponse struct {
	// operation.result holds ListTableParametersResult
	Operation            *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*DescribeTableOptionsResponse) Descriptor 

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

func (*DescribeTableOptionsResponse) GetOperation 

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

func (*DescribeTableOptionsResponse) ProtoMessage 

func (*DescribeTableOptionsResponse) ProtoMessage()

func (*DescribeTableOptionsResponse) Reset 

func (m *DescribeTableOptionsResponse) Reset()

func (*DescribeTableOptionsResponse) String 

func (m *DescribeTableOptionsResponse) String() string

func (*DescribeTableOptionsResponse) XXX_DiscardUnknown 

func (m *DescribeTableOptionsResponse) XXX_DiscardUnknown()

func (*DescribeTableOptionsResponse) XXX_Marshal 

func (m *DescribeTableOptionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DescribeTableOptionsResponse) XXX_Merge 

func (m *DescribeTableOptionsResponse) XXX_Merge(src proto.Message)

func (*DescribeTableOptionsResponse) XXX_Size 

func (m *DescribeTableOptionsResponse) XXX_Size() int

func (*DescribeTableOptionsResponse) XXX_Unmarshal 

func (m *DescribeTableOptionsResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral      struct{}                         `json:"-"`
	XXX_unrecognized          []byte                           `json:"-"`
	XXX_sizecache             int32                            `json:"-"`
}

func (*DescribeTableOptionsResult) Descriptor 

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

func (*DescribeTableOptionsResult) GetCachingPolicyPresets 

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

func (*DescribeTableOptionsResult) GetCompactionPolicyPresets 

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

func (*DescribeTableOptionsResult) GetExecutionPolicyPresets 

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

func (*DescribeTableOptionsResult) GetPartitioningPolicyPresets 

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

func (*DescribeTableOptionsResult) GetReplicationPolicyPresets 

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

func (*DescribeTableOptionsResult) GetStoragePolicyPresets 

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

func (*DescribeTableOptionsResult) GetTableProfilePresets 

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

func (*DescribeTableOptionsResult) ProtoMessage 

func (*DescribeTableOptionsResult) ProtoMessage()

func (*DescribeTableOptionsResult) Reset 

func (m *DescribeTableOptionsResult) Reset()

func (*DescribeTableOptionsResult) String 

func (m *DescribeTableOptionsResult) String() string

func (*DescribeTableOptionsResult) XXX_DiscardUnknown 

func (m *DescribeTableOptionsResult) XXX_DiscardUnknown()

func (*DescribeTableOptionsResult) XXX_Marshal 

func (m *DescribeTableOptionsResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DescribeTableOptionsResult) XXX_Merge 

func (m *DescribeTableOptionsResult) XXX_Merge(src proto.Message)

func (*DescribeTableOptionsResult) XXX_Size 

func (m *DescribeTableOptionsResult) XXX_Size() int

func (*DescribeTableOptionsResult) XXX_Unmarshal 

func (m *DescribeTableOptionsResult) XXX_Unmarshal(b []byte) error

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 */
	XXX_NoUnkeyedLiteral  struct{} `json:"-"`
	XXX_unrecognized      []byte   `json:"-"`
	XXX_sizecache         int32    `json:"-"`
}

Describe table with given path

func (*DescribeTableRequest) Descriptor 

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

func (*DescribeTableRequest) GetIncludePartitionStats 

func (m *DescribeTableRequest) GetIncludePartitionStats() bool

func (*DescribeTableRequest) GetIncludeShardKeyBounds 

func (m *DescribeTableRequest) GetIncludeShardKeyBounds() bool

func (*DescribeTableRequest) GetIncludeTableStats 

func (m *DescribeTableRequest) GetIncludeTableStats() bool

func (*DescribeTableRequest) GetOperationParams 

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

func (*DescribeTableRequest) GetPath 

func (m *DescribeTableRequest) GetPath() string

func (*DescribeTableRequest) GetSessionId 

func (m *DescribeTableRequest) GetSessionId() string

func (*DescribeTableRequest) ProtoMessage 

func (*DescribeTableRequest) ProtoMessage()

func (*DescribeTableRequest) Reset 

func (m *DescribeTableRequest) Reset()

func (*DescribeTableRequest) SetOperationParams 

func (m *DescribeTableRequest) SetOperationParams(v *Ydb_Operations.OperationParams)

SetOperationParams implements ydb generic interface for setting operation parameters inside driver implementation.

func (*DescribeTableRequest) String 

func (m *DescribeTableRequest) String() string

func (*DescribeTableRequest) XXX_DiscardUnknown 

func (m *DescribeTableRequest) XXX_DiscardUnknown()

func (*DescribeTableRequest) XXX_Marshal 

func (m *DescribeTableRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DescribeTableRequest) XXX_Merge 

func (m *DescribeTableRequest) XXX_Merge(src proto.Message)

func (*DescribeTableRequest) XXX_Size 

func (m *DescribeTableRequest) XXX_Size() int

func (*DescribeTableRequest) XXX_Unmarshal 

func (m *DescribeTableRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*DescribeTableResponse) Descriptor 

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

func (*DescribeTableResponse) GetOperation 

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

func (*DescribeTableResponse) ProtoMessage 

func (*DescribeTableResponse) ProtoMessage()

func (*DescribeTableResponse) Reset 

func (m *DescribeTableResponse) Reset()

func (*DescribeTableResponse) String 

func (m *DescribeTableResponse) String() string

func (*DescribeTableResponse) XXX_DiscardUnknown 

func (m *DescribeTableResponse) XXX_DiscardUnknown()

func (*DescribeTableResponse) XXX_Marshal 

func (m *DescribeTableResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DescribeTableResponse) XXX_Merge 

func (m *DescribeTableResponse) XXX_Merge(src proto.Message)

func (*DescribeTableResponse) XXX_Size 

func (m *DescribeTableResponse) XXX_Size() int

func (*DescribeTableResponse) XXX_Unmarshal 

func (m *DescribeTableResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*DescribeTableResult) Descriptor 

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

func (*DescribeTableResult) GetAttributes 

func (m *DescribeTableResult) GetAttributes() map[string]string

func (*DescribeTableResult) GetColumnFamilies 

func (m *DescribeTableResult) GetColumnFamilies() []*ColumnFamily

func (*DescribeTableResult) GetColumns 

func (m *DescribeTableResult) GetColumns() []*ColumnMeta

func (*DescribeTableResult) GetIndexes 

func (m *DescribeTableResult) GetIndexes() []*TableIndexDescription

func (*DescribeTableResult) GetKeyBloomFilter 

func (m *DescribeTableResult) GetKeyBloomFilter() Ydb.FeatureFlag_Status

func (*DescribeTableResult) GetPartitioningSettings 

func (m *DescribeTableResult) GetPartitioningSettings() *PartitioningSettings

func (*DescribeTableResult) GetPrimaryKey 

func (m *DescribeTableResult) GetPrimaryKey() []string

func (*DescribeTableResult) GetReadReplicasSettings 

func (m *DescribeTableResult) GetReadReplicasSettings() *ReadReplicasSettings

func (*DescribeTableResult) GetSelf 

func (m *DescribeTableResult) GetSelf() *Ydb_Scheme.Entry

func (*DescribeTableResult) GetShardKeyBounds 

func (m *DescribeTableResult) GetShardKeyBounds() []*Ydb.TypedValue

func (*DescribeTableResult) GetStorageSettings 

func (m *DescribeTableResult) GetStorageSettings() *StorageSettings

func (*DescribeTableResult) GetTableStats 

func (m *DescribeTableResult) GetTableStats() *TableStats

func (*DescribeTableResult) GetTtlSettings 

func (m *DescribeTableResult) GetTtlSettings() *TtlSettings

func (*DescribeTableResult) ProtoMessage 

func (*DescribeTableResult) ProtoMessage()

func (*DescribeTableResult) Reset 

func (m *DescribeTableResult) Reset()

func (*DescribeTableResult) String 

func (m *DescribeTableResult) String() string

func (*DescribeTableResult) XXX_DiscardUnknown 

func (m *DescribeTableResult) XXX_DiscardUnknown()

func (*DescribeTableResult) XXX_Marshal 

func (m *DescribeTableResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DescribeTableResult) XXX_Merge 

func (m *DescribeTableResult) XXX_Merge(src proto.Message)

func (*DescribeTableResult) XXX_Size 

func (m *DescribeTableResult) XXX_Size() int

func (*DescribeTableResult) XXX_Unmarshal 

func (m *DescribeTableResult) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

Drop table with given path

func (*DropTableRequest) Descriptor 

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

func (*DropTableRequest) GetOperationParams 

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

func (*DropTableRequest) GetPath 

func (m *DropTableRequest) GetPath() string

func (*DropTableRequest) GetSessionId 

func (m *DropTableRequest) GetSessionId() string

func (*DropTableRequest) ProtoMessage 

func (*DropTableRequest) ProtoMessage()

func (*DropTableRequest) Reset 

func (m *DropTableRequest) Reset()

func (*DropTableRequest) SetOperationParams 

func (m *DropTableRequest) SetOperationParams(v *Ydb_Operations.OperationParams)

SetOperationParams implements ydb generic interface for setting operation parameters inside driver implementation.

func (*DropTableRequest) String 

func (m *DropTableRequest) String() string

func (*DropTableRequest) XXX_DiscardUnknown 

func (m *DropTableRequest) XXX_DiscardUnknown()

func (*DropTableRequest) XXX_Marshal 

func (m *DropTableRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DropTableRequest) XXX_Merge 

func (m *DropTableRequest) XXX_Merge(src proto.Message)

func (*DropTableRequest) XXX_Size 

func (m *DropTableRequest) XXX_Size() int

func (*DropTableRequest) XXX_Unmarshal 

func (m *DropTableRequest) XXX_Unmarshal(b []byte) error

type DropTableResponse 

type DropTableResponse struct {
	Operation            *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*DropTableResponse) Descriptor 

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

func (*DropTableResponse) GetOperation 

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

func (*DropTableResponse) ProtoMessage 

func (*DropTableResponse) ProtoMessage()

func (*DropTableResponse) Reset 

func (m *DropTableResponse) Reset()

func (*DropTableResponse) String 

func (m *DropTableResponse) String() string

func (*DropTableResponse) XXX_DiscardUnknown 

func (m *DropTableResponse) XXX_DiscardUnknown()

func (*DropTableResponse) XXX_Marshal 

func (m *DropTableResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DropTableResponse) XXX_Merge 

func (m *DropTableResponse) XXX_Merge(src proto.Message)

func (*DropTableResponse) XXX_Size 

func (m *DropTableResponse) XXX_Size() int

func (*DropTableResponse) XXX_Unmarshal 

func (m *DropTableResponse) XXX_Unmarshal(b []byte) error

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 */
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*ExecuteDataQueryRequest) Descriptor 

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

func (*ExecuteDataQueryRequest) GetCollectStats 

func (m *ExecuteDataQueryRequest) GetCollectStats() QueryStatsCollection_Mode

func (*ExecuteDataQueryRequest) GetOperationParams 

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

func (*ExecuteDataQueryRequest) GetParameters 

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

func (*ExecuteDataQueryRequest) GetQuery 

func (m *ExecuteDataQueryRequest) GetQuery() *Query

func (*ExecuteDataQueryRequest) GetQueryCachePolicy 

func (m *ExecuteDataQueryRequest) GetQueryCachePolicy() *QueryCachePolicy

func (*ExecuteDataQueryRequest) GetSessionId 

func (m *ExecuteDataQueryRequest) GetSessionId() string

func (*ExecuteDataQueryRequest) GetTxControl 

func (m *ExecuteDataQueryRequest) GetTxControl() *TransactionControl

func (*ExecuteDataQueryRequest) ProtoMessage 

func (*ExecuteDataQueryRequest) ProtoMessage()

func (*ExecuteDataQueryRequest) Reset 

func (m *ExecuteDataQueryRequest) Reset()

func (*ExecuteDataQueryRequest) SetOperationParams 

func (m *ExecuteDataQueryRequest) SetOperationParams(v *Ydb_Operations.OperationParams)

SetOperationParams implements ydb generic interface for setting operation parameters inside driver implementation.

func (*ExecuteDataQueryRequest) String 

func (m *ExecuteDataQueryRequest) String() string

func (*ExecuteDataQueryRequest) XXX_DiscardUnknown 

func (m *ExecuteDataQueryRequest) XXX_DiscardUnknown()

func (*ExecuteDataQueryRequest) XXX_Marshal 

func (m *ExecuteDataQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecuteDataQueryRequest) XXX_Merge 

func (m *ExecuteDataQueryRequest) XXX_Merge(src proto.Message)

func (*ExecuteDataQueryRequest) XXX_Size 

func (m *ExecuteDataQueryRequest) XXX_Size() int

func (*ExecuteDataQueryRequest) XXX_Unmarshal 

func (m *ExecuteDataQueryRequest) XXX_Unmarshal(b []byte) error

type ExecuteDataQueryResponse 

type ExecuteDataQueryResponse struct {
	Operation            *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*ExecuteDataQueryResponse) Descriptor 

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

func (*ExecuteDataQueryResponse) GetOperation 

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

func (*ExecuteDataQueryResponse) ProtoMessage 

func (*ExecuteDataQueryResponse) ProtoMessage()

func (*ExecuteDataQueryResponse) Reset 

func (m *ExecuteDataQueryResponse) Reset()

func (*ExecuteDataQueryResponse) String 

func (m *ExecuteDataQueryResponse) String() string

func (*ExecuteDataQueryResponse) XXX_DiscardUnknown 

func (m *ExecuteDataQueryResponse) XXX_DiscardUnknown()

func (*ExecuteDataQueryResponse) XXX_Marshal 

func (m *ExecuteDataQueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecuteDataQueryResponse) XXX_Merge 

func (m *ExecuteDataQueryResponse) XXX_Merge(src proto.Message)

func (*ExecuteDataQueryResponse) XXX_Size 

func (m *ExecuteDataQueryResponse) XXX_Size() int

func (*ExecuteDataQueryResponse) XXX_Unmarshal 

func (m *ExecuteDataQueryResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

One QueryResult can contain multiple tables

func (*ExecuteQueryResult) Descriptor 

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

func (*ExecuteQueryResult) GetQueryMeta 

func (m *ExecuteQueryResult) GetQueryMeta() *QueryMeta

func (*ExecuteQueryResult) GetQueryStats 

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

func (*ExecuteQueryResult) GetResultSets 

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

func (*ExecuteQueryResult) GetTxMeta 

func (m *ExecuteQueryResult) GetTxMeta() *TransactionMeta

func (*ExecuteQueryResult) ProtoMessage 

func (*ExecuteQueryResult) ProtoMessage()

func (*ExecuteQueryResult) Reset 

func (m *ExecuteQueryResult) Reset()

func (*ExecuteQueryResult) String 

func (m *ExecuteQueryResult) String() string

func (*ExecuteQueryResult) XXX_DiscardUnknown 

func (m *ExecuteQueryResult) XXX_DiscardUnknown()

func (*ExecuteQueryResult) XXX_Marshal 

func (m *ExecuteQueryResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecuteQueryResult) XXX_Merge 

func (m *ExecuteQueryResult) XXX_Merge(src proto.Message)

func (*ExecuteQueryResult) XXX_Size 

func (m *ExecuteQueryResult) XXX_Size() int

func (*ExecuteQueryResult) XXX_Unmarshal 

func (m *ExecuteQueryResult) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*ExecuteScanQueryPartialResponse) Descriptor 

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

func (*ExecuteScanQueryPartialResponse) GetIssues 

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

func (*ExecuteScanQueryPartialResponse) GetResult 

func (m *ExecuteScanQueryPartialResponse) GetResult() *ExecuteScanQueryPartialResult

func (*ExecuteScanQueryPartialResponse) GetStatus 

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

func (*ExecuteScanQueryPartialResponse) ProtoMessage 

func (*ExecuteScanQueryPartialResponse) ProtoMessage()

func (*ExecuteScanQueryPartialResponse) Reset 

func (m *ExecuteScanQueryPartialResponse) Reset()

func (*ExecuteScanQueryPartialResponse) String 

func (m *ExecuteScanQueryPartialResponse) String() string

func (*ExecuteScanQueryPartialResponse) XXX_DiscardUnknown 

func (m *ExecuteScanQueryPartialResponse) XXX_DiscardUnknown()

func (*ExecuteScanQueryPartialResponse) XXX_Marshal 

func (m *ExecuteScanQueryPartialResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecuteScanQueryPartialResponse) XXX_Merge 

func (m *ExecuteScanQueryPartialResponse) XXX_Merge(src proto.Message)

func (*ExecuteScanQueryPartialResponse) XXX_Size 

func (m *ExecuteScanQueryPartialResponse) XXX_Size() int

func (*ExecuteScanQueryPartialResponse) XXX_Unmarshal 

func (m *ExecuteScanQueryPartialResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*ExecuteScanQueryPartialResult) Descriptor 

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

func (*ExecuteScanQueryPartialResult) GetQueryStats 

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

func (*ExecuteScanQueryPartialResult) GetResultSet 

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

func (*ExecuteScanQueryPartialResult) ProtoMessage 

func (*ExecuteScanQueryPartialResult) ProtoMessage()

func (*ExecuteScanQueryPartialResult) Reset 

func (m *ExecuteScanQueryPartialResult) Reset()

func (*ExecuteScanQueryPartialResult) String 

func (m *ExecuteScanQueryPartialResult) String() string

func (*ExecuteScanQueryPartialResult) XXX_DiscardUnknown 

func (m *ExecuteScanQueryPartialResult) XXX_DiscardUnknown()

func (*ExecuteScanQueryPartialResult) XXX_Marshal 

func (m *ExecuteScanQueryPartialResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecuteScanQueryPartialResult) XXX_Merge 

func (m *ExecuteScanQueryPartialResult) XXX_Merge(src proto.Message)

func (*ExecuteScanQueryPartialResult) XXX_Size 

func (m *ExecuteScanQueryPartialResult) XXX_Size() int

func (*ExecuteScanQueryPartialResult) XXX_Unmarshal 

func (m *ExecuteScanQueryPartialResult) XXX_Unmarshal(b []byte) error

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 */
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*ExecuteScanQueryRequest) Descriptor 

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

func (*ExecuteScanQueryRequest) GetCollectStats 

func (m *ExecuteScanQueryRequest) GetCollectStats() QueryStatsCollection_Mode

func (*ExecuteScanQueryRequest) GetMode 

func (m *ExecuteScanQueryRequest) GetMode() ExecuteScanQueryRequest_Mode

func (*ExecuteScanQueryRequest) GetParameters 

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

func (*ExecuteScanQueryRequest) GetQuery 

func (m *ExecuteScanQueryRequest) GetQuery() *Query

func (*ExecuteScanQueryRequest) ProtoMessage 

func (*ExecuteScanQueryRequest) ProtoMessage()

func (*ExecuteScanQueryRequest) Reset 

func (m *ExecuteScanQueryRequest) Reset()

func (*ExecuteScanQueryRequest) String 

func (m *ExecuteScanQueryRequest) String() string

func (*ExecuteScanQueryRequest) XXX_DiscardUnknown 

func (m *ExecuteScanQueryRequest) XXX_DiscardUnknown()

func (*ExecuteScanQueryRequest) XXX_Marshal 

func (m *ExecuteScanQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecuteScanQueryRequest) XXX_Merge 

func (m *ExecuteScanQueryRequest) XXX_Merge(src proto.Message)

func (*ExecuteScanQueryRequest) XXX_Size 

func (m *ExecuteScanQueryRequest) XXX_Size() int

func (*ExecuteScanQueryRequest) XXX_Unmarshal 

func (m *ExecuteScanQueryRequest) XXX_Unmarshal(b []byte) error

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

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

func (ExecuteScanQueryRequest_Mode) String 

func (x ExecuteScanQueryRequest_Mode) String() string

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"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*ExecuteSchemeQueryRequest) Descriptor 

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

func (*ExecuteSchemeQueryRequest) GetOperationParams 

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

func (*ExecuteSchemeQueryRequest) GetSessionId 

func (m *ExecuteSchemeQueryRequest) GetSessionId() string

func (*ExecuteSchemeQueryRequest) GetYqlText 

func (m *ExecuteSchemeQueryRequest) GetYqlText() string

func (*ExecuteSchemeQueryRequest) ProtoMessage 

func (*ExecuteSchemeQueryRequest) ProtoMessage()

func (*ExecuteSchemeQueryRequest) Reset 

func (m *ExecuteSchemeQueryRequest) Reset()

func (*ExecuteSchemeQueryRequest) SetOperationParams 

func (m *ExecuteSchemeQueryRequest) SetOperationParams(v *Ydb_Operations.OperationParams)

SetOperationParams implements ydb generic interface for setting operation parameters inside driver implementation.

func (*ExecuteSchemeQueryRequest) String 

func (m *ExecuteSchemeQueryRequest) String() string

func (*ExecuteSchemeQueryRequest) XXX_DiscardUnknown 

func (m *ExecuteSchemeQueryRequest) XXX_DiscardUnknown()

func (*ExecuteSchemeQueryRequest) XXX_Marshal 

func (m *ExecuteSchemeQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecuteSchemeQueryRequest) XXX_Merge 

func (m *ExecuteSchemeQueryRequest) XXX_Merge(src proto.Message)

func (*ExecuteSchemeQueryRequest) XXX_Size 

func (m *ExecuteSchemeQueryRequest) XXX_Size() int

func (*ExecuteSchemeQueryRequest) XXX_Unmarshal 

func (m *ExecuteSchemeQueryRequest) XXX_Unmarshal(b []byte) error

type ExecuteSchemeQueryResponse 

type ExecuteSchemeQueryResponse struct {
	Operation            *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*ExecuteSchemeQueryResponse) Descriptor 

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

func (*ExecuteSchemeQueryResponse) GetOperation 

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

func (*ExecuteSchemeQueryResponse) ProtoMessage 

func (*ExecuteSchemeQueryResponse) ProtoMessage()

func (*ExecuteSchemeQueryResponse) Reset 

func (m *ExecuteSchemeQueryResponse) Reset()

func (*ExecuteSchemeQueryResponse) String 

func (m *ExecuteSchemeQueryResponse) String() string

func (*ExecuteSchemeQueryResponse) XXX_DiscardUnknown 

func (m *ExecuteSchemeQueryResponse) XXX_DiscardUnknown()

func (*ExecuteSchemeQueryResponse) XXX_Marshal 

func (m *ExecuteSchemeQueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecuteSchemeQueryResponse) XXX_Merge 

func (m *ExecuteSchemeQueryResponse) XXX_Merge(src proto.Message)

func (*ExecuteSchemeQueryResponse) XXX_Size 

func (m *ExecuteSchemeQueryResponse) XXX_Size() int

func (*ExecuteSchemeQueryResponse) XXX_Unmarshal 

func (m *ExecuteSchemeQueryResponse) XXX_Unmarshal(b []byte) error

type ExecutionPolicy 

type ExecutionPolicy struct {
	PresetName           string   `protobuf:"bytes,1,opt,name=preset_name,json=presetName,proto3" json:"preset_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExecutionPolicy) Descriptor 

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

func (*ExecutionPolicy) GetPresetName 

func (m *ExecutionPolicy) GetPresetName() string

func (*ExecutionPolicy) ProtoMessage 

func (*ExecutionPolicy) ProtoMessage()

func (*ExecutionPolicy) Reset 

func (m *ExecutionPolicy) Reset()

func (*ExecutionPolicy) String 

func (m *ExecutionPolicy) String() string

func (*ExecutionPolicy) XXX_DiscardUnknown 

func (m *ExecutionPolicy) XXX_DiscardUnknown()

func (*ExecutionPolicy) XXX_Marshal 

func (m *ExecutionPolicy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecutionPolicy) XXX_Merge 

func (m *ExecutionPolicy) XXX_Merge(src proto.Message)

func (*ExecutionPolicy) XXX_Size 

func (m *ExecutionPolicy) XXX_Size() int

func (*ExecutionPolicy) XXX_Unmarshal 

func (m *ExecutionPolicy) XXX_Unmarshal(b []byte) error

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 */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ExecutionPolicyDescription) Descriptor 

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

func (*ExecutionPolicyDescription) GetLabels 

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

func (*ExecutionPolicyDescription) GetName 

func (m *ExecutionPolicyDescription) GetName() string

func (*ExecutionPolicyDescription) ProtoMessage 

func (*ExecutionPolicyDescription) ProtoMessage()

func (*ExecutionPolicyDescription) Reset 

func (m *ExecutionPolicyDescription) Reset()

func (*ExecutionPolicyDescription) String 

func (m *ExecutionPolicyDescription) String() string

func (*ExecutionPolicyDescription) XXX_DiscardUnknown 

func (m *ExecutionPolicyDescription) XXX_DiscardUnknown()

func (*ExecutionPolicyDescription) XXX_Marshal 

func (m *ExecutionPolicyDescription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecutionPolicyDescription) XXX_Merge 

func (m *ExecutionPolicyDescription) XXX_Merge(src proto.Message)

func (*ExecutionPolicyDescription) XXX_Size 

func (m *ExecutionPolicyDescription) XXX_Size() int

func (*ExecutionPolicyDescription) XXX_Unmarshal 

func (m *ExecutionPolicyDescription) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

Explain data query

func (*ExplainDataQueryRequest) Descriptor 

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

func (*ExplainDataQueryRequest) GetOperationParams 

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

func (*ExplainDataQueryRequest) GetSessionId 

func (m *ExplainDataQueryRequest) GetSessionId() string

func (*ExplainDataQueryRequest) GetYqlText 

func (m *ExplainDataQueryRequest) GetYqlText() string

func (*ExplainDataQueryRequest) ProtoMessage 

func (*ExplainDataQueryRequest) ProtoMessage()

func (*ExplainDataQueryRequest) Reset 

func (m *ExplainDataQueryRequest) Reset()

func (*ExplainDataQueryRequest) SetOperationParams 

func (m *ExplainDataQueryRequest) SetOperationParams(v *Ydb_Operations.OperationParams)

SetOperationParams implements ydb generic interface for setting operation parameters inside driver implementation.

func (*ExplainDataQueryRequest) String 

func (m *ExplainDataQueryRequest) String() string

func (*ExplainDataQueryRequest) XXX_DiscardUnknown 

func (m *ExplainDataQueryRequest) XXX_DiscardUnknown()

func (*ExplainDataQueryRequest) XXX_Marshal 

func (m *ExplainDataQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExplainDataQueryRequest) XXX_Merge 

func (m *ExplainDataQueryRequest) XXX_Merge(src proto.Message)

func (*ExplainDataQueryRequest) XXX_Size 

func (m *ExplainDataQueryRequest) XXX_Size() int

func (*ExplainDataQueryRequest) XXX_Unmarshal 

func (m *ExplainDataQueryRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*ExplainDataQueryResponse) Descriptor 

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

func (*ExplainDataQueryResponse) GetOperation 

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

func (*ExplainDataQueryResponse) ProtoMessage 

func (*ExplainDataQueryResponse) ProtoMessage()

func (*ExplainDataQueryResponse) Reset 

func (m *ExplainDataQueryResponse) Reset()

func (*ExplainDataQueryResponse) String 

func (m *ExplainDataQueryResponse) String() string

func (*ExplainDataQueryResponse) XXX_DiscardUnknown 

func (m *ExplainDataQueryResponse) XXX_DiscardUnknown()

func (*ExplainDataQueryResponse) XXX_Marshal 

func (m *ExplainDataQueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExplainDataQueryResponse) XXX_Merge 

func (m *ExplainDataQueryResponse) XXX_Merge(src proto.Message)

func (*ExplainDataQueryResponse) XXX_Size 

func (m *ExplainDataQueryResponse) XXX_Size() int

func (*ExplainDataQueryResponse) XXX_Unmarshal 

func (m *ExplainDataQueryResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExplainQueryResult) Descriptor 

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

func (*ExplainQueryResult) GetQueryAst 

func (m *ExplainQueryResult) GetQueryAst() string

func (*ExplainQueryResult) GetQueryPlan 

func (m *ExplainQueryResult) GetQueryPlan() string

func (*ExplainQueryResult) ProtoMessage 

func (*ExplainQueryResult) ProtoMessage()

func (*ExplainQueryResult) Reset 

func (m *ExplainQueryResult) Reset()

func (*ExplainQueryResult) String 

func (m *ExplainQueryResult) String() string

func (*ExplainQueryResult) XXX_DiscardUnknown 

func (m *ExplainQueryResult) XXX_DiscardUnknown()

func (*ExplainQueryResult) XXX_Marshal 

func (m *ExplainQueryResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExplainQueryResult) XXX_Merge 

func (m *ExplainQueryResult) XXX_Merge(src proto.Message)

func (*ExplainQueryResult) XXX_Size 

func (m *ExplainQueryResult) XXX_Size() int

func (*ExplainQueryResult) XXX_Unmarshal 

func (m *ExplainQueryResult) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ExplicitPartitions) Descriptor 

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

func (*ExplicitPartitions) GetSplitPoints 

func (m *ExplicitPartitions) GetSplitPoints() []*Ydb.TypedValue

func (*ExplicitPartitions) ProtoMessage 

func (*ExplicitPartitions) ProtoMessage()

func (*ExplicitPartitions) Reset 

func (m *ExplicitPartitions) Reset()

func (*ExplicitPartitions) String 

func (m *ExplicitPartitions) String() string

func (*ExplicitPartitions) XXX_DiscardUnknown 

func (m *ExplicitPartitions) XXX_DiscardUnknown()

func (*ExplicitPartitions) XXX_Marshal 

func (m *ExplicitPartitions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExplicitPartitions) XXX_Merge 

func (m *ExplicitPartitions) XXX_Merge(src proto.Message)

func (*ExplicitPartitions) XXX_Size 

func (m *ExplicitPartitions) XXX_Size() int

func (*ExplicitPartitions) XXX_Unmarshal 

func (m *ExplicitPartitions) XXX_Unmarshal(b []byte) error

type GlobalAsyncIndex 

type GlobalAsyncIndex struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GlobalAsyncIndex) Descriptor 

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

func (*GlobalAsyncIndex) ProtoMessage 

func (*GlobalAsyncIndex) ProtoMessage()

func (*GlobalAsyncIndex) Reset 

func (m *GlobalAsyncIndex) Reset()

func (*GlobalAsyncIndex) String 

func (m *GlobalAsyncIndex) String() string

func (*GlobalAsyncIndex) XXX_DiscardUnknown 

func (m *GlobalAsyncIndex) XXX_DiscardUnknown()

func (*GlobalAsyncIndex) XXX_Marshal 

func (m *GlobalAsyncIndex) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GlobalAsyncIndex) XXX_Merge 

func (m *GlobalAsyncIndex) XXX_Merge(src proto.Message)

func (*GlobalAsyncIndex) XXX_Size 

func (m *GlobalAsyncIndex) XXX_Size() int

func (*GlobalAsyncIndex) XXX_Unmarshal 

func (m *GlobalAsyncIndex) XXX_Unmarshal(b []byte) error

type GlobalIndex 

type GlobalIndex struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GlobalIndex) Descriptor 

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

func (*GlobalIndex) ProtoMessage 

func (*GlobalIndex) ProtoMessage()

func (*GlobalIndex) Reset 

func (m *GlobalIndex) Reset()

func (*GlobalIndex) String 

func (m *GlobalIndex) String() string

func (*GlobalIndex) XXX_DiscardUnknown 

func (m *GlobalIndex) XXX_DiscardUnknown()

func (*GlobalIndex) XXX_Marshal 

func (m *GlobalIndex) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GlobalIndex) XXX_Merge 

func (m *GlobalIndex) XXX_Merge(src proto.Message)

func (*GlobalIndex) XXX_Size 

func (m *GlobalIndex) XXX_Size() int

func (*GlobalIndex) XXX_Unmarshal 

func (m *GlobalIndex) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

Description of index building operation

func (*IndexBuildDescription) Descriptor 

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

func (*IndexBuildDescription) GetIndex 

func (m *IndexBuildDescription) GetIndex() *TableIndex

func (*IndexBuildDescription) GetPath 

func (m *IndexBuildDescription) GetPath() string

func (*IndexBuildDescription) ProtoMessage 

func (*IndexBuildDescription) ProtoMessage()

func (*IndexBuildDescription) Reset 

func (m *IndexBuildDescription) Reset()

func (*IndexBuildDescription) String 

func (m *IndexBuildDescription) String() string

func (*IndexBuildDescription) XXX_DiscardUnknown 

func (m *IndexBuildDescription) XXX_DiscardUnknown()

func (*IndexBuildDescription) XXX_Marshal 

func (m *IndexBuildDescription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IndexBuildDescription) XXX_Merge 

func (m *IndexBuildDescription) XXX_Merge(src proto.Message)

func (*IndexBuildDescription) XXX_Size 

func (m *IndexBuildDescription) XXX_Size() int

func (*IndexBuildDescription) XXX_Unmarshal 

func (m *IndexBuildDescription) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*IndexBuildMetadata) Descriptor 

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

func (*IndexBuildMetadata) GetDescription 

func (m *IndexBuildMetadata) GetDescription() *IndexBuildDescription

func (*IndexBuildMetadata) GetProgress 

func (m *IndexBuildMetadata) GetProgress() float32

func (*IndexBuildMetadata) GetState 

func (m *IndexBuildMetadata) GetState() IndexBuildState_State

func (*IndexBuildMetadata) ProtoMessage 

func (*IndexBuildMetadata) ProtoMessage()

func (*IndexBuildMetadata) Reset 

func (m *IndexBuildMetadata) Reset()

func (*IndexBuildMetadata) String 

func (m *IndexBuildMetadata) String() string

func (*IndexBuildMetadata) XXX_DiscardUnknown 

func (m *IndexBuildMetadata) XXX_DiscardUnknown()

func (*IndexBuildMetadata) XXX_Marshal 

func (m *IndexBuildMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IndexBuildMetadata) XXX_Merge 

func (m *IndexBuildMetadata) XXX_Merge(src proto.Message)

func (*IndexBuildMetadata) XXX_Size 

func (m *IndexBuildMetadata) XXX_Size() int

func (*IndexBuildMetadata) XXX_Unmarshal 

func (m *IndexBuildMetadata) XXX_Unmarshal(b []byte) error

type IndexBuildState 

type IndexBuildState struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

State of index building operation

func (*IndexBuildState) Descriptor 

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

func (*IndexBuildState) ProtoMessage 

func (*IndexBuildState) ProtoMessage()

func (*IndexBuildState) Reset 

func (m *IndexBuildState) Reset()

func (*IndexBuildState) String 

func (m *IndexBuildState) String() string

func (*IndexBuildState) XXX_DiscardUnknown 

func (m *IndexBuildState) XXX_DiscardUnknown()

func (*IndexBuildState) XXX_Marshal 

func (m *IndexBuildState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IndexBuildState) XXX_Merge 

func (m *IndexBuildState) XXX_Merge(src proto.Message)

func (*IndexBuildState) XXX_Size 

func (m *IndexBuildState) XXX_Size() int

func (*IndexBuildState) XXX_Unmarshal 

func (m *IndexBuildState) XXX_Unmarshal(b []byte) error

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

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

func (IndexBuildState_State) String 

func (x IndexBuildState_State) String() string

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"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

Keep session alive

func (*KeepAliveRequest) Descriptor 

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

func (*KeepAliveRequest) GetOperationParams 

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

func (*KeepAliveRequest) GetSessionId 

func (m *KeepAliveRequest) GetSessionId() string

func (*KeepAliveRequest) ProtoMessage 

func (*KeepAliveRequest) ProtoMessage()

func (*KeepAliveRequest) Reset 

func (m *KeepAliveRequest) Reset()

func (*KeepAliveRequest) SetOperationParams 

func (m *KeepAliveRequest) SetOperationParams(v *Ydb_Operations.OperationParams)

SetOperationParams implements ydb generic interface for setting operation parameters inside driver implementation.

func (*KeepAliveRequest) String 

func (m *KeepAliveRequest) String() string

func (*KeepAliveRequest) XXX_DiscardUnknown 

func (m *KeepAliveRequest) XXX_DiscardUnknown()

func (*KeepAliveRequest) XXX_Marshal 

func (m *KeepAliveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KeepAliveRequest) XXX_Merge 

func (m *KeepAliveRequest) XXX_Merge(src proto.Message)

func (*KeepAliveRequest) XXX_Size 

func (m *KeepAliveRequest) XXX_Size() int

func (*KeepAliveRequest) XXX_Unmarshal 

func (m *KeepAliveRequest) XXX_Unmarshal(b []byte) error

type KeepAliveResponse 

type KeepAliveResponse struct {
	Operation            *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*KeepAliveResponse) Descriptor 

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

func (*KeepAliveResponse) GetOperation 

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

func (*KeepAliveResponse) ProtoMessage 

func (*KeepAliveResponse) ProtoMessage()

func (*KeepAliveResponse) Reset 

func (m *KeepAliveResponse) Reset()

func (*KeepAliveResponse) String 

func (m *KeepAliveResponse) String() string

func (*KeepAliveResponse) XXX_DiscardUnknown 

func (m *KeepAliveResponse) XXX_DiscardUnknown()

func (*KeepAliveResponse) XXX_Marshal 

func (m *KeepAliveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KeepAliveResponse) XXX_Merge 

func (m *KeepAliveResponse) XXX_Merge(src proto.Message)

func (*KeepAliveResponse) XXX_Size 

func (m *KeepAliveResponse) XXX_Size() int

func (*KeepAliveResponse) XXX_Unmarshal 

func (m *KeepAliveResponse) XXX_Unmarshal(b []byte) error

type KeepAliveResult 

type KeepAliveResult struct {
	SessionStatus        KeepAliveResult_SessionStatus `` /* 146-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func (*KeepAliveResult) Descriptor 

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

func (*KeepAliveResult) GetSessionStatus 

func (m *KeepAliveResult) GetSessionStatus() KeepAliveResult_SessionStatus

func (*KeepAliveResult) ProtoMessage 

func (*KeepAliveResult) ProtoMessage()

func (*KeepAliveResult) Reset 

func (m *KeepAliveResult) Reset()

func (*KeepAliveResult) String 

func (m *KeepAliveResult) String() string

func (*KeepAliveResult) XXX_DiscardUnknown 

func (m *KeepAliveResult) XXX_DiscardUnknown()

func (*KeepAliveResult) XXX_Marshal 

func (m *KeepAliveResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KeepAliveResult) XXX_Merge 

func (m *KeepAliveResult) XXX_Merge(src proto.Message)

func (*KeepAliveResult) XXX_Size 

func (m *KeepAliveResult) XXX_Size() int

func (*KeepAliveResult) XXX_Unmarshal 

func (m *KeepAliveResult) XXX_Unmarshal(b []byte) error

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

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

func (KeepAliveResult_SessionStatus) String 

func (x KeepAliveResult_SessionStatus) String() string

type KeyRange 

type KeyRange struct {
	// Left border
	//
	// Types that are valid to be assigned to FromBound:
	//	*KeyRange_Greater
	//	*KeyRange_GreaterOrEqual
	FromBound isKeyRange_FromBound `protobuf_oneof:"from_bound"`
	// Right border
	//
	// Types that are valid to be assigned to ToBound:
	//	*KeyRange_Less
	//	*KeyRange_LessOrEqual
	ToBound              isKeyRange_ToBound `protobuf_oneof:"to_bound"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*KeyRange) Descriptor 

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

func (*KeyRange) GetFromBound 

func (m *KeyRange) GetFromBound() isKeyRange_FromBound

func (*KeyRange) GetGreater 

func (m *KeyRange) GetGreater() *Ydb.TypedValue

func (*KeyRange) GetGreaterOrEqual 

func (m *KeyRange) GetGreaterOrEqual() *Ydb.TypedValue

func (*KeyRange) GetLess 

func (m *KeyRange) GetLess() *Ydb.TypedValue

func (*KeyRange) GetLessOrEqual 

func (m *KeyRange) GetLessOrEqual() *Ydb.TypedValue

func (*KeyRange) GetToBound 

func (m *KeyRange) GetToBound() isKeyRange_ToBound

func (*KeyRange) ProtoMessage 

func (*KeyRange) ProtoMessage()

func (*KeyRange) Reset 

func (m *KeyRange) Reset()

func (*KeyRange) String 

func (m *KeyRange) String() string

func (*KeyRange) XXX_DiscardUnknown 

func (m *KeyRange) XXX_DiscardUnknown()

func (*KeyRange) XXX_Marshal 

func (m *KeyRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KeyRange) XXX_Merge 

func (m *KeyRange) XXX_Merge(src proto.Message)

func (*KeyRange) XXX_OneofWrappers 

func (*KeyRange) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*KeyRange) XXX_Size 

func (m *KeyRange) XXX_Size() int

func (*KeyRange) XXX_Unmarshal 

func (m *KeyRange) XXX_Unmarshal(b []byte) error

type KeyRange_Greater 

type KeyRange_Greater struct {
	Greater *Ydb.TypedValue `protobuf:"bytes,1,opt,name=greater,proto3,oneof"`
}

type KeyRange_GreaterOrEqual 

type KeyRange_GreaterOrEqual struct {
	GreaterOrEqual *Ydb.TypedValue `protobuf:"bytes,2,opt,name=greater_or_equal,json=greaterOrEqual,proto3,oneof"`
}

type KeyRange_Less 

type KeyRange_Less struct {
	Less *Ydb.TypedValue `protobuf:"bytes,3,opt,name=less,proto3,oneof"`
}

type KeyRange_LessOrEqual 

type KeyRange_LessOrEqual struct {
	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 */
	XXX_NoUnkeyedLiteral   struct{} `json:"-"`
	XXX_unrecognized       []byte   `json:"-"`
	XXX_sizecache          int32    `json:"-"`
}

func (*OnlineModeSettings) Descriptor 

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

func (*OnlineModeSettings) GetAllowInconsistentReads 

func (m *OnlineModeSettings) GetAllowInconsistentReads() bool

func (*OnlineModeSettings) ProtoMessage 

func (*OnlineModeSettings) ProtoMessage()

func (*OnlineModeSettings) Reset 

func (m *OnlineModeSettings) Reset()

func (*OnlineModeSettings) String 

func (m *OnlineModeSettings) String() string

func (*OnlineModeSettings) XXX_DiscardUnknown 

func (m *OnlineModeSettings) XXX_DiscardUnknown()

func (*OnlineModeSettings) XXX_Marshal 

func (m *OnlineModeSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OnlineModeSettings) XXX_Merge 

func (m *OnlineModeSettings) XXX_Merge(src proto.Message)

func (*OnlineModeSettings) XXX_Size 

func (m *OnlineModeSettings) XXX_Size() int

func (*OnlineModeSettings) XXX_Unmarshal 

func (m *OnlineModeSettings) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PartitionStats) Descriptor 

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

func (*PartitionStats) GetRowsEstimate 

func (m *PartitionStats) GetRowsEstimate() uint64

func (*PartitionStats) GetStoreSize 

func (m *PartitionStats) GetStoreSize() uint64

func (*PartitionStats) ProtoMessage 

func (*PartitionStats) ProtoMessage()

func (*PartitionStats) Reset 

func (m *PartitionStats) Reset()

func (*PartitionStats) String 

func (m *PartitionStats) String() string

func (*PartitionStats) XXX_DiscardUnknown 

func (m *PartitionStats) XXX_DiscardUnknown()

func (*PartitionStats) XXX_Marshal 

func (m *PartitionStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PartitionStats) XXX_Merge 

func (m *PartitionStats) XXX_Merge(src proto.Message)

func (*PartitionStats) XXX_Size 

func (m *PartitionStats) XXX_Size() int

func (*PartitionStats) XXX_Unmarshal 

func (m *PartitionStats) XXX_Unmarshal(b []byte) error

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 valid to be assigned to Partitions:
	//	*PartitioningPolicy_UniformPartitions
	//	*PartitioningPolicy_ExplicitPartitions
	Partitions           isPartitioningPolicy_Partitions `protobuf_oneof:"partitions"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*PartitioningPolicy) Descriptor 

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

func (*PartitioningPolicy) GetAutoPartitioning 

func (m *PartitioningPolicy) GetAutoPartitioning() PartitioningPolicy_AutoPartitioningPolicy

func (*PartitioningPolicy) GetExplicitPartitions 

func (m *PartitioningPolicy) GetExplicitPartitions() *ExplicitPartitions

func (*PartitioningPolicy) GetPartitions 

func (m *PartitioningPolicy) GetPartitions() isPartitioningPolicy_Partitions

func (*PartitioningPolicy) GetPresetName 

func (m *PartitioningPolicy) GetPresetName() string

func (*PartitioningPolicy) GetUniformPartitions 

func (m *PartitioningPolicy) GetUniformPartitions() uint64

func (*PartitioningPolicy) ProtoMessage 

func (*PartitioningPolicy) ProtoMessage()

func (*PartitioningPolicy) Reset 

func (m *PartitioningPolicy) Reset()

func (*PartitioningPolicy) String 

func (m *PartitioningPolicy) String() string

func (*PartitioningPolicy) XXX_DiscardUnknown 

func (m *PartitioningPolicy) XXX_DiscardUnknown()

func (*PartitioningPolicy) XXX_Marshal 

func (m *PartitioningPolicy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PartitioningPolicy) XXX_Merge 

func (m *PartitioningPolicy) XXX_Merge(src proto.Message)

func (*PartitioningPolicy) XXX_OneofWrappers 

func (*PartitioningPolicy) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*PartitioningPolicy) XXX_Size 

func (m *PartitioningPolicy) XXX_Size() int

func (*PartitioningPolicy) XXX_Unmarshal 

func (m *PartitioningPolicy) XXX_Unmarshal(b []byte) error

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 */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*PartitioningPolicyDescription) Descriptor 

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

func (*PartitioningPolicyDescription) GetLabels 

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

func (*PartitioningPolicyDescription) GetName 

func (m *PartitioningPolicyDescription) GetName() string

func (*PartitioningPolicyDescription) ProtoMessage 

func (*PartitioningPolicyDescription) ProtoMessage()

func (*PartitioningPolicyDescription) Reset 

func (m *PartitioningPolicyDescription) Reset()

func (*PartitioningPolicyDescription) String 

func (m *PartitioningPolicyDescription) String() string

func (*PartitioningPolicyDescription) XXX_DiscardUnknown 

func (m *PartitioningPolicyDescription) XXX_DiscardUnknown()

func (*PartitioningPolicyDescription) XXX_Marshal 

func (m *PartitioningPolicyDescription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PartitioningPolicyDescription) XXX_Merge 

func (m *PartitioningPolicyDescription) XXX_Merge(src proto.Message)

func (*PartitioningPolicyDescription) XXX_Size 

func (m *PartitioningPolicyDescription) XXX_Size() int

func (*PartitioningPolicyDescription) XXX_Unmarshal 

func (m *PartitioningPolicyDescription) XXX_Unmarshal(b []byte) error

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

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

func (PartitioningPolicy_AutoPartitioningPolicy) String 

func (x PartitioningPolicy_AutoPartitioningPolicy) String() string

type PartitioningPolicy_ExplicitPartitions 

type PartitioningPolicy_ExplicitPartitions struct {
	ExplicitPartitions *ExplicitPartitions `protobuf:"bytes,4,opt,name=explicit_partitions,json=explicitPartitions,proto3,oneof"`
}

type PartitioningPolicy_UniformPartitions 

type PartitioningPolicy_UniformPartitions struct {
	UniformPartitions uint64 `protobuf:"varint,3,opt,name=uniform_partitions,json=uniformPartitions,proto3,oneof"`
}

type PartitioningSettings 

type PartitioningSettings struct {
	// 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PartitioningSettings) Descriptor 

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

func (*PartitioningSettings) GetMaxPartitionsCount 

func (m *PartitioningSettings) GetMaxPartitionsCount() uint64

func (*PartitioningSettings) GetMinPartitionsCount 

func (m *PartitioningSettings) GetMinPartitionsCount() uint64

func (*PartitioningSettings) GetPartitionSizeMb 

func (m *PartitioningSettings) GetPartitionSizeMb() uint64

func (*PartitioningSettings) GetPartitioningByLoad 

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

func (*PartitioningSettings) GetPartitioningBySize 

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

func (*PartitioningSettings) ProtoMessage 

func (*PartitioningSettings) ProtoMessage()

func (*PartitioningSettings) Reset 

func (m *PartitioningSettings) Reset()

func (*PartitioningSettings) String 

func (m *PartitioningSettings) String() string

func (*PartitioningSettings) XXX_DiscardUnknown 

func (m *PartitioningSettings) XXX_DiscardUnknown()

func (*PartitioningSettings) XXX_Marshal 

func (m *PartitioningSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PartitioningSettings) XXX_Merge 

func (m *PartitioningSettings) XXX_Merge(src proto.Message)

func (*PartitioningSettings) XXX_Size 

func (m *PartitioningSettings) XXX_Size() int

func (*PartitioningSettings) XXX_Unmarshal 

func (m *PartitioningSettings) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

Prepare given program to execute

func (*PrepareDataQueryRequest) Descriptor 

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

func (*PrepareDataQueryRequest) GetOperationParams 

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

func (*PrepareDataQueryRequest) GetSessionId 

func (m *PrepareDataQueryRequest) GetSessionId() string

func (*PrepareDataQueryRequest) GetYqlText 

func (m *PrepareDataQueryRequest) GetYqlText() string

func (*PrepareDataQueryRequest) ProtoMessage 

func (*PrepareDataQueryRequest) ProtoMessage()

func (*PrepareDataQueryRequest) Reset 

func (m *PrepareDataQueryRequest) Reset()

func (*PrepareDataQueryRequest) SetOperationParams 

func (m *PrepareDataQueryRequest) SetOperationParams(v *Ydb_Operations.OperationParams)

SetOperationParams implements ydb generic interface for setting operation parameters inside driver implementation.

func (*PrepareDataQueryRequest) String 

func (m *PrepareDataQueryRequest) String() string

func (*PrepareDataQueryRequest) XXX_DiscardUnknown 

func (m *PrepareDataQueryRequest) XXX_DiscardUnknown()

func (*PrepareDataQueryRequest) XXX_Marshal 

func (m *PrepareDataQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrepareDataQueryRequest) XXX_Merge 

func (m *PrepareDataQueryRequest) XXX_Merge(src proto.Message)

func (*PrepareDataQueryRequest) XXX_Size 

func (m *PrepareDataQueryRequest) XXX_Size() int

func (*PrepareDataQueryRequest) XXX_Unmarshal 

func (m *PrepareDataQueryRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*PrepareDataQueryResponse) Descriptor 

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

func (*PrepareDataQueryResponse) GetOperation 

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

func (*PrepareDataQueryResponse) ProtoMessage 

func (*PrepareDataQueryResponse) ProtoMessage()

func (*PrepareDataQueryResponse) Reset 

func (m *PrepareDataQueryResponse) Reset()

func (*PrepareDataQueryResponse) String 

func (m *PrepareDataQueryResponse) String() string

func (*PrepareDataQueryResponse) XXX_DiscardUnknown 

func (m *PrepareDataQueryResponse) XXX_DiscardUnknown()

func (*PrepareDataQueryResponse) XXX_Marshal 

func (m *PrepareDataQueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrepareDataQueryResponse) XXX_Merge 

func (m *PrepareDataQueryResponse) XXX_Merge(src proto.Message)

func (*PrepareDataQueryResponse) XXX_Size 

func (m *PrepareDataQueryResponse) XXX_Size() int

func (*PrepareDataQueryResponse) XXX_Unmarshal 

func (m *PrepareDataQueryResponse) XXX_Unmarshal(b []byte) error

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 */
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*PrepareQueryResult) Descriptor 

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

func (*PrepareQueryResult) GetParametersTypes 

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

func (*PrepareQueryResult) GetQueryId 

func (m *PrepareQueryResult) GetQueryId() string

func (*PrepareQueryResult) ProtoMessage 

func (*PrepareQueryResult) ProtoMessage()

func (*PrepareQueryResult) Reset 

func (m *PrepareQueryResult) Reset()

func (*PrepareQueryResult) String 

func (m *PrepareQueryResult) String() string

func (*PrepareQueryResult) XXX_DiscardUnknown 

func (m *PrepareQueryResult) XXX_DiscardUnknown()

func (*PrepareQueryResult) XXX_Marshal 

func (m *PrepareQueryResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrepareQueryResult) XXX_Merge 

func (m *PrepareQueryResult) XXX_Merge(src proto.Message)

func (*PrepareQueryResult) XXX_Size 

func (m *PrepareQueryResult) XXX_Size() int

func (*PrepareQueryResult) XXX_Unmarshal 

func (m *PrepareQueryResult) XXX_Unmarshal(b []byte) error

type Query 

type Query struct {
	// Text of query or id prepared query
	//
	// Types that are valid to be assigned to Query:
	//	*Query_YqlText
	//	*Query_Id
	Query                isQuery_Query `protobuf_oneof:"query"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*Query) Descriptor 

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

func (*Query) GetId 

func (m *Query) GetId() string

func (*Query) GetQuery 

func (m *Query) GetQuery() isQuery_Query

func (*Query) GetYqlText 

func (m *Query) GetYqlText() string

func (*Query) ProtoMessage 

func (*Query) ProtoMessage()

func (*Query) Reset 

func (m *Query) Reset()

func (*Query) String 

func (m *Query) String() string

func (*Query) XXX_DiscardUnknown 

func (m *Query) XXX_DiscardUnknown()

func (*Query) XXX_Marshal 

func (m *Query) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Query) XXX_Merge 

func (m *Query) XXX_Merge(src proto.Message)

func (*Query) XXX_OneofWrappers 

func (*Query) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Query) XXX_Size 

func (m *Query) XXX_Size() int

func (*Query) XXX_Unmarshal 

func (m *Query) XXX_Unmarshal(b []byte) error

type QueryCachePolicy 

type QueryCachePolicy struct {
	KeepInCache          bool     `protobuf:"varint,1,opt,name=keep_in_cache,json=keepInCache,proto3" json:"keep_in_cache,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QueryCachePolicy) Descriptor 

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

func (*QueryCachePolicy) GetKeepInCache 

func (m *QueryCachePolicy) GetKeepInCache() bool

func (*QueryCachePolicy) ProtoMessage 

func (*QueryCachePolicy) ProtoMessage()

func (*QueryCachePolicy) Reset 

func (m *QueryCachePolicy) Reset()

func (*QueryCachePolicy) String 

func (m *QueryCachePolicy) String() string

func (*QueryCachePolicy) XXX_DiscardUnknown 

func (m *QueryCachePolicy) XXX_DiscardUnknown()

func (*QueryCachePolicy) XXX_Marshal 

func (m *QueryCachePolicy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryCachePolicy) XXX_Merge 

func (m *QueryCachePolicy) XXX_Merge(src proto.Message)

func (*QueryCachePolicy) XXX_Size 

func (m *QueryCachePolicy) XXX_Size() int

func (*QueryCachePolicy) XXX_Unmarshal 

func (m *QueryCachePolicy) XXX_Unmarshal(b []byte) error

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 */
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Holds query id and type of parameters

func (*QueryMeta) Descriptor 

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

func (*QueryMeta) GetId 

func (m *QueryMeta) GetId() string

func (*QueryMeta) GetParametersTypes 

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

func (*QueryMeta) ProtoMessage 

func (*QueryMeta) ProtoMessage()

func (*QueryMeta) Reset 

func (m *QueryMeta) Reset()

func (*QueryMeta) String 

func (m *QueryMeta) String() string

func (*QueryMeta) XXX_DiscardUnknown 

func (m *QueryMeta) XXX_DiscardUnknown()

func (*QueryMeta) XXX_Marshal 

func (m *QueryMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryMeta) XXX_Merge 

func (m *QueryMeta) XXX_Merge(src proto.Message)

func (*QueryMeta) XXX_Size 

func (m *QueryMeta) XXX_Size() int

func (*QueryMeta) XXX_Unmarshal 

func (m *QueryMeta) XXX_Unmarshal(b []byte) error

type QueryStatsCollection 

type QueryStatsCollection struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Collect and return query execution stats

func (*QueryStatsCollection) Descriptor 

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

func (*QueryStatsCollection) ProtoMessage 

func (*QueryStatsCollection) ProtoMessage()

func (*QueryStatsCollection) Reset 

func (m *QueryStatsCollection) Reset()

func (*QueryStatsCollection) String 

func (m *QueryStatsCollection) String() string

func (*QueryStatsCollection) XXX_DiscardUnknown 

func (m *QueryStatsCollection) XXX_DiscardUnknown()

func (*QueryStatsCollection) XXX_Marshal 

func (m *QueryStatsCollection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryStatsCollection) XXX_Merge 

func (m *QueryStatsCollection) XXX_Merge(src proto.Message)

func (*QueryStatsCollection) XXX_Size 

func (m *QueryStatsCollection) XXX_Size() int

func (*QueryStatsCollection) XXX_Unmarshal 

func (m *QueryStatsCollection) XXX_Unmarshal(b []byte) error

type QueryStatsCollection_Mode 

type QueryStatsCollection_Mode int32
const (
	QueryStatsCollection_STATS_COLLECTION_UNSPECIFIED QueryStatsCollection_Mode = 0
	QueryStatsCollection_STATS_COLLECTION_NONE        QueryStatsCollection_Mode = 1
	QueryStatsCollection_STATS_COLLECTION_BASIC       QueryStatsCollection_Mode = 2
	QueryStatsCollection_STATS_COLLECTION_FULL        QueryStatsCollection_Mode = 3
)

func (QueryStatsCollection_Mode) EnumDescriptor 

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

func (QueryStatsCollection_Mode) String 

func (x QueryStatsCollection_Mode) String() string

type Query_Id 

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

type Query_YqlText 

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

type ReadReplicasSettings 

type ReadReplicasSettings struct {
	// Types that are valid to be assigned to Settings:
	//	*ReadReplicasSettings_PerAzReadReplicasCount
	//	*ReadReplicasSettings_AnyAzReadReplicasCount
	Settings             isReadReplicasSettings_Settings `protobuf_oneof:"settings"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*ReadReplicasSettings) Descriptor 

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

func (*ReadReplicasSettings) GetAnyAzReadReplicasCount 

func (m *ReadReplicasSettings) GetAnyAzReadReplicasCount() uint64

func (*ReadReplicasSettings) GetPerAzReadReplicasCount 

func (m *ReadReplicasSettings) GetPerAzReadReplicasCount() uint64

func (*ReadReplicasSettings) GetSettings 

func (m *ReadReplicasSettings) GetSettings() isReadReplicasSettings_Settings

func (*ReadReplicasSettings) ProtoMessage 

func (*ReadReplicasSettings) ProtoMessage()

func (*ReadReplicasSettings) Reset 

func (m *ReadReplicasSettings) Reset()

func (*ReadReplicasSettings) String 

func (m *ReadReplicasSettings) String() string

func (*ReadReplicasSettings) XXX_DiscardUnknown 

func (m *ReadReplicasSettings) XXX_DiscardUnknown()

func (*ReadReplicasSettings) XXX_Marshal 

func (m *ReadReplicasSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadReplicasSettings) XXX_Merge 

func (m *ReadReplicasSettings) XXX_Merge(src proto.Message)

func (*ReadReplicasSettings) XXX_OneofWrappers 

func (*ReadReplicasSettings) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ReadReplicasSettings) XXX_Size 

func (m *ReadReplicasSettings) XXX_Size() int

func (*ReadReplicasSettings) XXX_Unmarshal 

func (m *ReadReplicasSettings) XXX_Unmarshal(b []byte) error

type ReadReplicasSettings_AnyAzReadReplicasCount 

type ReadReplicasSettings_AnyAzReadReplicasCount struct {
	AnyAzReadReplicasCount uint64 `protobuf:"varint,2,opt,name=any_az_read_replicas_count,json=anyAzReadReplicasCount,proto3,oneof"`
}

type ReadReplicasSettings_PerAzReadReplicasCount 

type ReadReplicasSettings_PerAzReadReplicasCount struct {
	PerAzReadReplicasCount uint64 `protobuf:"varint,1,opt,name=per_az_read_replicas_count,json=perAzReadReplicasCount,proto3,oneof"`
}

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"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

Request to read table (without SQL)

func (*ReadTableRequest) Descriptor 

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

func (*ReadTableRequest) GetColumns 

func (m *ReadTableRequest) GetColumns() []string

func (*ReadTableRequest) GetKeyRange 

func (m *ReadTableRequest) GetKeyRange() *KeyRange

func (*ReadTableRequest) GetOrdered 

func (m *ReadTableRequest) GetOrdered() bool

func (*ReadTableRequest) GetPath 

func (m *ReadTableRequest) GetPath() string

func (*ReadTableRequest) GetRowLimit 

func (m *ReadTableRequest) GetRowLimit() uint64

func (*ReadTableRequest) GetSessionId 

func (m *ReadTableRequest) GetSessionId() string

func (*ReadTableRequest) GetUseSnapshot 

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

func (*ReadTableRequest) ProtoMessage 

func (*ReadTableRequest) ProtoMessage()

func (*ReadTableRequest) Reset 

func (m *ReadTableRequest) Reset()

func (*ReadTableRequest) String 

func (m *ReadTableRequest) String() string

func (*ReadTableRequest) XXX_DiscardUnknown 

func (m *ReadTableRequest) XXX_DiscardUnknown()

func (*ReadTableRequest) XXX_Marshal 

func (m *ReadTableRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadTableRequest) XXX_Merge 

func (m *ReadTableRequest) XXX_Merge(src proto.Message)

func (*ReadTableRequest) XXX_Size 

func (m *ReadTableRequest) XXX_Size() int

func (*ReadTableRequest) XXX_Unmarshal 

func (m *ReadTableRequest) XXX_Unmarshal(b []byte) error

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"`
	// Read table result
	Result               *ReadTableResult `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

ReadTable doesn't use Operation, returns result directly

func (*ReadTableResponse) Descriptor 

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

func (*ReadTableResponse) GetIssues 

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

func (*ReadTableResponse) GetResult 

func (m *ReadTableResponse) GetResult() *ReadTableResult

func (*ReadTableResponse) GetStatus 

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

func (*ReadTableResponse) ProtoMessage 

func (*ReadTableResponse) ProtoMessage()

func (*ReadTableResponse) Reset 

func (m *ReadTableResponse) Reset()

func (*ReadTableResponse) String 

func (m *ReadTableResponse) String() string

func (*ReadTableResponse) XXX_DiscardUnknown 

func (m *ReadTableResponse) XXX_DiscardUnknown()

func (*ReadTableResponse) XXX_Marshal 

func (m *ReadTableResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadTableResponse) XXX_Merge 

func (m *ReadTableResponse) XXX_Merge(src proto.Message)

func (*ReadTableResponse) XXX_Size 

func (m *ReadTableResponse) XXX_Size() int

func (*ReadTableResponse) XXX_Unmarshal 

func (m *ReadTableResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

Result of read table request

func (*ReadTableResult) Descriptor 

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

func (*ReadTableResult) GetResultSet 

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

func (*ReadTableResult) ProtoMessage 

func (*ReadTableResult) ProtoMessage()

func (*ReadTableResult) Reset 

func (m *ReadTableResult) Reset()

func (*ReadTableResult) String 

func (m *ReadTableResult) String() string

func (*ReadTableResult) XXX_DiscardUnknown 

func (m *ReadTableResult) XXX_DiscardUnknown()

func (*ReadTableResult) XXX_Marshal 

func (m *ReadTableResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadTableResult) XXX_Merge 

func (m *ReadTableResult) XXX_Merge(src proto.Message)

func (*ReadTableResult) XXX_Size 

func (m *ReadTableResult) XXX_Size() int

func (*ReadTableResult) XXX_Unmarshal 

func (m *ReadTableResult) XXX_Unmarshal(b []byte) error

type RenameTableItem added in v2.4.1 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RenameTableItem) Descriptor added in v2.4.1 

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

func (*RenameTableItem) GetDestinationPath added in v2.4.1 

func (m *RenameTableItem) GetDestinationPath() string

func (*RenameTableItem) GetReplaceDestination added in v2.4.1 

func (m *RenameTableItem) GetReplaceDestination() bool

func (*RenameTableItem) GetSourcePath added in v2.4.1 

func (m *RenameTableItem) GetSourcePath() string

func (*RenameTableItem) ProtoMessage added in v2.4.1 

func (*RenameTableItem) ProtoMessage()

func (*RenameTableItem) Reset added in v2.4.1 

func (m *RenameTableItem) Reset()

func (*RenameTableItem) String added in v2.4.1 

func (m *RenameTableItem) String() string

func (*RenameTableItem) XXX_DiscardUnknown added in v2.4.1 

func (m *RenameTableItem) XXX_DiscardUnknown()

func (*RenameTableItem) XXX_Marshal added in v2.4.1 

func (m *RenameTableItem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RenameTableItem) XXX_Merge added in v2.4.1 

func (m *RenameTableItem) XXX_Merge(src proto.Message)

func (*RenameTableItem) XXX_Size added in v2.4.1 

func (m *RenameTableItem) XXX_Size() int

func (*RenameTableItem) XXX_Unmarshal added in v2.4.1 

func (m *RenameTableItem) XXX_Unmarshal(b []byte) error

type RenameTablesRequest added in v2.4.1 

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"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

Moves given tables

func (*RenameTablesRequest) Descriptor added in v2.4.1 

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

func (*RenameTablesRequest) GetOperationParams added in v2.4.1 

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

func (*RenameTablesRequest) GetSessionId added in v2.4.1 

func (m *RenameTablesRequest) GetSessionId() string

func (*RenameTablesRequest) GetTables added in v2.4.1 

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

func (*RenameTablesRequest) ProtoMessage added in v2.4.1 

func (*RenameTablesRequest) ProtoMessage()

func (*RenameTablesRequest) Reset added in v2.4.1 

func (m *RenameTablesRequest) Reset()

func (*RenameTablesRequest) SetOperationParams added in v2.4.1 

func (m *RenameTablesRequest) SetOperationParams(v *Ydb_Operations.OperationParams)

SetOperationParams implements ydb generic interface for setting operation parameters inside driver implementation.

func (*RenameTablesRequest) String added in v2.4.1 

func (m *RenameTablesRequest) String() string

func (*RenameTablesRequest) XXX_DiscardUnknown added in v2.4.1 

func (m *RenameTablesRequest) XXX_DiscardUnknown()

func (*RenameTablesRequest) XXX_Marshal added in v2.4.1 

func (m *RenameTablesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RenameTablesRequest) XXX_Merge added in v2.4.1 

func (m *RenameTablesRequest) XXX_Merge(src proto.Message)

func (*RenameTablesRequest) XXX_Size added in v2.4.1 

func (m *RenameTablesRequest) XXX_Size() int

func (*RenameTablesRequest) XXX_Unmarshal added in v2.4.1 

func (m *RenameTablesRequest) XXX_Unmarshal(b []byte) error

type RenameTablesResponse added in v2.4.1 

type RenameTablesResponse struct {
	Operation            *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*RenameTablesResponse) Descriptor added in v2.4.1 

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

func (*RenameTablesResponse) GetOperation added in v2.4.1 

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

func (*RenameTablesResponse) ProtoMessage added in v2.4.1 

func (*RenameTablesResponse) ProtoMessage()

func (*RenameTablesResponse) Reset added in v2.4.1 

func (m *RenameTablesResponse) Reset()

func (*RenameTablesResponse) String added in v2.4.1 

func (m *RenameTablesResponse) String() string

func (*RenameTablesResponse) XXX_DiscardUnknown added in v2.4.1 

func (m *RenameTablesResponse) XXX_DiscardUnknown()

func (*RenameTablesResponse) XXX_Marshal added in v2.4.1 

func (m *RenameTablesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RenameTablesResponse) XXX_Merge added in v2.4.1 

func (m *RenameTablesResponse) XXX_Merge(src proto.Message)

func (*RenameTablesResponse) XXX_Size added in v2.4.1 

func (m *RenameTablesResponse) XXX_Size() int

func (*RenameTablesResponse) XXX_Unmarshal added in v2.4.1 

func (m *RenameTablesResponse) XXX_Unmarshal(b []byte) error

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 */
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*ReplicationPolicy) Descriptor 

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

func (*ReplicationPolicy) GetAllowPromotion 

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

func (*ReplicationPolicy) GetCreatePerAvailabilityZone 

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

func (*ReplicationPolicy) GetPresetName 

func (m *ReplicationPolicy) GetPresetName() string

func (*ReplicationPolicy) GetReplicasCount 

func (m *ReplicationPolicy) GetReplicasCount() uint32

func (*ReplicationPolicy) ProtoMessage 

func (*ReplicationPolicy) ProtoMessage()

func (*ReplicationPolicy) Reset 

func (m *ReplicationPolicy) Reset()

func (*ReplicationPolicy) String 

func (m *ReplicationPolicy) String() string

func (*ReplicationPolicy) XXX_DiscardUnknown 

func (m *ReplicationPolicy) XXX_DiscardUnknown()

func (*ReplicationPolicy) XXX_Marshal 

func (m *ReplicationPolicy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplicationPolicy) XXX_Merge 

func (m *ReplicationPolicy) XXX_Merge(src proto.Message)

func (*ReplicationPolicy) XXX_Size 

func (m *ReplicationPolicy) XXX_Size() int

func (*ReplicationPolicy) XXX_Unmarshal 

func (m *ReplicationPolicy) XXX_Unmarshal(b []byte) error

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 */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ReplicationPolicyDescription) Descriptor 

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

func (*ReplicationPolicyDescription) GetLabels 

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

func (*ReplicationPolicyDescription) GetName 

func (m *ReplicationPolicyDescription) GetName() string

func (*ReplicationPolicyDescription) ProtoMessage 

func (*ReplicationPolicyDescription) ProtoMessage()

func (*ReplicationPolicyDescription) Reset 

func (m *ReplicationPolicyDescription) Reset()

func (*ReplicationPolicyDescription) String 

func (m *ReplicationPolicyDescription) String() string

func (*ReplicationPolicyDescription) XXX_DiscardUnknown 

func (m *ReplicationPolicyDescription) XXX_DiscardUnknown()

func (*ReplicationPolicyDescription) XXX_Marshal 

func (m *ReplicationPolicyDescription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplicationPolicyDescription) XXX_Merge 

func (m *ReplicationPolicyDescription) XXX_Merge(src proto.Message)

func (*ReplicationPolicyDescription) XXX_Size 

func (m *ReplicationPolicyDescription) XXX_Size() int

func (*ReplicationPolicyDescription) XXX_Unmarshal 

func (m *ReplicationPolicyDescription) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

Rollback transaction with given session and tx id

func (*RollbackTransactionRequest) Descriptor 

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

func (*RollbackTransactionRequest) GetOperationParams 

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

func (*RollbackTransactionRequest) GetSessionId 

func (m *RollbackTransactionRequest) GetSessionId() string

func (*RollbackTransactionRequest) GetTxId 

func (m *RollbackTransactionRequest) GetTxId() string

func (*RollbackTransactionRequest) ProtoMessage 

func (*RollbackTransactionRequest) ProtoMessage()

func (*RollbackTransactionRequest) Reset 

func (m *RollbackTransactionRequest) Reset()

func (*RollbackTransactionRequest) SetOperationParams 

func (m *RollbackTransactionRequest) SetOperationParams(v *Ydb_Operations.OperationParams)

SetOperationParams implements ydb generic interface for setting operation parameters inside driver implementation.

func (*RollbackTransactionRequest) String 

func (m *RollbackTransactionRequest) String() string

func (*RollbackTransactionRequest) XXX_DiscardUnknown 

func (m *RollbackTransactionRequest) XXX_DiscardUnknown()

func (*RollbackTransactionRequest) XXX_Marshal 

func (m *RollbackTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RollbackTransactionRequest) XXX_Merge 

func (m *RollbackTransactionRequest) XXX_Merge(src proto.Message)

func (*RollbackTransactionRequest) XXX_Size 

func (m *RollbackTransactionRequest) XXX_Size() int

func (*RollbackTransactionRequest) XXX_Unmarshal 

func (m *RollbackTransactionRequest) XXX_Unmarshal(b []byte) error

type RollbackTransactionResponse 

type RollbackTransactionResponse struct {
	Operation            *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*RollbackTransactionResponse) Descriptor 

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

func (*RollbackTransactionResponse) GetOperation 

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

func (*RollbackTransactionResponse) ProtoMessage 

func (*RollbackTransactionResponse) ProtoMessage()

func (*RollbackTransactionResponse) Reset 

func (m *RollbackTransactionResponse) Reset()

func (*RollbackTransactionResponse) String 

func (m *RollbackTransactionResponse) String() string

func (*RollbackTransactionResponse) XXX_DiscardUnknown 

func (m *RollbackTransactionResponse) XXX_DiscardUnknown()

func (*RollbackTransactionResponse) XXX_Marshal 

func (m *RollbackTransactionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RollbackTransactionResponse) XXX_Merge 

func (m *RollbackTransactionResponse) XXX_Merge(src proto.Message)

func (*RollbackTransactionResponse) XXX_Size 

func (m *RollbackTransactionResponse) XXX_Size() int

func (*RollbackTransactionResponse) XXX_Unmarshal 

func (m *RollbackTransactionResponse) XXX_Unmarshal(b []byte) error

type SerializableModeSettings 

type SerializableModeSettings struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SerializableModeSettings) Descriptor 

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

func (*SerializableModeSettings) ProtoMessage 

func (*SerializableModeSettings) ProtoMessage()

func (*SerializableModeSettings) Reset 

func (m *SerializableModeSettings) Reset()

func (*SerializableModeSettings) String 

func (m *SerializableModeSettings) String() string

func (*SerializableModeSettings) XXX_DiscardUnknown 

func (m *SerializableModeSettings) XXX_DiscardUnknown()

func (*SerializableModeSettings) XXX_Marshal 

func (m *SerializableModeSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SerializableModeSettings) XXX_Merge 

func (m *SerializableModeSettings) XXX_Merge(src proto.Message)

func (*SerializableModeSettings) XXX_Size 

func (m *SerializableModeSettings) XXX_Size() int

func (*SerializableModeSettings) XXX_Unmarshal 

func (m *SerializableModeSettings) XXX_Unmarshal(b []byte) error

type StaleModeSettings 

type StaleModeSettings struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StaleModeSettings) Descriptor 

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

func (*StaleModeSettings) ProtoMessage 

func (*StaleModeSettings) ProtoMessage()

func (*StaleModeSettings) Reset 

func (m *StaleModeSettings) Reset()

func (*StaleModeSettings) String 

func (m *StaleModeSettings) String() string

func (*StaleModeSettings) XXX_DiscardUnknown 

func (m *StaleModeSettings) XXX_DiscardUnknown()

func (*StaleModeSettings) XXX_Marshal 

func (m *StaleModeSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StaleModeSettings) XXX_Merge 

func (m *StaleModeSettings) XXX_Merge(src proto.Message)

func (*StaleModeSettings) XXX_Size 

func (m *StaleModeSettings) XXX_Size() int

func (*StaleModeSettings) XXX_Unmarshal 

func (m *StaleModeSettings) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*StoragePolicy) Descriptor 

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

func (*StoragePolicy) GetColumnFamilies 

func (m *StoragePolicy) GetColumnFamilies() []*ColumnFamilyPolicy

func (*StoragePolicy) GetData 

func (m *StoragePolicy) GetData() *StoragePool

func (*StoragePolicy) GetExternal 

func (m *StoragePolicy) GetExternal() *StoragePool

func (*StoragePolicy) GetKeepInMemory 

func (m *StoragePolicy) GetKeepInMemory() Ydb.FeatureFlag_Status

func (*StoragePolicy) GetLog 

func (m *StoragePolicy) GetLog() *StoragePool

func (*StoragePolicy) GetPresetName 

func (m *StoragePolicy) GetPresetName() string

func (*StoragePolicy) GetSyslog 

func (m *StoragePolicy) GetSyslog() *StoragePool

func (*StoragePolicy) ProtoMessage 

func (*StoragePolicy) ProtoMessage()

func (*StoragePolicy) Reset 

func (m *StoragePolicy) Reset()

func (*StoragePolicy) String 

func (m *StoragePolicy) String() string

func (*StoragePolicy) XXX_DiscardUnknown 

func (m *StoragePolicy) XXX_DiscardUnknown()

func (*StoragePolicy) XXX_Marshal 

func (m *StoragePolicy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StoragePolicy) XXX_Merge 

func (m *StoragePolicy) XXX_Merge(src proto.Message)

func (*StoragePolicy) XXX_Size 

func (m *StoragePolicy) XXX_Size() int

func (*StoragePolicy) XXX_Unmarshal 

func (m *StoragePolicy) XXX_Unmarshal(b []byte) error

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 */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*StoragePolicyDescription) Descriptor 

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

func (*StoragePolicyDescription) GetLabels 

func (m *StoragePolicyDescription) GetLabels() map[string]string

func (*StoragePolicyDescription) GetName 

func (m *StoragePolicyDescription) GetName() string

func (*StoragePolicyDescription) ProtoMessage 

func (*StoragePolicyDescription) ProtoMessage()

func (*StoragePolicyDescription) Reset 

func (m *StoragePolicyDescription) Reset()

func (*StoragePolicyDescription) String 

func (m *StoragePolicyDescription) String() string

func (*StoragePolicyDescription) XXX_DiscardUnknown 

func (m *StoragePolicyDescription) XXX_DiscardUnknown()

func (*StoragePolicyDescription) XXX_Marshal 

func (m *StoragePolicyDescription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StoragePolicyDescription) XXX_Merge 

func (m *StoragePolicyDescription) XXX_Merge(src proto.Message)

func (*StoragePolicyDescription) XXX_Size 

func (m *StoragePolicyDescription) XXX_Size() int

func (*StoragePolicyDescription) XXX_Unmarshal 

func (m *StoragePolicyDescription) XXX_Unmarshal(b []byte) error

type StoragePool 

type StoragePool struct {
	Media                string   `protobuf:"bytes,1,opt,name=media,proto3" json:"media,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StoragePool) Descriptor 

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

func (*StoragePool) GetMedia 

func (m *StoragePool) GetMedia() string

func (*StoragePool) ProtoMessage 

func (*StoragePool) ProtoMessage()

func (*StoragePool) Reset 

func (m *StoragePool) Reset()

func (*StoragePool) String 

func (m *StoragePool) String() string

func (*StoragePool) XXX_DiscardUnknown 

func (m *StoragePool) XXX_DiscardUnknown()

func (*StoragePool) XXX_Marshal 

func (m *StoragePool) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StoragePool) XXX_Merge 

func (m *StoragePool) XXX_Merge(src proto.Message)

func (*StoragePool) XXX_Size 

func (m *StoragePool) XXX_Size() int

func (*StoragePool) XXX_Unmarshal 

func (m *StoragePool) XXX_Unmarshal(b []byte) error

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"
	// Don't use unless required, 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 */
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*StorageSettings) Descriptor 

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

func (*StorageSettings) GetExternal 

func (m *StorageSettings) GetExternal() *StoragePool

func (*StorageSettings) GetStoreExternalBlobs 

func (m *StorageSettings) GetStoreExternalBlobs() Ydb.FeatureFlag_Status

func (*StorageSettings) GetTabletCommitLog0 

func (m *StorageSettings) GetTabletCommitLog0() *StoragePool

func (*StorageSettings) GetTabletCommitLog1 

func (m *StorageSettings) GetTabletCommitLog1() *StoragePool

func (*StorageSettings) ProtoMessage 

func (*StorageSettings) ProtoMessage()

func (*StorageSettings) Reset 

func (m *StorageSettings) Reset()

func (*StorageSettings) String 

func (m *StorageSettings) String() string

func (*StorageSettings) XXX_DiscardUnknown 

func (m *StorageSettings) XXX_DiscardUnknown()

func (*StorageSettings) XXX_Marshal 

func (m *StorageSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StorageSettings) XXX_Merge 

func (m *StorageSettings) XXX_Merge(src proto.Message)

func (*StorageSettings) XXX_Size 

func (m *StorageSettings) XXX_Size() int

func (*StorageSettings) XXX_Unmarshal 

func (m *StorageSettings) XXX_Unmarshal(b []byte) error

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 valid to be assigned 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Represent secondary index

func (*TableIndex) Descriptor 

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

func (*TableIndex) GetDataColumns 

func (m *TableIndex) GetDataColumns() []string

func (*TableIndex) GetGlobalAsyncIndex 

func (m *TableIndex) GetGlobalAsyncIndex() *GlobalAsyncIndex

func (*TableIndex) GetGlobalIndex 

func (m *TableIndex) GetGlobalIndex() *GlobalIndex

func (*TableIndex) GetIndexColumns 

func (m *TableIndex) GetIndexColumns() []string

func (*TableIndex) GetName 

func (m *TableIndex) GetName() string

func (*TableIndex) GetType 

func (m *TableIndex) GetType() isTableIndex_Type

func (*TableIndex) ProtoMessage 

func (*TableIndex) ProtoMessage()

func (*TableIndex) Reset 

func (m *TableIndex) Reset()

func (*TableIndex) String 

func (m *TableIndex) String() string

func (*TableIndex) XXX_DiscardUnknown 

func (m *TableIndex) XXX_DiscardUnknown()

func (*TableIndex) XXX_Marshal 

func (m *TableIndex) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TableIndex) XXX_Merge 

func (m *TableIndex) XXX_Merge(src proto.Message)

func (*TableIndex) XXX_OneofWrappers 

func (*TableIndex) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*TableIndex) XXX_Size 

func (m *TableIndex) XXX_Size() int

func (*TableIndex) XXX_Unmarshal 

func (m *TableIndex) XXX_Unmarshal(b []byte) error

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 valid to be assigned 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Represent secondary index with index state

func (*TableIndexDescription) Descriptor 

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

func (*TableIndexDescription) GetDataColumns 

func (m *TableIndexDescription) GetDataColumns() []string

func (*TableIndexDescription) GetGlobalAsyncIndex 

func (m *TableIndexDescription) GetGlobalAsyncIndex() *GlobalAsyncIndex

func (*TableIndexDescription) GetGlobalIndex 

func (m *TableIndexDescription) GetGlobalIndex() *GlobalIndex

func (*TableIndexDescription) GetIndexColumns 

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

func (*TableIndexDescription) GetName 

func (m *TableIndexDescription) GetName() string

func (*TableIndexDescription) GetSizeBytes added in v2.7.0 

func (m *TableIndexDescription) GetSizeBytes() uint64

func (*TableIndexDescription) GetStatus 

func (m *TableIndexDescription) GetStatus() TableIndexDescription_Status

func (*TableIndexDescription) GetType 

func (m *TableIndexDescription) GetType() isTableIndexDescription_Type

func (*TableIndexDescription) ProtoMessage 

func (*TableIndexDescription) ProtoMessage()

func (*TableIndexDescription) Reset 

func (m *TableIndexDescription) Reset()

func (*TableIndexDescription) String 

func (m *TableIndexDescription) String() string

func (*TableIndexDescription) XXX_DiscardUnknown 

func (m *TableIndexDescription) XXX_DiscardUnknown()

func (*TableIndexDescription) XXX_Marshal 

func (m *TableIndexDescription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TableIndexDescription) XXX_Merge 

func (m *TableIndexDescription) XXX_Merge(src proto.Message)

func (*TableIndexDescription) XXX_OneofWrappers 

func (*TableIndexDescription) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*TableIndexDescription) XXX_Size 

func (m *TableIndexDescription) XXX_Size() int

func (*TableIndexDescription) XXX_Unmarshal 

func (m *TableIndexDescription) XXX_Unmarshal(b []byte) error

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

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

func (TableIndexDescription_Status) String 

func (x TableIndexDescription_Status) String() string

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"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*TableProfile) Descriptor 

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

func (*TableProfile) GetCachingPolicy 

func (m *TableProfile) GetCachingPolicy() *CachingPolicy

func (*TableProfile) GetCompactionPolicy 

func (m *TableProfile) GetCompactionPolicy() *CompactionPolicy

func (*TableProfile) GetExecutionPolicy 

func (m *TableProfile) GetExecutionPolicy() *ExecutionPolicy

func (*TableProfile) GetPartitioningPolicy 

func (m *TableProfile) GetPartitioningPolicy() *PartitioningPolicy

func (*TableProfile) GetPresetName 

func (m *TableProfile) GetPresetName() string

func (*TableProfile) GetReplicationPolicy 

func (m *TableProfile) GetReplicationPolicy() *ReplicationPolicy

func (*TableProfile) GetStoragePolicy 

func (m *TableProfile) GetStoragePolicy() *StoragePolicy

func (*TableProfile) ProtoMessage 

func (*TableProfile) ProtoMessage()

func (*TableProfile) Reset 

func (m *TableProfile) Reset()

func (*TableProfile) String 

func (m *TableProfile) String() string

func (*TableProfile) XXX_DiscardUnknown 

func (m *TableProfile) XXX_DiscardUnknown()

func (*TableProfile) XXX_Marshal 

func (m *TableProfile) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TableProfile) XXX_Merge 

func (m *TableProfile) XXX_Merge(src proto.Message)

func (*TableProfile) XXX_Size 

func (m *TableProfile) XXX_Size() int

func (*TableProfile) XXX_Unmarshal 

func (m *TableProfile) XXX_Unmarshal(b []byte) error

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 */
	XXX_NoUnkeyedLiteral        struct{}          `json:"-"`
	XXX_unrecognized            []byte            `json:"-"`
	XXX_sizecache               int32             `json:"-"`
}

func (*TableProfileDescription) Descriptor 

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

func (*TableProfileDescription) GetAllowedCachingPolicies 

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

func (*TableProfileDescription) GetAllowedCompactionPolicies 

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

func (*TableProfileDescription) GetAllowedExecutionPolicies 

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

func (*TableProfileDescription) GetAllowedPartitioningPolicies 

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

func (*TableProfileDescription) GetAllowedReplicationPolicies 

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

func (*TableProfileDescription) GetAllowedStoragePolicies 

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

func (*TableProfileDescription) GetDefaultCachingPolicy 

func (m *TableProfileDescription) GetDefaultCachingPolicy() string

func (*TableProfileDescription) GetDefaultCompactionPolicy 

func (m *TableProfileDescription) GetDefaultCompactionPolicy() string

func (*TableProfileDescription) GetDefaultExecutionPolicy 

func (m *TableProfileDescription) GetDefaultExecutionPolicy() string

func (*TableProfileDescription) GetDefaultPartitioningPolicy 

func (m *TableProfileDescription) GetDefaultPartitioningPolicy() string

func (*TableProfileDescription) GetDefaultReplicationPolicy 

func (m *TableProfileDescription) GetDefaultReplicationPolicy() string

func (*TableProfileDescription) GetDefaultStoragePolicy 

func (m *TableProfileDescription) GetDefaultStoragePolicy() string

func (*TableProfileDescription) GetLabels 

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

func (*TableProfileDescription) GetName 

func (m *TableProfileDescription) GetName() string

func (*TableProfileDescription) ProtoMessage 

func (*TableProfileDescription) ProtoMessage()

func (*TableProfileDescription) Reset 

func (m *TableProfileDescription) Reset()

func (*TableProfileDescription) String 

func (m *TableProfileDescription) String() string

func (*TableProfileDescription) XXX_DiscardUnknown 

func (m *TableProfileDescription) XXX_DiscardUnknown()

func (*TableProfileDescription) XXX_Marshal 

func (m *TableProfileDescription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TableProfileDescription) XXX_Merge 

func (m *TableProfileDescription) XXX_Merge(src proto.Message)

func (*TableProfileDescription) XXX_Size 

func (m *TableProfileDescription) XXX_Size() int

func (*TableProfileDescription) XXX_Unmarshal 

func (m *TableProfileDescription) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*TableStats) Descriptor 

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

func (*TableStats) GetCreationTime 

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

func (*TableStats) GetModificationTime 

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

func (*TableStats) GetPartitionStats 

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

func (*TableStats) GetPartitions 

func (m *TableStats) GetPartitions() uint64

func (*TableStats) GetRowsEstimate 

func (m *TableStats) GetRowsEstimate() uint64

func (*TableStats) GetStoreSize 

func (m *TableStats) GetStoreSize() uint64

func (*TableStats) ProtoMessage 

func (*TableStats) ProtoMessage()

func (*TableStats) Reset 

func (m *TableStats) Reset()

func (*TableStats) String 

func (m *TableStats) String() string

func (*TableStats) XXX_DiscardUnknown 

func (m *TableStats) XXX_DiscardUnknown()

func (*TableStats) XXX_Marshal 

func (m *TableStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TableStats) XXX_Merge 

func (m *TableStats) XXX_Merge(src proto.Message)

func (*TableStats) XXX_Size 

func (m *TableStats) XXX_Size() int

func (*TableStats) XXX_Unmarshal 

func (m *TableStats) XXX_Unmarshal(b []byte) error

type TransactionControl 

type TransactionControl struct {
	// Types that are valid to be assigned 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"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*TransactionControl) Descriptor 

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

func (*TransactionControl) GetBeginTx 

func (m *TransactionControl) GetBeginTx() *TransactionSettings

func (*TransactionControl) GetCommitTx 

func (m *TransactionControl) GetCommitTx() bool

func (*TransactionControl) GetTxId 

func (m *TransactionControl) GetTxId() string

func (*TransactionControl) GetTxSelector 

func (m *TransactionControl) GetTxSelector() isTransactionControl_TxSelector

func (*TransactionControl) ProtoMessage 

func (*TransactionControl) ProtoMessage()

func (*TransactionControl) Reset 

func (m *TransactionControl) Reset()

func (*TransactionControl) String 

func (m *TransactionControl) String() string

func (*TransactionControl) XXX_DiscardUnknown 

func (m *TransactionControl) XXX_DiscardUnknown()

func (*TransactionControl) XXX_Marshal 

func (m *TransactionControl) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TransactionControl) XXX_Merge 

func (m *TransactionControl) XXX_Merge(src proto.Message)

func (*TransactionControl) XXX_OneofWrappers 

func (*TransactionControl) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*TransactionControl) XXX_Size 

func (m *TransactionControl) XXX_Size() int

func (*TransactionControl) XXX_Unmarshal 

func (m *TransactionControl) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Holds transaction id

func (*TransactionMeta) Descriptor 

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

func (*TransactionMeta) GetId 

func (m *TransactionMeta) GetId() string

func (*TransactionMeta) ProtoMessage 

func (*TransactionMeta) ProtoMessage()

func (*TransactionMeta) Reset 

func (m *TransactionMeta) Reset()

func (*TransactionMeta) String 

func (m *TransactionMeta) String() string

func (*TransactionMeta) XXX_DiscardUnknown 

func (m *TransactionMeta) XXX_DiscardUnknown()

func (*TransactionMeta) XXX_Marshal 

func (m *TransactionMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TransactionMeta) XXX_Merge 

func (m *TransactionMeta) XXX_Merge(src proto.Message)

func (*TransactionMeta) XXX_Size 

func (m *TransactionMeta) XXX_Size() int

func (*TransactionMeta) XXX_Unmarshal 

func (m *TransactionMeta) XXX_Unmarshal(b []byte) error

type TransactionSettings 

type TransactionSettings struct {
	// Types that are valid to be assigned to TxMode:
	//	*TransactionSettings_SerializableReadWrite
	//	*TransactionSettings_OnlineReadOnly
	//	*TransactionSettings_StaleReadOnly
	TxMode               isTransactionSettings_TxMode `protobuf_oneof:"tx_mode"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*TransactionSettings) Descriptor 

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

func (*TransactionSettings) GetOnlineReadOnly 

func (m *TransactionSettings) GetOnlineReadOnly() *OnlineModeSettings

func (*TransactionSettings) GetSerializableReadWrite 

func (m *TransactionSettings) GetSerializableReadWrite() *SerializableModeSettings

func (*TransactionSettings) GetStaleReadOnly 

func (m *TransactionSettings) GetStaleReadOnly() *StaleModeSettings

func (*TransactionSettings) GetTxMode 

func (m *TransactionSettings) GetTxMode() isTransactionSettings_TxMode

func (*TransactionSettings) ProtoMessage 

func (*TransactionSettings) ProtoMessage()

func (*TransactionSettings) Reset 

func (m *TransactionSettings) Reset()

func (*TransactionSettings) String 

func (m *TransactionSettings) String() string

func (*TransactionSettings) XXX_DiscardUnknown 

func (m *TransactionSettings) XXX_DiscardUnknown()

func (*TransactionSettings) XXX_Marshal 

func (m *TransactionSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TransactionSettings) XXX_Merge 

func (m *TransactionSettings) XXX_Merge(src proto.Message)

func (*TransactionSettings) XXX_OneofWrappers 

func (*TransactionSettings) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*TransactionSettings) XXX_Size 

func (m *TransactionSettings) XXX_Size() int

func (*TransactionSettings) XXX_Unmarshal 

func (m *TransactionSettings) XXX_Unmarshal(b []byte) error

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_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 valid to be assigned 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TtlSettings) Descriptor 

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

func (*TtlSettings) GetDateTypeColumn 

func (m *TtlSettings) GetDateTypeColumn() *DateTypeColumnModeSettings

func (*TtlSettings) GetMode 

func (m *TtlSettings) GetMode() isTtlSettings_Mode

func (*TtlSettings) GetRunIntervalSeconds added in v2.9.3 

func (m *TtlSettings) GetRunIntervalSeconds() uint32

func (*TtlSettings) GetValueSinceUnixEpoch 

func (m *TtlSettings) GetValueSinceUnixEpoch() *ValueSinceUnixEpochModeSettings

func (*TtlSettings) ProtoMessage 

func (*TtlSettings) ProtoMessage()

func (*TtlSettings) Reset 

func (m *TtlSettings) Reset()

func (*TtlSettings) String 

func (m *TtlSettings) String() string

func (*TtlSettings) XXX_DiscardUnknown 

func (m *TtlSettings) XXX_DiscardUnknown()

func (*TtlSettings) XXX_Marshal 

func (m *TtlSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TtlSettings) XXX_Merge 

func (m *TtlSettings) XXX_Merge(src proto.Message)

func (*TtlSettings) XXX_OneofWrappers 

func (*TtlSettings) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*TtlSettings) XXX_Size 

func (m *TtlSettings) XXX_Size() int

func (*TtlSettings) XXX_Unmarshal 

func (m *TtlSettings) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ValueSinceUnixEpochModeSettings) Descriptor 

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

func (*ValueSinceUnixEpochModeSettings) GetColumnName 

func (m *ValueSinceUnixEpochModeSettings) GetColumnName() string

func (*ValueSinceUnixEpochModeSettings) GetColumnUnit 

func (m *ValueSinceUnixEpochModeSettings) GetColumnUnit() ValueSinceUnixEpochModeSettings_Unit

func (*ValueSinceUnixEpochModeSettings) GetExpireAfterSeconds 

func (m *ValueSinceUnixEpochModeSettings) GetExpireAfterSeconds() uint32

func (*ValueSinceUnixEpochModeSettings) ProtoMessage 

func (*ValueSinceUnixEpochModeSettings) ProtoMessage()

func (*ValueSinceUnixEpochModeSettings) Reset 

func (m *ValueSinceUnixEpochModeSettings) Reset()

func (*ValueSinceUnixEpochModeSettings) String 

func (m *ValueSinceUnixEpochModeSettings) String() string

func (*ValueSinceUnixEpochModeSettings) XXX_DiscardUnknown 

func (m *ValueSinceUnixEpochModeSettings) XXX_DiscardUnknown()

func (*ValueSinceUnixEpochModeSettings) XXX_Marshal 

func (m *ValueSinceUnixEpochModeSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ValueSinceUnixEpochModeSettings) XXX_Merge 

func (m *ValueSinceUnixEpochModeSettings) XXX_Merge(src proto.Message)

func (*ValueSinceUnixEpochModeSettings) XXX_Size 

func (m *ValueSinceUnixEpochModeSettings) XXX_Size() int

func (*ValueSinceUnixEpochModeSettings) XXX_Unmarshal 

func (m *ValueSinceUnixEpochModeSettings) XXX_Unmarshal(b []byte) error

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

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

func (ValueSinceUnixEpochModeSettings_Unit) String 

func (x ValueSinceUnixEpochModeSettings_Unit) String() string

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.