Package io.dapr.durabletask.implementation.protobuf

Class TaskHubSidecarServiceGrpc.TaskHubSidecarServiceBlockingV2Stub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractBlockingStub<TaskHubSidecarServiceGrpc.TaskHubSidecarServiceBlockingV2Stub>

io.dapr.durabletask.implementation.protobuf.TaskHubSidecarServiceGrpc.TaskHubSidecarServiceBlockingV2Stub

Enclosing class:

TaskHubSidecarServiceGrpc

public static final class TaskHubSidecarServiceGrpc.TaskHubSidecarServiceBlockingV2Stub
extends io.grpc.stub.AbstractBlockingStub<TaskHubSidecarServiceGrpc.TaskHubSidecarServiceBlockingV2Stub>

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

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.TaskHubSidecarServiceBlockingV2Stub build(io.grpc.Channel channel,
 io.grpc.CallOptions callOptions)

Specified by:

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

hello

public com.google.protobuf.Empty hello(com.google.protobuf.Empty request)
                                throws io.grpc.StatusException

 Sends a hello request to the sidecar service.
 

Throws:

io.grpc.StatusException

startInstance

public OrchestratorService.CreateInstanceResponse startInstance(OrchestratorService.CreateInstanceRequest request)
                                                         throws io.grpc.StatusException

 Starts a new orchestration instance.
 

Throws:

io.grpc.StatusException

getInstance

public OrchestratorService.GetInstanceResponse getInstance(OrchestratorService.GetInstanceRequest request)
                                                    throws io.grpc.StatusException

 Gets the status of an existing orchestration instance.
 

Throws:

io.grpc.StatusException

rewindInstance

public OrchestratorService.RewindInstanceResponse rewindInstance(OrchestratorService.RewindInstanceRequest request)
                                                          throws io.grpc.StatusException

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

Throws:

io.grpc.StatusException

waitForInstanceStart

public OrchestratorService.GetInstanceResponse waitForInstanceStart(OrchestratorService.GetInstanceRequest request)
                                                             throws io.grpc.StatusException

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

Throws:

io.grpc.StatusException

waitForInstanceCompletion

public OrchestratorService.GetInstanceResponse waitForInstanceCompletion(OrchestratorService.GetInstanceRequest request)
                                                                  throws io.grpc.StatusException

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

Throws:

io.grpc.StatusException

raiseEvent

public OrchestratorService.RaiseEventResponse raiseEvent(OrchestratorService.RaiseEventRequest request)
                                                  throws io.grpc.StatusException

 Raises an event to a running orchestration instance.
 

Throws:

io.grpc.StatusException

terminateInstance

public OrchestratorService.TerminateResponse terminateInstance(OrchestratorService.TerminateRequest request)
                                                        throws io.grpc.StatusException

 Terminates a running orchestration instance.
 

Throws:

io.grpc.StatusException

suspendInstance

public OrchestratorService.SuspendResponse suspendInstance(OrchestratorService.SuspendRequest request)
                                                    throws io.grpc.StatusException

 Suspends a running orchestration instance.
 

Throws:

io.grpc.StatusException

resumeInstance

public OrchestratorService.ResumeResponse resumeInstance(OrchestratorService.ResumeRequest request)
                                                  throws io.grpc.StatusException

 Resumes a suspended orchestration instance.
 

Throws:

io.grpc.StatusException

queryInstances

public OrchestratorService.QueryInstancesResponse queryInstances(OrchestratorService.QueryInstancesRequest request)
                                                          throws io.grpc.StatusException

Throws:

io.grpc.StatusException

purgeInstances

public OrchestratorService.PurgeInstancesResponse purgeInstances(OrchestratorService.PurgeInstancesRequest request)
                                                          throws io.grpc.StatusException

Throws:

io.grpc.StatusException

getWorkItems

@ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
public io.grpc.stub.BlockingClientCall<?,OrchestratorService.WorkItem> getWorkItems(OrchestratorService.GetWorkItemsRequest request)

completeActivityTask

public OrchestratorService.CompleteTaskResponse completeActivityTask(OrchestratorService.ActivityResponse request)
                                                              throws io.grpc.StatusException

Throws:

io.grpc.StatusException

completeOrchestratorTask

public OrchestratorService.CompleteTaskResponse completeOrchestratorTask(OrchestratorService.OrchestratorResponse request)
                                                                  throws io.grpc.StatusException

Throws:

io.grpc.StatusException

completeEntityTask

public OrchestratorService.CompleteTaskResponse completeEntityTask(OrchestratorService.EntityBatchResult request)
                                                            throws io.grpc.StatusException

Throws:

io.grpc.StatusException

streamInstanceHistory

@ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
public io.grpc.stub.BlockingClientCall<?,OrchestratorService.HistoryChunk> streamInstanceHistory(OrchestratorService.StreamInstanceHistoryRequest request)

 Gets the history of an orchestration instance as a stream of events.
 

createTaskHub

public OrchestratorService.CreateTaskHubResponse createTaskHub(OrchestratorService.CreateTaskHubRequest request)
                                                        throws io.grpc.StatusException

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

Throws:

io.grpc.StatusException

deleteTaskHub

public OrchestratorService.DeleteTaskHubResponse deleteTaskHub(OrchestratorService.DeleteTaskHubRequest request)
                                                        throws io.grpc.StatusException

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

Throws:

io.grpc.StatusException

signalEntity

public OrchestratorService.SignalEntityResponse signalEntity(OrchestratorService.SignalEntityRequest request)
                                                      throws io.grpc.StatusException

 sends a signal to an entity
 

Throws:

io.grpc.StatusException

getEntity

public OrchestratorService.GetEntityResponse getEntity(OrchestratorService.GetEntityRequest request)
                                                throws io.grpc.StatusException

 get information about a specific entity
 

Throws:

io.grpc.StatusException

queryEntities

public OrchestratorService.QueryEntitiesResponse queryEntities(OrchestratorService.QueryEntitiesRequest request)
                                                        throws io.grpc.StatusException

 query entities
 

Throws:

io.grpc.StatusException

cleanEntityStorage

public OrchestratorService.CleanEntityStorageResponse cleanEntityStorage(OrchestratorService.CleanEntityStorageRequest request)
                                                                  throws io.grpc.StatusException

 clean entity storage
 

Throws:

io.grpc.StatusException

abandonTaskActivityWorkItem

public OrchestratorService.AbandonActivityTaskResponse abandonTaskActivityWorkItem(OrchestratorService.AbandonActivityTaskRequest request)
                                                                            throws io.grpc.StatusException

 Abandons a single work item
 

Throws:

io.grpc.StatusException

abandonTaskOrchestratorWorkItem

public OrchestratorService.AbandonOrchestrationTaskResponse abandonTaskOrchestratorWorkItem(OrchestratorService.AbandonOrchestrationTaskRequest request)
                                                                                     throws io.grpc.StatusException

 Abandon an orchestration work item
 

Throws:

io.grpc.StatusException

abandonTaskEntityWorkItem

public OrchestratorService.AbandonEntityTaskResponse abandonTaskEntityWorkItem(OrchestratorService.AbandonEntityTaskRequest request)
                                                                        throws io.grpc.StatusException

 Abandon an entity work item
 

Throws:

io.grpc.StatusException

rerunWorkflowFromEvent

public OrchestratorService.RerunWorkflowFromEventResponse rerunWorkflowFromEvent(OrchestratorService.RerunWorkflowFromEventRequest request)
                                                                          throws io.grpc.StatusException

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

Throws:

io.grpc.StatusException

listInstanceIDs

public OrchestratorService.ListInstanceIDsResponse listInstanceIDs(OrchestratorService.ListInstanceIDsRequest request)
                                                            throws io.grpc.StatusException

Throws:

io.grpc.StatusException

getInstanceHistory

public OrchestratorService.GetInstanceHistoryResponse getInstanceHistory(OrchestratorService.GetInstanceHistoryRequest request)
                                                                  throws io.grpc.StatusException

Throws:

io.grpc.StatusException