Package api

Class ExecutorGrpc.ExecutorStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractAsyncStub<ExecutorGrpc.ExecutorStub>

api.ExecutorGrpc.ExecutorStub

Enclosing class:

ExecutorGrpc

public static final class ExecutorGrpc.ExecutorStub
extends io.grpc.stub.AbstractAsyncStub<ExecutorGrpc.ExecutorStub>

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

Nested Class Summary

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

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

Method Summary

Modifier and Type	Method	Description
protected ExecutorGrpc.ExecutorStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
void	cancelOnExecutor(ExecutorOuterClass.ExecutorCancelRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
void	deleteExecutorSettings(ExecutorOuterClass.ExecutorSettingsDeleteRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
void	preemptOnExecutor(ExecutorOuterClass.ExecutorPreemptRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
void	upsertExecutorSettings(ExecutorOuterClass.ExecutorSettingsUpsertRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

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, withOnReadyThreshold, withOption, withWaitForReady

Methods inherited from class java.lang.Object

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

Method Detail

build

protected ExecutorGrpc.ExecutorStub build(io.grpc.Channel channel,
                                          io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<ExecutorGrpc.ExecutorStub>

upsertExecutorSettings

public void upsertExecutorSettings(ExecutorOuterClass.ExecutorSettingsUpsertRequest request,
                                   io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

deleteExecutorSettings

public void deleteExecutorSettings(ExecutorOuterClass.ExecutorSettingsDeleteRequest request,
                                   io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

preemptOnExecutor

public void preemptOnExecutor(ExecutorOuterClass.ExecutorPreemptRequest request,
                              io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

cancelOnExecutor

public void cancelOnExecutor(ExecutorOuterClass.ExecutorCancelRequest request,
                             io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)