Package io.dapr.durabletask

Class TaskOrchestrationExecutor

java.lang.Object

io.dapr.durabletask.TaskOrchestrationExecutor

public final class TaskOrchestrationExecutor
extends Object

Constructor Summary

Constructors

Constructor	Description
TaskOrchestrationExecutor(TaskOrchestrationFactories orchestrationFactories, DataConverter dataConverter, Duration maximumTimerInterval, Logger logger, String appId)	Creates a new TaskOrchestrationExecutor.

Method Summary

Modifier and Type	Method	Description
TaskOrchestratorResult	execute(List<OrchestratorService.HistoryEvent> pastEvents, List<OrchestratorService.HistoryEvent> newEvents)	Executes the orchestration with the given past and new events.

Methods inherited from class java.lang.Object

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

Constructor Details

TaskOrchestrationExecutor

public TaskOrchestrationExecutor(TaskOrchestrationFactories orchestrationFactories,
 DataConverter dataConverter,
 Duration maximumTimerInterval,
 Logger logger,
 String appId)

Creates a new TaskOrchestrationExecutor.

Parameters:

orchestrationFactories - map of orchestration names to their factories

dataConverter - converter for serializing/deserializing data

maximumTimerInterval - maximum duration for timer intervals

logger - logger for orchestration execution

appId - application ID for cross-app routing

Method Details

execute

public TaskOrchestratorResult execute(List<OrchestratorService.HistoryEvent> pastEvents,
 List<OrchestratorService.HistoryEvent> newEvents)

Executes the orchestration with the given past and new events.

Parameters:

pastEvents - list of past history events

newEvents - list of new history events

Returns:

the result of the orchestrator execution