Package io.dapr.durabletask.implementation.protobuf

Class TaskHubSidecarServiceGrpc.TaskHubSidecarServiceFutureStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractFutureStub<TaskHubSidecarServiceGrpc.TaskHubSidecarServiceFutureStub>

io.dapr.durabletask.implementation.protobuf.TaskHubSidecarServiceGrpc.TaskHubSidecarServiceFutureStub

Enclosing class:

TaskHubSidecarServiceGrpc

public static final class TaskHubSidecarServiceGrpc.TaskHubSidecarServiceFutureStub
extends io.grpc.stub.AbstractFutureStub<TaskHubSidecarServiceGrpc.TaskHubSidecarServiceFutureStub>

A stub to allow clients to do ListenableFuture-style rpc calls to service TaskHubSidecarService.

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
com.google.common.util.concurrent.ListenableFuture<OrchestratorService.AbandonActivityTaskResponse>	abandonTaskActivityWorkItem(OrchestratorService.AbandonActivityTaskRequest request)	Abandons a single work item
com.google.common.util.concurrent.ListenableFuture<OrchestratorService.AbandonEntityTaskResponse>	abandonTaskEntityWorkItem(OrchestratorService.AbandonEntityTaskRequest request)	Abandon an entity work item
com.google.common.util.concurrent.ListenableFuture<OrchestratorService.AbandonOrchestrationTaskResponse>	abandonTaskOrchestratorWorkItem(OrchestratorService.AbandonOrchestrationTaskRequest request)	Abandon an orchestration work item
protected TaskHubSidecarServiceGrpc.TaskHubSidecarServiceFutureStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
com.google.common.util.concurrent.ListenableFuture<OrchestratorService.CleanEntityStorageResponse>	cleanEntityStorage(OrchestratorService.CleanEntityStorageRequest request)	clean entity storage
com.google.common.util.concurrent.ListenableFuture<OrchestratorService.CompleteTaskResponse>	completeActivityTask(OrchestratorService.ActivityResponse request)
com.google.common.util.concurrent.ListenableFuture<OrchestratorService.CompleteTaskResponse>	completeEntityTask(OrchestratorService.EntityBatchResult request)
com.google.common.util.concurrent.ListenableFuture<OrchestratorService.CompleteTaskResponse>	completeOrchestratorTask(OrchestratorService.OrchestratorResponse request)
com.google.common.util.concurrent.ListenableFuture<OrchestratorService.CreateTaskHubResponse>	createTaskHub(OrchestratorService.CreateTaskHubRequest request)	Deletes and Creates the necessary resources for the orchestration service and the instance store
com.google.common.util.concurrent.ListenableFuture<OrchestratorService.DeleteTaskHubResponse>	deleteTaskHub(OrchestratorService.DeleteTaskHubRequest request)	Deletes the resources for the orchestration service and optionally the instance store
com.google.common.util.concurrent.ListenableFuture<OrchestratorService.GetEntityResponse>	getEntity(OrchestratorService.GetEntityRequest request)	get information about a specific entity
com.google.common.util.concurrent.ListenableFuture<OrchestratorService.GetInstanceResponse>	getInstance(OrchestratorService.GetInstanceRequest request)	Gets the status of an existing orchestration instance.
com.google.common.util.concurrent.ListenableFuture<OrchestratorService.GetInstanceHistoryResponse>	getInstanceHistory(OrchestratorService.GetInstanceHistoryRequest request)
com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>	hello(com.google.protobuf.Empty request)	Sends a hello request to the sidecar service.
com.google.common.util.concurrent.ListenableFuture<OrchestratorService.ListInstanceIDsResponse>	listInstanceIDs(OrchestratorService.ListInstanceIDsRequest request)
com.google.common.util.concurrent.ListenableFuture<OrchestratorService.PurgeInstancesResponse>	purgeInstances(OrchestratorService.PurgeInstancesRequest request)
com.google.common.util.concurrent.ListenableFuture<OrchestratorService.QueryEntitiesResponse>	queryEntities(OrchestratorService.QueryEntitiesRequest request)	query entities
com.google.common.util.concurrent.ListenableFuture<OrchestratorService.QueryInstancesResponse>	queryInstances(OrchestratorService.QueryInstancesRequest request)
com.google.common.util.concurrent.ListenableFuture<OrchestratorService.RaiseEventResponse>	raiseEvent(OrchestratorService.RaiseEventRequest request)	Raises an event to a running orchestration instance.
com.google.common.util.concurrent.ListenableFuture<OrchestratorService.RerunWorkflowFromEventResponse>	rerunWorkflowFromEvent(OrchestratorService.RerunWorkflowFromEventRequest request)	Rerun a Workflow from a specific event ID of a workflow instance.
com.google.common.util.concurrent.ListenableFuture<OrchestratorService.ResumeResponse>	resumeInstance(OrchestratorService.ResumeRequest request)	Resumes a suspended orchestration instance.
com.google.common.util.concurrent.ListenableFuture<OrchestratorService.RewindInstanceResponse>	rewindInstance(OrchestratorService.RewindInstanceRequest request)	Rewinds an orchestration instance to last known good state and replays from there.
com.google.common.util.concurrent.ListenableFuture<OrchestratorService.SignalEntityResponse>	signalEntity(OrchestratorService.SignalEntityRequest request)	sends a signal to an entity
com.google.common.util.concurrent.ListenableFuture<OrchestratorService.CreateInstanceResponse>	startInstance(OrchestratorService.CreateInstanceRequest request)	Starts a new orchestration instance.
com.google.common.util.concurrent.ListenableFuture<OrchestratorService.SuspendResponse>	suspendInstance(OrchestratorService.SuspendRequest request)	Suspends a running orchestration instance.
com.google.common.util.concurrent.ListenableFuture<OrchestratorService.TerminateResponse>	terminateInstance(OrchestratorService.TerminateRequest request)	Terminates a running orchestration instance.
com.google.common.util.concurrent.ListenableFuture<OrchestratorService.GetInstanceResponse>	waitForInstanceCompletion(OrchestratorService.GetInstanceRequest request)	Waits for an orchestration instance to reach a completion state (completed, failed, terminated, etc.).
com.google.common.util.concurrent.ListenableFuture<OrchestratorService.GetInstanceResponse>	waitForInstanceStart(OrchestratorService.GetInstanceRequest request)	Waits for an orchestration instance to reach a running or completion state.

Methods inherited from class io.grpc.stub.AbstractFutureStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, 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 Details

build

protected TaskHubSidecarServiceGrpc.TaskHubSidecarServiceFutureStub build(io.grpc.Channel channel,
 io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<TaskHubSidecarServiceGrpc.TaskHubSidecarServiceFutureStub>

hello

public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> hello(com.google.protobuf.Empty request)

 Sends a hello request to the sidecar service.
 

startInstance

public com.google.common.util.concurrent.ListenableFuture<OrchestratorService.CreateInstanceResponse> startInstance(OrchestratorService.CreateInstanceRequest request)

 Starts a new orchestration instance.
 

getInstance

public com.google.common.util.concurrent.ListenableFuture<OrchestratorService.GetInstanceResponse> getInstance(OrchestratorService.GetInstanceRequest request)

 Gets the status of an existing orchestration instance.
 

rewindInstance

public com.google.common.util.concurrent.ListenableFuture<OrchestratorService.RewindInstanceResponse> rewindInstance(OrchestratorService.RewindInstanceRequest request)

 Rewinds an orchestration instance to last known good state and replays from there.
 

waitForInstanceStart

public com.google.common.util.concurrent.ListenableFuture<OrchestratorService.GetInstanceResponse> waitForInstanceStart(OrchestratorService.GetInstanceRequest request)

 Waits for an orchestration instance to reach a running or completion state.
 

waitForInstanceCompletion

public com.google.common.util.concurrent.ListenableFuture<OrchestratorService.GetInstanceResponse> waitForInstanceCompletion(OrchestratorService.GetInstanceRequest request)

 Waits for an orchestration instance to reach a completion state (completed, failed, terminated, etc.).
 

raiseEvent

public com.google.common.util.concurrent.ListenableFuture<OrchestratorService.RaiseEventResponse> raiseEvent(OrchestratorService.RaiseEventRequest request)

 Raises an event to a running orchestration instance.
 

terminateInstance

public com.google.common.util.concurrent.ListenableFuture<OrchestratorService.TerminateResponse> terminateInstance(OrchestratorService.TerminateRequest request)

 Terminates a running orchestration instance.
 

suspendInstance

public com.google.common.util.concurrent.ListenableFuture<OrchestratorService.SuspendResponse> suspendInstance(OrchestratorService.SuspendRequest request)

 Suspends a running orchestration instance.
 

resumeInstance

public com.google.common.util.concurrent.ListenableFuture<OrchestratorService.ResumeResponse> resumeInstance(OrchestratorService.ResumeRequest request)

 Resumes a suspended orchestration instance.
 

queryInstances

public com.google.common.util.concurrent.ListenableFuture<OrchestratorService.QueryInstancesResponse> queryInstances(OrchestratorService.QueryInstancesRequest request)

purgeInstances

public com.google.common.util.concurrent.ListenableFuture<OrchestratorService.PurgeInstancesResponse> purgeInstances(OrchestratorService.PurgeInstancesRequest request)

completeActivityTask

public com.google.common.util.concurrent.ListenableFuture<OrchestratorService.CompleteTaskResponse> completeActivityTask(OrchestratorService.ActivityResponse request)

completeOrchestratorTask

public com.google.common.util.concurrent.ListenableFuture<OrchestratorService.CompleteTaskResponse> completeOrchestratorTask(OrchestratorService.OrchestratorResponse request)

completeEntityTask

public com.google.common.util.concurrent.ListenableFuture<OrchestratorService.CompleteTaskResponse> completeEntityTask(OrchestratorService.EntityBatchResult request)

createTaskHub

public com.google.common.util.concurrent.ListenableFuture<OrchestratorService.CreateTaskHubResponse> createTaskHub(OrchestratorService.CreateTaskHubRequest request)

 Deletes and Creates the necessary resources for the orchestration service and the instance store
 

deleteTaskHub

public com.google.common.util.concurrent.ListenableFuture<OrchestratorService.DeleteTaskHubResponse> deleteTaskHub(OrchestratorService.DeleteTaskHubRequest request)

 Deletes the resources for the orchestration service and optionally the instance store
 

signalEntity

public com.google.common.util.concurrent.ListenableFuture<OrchestratorService.SignalEntityResponse> signalEntity(OrchestratorService.SignalEntityRequest request)

 sends a signal to an entity
 

getEntity

public com.google.common.util.concurrent.ListenableFuture<OrchestratorService.GetEntityResponse> getEntity(OrchestratorService.GetEntityRequest request)

 get information about a specific entity
 

queryEntities

public com.google.common.util.concurrent.ListenableFuture<OrchestratorService.QueryEntitiesResponse> queryEntities(OrchestratorService.QueryEntitiesRequest request)

 query entities
 

cleanEntityStorage

public com.google.common.util.concurrent.ListenableFuture<OrchestratorService.CleanEntityStorageResponse> cleanEntityStorage(OrchestratorService.CleanEntityStorageRequest request)

 clean entity storage
 

abandonTaskActivityWorkItem

public com.google.common.util.concurrent.ListenableFuture<OrchestratorService.AbandonActivityTaskResponse> abandonTaskActivityWorkItem(OrchestratorService.AbandonActivityTaskRequest request)

 Abandons a single work item
 

abandonTaskOrchestratorWorkItem

public com.google.common.util.concurrent.ListenableFuture<OrchestratorService.AbandonOrchestrationTaskResponse> abandonTaskOrchestratorWorkItem(OrchestratorService.AbandonOrchestrationTaskRequest request)

 Abandon an orchestration work item
 

abandonTaskEntityWorkItem

public com.google.common.util.concurrent.ListenableFuture<OrchestratorService.AbandonEntityTaskResponse> abandonTaskEntityWorkItem(OrchestratorService.AbandonEntityTaskRequest request)

 Abandon an entity work item
 

rerunWorkflowFromEvent

public com.google.common.util.concurrent.ListenableFuture<OrchestratorService.RerunWorkflowFromEventResponse> rerunWorkflowFromEvent(OrchestratorService.RerunWorkflowFromEventRequest request)

 Rerun a Workflow from a specific event ID of a workflow instance.
 

listInstanceIDs

public com.google.common.util.concurrent.ListenableFuture<OrchestratorService.ListInstanceIDsResponse> listInstanceIDs(OrchestratorService.ListInstanceIDsRequest request)

getInstanceHistory

public com.google.common.util.concurrent.ListenableFuture<OrchestratorService.GetInstanceHistoryResponse> getInstanceHistory(OrchestratorService.GetInstanceHistoryRequest request)