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

@GrpcService
public class ComputeServiceImpl
extends ComputeServiceGrpc.ComputeServiceImplBase

gRPC Service for Compute Task Management.

Since:

1.0

Author:

Silvere Martin-Michiellot, Gemini AI (Google DeepMind)

Constructor Summary

Constructors

Constructor	Description
ComputeServiceImpl(JobRepository jobRepository)

Method Summary

Modifier and Type	Method	Description
void	getStatus(Empty request, io.grpc.stub.StreamObserver<ServerStatus> responseObserver)	Checking server health/status
void	registerWorker(WorkerRegistration request, io.grpc.stub.StreamObserver<WorkerRegistrationResponse> responseObserver)	Worker Interface
void	requestTask(WorkerIdentifier request, io.grpc.stub.StreamObserver<TaskRequest> responseObserver)
void	streamResults(TaskIdentifier request, io.grpc.stub.StreamObserver<TaskResult> responseObserver)	Streams status updates or partial results for a task
void	submitResult(TaskResult request, io.grpc.stub.StreamObserver<Empty> responseObserver)
void	submitTask(TaskRequest request, io.grpc.stub.StreamObserver<TaskResponse> responseObserver)	Submits a single task for execution

Methods inherited from class ComputeServiceGrpc.ComputeServiceImplBase

bindService

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ComputeServiceImpl

@Autowired
public ComputeServiceImpl(JobRepository jobRepository)

Method Details

getStatus

public void getStatus(Empty request,
 io.grpc.stub.StreamObserver<ServerStatus> responseObserver)

Description copied from interface: ComputeServiceGrpc.AsyncService

Checking server health/status

submitTask

public void submitTask(TaskRequest request,
 io.grpc.stub.StreamObserver<TaskResponse> responseObserver)

Description copied from interface: ComputeServiceGrpc.AsyncService

Submits a single task for execution

registerWorker

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

Description copied from interface: ComputeServiceGrpc.AsyncService

Worker Interface

requestTask

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

submitResult

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

streamResults

public void streamResults(TaskIdentifier request,
 io.grpc.stub.StreamObserver<TaskResult> responseObserver)

Description copied from interface: ComputeServiceGrpc.AsyncService

Streams status updates or partial results for a task