| Package | Description |
|---|---|
| com.ebay.bascomtask.core |
| Modifier and Type | Class and Description |
|---|---|
class |
Engine
Core implementation of orchestrator maintains task state during execution.
|
| Modifier and Type | Field and Description |
|---|---|
protected List<BiConsumer<Orchestrator,Object>> |
GlobalOrchestratorConfig.Config.initializers |
| Modifier and Type | Method and Description |
|---|---|
static Orchestrator |
Orchestrator.create()
Creates an Orchestrator with no name.
|
static Orchestrator |
Orchestrator.create(String name)
Creates a new named Orchestrator, which is the same as
|
static Orchestrator |
Orchestrator.create(String name,
Object arg)
Creates an Orchestrator with the given name and argument.
|
| Modifier and Type | Method and Description |
|---|---|
abstract void |
GlobalOrchestratorConfig.Config.afterDefaultInitialization(Orchestrator orchestrator,
Object arg)
Subclasses can override to provide custom logic for
GlobalOrchestratorConfig.Config.updateConfigurationOn(Orchestrator, Object). |
void |
GlobalOrchestratorConfig.Config.updateConfigurationOn(Orchestrator orchestrator,
Object arg)
Transfers configuration settings to the supplied orchestrator.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ThreadLocalRunners.firstInterceptWith(Supplier<RUNNER> fn,
BiPredicate<Orchestrator,Object> pred)
Adds a TaskRunner to each new Orchestrator at the head of the list if the supplied predicate is true.
|
void |
GlobalOrchestratorConfig.Config.initializeWith(BiConsumer<Orchestrator,Object> fn) |
void |
ThreadLocalRunners.lastInterceptWith(Supplier<RUNNER> fn,
BiPredicate<Orchestrator,Object> pred)
Adds a TaskRunner to each new Orchestrator to the tail of the list if the supplied predicate is true.
|
Copyright © 2021. All rights reserved.