Package io.dapr.durabletask.implementation.protobuf

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

Specified by:

build in class io.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)