Class ComputeServiceImpl
java.lang.Object
org.episteme.server.server.proto.ComputeServiceGrpc.ComputeServiceImplBase
org.episteme.server.server.service.ComputeServiceImpl
- All Implemented Interfaces:
io.grpc.BindableService, ComputeServiceGrpc.AsyncService
gRPC Service for Compute Task Management.
- Since:
- 1.0
- Author:
- Silvere Martin-Michiellot, Gemini AI (Google DeepMind)
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidgetStatus(Empty request, io.grpc.stub.StreamObserver<ServerStatus> responseObserver) Checking server health/statusvoidregisterWorker(WorkerRegistration request, io.grpc.stub.StreamObserver<WorkerRegistrationResponse> responseObserver) Worker InterfacevoidrequestTask(WorkerIdentifier request, io.grpc.stub.StreamObserver<TaskRequest> responseObserver) voidstreamResults(TaskIdentifier request, io.grpc.stub.StreamObserver<TaskResult> responseObserver) Streams status updates or partial results for a taskvoidsubmitResult(TaskResult request, io.grpc.stub.StreamObserver<Empty> responseObserver) voidsubmitTask(TaskRequest request, io.grpc.stub.StreamObserver<TaskResponse> responseObserver) Submits a single task for executionMethods inherited from class ComputeServiceGrpc.ComputeServiceImplBase
bindService
-
Constructor Details
-
ComputeServiceImpl
-
-
Method Details
-
getStatus
Description copied from interface:ComputeServiceGrpc.AsyncServiceChecking server health/status
-
submitTask
public void submitTask(TaskRequest request, io.grpc.stub.StreamObserver<TaskResponse> responseObserver) Description copied from interface:ComputeServiceGrpc.AsyncServiceSubmits a single task for execution
-
registerWorker
public void registerWorker(WorkerRegistration request, io.grpc.stub.StreamObserver<WorkerRegistrationResponse> responseObserver) Description copied from interface:ComputeServiceGrpc.AsyncServiceWorker Interface
-
requestTask
public void requestTask(WorkerIdentifier request, io.grpc.stub.StreamObserver<TaskRequest> responseObserver) -
submitResult
-
streamResults
public void streamResults(TaskIdentifier request, io.grpc.stub.StreamObserver<TaskResult> responseObserver) Description copied from interface:ComputeServiceGrpc.AsyncServiceStreams status updates or partial results for a task
-