worker

Documentation

Index

• Variables
• func RegisterWorkerServiceServer(s grpc.ServiceRegistrar, srv WorkerServiceServer)
• type GetWorkerListReq
  • func (*GetWorkerListReq) Descriptor() ([]byte, []int)
  • func (x *GetWorkerListReq) GetId() string
  • func (*GetWorkerListReq) ProtoMessage()
  • func (x *GetWorkerListReq) ProtoReflect() protoreflect.Message
  • func (x *GetWorkerListReq) Reset()
  • func (x *GetWorkerListReq) String() string
• type GetWorkerListRes
  • func (*GetWorkerListRes) Descriptor() ([]byte, []int)
  • func (x *GetWorkerListRes) GetWorker() []*worker.Worker
  • func (*GetWorkerListRes) ProtoMessage()
  • func (x *GetWorkerListRes) ProtoReflect() protoreflect.Message
  • func (x *GetWorkerListRes) Reset()
  • func (x *GetWorkerListRes) String() string
• type UnimplementedWorkerServiceServer
  • func (UnimplementedWorkerServiceServer) GetWorkerList(context.Context, *GetWorkerListReq) (*GetWorkerListRes, error)
  • func (UnimplementedWorkerServiceServer) UpdateWorkerStatus(context.Context, *UpdateWorkerStatusReq) (*UpdateWorkerStatusRes, error)
• type UnsafeWorkerServiceServer
• type UpdateWorkerStatusReq
  • func (*UpdateWorkerStatusReq) Descriptor() ([]byte, []int)
  • func (x *UpdateWorkerStatusReq) GetId() string
  • func (x *UpdateWorkerStatusReq) GetMsg() string
  • func (*UpdateWorkerStatusReq) ProtoMessage()
  • func (x *UpdateWorkerStatusReq) ProtoReflect() protoreflect.Message
  • func (x *UpdateWorkerStatusReq) Reset()
  • func (x *UpdateWorkerStatusReq) String() string
• type UpdateWorkerStatusRes
  • func (*UpdateWorkerStatusRes) Descriptor() ([]byte, []int)
  • func (*UpdateWorkerStatusRes) ProtoMessage()
  • func (x *UpdateWorkerStatusRes) ProtoReflect() protoreflect.Message
  • func (x *UpdateWorkerStatusRes) Reset()
  • func (x *UpdateWorkerStatusRes) String() string
• type WorkerServiceClient
  • func NewWorkerServiceClient(cc grpc.ClientConnInterface) WorkerServiceClient
• type WorkerServiceServer

Variables

var File_pb_svc_manager_worker_proto protoreflect.FileDescriptor

var WorkerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.svc.manager.worker.WorkerService",
	HandlerType: (*WorkerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetWorkerList",
			Handler:    _WorkerService_GetWorkerList_Handler,
		},
		{
			MethodName: "UpdateWorkerStatus",
			Handler:    _WorkerService_UpdateWorkerStatus_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pb/svc/manager/worker.proto",
}

WorkerService_ServiceDesc is the grpc.ServiceDesc for WorkerService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterWorkerServiceServer

func RegisterWorkerServiceServer(s grpc.ServiceRegistrar, srv WorkerServiceServer)

Types

type GetWorkerListReq

type GetWorkerListReq struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkerListReq) Descriptor

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

Deprecated: Use GetWorkerListReq.ProtoReflect.Descriptor instead.

func (*GetWorkerListReq) GetId

func (x *GetWorkerListReq) GetId() string

func (*GetWorkerListReq) ProtoMessage

func (*GetWorkerListReq) ProtoMessage()

func (*GetWorkerListReq) ProtoReflect

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

func (*GetWorkerListReq) Reset

func (x *GetWorkerListReq) Reset()

func (*GetWorkerListReq) String

func (x *GetWorkerListReq) String() string

type GetWorkerListRes

type GetWorkerListRes struct {
	Worker []*worker.Worker `protobuf:"bytes,1,rep,name=Worker,proto3" json:"Worker,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkerListRes) Descriptor

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

Deprecated: Use GetWorkerListRes.ProtoReflect.Descriptor instead.

func (*GetWorkerListRes) GetWorker

func (x *GetWorkerListRes) GetWorker() []*worker.Worker

func (*GetWorkerListRes) ProtoMessage

func (*GetWorkerListRes) ProtoMessage()

func (*GetWorkerListRes) ProtoReflect

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

func (*GetWorkerListRes) Reset

func (x *GetWorkerListRes) Reset()

func (*GetWorkerListRes) String

func (x *GetWorkerListRes) String() string

type UnimplementedWorkerServiceServer

type UnimplementedWorkerServiceServer struct {
}

UnimplementedWorkerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedWorkerServiceServer) GetWorkerList

func (UnimplementedWorkerServiceServer) GetWorkerList(context.Context, *GetWorkerListReq) (*GetWorkerListRes, error)

func (UnimplementedWorkerServiceServer) UpdateWorkerStatus

func (UnimplementedWorkerServiceServer) UpdateWorkerStatus(context.Context, *UpdateWorkerStatusReq) (*UpdateWorkerStatusRes, error)

type UnsafeWorkerServiceServer

type UnsafeWorkerServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeWorkerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to WorkerServiceServer will result in compilation errors.

type UpdateWorkerStatusReq

type UpdateWorkerStatusReq struct {
	Id  string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateWorkerStatusReq) Descriptor

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

Deprecated: Use UpdateWorkerStatusReq.ProtoReflect.Descriptor instead.

func (*UpdateWorkerStatusReq) GetId

func (x *UpdateWorkerStatusReq) GetId() string

func (*UpdateWorkerStatusReq) GetMsg

func (x *UpdateWorkerStatusReq) GetMsg() string

func (*UpdateWorkerStatusReq) ProtoMessage

func (*UpdateWorkerStatusReq) ProtoMessage()

func (*UpdateWorkerStatusReq) ProtoReflect

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

func (*UpdateWorkerStatusReq) Reset

func (x *UpdateWorkerStatusReq) Reset()

func (*UpdateWorkerStatusReq) String

func (x *UpdateWorkerStatusReq) String() string

type UpdateWorkerStatusRes

type UpdateWorkerStatusRes struct {
	// contains filtered or unexported fields
}

func (*UpdateWorkerStatusRes) Descriptor

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

Deprecated: Use UpdateWorkerStatusRes.ProtoReflect.Descriptor instead.

func (*UpdateWorkerStatusRes) ProtoMessage

func (*UpdateWorkerStatusRes) ProtoMessage()

func (*UpdateWorkerStatusRes) ProtoReflect

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

func (*UpdateWorkerStatusRes) Reset

func (x *UpdateWorkerStatusRes) Reset()

func (*UpdateWorkerStatusRes) String

func (x *UpdateWorkerStatusRes) String() string

type WorkerServiceClient

type WorkerServiceClient interface {
	GetWorkerList(ctx context.Context, in *GetWorkerListReq, opts ...grpc.CallOption) (*GetWorkerListRes, error)
	UpdateWorkerStatus(ctx context.Context, in *UpdateWorkerStatusReq, opts ...grpc.CallOption) (*UpdateWorkerStatusRes, error)
}

WorkerServiceClient is the client API for WorkerService 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 NewWorkerServiceClient

func NewWorkerServiceClient(cc grpc.ClientConnInterface) WorkerServiceClient

type WorkerServiceServer

type WorkerServiceServer interface {
	GetWorkerList(context.Context, *GetWorkerListReq) (*GetWorkerListRes, error)
	UpdateWorkerStatus(context.Context, *UpdateWorkerStatusReq) (*UpdateWorkerStatusRes, error)
	// contains filtered or unexported methods
}

WorkerServiceServer is the server API for WorkerService service. All implementations must embed UnimplementedWorkerServiceServer for forward compatibility