Documentation ¶
Index ¶
- type GRPCHandler
- type WorkerNodeReceiverGRPCHandler
- func (w *WorkerNodeReceiverGRPCHandler) GetTaskFromQueue(ctx context.Context, payload *proto.GetTaskPayload) (*proto.Task, error)
- func (w *WorkerNodeReceiverGRPCHandler) ReportTaskFailure(ctx context.Context, payload *proto.ReportTaskFailureRequest) (*emptypb.Empty, error)
- func (w *WorkerNodeReceiverGRPCHandler) SubmitSuccessTask(ctx context.Context, payload *proto.SubmitSuccessTaskRequest) (*emptypb.Empty, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GRPCHandler ¶
type GRPCHandler struct { proto.UnimplementedWorkerNodeServer // contains filtered or unexported fields }
func ProvideWorkerGRPCHandler ¶
func ProvideWorkerGRPCHandler(grpcServer grpc.RAJDSGrpcServer, workerService handlerservice.IWorker, resourceMonitoringService service.IResourceMonitor, meter metric.Meter, workerNodeCertificate cert.TransportCertificate) GRPCHandler
func (*GRPCHandler) GetAllTasks ¶ added in v0.0.15
func (j *GRPCHandler) GetAllTasks(context.Context, *emptypb.Empty) (*proto.TaskResponse, error)
func (*GRPCHandler) HealthCheck ¶
func (*GRPCHandler) SendTask ¶
func (j *GRPCHandler) SendTask(ctx context.Context, task *proto.RecievedTask) (*emptypb.Empty, error)
type WorkerNodeReceiverGRPCHandler ¶
type WorkerNodeReceiverGRPCHandler struct { proto.UnimplementedWorkerNodeContainerReceiverServer // contains filtered or unexported fields }
func ProvideWorkerGRPCSocketHandler ¶
func ProvideWorkerGRPCSocketHandler(grpcSocketServer grpc.WorkerNodeReceiverGRPCServer, workerService handlerservice.IWorker, meter metric.Meter) WorkerNodeReceiverGRPCHandler
func (*WorkerNodeReceiverGRPCHandler) GetTaskFromQueue ¶
func (w *WorkerNodeReceiverGRPCHandler) GetTaskFromQueue(ctx context.Context, payload *proto.GetTaskPayload) (*proto.Task, error)
func (*WorkerNodeReceiverGRPCHandler) ReportTaskFailure ¶
func (w *WorkerNodeReceiverGRPCHandler) ReportTaskFailure(ctx context.Context, payload *proto.ReportTaskFailureRequest) (*emptypb.Empty, error)
func (*WorkerNodeReceiverGRPCHandler) SubmitSuccessTask ¶
func (w *WorkerNodeReceiverGRPCHandler) SubmitSuccessTask(ctx context.Context, payload *proto.SubmitSuccessTaskRequest) (*emptypb.Empty, error)
Click to show internal directories.
Click to hide internal directories.