Class ComputeServiceGrpc.ComputeServiceStub

java.lang.Object

io.grpc.stub.AbstractStub<ComputeServiceGrpc.ComputeServiceStub>

io.grpc.stub.AbstractAsyncStub<ComputeServiceGrpc.ComputeServiceStub>

org.episteme.server.server.proto.ComputeServiceGrpc.ComputeServiceStub

Enclosing class:

ComputeServiceGrpc

public static final class ComputeServiceGrpc.ComputeServiceStub
extends io.grpc.stub.AbstractAsyncStub<ComputeServiceGrpc.ComputeServiceStub>

A stub to allow clients to do asynchronous rpc calls to service ComputeService.

The distributed compute service definition.

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

io.grpc.stub.AbstractStub.StubFactory<T>

Method Summary

Modifier and Type	Method	Description
protected ComputeServiceGrpc.ComputeServiceStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
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 io.grpc.stub.AbstractAsyncStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReady

Methods inherited from class Object

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

Method Details

build

protected ComputeServiceGrpc.ComputeServiceStub build(io.grpc.Channel channel,
 io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<ComputeServiceGrpc.ComputeServiceStub>

submitTask

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

Submits a single task for execution

streamResults

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

Streams status updates or partial results for a task

getStatus

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

Checking server health/status

registerWorker

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

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)