Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterGalaxyCacheServer(s grpc.ServiceRegistrar, srv GalaxyCacheServer)
- type GalaxyCacheClient
- type GalaxyCacheServer
- type GetRequest
- type GetResponse
- func (*GetResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetResponse) GetMinuteQps() float64
- func (x *GetResponse) GetValue() []byte
- func (*GetResponse) ProtoMessage()
- func (x *GetResponse) ProtoReflect() protoreflect.Message
- func (x *GetResponse) Reset()
- func (x *GetResponse) String() string
- type UnimplementedGalaxyCacheServer
- type UnsafeGalaxyCacheServer
Constants ¶
const (
GalaxyCache_GetFromPeer_FullMethodName = "/galaxycachepb.GalaxyCache/GetFromPeer"
)
Variables ¶
var File_galaxycachepb_galaxycache_proto protoreflect.FileDescriptor
var GalaxyCache_ServiceDesc = grpc.ServiceDesc{ ServiceName: "galaxycachepb.GalaxyCache", HandlerType: (*GalaxyCacheServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetFromPeer", Handler: _GalaxyCache_GetFromPeer_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "galaxycachepb/galaxycache.proto", }
GalaxyCache_ServiceDesc is the grpc.ServiceDesc for GalaxyCache service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterGalaxyCacheServer ¶
func RegisterGalaxyCacheServer(s grpc.ServiceRegistrar, srv GalaxyCacheServer)
Types ¶
type GalaxyCacheClient ¶
type GalaxyCacheClient interface {
GetFromPeer(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
}
GalaxyCacheClient is the client API for GalaxyCache 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 NewGalaxyCacheClient ¶
func NewGalaxyCacheClient(cc grpc.ClientConnInterface) GalaxyCacheClient
type GalaxyCacheServer ¶
type GalaxyCacheServer interface {
GetFromPeer(context.Context, *GetRequest) (*GetResponse, error)
// contains filtered or unexported methods
}
GalaxyCacheServer is the server API for GalaxyCache service. All implementations must embed UnimplementedGalaxyCacheServer for forward compatibility
type GetRequest ¶
type GetRequest struct {
Galaxy string `protobuf:"bytes,1,opt,name=galaxy,proto3" json:"galaxy,omitempty"`
Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` // not required/guaranteed to be UTF-8
// contains filtered or unexported fields
}
func (*GetRequest) Descriptor
deprecated
func (*GetRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.
func (*GetRequest) GetGalaxy ¶
func (x *GetRequest) GetGalaxy() string
func (*GetRequest) GetKey ¶
func (x *GetRequest) GetKey() []byte
func (*GetRequest) ProtoMessage ¶
func (*GetRequest) ProtoMessage()
func (*GetRequest) ProtoReflect ¶ added in v1.0.2
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"`
MinuteQps float64 `protobuf:"fixed64,2,opt,name=minute_qps,json=minuteQps,proto3" json:"minute_qps,omitempty"`
// contains filtered or unexported fields
}
func (*GetResponse) Descriptor
deprecated
func (*GetResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.
func (*GetResponse) GetMinuteQps ¶
func (x *GetResponse) GetMinuteQps() float64
func (*GetResponse) GetValue ¶
func (x *GetResponse) GetValue() []byte
func (*GetResponse) ProtoMessage ¶
func (*GetResponse) ProtoMessage()
func (*GetResponse) ProtoReflect ¶ added in v1.0.2
func (x *GetResponse) ProtoReflect() protoreflect.Message
func (*GetResponse) Reset ¶
func (x *GetResponse) Reset()
func (*GetResponse) String ¶
func (x *GetResponse) String() string
type UnimplementedGalaxyCacheServer ¶ added in v1.0.2
type UnimplementedGalaxyCacheServer struct {
}
UnimplementedGalaxyCacheServer must be embedded to have forward compatible implementations.
func (UnimplementedGalaxyCacheServer) GetFromPeer ¶ added in v1.0.2
func (UnimplementedGalaxyCacheServer) GetFromPeer(context.Context, *GetRequest) (*GetResponse, error)
type UnsafeGalaxyCacheServer ¶ added in v1.0.2
type UnsafeGalaxyCacheServer interface {
// contains filtered or unexported methods
}
UnsafeGalaxyCacheServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to GalaxyCacheServer will result in compilation errors.
Source Files