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 LbServer_GetTaskByStreamClient
• type LbServer_GetTaskByStreamServer
• type TaskBasicImf
  • func (*TaskBasicImf) Descriptor() ([]byte, []int)
  • 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
  • func (UnimplementedLbServerServer) GetTask(context.Context, *TaskBasicImf) (*EmptyReq, error)
  • func (UnimplementedLbServerServer) GetTaskByStream(LbServer_GetTaskByStreamServer) error
  • func (UnimplementedLbServerServer) HelloLb(context.Context, *EmptyReq) (*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,
		},
		{
			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

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)
	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

type LbServer_GetTaskByStreamClient interface {
	Send(*TaskBasicImf) error
	CloseAndRecv() (*EmptyReq, error)
	grpc.ClientStream
}

type LbServer_GetTaskByStreamServer

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

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

Deprecated: Use TaskBasicImf.ProtoReflect.Descriptor instead.

func (*TaskBasicImf) GetCommand

func (x *TaskBasicImf) GetCommand() string

func (*TaskBasicImf) GetMaxhop

func (x *TaskBasicImf) GetMaxhop() int32

func (*TaskBasicImf) GetPrenodeIp

func (x *TaskBasicImf) GetPrenodeIp() string

func (*TaskBasicImf) GetSubmittime

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

func (UnimplementedLbServerServer) GetTaskByStream(LbServer_GetTaskByStreamServer) error

func (UnimplementedLbServerServer) HelloLb

func (UnimplementedLbServerServer) HelloLb(context.Context, *EmptyReq) (*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.