Package app.ductape.sdk.features

Class FeatureService

java.lang.Object

app.ductape.sdk.features.FeatureService

public class FeatureService
extends Object

Constructor Summary

Constructors

Constructor	Description
FeatureService(EnvType env, RequestContext auth)
FeatureService(EnvType env, RequestContext auth, JobsService jobsService)
FeatureService(RequestContext auth)
FeatureService(RequestContext auth, ProductsService productsService, ProcessorApiService processorApiService, FeatureApiService featureApiService)
FeatureService(RequestContext auth, ProductsService productsService, ProcessorApiService processorApiService, FeatureApiService featureApiService, LogApiService logApiService, JobsService jobsService)

Method Summary

Modifier and Type	Method	Description
RequestContext	auth()
Map<String,Object>	compare(Map<String,Object> options)
Map<String,Object>	dispatch(Map<String,Object> options)	TS dispatch: schedule feature via JobsService (requires Redis-backed jobs in typical deployments).
Map<String,Object>	execute(Map<String,Object> options)	TS IExecuteWorkflowOptions: feature or tag identifies the feature; session/cache resolved like TS.
Map<String,Object>	executeLocal(Map<String,Object> options)	TS WorkflowExecutor#execute parity entry point.
boolean	hasLocalExecutor()	Whether a FeatureLocalExecutor is registered.
Map<String,Object>	history(Map<String,Object> options)
Object	query(Map<String,Object> options)
Map<String,Object>	relatedExecutions(Map<String,Object> options)
Map<String,Object>	replay(Map<String,Object> options)
Map<String,Object>	replayFromStep(Map<String,Object> options)
Map<String,Object>	replayLocal(Map<String,Object> options)	TS replay on the local executor.
Map<String,Object>	restart(Map<String,Object> options)
Map<String,Object>	resume(Map<String,Object> options)
Map<String,Object>	resumeLocal(Map<String,Object> options)	TS resume on the local executor.
void	setCacheManager(CacheManager cacheManager)	TS workflows.service.ts: optional shared CacheManager for execute/dispatch idempotency.
void	setLocalExecutor(FeatureLocalExecutor executor)	Register an in-process FeatureLocalExecutor (TS WorkflowExecutor parity seam).
void	signal(Map<String,Object> options)
Map<String,Object>	status(Map<String,Object> options)
Map<String,Object>	stepDetail(Map<String,Object> options)

Methods inherited from class java.lang.Object

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

Constructor Details

FeatureService

public FeatureService(RequestContext auth)

FeatureService

public FeatureService(EnvType env,
 RequestContext auth)

FeatureService

public FeatureService(EnvType env,
 RequestContext auth,
 JobsService jobsService)

FeatureService

public FeatureService(RequestContext auth,
 ProductsService productsService,
 ProcessorApiService processorApiService,
 FeatureApiService featureApiService)

FeatureService

public FeatureService(RequestContext auth,
 ProductsService productsService,
 ProcessorApiService processorApiService,
 FeatureApiService featureApiService,
 LogApiService logApiService,
 JobsService jobsService)

Method Details

auth

public RequestContext auth()

setCacheManager

public void setCacheManager(CacheManager cacheManager)

TS workflows.service.ts: optional shared CacheManager for execute/dispatch idempotency.

setLocalExecutor

public void setLocalExecutor(FeatureLocalExecutor executor)

Register an in-process FeatureLocalExecutor (TS WorkflowExecutor parity seam).

executeLocal(Map), replayLocal(Map), and resumeLocal(Map) delegate to it after the same session/cache/log pipeline used by execute(Map). By default, the Java SDK wires DefaultFeatureExecutor; callers can replace it with a richer engine or pass null to disable local execution.

hasLocalExecutor

public boolean hasLocalExecutor()

Whether a FeatureLocalExecutor is registered. Useful for callers that want to gate behavior at runtime without try/catching the configuration error from executeLocal(Map).

execute

public Map<String,Object> execute(Map<String,Object> options)

TS IExecuteWorkflowOptions: feature or tag identifies the feature; session/cache resolved like TS.

executeLocal

public Map<String,Object> executeLocal(Map<String,Object> options)

TS WorkflowExecutor#execute parity entry point.

Runs the feature against the registered FeatureLocalExecutor instead of submitting to the remote processor. Re-uses the same session-resolution + cache-first + structured-log pipeline as execute(Map) so the public envelope is identical (success/status/data/feature_id/error).

Throws:

IllegalStateException - when no local executor has been registered.

replayLocal

public Map<String,Object> replayLocal(Map<String,Object> options)

TS replay on the local executor. Honors from_step when supplied.

resumeLocal

public Map<String,Object> resumeLocal(Map<String,Object> options)

TS resume on the local executor. Honors from_checkpoint and from_step.

dispatch

public Map<String,Object> dispatch(Map<String,Object> options)

TS dispatch: schedule feature via JobsService (requires Redis-backed jobs in typical deployments).

signal

public void signal(Map<String,Object> options)

query

public Object query(Map<String,Object> options)

replay

public Map<String,Object> replay(Map<String,Object> options)

restart

public Map<String,Object> restart(Map<String,Object> options)

resume

public Map<String,Object> resume(Map<String,Object> options)

replayFromStep

public Map<String,Object> replayFromStep(Map<String,Object> options)

status

public Map<String,Object> status(Map<String,Object> options)

history

public Map<String,Object> history(Map<String,Object> options)

stepDetail

public Map<String,Object> stepDetail(Map<String,Object> options)

relatedExecutions

public Map<String,Object> relatedExecutions(Map<String,Object> options)

compare

public Map<String,Object> compare(Map<String,Object> options)