All Classes Interface Summary Class Summary Enum Summary Exception Summary
Class |
Description |
AccessToken |
Class that encapsulates the OAuth credentials.
|
AgentAutoConfiguration |
Configuration for various agent beans.
|
AgentCleanupProperties |
Properties related to cleaning up jobs associated to AWOL/MIA agents.
|
AgentClientMetadata |
Metadata for a Genie Agent client.
|
AgentCommand |
Interface for commands that the agent executes.
|
AgentConfigRequest |
Configuration options for the Genie agent.
|
AgentConfigRequest.Builder |
|
AgentConfigurationProperties |
|
AgentConfigurationService |
Service that provides agent runtime configuration (i.e.
|
AgentConfigurationServiceImpl |
This implementation of AgentConfigurationService forwards properties set on the server that match a given
set of regular expressions, plus any additional ones specified in configuration.
|
AgentConnectionTrackingService |
Tracks active connections and heartbeats coming from agents actively executing a job.
|
AgentConnectionTrackingServiceImpl |
This service keeps track of agent connections and heartbeats.
|
AgentConnectionTrackingServiceProperties |
|
AgentFileProtocolResolver |
Resource resolver for files local to an agent running a job that can be streamed to the server and served via API.
|
AgentFileProtocolResolverRegistrar |
Registers AgentFileProtocolResolver in the application context.
|
AgentFileResourceImpl |
Implementation of Resource for files local to an agent running a job that can be
requested and streamed to the server (so they can be served via API).
|
AgentFileStreamProperties |
|
AgentFileStreamService |
This service regularly produces a manifest of the executing job folder and pushes it to the server.
|
AgentFileStreamService |
Service to retrieve files from a remote agent while the latter is executing a job.
|
AgentFileStreamService.AgentFileResource |
A Resource for files local to a remote agent.
|
AgentFilterProperties |
|
AgentFilterService |
Service to block agent/clients that the server wants to refuse service to.
|
AgentFilterServiceImpl |
|
AgentHeartBeatService |
Service that maintains an active connection with a Genie server node by sending heart beats.
|
AgentHostnameProjection |
Projection for job hosts.
|
AgentInspectorsAutoConfiguration |
|
AgentJobCleanupTask |
Leader task that cleans up jobs whose agent crashed or disconnected.
|
AgentJobKillService |
Register an agent to listen for job kill messages from the server
and respond to them.
|
AgentJobRequest |
The builder and methods available for a request generated by a Genie agent typically from the command arguments.
|
AgentJobRequest.Builder |
Builder for a V4 Job Request.
|
AgentJobService |
Agent side job specification service for resolving and retrieving job specifications from the server.
|
AgentJobService |
A Service to collect the logic for implementing calls from the Agent when a job is launched via the CLI.
|
AgentJobServiceImpl |
|
AgentLauncher |
A interface which implementations will launch instances of an agent in some manner in order to run a job.
|
AgentLaunchersAutoConfiguration |
Auto configuration for beans responsible for launching Genie Agent instances.
|
AgentLauncherSelectionContext |
|
AgentLauncherSelector |
Interface for any classes which provide a way to select a AgentLauncher from a set of available candidates.
|
AgentLauncherSelectorManagedScript |
Extension of ResourceSelectorScript that delegates selection of a job's agent launcher when more than one
choice is available.
|
AgentLauncherSelectorScriptProperties |
Properties for agent launcher selection via script.
|
AgentLaunchException |
An exception for when the server can't launch an agent for whatever reason.
|
AgentLogManager |
Utility to locate and relocate agent log file.
|
AgentLogManagerLog4j2Impl |
Utility class that locates and relocates the agent log file.
|
AgentMetadata |
Container for Genie agent metadata and runtime information.
|
AgentMetadataImpl |
Implementation of AgentMetadata.
|
AgentMetadataInspector |
Component that inspects an Agent client metadata and makes decision on whether it is allowed to proceed.
|
AgentProperties |
Root properties class for agent.
|
AgentResourcesAutoConfiguration |
Auto Configuration for Resource classes exposed in the Agent module.
|
AgentRoutingService |
Service that tracks agent connections on the local Genie node and provides routing information for
agent connected to other nodes.
|
AgentRoutingServiceCuratorDiscoveryImpl |
|
AgentRoutingServiceCuratorDiscoveryImpl.Agent |
Payload for typed ServiceDiscovery .
|
AgentRoutingServiceProperties |
|
AgentRoutingServiceSingleNodeImpl |
Implementation of AgentRoutingService that assumes a single Genie node and tracks connections in-memory.
|
AgentRpcEndpointsAutoConfiguration |
Configures various gRPC services and related beans if gRPC functionality is enabled.
|
AgentRpcInterceptorsAutoConfiguration |
Spring Auto Configuration for default ServerInterceptor implementations for the Genie gRPC services.
|
AgentRpcServersAutoConfiguration |
Controls whether a gRPC server is configured and started for this Genie node or not.
|
AgentServicesAutoConfiguration |
Auto configuration for services needed in the agent module.
|
ApiClientMetadata |
Data class to hold information about a Genie client whether it is an API client or an Agent.
|
ApiJobRequest |
The builder and methods available for a request generated by a REST API request.
|
ApiJobRequest.Builder |
Builder for a V4 Job Request.
|
ApisAutoConfiguration |
Configuration for external API tier.
|
Application |
Application DTO.
|
Application |
An immutable V4 Application resource.
|
Application.Builder |
A builder to create applications.
|
ApplicationClient |
Client library for the Application Service.
|
ApplicationEntity |
Representation of the state of an Application.
|
ApplicationEntity_ |
|
ApplicationMetadata |
Metadata supplied by a user for an Application resource.
|
ApplicationMetadata.Builder |
A builder to create application user metadata instances.
|
ApplicationModelAssembler |
Assembles Application resources out of applications.
|
ApplicationPredicates |
|
ApplicationRequest |
Fields representing all the values users can set when creating a new Application resource.
|
ApplicationRequest.Builder |
Builder for a V4 Application Request.
|
ApplicationRestController |
REST end-point for supporting Applications.
|
ApplicationService |
An interface that provides all methods needed for the Genie application client implementation.
|
ApplicationStatus |
The available statuses for applications.
|
ApplicationStatus |
The available statuses for applications.
|
ArchivedJobMetadata |
A simple POJO for a compound value of related information to a job archived location and files.
|
ArchivedJobService |
A Service interface for working with the metadata and data of a job that was archived by the Agent upon completion.
|
ArchivedJobServiceImpl |
|
ArchiveJobOutputsStage |
Archive job output files and logs, if the job reached a state where it is appropriate to do so.
|
ArchiveStatus |
Possible archival statuses for a Job.
|
ArchiveStatusCleanupProperties |
Properties related to cleaning up jobs archive status.
|
ArchiveStatusCleanupTask |
Leader task that find jobs whose archival status was left in 'PENDING' state.
|
ArgumentDelegates |
Interfaces for command-line delegates (groups of options shared by multiple commands).
|
ArgumentDelegates.CacheArguments |
Delegate for agent dependencies cache.
|
ArgumentDelegates.CleanupArguments |
Delegate for job folder cleanup options.
|
ArgumentDelegates.JobRequestArguments |
Delegate for agent job request parameters.
|
ArgumentDelegates.RuntimeConfigurationArguments |
Delegate for agent runtime options.
|
ArgumentDelegates.ServerArguments |
Delegate for server connection options.
|
AspectsAutoConfiguration |
Auto configuration for aspects that should be applied to a running Genie server instance.
|
AttachmentService |
APIs for saving a job attachments sent in with Genie requests.
|
AttachmentServiceProperties |
|
AttachmentTooLargeException |
Exception thrown when the user tries to submit a job whose attachments exceed the limits.
|
AuditEntity |
Abstract class to support basic columns for all entities for genie.
|
AuditEntity_ |
|
AuditProjection |
Returns all the base entity attributes.
|
AwsAutoConfiguration |
Spring Boot auto configuration for AWS related beans for the Genie Agent.
|
AWSAutoConfiguration |
AWS beans.
|
AwsCredentialsProperties |
Properties related to AWS credentials for Genie on top of what Spring Cloud AWS provides.
|
AwsCredentialsProperties.SpringCloudAwsRegionProperties |
Property bindings for Spring Cloud AWS region specific properties.
|
BaseDTO |
Base fields for multiple DTOs.
|
BaseDTO.Builder<T extends BaseDTO.Builder> |
Builder pattern to save constructor arguments.
|
BaseEntity |
The base for all Genie top level entities.
|
BaseEntity_ |
|
BaseProjection |
Projection for the common fields.
|
BaseSearchResult |
Base class for search results containing common fields.
|
BlacklistedVersionAgentMetadataInspector |
An AgentMetadataInspector that rejects agent whose version matches a regular expression
(obtained via properties) and accepts everything else.
|
BraveTagAdapter |
Extension of TagAdapter that specifies that tags should be key value pairs of Strings as they are in
Brave instrumentation.
|
BraveTracePropagator |
|
BraveTracingCleanup |
Any cleanup needed at program shutdown for Brave instrumentation.
|
BraveTracingComponents |
Container DTO class for Brave based components for tracing in
Genie server and agent.
|
BucketProperties |
A property class which holds information about how to interact with a specific S3 Bucket.
|
CachingAutoConfiguration |
Auto configuration to enable Spring Boot Caching annotation support.
|
ChangeJobArchiveStatusException |
Failure to update the job archive status remotely.
|
ChangeJobStatusException |
Failure to update the job status remotely.
|
ClaimJobStage |
Claim the job, so no other agent can execute it.
|
CleanupJobDirectoryStage |
Performs cleanup of the job directory after execution.
|
CleanupStrategy |
Enum to describe the different kind of post-execution cleanup of the job directory.
|
CliAutoConfiguration |
Spring auto configuration class to contain all beans involved in the CLI for the Agent.
|
ClientMetadata |
Common base for API and Agent client metadata.
|
CloseableLock |
A simple interface representing a closeable lock.
|
Cluster |
Cluster DTO object.
|
Cluster |
An immutable V4 Cluster resource.
|
Cluster.Builder |
A builder to create clusters.
|
ClusterClient |
Client library for the Cluster Service.
|
ClusterCriteria |
Cluster Criteria.
|
ClusterEntity |
Representation of the state of the Cluster object.
|
ClusterEntity_ |
|
ClusterLeaderService |
Service interface for the abstracts the details of leadership within nodes in a Genie cluster.
|
ClusterLeaderServiceCuratorImpl |
Implementation of ClusterLeaderService using Spring's LeaderInitiator (Zookeeper/Curator based
leader election mechanism).
|
ClusterLeaderServiceLocalLeaderImpl |
|
ClusterMetadata |
Metadata supplied by a user for a Cluster resource.
|
ClusterMetadata.Builder |
A builder to create cluster user metadata instances.
|
ClusterModelAssembler |
Assembles Cluster resources out of clusters.
|
ClusterPredicates |
|
ClusterRequest |
Fields representing all the values users can set when creating a new Cluster resource.
|
ClusterRequest.Builder |
Builder for a V4 Cluster Request.
|
ClusterRestController |
REST end-point for supporting clusters.
|
ClusterSelectionContext |
|
ClusterSelector |
Interface for any classes which provide a way to select a Cluster from a set of clusters
which matched criterion provided by a user in a JobRequest and combined with the criteria for the command
selected for a given job.
|
ClusterSelectorManagedScript |
Extension of ResourceSelectorScript that delegates selection of a job's cluster when more than one choice is
available.
|
ClusterSelectorScriptProperties |
Properties for cluster selection via script.
|
ClusterService |
An interface that provides all methods needed for the Genie cluster client implementation.
|
ClusterStatus |
The possible statuses for a cluster.
|
ClusterStatus |
The possible statuses for a cluster.
|
Command |
A command data transfer object.
|
Command |
An immutable V4 Command resource.
|
Command.Builder |
A builder to create commands.
|
CommandClient |
Client library for the Command Service.
|
CommandEntity |
Representation of the state of the Command Object.
|
CommandEntity_ |
|
CommandMetadata |
Metadata supplied by a user for a Command resource.
|
CommandMetadata.Builder |
A builder to create command user metadata instances.
|
CommandModelAssembler |
Assembles Command resources out of commands.
|
CommandPredicates |
|
CommandRequest |
Fields representing all the values users can set when creating a new Command resource.
|
CommandRequest.Builder |
Builder for a V4 Command Request.
|
CommandRestController |
REST end-point for supporting commands.
|
CommandSelectionContext |
|
CommandSelector |
Interface for any classes which provide a way to select a Command from a set of commands
which matched criterion provided by a user in a JobRequest .
|
CommandSelectorManagedScript |
An extension of ResourceSelectorScript which from a set of commands and the original job request will
attempt to determine the best command to use for execution.
|
CommandSelectorManagedScriptProperties |
|
CommandService |
An interface that provides all methods needed for the Genie command client implementation.
|
CommandStatus |
The available statuses for Commands.
|
CommandStatus |
The available statuses for Commands.
|
CommonDTO |
Common fields for multiple DTOs.
|
CommonDTO.Builder<T extends CommonDTO.Builder> |
Builder pattern to save constructor arguments.
|
CommonMetadata |
Metadata fields common to all Genie resources (Jobs, clusters, etc).
|
CommonMetadata.Builder<T extends CommonMetadata.Builder> |
Builder for common fields.
|
CommonRequest |
Common fields for Resource requests (clusters, commands, jobs, etc).
|
CommonResource |
Fields common to every Genie v4 resource (cluster, command, etc).
|
CommonServicesAutoConfiguration |
Auto configuration of any services that are common to both the agent and the server.
|
CommonTracingAutoConfiguration |
Auto configuration for common tracing components within Genie server and agent.
|
ConfigureAgentStage |
Configures the agent with server-provided runtime parameters that are independent of the job.
|
ConfigureException |
Failure to obtain configuration properties from server.
|
ConfigureExecutionStage |
Sets up context state based on the type of execution and other command-line parameters.
|
ConsoleLog |
Utilities for interacting with the user terminal/console.
|
ConsoleLogListener |
Job execution listener that prints messages visible to the user in the console.
|
ControllerUtils |
Utility methods re-used in various controllers.
|
CreateJobDirectoryStage |
Creates the job directory.
|
CreateJobScriptStage |
Creates the job script (a.k.a.
|
Criterion |
Representation of various criterion options available.
|
Criterion.Builder |
Builder for creating a Criterion instance.
|
CriterionEntity |
Entity for criteria records.
|
CriterionEntity_ |
|
DataAutoConfiguration |
Default auto configuration of data related services and beans for Genie.
|
DatabaseCleanupProperties |
Properties controlling the behavior of the database cleanup leadership task.
|
DatabaseCleanupProperties.ApplicationDatabaseCleanupProperties |
Properties related to cleaning up application records from the database.
|
DatabaseCleanupProperties.ClusterDatabaseCleanupProperties |
Properties related to cleaning up cluster records from the database.
|
DatabaseCleanupProperties.CommandDatabaseCleanupProperties |
Properties related to cleaning up command records from the database.
|
DatabaseCleanupProperties.CommandDeactivationDatabaseCleanupProperties |
Properties related to setting Commands to INACTIVE status in the database.
|
DatabaseCleanupProperties.FileDatabaseCleanupProperties |
Properties related to cleaning up file records from the database.
|
DatabaseCleanupProperties.JobDatabaseCleanupProperties |
Properties related to cleaning up job records from the database.
|
DatabaseCleanupProperties.TagDatabaseCleanupProperties |
Properties related to cleaning up tag records from the database.
|
DatabaseCleanupTask |
A LeaderTask which will clean up the database of old records if desired.
|
DataServiceRetryAspect |
Aspect implementation of retrying the data service methods on certain failures.
|
DataServiceRetryProperties |
All properties related to data service retry template in Genie.
|
DataServices |
Container class for encapsulating all the various data related services in Genie to ease dependency patterns.
|
DefaultBraveTagAdapterImpl |
Default implementation of BraveTagAdapter which is just a proxy for the actual call.
|
DefaultDirectoryWriter |
A default directory writer implementation.
|
DefaultDirectoryWriter.Directory |
DTO for representing a directory contents.
|
DefaultDirectoryWriter.Entry |
DTO for representing information about an entry within a job directory.
|
DetermineJobFinalStatusStage |
Sends the server the final job status, if the job reached a state where it is appropriate to do so.
|
DirectoryManifest |
A manifest of all the files and subdirectories in a directory.
|
DirectoryManifest.Factory |
Factory that encapsulates directory manifest creation.
|
DirectoryManifest.Filter |
This interface defines a filter function used during creation of the manifest.
|
DirectoryManifest.ManifestEntry |
Representation of the metadata for a job file on a given underlying storage system.
|
DirectoryWriter |
Interface for methods to convert a directory to various String representations.
|
DiskCleanupProperties |
Properties controlling the behavior of the database cleanup leadership task.
|
DiskCleanupTask |
This task runs on every Genie node and is responsible for cleaning up the local disk so that space can be
recaptured.
|
DownloadDependenciesStage |
Download dependencies such as binaries and configurations attached to the job and its dependent entities.
|
DownloadException |
Exception thrown by services that fail to download dependencies for a job.
|
DownloadService |
Service to download a set of files to local disk.
|
DownloadService.Manifest |
Manifest containing source (URIs) and their expected destination on disk after download.
|
DownloadService.Manifest.Builder |
Builder for Manifest.
|
DtoConverters |
Utility class to help converting between V3 and V4 DTOs during migration period.
|
EntityModelAssemblers |
A simple container DTO for passing all known resource assemblers around.
|
EntityV3DtoConverters |
Converters between entities and V3 DTOs.
|
EntityV4DtoConverters |
Utility methods for converting from V4 DTO to entities and vice versa.
|
EnvVarBraveTracePropagatorImpl |
|
EventsAutoConfiguration |
Configuration related to Eventing within the Genie application.
|
ExecutionAutoConfiguration |
Spring auto configuration for beans required for job execution.
|
ExecutionEnvironment |
Elements that should be brought into an execution environment for a given resource (job, cluster, etc).
|
ExecutionEnvironmentDTO |
Base class DTO for DTOs which require a setup file.
|
ExecutionEnvironmentDTO.Builder<T extends ExecutionEnvironmentDTO.Builder> |
A builder for helping to create instances.
|
ExecutionResourceCriteria |
Container for various options for user supplying criteria for the execution environment of a job.
|
ExecutionResourceProjection |
|
ExecutionStage |
Abstract base class for Genie Agent stage of execution.
|
ExecutorFactory |
A factory for Executor instances.
|
ExitCode |
Exit codes for Genie agent.
|
ExponentialBackOffTrigger |
Trigger implementation whose scheduling delay grows exponentially based on a given factor.
|
ExponentialBackOffTrigger.DelayType |
How the delay is calculated.
|
ExponentialBackOffTriggerProperties |
|
FatalJobExecutionException |
Fatal exception that should stop execution early.
|
FetchingCacheService |
Interface for a cache that downloads resources via URL and stores them on local disk for later reuse.
|
FileEntity |
File Entity.
|
FileEntity_ |
|
FileLock |
CloseableLock for a file.
|
FileLockFactory |
|
FileStreamServiceProperties |
|
FileSystemJobArchiverImpl |
An implementation of JobArchiver which attempts to copy the job directory somewhere else on the file
system for backup.
|
FinishedJob |
DTO for a job that reached a final state.
|
FinishedJob.Builder |
Builder.
|
FinishedJobProjection |
Projection for a job entity that reached a terminal status.
|
GenieAgentApplication |
Genie Agent application.
|
GenieAgentHealthIndicator |
Provides a health indicator relative to the behavior of Genie Agents and this Server.
|
GenieAgentRejectedException |
An exception to represent the case where an Agent was rejected by the server.
|
GenieAgentRunner |
Main entry point for execution after the application is initialized.
|
GenieApp |
Main Genie Spring Configuration class.
|
GenieApplicationNotFoundException |
An exception to represent the case where an application was expected to exist (e.g.
|
GenieBadRequestException |
Extension of a GenieException for all bad request failures.
|
GenieCheckedException |
Base class for Genie checked exceptions.
|
GenieClientException |
An exception class that represents all failures received by the client.
|
GenieClusterNotFoundException |
An exception to represent the case where a cluster was expected to exist (e.g.
|
GenieCommandNotFoundException |
An exception to represent the case where a command was expected to exist (e.g.
|
GenieConversionException |
Failure to convert objects into wire format or vice versa.
|
GenieCpuHealthIndicator |
Health indicator for system cpu usage.
|
GenieDefaultPropertiesPostProcessor |
Adds default properties to the Spring environment before application refresh.
|
GenieDefaultPropertiesPostProcessor |
Adds default properties to the Spring environment before application refresh.
|
GenieEventBus |
Genie Event Bus interface.
|
GenieEventBusImpl |
An event bus implementation for the Genie application to use.
|
GenieException |
The common exception class that represents a service failure.
|
GenieExceptionMapper |
Exception mapper for Genie Exceptions.
|
GenieHostInfo |
Container for information about the host a Genie process (web server or agent) is running on.
|
GenieIdAlreadyExistsException |
Exception thrown when an id is attempting to be saved that already exists in the system.
|
GenieInvalidStatusException |
Exception thrown when a status supplied by a client for as their known previous status doesn't match what the system
has in the database.
|
GenieJobAlreadyClaimedException |
Exception thrown when a job is already claimed in the system and another agent tries to claim it.
|
GenieJobNotFoundException |
An exception to represent the case where a job was expected to exist (e.g.
|
GenieJobResolutionException |
When a request for resolving a job can't be completed for some reason.
|
GenieJobResolutionRuntimeException |
When resolution fails with a runtime error, such as the selector timing out.
|
GenieJobSpecificationNotFoundException |
An exception to represent the case where a job specification was expected to exist but it doesn't.
|
GenieNetworkConfiguration |
An object that encapsulates network configurations for Genie client HTTP requests.
|
GenieNotFoundException |
Extension of a GenieException for all not found exceptions.
|
GenieObjectMapper |
A singleton for sharing a Jackson Object Mapper instance across Genie and not having to redefine the Object Mapper
everywhere.
|
GeniePreconditionException |
Extension of a GenieException for all precondition failures.
|
GenieRuntimeException |
Base class for Genie runtime exceptions.
|
GenieServerException |
Extension of a GenieException for all internal server failures.
|
GenieServerUnavailableException |
Extension of a GenieException for all server unavailable failures.
|
GenieTask |
Interface for any task that should run in the Genie system.
|
GenieTaskScheduleType |
The enumeration values which a GenieTask can be be scheduled with.
|
GenieTestApp |
Reusable Spring Boot test application.
|
GenieTimeoutException |
Extension of a GenieException for timeouts.
|
GenieUserLimitExceededException |
Extension of a GenieException for a user exceeding some limit (e.g., submitting too many jobs).
|
GenieWebHostInfo |
Extension of GenieHostInfo which adds metadata specific to the web server.
|
GenieWebRpcInfo |
Container class for RPC related properties.
|
GetJobStatusException |
Failure to retrieve job status from the server.
|
GroovyScriptUtils |
Utility functions that can be used within Groovy scripts executed from Genie.
|
GRpcAgentFileStreamServiceImpl |
|
GRpcAgentFileStreamServiceImpl |
|
GRpcAgentJobKillServiceImpl |
Implementation of the AgentJobKillService , listens for kill coming from server using long-polling.
|
GRpcAutoConfiguration |
Spring auto configuration for gRPC components.
|
GRpcHeartBeatServiceImpl |
An edge gRPC service that uses bi-directional streaming.
|
GRpcJobKillServiceImpl |
Implementation of JobKillService which uses parked gRPC requests to tell the agent to
shutdown via a user kill request if the job is in an active state.
|
GRpcJobServiceImpl |
Extension of JobServiceGrpc.JobServiceImplBase to provide
functionality for resolving and fetching specifications for jobs to be run by the Genie Agent.
|
GRpcPingServiceImpl |
Implementation of the Ping service definition.
|
GRpcServerManager |
A wrapper around a Server instance which implements AutoCloseable to control startup and shutdown
along with the application.
|
GRpcServerProperties |
Properties related to Genie's gRPC server functionality.
|
GRpcServerUtils |
Utilities for working with a gRPC Server instance.
|
GRpcServicesAutoConfiguration |
Spring auto configuration for the various gRPC services required for an agent to communicate with the Genie server.
|
H2Utils |
Utilities for working with H2 database.
|
HandshakeException |
Failure to handshake with server.
|
HandshakeStage |
Perform server handshake, to ensure server is ok with this agent running a job.
|
HateoasAutoConfiguration |
Spring auto configuration for HATEOAS module beans.
|
HealthAutoConfiguration |
Auto configuration for Health indicators related to Genie.
|
HealthCheckMetricsAspect |
Aspect around Spring Boot 'HealthIndicator' to publish metrics for status of individual indicator, as well as their
turnaround time.
|
HealthProperties |
All properties related to health thresholds in Genie.
|
HeartBeatProperties |
Properties related to Heart Beat gRPC Service.
|
HeartBeatServiceProperties |
|
HostnameUtil |
Static utility class to determine the local hostname.
|
HttpProperties |
Properties related to HTTP client configuration.
|
HttpProperties.Connect |
Connection related properties for HTTP requests.
|
HttpProperties.Read |
Read related properties for HTTP requests.
|
IdAlreadyExistsException |
Exception thrown when an resource is attempting to be saved with a unique ID that already exists in the system.
|
IdEntity |
Base class which only provides an ID.
|
IdEntity_ |
|
IdProjection |
A projection just for returning the id field of a given entity.
|
InitializeAgentStage |
Performs generic initialization.
|
InspectionReport |
|
InspectionReport.Decision |
The possible outcomes of an inspection.
|
IntegrationTestingConfiguration |
Configuration overrides for integration tests.
|
IntrospectionAutoConfiguration |
Auto configuration for shared DTO instances within the web server.
|
InvalidStateException |
Unchecked exception thrown in case a state action is executed with an unexpected state.
|
JCommanderAutoConfiguration |
Auto configuration for configuring JCommander to parse CLI arguments of the Agent.
|
Job |
Read only data transfer object representing a Job in the Genie system.
|
Job.Builder |
A builder to create jobs.
|
JobApiProjection |
A projection which allows the system to pull back whether the job was submitted via the REST API or other mechanism.
|
JobApplicationsProjection |
Projection to return just the applications associated with a given job.
|
JobArchiveException |
Exception thrown in case there is a problem with archiving files.
|
JobArchiveLocationProjection |
A projection which only returns the archive location for a job.
|
JobArchiver |
Implementations of this interface should be able to a write job files to a WritableResource root location.
|
JobArchiveService |
A service which is responsible for taking the files related to running a Genie job and backing them up to a different
location.
|
JobArchiveServiceImpl |
|
JobClient |
Client library for the Job Service.
|
JobClusterProjection |
Projection to return just the cluster for a given job.
|
JobCommandProjection |
Projection to return just the command for a given job.
|
JobCommonFieldsProjection |
Projection for common fields between pre 3.3.0 JobRequest and Job entities.
|
JobConstants |
A class holding some constants to be used everywhere.
|
JobDirectoryManifestCreatorService |
|
JobDirectoryManifestCreatorServiceImpl |
Implementation of JobDirectoryManifestCreatorService that caches manifests produced by the factory for a few
seconds, thus avoiding re-calculating the same for subsequent requests (e.g.
|
JobDirectoryManifestNotFoundException |
An exception thrown when a job was archived but the manifest of the archive can't be found in the archive location.
|
JobDirectoryManifestProtoConverter |
Converts DirectoryManifest from/to AgentManifestMessage in order to transport manifests
over gRPC.
|
JobDirectoryServerService |
This service abstracts away the details of responding to API requests for the files and directories created during
the execution of a job in the Genie ecosystem.
|
JobDirectoryServerServiceImpl |
|
JobEntity |
A row in the jobs table.
|
JobEntity_ |
|
JobEntityListener |
|
JobEnvironment |
Final values for settings of the Genie job execution environment.
|
JobEnvironment.Builder |
|
JobEnvironmentRequest |
Fields that allow manipulation of the Genie job execution container environment.
|
JobEnvironmentRequest.Builder |
|
JobExecution |
All information needed to show state of a running job.
|
JobExecution.Builder |
A builder to create job requests.
|
JobExecutionListener |
Listener of job execution.
|
JobExecutionModelAssembler |
Assembles Job Request resources out of JobRequest DTOs.
|
JobExecutionProjection |
Projection with the data present in a Genie JobExecutionEntity from pre-3.3.0.
|
JobExecutionStateMachine |
Interface JobExecutionStateMachine hides the actual state machine details.
|
JobExecutionStateMachineImpl |
Implementation of the job execution state machine.
|
JobFileState |
Representation of the metadata for a job file on a given underlying storage system.
|
JobFinishedSNSPublisher |
Publishes Amazon SNS notifications with detailed information about each completed job.
|
JobIdUnavailableException |
Exception thrown by AgentJobService when trying to reserve an ID that has already been used.
|
JobInfoAggregate |
An object to return aggregate data selected with regards to memory usage on a given Genie host.
|
JobKillService |
Interface for services to kill jobs.
|
JobKillServiceProperties |
|
JobLaunchException |
Exception during job launch.
|
JobLaunchService |
Top level coordination service responsible for taking a job request and running the job if possible.
|
JobLaunchServiceImpl |
|
JobMetadata |
Additional metadata associated with a Job Request such as client host, user agent, etc.
|
JobMetadata |
Metadata supplied by a user for a job.
|
JobMetadata.Builder |
Builder for creating a JobMetadata instance.
|
JobMetadata.Builder |
A builder to create job user metadata instances.
|
JobMetadataModelAssembler |
Assembles Job Request resources out of JobRequest DTOs.
|
JobMetadataProjection |
Projection of the jobs table which produces only the fields that were present in the pre-3.3.0
JobMetadata table before it was merged into one large jobs table.
|
JobModelAssembler |
Assembles Job resources out of job DTOs.
|
JobMonitorService |
Service that monitors the job directory and may decide to kill the job if some limit is exceeded.
|
JobMonitorServiceProperties |
|
JobNotArchivedException |
An exception thrown when a job is completed but wasn't archived and thus output isn't available.
|
JobNotFoundException |
An exception thrown when a job is not found in the system.
|
JobNotificationMetricPublisher |
Listens to job status changes and publishes metrics.
|
JobPredicates |
|
JobProcessManager |
Singleton to manage the subprocess for the actual user job this Agent instance is managing.
|
JobProcessManagerImpl |
Configures and launches a job sub-process using metadata passed through ExecutionContext.
|
JobProcessResult |
A DTO POJO to capture final information about the job process this agent process was responsible for.
|
JobProcessResult.Builder |
|
JobProjection |
Projection for the fields originally available in pre-3.3.0 JobEntity classes.
|
JobRequest |
All information needed to make a request to run a new job.
|
JobRequest |
All details a user will provide to Genie in order to run a job.
|
JobRequest.Builder |
A builder to create job requests.
|
JobRequestConverter |
|
JobRequestConverter.ConversionException |
Exception thrown in case of conversion error due to resulting object failing validation.
|
JobRequestMetadata |
Metadata gathered by the system as part of any JobRequest .
|
JobRequestModelAssembler |
Assembles Job Request resources out of JobRequest DTOs.
|
JobRequestProjection |
Projection to reproduce the JobRequest entity fields which were was a table present before 3.3.0.
|
JobReservationException |
Failure to reserve a job id for reasons other than the specified job id being already used.
|
JobResolverService |
Service API for taking inputs from a user and resolving them to concrete information that the Genie system will use
to execute the users job.
|
JobResolverServiceImpl |
|
JobRestController |
REST end-point for supporting jobs.
|
JobsActiveLimitProperties |
Properties related to number of active jobs per user.
|
JobSearchProjection |
Projection to return only the fields desired for a job with search results.
|
JobSearchResult |
This class represents the subset of data returned from a Job when a search for Jobs is conducted.
|
JobSearchResultModelAssembler |
Assembles Job resources out of job search result DTOs.
|
JobService |
An interface that provides all methods needed for the Genie job client implementation.
|
JobServiceProtoConverter |
Converter of proto messages for the JobServiceGrpc.JobServiceImplBase service to
and from V4 DTO POJO's.
|
JobServiceProtoErrorComposer |
Utility/helper to map exceptions into protocol responses.
|
JobSetupService |
Service that sets up a directory for a job to execute in.
|
JobSetupServiceProperties |
|
JobsForwardingProperties |
Properties related to job forwarding.
|
JobsLocationsProperties |
Properties for various job related locations.
|
JobsMemoryProperties |
Properties pertaining to how much memory jobs can use on Genie.
|
JobSpecification |
This DTO represents all the information needed to execute a job by the Genie Agent.
|
JobSpecification.ExecutionResource |
Common representation of resources used for job execution e.g.
|
JobSpecificationProjection |
Projection of the database fields which make up the required elements of a job specification.
|
JobSpecificationResolutionException |
Exception thrown by AgentJobService.
|
JobsProperties |
All properties related to jobs in Genie.
|
JobStateChangeEvent |
Event representing a job status change.
|
JobStateChangeSNSPublisher |
Publishes Amazon SNS notifications for fine-grained job state changes.
|
JobStatus |
Possible statuses for a Job.
|
JobStatus |
Possible statuses for a Job.
|
JobStatusMessages |
Constant strings for status message attached to a job after it terminates.
|
JobSubmission |
The payload of all gathered information from a user request to run a job via the API.
|
JobSubmission.Builder |
|
JobsUsersProperties |
Properties related to users running jobs.
|
JpaApplicationRepository |
Application repository.
|
JpaBaseRepository<E extends BaseEntity> |
A common repository for inheritance of common methods for Entities extending BaseEntity.
|
JpaClusterRepository |
Cluster repository.
|
JpaCommandRepository |
Command repository.
|
JpaCriterionRepository |
|
JpaFileRepository |
Repository for file references.
|
JpaJobRepository |
Job repository.
|
JpaPersistenceServiceImpl |
|
JpaRepositories |
Container class for encapsulating all the various JPA Repositories in Genie to ease dependency patterns.
|
JpaTagRepository |
Repository for tags.
|
JsonAttributeConverter |
An AttributeConverter to convert JsonNode objects into their String representations for storage
and vice versa.
|
JsonUtils |
Utility methods for interacting with JSON.
|
JsonUtils.InstantMillisecondSerializer |
Truncate instants to millisecond precision during ISO 8601 serialization to string for backwards compatibility.
|
JsonUtils.OptionalInstantMillisecondSerializer |
Truncate instants to millisecond precision during ISO 8601 serialization to string for backwards compatibility.
|
KillService |
Service responsible for killing the job.
|
KillService.KillSource |
Enumeration for the source of a request to kill the job.
|
LaunchJobStage |
Launches the job process.
|
LeaderAutoConfiguration |
Beans for Leadership of a Genie cluster.
|
LeaderElectionActuator |
An actuator endpoint that exposes leadership status and allows stop/start/restart of the leader election service.
|
LeaderElectionActuator.Action |
Operations that this actuator can perform on the leader service.
|
LeadershipProperties |
Properties related to static leadership election configurations.
|
LeaderTask |
Interface for any task that a node elected as the leader of a Genie cluster should run.
|
LeaderTasksCoordinator |
Class which handles coordinating leadership related tasks.
|
LocalAgentLauncherImpl |
Implementation of AgentLauncher which launched Agent instances on the local Genie hardware.
|
LocalAgentLauncherProperties |
Properties related to launching Agent processes locally.
|
LocalFileSystemAttachmentServiceImpl |
|
LocalLeader |
A class to control leadership activities when remote leadership isn't enabled and this node has been forcibly
elected as the leader.
|
LockException |
Exception thrown when there is a problem with locks.
|
LogExecutionErrorsStage |
Logs execution errors encountered so far.
|
LoggingListener |
Listener that logs state machine events and transitions.
|
ManagedScript |
Abstract script class for components that rely on an external script to be loaded and invoked at runtime.
|
ManagedScriptBaseProperties |
Base abstract properties for individual script classes to extend.
|
MetricsConstants |
Used to store constants related to metric names.
|
MetricsConstants.TagKeys |
Inner class for constants used as key to tag metrics.
|
MetricsConstants.TagValues |
Constants used as metrics tags values by various classes.
|
MetricsUtils |
Utility methods for metrics.
|
MinimumVersionAgentMetadataInspector |
|
NodeAutoConfiguration |
Auto configuration for tasks that run on every Genie server node.
|
NotFoundException |
An exception thrown when a resource is not found in the system.
|
NotificationsAutoConfiguration |
Beans related to external notifications.
|
OAuth2SecurityInterceptor |
An interceptor that adds security headers to all outgoing requests.
|
ObtainJobSpecificationStage |
Obtains job specification from server.
|
PathUtils |
Utilities to compose filesystem paths.
|
PersistedJobStatusObserver |
Interface for an observer that gets notified of job 'status' change after the latter is persisted.
|
PersistedJobStatusObserverImpl |
Observer of persisted entities modifications that publishes events on the event bus to be consumed asynchronously by
interested consumers.
|
PersistenceService |
Service API for all Genie persistence related operations.
|
PreconditionFailedException |
Exception thrown when a precondition is not met on method invocation.
|
PredicateUtils |
Utility methods for the JPA Predicate generation.
|
ProcessAutoConfiguration |
|
PropertiesMapCache |
Utility class that produces a map of properties and their values if they match a given prefix.
|
PropertiesMapCache.Factory |
|
PropertyConvertersAutoConfiguration |
Auto configuration for registering ConfigurationPropertiesBinding
beans.
|
PropertySourceUtils |
Utilities for working with Spring PropertySource .
|
ProtoConvertersAutoConfiguration |
Auto configuration of components common to both the agent and the server.
|
RandomAgentLauncherSelectorImpl |
|
RandomClusterSelectorImpl |
|
RandomCommandSelectorImpl |
|
RandomSuppliers |
Supply random types.
|
RefreshManifestStage |
Triggers a manual refresh of the cached files manifest.
|
RegexDirectoryManifestFilter |
Implementation of DirectoryManifestFilter that filters manifest entries base on a list of regular expressions
provided via properties class.
|
RegexDirectoryManifestProperties |
|
RegexRuleSet |
Utility class to match a string against an ordered set of regexes and obtain an accept/reject response.
|
RegexRuleSet.Builder |
Ruleset builder.
|
RegexRuleSet.Response |
The two responses to an input.
|
RegexRuleSet.Rule |
An individual rule in a ruleset.
|
RejectAllJobsAgentMetadataInspector |
|
RelocateLogFileStage |
Moves the agent log file into the job directory from the temporary location.
|
RequestForwardingService |
A service whose implementation should be responsible for forwarding requests between Genie server nodes.
|
RequestForwardingServiceImpl |
|
ReserveJobIdStage |
Performs job reservation, or ensures the job is pre-reserved and ready to be claimed.
|
ResolvedJob |
The payload of information representing all the concrete details the system needs to run a job.
|
ResolvedResources<R> |
Representing the result of resolving resources of type R from a Criterion .
|
ResourceSelectionContext<R> |
Context object for encapsulating state into the selectors.
|
ResourceSelectionException |
An exception thrown when a resource selector encounters an unrecoverable error while trying to select a resource
from a collection of possible resources.
|
ResourceSelectionResult<R> |
A data class for returning the results of an attempted resource selection.
|
ResourceSelectionResult.Builder<R> |
|
ResourceSelector<R,C extends ResourceSelectionContext<R>> |
Generic interface for a selector which selects a resource from a set of resources for a given job request.
|
ResourceSelectorScript<R,C extends ResourceSelectionContext<R>> |
Interface for defining the contract between the selection of a resource from a set of resources for a given
job request.
|
ResourceSelectorScriptResult<R> |
Class to represent a generic response from a script which selects a resource from a set of resources.
|
ResourceSelectorScriptResult.Builder<R> |
A builder for these the results to prevent scripts from having to redo everything based on constructors if
we change parameters.
|
ResponseMappingInterceptor |
Class that evaluates the retrofit response code and maps it to an appropriate Genie Exception.
|
RetryableJobExecutionException |
Exception thrown by state machine transition for retryable errors (e.g, network error talking to server).
|
RetryAutoConfiguration |
Auto configuration which enables Retryable for method calls on beans.
|
RetryProperties |
All properties related to Http retry template in Genie.
|
RetryProperties.ServiceSpecificProperties |
Retry properties specific to a particular service.
|
RootModelAssembler |
Assembles root resource from a JsonNode.
|
RootRestController |
Rest controller for the V3 API root.
|
S3AttachmentServiceImpl |
Implementation of the AttachmentService interface which saves attachments to AWS S3.
|
S3ClientFactory |
An AmazonS3 client factory class.
|
S3JobArchiverImpl |
|
S3ProtocolResolver |
This class implements the ProtocolResolver interface.
|
S3ProtocolResolverRegistrar |
A class which takes an instance of S3ProtocolResolver and adds it to the Spring ApplicationContext
set of ProtocolResolver .
|
SaveAttachmentException |
Exception thrown when the system tries to save a user attachment to an underlying data store and it fails for
some reason.
|
ScriptAgentLauncherSelectorImpl |
An implementation of the AgentLauncherSelector interface which uses user-provided script to make decisions
based on the list of agent launchers and the job request supplied.
|
ScriptClusterSelectorImpl |
An implementation of the ClusterSelector interface which uses user-provided script to make decisions
based on the list of clusters and the job request supplied.
|
ScriptCommandSelectorImpl |
Implementation of CommandSelector which defers the decision to a script provided by the system
administrators.
|
ScriptExecutionException |
An exception thrown when a script bean encounters an error during execution.
|
ScriptLoadingException |
An exception thrown when a script cannot be retrieved or compiled.
|
ScriptManager |
Utility to load, reload and execute scripts (in whichever format/language supported by ScriptEngine ) via URI
(e.g., local file, classpath, URL).
|
ScriptManagerProperties |
|
ScriptNotConfiguredException |
An exception thrown when a script bean is not configured an thus it cannot be loaded or executed.
|
ScriptsAutoConfiguration |
Configuration for script extensions.
|
SecurityInterceptor |
An interface whose implementation is supposed to modify the HTTP Request by adding Security credentials.
|
SelectorsAutoConfiguration |
Spring Auto Configuration for the selectors module.
|
ServicesAutoConfiguration |
Spring auto configuration for the service tier of an Agent process.
|
ServicesAutoConfiguration |
Configuration for all the services.
|
SetJobStatusFinal |
Sets the final job status (success/fail/kill).
|
SetJobStatusInit |
Updates job status when job starts initializing.
|
SetJobStatusRunning |
Updates the server job status after launch.
|
SetupFileProjection |
Projection for returning the setup file of a given entity.
|
SetUpJobException |
Exception during the set up of a job.
|
ShutdownProperties |
Properties to configure the Agent shutdown process.
|
ShutdownStage |
Performs final shutdown.
|
SimpleLoggingInterceptor |
Proof of concept server interceptor that logs gRPC requests and errors.
|
SimpleStorageRangeResource |
This class extends SimpleStorageResource in order to efficiently handle range requests.
|
SNSNotificationsProperties |
Properties to configure notification delivered via SNS.
|
SortAttribute |
Sort key for entity search results.
|
SortDirection |
Sort direction of entity search results.
|
StartFileServiceStage |
Starts the file streaming service.
|
StartHeartbeatServiceStage |
Starts the heartbeat service.
|
StartKillServiceStage |
Starts the kill service.
|
States |
Execution state machine states.
|
StatusProjection |
Projection for returning only the status of a given resource.
|
StopFileServiceStage |
Stops the file streaming service.
|
StopHeartbeatServiceStage |
Stops the heartbeat service.
|
StopKillServiceStage |
Stops the job kill service.
|
StreamBuffer |
A temporary in-memory structure to hold in-transit data.
|
SwaggerAutoConfiguration |
Spring configuration for Swagger via Spring Doc.
|
SystemArchitecture |
Application pointcut expressions.
|
TagAdapter<U,K,V> |
An interface for implementations to adapt any tags published by default OSS components for internal conventions.
|
TagEntity |
Entity representing a Tag.
|
TagEntity_ |
|
TasksAutoConfiguration |
Configuration of beans for asynchronous tasks within Genie.
|
TasksCleanup |
Performs any cleanup when the system is shutting down.
|
TasksExecutorPoolProperties |
Properties related to the thread pool for the task executor within Genie.
|
TasksSchedulerPoolProperties |
Properties related to the thread pool for the task executor within Genie.
|
TaskUtils |
Utility methods used by various Genie tasks.
|
TimeUtils |
Utility methods for dealing with time.
|
TitusAgentLauncherImpl |
Agent launcher that spawns a job in a dedicated container through Titus.
|
TitusAgentLauncherImpl.TitusAPIRetryPolicy |
A retry policy that has different behavior based on the type of exception thrown by the rest client during
calls to the Titus API.
|
TitusAgentLauncherImpl.TitusJobRequestAdapter |
An interface that should be implemented by any class which wants to modify the Titus job request before it is
sent.
|
TitusAgentLauncherProperties |
|
TitusBatchJobRequest |
Titus job request POJO.
|
TitusBatchJobRequest.Batch |
Titus batch job parameters.
|
TitusBatchJobRequest.Container |
Titus job container DTO.
|
TitusBatchJobRequest.DisruptionBudget |
Titus job disruption budget.
|
TitusBatchJobRequest.Image |
Titus job container image.
|
TitusBatchJobRequest.Immediate |
Titus job retry policy detail.
|
TitusBatchJobRequest.JobGroupInfo |
Job Group information.
|
TitusBatchJobRequest.Owner |
Titus job owner POJO.
|
TitusBatchJobRequest.Resources |
Titus job container resources POJO.
|
TitusBatchJobRequest.RetryPolicy |
Titus job retry policy.
|
TitusBatchJobRequest.SecurityProfile |
Titus job security profile.
|
TitusBatchJobRequest.SelfManaged |
Titus job disruption budget detail.
|
TitusBatchJobResponse |
Titus job response POJO.
|
TokenFetcher |
Class that contains the logic to get OAuth credentials from IDP.
|
TokenService |
A interface to fetch access tokens.
|
TracePropagator<C> |
This interface exists to provide a shared contract for how trace information is shared between the Genie
server job request handling and the agent process launch.
|
TracingConstants |
Constants used for adding metadata to tracing spans.
|
TracingListener |
A listener which adds data to spans based on the events emitted by the state machine.
|
UIController |
Controller for forwarding UI requests.
|
UniqueIdEntity |
An extendable entity class for tables which have a UniqueId field.
|
UniqueIdEntity_ |
|
UniqueIdProjection |
Projection for getting the Unique Id of a resource.
|
UNIXUtils |
Utility class for UNIX user and file permissions.
|
URIPropertyConverter |
A converter between a String and a URI to enforce well formatted schema representations of resources.
|
UserAgentInsertInterceptor |
An interceptor class that updates the User Agent String of the request with user info.
|
UserJobResourcesAggregate |
An aggregate of running jobs and memory used for a given user.
|
UserMetricsProperties |
Properties related to publishing of user metrics.
|
UserMetricsTask |
A task which publishes user metrics.
|
UserResourcesSummary |
A summary of the resources used by a given user.
|
UserRestController |
A helper RestController which allows the UI to request information about the current user.
|
Util |
CLI utility methods.
|
V4JobRequestProjection |
Projection of just the fields needed for a V4 JobRequest .
|
ValidationAutoConfiguration |
Configuration for bean validation within Genie.
|
WaitJobCompletionStage |
Wait for job process to exit.
|
WhitelistedVersionAgentMetadataInspector |
An AgentMetadataInspector that accepts agent whose version matches a regular expression
(obtained via properties) and rejects everything else.
|
ZookeeperAutoConfiguration |
Auto configuration for Zookeper components.
|
ZookeeperProperties |
Properties related to Zookeeper.
|