Ydb_KeyValue

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

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	StorageChannelInfo_StatusFlag_name = map[int32]string{
		0:  "STATUS_FLAG_UNSPECIFIED",
		10: "STATUS_FLAG_GREEN",
		20: "STATUS_FLAG_YELLOW_STOP",
		30: "STATUS_FLAG_ORANGE_OUT_SPACE",
	}
	StorageChannelInfo_StatusFlag_value = map[string]int32{
		"STATUS_FLAG_UNSPECIFIED":      0,
		"STATUS_FLAG_GREEN":            10,
		"STATUS_FLAG_YELLOW_STOP":      20,
		"STATUS_FLAG_ORANGE_OUT_SPACE": 30,
	}
)

Enum value maps for StorageChannelInfo_StatusFlag.

View Source 
var (
	Priorities_Priority_name = map[int32]string{
		0: "PRIORITY_UNSPECIFIED",
		1: "PRIORITY_REALTIME",
		2: "PRIORITY_BACKGROUND",
	}
	Priorities_Priority_value = map[string]int32{
		"PRIORITY_UNSPECIFIED": 0,
		"PRIORITY_REALTIME":    1,
		"PRIORITY_BACKGROUND":  2,
	}
)

Enum value maps for Priorities_Priority.

View Source 
var (
	ExecuteTransactionRequest_Command_Write_Tactic_name = map[int32]string{
		0: "TACTIC_UNSPECIFIED",
		1: "TACTIC_MAX_THROUGHPUT",
		2: "TACTIC_MIN_LATENCY",
	}
	ExecuteTransactionRequest_Command_Write_Tactic_value = map[string]int32{
		"TACTIC_UNSPECIFIED":    0,
		"TACTIC_MAX_THROUGHPUT": 1,
		"TACTIC_MIN_LATENCY":    2,
	}
)

Enum value maps for ExecuteTransactionRequest_Command_Write_Tactic.

View Source 
var File_draft_protos_ydb_keyvalue_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AcquireLockRequest 

type AcquireLockRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// Volume path.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// Partition of the volume.
	PartitionId uint64 `protobuf:"varint,3,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	// contains filtered or unexported fields
}

The lock mechanism provides a way to ensure that only one client holds the lock. The client is provided the lock generation. Only operations with matching lock generation and operations with no lock generation are executed. When lock generation is missmatched operations will be failed with PRECONDITION_FAILED status.

func (*AcquireLockRequest) Descriptor deprecated 

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

Deprecated: Use AcquireLockRequest.ProtoReflect.Descriptor instead.

func (*AcquireLockRequest) GetOperationParams 

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

func (*AcquireLockRequest) GetPartitionId 

func (x *AcquireLockRequest) GetPartitionId() uint64

func (*AcquireLockRequest) GetPath 

func (x *AcquireLockRequest) GetPath() string

func (*AcquireLockRequest) ProtoMessage 

func (*AcquireLockRequest) ProtoMessage()

func (*AcquireLockRequest) ProtoReflect 

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

func (*AcquireLockRequest) Reset 

func (x *AcquireLockRequest) Reset()

func (*AcquireLockRequest) String 

func (x *AcquireLockRequest) String() string

type AcquireLockResponse 

type AcquireLockResponse struct {

	// Operation contains the result of the request. Check the ydb_operation.proto.
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*AcquireLockResponse) Descriptor deprecated 

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

Deprecated: Use AcquireLockResponse.ProtoReflect.Descriptor instead.

func (*AcquireLockResponse) GetOperation 

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

func (*AcquireLockResponse) ProtoMessage 

func (*AcquireLockResponse) ProtoMessage()

func (*AcquireLockResponse) ProtoReflect 

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

func (*AcquireLockResponse) Reset 

func (x *AcquireLockResponse) Reset()

func (*AcquireLockResponse) String 

func (x *AcquireLockResponse) String() string

type AcquireLockResult 

type AcquireLockResult struct {

	// The generation of the lock to provide as an argument to all the operations the user performs with the partition.
	LockGeneration uint64 `protobuf:"varint,1,opt,name=lock_generation,json=lockGeneration,proto3" json:"lock_generation,omitempty"`
	// Contains 0 if the request was sent to the node of the partition, node ID of the partition otherwise.
	NodeId uint32 `protobuf:"varint,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// contains filtered or unexported fields
}

func (*AcquireLockResult) Descriptor deprecated 

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

Deprecated: Use AcquireLockResult.ProtoReflect.Descriptor instead.

func (*AcquireLockResult) GetLockGeneration 

func (x *AcquireLockResult) GetLockGeneration() uint64

func (*AcquireLockResult) GetNodeId 

func (x *AcquireLockResult) GetNodeId() uint32

func (*AcquireLockResult) ProtoMessage 

func (*AcquireLockResult) ProtoMessage()

func (*AcquireLockResult) ProtoReflect 

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

func (*AcquireLockResult) Reset 

func (x *AcquireLockResult) Reset()

func (*AcquireLockResult) String 

func (x *AcquireLockResult) String() string

type AlterVolumeRequest 

type AlterVolumeRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// Volume path.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// Change the partition count of the volume.
	// The value should be greater or equal than current patition count.
	AlterPartitionCount uint32 `protobuf:"varint,3,opt,name=alter_partition_count,json=alterPartitionCount,proto3" json:"alter_partition_count,omitempty"`
	// Set storage kinds for storage channels.
	// If the field is not present, storage channel settings are not changed.
	StorageConfig *StorageConfig `protobuf:"bytes,4,opt,name=storage_config,json=storageConfig,proto3" json:"storage_config,omitempty"`
	// contains filtered or unexported fields
}

func (*AlterVolumeRequest) Descriptor deprecated 

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

Deprecated: Use AlterVolumeRequest.ProtoReflect.Descriptor instead.

func (*AlterVolumeRequest) GetAlterPartitionCount 

func (x *AlterVolumeRequest) GetAlterPartitionCount() uint32

func (*AlterVolumeRequest) GetOperationParams 

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

func (*AlterVolumeRequest) GetPath 

func (x *AlterVolumeRequest) GetPath() string

func (*AlterVolumeRequest) GetStorageConfig 

func (x *AlterVolumeRequest) GetStorageConfig() *StorageConfig

func (*AlterVolumeRequest) ProtoMessage 

func (*AlterVolumeRequest) ProtoMessage()

func (*AlterVolumeRequest) ProtoReflect 

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

func (*AlterVolumeRequest) Reset 

func (x *AlterVolumeRequest) Reset()

func (*AlterVolumeRequest) String 

func (x *AlterVolumeRequest) String() string

type AlterVolumeResponse 

type AlterVolumeResponse struct {

	// Operation contains the result of the request. Check the ydb_operation.proto.
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*AlterVolumeResponse) Descriptor deprecated 

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

Deprecated: Use AlterVolumeResponse.ProtoReflect.Descriptor instead.

func (*AlterVolumeResponse) GetOperation 

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

func (*AlterVolumeResponse) ProtoMessage 

func (*AlterVolumeResponse) ProtoMessage()

func (*AlterVolumeResponse) ProtoReflect 

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

func (*AlterVolumeResponse) Reset 

func (x *AlterVolumeResponse) Reset()

func (*AlterVolumeResponse) String 

func (x *AlterVolumeResponse) String() string

type AlterVolumeResult 

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

func (*AlterVolumeResult) Descriptor deprecated 

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

Deprecated: Use AlterVolumeResult.ProtoReflect.Descriptor instead.

func (*AlterVolumeResult) ProtoMessage 

func (*AlterVolumeResult) ProtoMessage()

func (*AlterVolumeResult) ProtoReflect 

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

func (*AlterVolumeResult) Reset 

func (x *AlterVolumeResult) Reset()

func (*AlterVolumeResult) String 

func (x *AlterVolumeResult) String() string

type CreateVolumeRequest 

type CreateVolumeRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// Volume path.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// The partition count of the new volume.
	PartitionCount uint32 `protobuf:"varint,4,opt,name=partition_count,json=partitionCount,proto3" json:"partition_count,omitempty"`
	// Set storage kinds for storage channels.
	StorageConfig *StorageConfig `protobuf:"bytes,5,opt,name=storage_config,json=storageConfig,proto3" json:"storage_config,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateVolumeRequest) Descriptor deprecated 

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

Deprecated: Use CreateVolumeRequest.ProtoReflect.Descriptor instead.

func (*CreateVolumeRequest) GetOperationParams 

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

func (*CreateVolumeRequest) GetPartitionCount 

func (x *CreateVolumeRequest) GetPartitionCount() uint32

func (*CreateVolumeRequest) GetPath 

func (x *CreateVolumeRequest) GetPath() string

func (*CreateVolumeRequest) GetStorageConfig 

func (x *CreateVolumeRequest) GetStorageConfig() *StorageConfig

func (*CreateVolumeRequest) ProtoMessage 

func (*CreateVolumeRequest) ProtoMessage()

func (*CreateVolumeRequest) ProtoReflect 

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

func (*CreateVolumeRequest) Reset 

func (x *CreateVolumeRequest) Reset()

func (*CreateVolumeRequest) String 

func (x *CreateVolumeRequest) String() string

type CreateVolumeResponse 

type CreateVolumeResponse struct {

	// Operation contains the result of the request. Check the ydb_operation.proto.
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateVolumeResponse) Descriptor deprecated 

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

Deprecated: Use CreateVolumeResponse.ProtoReflect.Descriptor instead.

func (*CreateVolumeResponse) GetOperation 

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

func (*CreateVolumeResponse) ProtoMessage 

func (*CreateVolumeResponse) ProtoMessage()

func (*CreateVolumeResponse) ProtoReflect 

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

func (*CreateVolumeResponse) Reset 

func (x *CreateVolumeResponse) Reset()

func (*CreateVolumeResponse) String 

func (x *CreateVolumeResponse) String() string

type CreateVolumeResult 

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

func (*CreateVolumeResult) Descriptor deprecated 

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

Deprecated: Use CreateVolumeResult.ProtoReflect.Descriptor instead.

func (*CreateVolumeResult) ProtoMessage 

func (*CreateVolumeResult) ProtoMessage()

func (*CreateVolumeResult) ProtoReflect 

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

func (*CreateVolumeResult) Reset 

func (x *CreateVolumeResult) Reset()

func (*CreateVolumeResult) String 

func (x *CreateVolumeResult) String() string

type DescribeVolumeRequest 

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

func (*DescribeVolumeRequest) Descriptor deprecated 

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

Deprecated: Use DescribeVolumeRequest.ProtoReflect.Descriptor instead.

func (*DescribeVolumeRequest) GetOperationParams 

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

func (*DescribeVolumeRequest) GetPath 

func (x *DescribeVolumeRequest) GetPath() string

func (*DescribeVolumeRequest) ProtoMessage 

func (*DescribeVolumeRequest) ProtoMessage()

func (*DescribeVolumeRequest) ProtoReflect 

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

func (*DescribeVolumeRequest) Reset 

func (x *DescribeVolumeRequest) Reset()

func (*DescribeVolumeRequest) String 

func (x *DescribeVolumeRequest) String() string

type DescribeVolumeResponse 

type DescribeVolumeResponse struct {

	// Operation contains the result of the request. Check the ydb_operation.proto.
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeVolumeResponse) Descriptor deprecated 

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

Deprecated: Use DescribeVolumeResponse.ProtoReflect.Descriptor instead.

func (*DescribeVolumeResponse) GetOperation 

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

func (*DescribeVolumeResponse) ProtoMessage 

func (*DescribeVolumeResponse) ProtoMessage()

func (*DescribeVolumeResponse) ProtoReflect 

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

func (*DescribeVolumeResponse) Reset 

func (x *DescribeVolumeResponse) Reset()

func (*DescribeVolumeResponse) String 

func (x *DescribeVolumeResponse) String() string

type DescribeVolumeResult 

type DescribeVolumeResult struct {

	// Volume path.
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// Count of partitions.
	PartitionCount uint64 `protobuf:"varint,2,opt,name=partition_count,json=partitionCount,proto3" json:"partition_count,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeVolumeResult) Descriptor deprecated 

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

Deprecated: Use DescribeVolumeResult.ProtoReflect.Descriptor instead.

func (*DescribeVolumeResult) GetPartitionCount 

func (x *DescribeVolumeResult) GetPartitionCount() uint64

func (*DescribeVolumeResult) GetPath 

func (x *DescribeVolumeResult) GetPath() string

func (*DescribeVolumeResult) ProtoMessage 

func (*DescribeVolumeResult) ProtoMessage()

func (*DescribeVolumeResult) ProtoReflect 

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

func (*DescribeVolumeResult) Reset 

func (x *DescribeVolumeResult) Reset()

func (*DescribeVolumeResult) String 

func (x *DescribeVolumeResult) String() string

type DropVolumeRequest 

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

func (*DropVolumeRequest) Descriptor deprecated 

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

Deprecated: Use DropVolumeRequest.ProtoReflect.Descriptor instead.

func (*DropVolumeRequest) GetOperationParams 

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

func (*DropVolumeRequest) GetPath 

func (x *DropVolumeRequest) GetPath() string

func (*DropVolumeRequest) ProtoMessage 

func (*DropVolumeRequest) ProtoMessage()

func (*DropVolumeRequest) ProtoReflect 

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

func (*DropVolumeRequest) Reset 

func (x *DropVolumeRequest) Reset()

func (*DropVolumeRequest) String 

func (x *DropVolumeRequest) String() string

type DropVolumeResponse 

type DropVolumeResponse struct {

	// Operation contains the result of the request. Check the ydb_operation.proto.
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*DropVolumeResponse) Descriptor deprecated 

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

Deprecated: Use DropVolumeResponse.ProtoReflect.Descriptor instead.

func (*DropVolumeResponse) GetOperation 

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

func (*DropVolumeResponse) ProtoMessage 

func (*DropVolumeResponse) ProtoMessage()

func (*DropVolumeResponse) ProtoReflect 

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

func (*DropVolumeResponse) Reset 

func (x *DropVolumeResponse) Reset()

func (*DropVolumeResponse) String 

func (x *DropVolumeResponse) String() string

type DropVolumeResult 

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

func (*DropVolumeResult) Descriptor deprecated 

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

Deprecated: Use DropVolumeResult.ProtoReflect.Descriptor instead.

func (*DropVolumeResult) ProtoMessage 

func (*DropVolumeResult) ProtoMessage()

func (*DropVolumeResult) ProtoReflect 

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

func (*DropVolumeResult) Reset 

func (x *DropVolumeResult) Reset()

func (*DropVolumeResult) String 

func (x *DropVolumeResult) String() string

type ExecuteTransactionRequest 

type ExecuteTransactionRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// Volume path.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// Partition of the volume.
	PartitionId uint64 `protobuf:"varint,3,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	// Generation of the exclusive lock acquired for the partition as a result of an AcquireLock call.
	LockGeneration *uint64 `protobuf:"varint,4,opt,name=lock_generation,json=lockGeneration,proto3,oneof" json:"lock_generation,omitempty"`
	// Commands to execute as a single atomic transaction.
	// The order of execution of commands is the same as the order of commands in the ExecuteTransactionRequest.
	// The order of execution of different transactions is not specified.
	Commands []*ExecuteTransactionRequest_Command `protobuf:"bytes,5,rep,name=commands,proto3" json:"commands,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteTransactionRequest) Descriptor deprecated 

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

Deprecated: Use ExecuteTransactionRequest.ProtoReflect.Descriptor instead.

func (*ExecuteTransactionRequest) GetCommands 

func (x *ExecuteTransactionRequest) GetCommands() []*ExecuteTransactionRequest_Command

func (*ExecuteTransactionRequest) GetLockGeneration 

func (x *ExecuteTransactionRequest) GetLockGeneration() uint64

func (*ExecuteTransactionRequest) GetOperationParams 

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

func (*ExecuteTransactionRequest) GetPartitionId 

func (x *ExecuteTransactionRequest) GetPartitionId() uint64

func (*ExecuteTransactionRequest) GetPath 

func (x *ExecuteTransactionRequest) GetPath() string

func (*ExecuteTransactionRequest) ProtoMessage 

func (*ExecuteTransactionRequest) ProtoMessage()

func (*ExecuteTransactionRequest) ProtoReflect 

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

func (*ExecuteTransactionRequest) Reset 

func (x *ExecuteTransactionRequest) Reset()

func (*ExecuteTransactionRequest) String 

func (x *ExecuteTransactionRequest) String() string

type ExecuteTransactionRequest_Command 

type ExecuteTransactionRequest_Command struct {

	// Types that are assignable to Action:
	//
	//	*ExecuteTransactionRequest_Command_DeleteRange_
	//	*ExecuteTransactionRequest_Command_Rename_
	//	*ExecuteTransactionRequest_Command_CopyRange_
	//	*ExecuteTransactionRequest_Command_Concat_
	//	*ExecuteTransactionRequest_Command_Write_
	Action isExecuteTransactionRequest_Command_Action `protobuf_oneof:"action"`
	// contains filtered or unexported fields
}

func (*ExecuteTransactionRequest_Command) Descriptor deprecated 

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

Deprecated: Use ExecuteTransactionRequest_Command.ProtoReflect.Descriptor instead.

func (*ExecuteTransactionRequest_Command) GetAction 

func (m *ExecuteTransactionRequest_Command) GetAction() isExecuteTransactionRequest_Command_Action

func (*ExecuteTransactionRequest_Command) GetConcat 

func (x *ExecuteTransactionRequest_Command) GetConcat() *ExecuteTransactionRequest_Command_Concat

func (*ExecuteTransactionRequest_Command) GetCopyRange 

func (x *ExecuteTransactionRequest_Command) GetCopyRange() *ExecuteTransactionRequest_Command_CopyRange

func (*ExecuteTransactionRequest_Command) GetDeleteRange 

func (x *ExecuteTransactionRequest_Command) GetDeleteRange() *ExecuteTransactionRequest_Command_DeleteRange

func (*ExecuteTransactionRequest_Command) GetRename 

func (x *ExecuteTransactionRequest_Command) GetRename() *ExecuteTransactionRequest_Command_Rename

func (*ExecuteTransactionRequest_Command) GetWrite 

func (x *ExecuteTransactionRequest_Command) GetWrite() *ExecuteTransactionRequest_Command_Write

func (*ExecuteTransactionRequest_Command) ProtoMessage 

func (*ExecuteTransactionRequest_Command) ProtoMessage()

func (*ExecuteTransactionRequest_Command) ProtoReflect 

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

func (*ExecuteTransactionRequest_Command) Reset 

func (x *ExecuteTransactionRequest_Command) Reset()

func (*ExecuteTransactionRequest_Command) String 

func (x *ExecuteTransactionRequest_Command) String() string

type ExecuteTransactionRequest_Command_Concat 

type ExecuteTransactionRequest_Command_Concat struct {

	// Keys to use as the source for the concatenation.
	InputKeys []string `protobuf:"bytes,1,rep,name=input_keys,json=inputKeys,proto3" json:"input_keys,omitempty"`
	// New key to use for the result of the concatenation.
	OutputKey string `protobuf:"bytes,2,opt,name=output_key,json=outputKey,proto3" json:"output_key,omitempty"`
	// Input keys are deleted after the concatenation by default.
	// In order to keep both the inputs and the output, set keep_inputs to true.
	KeepInputs bool `protobuf:"varint,3,opt,name=keep_inputs,json=keepInputs,proto3" json:"keep_inputs,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteTransactionRequest_Command_Concat) Descriptor deprecated 

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

Deprecated: Use ExecuteTransactionRequest_Command_Concat.ProtoReflect.Descriptor instead.

func (*ExecuteTransactionRequest_Command_Concat) GetInputKeys 

func (x *ExecuteTransactionRequest_Command_Concat) GetInputKeys() []string

func (*ExecuteTransactionRequest_Command_Concat) GetKeepInputs 

func (x *ExecuteTransactionRequest_Command_Concat) GetKeepInputs() bool

func (*ExecuteTransactionRequest_Command_Concat) GetOutputKey 

func (x *ExecuteTransactionRequest_Command_Concat) GetOutputKey() string

func (*ExecuteTransactionRequest_Command_Concat) ProtoMessage 

func (*ExecuteTransactionRequest_Command_Concat) ProtoMessage()

func (*ExecuteTransactionRequest_Command_Concat) ProtoReflect 

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

func (*ExecuteTransactionRequest_Command_Concat) Reset 

func (x *ExecuteTransactionRequest_Command_Concat) Reset()

func (*ExecuteTransactionRequest_Command_Concat) String 

func (x *ExecuteTransactionRequest_Command_Concat) String() string

type ExecuteTransactionRequest_Command_Concat_ 

type ExecuteTransactionRequest_Command_Concat_ struct {
	// Create a new key-value pair with key specified by concatenating values of multiple other key-value pairs
	// with keys specified.
	Concat *ExecuteTransactionRequest_Command_Concat `protobuf:"bytes,4,opt,name=concat,proto3,oneof"`
}

type ExecuteTransactionRequest_Command_CopyRange 

type ExecuteTransactionRequest_Command_CopyRange struct {

	// The range of keys to copy
	Range *KeyRange `protobuf:"bytes,1,opt,name=range,proto3" json:"range,omitempty"`
	// For each source key that begins with the prefix_to_remove, that prefix is removed from the new key before
	// prepending it with the prefix_to_add.
	// Acts as filter if not empty.
	PrefixToRemove string `protobuf:"bytes,2,opt,name=prefix_to_remove,json=prefixToRemove,proto3" json:"prefix_to_remove,omitempty"`
	// The prefix to prepend to each new key.
	PrefixToAdd string `protobuf:"bytes,3,opt,name=prefix_to_add,json=prefixToAdd,proto3" json:"prefix_to_add,omitempty"`
	// contains filtered or unexported fields
}

Make a copy of a range of key-value pairs. New keys are formed by removing a prefix and/or prepending keys with the new prefix. For example, copy of the key-value pairs [{aaabc,1}, {aaaef,2}, {baaef,3}] can be stripped of the 'aa' prefix and prepended with the 'x' so that the new pairs that are added are [{xabc, 1}, {xaef, 2}].

func (*ExecuteTransactionRequest_Command_CopyRange) Descriptor deprecated 

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

Deprecated: Use ExecuteTransactionRequest_Command_CopyRange.ProtoReflect.Descriptor instead.

func (*ExecuteTransactionRequest_Command_CopyRange) GetPrefixToAdd 

func (x *ExecuteTransactionRequest_Command_CopyRange) GetPrefixToAdd() string

func (*ExecuteTransactionRequest_Command_CopyRange) GetPrefixToRemove 

func (x *ExecuteTransactionRequest_Command_CopyRange) GetPrefixToRemove() string

func (*ExecuteTransactionRequest_Command_CopyRange) GetRange 

func (x *ExecuteTransactionRequest_Command_CopyRange) GetRange() *KeyRange

func (*ExecuteTransactionRequest_Command_CopyRange) ProtoMessage 

func (*ExecuteTransactionRequest_Command_CopyRange) ProtoMessage()

func (*ExecuteTransactionRequest_Command_CopyRange) ProtoReflect 

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

func (*ExecuteTransactionRequest_Command_CopyRange) Reset 

func (x *ExecuteTransactionRequest_Command_CopyRange) Reset()

func (*ExecuteTransactionRequest_Command_CopyRange) String 

func (x *ExecuteTransactionRequest_Command_CopyRange) String() string

type ExecuteTransactionRequest_Command_CopyRange_ 

type ExecuteTransactionRequest_Command_CopyRange_ struct {
	// Create a copy of key-value pairs with keys in the range specified by removing and/or prepending a prefix
	// to each key.
	CopyRange *ExecuteTransactionRequest_Command_CopyRange `protobuf:"bytes,3,opt,name=copy_range,json=copyRange,proto3,oneof"`
}

type ExecuteTransactionRequest_Command_DeleteRange 

type ExecuteTransactionRequest_Command_DeleteRange struct {

	// The range of keys to delete.
	Range *KeyRange `protobuf:"bytes,1,opt,name=range,proto3" json:"range,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteTransactionRequest_Command_DeleteRange) Descriptor deprecated 

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

Deprecated: Use ExecuteTransactionRequest_Command_DeleteRange.ProtoReflect.Descriptor instead.

func (*ExecuteTransactionRequest_Command_DeleteRange) GetRange 

func (x *ExecuteTransactionRequest_Command_DeleteRange) GetRange() *KeyRange

func (*ExecuteTransactionRequest_Command_DeleteRange) ProtoMessage 

func (*ExecuteTransactionRequest_Command_DeleteRange) ProtoMessage()

func (*ExecuteTransactionRequest_Command_DeleteRange) ProtoReflect 

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

func (*ExecuteTransactionRequest_Command_DeleteRange) Reset 

func (x *ExecuteTransactionRequest_Command_DeleteRange) Reset()

func (*ExecuteTransactionRequest_Command_DeleteRange) String 

func (x *ExecuteTransactionRequest_Command_DeleteRange) String() string

type ExecuteTransactionRequest_Command_DeleteRange_ 

type ExecuteTransactionRequest_Command_DeleteRange_ struct {
	// Delete key-value pairs with keys in the range specified.
	DeleteRange *ExecuteTransactionRequest_Command_DeleteRange `protobuf:"bytes,1,opt,name=delete_range,json=deleteRange,proto3,oneof"`
}

type ExecuteTransactionRequest_Command_Rename 

type ExecuteTransactionRequest_Command_Rename struct {

	// The key to change.
	OldKey string `protobuf:"bytes,1,opt,name=old_key,json=oldKey,proto3" json:"old_key,omitempty"`
	// The new key to change the old key to.
	NewKey string `protobuf:"bytes,2,opt,name=new_key,json=newKey,proto3" json:"new_key,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteTransactionRequest_Command_Rename) Descriptor deprecated 

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

Deprecated: Use ExecuteTransactionRequest_Command_Rename.ProtoReflect.Descriptor instead.

func (*ExecuteTransactionRequest_Command_Rename) GetNewKey 

func (x *ExecuteTransactionRequest_Command_Rename) GetNewKey() string

func (*ExecuteTransactionRequest_Command_Rename) GetOldKey 

func (x *ExecuteTransactionRequest_Command_Rename) GetOldKey() string

func (*ExecuteTransactionRequest_Command_Rename) ProtoMessage 

func (*ExecuteTransactionRequest_Command_Rename) ProtoMessage()

func (*ExecuteTransactionRequest_Command_Rename) ProtoReflect 

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

func (*ExecuteTransactionRequest_Command_Rename) Reset 

func (x *ExecuteTransactionRequest_Command_Rename) Reset()

func (*ExecuteTransactionRequest_Command_Rename) String 

func (x *ExecuteTransactionRequest_Command_Rename) String() string

type ExecuteTransactionRequest_Command_Rename_ 

type ExecuteTransactionRequest_Command_Rename_ struct {
	// Change the key of a key-value pair.
	Rename *ExecuteTransactionRequest_Command_Rename `protobuf:"bytes,2,opt,name=rename,proto3,oneof"`
}

type ExecuteTransactionRequest_Command_Write 

type ExecuteTransactionRequest_Command_Write struct {

	// Key of the key-value pair to write.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Value of the key-value pair to write.
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// Storage channel to write the value to. Channel numbers begin with 1 and may go up to approximately 250
	// (depends on the channel configuration of each partition).
	// Channel 1 is called the INLINE channel (value is stored in the index table).
	// Channel 2 is called the MAIN channel (value is stored as a separate blob in the Distributed Storage).
	// Channels 1 and 2 are available for all partitions.
	// If the storage channel specified is not configured for the partition, the value is stored in
	// channel 2 (the MAIN channel).
	StorageChannel uint32 `protobuf:"varint,3,opt,name=storage_channel,json=storageChannel,proto3" json:"storage_channel,omitempty"` // (default = 0 is same as 2 or MAIN)
	// Priority to use for the Distributed Storage Get operation.
	// Has no effect for the INLINE storage channel.
	Priority Priorities_Priority `protobuf:"varint,4,opt,name=priority,proto3,enum=Ydb.KeyValue.Priorities_Priority" json:"priority,omitempty"`
	// Tactic to use for the Distributed Storage Put operation.
	// Has no effect for the INLINE storage channel.
	Tactic ExecuteTransactionRequest_Command_Write_Tactic `` /* 131-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ExecuteTransactionRequest_Command_Write) Descriptor deprecated 

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

Deprecated: Use ExecuteTransactionRequest_Command_Write.ProtoReflect.Descriptor instead.

func (*ExecuteTransactionRequest_Command_Write) GetKey 

func (x *ExecuteTransactionRequest_Command_Write) GetKey() string

func (*ExecuteTransactionRequest_Command_Write) GetPriority 

func (x *ExecuteTransactionRequest_Command_Write) GetPriority() Priorities_Priority

func (*ExecuteTransactionRequest_Command_Write) GetStorageChannel 

func (x *ExecuteTransactionRequest_Command_Write) GetStorageChannel() uint32

func (*ExecuteTransactionRequest_Command_Write) GetTactic 

func (x *ExecuteTransactionRequest_Command_Write) GetTactic() ExecuteTransactionRequest_Command_Write_Tactic

func (*ExecuteTransactionRequest_Command_Write) GetValue 

func (x *ExecuteTransactionRequest_Command_Write) GetValue() []byte

func (*ExecuteTransactionRequest_Command_Write) ProtoMessage 

func (*ExecuteTransactionRequest_Command_Write) ProtoMessage()

func (*ExecuteTransactionRequest_Command_Write) ProtoReflect 

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

func (*ExecuteTransactionRequest_Command_Write) Reset 

func (x *ExecuteTransactionRequest_Command_Write) Reset()

func (*ExecuteTransactionRequest_Command_Write) String 

func (x *ExecuteTransactionRequest_Command_Write) String() string

type ExecuteTransactionRequest_Command_Write_ 

type ExecuteTransactionRequest_Command_Write_ struct {
	// Create a new key-value pair with key and value specified.
	Write *ExecuteTransactionRequest_Command_Write `protobuf:"bytes,5,opt,name=write,proto3,oneof"`
}

type ExecuteTransactionRequest_Command_Write_Tactic 

type ExecuteTransactionRequest_Command_Write_Tactic int32
const (
	// Use default tactic (TACTIC_MAX_THROUGHPUT).
	ExecuteTransactionRequest_Command_Write_TACTIC_UNSPECIFIED ExecuteTransactionRequest_Command_Write_Tactic = 0
	// Write minimum required redundant data. Does not affect storage durability. The default tactic.
	ExecuteTransactionRequest_Command_Write_TACTIC_MAX_THROUGHPUT ExecuteTransactionRequest_Command_Write_Tactic = 1
	// Write additional redundant data to reduce operation duration. Will use additional space.
	ExecuteTransactionRequest_Command_Write_TACTIC_MIN_LATENCY ExecuteTransactionRequest_Command_Write_Tactic = 2
)

func (ExecuteTransactionRequest_Command_Write_Tactic) Descriptor 

func (ExecuteTransactionRequest_Command_Write_Tactic) Descriptor() protoreflect.EnumDescriptor

func (ExecuteTransactionRequest_Command_Write_Tactic) Enum 

func (x ExecuteTransactionRequest_Command_Write_Tactic) Enum() *ExecuteTransactionRequest_Command_Write_Tactic

func (ExecuteTransactionRequest_Command_Write_Tactic) EnumDescriptor deprecated 

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

Deprecated: Use ExecuteTransactionRequest_Command_Write_Tactic.Descriptor instead.

func (ExecuteTransactionRequest_Command_Write_Tactic) Number 

func (x ExecuteTransactionRequest_Command_Write_Tactic) Number() protoreflect.EnumNumber

func (ExecuteTransactionRequest_Command_Write_Tactic) String 

func (x ExecuteTransactionRequest_Command_Write_Tactic) String() string

func (ExecuteTransactionRequest_Command_Write_Tactic) Type 

func (ExecuteTransactionRequest_Command_Write_Tactic) Type() protoreflect.EnumType

type ExecuteTransactionResponse 

type ExecuteTransactionResponse struct {

	// Operation contains the result of the request. Check the ydb_operation.proto.
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteTransactionResponse) Descriptor deprecated 

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

Deprecated: Use ExecuteTransactionResponse.ProtoReflect.Descriptor instead.

func (*ExecuteTransactionResponse) GetOperation 

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

func (*ExecuteTransactionResponse) ProtoMessage 

func (*ExecuteTransactionResponse) ProtoMessage()

func (*ExecuteTransactionResponse) ProtoReflect 

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

func (*ExecuteTransactionResponse) Reset 

func (x *ExecuteTransactionResponse) Reset()

func (*ExecuteTransactionResponse) String 

func (x *ExecuteTransactionResponse) String() string

type ExecuteTransactionResult 

type ExecuteTransactionResult struct {

	// Contains status flags for the storage channels used by the transaction.
	StorageChannelInfo []*StorageChannelInfo `protobuf:"bytes,1,rep,name=storage_channel_info,json=storageChannelInfo,proto3" json:"storage_channel_info,omitempty"`
	// Contains 0 if the request was sent to the node of the partition, node ID of the partition otherwise.
	NodeId uint32 `protobuf:"varint,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteTransactionResult) Descriptor deprecated 

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

Deprecated: Use ExecuteTransactionResult.ProtoReflect.Descriptor instead.

func (*ExecuteTransactionResult) GetNodeId 

func (x *ExecuteTransactionResult) GetNodeId() uint32

func (*ExecuteTransactionResult) GetStorageChannelInfo 

func (x *ExecuteTransactionResult) GetStorageChannelInfo() []*StorageChannelInfo

func (*ExecuteTransactionResult) ProtoMessage 

func (*ExecuteTransactionResult) ProtoMessage()

func (*ExecuteTransactionResult) ProtoReflect 

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

func (*ExecuteTransactionResult) Reset 

func (x *ExecuteTransactionResult) Reset()

func (*ExecuteTransactionResult) String 

func (x *ExecuteTransactionResult) String() string

type GetStorageChannelStatusRequest 

type GetStorageChannelStatusRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// Volume path.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// Partition of the volume.
	PartitionId uint64 `protobuf:"varint,3,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	// Generation of the exclusive lock acquired for the partition as a result of an AcquireLock call.
	LockGeneration *uint64 `protobuf:"varint,4,opt,name=lock_generation,json=lockGeneration,proto3,oneof" json:"lock_generation,omitempty"`
	// List of storage channels to get StorageChannelInfo for.
	StorageChannel []uint32 `protobuf:"varint,5,rep,packed,name=storage_channel,json=storageChannel,proto3" json:"storage_channel,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStorageChannelStatusRequest) Descriptor deprecated 

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

Deprecated: Use GetStorageChannelStatusRequest.ProtoReflect.Descriptor instead.

func (*GetStorageChannelStatusRequest) GetLockGeneration 

func (x *GetStorageChannelStatusRequest) GetLockGeneration() uint64

func (*GetStorageChannelStatusRequest) GetOperationParams 

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

func (*GetStorageChannelStatusRequest) GetPartitionId 

func (x *GetStorageChannelStatusRequest) GetPartitionId() uint64

func (*GetStorageChannelStatusRequest) GetPath 

func (x *GetStorageChannelStatusRequest) GetPath() string

func (*GetStorageChannelStatusRequest) GetStorageChannel 

func (x *GetStorageChannelStatusRequest) GetStorageChannel() []uint32

func (*GetStorageChannelStatusRequest) ProtoMessage 

func (*GetStorageChannelStatusRequest) ProtoMessage()

func (*GetStorageChannelStatusRequest) ProtoReflect 

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

func (*GetStorageChannelStatusRequest) Reset 

func (x *GetStorageChannelStatusRequest) Reset()

func (*GetStorageChannelStatusRequest) String 

func (x *GetStorageChannelStatusRequest) String() string

type GetStorageChannelStatusResponse 

type GetStorageChannelStatusResponse struct {

	// Operation contains the result of the request. Check the ydb_operation.proto.
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStorageChannelStatusResponse) Descriptor deprecated 

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

Deprecated: Use GetStorageChannelStatusResponse.ProtoReflect.Descriptor instead.

func (*GetStorageChannelStatusResponse) GetOperation 

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

func (*GetStorageChannelStatusResponse) ProtoMessage 

func (*GetStorageChannelStatusResponse) ProtoMessage()

func (*GetStorageChannelStatusResponse) ProtoReflect 

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

func (*GetStorageChannelStatusResponse) Reset 

func (x *GetStorageChannelStatusResponse) Reset()

func (*GetStorageChannelStatusResponse) String 

func (x *GetStorageChannelStatusResponse) String() string

type GetStorageChannelStatusResult 

type GetStorageChannelStatusResult struct {

	// Contains status flags for the requested storage channels.
	StorageChannelInfo []*StorageChannelInfo `protobuf:"bytes,1,rep,name=storage_channel_info,json=storageChannelInfo,proto3" json:"storage_channel_info,omitempty"`
	// Contains 0 if the request was sent to the node of the partition, node ID of the partition otherwise.
	NodeId uint32 `protobuf:"varint,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStorageChannelStatusResult) Descriptor deprecated 

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

Deprecated: Use GetStorageChannelStatusResult.ProtoReflect.Descriptor instead.

func (*GetStorageChannelStatusResult) GetNodeId 

func (x *GetStorageChannelStatusResult) GetNodeId() uint32

func (*GetStorageChannelStatusResult) GetStorageChannelInfo 

func (x *GetStorageChannelStatusResult) GetStorageChannelInfo() []*StorageChannelInfo

func (*GetStorageChannelStatusResult) ProtoMessage 

func (*GetStorageChannelStatusResult) ProtoMessage()

func (*GetStorageChannelStatusResult) ProtoReflect 

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

func (*GetStorageChannelStatusResult) Reset 

func (x *GetStorageChannelStatusResult) Reset()

func (*GetStorageChannelStatusResult) String 

func (x *GetStorageChannelStatusResult) String() string

type KeyRange 

type KeyRange struct {

	// The lower bound of the key range.
	// If unspecified, the range begins from the lowest key.
	//
	// Types that are assignable to FromBound:
	//
	//	*KeyRange_FromKeyInclusive
	//	*KeyRange_FromKeyExclusive
	FromBound isKeyRange_FromBound `protobuf_oneof:"from_bound"`
	// The higher bound of the key range.
	// If unspecified, the range ends with the highest key.
	//
	// Types that are assignable to ToBound:
	//
	//	*KeyRange_ToKeyInclusive
	//	*KeyRange_ToKeyExclusive
	ToBound isKeyRange_ToBound `protobuf_oneof:"to_bound"`
	// contains filtered or unexported fields
}

func (*KeyRange) Descriptor deprecated 

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

Deprecated: Use KeyRange.ProtoReflect.Descriptor instead.

func (*KeyRange) GetFromBound 

func (m *KeyRange) GetFromBound() isKeyRange_FromBound

func (*KeyRange) GetFromKeyExclusive 

func (x *KeyRange) GetFromKeyExclusive() string

func (*KeyRange) GetFromKeyInclusive 

func (x *KeyRange) GetFromKeyInclusive() string

func (*KeyRange) GetToBound 

func (m *KeyRange) GetToBound() isKeyRange_ToBound

func (*KeyRange) GetToKeyExclusive 

func (x *KeyRange) GetToKeyExclusive() string

func (*KeyRange) GetToKeyInclusive 

func (x *KeyRange) GetToKeyInclusive() string

func (*KeyRange) ProtoMessage 

func (*KeyRange) ProtoMessage()

func (*KeyRange) ProtoReflect 

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

func (*KeyRange) Reset 

func (x *KeyRange) Reset()

func (*KeyRange) String 

func (x *KeyRange) String() string

type KeyRange_FromKeyExclusive 

type KeyRange_FromKeyExclusive struct {
	// Set in order for the range not to include the key specified
	FromKeyExclusive string `protobuf:"bytes,2,opt,name=from_key_exclusive,json=fromKeyExclusive,proto3,oneof"`
}

type KeyRange_FromKeyInclusive 

type KeyRange_FromKeyInclusive struct {
	// Set in order for the range to include the key specified
	FromKeyInclusive string `protobuf:"bytes,1,opt,name=from_key_inclusive,json=fromKeyInclusive,proto3,oneof"`
}

type KeyRange_ToKeyExclusive 

type KeyRange_ToKeyExclusive struct {
	// Set in order for the range not to include the key specified
	ToKeyExclusive string `protobuf:"bytes,4,opt,name=to_key_exclusive,json=toKeyExclusive,proto3,oneof"`
}

type KeyRange_ToKeyInclusive 

type KeyRange_ToKeyInclusive struct {
	// Set in order for the range to include the key specified
	ToKeyInclusive string `protobuf:"bytes,3,opt,name=to_key_inclusive,json=toKeyInclusive,proto3,oneof"`
}

type ListLocalPartitionsRequest 

type ListLocalPartitionsRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// Volume path.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// ID of the node to get partitions for.
	// 0 means the node the request was send to.
	NodeId uint64 `protobuf:"varint,3,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListLocalPartitionsRequest) Descriptor deprecated 

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

Deprecated: Use ListLocalPartitionsRequest.ProtoReflect.Descriptor instead.

func (*ListLocalPartitionsRequest) GetNodeId 

func (x *ListLocalPartitionsRequest) GetNodeId() uint64

func (*ListLocalPartitionsRequest) GetOperationParams 

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

func (*ListLocalPartitionsRequest) GetPath 

func (x *ListLocalPartitionsRequest) GetPath() string

func (*ListLocalPartitionsRequest) ProtoMessage 

func (*ListLocalPartitionsRequest) ProtoMessage()

func (*ListLocalPartitionsRequest) ProtoReflect 

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

func (*ListLocalPartitionsRequest) Reset 

func (x *ListLocalPartitionsRequest) Reset()

func (*ListLocalPartitionsRequest) String 

func (x *ListLocalPartitionsRequest) String() string

type ListLocalPartitionsResponse 

type ListLocalPartitionsResponse struct {

	// Operation contains the result of the request. Check the ydb_operation.proto.
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*ListLocalPartitionsResponse) Descriptor deprecated 

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

Deprecated: Use ListLocalPartitionsResponse.ProtoReflect.Descriptor instead.

func (*ListLocalPartitionsResponse) GetOperation 

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

func (*ListLocalPartitionsResponse) ProtoMessage 

func (*ListLocalPartitionsResponse) ProtoMessage()

func (*ListLocalPartitionsResponse) ProtoReflect 

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

func (*ListLocalPartitionsResponse) Reset 

func (x *ListLocalPartitionsResponse) Reset()

func (*ListLocalPartitionsResponse) String 

func (x *ListLocalPartitionsResponse) String() string

type ListLocalPartitionsResult 

type ListLocalPartitionsResult struct {

	// Volume path.
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// ID of the node.
	NodeId uint64 `protobuf:"varint,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// List of the partitions of the volume on the node.
	PartitionIds []uint64 `protobuf:"varint,3,rep,packed,name=partition_ids,json=partitionIds,proto3" json:"partition_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*ListLocalPartitionsResult) Descriptor deprecated 

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

Deprecated: Use ListLocalPartitionsResult.ProtoReflect.Descriptor instead.

func (*ListLocalPartitionsResult) GetNodeId 

func (x *ListLocalPartitionsResult) GetNodeId() uint64

func (*ListLocalPartitionsResult) GetPartitionIds 

func (x *ListLocalPartitionsResult) GetPartitionIds() []uint64

func (*ListLocalPartitionsResult) GetPath 

func (x *ListLocalPartitionsResult) GetPath() string

func (*ListLocalPartitionsResult) ProtoMessage 

func (*ListLocalPartitionsResult) ProtoMessage()

func (*ListLocalPartitionsResult) ProtoReflect 

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

func (*ListLocalPartitionsResult) Reset 

func (x *ListLocalPartitionsResult) Reset()

func (*ListLocalPartitionsResult) String 

func (x *ListLocalPartitionsResult) String() string

type ListRangeRequest 

type ListRangeRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// Volume path.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// Partition of the volume.
	PartitionId uint64 `protobuf:"varint,3,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	// Generation of the exclusive lock acquired for the partition as a result of an AcquireLock call.
	LockGeneration *uint64 `protobuf:"varint,4,opt,name=lock_generation,json=lockGeneration,proto3,oneof" json:"lock_generation,omitempty"`
	// The range of keys to read
	Range *KeyRange `protobuf:"bytes,5,opt,name=range,proto3" json:"range,omitempty"`
	// Result protobuf size limit. If not 0, overrides the default one only with a smaller value.
	LimitBytes uint64 `protobuf:"varint,6,opt,name=limit_bytes,json=limitBytes,proto3" json:"limit_bytes,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRangeRequest) Descriptor deprecated 

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

Deprecated: Use ListRangeRequest.ProtoReflect.Descriptor instead.

func (*ListRangeRequest) GetLimitBytes 

func (x *ListRangeRequest) GetLimitBytes() uint64

func (*ListRangeRequest) GetLockGeneration 

func (x *ListRangeRequest) GetLockGeneration() uint64

func (*ListRangeRequest) GetOperationParams 

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

func (*ListRangeRequest) GetPartitionId 

func (x *ListRangeRequest) GetPartitionId() uint64

func (*ListRangeRequest) GetPath 

func (x *ListRangeRequest) GetPath() string

func (*ListRangeRequest) GetRange 

func (x *ListRangeRequest) GetRange() *KeyRange

func (*ListRangeRequest) ProtoMessage 

func (*ListRangeRequest) ProtoMessage()

func (*ListRangeRequest) ProtoReflect 

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

func (*ListRangeRequest) Reset 

func (x *ListRangeRequest) Reset()

func (*ListRangeRequest) String 

func (x *ListRangeRequest) String() string

type ListRangeResponse 

type ListRangeResponse struct {

	// Operation contains the result of the request. Check the ydb_operation.proto.
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRangeResponse) Descriptor deprecated 

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

Deprecated: Use ListRangeResponse.ProtoReflect.Descriptor instead.

func (*ListRangeResponse) GetOperation 

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

func (*ListRangeResponse) ProtoMessage 

func (*ListRangeResponse) ProtoMessage()

func (*ListRangeResponse) ProtoReflect 

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

func (*ListRangeResponse) Reset 

func (x *ListRangeResponse) Reset()

func (*ListRangeResponse) String 

func (x *ListRangeResponse) String() string

type ListRangeResult 

type ListRangeResult struct {

	// List of the key-value pairs and metadata requested.
	Key []*ListRangeResult_KeyInfo `protobuf:"bytes,1,rep,name=key,proto3" json:"key,omitempty"`
	// If requested data size is larger than limit_bytes then result will contain
	// only part of the requested key-value pairs and the is_overrun flag will be set.
	IsOverrun bool `protobuf:"varint,2,opt,name=is_overrun,json=isOverrun,proto3" json:"is_overrun,omitempty"`
	// Contains 0 if the request was sent to the node of the partition, node ID of the partition otherwise.
	NodeId uint32 `protobuf:"varint,3,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRangeResult) Descriptor deprecated 

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

Deprecated: Use ListRangeResult.ProtoReflect.Descriptor instead.

func (*ListRangeResult) GetIsOverrun 

func (x *ListRangeResult) GetIsOverrun() bool

func (*ListRangeResult) GetKey 

func (x *ListRangeResult) GetKey() []*ListRangeResult_KeyInfo

func (*ListRangeResult) GetNodeId 

func (x *ListRangeResult) GetNodeId() uint32

func (*ListRangeResult) ProtoMessage 

func (*ListRangeResult) ProtoMessage()

func (*ListRangeResult) ProtoReflect 

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

func (*ListRangeResult) Reset 

func (x *ListRangeResult) Reset()

func (*ListRangeResult) String 

func (x *ListRangeResult) String() string

type ListRangeResult_KeyInfo 

type ListRangeResult_KeyInfo struct {

	// The key of the key-value pair.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Full size of the value of the key-value pair.
	ValueSize uint32 `protobuf:"varint,2,opt,name=value_size,json=valueSize,proto3" json:"value_size,omitempty"`
	// Unix time of the creation of the key-value pair (in ms).
	CreationUnixTime uint64 `protobuf:"varint,3,opt,name=creation_unix_time,json=creationUnixTime,proto3" json:"creation_unix_time,omitempty"`
	// Contains the index of the actually used storage channel. The actually used storage channel may differ from
	// the value specified in the write request for example if there were no such storage channel at the moment
	// of execution of the write command.
	// For values created as a result of concatenation or copy of concatenated values, the storage channel of the first
	// part of the value is specified.
	StorageChannel uint32 `protobuf:"varint,4,opt,name=storage_channel,json=storageChannel,proto3" json:"storage_channel,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRangeResult_KeyInfo) Descriptor deprecated 

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

Deprecated: Use ListRangeResult_KeyInfo.ProtoReflect.Descriptor instead.

func (*ListRangeResult_KeyInfo) GetCreationUnixTime 

func (x *ListRangeResult_KeyInfo) GetCreationUnixTime() uint64

func (*ListRangeResult_KeyInfo) GetKey 

func (x *ListRangeResult_KeyInfo) GetKey() string

func (*ListRangeResult_KeyInfo) GetStorageChannel 

func (x *ListRangeResult_KeyInfo) GetStorageChannel() uint32

func (*ListRangeResult_KeyInfo) GetValueSize 

func (x *ListRangeResult_KeyInfo) GetValueSize() uint32

func (*ListRangeResult_KeyInfo) ProtoMessage 

func (*ListRangeResult_KeyInfo) ProtoMessage()

func (*ListRangeResult_KeyInfo) ProtoReflect 

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

func (*ListRangeResult_KeyInfo) Reset 

func (x *ListRangeResult_KeyInfo) Reset()

func (*ListRangeResult_KeyInfo) String 

func (x *ListRangeResult_KeyInfo) String() string

type Priorities 

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

func (*Priorities) Descriptor deprecated 

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

Deprecated: Use Priorities.ProtoReflect.Descriptor instead.

func (*Priorities) ProtoMessage 

func (*Priorities) ProtoMessage()

func (*Priorities) ProtoReflect 

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

func (*Priorities) Reset 

func (x *Priorities) Reset()

func (*Priorities) String 

func (x *Priorities) String() string

type Priorities_Priority 

type Priorities_Priority int32
const (
	// Use default priority (PRIORITY_REALTIME).
	Priorities_PRIORITY_UNSPECIFIED Priorities_Priority = 0
	// High priority for user-initiated operations, the default priority.
	Priorities_PRIORITY_REALTIME Priorities_Priority = 1
	// Low priority for background system activity.
	Priorities_PRIORITY_BACKGROUND Priorities_Priority = 2
)

func (Priorities_Priority) Descriptor 

func (Priorities_Priority) Descriptor() protoreflect.EnumDescriptor

func (Priorities_Priority) Enum 

func (x Priorities_Priority) Enum() *Priorities_Priority

func (Priorities_Priority) EnumDescriptor deprecated 

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

Deprecated: Use Priorities_Priority.Descriptor instead.

func (Priorities_Priority) Number 

func (x Priorities_Priority) Number() protoreflect.EnumNumber

func (Priorities_Priority) String 

func (x Priorities_Priority) String() string

func (Priorities_Priority) Type 

func (Priorities_Priority) Type() protoreflect.EnumType

type ReadRangeRequest 

type ReadRangeRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// Volume path.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// Partition of the volume.
	PartitionId uint64 `protobuf:"varint,3,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	// Generation of the exclusive lock acquired for the partition as a result of an AcquireLock call.
	LockGeneration *uint64 `protobuf:"varint,4,opt,name=lock_generation,json=lockGeneration,proto3,oneof" json:"lock_generation,omitempty"`
	// The range of keys to read.
	Range *KeyRange `protobuf:"bytes,5,opt,name=range,proto3" json:"range,omitempty"`
	// Result protobuf size limit.
	// Overrides the default limit only with a smaller value.
	// 0 means "use the default limit".
	LimitBytes uint64 `protobuf:"varint,6,opt,name=limit_bytes,json=limitBytes,proto3" json:"limit_bytes,omitempty"`
	// Priority to use for the Distributed Storage Get operation.
	// Has no effect for the INLINE storage channel.
	Priority Priorities_Priority `protobuf:"varint,7,opt,name=priority,proto3,enum=Ydb.KeyValue.Priorities_Priority" json:"priority,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadRangeRequest) Descriptor deprecated 

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

Deprecated: Use ReadRangeRequest.ProtoReflect.Descriptor instead.

func (*ReadRangeRequest) GetLimitBytes 

func (x *ReadRangeRequest) GetLimitBytes() uint64

func (*ReadRangeRequest) GetLockGeneration 

func (x *ReadRangeRequest) GetLockGeneration() uint64

func (*ReadRangeRequest) GetOperationParams 

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

func (*ReadRangeRequest) GetPartitionId 

func (x *ReadRangeRequest) GetPartitionId() uint64

func (*ReadRangeRequest) GetPath 

func (x *ReadRangeRequest) GetPath() string

func (*ReadRangeRequest) GetPriority 

func (x *ReadRangeRequest) GetPriority() Priorities_Priority

func (*ReadRangeRequest) GetRange 

func (x *ReadRangeRequest) GetRange() *KeyRange

func (*ReadRangeRequest) ProtoMessage 

func (*ReadRangeRequest) ProtoMessage()

func (*ReadRangeRequest) ProtoReflect 

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

func (*ReadRangeRequest) Reset 

func (x *ReadRangeRequest) Reset()

func (*ReadRangeRequest) String 

func (x *ReadRangeRequest) String() string

type ReadRangeResponse 

type ReadRangeResponse struct {

	// Operation contains the result of the request. Check the ydb_operation.proto.
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadRangeResponse) Descriptor deprecated 

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

Deprecated: Use ReadRangeResponse.ProtoReflect.Descriptor instead.

func (*ReadRangeResponse) GetOperation 

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

func (*ReadRangeResponse) ProtoMessage 

func (*ReadRangeResponse) ProtoMessage()

func (*ReadRangeResponse) ProtoReflect 

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

func (*ReadRangeResponse) Reset 

func (x *ReadRangeResponse) Reset()

func (*ReadRangeResponse) String 

func (x *ReadRangeResponse) String() string

type ReadRangeResult 

type ReadRangeResult struct {

	// List of key-value pairs requested.
	Pair []*ReadRangeResult_KeyValuePair `protobuf:"bytes,1,rep,name=pair,proto3" json:"pair,omitempty"`
	// If requested data size is larger than limit_bytes then result will contain
	// only part of the requested key-value pairs and the is_overrun flag will be set.
	// The pair list contains only full values.
	// In order to continue reading the client should send another request for the key range
	// with from_key_exclusive set to the last key read.
	// If first pair doesn't fit the limit_bytes then the result will be empty and the is_overrun flag will be set.
	// Use ListRange and Read methods to find and read large key-value pairs.
	IsOverrun bool `protobuf:"varint,2,opt,name=is_overrun,json=isOverrun,proto3" json:"is_overrun,omitempty"`
	// Contains 0 if the request was sent to the node of the partition, node ID of the partition otherwise.
	NodeId uint32 `protobuf:"varint,3,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadRangeResult) Descriptor deprecated 

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

Deprecated: Use ReadRangeResult.ProtoReflect.Descriptor instead.

func (*ReadRangeResult) GetIsOverrun 

func (x *ReadRangeResult) GetIsOverrun() bool

func (*ReadRangeResult) GetNodeId 

func (x *ReadRangeResult) GetNodeId() uint32

func (*ReadRangeResult) GetPair 

func (x *ReadRangeResult) GetPair() []*ReadRangeResult_KeyValuePair

func (*ReadRangeResult) ProtoMessage 

func (*ReadRangeResult) ProtoMessage()

func (*ReadRangeResult) ProtoReflect 

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

func (*ReadRangeResult) Reset 

func (x *ReadRangeResult) Reset()

func (*ReadRangeResult) String 

func (x *ReadRangeResult) String() string

type ReadRangeResult_KeyValuePair 

type ReadRangeResult_KeyValuePair struct {

	// The key of the key-value pair.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The value of the key-value pair.
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// Unix time of the creation of the key-value pair (in ms).
	CreationUnixTime uint64 `protobuf:"varint,4,opt,name=creation_unix_time,json=creationUnixTime,proto3" json:"creation_unix_time,omitempty"`
	// Contains the index of the actually used storage channel. The actually used storage channel may differ from
	// the value specified in the write request for example if there were no such storage channel at the moment
	// of execution of the write command.
	// For values created as a result of concatenation or copy of concatenated values, the storage channel of the first
	// part of the value is specified.
	StorageChannel uint32 `protobuf:"varint,5,opt,name=storage_channel,json=storageChannel,proto3" json:"storage_channel,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadRangeResult_KeyValuePair) Descriptor deprecated 

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

Deprecated: Use ReadRangeResult_KeyValuePair.ProtoReflect.Descriptor instead.

func (*ReadRangeResult_KeyValuePair) GetCreationUnixTime 

func (x *ReadRangeResult_KeyValuePair) GetCreationUnixTime() uint64

func (*ReadRangeResult_KeyValuePair) GetKey 

func (x *ReadRangeResult_KeyValuePair) GetKey() string

func (*ReadRangeResult_KeyValuePair) GetStorageChannel 

func (x *ReadRangeResult_KeyValuePair) GetStorageChannel() uint32

func (*ReadRangeResult_KeyValuePair) GetValue 

func (x *ReadRangeResult_KeyValuePair) GetValue() []byte

func (*ReadRangeResult_KeyValuePair) ProtoMessage 

func (*ReadRangeResult_KeyValuePair) ProtoMessage()

func (*ReadRangeResult_KeyValuePair) ProtoReflect 

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

func (*ReadRangeResult_KeyValuePair) Reset 

func (x *ReadRangeResult_KeyValuePair) Reset()

func (*ReadRangeResult_KeyValuePair) String 

func (x *ReadRangeResult_KeyValuePair) String() string

type ReadRequest 

type ReadRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// Volume path.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// Partition of the volume.
	PartitionId uint64 `protobuf:"varint,3,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	// Generation of the exclusive lock acquired for the partition as a result of an AcquireLock call.
	LockGeneration *uint64 `protobuf:"varint,4,opt,name=lock_generation,json=lockGeneration,proto3,oneof" json:"lock_generation,omitempty"`
	// Key of the key-value pair to read.
	Key string `protobuf:"bytes,5,opt,name=key,proto3" json:"key,omitempty"`
	// Offset in bytes from the beginning of the value to read data from.
	Offset uint64 `protobuf:"varint,6,opt,name=offset,proto3" json:"offset,omitempty"`
	// Size of the data to read in bytes. 0 means "read to the end of the value".
	Size uint64 `protobuf:"varint,7,opt,name=size,proto3" json:"size,omitempty"`
	// Result protobuf size limit.
	// Overrides the default limit only with a smaller value.
	// 0 means "use the default limit".
	LimitBytes uint64 `protobuf:"varint,8,opt,name=limit_bytes,json=limitBytes,proto3" json:"limit_bytes,omitempty"`
	// Priority to use for the Distributed Storage Get operation.
	// Has no effect for the INLINE storage channel.
	Priority Priorities_Priority `protobuf:"varint,9,opt,name=priority,proto3,enum=Ydb.KeyValue.Priorities_Priority" json:"priority,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadRequest) Descriptor deprecated 

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

Deprecated: Use ReadRequest.ProtoReflect.Descriptor instead.

func (*ReadRequest) GetKey 

func (x *ReadRequest) GetKey() string

func (*ReadRequest) GetLimitBytes 

func (x *ReadRequest) GetLimitBytes() uint64

func (*ReadRequest) GetLockGeneration 

func (x *ReadRequest) GetLockGeneration() uint64

func (*ReadRequest) GetOffset 

func (x *ReadRequest) GetOffset() uint64

func (*ReadRequest) GetOperationParams 

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

func (*ReadRequest) GetPartitionId 

func (x *ReadRequest) GetPartitionId() uint64

func (*ReadRequest) GetPath 

func (x *ReadRequest) GetPath() string

func (*ReadRequest) GetPriority 

func (x *ReadRequest) GetPriority() Priorities_Priority

func (*ReadRequest) GetSize 

func (x *ReadRequest) GetSize() uint64

func (*ReadRequest) ProtoMessage 

func (*ReadRequest) ProtoMessage()

func (*ReadRequest) ProtoReflect 

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

func (*ReadRequest) Reset 

func (x *ReadRequest) Reset()

func (*ReadRequest) String 

func (x *ReadRequest) String() string

type ReadResponse 

type ReadResponse struct {

	// Operation contains the result of the request. Check the ydb_operation.proto.
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadResponse) Descriptor deprecated 

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

Deprecated: Use ReadResponse.ProtoReflect.Descriptor instead.

func (*ReadResponse) GetOperation 

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

func (*ReadResponse) ProtoMessage 

func (*ReadResponse) ProtoMessage()

func (*ReadResponse) ProtoReflect 

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

func (*ReadResponse) Reset 

func (x *ReadResponse) Reset()

func (*ReadResponse) String 

func (x *ReadResponse) String() string

type ReadResult 

type ReadResult struct {

	// The key of the requested key-value pair.
	RequestedKey string `protobuf:"bytes,1,opt,name=requested_key,json=requestedKey,proto3" json:"requested_key,omitempty"`
	// Offset in bytes from the beginning of the value requested.
	RequestedOffset uint64 `protobuf:"varint,2,opt,name=requested_offset,json=requestedOffset,proto3" json:"requested_offset,omitempty"`
	// Size of the data requested.
	RequestedSize uint64 `protobuf:"varint,3,opt,name=requested_size,json=requestedSize,proto3" json:"requested_size,omitempty"`
	// The bytes of the requested part of the value.
	Value []byte `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	// If requested data size is larger than limit_bytes then result will contain only part of the requested value and
	// the is_overrun flag will be set.
	IsOverrun bool `protobuf:"varint,5,opt,name=is_overrun,json=isOverrun,proto3" json:"is_overrun,omitempty"`
	// Contains 0 if the request was sent to the node of the partition, node ID of the partition otherwise.
	NodeId uint32 `protobuf:"varint,6,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadResult) Descriptor deprecated 

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

Deprecated: Use ReadResult.ProtoReflect.Descriptor instead.

func (*ReadResult) GetIsOverrun 

func (x *ReadResult) GetIsOverrun() bool

func (*ReadResult) GetNodeId 

func (x *ReadResult) GetNodeId() uint32

func (*ReadResult) GetRequestedKey 

func (x *ReadResult) GetRequestedKey() string

func (*ReadResult) GetRequestedOffset 

func (x *ReadResult) GetRequestedOffset() uint64

func (*ReadResult) GetRequestedSize 

func (x *ReadResult) GetRequestedSize() uint64

func (*ReadResult) GetValue 

func (x *ReadResult) GetValue() []byte

func (*ReadResult) ProtoMessage 

func (*ReadResult) ProtoMessage()

func (*ReadResult) ProtoReflect 

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

func (*ReadResult) Reset 

func (x *ReadResult) Reset()

func (*ReadResult) String 

func (x *ReadResult) String() string

type StorageChannelInfo 

type StorageChannelInfo struct {

	// Storage channel index.
	StorageChannel uint32 `protobuf:"varint,1,opt,name=storage_channel,json=storageChannel,proto3" json:"storage_channel,omitempty"`
	// The status flag of the storage channel.
	StatusFlag StorageChannelInfo_StatusFlag `` /* 140-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StorageChannelInfo) Descriptor deprecated 

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

Deprecated: Use StorageChannelInfo.ProtoReflect.Descriptor instead.

func (*StorageChannelInfo) GetStatusFlag 

func (x *StorageChannelInfo) GetStatusFlag() StorageChannelInfo_StatusFlag

func (*StorageChannelInfo) GetStorageChannel 

func (x *StorageChannelInfo) GetStorageChannel() uint32

func (*StorageChannelInfo) ProtoMessage 

func (*StorageChannelInfo) ProtoMessage()

func (*StorageChannelInfo) ProtoReflect 

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

func (*StorageChannelInfo) Reset 

func (x *StorageChannelInfo) Reset()

func (*StorageChannelInfo) String 

func (x *StorageChannelInfo) String() string

type StorageChannelInfo_StatusFlag 

type StorageChannelInfo_StatusFlag int32
const (
	// The system was unable to get the storage channel status.
	StorageChannelInfo_STATUS_FLAG_UNSPECIFIED StorageChannelInfo_StatusFlag = 0
	// Enough storage space is available.
	StorageChannelInfo_STATUS_FLAG_GREEN StorageChannelInfo_StatusFlag = 10
	// Free storage space is low, user must stop writing new data. Compaction's writes are allow.
	StorageChannelInfo_STATUS_FLAG_YELLOW_STOP StorageChannelInfo_StatusFlag = 20
	// No free storage space is available, no writes will successed.
	StorageChannelInfo_STATUS_FLAG_ORANGE_OUT_SPACE StorageChannelInfo_StatusFlag = 30
)

func (StorageChannelInfo_StatusFlag) Descriptor 

func (StorageChannelInfo_StatusFlag) Descriptor() protoreflect.EnumDescriptor

func (StorageChannelInfo_StatusFlag) Enum 

func (x StorageChannelInfo_StatusFlag) Enum() *StorageChannelInfo_StatusFlag

func (StorageChannelInfo_StatusFlag) EnumDescriptor deprecated 

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

Deprecated: Use StorageChannelInfo_StatusFlag.Descriptor instead.

func (StorageChannelInfo_StatusFlag) Number 

func (x StorageChannelInfo_StatusFlag) Number() protoreflect.EnumNumber

func (StorageChannelInfo_StatusFlag) String 

func (x StorageChannelInfo_StatusFlag) String() string

func (StorageChannelInfo_StatusFlag) Type 

func (StorageChannelInfo_StatusFlag) Type() protoreflect.EnumType

type StorageConfig 

type StorageConfig struct {

	// Channel configs.
	// Channels 0 and 1 are system channels needed for tablet operation.
	// Channels starting with 2 are user channels.
	Channel []*StorageConfig_ChannelConfig `protobuf:"bytes,1,rep,name=channel,proto3" json:"channel,omitempty"`
	// contains filtered or unexported fields
}

func (*StorageConfig) Descriptor deprecated 

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

Deprecated: Use StorageConfig.ProtoReflect.Descriptor instead.

func (*StorageConfig) GetChannel 

func (x *StorageConfig) GetChannel() []*StorageConfig_ChannelConfig

func (*StorageConfig) ProtoMessage 

func (*StorageConfig) ProtoMessage()

func (*StorageConfig) ProtoReflect 

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

func (*StorageConfig) Reset 

func (x *StorageConfig) Reset()

func (*StorageConfig) String 

func (x *StorageConfig) String() string

type StorageConfig_ChannelConfig 

type StorageConfig_ChannelConfig struct {

	// Media for the storage channel.
	// This field specifies the kind of one storage_pool_types configured in config.yaml
	Media string `protobuf:"bytes,1,opt,name=media,proto3" json:"media,omitempty"`
	// contains filtered or unexported fields
}

func (*StorageConfig_ChannelConfig) Descriptor deprecated 

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

Deprecated: Use StorageConfig_ChannelConfig.ProtoReflect.Descriptor instead.

func (*StorageConfig_ChannelConfig) GetMedia 

func (x *StorageConfig_ChannelConfig) GetMedia() string

func (*StorageConfig_ChannelConfig) ProtoMessage 

func (*StorageConfig_ChannelConfig) ProtoMessage()

func (*StorageConfig_ChannelConfig) ProtoReflect 

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

func (*StorageConfig_ChannelConfig) Reset 

func (x *StorageConfig_ChannelConfig) Reset()

func (*StorageConfig_ChannelConfig) String 

func (x *StorageConfig_ChannelConfig) 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.