package Ydb_KeyValue_V1
import "github.com/ydb-platform/ydb-go-genproto/draft/Ydb_KeyValue_V1"
Index ¶
- Constants
- Variables
- func RegisterKeyValueServiceServer(s grpc.ServiceRegistrar, srv KeyValueServiceServer)
- type KeyValueServiceClient
- type KeyValueServiceServer
- type UnimplementedKeyValueServiceServer
- func (UnimplementedKeyValueServiceServer) AcquireLock(context.Context, *Ydb_KeyValue.AcquireLockRequest) (*Ydb_KeyValue.AcquireLockResponse, error)
- func (UnimplementedKeyValueServiceServer) AlterVolume(context.Context, *Ydb_KeyValue.AlterVolumeRequest) (*Ydb_KeyValue.AlterVolumeResponse, error)
- func (UnimplementedKeyValueServiceServer) CreateVolume(context.Context, *Ydb_KeyValue.CreateVolumeRequest) (*Ydb_KeyValue.CreateVolumeResponse, error)
- func (UnimplementedKeyValueServiceServer) DescribeVolume(context.Context, *Ydb_KeyValue.DescribeVolumeRequest) (*Ydb_KeyValue.DescribeVolumeResponse, error)
- func (UnimplementedKeyValueServiceServer) DropVolume(context.Context, *Ydb_KeyValue.DropVolumeRequest) (*Ydb_KeyValue.DropVolumeResponse, error)
- func (UnimplementedKeyValueServiceServer) ExecuteTransaction(context.Context, *Ydb_KeyValue.ExecuteTransactionRequest) (*Ydb_KeyValue.ExecuteTransactionResponse, error)
- func (UnimplementedKeyValueServiceServer) GetStorageChannelStatus(context.Context, *Ydb_KeyValue.GetStorageChannelStatusRequest) (*Ydb_KeyValue.GetStorageChannelStatusResponse, error)
- func (UnimplementedKeyValueServiceServer) ListLocalPartitions(context.Context, *Ydb_KeyValue.ListLocalPartitionsRequest) (*Ydb_KeyValue.ListLocalPartitionsResponse, error)
- func (UnimplementedKeyValueServiceServer) ListRange(context.Context, *Ydb_KeyValue.ListRangeRequest) (*Ydb_KeyValue.ListRangeResponse, error)
- func (UnimplementedKeyValueServiceServer) Read(context.Context, *Ydb_KeyValue.ReadRequest) (*Ydb_KeyValue.ReadResponse, error)
- func (UnimplementedKeyValueServiceServer) ReadRange(context.Context, *Ydb_KeyValue.ReadRangeRequest) (*Ydb_KeyValue.ReadRangeResponse, error)
- type UnsafeKeyValueServiceServer
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) 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 ¶
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.