Class TaskHubSidecarServiceGrpc.TaskHubSidecarServiceStub
java.lang.Object
io.grpc.stub.AbstractStub<S>
io.grpc.stub.AbstractAsyncStub<TaskHubSidecarServiceGrpc.TaskHubSidecarServiceStub>
io.dapr.durabletask.implementation.protobuf.TaskHubSidecarServiceGrpc.TaskHubSidecarServiceStub
- Enclosing class:
- TaskHubSidecarServiceGrpc
public static final class TaskHubSidecarServiceGrpc.TaskHubSidecarServiceStub
extends io.grpc.stub.AbstractAsyncStub<TaskHubSidecarServiceGrpc.TaskHubSidecarServiceStub>
A stub to allow clients to do asynchronous 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 TypeMethodDescriptionvoidabandonTaskActivityWorkItem(OrchestratorService.AbandonActivityTaskRequest request, io.grpc.stub.StreamObserver<OrchestratorService.AbandonActivityTaskResponse> responseObserver) Abandons a single work itemvoidabandonTaskEntityWorkItem(OrchestratorService.AbandonEntityTaskRequest request, io.grpc.stub.StreamObserver<OrchestratorService.AbandonEntityTaskResponse> responseObserver) Abandon an entity work itemvoidabandonTaskOrchestratorWorkItem(OrchestratorService.AbandonOrchestrationTaskRequest request, io.grpc.stub.StreamObserver<OrchestratorService.AbandonOrchestrationTaskResponse> responseObserver) Abandon an orchestration work itembuild(io.grpc.Channel channel, io.grpc.CallOptions callOptions) voidcleanEntityStorage(OrchestratorService.CleanEntityStorageRequest request, io.grpc.stub.StreamObserver<OrchestratorService.CleanEntityStorageResponse> responseObserver) clean entity storagevoidcompleteActivityTask(OrchestratorService.ActivityResponse request, io.grpc.stub.StreamObserver<OrchestratorService.CompleteTaskResponse> responseObserver) voidcompleteEntityTask(OrchestratorService.EntityBatchResult request, io.grpc.stub.StreamObserver<OrchestratorService.CompleteTaskResponse> responseObserver) voidcompleteOrchestratorTask(OrchestratorService.OrchestratorResponse request, io.grpc.stub.StreamObserver<OrchestratorService.CompleteTaskResponse> responseObserver) voidcreateTaskHub(OrchestratorService.CreateTaskHubRequest request, io.grpc.stub.StreamObserver<OrchestratorService.CreateTaskHubResponse> responseObserver) Deletes and Creates the necessary resources for the orchestration service and the instance storevoiddeleteTaskHub(OrchestratorService.DeleteTaskHubRequest request, io.grpc.stub.StreamObserver<OrchestratorService.DeleteTaskHubResponse> responseObserver) Deletes the resources for the orchestration service and optionally the instance storevoidgetEntity(OrchestratorService.GetEntityRequest request, io.grpc.stub.StreamObserver<OrchestratorService.GetEntityResponse> responseObserver) get information about a specific entityvoidgetInstance(OrchestratorService.GetInstanceRequest request, io.grpc.stub.StreamObserver<OrchestratorService.GetInstanceResponse> responseObserver) Gets the status of an existing orchestration instance.voidgetInstanceHistory(OrchestratorService.GetInstanceHistoryRequest request, io.grpc.stub.StreamObserver<OrchestratorService.GetInstanceHistoryResponse> responseObserver) voidgetWorkItems(OrchestratorService.GetWorkItemsRequest request, io.grpc.stub.StreamObserver<OrchestratorService.WorkItem> responseObserver) voidhello(com.google.protobuf.Empty request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Sends a hello request to the sidecar service.voidlistInstanceIDs(OrchestratorService.ListInstanceIDsRequest request, io.grpc.stub.StreamObserver<OrchestratorService.ListInstanceIDsResponse> responseObserver) voidpurgeInstances(OrchestratorService.PurgeInstancesRequest request, io.grpc.stub.StreamObserver<OrchestratorService.PurgeInstancesResponse> responseObserver) voidqueryEntities(OrchestratorService.QueryEntitiesRequest request, io.grpc.stub.StreamObserver<OrchestratorService.QueryEntitiesResponse> responseObserver) query entitiesvoidqueryInstances(OrchestratorService.QueryInstancesRequest request, io.grpc.stub.StreamObserver<OrchestratorService.QueryInstancesResponse> responseObserver) voidraiseEvent(OrchestratorService.RaiseEventRequest request, io.grpc.stub.StreamObserver<OrchestratorService.RaiseEventResponse> responseObserver) Raises an event to a running orchestration instance.voidrerunWorkflowFromEvent(OrchestratorService.RerunWorkflowFromEventRequest request, io.grpc.stub.StreamObserver<OrchestratorService.RerunWorkflowFromEventResponse> responseObserver) Rerun a Workflow from a specific event ID of a workflow instance.voidresumeInstance(OrchestratorService.ResumeRequest request, io.grpc.stub.StreamObserver<OrchestratorService.ResumeResponse> responseObserver) Resumes a suspended orchestration instance.voidrewindInstance(OrchestratorService.RewindInstanceRequest request, io.grpc.stub.StreamObserver<OrchestratorService.RewindInstanceResponse> responseObserver) Rewinds an orchestration instance to last known good state and replays from there.voidsignalEntity(OrchestratorService.SignalEntityRequest request, io.grpc.stub.StreamObserver<OrchestratorService.SignalEntityResponse> responseObserver) sends a signal to an entityvoidstartInstance(OrchestratorService.CreateInstanceRequest request, io.grpc.stub.StreamObserver<OrchestratorService.CreateInstanceResponse> responseObserver) Starts a new orchestration instance.voidstreamInstanceHistory(OrchestratorService.StreamInstanceHistoryRequest request, io.grpc.stub.StreamObserver<OrchestratorService.HistoryChunk> responseObserver) Gets the history of an orchestration instance as a stream of events.voidsuspendInstance(OrchestratorService.SuspendRequest request, io.grpc.stub.StreamObserver<OrchestratorService.SuspendResponse> responseObserver) Suspends a running orchestration instance.voidterminateInstance(OrchestratorService.TerminateRequest request, io.grpc.stub.StreamObserver<OrchestratorService.TerminateResponse> responseObserver) Terminates a running orchestration instance.voidwaitForInstanceCompletion(OrchestratorService.GetInstanceRequest request, io.grpc.stub.StreamObserver<OrchestratorService.GetInstanceResponse> responseObserver) Waits for an orchestration instance to reach a completion state (completed, failed, terminated, etc.).voidwaitForInstanceStart(OrchestratorService.GetInstanceRequest request, io.grpc.stub.StreamObserver<OrchestratorService.GetInstanceResponse> responseObserver) Waits for an orchestration instance to reach a running or completion state.Methods inherited from class io.grpc.stub.AbstractAsyncStub
newStub, newStubMethods inherited from class io.grpc.stub.AbstractStub
getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady
-
Method Details
-
build
protected TaskHubSidecarServiceGrpc.TaskHubSidecarServiceStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) - Specified by:
buildin classio.grpc.stub.AbstractStub<TaskHubSidecarServiceGrpc.TaskHubSidecarServiceStub>
-
hello
public void hello(com.google.protobuf.Empty request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Sends a hello request to the sidecar service.
-
startInstance
public void startInstance(OrchestratorService.CreateInstanceRequest request, io.grpc.stub.StreamObserver<OrchestratorService.CreateInstanceResponse> responseObserver) Starts a new orchestration instance.
-
getInstance
public void getInstance(OrchestratorService.GetInstanceRequest request, io.grpc.stub.StreamObserver<OrchestratorService.GetInstanceResponse> responseObserver) Gets the status of an existing orchestration instance.
-
rewindInstance
public void rewindInstance(OrchestratorService.RewindInstanceRequest request, io.grpc.stub.StreamObserver<OrchestratorService.RewindInstanceResponse> responseObserver) Rewinds an orchestration instance to last known good state and replays from there.
-
waitForInstanceStart
public void waitForInstanceStart(OrchestratorService.GetInstanceRequest request, io.grpc.stub.StreamObserver<OrchestratorService.GetInstanceResponse> responseObserver) Waits for an orchestration instance to reach a running or completion state.
-
waitForInstanceCompletion
public void waitForInstanceCompletion(OrchestratorService.GetInstanceRequest request, io.grpc.stub.StreamObserver<OrchestratorService.GetInstanceResponse> responseObserver) Waits for an orchestration instance to reach a completion state (completed, failed, terminated, etc.).
-
raiseEvent
public void raiseEvent(OrchestratorService.RaiseEventRequest request, io.grpc.stub.StreamObserver<OrchestratorService.RaiseEventResponse> responseObserver) Raises an event to a running orchestration instance.
-
terminateInstance
public void terminateInstance(OrchestratorService.TerminateRequest request, io.grpc.stub.StreamObserver<OrchestratorService.TerminateResponse> responseObserver) Terminates a running orchestration instance.
-
suspendInstance
public void suspendInstance(OrchestratorService.SuspendRequest request, io.grpc.stub.StreamObserver<OrchestratorService.SuspendResponse> responseObserver) Suspends a running orchestration instance.
-
resumeInstance
public void resumeInstance(OrchestratorService.ResumeRequest request, io.grpc.stub.StreamObserver<OrchestratorService.ResumeResponse> responseObserver) Resumes a suspended orchestration instance.
-
queryInstances
public void queryInstances(OrchestratorService.QueryInstancesRequest request, io.grpc.stub.StreamObserver<OrchestratorService.QueryInstancesResponse> responseObserver) -
purgeInstances
public void purgeInstances(OrchestratorService.PurgeInstancesRequest request, io.grpc.stub.StreamObserver<OrchestratorService.PurgeInstancesResponse> responseObserver) -
getWorkItems
public void getWorkItems(OrchestratorService.GetWorkItemsRequest request, io.grpc.stub.StreamObserver<OrchestratorService.WorkItem> responseObserver) -
completeActivityTask
public void completeActivityTask(OrchestratorService.ActivityResponse request, io.grpc.stub.StreamObserver<OrchestratorService.CompleteTaskResponse> responseObserver) -
completeOrchestratorTask
public void completeOrchestratorTask(OrchestratorService.OrchestratorResponse request, io.grpc.stub.StreamObserver<OrchestratorService.CompleteTaskResponse> responseObserver) -
completeEntityTask
public void completeEntityTask(OrchestratorService.EntityBatchResult request, io.grpc.stub.StreamObserver<OrchestratorService.CompleteTaskResponse> responseObserver) -
streamInstanceHistory
public void streamInstanceHistory(OrchestratorService.StreamInstanceHistoryRequest request, io.grpc.stub.StreamObserver<OrchestratorService.HistoryChunk> responseObserver) Gets the history of an orchestration instance as a stream of events.
-
createTaskHub
public void createTaskHub(OrchestratorService.CreateTaskHubRequest request, io.grpc.stub.StreamObserver<OrchestratorService.CreateTaskHubResponse> responseObserver) Deletes and Creates the necessary resources for the orchestration service and the instance store
-
deleteTaskHub
public void deleteTaskHub(OrchestratorService.DeleteTaskHubRequest request, io.grpc.stub.StreamObserver<OrchestratorService.DeleteTaskHubResponse> responseObserver) Deletes the resources for the orchestration service and optionally the instance store
-
signalEntity
public void signalEntity(OrchestratorService.SignalEntityRequest request, io.grpc.stub.StreamObserver<OrchestratorService.SignalEntityResponse> responseObserver) sends a signal to an entity
-
getEntity
public void getEntity(OrchestratorService.GetEntityRequest request, io.grpc.stub.StreamObserver<OrchestratorService.GetEntityResponse> responseObserver) get information about a specific entity
-
queryEntities
public void queryEntities(OrchestratorService.QueryEntitiesRequest request, io.grpc.stub.StreamObserver<OrchestratorService.QueryEntitiesResponse> responseObserver) query entities
-
cleanEntityStorage
public void cleanEntityStorage(OrchestratorService.CleanEntityStorageRequest request, io.grpc.stub.StreamObserver<OrchestratorService.CleanEntityStorageResponse> responseObserver) clean entity storage
-
abandonTaskActivityWorkItem
public void abandonTaskActivityWorkItem(OrchestratorService.AbandonActivityTaskRequest request, io.grpc.stub.StreamObserver<OrchestratorService.AbandonActivityTaskResponse> responseObserver) Abandons a single work item
-
abandonTaskOrchestratorWorkItem
public void abandonTaskOrchestratorWorkItem(OrchestratorService.AbandonOrchestrationTaskRequest request, io.grpc.stub.StreamObserver<OrchestratorService.AbandonOrchestrationTaskResponse> responseObserver) Abandon an orchestration work item
-
abandonTaskEntityWorkItem
public void abandonTaskEntityWorkItem(OrchestratorService.AbandonEntityTaskRequest request, io.grpc.stub.StreamObserver<OrchestratorService.AbandonEntityTaskResponse> responseObserver) Abandon an entity work item
-
rerunWorkflowFromEvent
public void rerunWorkflowFromEvent(OrchestratorService.RerunWorkflowFromEventRequest request, io.grpc.stub.StreamObserver<OrchestratorService.RerunWorkflowFromEventResponse> responseObserver) Rerun a Workflow from a specific event ID of a workflow instance.
-
listInstanceIDs
public void listInstanceIDs(OrchestratorService.ListInstanceIDsRequest request, io.grpc.stub.StreamObserver<OrchestratorService.ListInstanceIDsResponse> responseObserver) -
getInstanceHistory
public void getInstanceHistory(OrchestratorService.GetInstanceHistoryRequest request, io.grpc.stub.StreamObserver<OrchestratorService.GetInstanceHistoryResponse> responseObserver)
-