Package app.ductape.sdk.features.executor

Class DefaultFeatureExecutor

java.lang.Object

app.ductape.sdk.features.executor.DefaultFeatureExecutor

All Implemented Interfaces:

FeatureLocalExecutor

public class DefaultFeatureExecutor
extends Object
implements FeatureLocalExecutor

Sprint 4 — default in-process feature executor.

This ports the core TS WorkflowExecutor semantics into Java: deterministic sequential orchestration, step retries/backoff, conditional/loop/parallel composition, checkpoint/resume bookkeeping, signal-aware pause/cancel hooks, and saga-style rollback/compensation summaries.

Domain-specific side effects (database, graph, broker, storage, vector, quota, fallback, healthcheck, action) are pluggable through registerHandler(java.lang.String, app.ductape.sdk.features.executor.DefaultFeatureExecutor.StepHandler). If no handler is registered for a domain step, the executor returns a TS-shaped no-op output that includes the step input and kind; this keeps pure orchestration tests deterministic while allowing applications to wire real services without processor round-trips.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	DefaultFeatureExecutor.StepHandler

Constructor Summary

Constructors

Constructor	Description
DefaultFeatureExecutor()

Method Summary

Modifier and Type	Method	Description
Map<String,Object>	execute(FeatureExecutionContext context)	Run the feature definition end-to-end.
DefaultFeatureExecutor	registerHandler(String kind, DefaultFeatureExecutor.StepHandler handler)	Register or replace a domain handler by step kind wire value, e.g.
Map<String,Object>	replay(FeatureExecutionContext context, String fromStep)	TS replay from a specific step (or default = from start).
Map<String,Object>	resume(FeatureExecutionContext context, Object fromCheckpoint, String fromStep)	TS resume from a checkpoint (or step).
boolean	supports(FeatureExecutionContext context)	Optional probe used by FeatureService to skip local execution when the executor cannot run a particular feature (e.g.

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultFeatureExecutor

public DefaultFeatureExecutor()

Method Details

registerHandler

public DefaultFeatureExecutor registerHandler(String kind,
 DefaultFeatureExecutor.StepHandler handler)

Register or replace a domain handler by step kind wire value, e.g. database.

execute

public Map<String,Object> execute(FeatureExecutionContext context)

Description copied from interface: FeatureLocalExecutor

Run the feature definition end-to-end. The implementation is responsible for step orchestration, retries, and per-step rollback semantics that the TS WorkflowExecutor provides.

Return shape SHOULD include keys: status, feature_id, output, error, execution_time, completed_steps, step_timings, failed_step, rollback_info (mirroring TS IWorkflowExecutionResult). FeatureService normalizes the result into the public TS-shaped envelope (success/status/ data/feature_id/error) before returning to callers.

Specified by:

execute in interface FeatureLocalExecutor

replay

public Map<String,Object> replay(FeatureExecutionContext context,
 String fromStep)

Description copied from interface: FeatureLocalExecutor

TS replay from a specific step (or default = from start). Defaults to FeatureLocalExecutor.execute(app.ductape.sdk.features.FeatureExecutionContext) so simple executors stay parity-shaped without extra work.

Specified by:

replay in interface FeatureLocalExecutor

resume

public Map<String,Object> resume(FeatureExecutionContext context,
 Object fromCheckpoint,
 String fromStep)

Description copied from interface: FeatureLocalExecutor

TS resume from a checkpoint (or step). Defaults to FeatureLocalExecutor.execute(app.ductape.sdk.features.FeatureExecutionContext) so simple executors stay parity-shaped without extra work.

Specified by:

resume in interface FeatureLocalExecutor

supports

public boolean supports(FeatureExecutionContext context)

Description copied from interface: FeatureLocalExecutor

Optional probe used by FeatureService to skip local execution when the executor cannot run a particular feature (e.g. uses unsupported step types). Defaults to true.

Specified by:

supports in interface FeatureLocalExecutor