Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterKVStorageServer(s grpc.ServiceRegistrar, srv KVStorageServer)
- type DeleteResponse
- type KVStorageClient
- type KVStorageServer
- type KVStorage_GetClient
- type KVStorage_GetServer
- type KVStorage_PutClient
- type KVStorage_PutServer
- type UnimplementedKVStorageServer
- func (UnimplementedKVStorageServer) Delete(context.Context, *bytestream.ReadRequest) (*DeleteResponse, error)
- func (UnimplementedKVStorageServer) Get(*bytestream.ReadRequest, grpc.ServerStreamingServer[bytestream.ReadResponse]) error
- func (UnimplementedKVStorageServer) Put(grpc.ClientStreamingServer[bytestream.WriteRequest, bytestream.WriteResponse]) error
- type UnsafeKVStorageServer
Constants ¶
const ( KVStorage_Get_FullMethodName = "/kv_storage.KVStorage/Get" KVStorage_Put_FullMethodName = "/kv_storage.KVStorage/Put" KVStorage_Delete_FullMethodName = "/kv_storage.KVStorage/Delete" )
Variables ¶
var File_kv_storage_kv_storage_proto protoreflect.FileDescriptor
var KVStorage_ServiceDesc = grpc.ServiceDesc{ ServiceName: "kv_storage.KVStorage", HandlerType: (*KVStorageServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Delete", Handler: _KVStorage_Delete_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "Get", Handler: _KVStorage_Get_Handler, ServerStreams: true, }, { StreamName: "Put", Handler: _KVStorage_Put_Handler, ClientStreams: true, }, }, Metadata: "kv_storage/kv_storage.proto", }
KVStorage_ServiceDesc is the grpc.ServiceDesc for KVStorage service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterKVStorageServer ¶
func RegisterKVStorageServer(s grpc.ServiceRegistrar, srv KVStorageServer)
Types ¶
type DeleteResponse ¶
type DeleteResponse struct {
Ok uint32 `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
// contains filtered or unexported fields
}
func (*DeleteResponse) Descriptor
deprecated
func (*DeleteResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.
func (*DeleteResponse) GetOk ¶
func (x *DeleteResponse) GetOk() uint32
func (*DeleteResponse) ProtoMessage ¶
func (*DeleteResponse) ProtoMessage()
func (*DeleteResponse) ProtoReflect ¶
func (x *DeleteResponse) ProtoReflect() protoreflect.Message
func (*DeleteResponse) Reset ¶
func (x *DeleteResponse) Reset()
func (*DeleteResponse) String ¶
func (x *DeleteResponse) String() string
type KVStorageClient ¶
type KVStorageClient interface {
Get(ctx context.Context, in *bytestream.ReadRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[bytestream.ReadResponse], error)
Put(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[bytestream.WriteRequest, bytestream.WriteResponse], error)
Delete(ctx context.Context, in *bytestream.ReadRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
}
KVStorageClient is the client API for KVStorage 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 NewKVStorageClient ¶
func NewKVStorageClient(cc grpc.ClientConnInterface) KVStorageClient
type KVStorageServer ¶
type KVStorageServer interface {
Get(*bytestream.ReadRequest, grpc.ServerStreamingServer[bytestream.ReadResponse]) error
Put(grpc.ClientStreamingServer[bytestream.WriteRequest, bytestream.WriteResponse]) error
Delete(context.Context, *bytestream.ReadRequest) (*DeleteResponse, error)
// contains filtered or unexported methods
}
KVStorageServer is the server API for KVStorage service. All implementations must embed UnimplementedKVStorageServer for forward compatibility.
type KVStorage_GetClient ¶
type KVStorage_GetClient = grpc.ServerStreamingClient[bytestream.ReadResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type KVStorage_GetServer ¶
type KVStorage_GetServer = grpc.ServerStreamingServer[bytestream.ReadResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type KVStorage_PutClient ¶
type KVStorage_PutClient = grpc.ClientStreamingClient[bytestream.WriteRequest, bytestream.WriteResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type KVStorage_PutServer ¶
type KVStorage_PutServer = grpc.ClientStreamingServer[bytestream.WriteRequest, bytestream.WriteResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type UnimplementedKVStorageServer ¶
type UnimplementedKVStorageServer struct{}
UnimplementedKVStorageServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedKVStorageServer) Delete ¶
func (UnimplementedKVStorageServer) Delete(context.Context, *bytestream.ReadRequest) (*DeleteResponse, error)
type UnsafeKVStorageServer ¶
type UnsafeKVStorageServer interface {
// contains filtered or unexported methods
}
UnsafeKVStorageServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to KVStorageServer will result in compilation errors.
Source Files