package Ydb_KeyValue_V1

import "github.com/ydb-platform/ydb-go-genproto/draft/Ydb_KeyValue_V1"

Index

Constants

const (
	KeyValueService_CreateVolume_FullMethodName            = "/Ydb.KeyValue.V1.KeyValueService/CreateVolume"
	KeyValueService_DropVolume_FullMethodName              = "/Ydb.KeyValue.V1.KeyValueService/DropVolume"
	KeyValueService_AlterVolume_FullMethodName             = "/Ydb.KeyValue.V1.KeyValueService/AlterVolume"
	KeyValueService_DescribeVolume_FullMethodName          = "/Ydb.KeyValue.V1.KeyValueService/DescribeVolume"
	KeyValueService_ListLocalPartitions_FullMethodName     = "/Ydb.KeyValue.V1.KeyValueService/ListLocalPartitions"
	KeyValueService_AcquireLock_FullMethodName             = "/Ydb.KeyValue.V1.KeyValueService/AcquireLock"
	KeyValueService_ExecuteTransaction_FullMethodName      = "/Ydb.KeyValue.V1.KeyValueService/ExecuteTransaction"
	KeyValueService_Read_FullMethodName                    = "/Ydb.KeyValue.V1.KeyValueService/Read"
	KeyValueService_ReadRange_FullMethodName               = "/Ydb.KeyValue.V1.KeyValueService/ReadRange"
	KeyValueService_ListRange_FullMethodName               = "/Ydb.KeyValue.V1.KeyValueService/ListRange"
	KeyValueService_GetStorageChannelStatus_FullMethodName = "/Ydb.KeyValue.V1.KeyValueService/GetStorageChannelStatus"
)

Variables

var File_draft_ydb_keyvalue_v1_proto protoreflect.FileDescriptor
var KeyValueService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "Ydb.KeyValue.V1.KeyValueService",
	HandlerType: (*KeyValueServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateVolume",
			Handler:    _KeyValueService_CreateVolume_Handler,
		},
		{
			MethodName: "DropVolume",
			Handler:    _KeyValueService_DropVolume_Handler,
		},
		{
			MethodName: "AlterVolume",
			Handler:    _KeyValueService_AlterVolume_Handler,
		},
		{
			MethodName: "DescribeVolume",
			Handler:    _KeyValueService_DescribeVolume_Handler,
		},
		{
			MethodName: "ListLocalPartitions",
			Handler:    _KeyValueService_ListLocalPartitions_Handler,
		},
		{
			MethodName: "AcquireLock",
			Handler:    _KeyValueService_AcquireLock_Handler,
		},
		{
			MethodName: "ExecuteTransaction",
			Handler:    _KeyValueService_ExecuteTransaction_Handler,
		},
		{
			MethodName: "Read",
			Handler:    _KeyValueService_Read_Handler,
		},
		{
			MethodName: "ReadRange",
			Handler:    _KeyValueService_ReadRange_Handler,
		},
		{
			MethodName: "ListRange",
			Handler:    _KeyValueService_ListRange_Handler,
		},
		{
			MethodName: "GetStorageChannelStatus",
			Handler:    _KeyValueService_GetStorageChannelStatus_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "draft/ydb_keyvalue_v1.proto",
}

KeyValueService_ServiceDesc is the grpc.ServiceDesc for KeyValueService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterKeyValueServiceServer

func RegisterKeyValueServiceServer(s grpc.ServiceRegistrar, srv KeyValueServiceServer)

Types

type KeyValueServiceClient

type KeyValueServiceClient interface {
	// Create a volume by path and partition count
	CreateVolume(ctx context.Context, in *Ydb_KeyValue.CreateVolumeRequest, opts ...grpc.CallOption) (*Ydb_KeyValue.CreateVolumeResponse, error)
	// Drop the volume by path
	DropVolume(ctx context.Context, in *Ydb_KeyValue.DropVolumeRequest, opts ...grpc.CallOption) (*Ydb_KeyValue.DropVolumeResponse, error)
	// Alter the volume by path
	AlterVolume(ctx context.Context, in *Ydb_KeyValue.AlterVolumeRequest, opts ...grpc.CallOption) (*Ydb_KeyValue.AlterVolumeResponse, error)
	// Describe the volume by path
	DescribeVolume(ctx context.Context, in *Ydb_KeyValue.DescribeVolumeRequest, opts ...grpc.CallOption) (*Ydb_KeyValue.DescribeVolumeResponse, error)
	// List partitions of a volume at the local node.
	ListLocalPartitions(ctx context.Context, in *Ydb_KeyValue.ListLocalPartitionsRequest, opts ...grpc.CallOption) (*Ydb_KeyValue.ListLocalPartitionsResponse, error)
	// Acquire an exclusive lock for the partition.
	AcquireLock(ctx context.Context, in *Ydb_KeyValue.AcquireLockRequest, opts ...grpc.CallOption) (*Ydb_KeyValue.AcquireLockResponse, error)
	// Perform list of commands to modify the state of the partition as an atomic transaction.
	ExecuteTransaction(ctx context.Context, in *Ydb_KeyValue.ExecuteTransactionRequest, opts ...grpc.CallOption) (*Ydb_KeyValue.ExecuteTransactionResponse, error)
	// Read the value stored in the item with the key specified.
	Read(ctx context.Context, in *Ydb_KeyValue.ReadRequest, opts ...grpc.CallOption) (*Ydb_KeyValue.ReadResponse, error)
	// Read items with keys in the specified range.
	ReadRange(ctx context.Context, in *Ydb_KeyValue.ReadRangeRequest, opts ...grpc.CallOption) (*Ydb_KeyValue.ReadRangeResponse, error)
	// List keys and metadata of items with keys in the specified range.
	ListRange(ctx context.Context, in *Ydb_KeyValue.ListRangeRequest, opts ...grpc.CallOption) (*Ydb_KeyValue.ListRangeResponse, error)
	// Get storage channel status of the partition.
	GetStorageChannelStatus(ctx context.Context, in *Ydb_KeyValue.GetStorageChannelStatusRequest, opts ...grpc.CallOption) (*Ydb_KeyValue.GetStorageChannelStatusResponse, error)
}

KeyValueServiceClient is the client API for KeyValueService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewKeyValueServiceClient

func NewKeyValueServiceClient(cc grpc.ClientConnInterface) KeyValueServiceClient

type KeyValueServiceServer

type KeyValueServiceServer interface {
	// Create a volume by path and partition count
	CreateVolume(context.Context, *Ydb_KeyValue.CreateVolumeRequest) (*Ydb_KeyValue.CreateVolumeResponse, error)
	// Drop the volume by path
	DropVolume(context.Context, *Ydb_KeyValue.DropVolumeRequest) (*Ydb_KeyValue.DropVolumeResponse, error)
	// Alter the volume by path
	AlterVolume(context.Context, *Ydb_KeyValue.AlterVolumeRequest) (*Ydb_KeyValue.AlterVolumeResponse, error)
	// Describe the volume by path
	DescribeVolume(context.Context, *Ydb_KeyValue.DescribeVolumeRequest) (*Ydb_KeyValue.DescribeVolumeResponse, error)
	// List partitions of a volume at the local node.
	ListLocalPartitions(context.Context, *Ydb_KeyValue.ListLocalPartitionsRequest) (*Ydb_KeyValue.ListLocalPartitionsResponse, error)
	// Acquire an exclusive lock for the partition.
	AcquireLock(context.Context, *Ydb_KeyValue.AcquireLockRequest) (*Ydb_KeyValue.AcquireLockResponse, error)
	// Perform list of commands to modify the state of the partition as an atomic transaction.
	ExecuteTransaction(context.Context, *Ydb_KeyValue.ExecuteTransactionRequest) (*Ydb_KeyValue.ExecuteTransactionResponse, error)
	// Read the value stored in the item with the key specified.
	Read(context.Context, *Ydb_KeyValue.ReadRequest) (*Ydb_KeyValue.ReadResponse, error)
	// Read items with keys in the specified range.
	ReadRange(context.Context, *Ydb_KeyValue.ReadRangeRequest) (*Ydb_KeyValue.ReadRangeResponse, error)
	// List keys and metadata of items with keys in the specified range.
	ListRange(context.Context, *Ydb_KeyValue.ListRangeRequest) (*Ydb_KeyValue.ListRangeResponse, error)
	// Get storage channel status of the partition.
	GetStorageChannelStatus(context.Context, *Ydb_KeyValue.GetStorageChannelStatusRequest) (*Ydb_KeyValue.GetStorageChannelStatusResponse, error)
	// contains filtered or unexported methods
}

KeyValueServiceServer is the server API for KeyValueService service. All implementations must embed UnimplementedKeyValueServiceServer for forward compatibility

type UnimplementedKeyValueServiceServer

type UnimplementedKeyValueServiceServer struct {
}

UnimplementedKeyValueServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedKeyValueServiceServer) AcquireLock

func (UnimplementedKeyValueServiceServer) AlterVolume

func (UnimplementedKeyValueServiceServer) CreateVolume

func (UnimplementedKeyValueServiceServer) DescribeVolume

func (UnimplementedKeyValueServiceServer) DropVolume

func (UnimplementedKeyValueServiceServer) ExecuteTransaction

func (UnimplementedKeyValueServiceServer) GetStorageChannelStatus

func (UnimplementedKeyValueServiceServer) ListLocalPartitions

func (UnimplementedKeyValueServiceServer) ListRange

func (UnimplementedKeyValueServiceServer) Read

func (UnimplementedKeyValueServiceServer) ReadRange

type UnsafeKeyValueServiceServer

type UnsafeKeyValueServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeKeyValueServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to KeyValueServiceServer will result in compilation errors.

Source Files

ydb_keyvalue_v1.pb.go ydb_keyvalue_v1_grpc.pb.go

Version
v0.0.0-20241112172322-ea1f63298f77 (latest)
Published
Nov 12, 2024
Platform
linux/amd64
Imports
8 packages
Last checked
4 weeks ago

Tools for package owners.