Interface ComputeServiceGrpc.AsyncService

All Known Implementing Classes:
ComputeServiceGrpc.ComputeServiceImplBase, ComputeServiceImpl
Enclosing class:
ComputeServiceGrpc
public static interface ComputeServiceGrpc.AsyncService
The distributed compute service definition.

  • Method Details

    • submitTask

      default void submitTask(TaskRequest request, io.grpc.stub.StreamObserver<TaskResponse> responseObserver)
      Submits a single task for execution

    • streamResults

      default void streamResults(TaskIdentifier request, io.grpc.stub.StreamObserver<TaskResult> responseObserver)
      Streams status updates or partial results for a task

    • getStatus

      default void getStatus(Empty request, io.grpc.stub.StreamObserver<ServerStatus> responseObserver)
      Checking server health/status

    • registerWorker

      default void registerWorker(WorkerRegistration request, io.grpc.stub.StreamObserver<WorkerRegistrationResponse> responseObserver)
      Worker Interface

    • requestTask

      default void requestTask(WorkerIdentifier request, io.grpc.stub.StreamObserver<TaskRequest> responseObserver)

    • submitResult

      default void submitResult(TaskResult request, io.grpc.stub.StreamObserver<Empty> responseObserver)