Documentation
¶
Index ¶
Constants ¶
View Source
const ( KV_Get_FullMethodName = "/proto.KV/Get" KV_Put_FullMethodName = "/proto.KV/Put" )
Variables ¶
View Source
var File_proto_kv_proto protoreflect.FileDescriptor
View Source
var KV_ServiceDesc = grpc.ServiceDesc{ ServiceName: "proto.KV", HandlerType: (*KVServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Get", Handler: _KV_Get_Handler, }, { MethodName: "Put", Handler: _KV_Put_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "proto/kv.proto", }
KV_ServiceDesc is the grpc.ServiceDesc for KV service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterKVServer ¶
func RegisterKVServer(s grpc.ServiceRegistrar, srv KVServer)
Types ¶
type Empty ¶
type Empty struct {
// contains filtered or unexported fields
}
func (*Empty) Descriptor
deprecated
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) ProtoReflect ¶ added in v1.6.0
func (x *Empty) ProtoReflect() protoreflect.Message
type GetRequest ¶
type GetRequest struct {
Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
// contains filtered or unexported fields
}
func (*GetRequest) Descriptor
deprecated
func (*GetRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.
func (*GetRequest) GetKey ¶
func (x *GetRequest) GetKey() string
func (*GetRequest) ProtoMessage ¶
func (*GetRequest) ProtoMessage()
func (*GetRequest) ProtoReflect ¶ added in v1.6.0
func (x *GetRequest) ProtoReflect() protoreflect.Message
func (*GetRequest) Reset ¶
func (x *GetRequest) Reset()
func (*GetRequest) String ¶
func (x *GetRequest) String() string
type GetResponse ¶
type GetResponse struct {
Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
// contains filtered or unexported fields
}
func (*GetResponse) Descriptor
deprecated
func (*GetResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.
func (*GetResponse) GetValue ¶
func (x *GetResponse) GetValue() []byte
func (*GetResponse) ProtoMessage ¶
func (*GetResponse) ProtoMessage()
func (*GetResponse) ProtoReflect ¶ added in v1.6.0
func (x *GetResponse) ProtoReflect() protoreflect.Message
func (*GetResponse) Reset ¶
func (x *GetResponse) Reset()
func (*GetResponse) String ¶
func (x *GetResponse) String() string
type KVClient ¶
type KVClient interface {
Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*Empty, error)
}
KVClient is the client API for KV 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 NewKVClient ¶
func NewKVClient(cc grpc.ClientConnInterface) KVClient
type KVServer ¶
type KVServer interface {
Get(context.Context, *GetRequest) (*GetResponse, error)
Put(context.Context, *PutRequest) (*Empty, error)
}
KVServer is the server API for KV service. All implementations should embed UnimplementedKVServer for forward compatibility
type PutRequest ¶
type PutRequest struct {
Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
// contains filtered or unexported fields
}
func (*PutRequest) Descriptor
deprecated
func (*PutRequest) Descriptor() ([]byte, []int)
Deprecated: Use PutRequest.ProtoReflect.Descriptor instead.
func (*PutRequest) GetKey ¶
func (x *PutRequest) GetKey() string
func (*PutRequest) GetValue ¶
func (x *PutRequest) GetValue() []byte
func (*PutRequest) ProtoMessage ¶
func (*PutRequest) ProtoMessage()
func (*PutRequest) ProtoReflect ¶ added in v1.6.0
func (x *PutRequest) ProtoReflect() protoreflect.Message
func (*PutRequest) Reset ¶
func (x *PutRequest) Reset()
func (*PutRequest) String ¶
func (x *PutRequest) String() string
type UnimplementedKVServer ¶ added in v1.6.0
type UnimplementedKVServer struct {
}
UnimplementedKVServer should be embedded to have forward compatible implementations.
func (UnimplementedKVServer) Get ¶ added in v1.6.0
func (UnimplementedKVServer) Get(context.Context, *GetRequest) (*GetResponse, error)
func (UnimplementedKVServer) Put ¶ added in v1.6.0
func (UnimplementedKVServer) Put(context.Context, *PutRequest) (*Empty, error)
type UnsafeKVServer ¶ added in v1.6.0
type UnsafeKVServer interface {
// contains filtered or unexported methods
}
UnsafeKVServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to KVServer will result in compilation errors.
Source Files
Click to show internal directories.
Click to hide internal directories.