Ydb_KeyValue_V1

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

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

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

Documentation

Index

Constants

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

View Source 
var File_draft_ydb_keyvalue_v1_proto protoreflect.FileDescriptor
View Source 
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) AcquireLock(context.Context, *Ydb_KeyValue.AcquireLockRequest) (*Ydb_KeyValue.AcquireLockResponse, error)

func (UnimplementedKeyValueServiceServer) AlterVolume 

func (UnimplementedKeyValueServiceServer) AlterVolume(context.Context, *Ydb_KeyValue.AlterVolumeRequest) (*Ydb_KeyValue.AlterVolumeResponse, error)

func (UnimplementedKeyValueServiceServer) CreateVolume 

func (UnimplementedKeyValueServiceServer) CreateVolume(context.Context, *Ydb_KeyValue.CreateVolumeRequest) (*Ydb_KeyValue.CreateVolumeResponse, error)

func (UnimplementedKeyValueServiceServer) DescribeVolume 

func (UnimplementedKeyValueServiceServer) DescribeVolume(context.Context, *Ydb_KeyValue.DescribeVolumeRequest) (*Ydb_KeyValue.DescribeVolumeResponse, error)

func (UnimplementedKeyValueServiceServer) DropVolume 

func (UnimplementedKeyValueServiceServer) DropVolume(context.Context, *Ydb_KeyValue.DropVolumeRequest) (*Ydb_KeyValue.DropVolumeResponse, error)

func (UnimplementedKeyValueServiceServer) ExecuteTransaction 

func (UnimplementedKeyValueServiceServer) ExecuteTransaction(context.Context, *Ydb_KeyValue.ExecuteTransactionRequest) (*Ydb_KeyValue.ExecuteTransactionResponse, error)

func (UnimplementedKeyValueServiceServer) GetStorageChannelStatus 

func (UnimplementedKeyValueServiceServer) GetStorageChannelStatus(context.Context, *Ydb_KeyValue.GetStorageChannelStatusRequest) (*Ydb_KeyValue.GetStorageChannelStatusResponse, error)

func (UnimplementedKeyValueServiceServer) ListLocalPartitions 

func (UnimplementedKeyValueServiceServer) ListLocalPartitions(context.Context, *Ydb_KeyValue.ListLocalPartitionsRequest) (*Ydb_KeyValue.ListLocalPartitionsResponse, error)

func (UnimplementedKeyValueServiceServer) ListRange 

func (UnimplementedKeyValueServiceServer) ListRange(context.Context, *Ydb_KeyValue.ListRangeRequest) (*Ydb_KeyValue.ListRangeResponse, error)

func (UnimplementedKeyValueServiceServer) Read 

func (UnimplementedKeyValueServiceServer) Read(context.Context, *Ydb_KeyValue.ReadRequest) (*Ydb_KeyValue.ReadResponse, error)

func (UnimplementedKeyValueServiceServer) ReadRange 

func (UnimplementedKeyValueServiceServer) ReadRange(context.Context, *Ydb_KeyValue.ReadRangeRequest) (*Ydb_KeyValue.ReadRangeResponse, error)

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

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.