Package com.ebay.bascomtask.core

Interface Summary

Interface	Description
CommonConfig	Configuration settings.
ConsumerTask	Function tasks added through 'fn()' methods on Orchestrator allow CompletableFuture tasks to be created from lambda expressions that do not return a value.
Orchestrator	Provides entry points for task method activation, and for common configuration among all such tasks.
SupplierTask<R>	Function tasks added through 'fn()' methods on Orchestrator allow CompletableFuture tasks to be created from lambda expressions that supply a return value.
TaskInterface<T>	Common interface that all user POJO task interfaces must implement in order to be added to an Orchestrator, for example like this:
TaskMeta	Exposes execution statistics to TaskRunners.
TaskRun	User task wrapper exposed to TaskRunners.
TaskRunner	Interface for task execution hooks that allow custom code to be inserted before and after the invocation of task methods.
TriConsumer<T,U,V>	Three-arg variant of BiConsumer.

Class Summary

Class	Description
ConsumerTask.ConsumerTask1<IN>	An ConsumerTask that takes 1 argument.
ConsumerTask.ConsumerTask2<IN1,IN2>	An ConsumerTask that takes 2 arguments.
Engine	Core implementation of orchestrator maintains task state during execution.
GlobalOrchestratorConfig	Maintains configuration settings that will be applied to new Orchestrators.
GlobalOrchestratorConfig.Config	Default implementation maintains values that are transferred to an Orchestrator on demand.
LaneRunner<T extends TaskRunner>	Establishes a TaskRunner creation capability that for each new Orchestrator created in this thread will be applied and recorded for later retrieval.
SupplierTask.SupplierTask0<R>	An SupplierTask that takes no arguments.
SupplierTask.SupplierTask1<T,R>	An SupplierTask that takes 1 argument.
SupplierTask.SupplierTask2<T,U,R>	An SupplierTask that takes 2 arguments.

Enum Summary

Enum	Description
SpawnMode	Defines thread spawning behavior for the BascomTask framework.
TimeoutStrategy	Strategies for dealing with execution timeouts that impact threads spawned during the execution of a request such as CompletableFuture.get(long, TimeUnit).