- Dag<T extends Comparable<T>,R> - Interface in com.github.dexecutor.core.graph
-
Dependency would be constructed based on this APIs, Dexecutor uses this data structure to represent the dependencies between tasks
- decrementUnProcessedNodesCount() - Method in class com.github.dexecutor.core.DefaultDexecutorState
-
- decrementUnProcessedNodesCount() - Method in interface com.github.dexecutor.core.DexecutorState
-
decrements the count of total number of unprocessed nodes
- DefaultDag<T extends Comparable<T>,R> - Class in com.github.dexecutor.core.graph
-
Default implementation of Graph
- DefaultDag() - Constructor for class com.github.dexecutor.core.graph.DefaultDag
-
- DefaultDexecutor<T extends Comparable<T>,R> - Class in com.github.dexecutor.core
-
Default implementation of @Dexecutor
- DefaultDexecutor(DexecutorConfig<T, R>) - Constructor for class com.github.dexecutor.core.DefaultDexecutor
-
Creates the Executor with Config
- DefaultDexecutorState<T extends Comparable<T>,R> - Class in com.github.dexecutor.core
-
- DefaultDexecutorState() - Constructor for class com.github.dexecutor.core.DefaultDexecutorState
-
- DefaultExecutionEngine<T extends Comparable<T>,R> - Class in com.github.dexecutor.core
-
Default Executor, which internally operates on @ExecutorService
- DefaultExecutionEngine(DexecutorState<T, R>, ExecutorService) - Constructor for class com.github.dexecutor.core.DefaultExecutionEngine
-
Creates the default instance given @ExecutorService, internally it uses @CompletionService
- DependencyAware<T extends Comparable<T>> - Interface in com.github.dexecutor.core.graph
-
Implementors should be aware of the the dependencies between entities
- Dexecutor<T extends Comparable<T>,R> - Interface in com.github.dexecutor.core
-
Main Interface for Dexecutor framework, It provides api to build the graph and and to kick off the execution.
- DexecutorConfig<T extends Comparable<T>,R> - Class in com.github.dexecutor.core
-
Configuration Object for Dexecutor framework.
- DexecutorConfig(ExecutorService, TaskProvider<T, R>) - Constructor for class com.github.dexecutor.core.DexecutorConfig
-
Construct the object with mandatory params, rest are optional
- DexecutorConfig(ExecutionEngine<T, R>, TaskProvider<T, R>) - Constructor for class com.github.dexecutor.core.DexecutorConfig
-
Construct the object with mandatory params, rest are optional
- DexecutorState<T extends Comparable<T>,R> - Interface in com.github.dexecutor.core
-
Represents Dexecutor state at any given moment of time, It basically tracks
Phase : Current Phase Dexecutor is in
Graph : Exposes API around building graph
unprocessed nodes count : How many nodes are waiting to be processed
processed nodes : Nodes which are processed till that point
Discontinued nodes : Nodes for which processing should continue after system comes to valid state
- Duration - Class in com.github.dexecutor.core
-
- Duration(long, TimeUnit) - Constructor for class com.github.dexecutor.core.Duration
-