lbGrpc

Documentation

Index

• Variables
• func RegisterLbServerServer(s grpc.ServiceRegistrar, srv LbServerServer)
• type EmptyReq
  • func (*EmptyReq) Descriptor() ([]byte, []int)
  • func (*EmptyReq) ProtoMessage()
  • func (x *EmptyReq) ProtoReflect() protoreflect.Message
  • func (x *EmptyReq) Reset()
  • func (x *EmptyReq) String() string
• type LbServerClient
  • func NewLbServerClient(cc grpc.ClientConnInterface) LbServerClient
• type LbServerServer
• type TaskBasicImf
  • func (*TaskBasicImf) Descriptor() ([]byte, []int)
  • func (x *TaskBasicImf) GetCommand() string
  • func (x *TaskBasicImf) GetRetrynum() int32
  • 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
  • func (UnimplementedLbServerServer) GetTask(context.Context, *TaskBasicImf) (*EmptyReq, error)
• type UnsafeLbServerServer

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,
		},
	},
	Streams:  []grpc.StreamDesc{},
	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

func (*EmptyReq) Descriptor() ([]byte, []int)

Deprecated: Use EmptyReq.ProtoReflect.Descriptor instead.

func (*EmptyReq) ProtoMessage

func (*EmptyReq) ProtoMessage()

func (*EmptyReq) ProtoReflect

func (x *EmptyReq) ProtoReflect() protoreflect.Message

func (*EmptyReq) Reset

func (x *EmptyReq) Reset()

func (*EmptyReq) String

func (x *EmptyReq) String() string

type LbServerClient

type LbServerClient interface {
	GetTask(ctx context.Context, in *TaskBasicImf, 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)
}

LbServerServer is the server API for LbServer service. All implementations should embed UnimplementedLbServerServer for forward compatibility

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"`
	Retrynum *int32  `protobuf:"varint,5,opt,name=retrynum,proto3,oneof" json:"retrynum,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskBasicImf) Descriptor

func (*TaskBasicImf) Descriptor() ([]byte, []int)

Deprecated: Use TaskBasicImf.ProtoReflect.Descriptor instead.

func (*TaskBasicImf) GetCommand

func (x *TaskBasicImf) GetCommand() string

func (*TaskBasicImf) GetRetrynum

func (x *TaskBasicImf) GetRetrynum() int32

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)

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.