All Classes and Interfaces
Class
Description
Abstract implementation of
TaskTideWorkloadAcquisitionPolicy
to take the field policy building, and field getter aspects.Abstract class to wrap standardize class fields
across manager commands, getters/setters etc, JSON (de)serialization,
wraps the execution process with a validation step.
Abstract class deals with the broader parts of config,
ArgumentMap, path etcAbstract
ItemStore to implement getting ItemStore attributes,
handling the locking/releasing of masterDB for updates, and
caching/clearing the master prototype to another file.Abstract class to implement shared logic
Implements the upper level CRUD logic for
TaskTideService
against TaskTideRepository for related TaskTideModel.AbstractWorkflowStrategy to hold shared operational logic
of concrete WorkflowStrategyType instances.Data object for representing
AbstractAcquisitionPolicyEnum to support operations of valid
AbstractAcquisitionPolicyParsing records for annotation with
CustomAnnotation
or Job Environment IdBase data model for command-line argument
For building
ArgumentHolds an
Argument collectionDeprecated in favor of
ArgumentTreeImplementation of
GenericTree for ArgumentMapDenotes type of argument
Intercept requests for authentication properties
Interface through which authentication
is verified.
Container class for
AuthenticationSchemeFactory for
AuthenticationSchemeSupported
AuthenticationSchemeData model for authentication and authorization
Collection of common authentication and
authorization methods
Bucketing based on crc32
Bucket key used for hashing
Enumeration fo valid builder types
Various static methods to make
TaskTideModel objectsFunctional interface for executing a workflow
of DB/
ItemStore operations over provided
ItemStoreSessionCDI container interface to provide
Valid implementations of
CdiContainerProviderGathers
TaskTideConfig into map, entry-point
for both their configuration, and application of command-line
arguments.Class to parse command-line arguments into
ArgumentTreeDeprecated in favour of
CliParserStandardize peripheral requirements for
ManagerCommandFor building
CommandSpecBuilderValid ways
ManagerCommand can interact with TaskTideRepositoryClass to hold collection of custom annotations
as a
LinkedHashMapCustomAnnotation builderCustomAnnotation JSON SERDEUtility to handle dates
Enum to hold valid backend target instances: Master, Prototype, or Both
Class for handling the deletion of
TaskTideModelEmbedded authentication scheme to support unit tests
where RSA key pair is statically configured by
WebApiUtils.Class to template the
TaskTideEngineWorker module parametersManagerTask generatorEnum of valid task types
Deprecated.
Observer for the full processing life-cycle of an executor
Deprecated.
Deprecated.
Class to carry logic for exporting to json
Enum to support exports
Package private class for managing the acquisitions and
releasing of
FileChannelClass specializing in applying, and releasing
FileChannelActorCollection of useful File I/O methods
Deprecated.
Generic implementation of tree
Datapoint of
GenericTreeConfigure global settings for TaskTideClient used across
each client type.
Enum to hold values for various host names
Model class to hold host file lock data
Package private factory for creating
HostLockGenerating Hostname tasks
ManagerCommand for importing tasks from JSON
query string, or fileFunctional interface to standardize file handling operations
from
ManagerCommandParsing
WorkItem collection from target filePackage private class for coordinating locks on NSF where member
nodes are unknown and dynamic.
Uses
HostLock data model to conduct
package private OS file lock with the same
semantics as the inter process mutexBase model storing records in
ItemStoreEnumeration of valid item states of ToDo, Locked, Done, Error
Data model class for representing task summary counts
across valid
ItemState instanceInterface for storing
Items into RocksDB/SqliteOrganizing checked exceptions from
ItemStoreStrategy to hold evaluation logic around whether or not
to allow the opening/closing of
ItemStore to take
that bloat out these classes using ThrowableItemStoreOperationFunctional interface for defining operations
against
ItemStore throwing ItemStoreUncheckedExceptionUtilize RocksDB as a
TaskTideRepository through the ItemStoreSupports creation of
ItemStore TaskTideRepository,
TaskTideService, and initialize the TaskTideServiceManagerOperations supported under an
ItemStore session, ultimately
these are pushed back to the DB just bypassing the Open/Close
connection aspects until done.Step TaskTideRepository backed by RocksDB/SQLiteEnum to support operations over
ItemStore based on the
type value, and strategic factoryOrganizing unchecked exceptions from
ItemStoreCollection of useful methods supporting the
ItemStoreWorkflow TaskTideRepository backed by RocksDBWorkItem TaskTideRepository backed by RocksDBModel class to hold the task related to a WorkItem
Allow ProcessLog objects to be built where all fields are optional
Class to handle the execution of
ItemTaskClass to hold the logic for constructing
TaskTideExecutor for ItemTaskCoordinates the work across the
WorkerObservers for the processing of WorkItem
through the TaskTideEngineObserver chain for ItemTasksClass to the logic for constructing
TaskTideEngineObserver of ItemTaskObserverTask
ProcessingStrategy implemntation for ItemTaskClass for handling
ItemTask statesItemTask specific time keeperProcesses workload of
WorkItemBuilding
ItemTaskTraverserEnumeration of valid WorkItem Types (Single, Nested)
Configurer for Jakarta NoSQL Template
Enum to support valid Jakarta NoSQL databases
Data class to hold collection of host meta-data running job
such as where Hostname/Environment etc, job Id, OS, and.
JobEnvironment builderREST resource for interacting with
JobEnvironmentServiceService to provide
JobEnvironment interactions to backend DB (TaskTideRepository).Holds valid
JobEnvironment statesEnum to support strategic construction of
JobEnvironment.Applies JPA micro-profile config values to
ArgumentTreeJpaRepository orientated repository for JobEnvironmentJpaRepository repository for MetricProfileJpaRepository orientated repository for MetricProfileJPA Entity Manager repository allowing subclasses to be persisted
to Relational backends (ex Postgres, MySQL etc)
Supports creation of
JpaRepository TaskTideRepository,
TaskTideService, and initialize the TaskTideServiceManagerPersistence of
StepPersistence of
WorkflowPersistence of
WorkItemFor parsing
WorkItem from ManagerTask recordsSingle class for JSON Serde with(out) indentation
Interface adding support for
BulkOperation
across multiple ItemStoreSession under "one" connection.Functional interface allowing donor
ItemStoreSession
to be re-used recipient ItemStoreSession mapEnum to support valid actions covered by the Manager
Interface through which interactions against
TaskTideService
are executedClass to template the
TaskTideServiceManager module parametersEnum to suport
ManagerAction over specific TaskTideModel.Simple converter class for converting user input into
ItemTaskHolds metrics data for
MetricType instances.Builder class for
MetricData.REST resource for interacting with
MetricDataServiceService to provide
MetricData interactions to backend DB (TaskTideRepository).Holds
ProfileData and computes mean across its
observed MetricData datapoints as its own Entity.MetricProfile builderREST resource for interacting with
MetricProfileServiceService to provide
MetricProfile interactions to backend DB (TaskTideRepository).Represent valid
MetricData instancesAbstract for building model classes
Class for providing builders
Model class for
MutexActorDefines the package private semantics for electing leader mutex
Places exceptions under class with different messages
Configure properties for the
MutexOrchestratorHolds constants for building
MutexClass for creating
Mutex, assuming MutexConstants
have been configuredFile utility for operations with
MutexEnum to support operation over valid file types
Utility for
Mutex labellingImplementing
Currently the algorithm only runs as a waiter/holds the executing thread.
MutexActor lock by composing the NfsMutexActor,
and FileChannelActor which collectively offer a Mutex which
can be acquired and released.Currently the algorithm only runs as a waiter/holds the executing thread.
Enum of valid states for distributed lock
Package private enum to support strategic physical locking/and
release method.
Runtime exceptions for Mutex
Package private implementation of the
InterProcessMutexActor for
shared file systemAllows no authentication scheme to support
testing, and piloting TaskTide
Generating NS Lookup tasks
Holds each
WorkerObserver in a list, with onStart, onProcessing, and onEnd
methods operating iteratively where the failure of one breaks exeuction chain.Class to support handling of failed
WorkerObserver actionEnum to support logic handling optional/critical
WorkerObserverOIDC
AuthenticationScheme.Record to hold config properties of OIDC backend
OIDC Provider type
Generating ping tasks
Class responsible for spawning OS process for the command of
ItemTaskStrategy for handling how to process a task,
namely Nested/UnNested task
Model class to hold standard error and out logs
Allow ProcessLog objects to be built where all fields are optional
Holds a collection of
MetricData observed over a time-period,
for embedding into MetricProfileCDI container provider which explicitly uses embedded
Arc/Quarkus runtimeEnum of valid repository types
Command class handling resetting
TaskTideModelMapper to for converting
AcquisitionPolicyJsonResource
to/from TaskTideWorkloadAcquisitionPolicy.Represent valid model types which
ResourcePolicyMapper applies toUse
RocksDB as storage backendRound robin strategy to consume steps of workflow FIFO queue
CDI container provider which explicitly uses no embedded runtime
compatible with Jakarta
Generating seq tasks
Sequential consummation strategy for steps of a workflow
Class to create
TaskTideServicePrint splash message
Class to add support for SQLite
JSON-B compatible representation of
Resolves yasson-3.0.>=4 bump where generic key does not seem supported
PR = https://github.com/BrenKenna/TaskTide/pull/15
Commit = https://github.com/BrenKenna/TaskTide/commit/5a4894d3421c9d7a926fa54f7bb9988ef244a60d
StateSummaryType
maps
Resolves yasson-3.0.>=4 bump where generic key does not seem supported
PR = https://github.com/BrenKenna/TaskTide/pull/15
Commit = https://github.com/BrenKenna/TaskTide/commit/5a4894d3421c9d7a926fa54f7bb9988ef244a60d
For static initialization of valid
StateSummary.Referential interface for state summaries
Model class for a collection of work items as metadata
Allow
Step objects to be built where all fields are optionalREST resource for interacting with
StepServiceService to provide
Step interactions to backend DB (TaskTideRepository).Stdout and Stderr log stream handler for
ProcessExecutor.Carries logic for summarizing
TaskTideModel,
ItemStateAcquisition policy targeting a single collection of
WorkItemGenerator to support creation of random tasks
Model class to hold the data from task processing
Allow TaskLogging objects to be built where all fields are optional
Enumeration of valid Task States: Pending, Active, Error, Complete
Data model class for representing task summary counts
across valid
TaskState instanceRuns the desited
TaskTideClientAbstract for standardizing client logic for
configuration, running, and clean-up
Enum of valid TaskTide client modules
Utility class for
TaskTideClient interfaceInterface for configuring and population programs
ArgumentTreeChecked exceptions for engine components
Class for configuring implementing the
TaskTideEngineWorkerInterface to decouple the
WorkerObserver from their operation in chainRuntimeException for engine componentsCollection of useful engine methods
Engine worker using the
TargetedAcquisitionPolicy interface
to acquire a workload to process, and process them through the
TaskTideWorkloadTraverser interface.Abstract class to handle the nuances of workload execution
Checked exceptions for TaskTide-Manager
Manager client for providing IO functionality for
Workloads, Steps, and WorkItems
Unchecked exception for TaskTide-Manager
Collection of static methods to support
ManagerTask to TaskTideModel.Interface to facilitate model class mapping from
WorkflowService -> Step
StepService -> WorkItem
WorkItemService -> ItemTask
Interface to support methods around model classes
Enum of valid model types
Interface for TaskTideRepository
Root application path
Marker interface for TaskTideService, want to restrict eventually.
Container class
TaskTideService for WorkItem,
Step, Workflow, JobEnvironment,
MetricProfile, and JobEnvironmentInterface for starting embedded HTTP server
Checked exception for API components
Launches configured
TaskTideWebApi providing a web-based interface
for CRUD operationsChecked exception for API components
Marker interface for TaskTide processing
Single class to provide the builders for Observer, Processors and Executors
Class to support operations over valid
TaskTideWorkerUnitInterface for defining policies for consuming workloads.
Class to template process of processing a list of
TaskTideModelDeprecated.
Deprecated.
NoSQL orientated repository for
JobEnvironmentNoSQL orientated repository for
MetricDataNoSQL orientated repository for
MetricProfileTemplate Model Repository adding utility and collection info
Supports creation of
Template TaskTideRepository,
TaskTideService, and initialize the TaskTideServiceManagerStep repository
Workflow repository
WorkItem repository
Functional interface for defining operations
against
ItemStoreDeprecated.
Checked
Exception for TraverserRuntimeException for TraverserClass to support various actions
Class to template the
TaskTideWebApi module parametersUtility to support unit-testing web api resources.
CDI container provider which explicitly uses embedded
Weld runtimeDefines valid execution policies of the worker
Container class to hold instances of each
TaskTideWorkerUnit
for their use across the engineEnum for valid model types used by engine
Model class for a collection of steps as a workflow/pipeline
AbstractAcquisitionPolicy for user-defined workflow as an order provided
list of Step names.Defines specifications for different ways to fetch workload
from a collection of steps
Allow
Workflow objects to be built where all fields are optionalREST resource for interacting with
WorkflowServiceService to provide WorkflowService interactions to backend DB
Builds required
WorkflowAcquisitionStrategyEnum to support operations over valid
RoundRobinWorkflowStrategy modesEnum to support operations over valid
WorkflowAcquisitionStrategy
instances, and is the interface for initializing their strategic buildingTaskTideModel class for Work Items
Allow
WorkItem objects to be built where all fields are optionalProcesses provided collection of data using a given
WorkItemLineHandler.Functional interface for standardizing operations over input files
Coordinates the work across the
WorkerObservers for the processing of WorkItem
through the TaskTideEngineObserver chain for WorkItemsClass to the logic for build
TaskTideEngineObserver of WorkItemObserverHandles processing
WorkItem as Nested/Un-Nested taskREST resource for interacting with
WorkItemServiceService to provide
WorkItem interactions to backend DBClass for observing the processing of
WorkItemWorkItem specific TimeKeeperObserverClass to hold logic for fetching a workload from the
TaskTideServiceManager.Building
WorkItemTraverserModel class for worklaod
Allow ProcessLog objects to be built where all fields are optional
Converter class for JSON-Serde of Workloads
Configurations for workload acquisition policy