Documentation ¶
Index ¶
- Variables
- func RegisterLbServerServer(s grpc.ServiceRegistrar, srv LbServerServer)
- type EmptyReq
- type LbServerClient
- type LbServerServer
- type LbServer_GetTaskByStreamClient
- type LbServer_GetTaskByStreamServer
- type TaskBasicImf
- func (*TaskBasicImf) Descriptor() ([]byte, []int)deprecated
- func (x *TaskBasicImf) GetCommand() string
- func (x *TaskBasicImf) GetMaxhop() int32
- func (x *TaskBasicImf) GetPrenodeIp() string
- func (x *TaskBasicImf) GetSubmittime() int64
- func (x *TaskBasicImf) GetTaskcpu() float32
- func (x *TaskBasicImf) GetTaskid() string
- func (x *TaskBasicImf) GetTaskram() float32
- func (*TaskBasicImf) ProtoMessage()
- func (x *TaskBasicImf) ProtoReflect() protoreflect.Message
- func (x *TaskBasicImf) Reset()
- func (x *TaskBasicImf) String() string
- type UnimplementedLbServerServer
- type UnsafeLbServerServer
Constants ¶
This section is empty.
Variables ¶
var File_lbServer_proto protoreflect.FileDescriptor
var LbServer_ServiceDesc = grpc.ServiceDesc{ ServiceName: "lbGrpc.lbServer", HandlerType: (*LbServerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetTask", Handler: _LbServer_GetTask_Handler, }, { MethodName: "HelloLb", Handler: _LbServer_HelloLb_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "GetTaskByStream", Handler: _LbServer_GetTaskByStream_Handler, ClientStreams: true, }, }, Metadata: "lbServer.proto", }
LbServer_ServiceDesc is the grpc.ServiceDesc for LbServer service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterLbServerServer ¶
func RegisterLbServerServer(s grpc.ServiceRegistrar, srv LbServerServer)
Types ¶
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 LbServerClient ¶
type LbServerClient interface { GetTask(ctx context.Context, in *TaskBasicImf, opts ...grpc.CallOption) (*EmptyReq, error) GetTaskByStream(ctx context.Context, opts ...grpc.CallOption) (LbServer_GetTaskByStreamClient, error) HelloLb(ctx context.Context, in *EmptyReq, opts ...grpc.CallOption) (*EmptyReq, error) }
LbServerClient is the client API for LbServer 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 NewLbServerClient ¶
func NewLbServerClient(cc grpc.ClientConnInterface) LbServerClient
type LbServerServer ¶
type LbServerServer interface { GetTask(context.Context, *TaskBasicImf) (*EmptyReq, error) GetTaskByStream(LbServer_GetTaskByStreamServer) error HelloLb(context.Context, *EmptyReq) (*EmptyReq, error) }
LbServerServer is the server API for LbServer service. All implementations should embed UnimplementedLbServerServer for forward compatibility
type LbServer_GetTaskByStreamClient ¶ added in v0.1.10
type LbServer_GetTaskByStreamClient interface { Send(*TaskBasicImf) error CloseAndRecv() (*EmptyReq, error) grpc.ClientStream }
type LbServer_GetTaskByStreamServer ¶ added in v0.1.10
type LbServer_GetTaskByStreamServer interface { SendAndClose(*EmptyReq) error Recv() (*TaskBasicImf, error) grpc.ServerStream }
type TaskBasicImf ¶
type TaskBasicImf struct { Taskid string `protobuf:"bytes,1,opt,name=taskid,proto3" json:"taskid,omitempty"` Taskram float32 `protobuf:"fixed32,2,opt,name=taskram,proto3" json:"taskram,omitempty"` Taskcpu float32 `protobuf:"fixed32,3,opt,name=taskcpu,proto3" json:"taskcpu,omitempty"` Command string `protobuf:"bytes,4,opt,name=command,proto3" json:"command,omitempty"` Submittime int64 `protobuf:"varint,5,opt,name=submittime,proto3" json:"submittime,omitempty"` PrenodeIp string `protobuf:"bytes,6,opt,name=prenodeIp,proto3" json:"prenodeIp,omitempty"` Maxhop int32 `protobuf:"varint,7,opt,name=maxhop,proto3" json:"maxhop,omitempty"` // contains filtered or unexported fields }
func (*TaskBasicImf) Descriptor
deprecated
func (*TaskBasicImf) Descriptor() ([]byte, []int)
Deprecated: Use TaskBasicImf.ProtoReflect.Descriptor instead.
func (*TaskBasicImf) GetCommand ¶
func (x *TaskBasicImf) GetCommand() string
func (*TaskBasicImf) GetMaxhop ¶ added in v0.1.8
func (x *TaskBasicImf) GetMaxhop() int32
func (*TaskBasicImf) GetPrenodeIp ¶ added in v0.1.5
func (x *TaskBasicImf) GetPrenodeIp() string
func (*TaskBasicImf) GetSubmittime ¶ added in v0.1.5
func (x *TaskBasicImf) GetSubmittime() int64
func (*TaskBasicImf) GetTaskcpu ¶
func (x *TaskBasicImf) GetTaskcpu() float32
func (*TaskBasicImf) GetTaskid ¶
func (x *TaskBasicImf) GetTaskid() string
func (*TaskBasicImf) GetTaskram ¶
func (x *TaskBasicImf) GetTaskram() float32
func (*TaskBasicImf) ProtoMessage ¶
func (*TaskBasicImf) ProtoMessage()
func (*TaskBasicImf) ProtoReflect ¶
func (x *TaskBasicImf) ProtoReflect() protoreflect.Message
func (*TaskBasicImf) Reset ¶
func (x *TaskBasicImf) Reset()
func (*TaskBasicImf) String ¶
func (x *TaskBasicImf) String() string
type UnimplementedLbServerServer ¶
type UnimplementedLbServerServer struct { }
UnimplementedLbServerServer should be embedded to have forward compatible implementations.
func (UnimplementedLbServerServer) GetTask ¶
func (UnimplementedLbServerServer) GetTask(context.Context, *TaskBasicImf) (*EmptyReq, error)
func (UnimplementedLbServerServer) GetTaskByStream ¶ added in v0.1.10
func (UnimplementedLbServerServer) GetTaskByStream(LbServer_GetTaskByStreamServer) error
type UnsafeLbServerServer ¶
type UnsafeLbServerServer interface {
// contains filtered or unexported methods
}
UnsafeLbServerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LbServerServer will result in compilation errors.