Documentation ¶
Index ¶
- Variables
- func RegisterGcsGrpcServer(s grpc.ServiceRegistrar, srv GcsGrpcServer)
- type AllNodes
- type EmptyReq
- type GcsGrpcClient
- type GcsGrpcServer
- type NbhInfo
- func (*NbhInfo) Descriptor() ([]byte, []int)deprecated
- func (x *NbhInfo) GetAddr() string
- func (x *NbhInfo) GetCpu() float32
- func (x *NbhInfo) GetQueuenum() int32
- func (x *NbhInfo) GetRam() float32
- func (x *NbhInfo) GetTimestamp() int64
- func (x *NbhInfo) GetVisitnum() int32
- func (*NbhInfo) ProtoMessage()
- func (x *NbhInfo) ProtoReflect() protoreflect.Message
- func (x *NbhInfo) Reset()
- func (x *NbhInfo) String() string
- type Nbhnodes
- type OnlyAddr
- type UnimplementedGcsGrpcServer
- type UnsafeGcsGrpcServer
Constants ¶
This section is empty.
Variables ¶
var File_gcsServer_proto protoreflect.FileDescriptor
var GcsGrpc_ServiceDesc = grpc.ServiceDesc{ ServiceName: "gcsServer.GcsGrpc", HandlerType: (*GcsGrpcServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetNbh", Handler: _GcsGrpc_GetNbh_Handler, }, { MethodName: "GetAllNodes", Handler: _GcsGrpc_GetAllNodes_Handler, }, { MethodName: "GetOnlyAddr", Handler: _GcsGrpc_GetOnlyAddr_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "gcsServer.proto", }
GcsGrpc_ServiceDesc is the grpc.ServiceDesc for GcsGrpc service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterGcsGrpcServer ¶
func RegisterGcsGrpcServer(s grpc.ServiceRegistrar, srv GcsGrpcServer)
Types ¶
type AllNodes ¶
type AllNodes struct { Nbh []*NbhInfo `protobuf:"bytes,1,rep,name=nbh,proto3" json:"nbh,omitempty"` // contains filtered or unexported fields }
func (*AllNodes) Descriptor
deprecated
func (*AllNodes) ProtoMessage ¶
func (*AllNodes) ProtoMessage()
func (*AllNodes) ProtoReflect ¶
func (x *AllNodes) ProtoReflect() protoreflect.Message
type EmptyReq ¶
type EmptyReq struct {
// contains filtered or unexported fields
}
func (*EmptyReq) Descriptor
deprecated
func (*EmptyReq) ProtoMessage ¶
func (*EmptyReq) ProtoMessage()
func (*EmptyReq) ProtoReflect ¶
func (x *EmptyReq) ProtoReflect() protoreflect.Message
type GcsGrpcClient ¶
type GcsGrpcClient interface { GetNbh(ctx context.Context, in *EmptyReq, opts ...grpc.CallOption) (*Nbhnodes, error) GetAllNodes(ctx context.Context, in *EmptyReq, opts ...grpc.CallOption) (*AllNodes, error) GetOnlyAddr(ctx context.Context, in *EmptyReq, opts ...grpc.CallOption) (*OnlyAddr, error) }
GcsGrpcClient is the client API for GcsGrpc 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 NewGcsGrpcClient ¶
func NewGcsGrpcClient(cc grpc.ClientConnInterface) GcsGrpcClient
type GcsGrpcServer ¶
type GcsGrpcServer interface { GetNbh(context.Context, *EmptyReq) (*Nbhnodes, error) GetAllNodes(context.Context, *EmptyReq) (*AllNodes, error) GetOnlyAddr(context.Context, *EmptyReq) (*OnlyAddr, error) }
GcsGrpcServer is the server API for GcsGrpc service. All implementations should embed UnimplementedGcsGrpcServer for forward compatibility
type NbhInfo ¶
type NbhInfo struct { Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"` Cpu float32 `protobuf:"fixed32,2,opt,name=cpu,proto3" json:"cpu,omitempty"` Ram float32 `protobuf:"fixed32,3,opt,name=ram,proto3" json:"ram,omitempty"` Queuenum int32 `protobuf:"varint,4,opt,name=queuenum,proto3" json:"queuenum,omitempty"` Visitnum int32 `protobuf:"varint,5,opt,name=visitnum,proto3" json:"visitnum,omitempty"` Timestamp int64 `protobuf:"varint,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // contains filtered or unexported fields }
func (*NbhInfo) Descriptor
deprecated
func (*NbhInfo) GetQueuenum ¶
func (*NbhInfo) GetTimestamp ¶
func (*NbhInfo) GetVisitnum ¶
func (*NbhInfo) ProtoMessage ¶
func (*NbhInfo) ProtoMessage()
func (*NbhInfo) ProtoReflect ¶
func (x *NbhInfo) ProtoReflect() protoreflect.Message
type Nbhnodes ¶
type Nbhnodes struct { Nbh []*NbhInfo `protobuf:"bytes,1,rep,name=nbh,proto3" json:"nbh,omitempty"` // contains filtered or unexported fields }
func (*Nbhnodes) Descriptor
deprecated
func (*Nbhnodes) ProtoMessage ¶
func (*Nbhnodes) ProtoMessage()
func (*Nbhnodes) ProtoReflect ¶
func (x *Nbhnodes) ProtoReflect() protoreflect.Message
type OnlyAddr ¶
type OnlyAddr struct { Addr []string `protobuf:"bytes,1,rep,name=addr,proto3" json:"addr,omitempty"` // contains filtered or unexported fields }
func (*OnlyAddr) Descriptor
deprecated
func (*OnlyAddr) ProtoMessage ¶
func (*OnlyAddr) ProtoMessage()
func (*OnlyAddr) ProtoReflect ¶
func (x *OnlyAddr) ProtoReflect() protoreflect.Message
type UnimplementedGcsGrpcServer ¶
type UnimplementedGcsGrpcServer struct { }
UnimplementedGcsGrpcServer should be embedded to have forward compatible implementations.
func (UnimplementedGcsGrpcServer) GetAllNodes ¶
func (UnimplementedGcsGrpcServer) GetOnlyAddr ¶
type UnsafeGcsGrpcServer ¶
type UnsafeGcsGrpcServer interface {
// contains filtered or unexported methods
}
UnsafeGcsGrpcServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to GcsGrpcServer will result in compilation errors.