Package io.dapr.durabletask.implementation.protobuf

Interface TaskHubSidecarServiceGrpc.AsyncService

All Known Implementing Classes:

TaskHubSidecarServiceGrpc.TaskHubSidecarServiceImplBase

Enclosing class:

TaskHubSidecarServiceGrpc

public static interface TaskHubSidecarServiceGrpc.AsyncService

Method Summary

Modifier and Type	Method	Description
default void	abandonTaskActivityWorkItem(OrchestratorService.AbandonActivityTaskRequest request, io.grpc.stub.StreamObserver<OrchestratorService.AbandonActivityTaskResponse> responseObserver)	Abandons a single work item
default void	abandonTaskEntityWorkItem(OrchestratorService.AbandonEntityTaskRequest request, io.grpc.stub.StreamObserver<OrchestratorService.AbandonEntityTaskResponse> responseObserver)	Abandon an entity work item
default void	abandonTaskOrchestratorWorkItem(OrchestratorService.AbandonOrchestrationTaskRequest request, io.grpc.stub.StreamObserver<OrchestratorService.AbandonOrchestrationTaskResponse> responseObserver)	Abandon an orchestration work item
default void	cleanEntityStorage(OrchestratorService.CleanEntityStorageRequest request, io.grpc.stub.StreamObserver<OrchestratorService.CleanEntityStorageResponse> responseObserver)	clean entity storage
default void	completeActivityTask(OrchestratorService.ActivityResponse request, io.grpc.stub.StreamObserver<OrchestratorService.CompleteTaskResponse> responseObserver)
default void	completeEntityTask(OrchestratorService.EntityBatchResult request, io.grpc.stub.StreamObserver<OrchestratorService.CompleteTaskResponse> responseObserver)
default void	completeOrchestratorTask(OrchestratorService.OrchestratorResponse request, io.grpc.stub.StreamObserver<OrchestratorService.CompleteTaskResponse> responseObserver)
default 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
default void	deleteTaskHub(OrchestratorService.DeleteTaskHubRequest request, io.grpc.stub.StreamObserver<OrchestratorService.DeleteTaskHubResponse> responseObserver)	Deletes the resources for the orchestration service and optionally the instance store
default void	getEntity(OrchestratorService.GetEntityRequest request, io.grpc.stub.StreamObserver<OrchestratorService.GetEntityResponse> responseObserver)	get information about a specific entity
default void	getInstance(OrchestratorService.GetInstanceRequest request, io.grpc.stub.StreamObserver<OrchestratorService.GetInstanceResponse> responseObserver)	Gets the status of an existing orchestration instance.
default void	getInstanceHistory(OrchestratorService.GetInstanceHistoryRequest request, io.grpc.stub.StreamObserver<OrchestratorService.GetInstanceHistoryResponse> responseObserver)
default void	getWorkItems(OrchestratorService.GetWorkItemsRequest request, io.grpc.stub.StreamObserver<OrchestratorService.WorkItem> responseObserver)
default void	hello(com.google.protobuf.Empty request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)	Sends a hello request to the sidecar service.
default void	listInstanceIDs(OrchestratorService.ListInstanceIDsRequest request, io.grpc.stub.StreamObserver<OrchestratorService.ListInstanceIDsResponse> responseObserver)
default void	purgeInstances(OrchestratorService.PurgeInstancesRequest request, io.grpc.stub.StreamObserver<OrchestratorService.PurgeInstancesResponse> responseObserver)
default void	queryEntities(OrchestratorService.QueryEntitiesRequest request, io.grpc.stub.StreamObserver<OrchestratorService.QueryEntitiesResponse> responseObserver)	query entities
default void	queryInstances(OrchestratorService.QueryInstancesRequest request, io.grpc.stub.StreamObserver<OrchestratorService.QueryInstancesResponse> responseObserver)
default void	raiseEvent(OrchestratorService.RaiseEventRequest request, io.grpc.stub.StreamObserver<OrchestratorService.RaiseEventResponse> responseObserver)	Raises an event to a running orchestration instance.
default void	rerunWorkflowFromEvent(OrchestratorService.RerunWorkflowFromEventRequest request, io.grpc.stub.StreamObserver<OrchestratorService.RerunWorkflowFromEventResponse> responseObserver)	Rerun a Workflow from a specific event ID of a workflow instance.
default void	resumeInstance(OrchestratorService.ResumeRequest request, io.grpc.stub.StreamObserver<OrchestratorService.ResumeResponse> responseObserver)	Resumes a suspended orchestration instance.
default 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.
default void	signalEntity(OrchestratorService.SignalEntityRequest request, io.grpc.stub.StreamObserver<OrchestratorService.SignalEntityResponse> responseObserver)	sends a signal to an entity
default void	startInstance(OrchestratorService.CreateInstanceRequest request, io.grpc.stub.StreamObserver<OrchestratorService.CreateInstanceResponse> responseObserver)	Starts a new orchestration instance.
default void	streamInstanceHistory(OrchestratorService.StreamInstanceHistoryRequest request, io.grpc.stub.StreamObserver<OrchestratorService.HistoryChunk> responseObserver)	Gets the history of an orchestration instance as a stream of events.
default void	suspendInstance(OrchestratorService.SuspendRequest request, io.grpc.stub.StreamObserver<OrchestratorService.SuspendResponse> responseObserver)	Suspends a running orchestration instance.
default void	terminateInstance(OrchestratorService.TerminateRequest request, io.grpc.stub.StreamObserver<OrchestratorService.TerminateResponse> responseObserver)	Terminates a running orchestration instance.
default 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.).
default void	waitForInstanceStart(OrchestratorService.GetInstanceRequest request, io.grpc.stub.StreamObserver<OrchestratorService.GetInstanceResponse> responseObserver)	Waits for an orchestration instance to reach a running or completion state.

Method Details

hello

default 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

default void startInstance(OrchestratorService.CreateInstanceRequest request,
 io.grpc.stub.StreamObserver<OrchestratorService.CreateInstanceResponse> responseObserver)

 Starts a new orchestration instance.
 

getInstance

default void getInstance(OrchestratorService.GetInstanceRequest request,
 io.grpc.stub.StreamObserver<OrchestratorService.GetInstanceResponse> responseObserver)

 Gets the status of an existing orchestration instance.
 

rewindInstance

default 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

default 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

default 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

default void raiseEvent(OrchestratorService.RaiseEventRequest request,
 io.grpc.stub.StreamObserver<OrchestratorService.RaiseEventResponse> responseObserver)

 Raises an event to a running orchestration instance.
 

terminateInstance

default void terminateInstance(OrchestratorService.TerminateRequest request,
 io.grpc.stub.StreamObserver<OrchestratorService.TerminateResponse> responseObserver)

 Terminates a running orchestration instance.
 

suspendInstance

default void suspendInstance(OrchestratorService.SuspendRequest request,
 io.grpc.stub.StreamObserver<OrchestratorService.SuspendResponse> responseObserver)

 Suspends a running orchestration instance.
 

resumeInstance

default void resumeInstance(OrchestratorService.ResumeRequest request,
 io.grpc.stub.StreamObserver<OrchestratorService.ResumeResponse> responseObserver)

 Resumes a suspended orchestration instance.
 

queryInstances

default void queryInstances(OrchestratorService.QueryInstancesRequest request,
 io.grpc.stub.StreamObserver<OrchestratorService.QueryInstancesResponse> responseObserver)

purgeInstances

default void purgeInstances(OrchestratorService.PurgeInstancesRequest request,
 io.grpc.stub.StreamObserver<OrchestratorService.PurgeInstancesResponse> responseObserver)

getWorkItems

default void getWorkItems(OrchestratorService.GetWorkItemsRequest request,
 io.grpc.stub.StreamObserver<OrchestratorService.WorkItem> responseObserver)

completeActivityTask

default void completeActivityTask(OrchestratorService.ActivityResponse request,
 io.grpc.stub.StreamObserver<OrchestratorService.CompleteTaskResponse> responseObserver)

completeOrchestratorTask

default void completeOrchestratorTask(OrchestratorService.OrchestratorResponse request,
 io.grpc.stub.StreamObserver<OrchestratorService.CompleteTaskResponse> responseObserver)

completeEntityTask

default void completeEntityTask(OrchestratorService.EntityBatchResult request,
 io.grpc.stub.StreamObserver<OrchestratorService.CompleteTaskResponse> responseObserver)

streamInstanceHistory

default 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

default 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

default 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

default void signalEntity(OrchestratorService.SignalEntityRequest request,
 io.grpc.stub.StreamObserver<OrchestratorService.SignalEntityResponse> responseObserver)

 sends a signal to an entity
 

getEntity

default void getEntity(OrchestratorService.GetEntityRequest request,
 io.grpc.stub.StreamObserver<OrchestratorService.GetEntityResponse> responseObserver)

 get information about a specific entity
 

queryEntities

default void queryEntities(OrchestratorService.QueryEntitiesRequest request,
 io.grpc.stub.StreamObserver<OrchestratorService.QueryEntitiesResponse> responseObserver)

 query entities
 

cleanEntityStorage

default void cleanEntityStorage(OrchestratorService.CleanEntityStorageRequest request,
 io.grpc.stub.StreamObserver<OrchestratorService.CleanEntityStorageResponse> responseObserver)

 clean entity storage
 

abandonTaskActivityWorkItem

default void abandonTaskActivityWorkItem(OrchestratorService.AbandonActivityTaskRequest request,
 io.grpc.stub.StreamObserver<OrchestratorService.AbandonActivityTaskResponse> responseObserver)

 Abandons a single work item
 

abandonTaskOrchestratorWorkItem

default void abandonTaskOrchestratorWorkItem(OrchestratorService.AbandonOrchestrationTaskRequest request,
 io.grpc.stub.StreamObserver<OrchestratorService.AbandonOrchestrationTaskResponse> responseObserver)

 Abandon an orchestration work item
 

abandonTaskEntityWorkItem

default void abandonTaskEntityWorkItem(OrchestratorService.AbandonEntityTaskRequest request,
 io.grpc.stub.StreamObserver<OrchestratorService.AbandonEntityTaskResponse> responseObserver)

 Abandon an entity work item
 

rerunWorkflowFromEvent

default 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

default void listInstanceIDs(OrchestratorService.ListInstanceIDsRequest request,
 io.grpc.stub.StreamObserver<OrchestratorService.ListInstanceIDsResponse> responseObserver)

getInstanceHistory

default void getInstanceHistory(OrchestratorService.GetInstanceHistoryRequest request,
 io.grpc.stub.StreamObserver<OrchestratorService.GetInstanceHistoryResponse> responseObserver)