Package io.dapr.durabletask.runner

Class OrchestratorRunner

java.lang.Object

io.dapr.durabletask.runner.DurableRunner

io.dapr.durabletask.runner.OrchestratorRunner

All Implemented Interfaces:

Runnable

public class OrchestratorRunner
extends DurableRunner

Field Summary

Fields inherited from class io.dapr.durabletask.runner.DurableRunner

sidecarClient, tracer, workItem

Constructor Summary

Constructors

Constructor	Description
OrchestratorRunner(OrchestratorService.WorkItem workItem, TaskOrchestrationExecutor taskOrchestrationExecutor, TaskHubSidecarServiceGrpc.TaskHubSidecarServiceBlockingStub sidecarClient, io.opentelemetry.api.trace.Tracer tracer)	Constructs a new instance of the OrchestratorRunner class.

Method Summary

Modifier and Type	Method	Description
void	run()

Methods inherited from class io.dapr.durabletask.runner.DurableRunner

getSidecarAddress, logException

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

OrchestratorRunner

public OrchestratorRunner(OrchestratorService.WorkItem workItem,
 TaskOrchestrationExecutor taskOrchestrationExecutor,
 TaskHubSidecarServiceGrpc.TaskHubSidecarServiceBlockingStub sidecarClient,
 @Nullable
 io.opentelemetry.api.trace.Tracer tracer)

Constructs a new instance of the OrchestratorRunner class.

Parameters:

workItem - The work item containing details about the orchestrator task to be executed.

taskOrchestrationExecutor - The executor responsible for running task orchestration logic.

sidecarClient - The gRPC stub for communication with the Task Hub sidecar service.

tracer - An optional tracer used for distributed tracing, can be null.

Method Details

run

public void run()