- cacheArgumentsDelegate() - Method in class com.netflix.genie.agent.cli.CliAutoConfiguration
-
Provide a bean for cache command line arguments.
- cacheGenieFileTransferService(FileTransferFactory, FileCacheProperties, LocalFileTransferImpl, MeterRegistry) - Method in class com.netflix.genie.web.configs.GenieServicesAutoConfiguration
-
Get an instance of the Cache Genie File Transfer service.
- CacheGenieFileTransferService - Class in com.netflix.genie.web.services.impl
-
Caches the downloaded file from the remote location.
- CacheGenieFileTransferService(FileTransferFactory, String, LocalFileTransferImpl, MeterRegistry) - Constructor for class com.netflix.genie.web.services.impl.CacheGenieFileTransferService
-
Constructor.
- changeJobStatus(String, JobStatus, JobStatus, String) - Method in interface com.netflix.genie.agent.execution.services.AgentJobService
-
Notify the server of a change of job status.
- changeJobStatus(ChangeJobStatusRequest, StreamObserver<ChangeJobStatusResponse>) - Method in class com.netflix.genie.web.rpc.grpc.services.impl.v4.GRpcJobServiceImpl
-
When the agent wants to tell the system that the status of a job is changed this API is called.
- ChangeJobStatusException - Exception in com.netflix.genie.agent.execution.exceptions
-
Failure to update the job status remotely.
- ChangeJobStatusException(String) - Constructor for exception com.netflix.genie.agent.execution.exceptions.ChangeJobStatusException
-
Constructor with message.
- ChangeJobStatusException(String, Throwable) - Constructor for exception com.netflix.genie.agent.execution.exceptions.ChangeJobStatusException
-
Constructor with message and cause.
- changeOwnershipOfDirectory(String, String) - Method in class com.netflix.genie.web.jobs.workflow.impl.JobKickoffTask
-
Method to change the ownership of a directory.
- channel(ArgumentDelegates.ServerArguments) - Method in class com.netflix.genie.agent.rpc.GRpcAutoConfiguration
-
Provide a lazy ManagedChannel
bean if none was already defined for communicating with the Genie server.
- channelLoggingInterceptor() - Method in class com.netflix.genie.agent.rpc.GRpcAutoConfiguration
-
Provide a lazy ChannelLoggingInterceptor
bean.
- characterEncodingFilter() - Method in class com.netflix.genie.web.configs.GenieApiAutoConfiguration
-
Character encoding filter that forces content-type in response to be UTF-8.
- CHECK_DELAY - Static variable in class com.netflix.genie.web.data.entities.CommandEntity_
-
- CHECK_DELAY - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- checkDelay - Static variable in class com.netflix.genie.web.data.entities.CommandEntity_
-
- checkDelay - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- checkProcess() - Method in interface com.netflix.genie.web.util.ProcessChecker
-
Check the status of the process the process checker was constructed to check.
- checkProcess() - Method in class com.netflix.genie.web.util.UnixProcessChecker
-
Check the status of the process the process checker was constructed to check.
- CHILDREN_PID_ENV_VAR - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
Environment variable run script children pid.
- claimed - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- CLAIMED - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- claimJob(String, AgentClientMetadata) - Method in interface com.netflix.genie.agent.execution.services.AgentJobService
-
Claim a given job, telling the server that this agent is about to begin execution.
- claimJob(String, AgentClientMetadata) - Method in class com.netflix.genie.web.data.services.jpa.JpaJobPersistenceServiceImpl
-
Set a job identified by id
to be owned by the agent identified by agentClientMetadata
.
- claimJob(ClaimJobRequest, StreamObserver<ClaimJobResponse>) - Method in class com.netflix.genie.web.rpc.grpc.services.impl.v4.GRpcJobServiceImpl
-
When an agent is claiming responsibility and ownership for a job this API is called.
- claimJob(String, AgentClientMetadata) - Method in interface com.netflix.genie.web.services.AgentJobService
-
Set a job identified by id
to be owned by the agent identified by agentClientMetadata
.
- claimJob(String, AgentClientMetadata) - Method in class com.netflix.genie.web.services.impl.AgentJobServiceImpl
-
Set a job identified by id
to be owned by the agent identified by agentClientMetadata
.
- claimJob(String, AgentClientMetadata) - Method in interface com.netflix.genie.web.services.JobPersistenceService
-
Set a job identified by id
to be owned by the agent identified by agentClientMetadata
.
- CLASS_NAME - Static variable in class com.netflix.genie.web.util.MetricsConstants.TagKeys
-
Key to tag a class name.
- cleanup() - Method in class com.netflix.genie.agent.execution.statemachine.actions.BaseStateAction
-
Clean up any cruft create by the action once the job has executed (or aborted).
- cleanup() - Method in interface com.netflix.genie.agent.execution.statemachine.actions.StateAction
-
Clean up any cruft create by the action once the job has executed (or aborted).
- cleanup() - Method in class com.netflix.genie.test.web.configs.IntegrationTestingConfiguration
-
Get rid of the directories created by the system temporarily.
- cleanup() - Method in class com.netflix.genie.web.tasks.leader.AgentJobCleanupTask
-
Any cleanup that needs to be performed when this task is stopped due to leadership being revoked.
- cleanup() - Method in class com.netflix.genie.web.tasks.leader.ClusterCheckerTask
-
Any cleanup that needs to be performed when this task is stopped due to leadership being revoked.
- cleanup() - Method in class com.netflix.genie.web.tasks.leader.DatabaseCleanupTask
-
Any cleanup that needs to be performed when this task is stopped due to leadership being revoked.
- cleanup() - Method in class com.netflix.genie.web.tasks.leader.LeadershipTask
-
Any cleanup that needs to be performed when this task is stopped due to leadership being revoked.
- cleanup() - Method in class com.netflix.genie.web.tasks.leader.UserMetricsTask
-
Any cleanup that needs to be performed when this task is stopped due to leadership being revoked.
- CLEANUP_HELP_MESSAGE - Static variable in enum com.netflix.genie.agent.execution.CleanupStrategy
-
Section of the help message explaining the cleanup strategy.
- cleanupArguments() - Method in class com.netflix.genie.agent.cli.CliAutoConfiguration
-
- cleanupJobAction(ExecutionContext, AgentJobService) - Method in class com.netflix.genie.agent.execution.statemachine.actions.StateMachineActionsAutoConfiguration
-
Provide a lazy CleanupJobAction
bean.
- CleanupStrategy - Enum in com.netflix.genie.agent.execution
-
Enum to describe the different kind of post-execution cleanup of the job directory.
- CliAutoConfiguration - Class in com.netflix.genie.agent.cli
-
Spring auto configuration class to contain all beans involved in the CLI for the Agent.
- CliAutoConfiguration() - Constructor for class com.netflix.genie.agent.cli.CliAutoConfiguration
-
- CLIENT_ID_KEY - Static variable in class com.netflix.genie.security.oauth2.pingfederate.PingFederateRemoteTokenServices
-
- CLIENT_ID_KEY - Static variable in class com.netflix.genie.security.oauth2.pingfederate.PingFederateUserAuthenticationConverter
-
- ClientMetadata - Class in com.netflix.genie.common.internal.dto.v4
-
Common base for API and Agent client metadata.
- ClientMetadata(String) - Constructor for class com.netflix.genie.common.internal.dto.v4.ClientMetadata
-
Constructor.
- close() - Method in class com.netflix.genie.agent.utils.locks.impl.FileLock
- CloseableLock - Interface in com.netflix.genie.agent.utils.locks
-
A simple interface representing a closeable lock.
- closeForCompleted() - Method in class com.netflix.genie.web.util.StreamBuffer
-
Close this buffer because all expected data has been written
Reading will return the end of stream marker after all data has been consumed.
- closeForError(Throwable) - Method in class com.netflix.genie.web.util.StreamBuffer
-
Close this buffer before all data is written due to an error.
- Cluster - Class in com.netflix.genie.common.dto
-
Cluster DTO object.
- Cluster(Cluster.Builder) - Constructor for class com.netflix.genie.common.dto.Cluster
-
Constructor used only by the build() method of the builder.
- Cluster - Class in com.netflix.genie.common.internal.dto.v4
-
An immutable V4 Cluster resource.
- Cluster(String, Instant, Instant, ExecutionEnvironment, ClusterMetadata) - Constructor for class com.netflix.genie.common.internal.dto.v4.Cluster
-
Constructor.
- cluster - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- CLUSTER - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- Cluster.Builder - Class in com.netflix.genie.common.dto
-
A builder to create clusters.
- CLUSTER_CRITERIA - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- CLUSTER_ID - Static variable in class com.netflix.genie.web.util.MetricsConstants.TagKeys
-
Key to tag metrics with cluster ID.
- CLUSTER_NAME - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- CLUSTER_NAME - Static variable in class com.netflix.genie.web.util.MetricsConstants.TagKeys
-
Key to tag metrics with cluster name.
- CLUSTER_PATH_VAR - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
File Path prefix to be used while creating directories for cluster files to local dir.
- CLUSTER_URL_SUFFIX - Static variable in interface com.netflix.genie.client.apis.ClusterService
-
Path to Clusters.
- ClusterCheckerProperties - Class in com.netflix.genie.web.properties
-
Properties associated with the cluster checking task.
- ClusterCheckerProperties() - Constructor for class com.netflix.genie.web.properties.ClusterCheckerProperties
-
- clusterCheckerTask(GenieHostInfo, ClusterCheckerProperties, JobSearchService, JobPersistenceService, RestTemplate, WebEndpointProperties, MeterRegistry) - Method in class com.netflix.genie.web.configs.GenieTasksAutoConfiguration
-
- ClusterCheckerTask - Class in com.netflix.genie.web.tasks.leader
-
A task which checks to see if this leader node can communicate with all other nodes in the cluster.
- ClusterCheckerTask(GenieHostInfo, ClusterCheckerProperties, JobSearchService, JobPersistenceService, RestTemplate, WebEndpointProperties, MeterRegistry) - Constructor for class com.netflix.genie.web.tasks.leader.ClusterCheckerTask
-
Constructor.
- ClusterClient - Class in com.netflix.genie.client
-
Client library for the Cluster Service.
- ClusterClient(Retrofit) - Constructor for class com.netflix.genie.client.ClusterClient
-
Constructor.
- ClusterClient(String, List<Interceptor>, GenieNetworkConfiguration) - Constructor for class com.netflix.genie.client.ClusterClient
-
- ClusterCommandsProjection - Interface in com.netflix.genie.web.data.entities.projections
-
Projection to return only the commands for a cluster.
- ClusterCriteria - Class in com.netflix.genie.common.dto
-
Cluster Criteria.
- ClusterCriteria(Set<String>) - Constructor for class com.netflix.genie.common.dto.ClusterCriteria
-
Create a cluster criteria object with the included tags.
- clusterCriteria - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- ClusterEntity - Class in com.netflix.genie.web.data.entities
-
Representation of the state of the Cluster object.
- ClusterEntity() - Constructor for class com.netflix.genie.web.data.entities.ClusterEntity
-
Default Constructor.
- ClusterEntity_ - Class in com.netflix.genie.web.data.entities
-
- ClusterEntity_() - Constructor for class com.netflix.genie.web.data.entities.ClusterEntity_
-
- ClusterLoadBalancer - Interface in com.netflix.genie.web.services
-
Interface for the cluster load-balancer, which returns the "best" cluster to
run job on from an array of candidates.
- ClusterMetadata - Class in com.netflix.genie.common.internal.dto.v4
-
Metadata supplied by a user for a Cluster resource.
- ClusterMetadata.Builder - Class in com.netflix.genie.common.internal.dto.v4
-
A builder to create cluster user metadata instances.
- clusterName - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- clusterPersistenceService(JpaTagPersistenceService, JpaFilePersistenceService, JpaApplicationRepository, JpaClusterRepository, JpaCommandRepository) - Method in class com.netflix.genie.web.configs.GenieJpaAutoConfiguration
-
- ClusterPersistenceService - Interface in com.netflix.genie.web.services
-
Abstraction layer to encapsulate data ClusterConfig functionality.
Classes implementing this abstraction layer must be thread-safe
- clusterProcessorTask(MeterRegistry, GenieFileTransferService) - Method in class com.netflix.genie.web.configs.GenieJobWorkflowAutoConfiguration
-
Create an Cluster Task bean that processes the cluster needed for a job.
- ClusterRequest - Class in com.netflix.genie.common.internal.dto.v4
-
Fields representing all the values users can set when creating a new Cluster resource.
- ClusterRequest.Builder - Class in com.netflix.genie.common.internal.dto.v4
-
Builder for a V4 Cluster Request.
- ClusterResource - Class in com.netflix.genie.web.hateoas.resources
-
HATEOAS resource representation of a Cluster.
- ClusterResource(Cluster) - Constructor for class com.netflix.genie.web.hateoas.resources.ClusterResource
-
Constructor.
- ClusterResourceAssembler - Class in com.netflix.genie.web.hateoas.assemblers
-
Assembles Cluster resources out of clusters.
- ClusterResourceAssembler() - Constructor for class com.netflix.genie.web.hateoas.assemblers.ClusterResourceAssembler
-
- ClusterRestController - Class in com.netflix.genie.web.controllers
-
REST end-point for supporting clusters.
- ClusterRestController(ClusterPersistenceService, ClusterResourceAssembler, CommandResourceAssembler) - Constructor for class com.netflix.genie.web.controllers.ClusterRestController
-
Constructor.
- clusters - Static variable in class com.netflix.genie.web.data.entities.CommandEntity_
-
- CLUSTERS - Static variable in class com.netflix.genie.web.data.entities.CommandEntity_
-
- ClusterService - Interface in com.netflix.genie.client.apis
-
An interface that provides all methods needed for the Genie cluster client implementation.
- ClusterStatus - Enum in com.netflix.genie.common.dto
-
The possible statuses for a cluster.
- ClusterTask - Class in com.netflix.genie.web.jobs.workflow.impl
-
Implementation of the workflow task for processing cluster information a job needs.
- ClusterTask(MeterRegistry, GenieFileTransferService) - Constructor for class com.netflix.genie.web.jobs.workflow.impl.ClusterTask
-
Constructor.
- com.netflix.genie - package com.netflix.genie
-
Main classes for running Genie within a servlet container like Tomcat.
- com.netflix.genie.agent - package com.netflix.genie.agent
-
Classes shared by the entire Agent project.
- com.netflix.genie.agent.cli - package com.netflix.genie.agent.cli
-
Commands for Agent and their command-line arguments descriptors.
- com.netflix.genie.agent.configs - package com.netflix.genie.agent.configs
-
Spring configuration classes for the Genie Agent.
- com.netflix.genie.agent.configs.processors - package com.netflix.genie.agent.configs.processors
-
Any environment post processors for Spring that are needed.
- com.netflix.genie.agent.execution - package com.netflix.genie.agent.execution
-
Job execution.
- com.netflix.genie.agent.execution.exceptions - package com.netflix.genie.agent.execution.exceptions
-
Execution exceptions.
- com.netflix.genie.agent.execution.services - package com.netflix.genie.agent.execution.services
-
Services used during job execution components.
- com.netflix.genie.agent.execution.services.impl - package com.netflix.genie.agent.execution.services.impl
-
Implementations of execution services for the Agent.
- com.netflix.genie.agent.execution.services.impl.grpc - package com.netflix.genie.agent.execution.services.impl.grpc
-
gRPC based implementations of the agent execution services.
- com.netflix.genie.agent.execution.statemachine - package com.netflix.genie.agent.execution.statemachine
-
Job execution state machine.
- com.netflix.genie.agent.execution.statemachine.actions - package com.netflix.genie.agent.execution.statemachine.actions
-
State actions for JobExecutionStateMachine.
- com.netflix.genie.agent.execution.statemachine.listeners - package com.netflix.genie.agent.execution.statemachine.listeners
-
Listeners for JobExecutionStateMachine.
- com.netflix.genie.agent.rpc - package com.netflix.genie.agent.rpc
-
RPC clients and utilities.
- com.netflix.genie.agent.utils - package com.netflix.genie.agent.utils
-
Utility classes.
- com.netflix.genie.agent.utils.locks - package com.netflix.genie.agent.utils.locks
-
Locks used for caching resources.
- com.netflix.genie.agent.utils.locks.impl - package com.netflix.genie.agent.utils.locks.impl
-
CloseableLock implementations used for caching resources.
- com.netflix.genie.client - package com.netflix.genie.client
-
Client library for Genie.
- com.netflix.genie.client.apis - package com.netflix.genie.client.apis
-
Package containing all the interfaces encapsulating request calls to Genie.
- com.netflix.genie.client.configs - package com.netflix.genie.client.configs
-
Package containing configuration classes for Genie client.
- com.netflix.genie.client.exceptions - package com.netflix.genie.client.exceptions
-
A package containing all exceptions in the Genie client.
- com.netflix.genie.client.interceptors - package com.netflix.genie.client.interceptors
-
A package that contains all interceptors to be added to modify outgoing requests and incoming responses.
- com.netflix.genie.client.security.oauth2 - package com.netflix.genie.client.security.oauth2
-
Package containing Oauth security related classes.
- com.netflix.genie.client.security.oauth2.impl - package com.netflix.genie.client.security.oauth2.impl
-
Package containing implementations of interfaces defined in the oauth package.
- com.netflix.genie.common.dto - package com.netflix.genie.common.dto
-
Data transfer objects for Genie for the APIs as well as the internal services.
- com.netflix.genie.common.dto.search - package com.netflix.genie.common.dto.search
-
DTOs specifically related to search results.
- com.netflix.genie.common.exceptions - package com.netflix.genie.common.exceptions
-
Classes that represent Genie exceptions.
- com.netflix.genie.common.internal.aws.s3 - package com.netflix.genie.common.internal.aws.s3
-
This package contains classes and utilities for working with the AWS S3 service.
- com.netflix.genie.common.internal.configs - package com.netflix.genie.common.internal.configs
-
Common Spring Auto Configuration classes for use in both Agent and Server.
- com.netflix.genie.common.internal.dto - package com.netflix.genie.common.internal.dto
-
DTOs shared between the Agent and the Server code base.
- com.netflix.genie.common.internal.dto.v4 - package com.netflix.genie.common.internal.dto.v4
-
DTOs for Genie v4.
- com.netflix.genie.common.internal.dto.v4.converters - package com.netflix.genie.common.internal.dto.v4.converters
-
Package for converting gRPC messages to V4 DTOs and vice versa.
- com.netflix.genie.common.internal.dto.v4.files - package com.netflix.genie.common.internal.dto.v4.files
-
Immutable DTOs used for representing state of a jobs files at any given time.
- com.netflix.genie.common.internal.exceptions - package com.netflix.genie.common.internal.exceptions
-
All checked exceptions internal to Genie.
- com.netflix.genie.common.internal.exceptions.unchecked - package com.netflix.genie.common.internal.exceptions.unchecked
-
All unchecked (Runtime) exceptions for Genie.
- com.netflix.genie.common.internal.jobs - package com.netflix.genie.common.internal.jobs
-
Common job classes shared by agent and server.
- com.netflix.genie.common.internal.services - package com.netflix.genie.common.internal.services
-
Any service interfaces and implementations shared between the Agent and the Server codebases.
- com.netflix.genie.common.internal.services.impl - package com.netflix.genie.common.internal.services.impl
-
Implementations of service interfaces found in com.netflix.genie.common.internal.services
.
- com.netflix.genie.common.internal.util - package com.netflix.genie.common.internal.util
-
Internal utilities shared by client and server components.
- com.netflix.genie.common.util - package com.netflix.genie.common.util
-
Classes that have common Genie utilities.
- com.netflix.genie.security - package com.netflix.genie.security
-
All the classes that handle configuring security for Genie.
- com.netflix.genie.security.configs - package com.netflix.genie.security.configs
-
Configuration classes related to security.
- com.netflix.genie.security.configs.processors - package com.netflix.genie.security.configs.processors
-
Spring environment post processors for the security module.
- com.netflix.genie.security.oauth2 - package com.netflix.genie.security.oauth2
-
Classes for securing Genie using oauth2.
- com.netflix.genie.security.oauth2.pingfederate - package com.netflix.genie.security.oauth2.pingfederate
-
Classes to augment the default OAuth2 Spring support to add compatibility with Ping Federate as the primary
authentication and token store.
- com.netflix.genie.security.saml - package com.netflix.genie.security.saml
-
Classes for interacting with a SAML IDP for SSO.
- com.netflix.genie.security.x509 - package com.netflix.genie.security.x509
-
Classes for securing Genie endpoints using x509 certificate authentication.
- com.netflix.genie.test.suppliers - package com.netflix.genie.test.suppliers
-
Functional interfaces for suppliers.
- com.netflix.genie.test.web.configs - package com.netflix.genie.test.web.configs
-
Any configurations used during web testing.
- com.netflix.genie.ui.controllers - package com.netflix.genie.ui.controllers
-
Controllers for MVC.
- com.netflix.genie.web.aspect - package com.netflix.genie.web.aspect
-
Various Spring aspects for Genie web.
- com.netflix.genie.web.configs - package com.netflix.genie.web.configs
-
Various Spring configurations for Genie web.
- com.netflix.genie.web.configs.aws - package com.netflix.genie.web.configs.aws
-
Spring configuration classes for running on AWS.
- com.netflix.genie.web.configs.processors - package com.netflix.genie.web.configs.processors
-
Any environment post processors for Spring that are needed.
- com.netflix.genie.web.controllers - package com.netflix.genie.web.controllers
-
Classes that represent the REST-ful resources provided by Genie.
- com.netflix.genie.web.data.entities - package com.netflix.genie.web.data.entities
-
Entity classes that represent the Genie data model/internal state.
- com.netflix.genie.web.data.entities.aggregates - package com.netflix.genie.web.data.entities.aggregates
-
A package containing aggregates interfaces for Spring Data JPA.
- com.netflix.genie.web.data.entities.projections - package com.netflix.genie.web.data.entities.projections
-
A package containing projection interfaces for Spring Data JPA.
- com.netflix.genie.web.data.entities.projections.v4 - package com.netflix.genie.web.data.entities.projections.v4
-
Projections for V4 data types.
- com.netflix.genie.web.data.entities.v4 - package com.netflix.genie.web.data.entities.v4
-
Classes related to working with entities for Genie v4.
- com.netflix.genie.web.data.repositories.jpa - package com.netflix.genie.web.data.repositories.jpa
-
Classes used for accessing data with JPA.
- com.netflix.genie.web.data.repositories.jpa.specifications - package com.netflix.genie.web.data.repositories.jpa.specifications
-
Package containing specification classes for use with JPA queries through Spring.
- com.netflix.genie.web.data.services.jpa - package com.netflix.genie.web.data.services.jpa
-
Implementation of Genie services using JPA.
- com.netflix.genie.web.data.utils - package com.netflix.genie.web.data.utils
-
Utilities for working with JPA or the Genie databases in general.
- com.netflix.genie.web.events - package com.netflix.genie.web.events
-
Contains all the classes which extend ApplicationEvent
for customized events
within Genie.
- com.netflix.genie.web.hateoas.assemblers - package com.netflix.genie.web.hateoas.assemblers
-
Classes used to assemble resources from model objects.
- com.netflix.genie.web.hateoas.resources - package com.netflix.genie.web.hateoas.resources
-
Resource wrappers for the model classes.
- com.netflix.genie.web.health - package com.netflix.genie.web.health
-
Classes for reporting health information to actuator.
- com.netflix.genie.web.jobs - package com.netflix.genie.web.jobs
-
Classes for core Genie job execution.
- com.netflix.genie.web.jobs.workflow - package com.netflix.genie.web.jobs.workflow
-
Classes for core Genie job execution.
- com.netflix.genie.web.jobs.workflow.impl - package com.netflix.genie.web.jobs.workflow.impl
-
Classes for core Genie job execution.
- com.netflix.genie.web.properties - package com.netflix.genie.web.properties
-
This package contains classes which represent configuration properties for type binding and simpler usage.
- com.netflix.genie.web.resources.agent - package com.netflix.genie.web.resources.agent
-
Spring Resource
abstraction applied to file streamed during a running agent job.
- com.netflix.genie.web.resources.writers - package com.netflix.genie.web.resources.writers
-
Interfaces and implementations to convert a directory to given representations.
- com.netflix.genie.web.rpc.grpc.interceptors - package com.netflix.genie.web.rpc.grpc.interceptors
-
Custom interceptors for the gRPC server.
- com.netflix.genie.web.rpc.grpc.services.impl.v4 - package com.netflix.genie.web.rpc.grpc.services.impl.v4
-
Implementations of V4 gRPC service interfaces.
- com.netflix.genie.web.services - package com.netflix.genie.web.services
-
Interfaces for core Genie services.
- com.netflix.genie.web.services.impl - package com.netflix.genie.web.services.impl
-
Implementations of services specific to a web application.
- com.netflix.genie.web.services.loadbalancers.script - package com.netflix.genie.web.services.loadbalancers.script
-
Classes related to a JavaScript engine based cluster load balancer.
- com.netflix.genie.web.tasks - package com.netflix.genie.web.tasks
-
Classes which Genie will run basically as cron jobs to do various impl.
- com.netflix.genie.web.tasks.job - package com.netflix.genie.web.tasks.job
-
Tasks for monitoring and acting on jobs.
- com.netflix.genie.web.tasks.leader - package com.netflix.genie.web.tasks.leader
-
Classes involved in leadership election and tasks associated with being a cluster leader.
- com.netflix.genie.web.tasks.node - package com.netflix.genie.web.tasks.node
-
Classes that run as tasks on every node in a Genie cluster.
- com.netflix.genie.web.util - package com.netflix.genie.web.util
-
General utility classes.
- Command - Class in com.netflix.genie.common.dto
-
A command data transfer object.
- Command(Command.Builder) - Constructor for class com.netflix.genie.common.dto.Command
-
Constructor used by the builder.
- Command - Class in com.netflix.genie.common.internal.dto.v4
-
An immutable V4 Command resource.
- Command(String, Instant, Instant, ExecutionEnvironment, CommandMetadata, List<String>, Integer, long) - Constructor for class com.netflix.genie.common.internal.dto.v4.Command
-
Constructor.
- command - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- COMMAND - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- Command.Builder - Class in com.netflix.genie.common.dto
-
A builder to create commands.
- COMMAND_ARGS - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- COMMAND_CRITERION - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- COMMAND_ID - Static variable in class com.netflix.genie.web.util.MetricsConstants.TagKeys
-
Key to tag metrics with command ID.
- COMMAND_NAME - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- COMMAND_NAME - Static variable in class com.netflix.genie.web.util.MetricsConstants.TagKeys
-
Key to tag metrics with command name.
- COMMAND_PATH_VAR - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
File Path prefix to be used while creating directories for command files to local dir.
- COMMAND_URL_SUFFIX - Static variable in interface com.netflix.genie.client.apis.CommandService
-
Path to Commands.
- commandArgs - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- CommandClient - Class in com.netflix.genie.client
-
Client library for the Command Service.
- CommandClient(Retrofit) - Constructor for class com.netflix.genie.client.CommandClient
-
Constructor.
- CommandClient(String, List<Interceptor>, GenieNetworkConfiguration) - Constructor for class com.netflix.genie.client.CommandClient
-
- commandCriterion - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- CommandEntity - Class in com.netflix.genie.web.data.entities
-
Representation of the state of the Command Object.
- CommandEntity() - Constructor for class com.netflix.genie.web.data.entities.CommandEntity
-
Default Constructor.
- CommandEntity_ - Class in com.netflix.genie.web.data.entities
-
- CommandEntity_() - Constructor for class com.netflix.genie.web.data.entities.CommandEntity_
-
- commandFactory(List<AgentCommandArguments>, ApplicationContext) - Method in class com.netflix.genie.agent.cli.JCommanderAutoConfiguration
-
Provide a command factory bean.
- CommandMetadata - Class in com.netflix.genie.common.internal.dto.v4
-
Metadata supplied by a user for a Command resource.
- CommandMetadata.Builder - Class in com.netflix.genie.common.internal.dto.v4
-
A builder to create command user metadata instances.
- commandName - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- commandPersistenceService(JpaTagPersistenceService, JpaFilePersistenceService, JpaApplicationRepository, JpaClusterRepository, JpaCommandRepository) - Method in class com.netflix.genie.web.configs.GenieJpaAutoConfiguration
-
- CommandPersistenceService - Interface in com.netflix.genie.web.services
-
Abstraction layer to encapsulate CommandConfig functionality.
Classes implementing this abstraction layer must be thread-safe.
- commandProcessorTask(MeterRegistry, GenieFileTransferService) - Method in class com.netflix.genie.web.configs.GenieJobWorkflowAutoConfiguration
-
Create an Command Task bean that processes the command needed for a job.
- CommandRequest - Class in com.netflix.genie.common.internal.dto.v4
-
Fields representing all the values users can set when creating a new Command resource.
- CommandRequest.Builder - Class in com.netflix.genie.common.internal.dto.v4
-
Builder for a V4 Command Request.
- CommandResource - Class in com.netflix.genie.web.hateoas.resources
-
HATEOAS resource representation of a Command.
- CommandResource(Command) - Constructor for class com.netflix.genie.web.hateoas.resources.CommandResource
-
Constructor.
- CommandResourceAssembler - Class in com.netflix.genie.web.hateoas.assemblers
-
Assembles Command resources out of commands.
- CommandResourceAssembler() - Constructor for class com.netflix.genie.web.hateoas.assemblers.CommandResourceAssembler
-
- CommandRestController - Class in com.netflix.genie.web.controllers
-
REST end-point for supporting commands.
- CommandRestController(CommandPersistenceService, CommandResourceAssembler, ApplicationResourceAssembler, ClusterResourceAssembler) - Constructor for class com.netflix.genie.web.controllers.CommandRestController
-
Constructor.
- commands - Static variable in class com.netflix.genie.web.data.entities.ApplicationEntity_
-
- COMMANDS - Static variable in class com.netflix.genie.web.data.entities.ApplicationEntity_
-
- commands - Static variable in class com.netflix.genie.web.data.entities.ClusterEntity_
-
- COMMANDS - Static variable in class com.netflix.genie.web.data.entities.ClusterEntity_
-
- CommandService - Interface in com.netflix.genie.client.apis
-
An interface that provides all methods needed for the Genie command client implementation.
- CommandStatus - Enum in com.netflix.genie.common.dto
-
The available statuses for Commands.
- CommandTask - Class in com.netflix.genie.web.jobs.workflow.impl
-
Implementation of the workflow task for processing command information.
- CommandTask(MeterRegistry, GenieFileTransferService) - Constructor for class com.netflix.genie.web.jobs.workflow.impl.CommandTask
-
Constructor.
- CommonDTO - Class in com.netflix.genie.common.dto
-
Common fields for multiple DTOs.
- CommonDTO.Builder<T extends CommonDTO.Builder> - Class in com.netflix.genie.common.dto
-
Builder pattern to save constructor arguments.
- CommonMetadata - Class in com.netflix.genie.common.internal.dto.v4
-
Metadata fields common to all Genie resources (Jobs, clusters, etc).
- CommonMetadata.Builder<T extends CommonMetadata.Builder> - Class in com.netflix.genie.common.internal.dto.v4
-
Builder for common fields.
- CommonRequest - Interface in com.netflix.genie.common.internal.dto.v4
-
Common fields for Resource requests (clusters, commands, jobs, etc).
- CommonServicesAutoConfiguration - Class in com.netflix.genie.common.internal.configs
-
Auto configuration of any services that are common to both the agent and the server.
- CommonServicesAutoConfiguration() - Constructor for class com.netflix.genie.common.internal.configs.CommonServicesAutoConfiguration
-
- composePath(File, String...) - Static method in class com.netflix.genie.agent.utils.PathUtils
-
Append an arbitrary set of components to a base path.
- composePath(Path, String...) - Static method in class com.netflix.genie.agent.utils.PathUtils
-
Append an arbitrary set of components to a base path.
- CONFIG_FILE_PATH_PREFIX - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
File Path prefix to be used while creating paths for config files downloaded by Genie to local dir.
- configs - Static variable in class com.netflix.genie.web.data.entities.ApplicationEntity_
-
- CONFIGS - Static variable in class com.netflix.genie.web.data.entities.ApplicationEntity_
-
- configs - Static variable in class com.netflix.genie.web.data.entities.ClusterEntity_
-
- CONFIGS - Static variable in class com.netflix.genie.web.data.entities.ClusterEntity_
-
- configs - Static variable in class com.netflix.genie.web.data.entities.CommandEntity_
-
- CONFIGS - Static variable in class com.netflix.genie.web.data.entities.CommandEntity_
-
- configs - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- CONFIGS - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- configure(SpringApplicationBuilder) - Method in class com.netflix.genie.GenieWar
- configure(ResourceServerSecurityConfigurer) - Method in class com.netflix.genie.security.oauth2.OAuth2Config
- configure(HttpSecurity) - Method in class com.netflix.genie.security.oauth2.OAuth2Config
- configure(HttpSecurity) - Method in class com.netflix.genie.security.saml.SAMLConfig
-
Defines the web based security configuration.
- configure(WebSecurity) - Method in class com.netflix.genie.security.SecurityConfig
- configure(HttpSecurity) - Method in class com.netflix.genie.security.SecurityConfig
- configure(HttpSecurity) - Method in class com.netflix.genie.security.x509.X509Config
- configureAgentAction(ExecutionContext) - Method in class com.netflix.genie.agent.execution.statemachine.actions.StateMachineActionsAutoConfiguration
-
Provide a lazy ConfigureAgentAction
bean.
- configureGlobal(AuthenticationManagerBuilder) - Method in class com.netflix.genie.security.SecurityConfig
-
Configure the global authentication manager.
- Connect() - Constructor for class com.netflix.genie.web.properties.HttpProperties.Connect
-
- contentLength() - Method in class com.netflix.genie.web.resources.agent.AgentFileResourceImpl
- contextProvider(SAMLProperties) - Method in class com.netflix.genie.security.saml.SAMLConfig
-
Provider of the SAML context.
- ControllerUtils - Class in com.netflix.genie.web.controllers
-
Utility methods re-used in various controllers.
- coordinateJob(JobRequest, JobMetadata) - Method in class com.netflix.genie.web.services.impl.JobCoordinatorServiceImpl
-
Takes in a Job Request object and does necessary preparation for execution.
- coordinateJob(JobRequest, JobMetadata) - Method in interface com.netflix.genie.web.services.JobCoordinatorService
-
Takes in a Job Request object and does necessary preparation for execution.
- copy(String, File) - Method in interface com.netflix.genie.web.services.AttachmentService
-
Copy all the attachments for a job into the specified directory.
- copy(String, File) - Method in class com.netflix.genie.web.services.impl.FileSystemAttachmentService
-
Copy all the attachments for a job into the specified directory.
- COULD_NOT_LOAD_DONE_FILE - Static variable in class com.netflix.genie.common.dto.JobStatusMessages
-
Job killed, exit status unknown as done file is unreadable.
- countByServerHostnameEquals(String) - Method in interface com.netflix.genie.web.data.repositories.jpa.JpaAgentConnectionRepository
-
Find the number of agents currently connected to the given server identified by serverHostName
.
- countJobsByUserAndStatusIn(String, Set<JobStatus>) - Method in interface com.netflix.genie.web.data.repositories.jpa.JpaJobRepository
-
Count all jobs that belong to a given user and are in any of the given states.
- createApplication(Application) - Method in interface com.netflix.genie.client.apis.ApplicationService
-
Method to create a application in Genie.
- createApplication(Application) - Method in class com.netflix.genie.client.ApplicationClient
-
Create an application in genie.
- createApplication(Application) - Method in class com.netflix.genie.web.controllers.ApplicationRestController
-
Create an Application.
- createApplication(ApplicationRequest) - Method in class com.netflix.genie.web.data.services.jpa.JpaApplicationPersistenceServiceImpl
-
Create new application.
- createApplication(ApplicationRequest) - Method in interface com.netflix.genie.web.services.ApplicationPersistenceService
-
Create new application.
- createCluster(Cluster) - Method in interface com.netflix.genie.client.apis.ClusterService
-
Method to create a cluster in Genie.
- createCluster(Cluster) - Method in class com.netflix.genie.client.ClusterClient
-
Create a cluster ing genie.
- createCluster(Cluster) - Method in class com.netflix.genie.web.controllers.ClusterRestController
-
Create cluster configuration.
- createCluster(ClusterRequest) - Method in class com.netflix.genie.web.data.services.jpa.JpaClusterPersistenceServiceImpl
-
Create new cluster configuration.
- createCluster(ClusterRequest) - Method in interface com.netflix.genie.web.services.ClusterPersistenceService
-
Create new cluster configuration.
- createCommand(Command) - Method in interface com.netflix.genie.client.apis.CommandService
-
Method to create a command in Genie.
- createCommand(Command) - Method in class com.netflix.genie.client.CommandClient
-
Create a command ing genie.
- createCommand(Command) - Method in class com.netflix.genie.web.controllers.CommandRestController
-
Create a Command configuration.
- createCommand(CommandRequest) - Method in class com.netflix.genie.web.data.services.jpa.JpaCommandPersistenceServiceImpl
-
Create new command configuration.
- createCommand(CommandRequest) - Method in interface com.netflix.genie.web.services.CommandPersistenceService
-
Create new command configuration.
- created - Static variable in class com.netflix.genie.web.data.entities.AuditEntity_
-
- CREATED - Static variable in class com.netflix.genie.web.data.entities.AuditEntity_
-
- createDirectories(String) - Method in class com.netflix.genie.web.services.impl.CacheGenieFileTransferService
-
- createFileIfNotExists(String) - Method in class com.netflix.genie.web.data.services.jpa.JpaFilePersistenceServiceImpl
-
Attempt to create a file reference in the system if it doesn't already exist.
- createFileIfNotExists(String) - Method in interface com.netflix.genie.web.services.FilePersistenceService
-
Attempt to create a file reference in the system if it doesn't already exist.
- createForActiveJobsLimit(String, long, long) - Static method in exception com.netflix.genie.common.exceptions.GenieUserLimitExceededException
-
Static factory method to produce a GenieUserLimitExceededException suitable for when the user exceeded the
maximum number of active jobs and its trying to submit yet another.
- createJob(JobRequest, JobMetadata, Job, JobExecution) - Method in class com.netflix.genie.web.data.services.jpa.JpaJobPersistenceServiceImpl
-
Save all the initial job fields in the data store.
- createJob(JobRequest, JobMetadata, Job, JobExecution) - Method in interface com.netflix.genie.web.services.JobPersistenceService
-
Save all the initial job fields in the data store.
- createJobDirectory(String) - Method in class com.netflix.genie.web.services.impl.DiskJobFileServiceImpl
-
Create the root of the job directory for the given job.
- createJobDirectory(String) - Method in interface com.netflix.genie.web.services.JobFileService
-
Create the root of the job directory for the given job.
- createRelative(String) - Method in class com.netflix.genie.web.resources.agent.AgentFileResourceImpl
- createTagIfNotExists(String) - Method in class com.netflix.genie.web.data.services.jpa.JpaTagPersistenceServiceImpl
-
Attempt to create a tag in the system if it doesn't already exist.
- createTagIfNotExists(String) - Method in interface com.netflix.genie.web.services.TagPersistenceService
-
Attempt to create a tag in the system if it doesn't already exist.
- createTagSearchString(Set<TagEntity>) - Static method in class com.netflix.genie.web.data.repositories.jpa.specifications.JpaSpecificationUtils
-
Convert a set of TagEntities to the '|' delimited tag search string.
- createUser(String, String) - Method in class com.netflix.genie.web.jobs.workflow.impl.JobKickoffTask
-
Create user on the system.
- CriteriaResolutionRepository - Interface in com.netflix.genie.web.data.repositories.jpa
-
Custom extension interfaces for the
JpaClusterRepository
which require more hands on control rather than
generated code from Spring.
- CriteriaResolutionRepositoryImpl - Class in com.netflix.genie.web.data.repositories.jpa
-
- CriteriaResolutionRepositoryImpl() - Constructor for class com.netflix.genie.web.data.repositories.jpa.CriteriaResolutionRepositoryImpl
-
- Criterion - Class in com.netflix.genie.common.internal.dto.v4
-
Representation of various criterion options available.
- Criterion.Builder - Class in com.netflix.genie.common.internal.dto.v4
-
Builder for creating a Criterion instance.
- CriterionEntity - Class in com.netflix.genie.web.data.entities
-
Entity for criteria records.
- CriterionEntity(String, String, String, String, Set<TagEntity>) - Constructor for class com.netflix.genie.web.data.entities.CriterionEntity
-
Constructor.
- CriterionEntity_ - Class in com.netflix.genie.web.data.entities
-
- CriterionEntity_() - Constructor for class com.netflix.genie.web.data.entities.CriterionEntity_
-
- GENIE_AGENT_ENV_SCRIPT_LOG_FILE_NAME - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
Filename for logfile generated by master setup script.
- GENIE_AGENT_ENV_SCRIPT_OUTPUT_FILE_NAME - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
Filename for output of master setup script, containing environment for job.
- GENIE_AGENT_ENV_SCRIPT_RESOURCE - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
Genie Agent script to run entities setup and dump environment.
- GENIE_AGENT_LOG_FILE_NAME - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
Genie Agent log file name (after it is relocated inside the job directory).
- GENIE_APPLICATION_DIR_ENV_VAR - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
Environment variable for Genie application directory.
- GENIE_CLUSTER_DIR_ENV_VAR - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
Environment variable for Genie cluster directory.
- GENIE_CLUSTER_ID_ENV_VAR - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
Environment variable for Genie cluster id.
- GENIE_CLUSTER_NAME_ENV_VAR - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
Environment variable for the Genie cluster name.
- GENIE_CLUSTER_TAGS_ENV_VAR - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
Environment variable for the Genie cluster tags.
- GENIE_COMMAND_DIR_ENV_VAR - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
Environment variable for Genie command directory.
- GENIE_COMMAND_ID_ENV_VAR - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
Environment variable for Genie command id.
- GENIE_COMMAND_NAME_ENV_VAR - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
Environment variable for the Genie command name.
- GENIE_COMMAND_TAGS_ENV_VAR - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
Environment variable for the Genie command tags.
- GENIE_DONE_FILE_CONTENT_PREFIX - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
Genie Done file contents prefix.
- GENIE_DONE_FILE_NAME - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
Done filename generated by Genie after running a job.
- GENIE_ENV_PATH - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
Genie env file path.
- GENIE_FORWARDED_FROM_HEADER - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
The header to use to mark a forwarded from another Genie node.
- GENIE_ID_PREFIX - Static variable in class com.netflix.genie.web.controllers.DtoConverters
-
The Genie 3 prefix for resource ID added to the set of tags by the system.
- GENIE_INIT_FAILURE_MESSAGE_FILE_NAME - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
File created by Genie with details and trace for a job that failed to initialize.
- GENIE_JOB_DIR_ENV_VAR - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
Environment variable for Genie job working directory.
- GENIE_JOB_GROUPING_ENV_VAR - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
Environment variable for Genie Job grouping.
- GENIE_JOB_GROUPING_INSTANCE_ENV_VAR - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
Environment variable for Genie Job grouping instance.
- GENIE_JOB_ID_ENV_VAR - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
Environment variable for Genie Job ID.
- GENIE_JOB_LAUNCHER_SCRIPT - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
The launcher script name that genie creates to setup a job for running.
- GENIE_JOB_MEMORY_ENV_VAR - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
Environment variable for Genie Job Memory.
- GENIE_JOB_NAME_ENV_VAR - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
Environment variable for Genie Job Name.
- GENIE_JOB_TAGS_ENV_VAR - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
Environment variable for Genie job tags provided by the user.
- GENIE_KILL_REASON_FILE_NAME - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
"Kill reason" filename generated by Genie after killing a job.
- GENIE_LOG_PATH - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
Genie log file path.
- GENIE_NAME_PREFIX - Static variable in class com.netflix.genie.web.controllers.DtoConverters
-
The Genie 3 prefix for resource names added to the set of tags by the system.
- GENIE_PATH_VAR - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
File Path prefix to be used while creating working directory for jobs.
- GENIE_PREFIX - Static variable in class com.netflix.genie.security.oauth2.pingfederate.PingFederateUserAuthenticationConverter
-
- GENIE_REQUESTED_CLUSTER_TAGS_ENV_VAR - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
Environment variable for the Genie cluster criteria tags in the job request.
- GENIE_REQUESTED_COMMAND_TAGS_ENV_VAR - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
Environment variable for the Genie command tags in the job request.
- GENIE_TEMPORARY_DONE_FILE_NAME - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
Temporary done filename generated by Genie after running a job as not to conflict/overwrite the
one that 'trap' handler might have created.
- GENIE_USER_GROUP - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- GenieAgentApplication - Class in com.netflix.genie
-
Genie Agent application.
- GenieAgentApplication() - Constructor for class com.netflix.genie.GenieAgentApplication
-
- GenieAgentFilterAutoConfiguration - Class in com.netflix.genie.web.configs
-
- GenieAgentFilterAutoConfiguration() - Constructor for class com.netflix.genie.web.configs.GenieAgentFilterAutoConfiguration
-
- genieAgentHealthIndicator(AgentMetricsService) - Method in class com.netflix.genie.web.configs.GenieHealthAutoConfiguration
-
Provide a health indicator tied to agent related information if one hasn't already been provided elsewhere.
- GenieAgentHealthIndicator - Class in com.netflix.genie.web.health
-
Provides a health indicator relative to the behavior of Genie Agents and this Server.
- GenieAgentHealthIndicator(AgentMetricsService) - Constructor for class com.netflix.genie.web.health.GenieAgentHealthIndicator
-
Constructor.
- GenieAgentRejectedException - Exception in com.netflix.genie.common.internal.exceptions.unchecked
-
An exception to represent the case where an Agent was rejected by the server.
- GenieAgentRejectedException() - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieAgentRejectedException
-
Constructor.
- GenieAgentRejectedException(String) - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieAgentRejectedException
-
Constructor.
- GenieAgentRejectedException(String, Throwable) - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieAgentRejectedException
-
Constructor.
- GenieAgentRejectedException(Throwable) - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieAgentRejectedException
-
Constructor.
- genieAgentRunner(ArgumentParser, CommandFactory, Environment) - Method in class com.netflix.genie.agent.cli.CliAutoConfiguration
-
- GenieAgentRunner - Class in com.netflix.genie.agent.cli
-
Main entry point for execution after the application is initialized.
- genieApi() - Method in class com.netflix.genie.web.configs.GenieSwaggerAutoConfiguration
-
Configure Spring Fox.
- GenieApiAutoConfiguration - Class in com.netflix.genie.web.configs
-
Configuration for Spring MVC REST API tier.
- GenieApiAutoConfiguration() - Constructor for class com.netflix.genie.web.configs.GenieApiAutoConfiguration
-
- GenieApp - Class in com.netflix.genie
-
Main Genie Spring Configuration class.
- GenieApp() - Constructor for class com.netflix.genie.GenieApp
-
Protected constructor.
- GenieApplicationNotFoundException - Exception in com.netflix.genie.common.internal.exceptions.unchecked
-
An exception to represent the case where an application was expected to exist (e.g.
- GenieApplicationNotFoundException() - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieApplicationNotFoundException
-
Constructor.
- GenieApplicationNotFoundException(String) - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieApplicationNotFoundException
-
Constructor.
- GenieApplicationNotFoundException(String, Throwable) - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieApplicationNotFoundException
-
Constructor.
- GenieApplicationNotFoundException(Throwable) - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieApplicationNotFoundException
-
Constructor.
- genieAsyncTaskExecutor(TasksExecutorPoolProperties) - Method in class com.netflix.genie.web.configs.GenieTasksAutoConfiguration
-
Get a task executor for executing tasks asynchronously that don't need to be scheduled at a recurring rate.
- GenieAwsApiAutoConfiguration - Class in com.netflix.genie.web.configs.aws
-
Beans and configuration specifically for MVC on AWS.
- GenieAwsApiAutoConfiguration() - Constructor for class com.netflix.genie.web.configs.aws.GenieAwsApiAutoConfiguration
-
- genieAwsClientConfiguration(RetryProperties) - Method in class com.netflix.genie.web.configs.aws.GenieAwsS3AutoConfiguration
-
Default AWS client configuration that sets the number of retries provided by the user.
- GenieAwsS3AutoConfiguration - Class in com.netflix.genie.web.configs.aws
-
Beans and configuration specifically for S3 connection on AWS.
- GenieAwsS3AutoConfiguration() - Constructor for class com.netflix.genie.web.configs.aws.GenieAwsS3AutoConfiguration
-
- GenieBadRequestException - Exception in com.netflix.genie.common.exceptions
-
Extension of a GenieException for all bad request failures.
- GenieBadRequestException(String, Throwable) - Constructor for exception com.netflix.genie.common.exceptions.GenieBadRequestException
-
Constructor.
- GenieBadRequestException(String) - Constructor for exception com.netflix.genie.common.exceptions.GenieBadRequestException
-
Constructor.
- GenieBaseTask - Class in com.netflix.genie.web.jobs.workflow.impl
-
An abstract class that all classes that implement a workflow task should inherit from.
- GenieClientException - Exception in com.netflix.genie.client.exceptions
-
An exception class that represents all failures received by the client.
- GenieClientException(int, String) - Constructor for exception com.netflix.genie.client.exceptions.GenieClientException
-
Constructor.
- GenieClientException(String) - Constructor for exception com.netflix.genie.client.exceptions.GenieClientException
-
Constructor.
- GenieClusterLoadBalancerAutoConfiguration - Class in com.netflix.genie.web.configs
-
- GenieClusterLoadBalancerAutoConfiguration() - Constructor for class com.netflix.genie.web.configs.GenieClusterLoadBalancerAutoConfiguration
-
- GenieClusterNotFoundException - Exception in com.netflix.genie.common.internal.exceptions.unchecked
-
An exception to represent the case where a cluster was expected to exist (e.g.
- GenieClusterNotFoundException() - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieClusterNotFoundException
-
Constructor.
- GenieClusterNotFoundException(String) - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieClusterNotFoundException
-
Constructor.
- GenieClusterNotFoundException(String, Throwable) - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieClusterNotFoundException
-
Constructor.
- GenieClusterNotFoundException(Throwable) - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieClusterNotFoundException
-
Constructor.
- GenieCommandNotFoundException - Exception in com.netflix.genie.common.internal.exceptions.unchecked
-
An exception to represent the case where a command was expected to exist (e.g.
- GenieCommandNotFoundException() - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieCommandNotFoundException
-
Constructor.
- GenieCommandNotFoundException(String) - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieCommandNotFoundException
-
Constructor.
- GenieCommandNotFoundException(String, Throwable) - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieCommandNotFoundException
-
Constructor.
- GenieCommandNotFoundException(Throwable) - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieCommandNotFoundException
-
Constructor.
- GenieConflictException - Exception in com.netflix.genie.common.exceptions
-
Extension of a GenieException for all conflict failures.
- GenieConflictException(String, Throwable) - Constructor for exception com.netflix.genie.common.exceptions.GenieConflictException
-
Constructor.
- GenieConflictException(String) - Constructor for exception com.netflix.genie.common.exceptions.GenieConflictException
-
Constructor.
- GenieConversionException - Exception in com.netflix.genie.common.internal.exceptions
-
Failure to convert objects into wire format or vice versa.
- GenieConversionException(String) - Constructor for exception com.netflix.genie.common.internal.exceptions.GenieConversionException
-
Constructor with message.
- GenieConversionException(String, Throwable) - Constructor for exception com.netflix.genie.common.internal.exceptions.GenieConversionException
-
Constructor with message and cause.
- GenieCpuHealthIndicator - Class in com.netflix.genie.web.health
-
Health indicator for system cpu usage.
- GenieCpuHealthIndicator(HealthProperties, MeterRegistry, TaskScheduler) - Constructor for class com.netflix.genie.web.health.GenieCpuHealthIndicator
-
Constructor.
- GenieDefaultPropertiesPostProcessor - Class in com.netflix.genie.agent.configs.processors
-
Adds default properties to the Spring environment before application refresh.
- GenieDefaultPropertiesPostProcessor() - Constructor for class com.netflix.genie.agent.configs.processors.GenieDefaultPropertiesPostProcessor
-
- GenieDefaultPropertiesPostProcessor - Class in com.netflix.genie.web.configs.processors
-
Adds default properties to the Spring environment before application refresh.
- GenieDefaultPropertiesPostProcessor() - Constructor for class com.netflix.genie.web.configs.processors.GenieDefaultPropertiesPostProcessor
-
- GenieEventBus - Interface in com.netflix.genie.web.events
-
Genie Event Bus interface.
- genieEventBus - Variable in class com.netflix.genie.web.services.impl.JobStateServiceImpl
-
- GenieEventBusAutoConfiguration - Class in com.netflix.genie.web.configs
-
Configuration related to Eventing within the Genie application.
- GenieEventBusAutoConfiguration() - Constructor for class com.netflix.genie.web.configs.GenieEventBusAutoConfiguration
-
- GenieEventBusImpl - Class in com.netflix.genie.web.events
-
An event bus implementation for the Genie application to use.
- GenieEventBusImpl(SimpleApplicationEventMulticaster, SimpleApplicationEventMulticaster) - Constructor for class com.netflix.genie.web.events.GenieEventBusImpl
-
Constructor.
- GenieException - Exception in com.netflix.genie.common.exceptions
-
The common exception class that represents a service failure.
- GenieException(int, String, Throwable) - Constructor for exception com.netflix.genie.common.exceptions.GenieException
-
Constructor.
- GenieException(int, String) - Constructor for exception com.netflix.genie.common.exceptions.GenieException
-
Constructor.
- GenieExceptionMapper - Class in com.netflix.genie.web.controllers
-
Exception mapper for Genie Exceptions.
- GenieExceptionMapper(MeterRegistry) - Constructor for class com.netflix.genie.web.controllers.GenieExceptionMapper
-
Constructor.
- genieFileTransferService(FileTransferFactory) - Method in class com.netflix.genie.web.configs.GenieServicesAutoConfiguration
-
Get an instance of the Genie File Transfer service.
- GenieFileTransferService - Class in com.netflix.genie.web.services.impl
-
This class abstracts away all the implementations of FileTransfer interface.
- GenieFileTransferService(FileTransferFactory) - Constructor for class com.netflix.genie.web.services.impl.GenieFileTransferService
-
Constructor.
- GenieGRpcServerAutoConfiguration - Class in com.netflix.genie.web.configs
-
Controls whether a gRPC server is configured for this Genie node or not.
- GenieGRpcServerAutoConfiguration() - Constructor for class com.netflix.genie.web.configs.GenieGRpcServerAutoConfiguration
-
- GenieHealthAutoConfiguration - Class in com.netflix.genie.web.configs
-
Auto configuration for Health indicators related to Genie.
- GenieHealthAutoConfiguration() - Constructor for class com.netflix.genie.web.configs.GenieHealthAutoConfiguration
-
- GenieHostInfo - Class in com.netflix.genie.common.internal.util
-
Container for information about the host a Genie process (web server or agent) is running on.
- GenieHostInfo(String) - Constructor for class com.netflix.genie.common.internal.util.GenieHostInfo
-
Constructor.
- genieHostInfo() - Method in class com.netflix.genie.web.configs.aws.GenieAwsApiAutoConfiguration
-
Create an instance of
GenieHostInfo
using the EC2 metadata service as we're deployed in an AWS cloud
environment.
- genieHostInfo() - Method in class com.netflix.genie.web.configs.GenieApiAutoConfiguration
-
- GenieIdAlreadyExistsException - Exception in com.netflix.genie.common.internal.exceptions.unchecked
-
Exception thrown when an id is attempting to be saved that already exists in the system.
- GenieIdAlreadyExistsException() - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieIdAlreadyExistsException
-
Constructor.
- GenieIdAlreadyExistsException(String) - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieIdAlreadyExistsException
-
Constructor.
- GenieIdAlreadyExistsException(String, Throwable) - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieIdAlreadyExistsException
-
Constructor.
- GenieIdAlreadyExistsException(Throwable) - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieIdAlreadyExistsException
-
Constructor.
- GenieInvalidStatusException - Exception in com.netflix.genie.common.internal.exceptions.unchecked
-
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.
- GenieInvalidStatusException() - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieInvalidStatusException
-
Constructor.
- GenieInvalidStatusException(String) - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieInvalidStatusException
-
Constructor.
- GenieInvalidStatusException(String, Throwable) - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieInvalidStatusException
-
Constructor.
- GenieInvalidStatusException(Throwable) - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieInvalidStatusException
-
Constructor.
- GenieJobAlreadyClaimedException - Exception in com.netflix.genie.common.internal.exceptions.unchecked
-
Exception thrown when a job is already claimed in the system and another agent tries to claim it.
- GenieJobAlreadyClaimedException() - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieJobAlreadyClaimedException
-
Constructor.
- GenieJobAlreadyClaimedException(String) - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieJobAlreadyClaimedException
-
Constructor.
- GenieJobAlreadyClaimedException(String, Throwable) - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieJobAlreadyClaimedException
-
Constructor.
- GenieJobAlreadyClaimedException(Throwable) - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieJobAlreadyClaimedException
-
Constructor.
- GenieJobNotFoundException - Exception in com.netflix.genie.common.internal.exceptions.unchecked
-
An exception to represent the case where a job was expected to exist (e.g.
- GenieJobNotFoundException() - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieJobNotFoundException
-
Constructor.
- GenieJobNotFoundException(String) - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieJobNotFoundException
-
Constructor.
- GenieJobNotFoundException(String, Throwable) - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieJobNotFoundException
-
Constructor.
- GenieJobNotFoundException(Throwable) - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieJobNotFoundException
-
Constructor.
- GenieJobSpecificationNotFoundException - Exception in com.netflix.genie.common.internal.exceptions.unchecked
-
An exception to represent the case where a job specification was expected to exist but it doesn't.
- GenieJobSpecificationNotFoundException() - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieJobSpecificationNotFoundException
-
Constructor.
- GenieJobSpecificationNotFoundException(String) - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieJobSpecificationNotFoundException
-
Constructor.
- GenieJobSpecificationNotFoundException(String, Throwable) - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieJobSpecificationNotFoundException
-
Constructor.
- GenieJobSpecificationNotFoundException(Throwable) - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieJobSpecificationNotFoundException
-
Constructor.
- GenieJobWorkflowAutoConfiguration - Class in com.netflix.genie.web.configs
-
Configuration for Jobs Setup and Run.
- GenieJobWorkflowAutoConfiguration() - Constructor for class com.netflix.genie.web.configs.GenieJobWorkflowAutoConfiguration
-
- GenieJpaAutoConfiguration - Class in com.netflix.genie.web.configs
-
Auto configuration of JPA related services and beans for Genie.
- GenieJpaAutoConfiguration() - Constructor for class com.netflix.genie.web.configs.GenieJpaAutoConfiguration
-
- GenieLeadershipAutoConfiguration - Class in com.netflix.genie.web.configs
-
Beans for Leadership of a Genie cluster.
- GenieLeadershipAutoConfiguration() - Constructor for class com.netflix.genie.web.configs.GenieLeadershipAutoConfiguration
-
- GenieMailAutoConfiguration - Class in com.netflix.genie.web.configs
-
Auto configuration for email support within Genie.
- GenieMailAutoConfiguration() - Constructor for class com.netflix.genie.web.configs.GenieMailAutoConfiguration
-
- genieMemoryHealthIndicator(JobMetricsService, JobsProperties) - Method in class com.netflix.genie.web.configs.GenieHealthAutoConfiguration
-
Provide a health indicator related to job memory usage if one hasn't already been provided elsewhere.
- GenieMemoryHealthIndicator - Class in com.netflix.genie.web.health
-
A health indicator based around metrics from the Genie system.
- GenieMemoryHealthIndicator(JobMetricsService, JobsProperties) - Constructor for class com.netflix.genie.web.health.GenieMemoryHealthIndicator
-
Constructor.
- GenieNetworkConfiguration - Class in com.netflix.genie.client.configs
-
An object that encapsulates network configurations for Genie client HTTP requests.
- GenieNetworkConfiguration() - Constructor for class com.netflix.genie.client.configs.GenieNetworkConfiguration
-
- GenieNotFoundException - Exception in com.netflix.genie.common.exceptions
-
Extension of a GenieException for all not found exceptions.
- GenieNotFoundException(String, Throwable) - Constructor for exception com.netflix.genie.common.exceptions.GenieNotFoundException
-
Constructor.
- GenieNotFoundException(String) - Constructor for exception com.netflix.genie.common.exceptions.GenieNotFoundException
-
Constructor.
- GenieObjectMapper - Class in com.netflix.genie.common.util
-
A singleton for sharing a Jackson Object Mapper instance across Genie and not having to redefine the Object Mapper
everywhere.
- GeniePreconditionException - Exception in com.netflix.genie.common.exceptions
-
Extension of a GenieException for all precondition failures.
- GeniePreconditionException(String, Throwable) - Constructor for exception com.netflix.genie.common.exceptions.GeniePreconditionException
-
Constructor.
- GeniePreconditionException(String) - Constructor for exception com.netflix.genie.common.exceptions.GeniePreconditionException
-
Constructor.
- genieRestTemplate(HttpProperties, RestTemplateBuilder) - Method in class com.netflix.genie.web.configs.GenieApiAutoConfiguration
-
Get RestTemplate for calling between Genie nodes.
- genieRetryTemplate(RetryProperties) - Method in class com.netflix.genie.web.configs.GenieApiAutoConfiguration
-
Get RetryTemplate.
- GenieRuntimeException - Exception in com.netflix.genie.common.internal.exceptions.unchecked
-
Base class for Genie runtime exceptions.
- GenieRuntimeException() - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieRuntimeException
-
Constructor.
- GenieRuntimeException(String) - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieRuntimeException
-
Constructor.
- GenieRuntimeException(String, Throwable) - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieRuntimeException
-
Constructor.
- GenieRuntimeException(Throwable) - Constructor for exception com.netflix.genie.common.internal.exceptions.unchecked.GenieRuntimeException
-
Constructor.
- GenieSecurityDefaultPropertiesPostProcessor - Class in com.netflix.genie.security.configs.processors
-
Apply default properties to the Spring application context before application auto configuration is evaluated.
- GenieSecurityDefaultPropertiesPostProcessor() - Constructor for class com.netflix.genie.security.configs.processors.GenieSecurityDefaultPropertiesPostProcessor
-
- GenieServerException - Exception in com.netflix.genie.common.exceptions
-
Extension of a GenieException for all internal server failures.
- GenieServerException(String, Throwable) - Constructor for exception com.netflix.genie.common.exceptions.GenieServerException
-
Constructor.
- GenieServerException(String) - Constructor for exception com.netflix.genie.common.exceptions.GenieServerException
-
Constructor.
- GenieServerUnavailableException - Exception in com.netflix.genie.common.exceptions
-
Extension of a GenieException for all server unavailable failures.
- GenieServerUnavailableException(String, Throwable) - Constructor for exception com.netflix.genie.common.exceptions.GenieServerUnavailableException
-
Constructor.
- GenieServerUnavailableException(String) - Constructor for exception com.netflix.genie.common.exceptions.GenieServerUnavailableException
-
Constructor.
- GenieServicesAutoConfiguration - Class in com.netflix.genie.web.configs
-
Configuration for all the services.
- GenieServicesAutoConfiguration() - Constructor for class com.netflix.genie.web.configs.GenieServicesAutoConfiguration
-
- GenieSwaggerAutoConfiguration - Class in com.netflix.genie.web.configs
-
Spring configuration for Swagger via SpringFox.
- GenieSwaggerAutoConfiguration() - Constructor for class com.netflix.genie.web.configs.GenieSwaggerAutoConfiguration
-
- genieSyncTaskExecutor() - Method in class com.netflix.genie.web.configs.GenieTasksAutoConfiguration
-
Synchronous task executor.
- GenieTask - Class in com.netflix.genie.web.tasks
-
Interface for any task that should run in the Genie system.
- GenieTask() - Constructor for class com.netflix.genie.web.tasks.GenieTask
-
- GenieTasksAutoConfiguration - Class in com.netflix.genie.web.configs
-
Configuration of beans for asynchronous tasks within Genie.
- GenieTasksAutoConfiguration() - Constructor for class com.netflix.genie.web.configs.GenieTasksAutoConfiguration
-
- genieTaskScheduler(TasksSchedulerPoolProperties) - Method in class com.netflix.genie.web.configs.GenieTasksAutoConfiguration
-
Get a task scheduler.
- GenieTaskScheduleType - Enum in com.netflix.genie.web.tasks
-
The enumeration values which a
GenieTask
can be be scheduled with.
- GenieTestApp - Class in com.netflix.genie
-
Reusable Spring Boot test application.
- GenieTestApp() - Constructor for class com.netflix.genie.GenieTestApp
-
Constructor.
- GenieTimeoutException - Exception in com.netflix.genie.common.exceptions
-
Extension of a GenieException for timeouts.
- GenieTimeoutException(String, Throwable) - Constructor for exception com.netflix.genie.common.exceptions.GenieTimeoutException
-
Constructor.
- GenieTimeoutException(String) - Constructor for exception com.netflix.genie.common.exceptions.GenieTimeoutException
-
Constructor.
- genieUserGroup - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- GenieUserLimitExceededException - Exception in com.netflix.genie.common.exceptions
-
Extension of a GenieException for a user exceeding some limit (e.g., submitting too many jobs).
- GenieUserLimitExceededException(String, String, String) - Constructor for exception com.netflix.genie.common.exceptions.GenieUserLimitExceededException
-
Constructor.
- GenieValidationAutoConfiguration - Class in com.netflix.genie.web.configs
-
Configuration for bean validation within Genie.
- GenieValidationAutoConfiguration() - Constructor for class com.netflix.genie.web.configs.GenieValidationAutoConfiguration
-
- GenieWar - Class in com.netflix.genie
-
A class that serves to set up Spring Boot within a servlet container rather than an embedded one.
- GenieWar() - Constructor for class com.netflix.genie.GenieWar
-
- get(URI, File) - Method in interface com.netflix.genie.agent.execution.services.FetchingCacheService
-
Download a given resource (if not already cached) and copy it to the specified destination.
- get(Set<Pair<URI, File>>) - Method in interface com.netflix.genie.agent.execution.services.FetchingCacheService
-
Download a given set of resources (if not already cached) and copy them to the specified destinations.
- get(String) - Method in interface com.netflix.genie.web.services.FileTransferFactory
-
Factory method to return the FileTransfer implementation.
- get(int, Instant) - Method in interface com.netflix.genie.web.util.ProcessChecker.Factory
-
Get a new process checker to check on the given PID.
- get(int, Instant) - Method in class com.netflix.genie.web.util.UnixProcessChecker.Factory
-
Get a new process checker to check on the given PID.
- getActiveDisconnectedAgentJobs() - Method in class com.netflix.genie.web.data.services.jpa.JpaJobSearchServiceImpl
-
Get the IDs of all agent jobs that are active but currently not connected to any node.
- getActiveDisconnectedAgentJobs() - Method in interface com.netflix.genie.web.services.JobSearchService
-
Get the IDs of all agent jobs that are active but currently not connected to any node.
- getActiveJobCountForUser(String) - Method in class com.netflix.genie.web.data.services.jpa.JpaJobSearchServiceImpl
-
Get the count of 'active' jobs for a given user across all instances.
- getActiveJobCountForUser(String) - Method in interface com.netflix.genie.web.services.JobSearchService
-
Get the count of 'active' jobs for a given user across all instances.
- getActiveStatuses() - Static method in enum com.netflix.genie.common.dto.JobStatus
-
Get an unmodifiable set of all the statuses that make up a job being considered active.
- getAgentClientMetadata() - Method in class com.netflix.genie.common.internal.dto.v4.JobRequestMetadata
-
If the job request was sent via the Agent this field will be populated.
- getAgentHostName() - Method in interface com.netflix.genie.agent.AgentMetadata
-
Get the name of the host the agent is running on.
- getAgentHostname() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get the host name where the agent ran or is running the job.
- getAgentHostname() - Method in interface com.netflix.genie.web.data.entities.projections.AgentHostnameProjection
-
Get the host name where the agent ran or is running the job.
- getAgentJobIdsWithNoConnectionInState(Set<JobStatus>) - Method in interface com.netflix.genie.web.data.repositories.jpa.JpaJobRepository
-
Find agent jobs in the given set of states that don't have an entry in the connections table.
- getAgentPid() - Method in interface com.netflix.genie.agent.AgentMetadata
-
Get the agent process ID.
- getAgentPid() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get the pid of the agent that claimed this job.
- getAgentVersion() - Method in interface com.netflix.genie.agent.AgentMetadata
-
Get the agent version string, as it appears in the agent jar metadata.
- getAgentVersion() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get the version of the agent that claimed this job.
- getAllActiveJobsOnHost(String) - Method in class com.netflix.genie.web.data.services.jpa.JpaJobSearchServiceImpl
-
Given a hostname return a set of all the jobs currently active on that host.
- getAllActiveJobsOnHost(String) - Method in interface com.netflix.genie.web.services.JobSearchService
-
Given a hostname return a set of all the jobs currently active on that host.
- getAllHostsWithActiveJobs() - Method in class com.netflix.genie.web.data.services.jpa.JpaJobSearchServiceImpl
-
Get a set of host names which are currently have active jobs in the Genie cluster.
- getAllHostsWithActiveJobs() - Method in interface com.netflix.genie.web.services.JobSearchService
-
Get a set of host names which are currently have active jobs in the Genie cluster.
- getApiClientMetadata() - Method in class com.netflix.genie.common.internal.dto.v4.JobRequestMetadata
-
If the job request was sent via API this field will be populated.
- getApplication(String) - Method in interface com.netflix.genie.client.apis.ApplicationService
-
Method to fetch a single job from Genie.
- getApplication(String) - Method in class com.netflix.genie.client.ApplicationClient
-
Method to get a Application from Genie.
- getApplication(String) - Method in class com.netflix.genie.web.controllers.ApplicationRestController
-
Get Application for given id.
- getApplication(String) - Method in class com.netflix.genie.web.data.services.jpa.JpaApplicationPersistenceServiceImpl
-
Gets application for given id.
- getApplication(String) - Method in interface com.netflix.genie.web.services.ApplicationPersistenceService
-
Gets application for given id.
- getApplicationIds() - Method in interface com.netflix.genie.agent.cli.ArgumentDelegates.JobRequestArguments
-
- getApplicationIds() - Method in class com.netflix.genie.common.internal.dto.v4.ExecutionResourceCriteria
-
Get the ordered list of ids the user desires to override the applications associated with selected command with.
- getApplications(String, String, List<String>, List<String>, String) - Method in interface com.netflix.genie.client.apis.ApplicationService
-
Method to get all applications from Genie.
- getApplications() - Method in class com.netflix.genie.client.ApplicationClient
-
Method to get a list of all the applications.
- getApplications(String, String, List<String>, List<String>, String) - Method in class com.netflix.genie.client.ApplicationClient
-
Method to get a list of all the applications from Genie for the query parameters specified.
- getApplications() - Method in class com.netflix.genie.common.internal.dto.v4.JobSpecification
-
Returns an unmodifiable list of applications.
- getApplications(String, String, Set<String>, Set<String>, String, Pageable, PagedResourcesAssembler<Application>) - Method in class com.netflix.genie.web.controllers.ApplicationRestController
-
Get Applications based on user parameters.
- getApplications() - Method in interface com.netflix.genie.web.data.entities.projections.JobApplicationsProjection
-
Get the applications associated with a job.
- getApplications() - Method in interface com.netflix.genie.web.data.entities.projections.JobProjection
-
Get the applications used to run this job.
- getApplications() - Method in interface com.netflix.genie.web.data.entities.projections.v4.JobSpecificationProjection
-
Get the applications used to run this job.
- getApplications(String, String, Set<ApplicationStatus>, Set<String>, String, Pageable) - Method in class com.netflix.genie.web.data.services.jpa.JpaApplicationPersistenceServiceImpl
-
Get applications for given filter criteria.
- getApplications() - Method in class com.netflix.genie.web.jobs.JobExecutionEnvironment
-
Get the applications for this instance.
- getApplications(String, String, Set<ApplicationStatus>, Set<String>, String, Pageable) - Method in interface com.netflix.genie.web.services.ApplicationPersistenceService
-
Get applications for given filter criteria.
- getApplicationsForCommand(String) - Method in interface com.netflix.genie.client.apis.CommandService
-
Method to get applications for a command in Genie.
- getApplicationsForCommand(String) - Method in class com.netflix.genie.client.CommandClient
-
Method to get all the applications for a command.
- getApplicationsForCommand(String) - Method in class com.netflix.genie.web.controllers.CommandRestController
-
Get the applications configured for a given command.
- getApplicationsForCommand(String) - Method in class com.netflix.genie.web.data.services.jpa.JpaCommandPersistenceServiceImpl
-
Get the applications for a given command.
- getApplicationsForCommand(String) - Method in interface com.netflix.genie.web.services.CommandPersistenceService
-
Get the applications for a given command.
- getArchiveLocation() - Method in class com.netflix.genie.common.dto.Job
-
Get the archive location for the job if there is one.
- getArchiveLocation() - Method in class com.netflix.genie.common.internal.dto.v4.JobSpecification
-
Get the archive location for the job folder.
- getArchiveLocation() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get the location where the job was archived.
- getArchiveLocation() - Method in interface com.netflix.genie.web.data.entities.projections.JobArchiveLocationProjection
-
Get the location where the job was archived.
- getArchiveLocationPrefix() - Method in interface com.netflix.genie.agent.cli.ArgumentDelegates.JobRequestArguments
-
- getBlacklistedVersions() - Method in class com.netflix.genie.web.properties.AgentFilterProperties
-
Get the (dynamic) property value containing a regular expression used to blacklist agent versions.
- getCacheDirectory() - Method in interface com.netflix.genie.agent.cli.ArgumentDelegates.CacheArguments
-
- getCheckDelay() - Method in class com.netflix.genie.common.dto.JobExecution
-
Get the amount of time (in milliseconds) to delay between checks of status of the job process.
- getCheckDelay() - Method in class com.netflix.genie.common.internal.dto.v4.CommandRequest
-
Get the requested amount of time (in milliseconds) between checks of job status for jobs run using this command.
- getCheckDelay() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get the amount of time (in milliseconds) to delay the check for the job status.
- getCheckDelay() - Method in interface com.netflix.genie.web.data.entities.projections.JobExecutionProjection
-
Get the amount of time (in milliseconds) to delay the check for the job status.
- getClaimableStatuses() - Static method in enum com.netflix.genie.common.dto.JobStatus
-
Get an unmodifiable set of all the statuses from which a job can be marked claimed.
- getClaimedJobId() - Method in interface com.netflix.genie.agent.execution.ExecutionContext
-
Get the job id, if a job was claimed.
- getCleanupActions() - Method in interface com.netflix.genie.agent.execution.ExecutionContext
-
Get the queue of states visited for the purpose of tracking post-job cleanup execution.
- getCleanupStrategy() - Method in interface com.netflix.genie.agent.cli.ArgumentDelegates.CleanupArguments
-
- getClient(AmazonS3URI) - Method in class com.netflix.genie.common.internal.aws.s3.S3ClientFactory
-
Get an AmazonS3
client instance appropriate for the given AmazonS3URI
.
- getClientHost() - Method in class com.netflix.genie.common.dto.JobMetadata
-
Get the client host.
- getCluster(String) - Method in interface com.netflix.genie.client.apis.ClusterService
-
Method to fetch a single job from Genie.
- getCluster(String) - Method in class com.netflix.genie.client.ClusterClient
-
Method to get a Cluster from Genie.
- getCluster(String) - Method in class com.netflix.genie.web.controllers.ClusterRestController
-
Get cluster configuration from unique id.
- getCluster() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get the cluster that ran or is currently running a given job.
- getCluster() - Method in interface com.netflix.genie.web.data.entities.projections.JobClusterProjection
-
Get the cluster that ran or is currently running a given job.
- getCluster() - Method in interface com.netflix.genie.web.data.entities.projections.v4.JobSpecificationProjection
-
Get the cluster that ran or is currently running a given job.
- getCluster(String) - Method in class com.netflix.genie.web.data.services.jpa.JpaClusterPersistenceServiceImpl
-
Get the cluster configuration by id.
- getCluster(String) - Method in interface com.netflix.genie.web.services.ClusterPersistenceService
-
Get the cluster configuration by id.
- getClusterCriteria() - Method in interface com.netflix.genie.agent.cli.ArgumentDelegates.JobRequestArguments
-
- getClusterCriteria() - Method in class com.netflix.genie.common.internal.dto.v4.ExecutionResourceCriteria
-
Get the ordered list of criteria the system should use to find a cluster for job execution.
- getClusterCriteria() - Method in interface com.netflix.genie.web.data.entities.projections.JobRequestProjection
-
Get all the cluster criteria.
- getClusterCriteria() - Method in interface com.netflix.genie.web.data.entities.projections.v4.V4JobRequestProjection
-
Get all the cluster criteria.
- getClusterName() - Method in class com.netflix.genie.common.dto.Job
-
Get the name of the cluster running the job if there currently is one.
- getClusterName() - Method in class com.netflix.genie.common.dto.search.JobSearchResult
-
Get the name of the cluster running the job if there currently is one.
- getClusterName() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get the name of the cluster that is running or did run this job.
- getClusterName() - Method in interface com.netflix.genie.web.data.entities.projections.JobProjection
-
Get the name of the cluster that is running or did run this job.
- getClusterName() - Method in interface com.netflix.genie.web.data.entities.projections.JobSearchProjection
-
Get the name of the cluster that is running or did run this job.
- getClusters(String, List<String>, List<String>, Long, Long) - Method in interface com.netflix.genie.client.apis.ClusterService
-
Method to get clusters from Genie based on filters specified.
- getClusters() - Method in class com.netflix.genie.client.ClusterClient
-
Method to get a list of all the clusters.
- getClusters(String, List<String>, List<String>, Long, Long) - Method in class com.netflix.genie.client.ClusterClient
-
Method to get a list of all the clusters from Genie for the query parameters specified.
- getClusters(String, Set<String>, Set<String>, Long, Long, Pageable, PagedResourcesAssembler<Cluster>) - Method in class com.netflix.genie.web.controllers.ClusterRestController
-
Get cluster config based on user params.
- getClusters(String, Set<ClusterStatus>, Set<String>, Instant, Instant, Pageable) - Method in class com.netflix.genie.web.data.services.jpa.JpaClusterPersistenceServiceImpl
-
Get cluster info for various parameters.
- getClusters(String, Set<ClusterStatus>, Set<String>, Instant, Instant, Pageable) - Method in interface com.netflix.genie.web.services.ClusterPersistenceService
-
Get cluster info for various parameters.
- getClustersForCommand(String) - Method in interface com.netflix.genie.client.apis.CommandService
-
Method to get clusters for a command in Genie.
- getClustersForCommand(String) - Method in class com.netflix.genie.client.CommandClient
-
Method to get all the clusters for a command.
- getClustersForCommand(String, Set<String>) - Method in class com.netflix.genie.web.controllers.CommandRestController
-
Get all the clusters this command is associated with.
- getClustersForCommand(String, Set<ClusterStatus>) - Method in class com.netflix.genie.web.data.services.jpa.JpaCommandPersistenceServiceImpl
-
Get all the clusters the command with given id is associated with.
- getClustersForCommand(String, Set<ClusterStatus>) - Method in interface com.netflix.genie.web.services.CommandPersistenceService
-
Get all the clusters the command with given id is associated with.
- getCommand(String) - Method in interface com.netflix.genie.client.apis.CommandService
-
Method to fetch a single job from Genie.
- getCommand(String) - Method in class com.netflix.genie.client.CommandClient
-
Method to get a Command from Genie.
- getCommand(String) - Method in class com.netflix.genie.web.controllers.CommandRestController
-
Get Command configuration for given id.
- getCommand() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get the command that ran or is currently running a given job.
- getCommand() - Method in interface com.netflix.genie.web.data.entities.projections.JobCommandProjection
-
Get the command that ran or is currently running a given job.
- getCommand() - Method in interface com.netflix.genie.web.data.entities.projections.v4.JobSpecificationProjection
-
Get the command that ran or is currently running a given job.
- getCommand(String) - Method in class com.netflix.genie.web.data.services.jpa.JpaCommandPersistenceServiceImpl
-
Gets command configuration for given id.
- getCommand(String) - Method in interface com.netflix.genie.web.services.CommandPersistenceService
-
Gets command configuration for given id.
- getCommandArgs() - Method in class com.netflix.genie.common.dto.Job
-
Get the arguments to be put on the command line along with the command executable.
- getCommandArgs() - Method in class com.netflix.genie.common.dto.JobRequest
-
Get the arguments to be put on the command line along with the command executable.
- getCommandArgs() - Method in interface com.netflix.genie.common.internal.dto.v4.AgentJobRequest
-
Get the command arguments a user has requested be appended to a command executable for their job.
- getCommandArgs() - Method in interface com.netflix.genie.common.internal.dto.v4.ApiJobRequest
-
Get the command arguments a user has requested be appended to a command executable for their job.
- getCommandArgs() - Method in class com.netflix.genie.common.internal.dto.v4.JobRequest
-
Get the command arguments a user has requested be appended to a command executable for their job.
- getCommandArgs() - Method in class com.netflix.genie.common.internal.dto.v4.JobSpecification
-
Returns an unmodifiable list of the command args for this job specification.
- getCommandArgs() - Method in interface com.netflix.genie.web.data.entities.projections.JobCommonFieldsProjection
-
Get the command arguments for this job.
- getCommandArgs() - Method in interface com.netflix.genie.web.data.entities.projections.v4.JobSpecificationProjection
-
Get the command arguments the user supplied for this job.
- getCommandArgs() - Method in interface com.netflix.genie.web.data.entities.projections.v4.V4JobRequestProjection
-
Get the command arguments the user supplied for this job.
- getCommandArguments() - Method in interface com.netflix.genie.agent.cli.ArgumentDelegates.JobRequestArguments
-
- getCommandCriterion() - Method in interface com.netflix.genie.agent.cli.ArgumentDelegates.JobRequestArguments
-
- getCommandCriterion() - Method in interface com.netflix.genie.web.data.entities.projections.JobRequestProjection
-
Get the command criterion for this job.
- getCommandCriterion() - Method in interface com.netflix.genie.web.data.entities.projections.v4.V4JobRequestProjection
-
Get the command criterion for this job.
- getCommandName() - Method in class com.netflix.genie.common.dto.Job
-
Get the name of the command running this job if there currently is one.
- getCommandName() - Method in class com.netflix.genie.common.dto.search.JobSearchResult
-
Get the name of the command running this job if there currently is one.
- getCommandName() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get the name of the command that is executing this job.
- getCommandName() - Method in interface com.netflix.genie.web.data.entities.projections.JobProjection
-
Get the name of the command that is executing this job.
- getCommandName() - Method in interface com.netflix.genie.web.data.entities.projections.JobSearchProjection
-
Get the name of the command that is executing this job.
- getCommands(String, String, List<String>, List<String>) - Method in interface com.netflix.genie.client.apis.CommandService
-
Method to get all commands from Genie filtered based on query params.
- getCommands() - Method in class com.netflix.genie.client.CommandClient
-
Method to get a list of all the commands.
- getCommands(String, String, List<String>, List<String>) - Method in class com.netflix.genie.client.CommandClient
-
Method to get a list of all the commands from Genie for the query parameters specified.
- getCommands(String, String, Set<String>, Set<String>, Pageable, PagedResourcesAssembler<Command>) - Method in class com.netflix.genie.web.controllers.CommandRestController
-
Get Command configuration based on user parameters.
- getCommands() - Method in interface com.netflix.genie.web.data.entities.projections.ClusterCommandsProjection
-
Get the commands associated with a cluster.
- getCommands(String, String, Set<CommandStatus>, Set<String>, Pageable) - Method in class com.netflix.genie.web.data.services.jpa.JpaCommandPersistenceServiceImpl
-
Get command configurations for given filter criteria.
- getCommands(String, String, Set<CommandStatus>, Set<String>, Pageable) - Method in interface com.netflix.genie.web.services.CommandPersistenceService
-
Get command configurations for given filter criteria.
- getCommandsForApplication(String) - Method in interface com.netflix.genie.client.apis.ApplicationService
-
Method to get commmands for a application in Genie.
- getCommandsForApplication(String) - Method in class com.netflix.genie.client.ApplicationClient
-
Method to get all the commands for an application.
- getCommandsForApplication(String, Set<String>) - Method in class com.netflix.genie.web.controllers.ApplicationRestController
-
Get all the commands this application is associated with.
- getCommandsForApplication(String, Set<CommandStatus>) - Method in class com.netflix.genie.web.data.services.jpa.JpaApplicationPersistenceServiceImpl
-
Get all the commands the application with given id is associated with.
- getCommandsForApplication(String, Set<CommandStatus>) - Method in interface com.netflix.genie.web.services.ApplicationPersistenceService
-
Get all the commands the application with given id is associated with.
- getCommandsForCluster(String) - Method in interface com.netflix.genie.client.apis.ClusterService
-
Method to get commmands for a cluster in Genie.
- getCommandsForCluster(String) - Method in class com.netflix.genie.client.ClusterClient
-
Method to get all the commands for a cluster.
- getCommandsForCluster(String, Set<String>) - Method in class com.netflix.genie.web.controllers.ClusterRestController
-
Get all the commandIds configured for a given cluster.
- getCommandsForCluster(String, Set<CommandStatus>) - Method in class com.netflix.genie.web.data.services.jpa.JpaClusterPersistenceServiceImpl
-
Get the set of commands associated with the cluster with given id.
- getCommandsForCluster(String, Set<CommandStatus>) - Method in interface com.netflix.genie.web.services.ClusterPersistenceService
-
Get the set of commands associated with the cluster with given id.
- getConfigs() - Method in class com.netflix.genie.common.internal.dto.v4.ExecutionEnvironment
-
Get the configuration files needed at runtime.
- getConfigs() - Method in interface com.netflix.genie.web.data.entities.projections.JobRequestProjection
-
Get all the configuration files for this job.
- getConfigs() - Method in interface com.netflix.genie.web.data.entities.projections.v4.ExecutionResourceProjection
-
Get all the configuration files for this entity.
- getConfigs() - Method in interface com.netflix.genie.web.data.entities.projections.v4.JobSpecificationProjection
-
Get all the configuration files for this job.
- getConfigs() - Method in interface com.netflix.genie.web.data.entities.projections.v4.V4JobRequestProjection
-
Get all the configuration files for this job.
- getConfigsForApplication(String) - Method in interface com.netflix.genie.client.apis.ApplicationService
-
Method to get configs for a application in Genie.
- getConfigsForApplication(String) - Method in class com.netflix.genie.client.ApplicationClient
-
Method to get all the configs for a application.
- getConfigsForApplication(String) - Method in class com.netflix.genie.web.controllers.ApplicationRestController
-
Get all the configuration files for a given application.
- getConfigsForApplication(String) - Method in class com.netflix.genie.web.data.services.jpa.JpaApplicationPersistenceServiceImpl
-
Get the set of configuration files associated with the application with
given id.
- getConfigsForApplication(String) - Method in interface com.netflix.genie.web.services.ApplicationPersistenceService
-
Get the set of configuration files associated with the application with
given id.
- getConfigsForCluster(String) - Method in interface com.netflix.genie.client.apis.ClusterService
-
Method to get configs for a cluster in Genie.
- getConfigsForCluster(String) - Method in class com.netflix.genie.client.ClusterClient
-
Method to get all the configs for a cluster.
- getConfigsForCluster(String) - Method in class com.netflix.genie.web.controllers.ClusterRestController
-
Get all the configuration files for a given cluster.
- getConfigsForCluster(String) - Method in class com.netflix.genie.web.data.services.jpa.JpaClusterPersistenceServiceImpl
-
Get the set of configuration files associated with the cluster with given
id.
- getConfigsForCluster(String) - Method in interface com.netflix.genie.web.services.ClusterPersistenceService
-
Get the set of configuration files associated with the cluster with given
id.
- getConfigsForCommand(String) - Method in interface com.netflix.genie.client.apis.CommandService
-
Method to get configs for a command in Genie.
- getConfigsForCommand(String) - Method in class com.netflix.genie.client.CommandClient
-
Method to get all the configs for a command.
- getConfigsForCommand(String) - Method in class com.netflix.genie.web.controllers.CommandRestController
-
Get all the configuration files for a given command.
- getConfigsForCommand(String) - Method in class com.netflix.genie.web.data.services.jpa.JpaCommandPersistenceServiceImpl
-
Get the set of configuration files associated with the command with given
id.
- getConfigsForCommand(String) - Method in interface com.netflix.genie.web.services.CommandPersistenceService
-
Get the set of configuration files associated with the command with given
id.
- getCpu() - Method in class com.netflix.genie.common.dto.JobRequest
-
Get the number of CPU's requested to run this job.
- getCreated() - Method in class com.netflix.genie.common.dto.BaseDTO
-
Get the creation time.
- getCreated() - Method in class com.netflix.genie.web.data.entities.AuditEntity
-
Get when this entity was created.
- getCreated() - Method in interface com.netflix.genie.web.data.entities.projections.AuditProjection
-
Get when this entity was created.
- getCriteria() - Method in interface com.netflix.genie.common.internal.dto.v4.AgentJobRequest
-
The resource criteria that was supplied for the job.
- getCriteria() - Method in interface com.netflix.genie.common.internal.dto.v4.ApiJobRequest
-
The resource criteria that was supplied for the job.
- getCurrentJobStatus() - Method in interface com.netflix.genie.agent.execution.ExecutionContext
-
Get the current job status.
- getDefaultMailServiceImpl() - Method in class com.netflix.genie.web.configs.GenieMailAutoConfiguration
-
Get an default implementation of the Mail Service interface if nothing is supplied.
- getDependencies() - Method in class com.netflix.genie.common.internal.dto.v4.ExecutionEnvironment
-
Get the dependency files needed at runtime.
- getDependencies() - Method in interface com.netflix.genie.web.data.entities.projections.JobRequestProjection
-
Get all the dependency files for this job.
- getDependencies() - Method in interface com.netflix.genie.web.data.entities.projections.v4.ExecutionResourceProjection
-
Get all the dependency files for this entity.
- getDependencies() - Method in interface com.netflix.genie.web.data.entities.projections.v4.JobSpecificationProjection
-
Get all the dependency files for this job.
- getDependencies() - Method in interface com.netflix.genie.web.data.entities.projections.v4.V4JobRequestProjection
-
Get all the dependency files for this job.
- getDependenciesForApplication(String) - Method in interface com.netflix.genie.client.apis.ApplicationService
-
Method to get dependency files for a application in Genie.
- getDependenciesForApplication(String) - Method in class com.netflix.genie.client.ApplicationClient
-
Method to get all the dependency files for an application.
- getDependenciesForApplication(String) - Method in class com.netflix.genie.web.controllers.ApplicationRestController
-
Get all the dependency files for a given application.
- getDependenciesForApplication(String) - Method in class com.netflix.genie.web.data.services.jpa.JpaApplicationPersistenceServiceImpl
-
Get the set of dependency files associated with the application with given id.
- getDependenciesForApplication(String) - Method in interface com.netflix.genie.web.services.ApplicationPersistenceService
-
Get the set of dependency files associated with the application with given id.
- getDependenciesForCluster(String) - Method in interface com.netflix.genie.client.apis.ClusterService
-
Method to get dependency files for a cluster in Genie.
- getDependenciesForCluster(String) - Method in class com.netflix.genie.client.ClusterClient
-
Method to get all the dependency files for an cluster.
- getDependenciesForCluster(String) - Method in class com.netflix.genie.web.controllers.ClusterRestController
-
Get all the dependency files for a given cluster.
- getDependenciesForCluster(String) - Method in class com.netflix.genie.web.data.services.jpa.JpaClusterPersistenceServiceImpl
-
Get the set of dependency files associated with the cluster with given id.
- getDependenciesForCluster(String) - Method in interface com.netflix.genie.web.services.ClusterPersistenceService
-
Get the set of dependency files associated with the cluster with given id.
- getDependenciesForCommand(String) - Method in interface com.netflix.genie.client.apis.CommandService
-
Method to get dependency files for a command in Genie.
- getDependenciesForCommand(String) - Method in class com.netflix.genie.client.CommandClient
-
Method to get all the dependency files for an command.
- getDependenciesForCommand(String) - Method in class com.netflix.genie.web.controllers.CommandRestController
-
Get all the dependency files for a given command.
- getDependenciesForCommand(String) - Method in class com.netflix.genie.web.data.services.jpa.JpaCommandPersistenceServiceImpl
-
Get the set of dependency files associated with the command with given id.
- getDependenciesForCommand(String) - Method in interface com.netflix.genie.web.services.CommandPersistenceService
-
Get the set of dependency files associated with the command with given id.
- getDescription() - Method in class com.netflix.genie.common.dto.CommonDTO
-
Get the description.
- getDescription() - Method in class com.netflix.genie.common.internal.dto.v4.CommonMetadata
-
Get the description.
- getDescription() - Method in class com.netflix.genie.web.data.entities.BaseEntity
-
Get the description of this resource.
- getDescription() - Method in interface com.netflix.genie.web.data.entities.projections.BaseProjection
-
Get the description of this resource.
- getDescription() - Method in interface com.netflix.genie.web.data.entities.projections.v4.V4JobRequestProjection
-
Get the description of this resource.
- getDescription() - Method in class com.netflix.genie.web.resources.agent.AgentFileResourceImpl
- getDirectories() - Method in class com.netflix.genie.common.internal.dto.DirectoryManifest
-
Get all the entries that are directories for this manifest.
- getDirectory(File, String, boolean) - Method in class com.netflix.genie.web.resources.writers.DefaultDirectoryWriter
-
- getDirectoryManifest(Path, boolean) - Method in class com.netflix.genie.common.internal.dto.DirectoryManifest.Factory
-
Create a manifest from the given job directory.
- getDirectoryManifest(Path) - Method in class com.netflix.genie.common.internal.services.impl.JobDirectoryManifestServiceImpl
-
- getDirectoryManifest(Path) - Method in interface com.netflix.genie.common.internal.services.JobDirectoryManifestService
-
- getDuration(Instant, Instant) - Static method in class com.netflix.genie.common.util.TimeUtils
-
Get the duration between when something was started and finished.
- getEmail() - Method in interface com.netflix.genie.agent.cli.ArgumentDelegates.JobRequestArguments
-
- getEmail() - Method in class com.netflix.genie.common.dto.JobRequest
-
Get the email for the user.
- getEmail() - Method in class com.netflix.genie.common.internal.dto.v4.JobMetadata
-
Get the email for the user if there is one as an Optional
.
- getEmail() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get the email of the user associated with this job if they desire an email notification at completion
of the job.
- getEmail() - Method in interface com.netflix.genie.web.data.entities.projections.JobRequestProjection
-
Get the email of the user associated with this job if they desire an email notification at completion
of the job.
- getEmail() - Method in interface com.netflix.genie.web.data.entities.projections.v4.V4JobRequestProjection
-
Get the email of the user associated with this job if they desire an email notification at completion
of the job.
- getEntries() - Method in interface com.netflix.genie.agent.execution.services.DownloadService.Manifest
-
Get the manifest entries.
- getEntry(String) - Method in class com.netflix.genie.common.internal.dto.DirectoryManifest
-
Get the entry, if one exists, for the given path.
- getEnvironmentVariables() - Method in class com.netflix.genie.common.internal.dto.v4.JobSpecification
-
Get the environment variables dictated by the server that should be set in the job execution environment.
- getEnvironmentVariables() - Method in interface com.netflix.genie.web.data.entities.projections.v4.JobSpecificationProjection
-
Get the final set of environment variables sent from the server to the agent for the job.
- getErrorCode() - Method in exception com.netflix.genie.client.exceptions.GenieClientException
-
Return the HTTP status code for this exception.
- getErrorCode() - Method in exception com.netflix.genie.common.exceptions.GenieException
-
Return the HTTP status code for this exception.
- getExecutable() - Method in class com.netflix.genie.common.internal.dto.v4.Command
-
Get the executable elements (generally a binary followed optionally by default arguments) that should be used
with this command when executing a job.
- getExecutable() - Method in class com.netflix.genie.common.internal.dto.v4.CommandRequest
-
Get the executable elements (generally a binary followed optionally by default arguments) that should be used
with this command when executing a job.
- getExitCode() - Method in class com.netflix.genie.agent.cli.GenieAgentRunner
-
- getExitCode() - Method in class com.netflix.genie.common.dto.JobExecution
-
Get the exit code of the process.
- getExitCode() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get the exit code from the process that ran the job.
- getExitCode() - Method in interface com.netflix.genie.web.data.entities.projections.JobExecutionProjection
-
Get the exit code from the process that ran the job.
- getExt() - Method in class com.netflix.genie.common.internal.dto.v4.AgentConfigRequest
-
Get the extension variables to the agent configuration as a JSON blob.
- getExt() - Method in class com.netflix.genie.common.internal.dto.v4.AgentEnvironmentRequest
-
Get the extension variables to the agent configuration as a JSON blob.
- getFile(String, HttpServletRequest) - Method in class com.netflix.genie.ui.controllers.UIController
-
Forward the file request to the API.
- getFile(String) - Method in interface com.netflix.genie.web.data.services.jpa.JpaFilePersistenceService
-
Get a reference to the file entity for the given file path string.
- getFile(String) - Method in class com.netflix.genie.web.data.services.jpa.JpaFilePersistenceServiceImpl
-
Get a reference to the file entity for the given file path string.
- getFile() - Method in class com.netflix.genie.web.resources.agent.AgentFileResourceImpl
- getFile(String, String) - Method in interface com.netflix.genie.web.services.FileTransfer
-
Gets a file from any remote location to Genie's local working directory.
- getFile(String, String) - Method in class com.netflix.genie.web.services.impl.CacheGenieFileTransferService
-
Get the file needed by Genie for job execution.
- getFile(String, String) - Method in class com.netflix.genie.web.services.impl.GenieFileTransferService
-
Get the file needed by Genie for job execution.
- getFile(String, String) - Method in class com.netflix.genie.web.services.impl.HttpFileTransferImpl
-
Gets a file from any remote location to Genie's local working directory.
- getFile(String, String) - Method in class com.netflix.genie.web.services.impl.LocalFileTransferImpl
-
Gets a file from any remote location to Genie's local working directory.
- getFile(String, String) - Method in class com.netflix.genie.web.services.impl.S3FileTransferImpl
-
Gets a file from any remote location to Genie's local working directory.
- getFilename() - Method in class com.netflix.genie.web.resources.agent.AgentFileResourceImpl
- getFiles() - Method in class com.netflix.genie.common.internal.dto.DirectoryManifest
-
Get all the entries that are files for this manifest.
- getFiles(Set<String>) - Method in interface com.netflix.genie.web.data.services.jpa.JpaFilePersistenceService
-
Get all the file entity references that match the input set of file strings.
- getFiles(Set<String>) - Method in class com.netflix.genie.web.data.services.jpa.JpaFilePersistenceServiceImpl
-
Get all the file entity references that match the input set of file strings.
- getFinalJobStatus() - Method in interface com.netflix.genie.agent.execution.ExecutionContext
-
Get the job status, if one was set.
- getFindPredicate(Root<JobEntity>, CriteriaBuilder, String, String, String, Set<JobStatus>, Set<String>, String, ClusterEntity, String, CommandEntity, Instant, Instant, Instant, Instant, String, String) - Static method in class com.netflix.genie.web.data.repositories.jpa.specifications.JpaJobSpecs
-
Generate a criteria query predicate for a where clause based on the given parameters.
- getFinished() - Method in class com.netflix.genie.common.dto.Job
-
Get the time the job finished.
- getFinished() - Method in class com.netflix.genie.common.dto.search.JobSearchResult
-
Get the time the job finished.
- getFinished() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get when the job was finished.
- getFinished() - Method in interface com.netflix.genie.web.data.entities.projections.JobProjection
-
Get when the job was finished.
- getFinished() - Method in interface com.netflix.genie.web.data.entities.projections.JobSearchProjection
-
Get the time the job finished if it has finished.
- getFinishedStatuses() - Static method in enum com.netflix.genie.common.dto.JobStatus
-
Get an unmodifiable set of all the statuses that make up a job being considered finished.
- getFixedDelay() - Method in class com.netflix.genie.web.tasks.GenieTask
-
Get how long the system should wait between invoking the run() method of this task in milliseconds after the
last successful run of the task.
- getFixedRate() - Method in class com.netflix.genie.web.tasks.GenieTask
-
Get how long the system should wait between invoking the run() method of this task in milliseconds.
- getFixedRate() - Method in class com.netflix.genie.web.tasks.leader.AgentJobCleanupTask
-
Get how long the system should wait between invoking the run() method of this task in milliseconds.
- getFixedRate() - Method in class com.netflix.genie.web.tasks.leader.ClusterCheckerTask
-
Get how long the system should wait between invoking the run() method of this task in milliseconds.
- getFixedRate() - Method in class com.netflix.genie.web.tasks.leader.UserMetricsTask
-
Get how long the system should wait between invoking the run() method of this task in milliseconds.
- getGenieUserGroup() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get the user group for this job.
- getGenieUserGroup() - Method in interface com.netflix.genie.web.data.entities.projections.JobRequestProjection
-
Get the user group for this job.
- getGenieUserGroup() - Method in interface com.netflix.genie.web.data.entities.projections.v4.V4JobRequestProjection
-
Get the user group for this job.
- getGroup() - Method in class com.netflix.genie.common.dto.JobRequest
-
Get the group the user should be a member of.
- getGroup() - Method in class com.netflix.genie.common.internal.dto.v4.JobMetadata
-
Get the group the user should is a member of as an Optional
.
- getGrouping() - Method in interface com.netflix.genie.agent.cli.ArgumentDelegates.JobRequestArguments
-
- getGrouping() - Method in class com.netflix.genie.common.dto.Job
-
Get the grouping for this job if there currently is one.
- getGrouping() - Method in class com.netflix.genie.common.dto.JobRequest
-
Get the grouping for this job if there currently is one.
- getGrouping() - Method in class com.netflix.genie.common.internal.dto.v4.JobMetadata
-
Get the grouping for this job if there currently is one as an Optional
.
- getGrouping() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get the grouping this job is a part of.
- getGrouping() - Method in interface com.netflix.genie.web.data.entities.projections.JobCommonFieldsProjection
-
Get the grouping this job is a part of.
- getGrouping() - Method in interface com.netflix.genie.web.data.entities.projections.v4.V4JobRequestProjection
-
Get the grouping this job is a part of.
- getGroupingInstance() - Method in interface com.netflix.genie.agent.cli.ArgumentDelegates.JobRequestArguments
-
- getGroupingInstance() - Method in class com.netflix.genie.common.dto.Job
-
Get the grouping instance for this job if there currently is one.
- getGroupingInstance() - Method in class com.netflix.genie.common.dto.JobRequest
-
Get the grouping instance for this job if there currently is one.
- getGroupingInstance() - Method in class com.netflix.genie.common.internal.dto.v4.JobMetadata
-
Get the grouping instance for this job if there currently is one as an Optional
.
- getGroupingInstance() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get the instance identifier of a grouping.
- getGroupingInstance() - Method in interface com.netflix.genie.web.data.entities.projections.JobCommonFieldsProjection
-
Get the instance identifier of a grouping.
- getGroupingInstance() - Method in interface com.netflix.genie.web.data.entities.projections.v4.V4JobRequestProjection
-
Get the instance identifier of a grouping.
- getHostname() - Method in class com.netflix.genie.common.internal.dto.v4.ClientMetadata
-
Get the hostname of the client.
- getHostnameForAgentConnection(String) - Method in interface com.netflix.genie.web.services.AgentRoutingService
-
Look up the hostname of the Genie node currently handling the agent connection for a given job.
- getHostnameForAgentConnection(String) - Method in class com.netflix.genie.web.services.impl.AgentRoutingServiceImpl
-
Look up the hostname of the Genie node currently handling the agent connection for a given job.
- getId() - Method in class com.netflix.genie.common.dto.BaseDTO
-
Get the Id of this DTO.
- getId() - Method in class com.netflix.genie.common.internal.dto.v4.Criterion
-
Get the id of the resource desired if it exists.
- getId() - Method in interface com.netflix.genie.web.data.entities.projections.IdProjection
-
Get the id from the projection.
- getIndex() - Method in class com.netflix.genie.ui.controllers.UIController
-
Return the getIndex.html template for requests to root.
- getInputStream() - Method in class com.netflix.genie.web.resources.agent.AgentFileResourceImpl
- getInputStream() - Method in class com.netflix.genie.web.util.StreamBuffer
-
Obtain the input stream to read this data.
- getJavaMailSenderMailService(JavaMailSender, MailProperties) - Method in class com.netflix.genie.web.configs.GenieMailAutoConfiguration
-
Returns a bean for mail service impl using the Spring Mail.
- getJob(String) - Method in interface com.netflix.genie.client.apis.JobService
-
Method to fetch a single job from Genie.
- getJob(String) - Method in class com.netflix.genie.client.JobClient
-
Method to get a job from Genie.
- getJob(String) - Method in class com.netflix.genie.web.controllers.JobRestController
-
Get job information for given job id.
- getJob(String) - Method in class com.netflix.genie.web.data.services.jpa.JpaJobSearchServiceImpl
-
Get job information for given job id.
- getJob(String) - Method in interface com.netflix.genie.web.services.JobSearchService
-
Get job information for given job id.
- getJobApplications(String) - Method in interface com.netflix.genie.client.apis.JobService
-
Method to get the Applications for a job.
- getJobApplications(String) - Method in class com.netflix.genie.client.JobClient
-
Method to get the Applications for the job.
- getJobApplications(String) - Method in class com.netflix.genie.web.controllers.JobRestController
-
Get the applications used ot run the job.
- getJobApplications(String) - Method in class com.netflix.genie.web.data.services.jpa.JpaJobSearchServiceImpl
-
Get the applications the job was run with or exception if not found.
- getJobApplications(String) - Method in interface com.netflix.genie.web.services.JobSearchService
-
Get the applications the job was run with or exception if not found.
- getJobArchiveLocation(String) - Method in class com.netflix.genie.web.data.services.jpa.JpaJobPersistenceServiceImpl
-
Get the location a job directory was archived to if at all.
- getJobArchiveLocation(String) - Method in interface com.netflix.genie.web.services.JobPersistenceService
-
Get the location a job directory was archived to if at all.
- getJobCluster(String) - Method in interface com.netflix.genie.client.apis.JobService
-
Method to get the cluster information on which a job is run.
- getJobCluster(String) - Method in class com.netflix.genie.client.JobClient
-
Method to get the cluster on which the job executes.
- getJobCluster(String) - Method in class com.netflix.genie.web.controllers.JobRestController
-
Get the cluster the job was run on or is currently running on.
- getJobCluster(String) - Method in class com.netflix.genie.web.data.services.jpa.JpaJobSearchServiceImpl
-
Get the cluster the job was run on or exception if not found.
- getJobCluster(String) - Method in interface com.netflix.genie.web.services.JobSearchService
-
Get the cluster the job was run on or exception if not found.
- getJobCommand(String) - Method in interface com.netflix.genie.client.apis.JobService
-
Method to get the command information on which a job is run.
- getJobCommand(String) - Method in class com.netflix.genie.client.JobClient
-
Method to get the command on which the job executes.
- getJobCommand(String) - Method in class com.netflix.genie.web.controllers.JobRestController
-
Get the command the job was run with or is currently running with.
- getJobCommand(String) - Method in class com.netflix.genie.web.data.services.jpa.JpaJobSearchServiceImpl
-
Get the command the job was run with or exception if not found.
- getJobCommand(String) - Method in interface com.netflix.genie.web.services.JobSearchService
-
Get the command the job was run with or exception if not found.
- getJobConfigurations() - Method in interface com.netflix.genie.agent.cli.ArgumentDelegates.JobRequestArguments
-
- getJobDependencies() - Method in interface com.netflix.genie.agent.cli.ArgumentDelegates.JobRequestArguments
-
- getJobDescription() - Method in interface com.netflix.genie.agent.cli.ArgumentDelegates.JobRequestArguments
-
- getJobDirectory() - Method in interface com.netflix.genie.agent.execution.ExecutionContext
-
Get the job run directory.
- getJobDirectoryFileState(String, boolean) - Method in class com.netflix.genie.web.services.impl.DiskJobFileServiceImpl
-
Given a job id this API will traverse the job directory (if it exists) and return the set of all the files
including their relative paths from the directory root, the files' size and optionally a MD5 hash of the
file contents.
- getJobDirectoryFileState(String, boolean) - Method in interface com.netflix.genie.web.services.JobFileService
-
Given a job id this API will traverse the job directory (if it exists) and return the set of all the files
including their relative paths from the directory root, the files' size and optionally a MD5 hash of the
file contents.
- getJobDirectoryLocation() - Method in interface com.netflix.genie.agent.cli.ArgumentDelegates.JobRequestArguments
-
- getJobDirectoryLocation() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get the job directory location the agent should use.
- getJobDirectoryLocation() - Method in interface com.netflix.genie.web.data.entities.projections.v4.JobSpecificationProjection
-
Get the job directory location the agent should use.
- getJobEnvironment() - Method in interface com.netflix.genie.agent.execution.ExecutionContext
-
Get the environment variables map for the job process.
- getJobExecution(String) - Method in interface com.netflix.genie.client.apis.JobService
-
Method to get the execution information for a job.
- getJobExecution(String) - Method in class com.netflix.genie.client.JobClient
-
Method to get the Job Execution information for the job.
- getJobExecution(String) - Method in class com.netflix.genie.web.controllers.JobRestController
-
Get the execution information about a job.
- getJobExecution(String) - Method in class com.netflix.genie.web.data.services.jpa.JpaJobSearchServiceImpl
-
Get job execution for given job id.
- getJobExecution(String) - Method in interface com.netflix.genie.web.services.JobSearchService
-
Get job execution for given job id.
- getJobFileAsResource(String, String) - Method in class com.netflix.genie.web.services.impl.DiskJobFileServiceImpl
-
Given the expected path of a job resource (file or directory) for a given job return a Resource
handle for this location.
- getJobFileAsResource(String, String) - Method in interface com.netflix.genie.web.services.JobFileService
-
Given the expected path of a job resource (file or directory) for a given job return a Resource
handle for this location.
- getJobHost(String) - Method in class com.netflix.genie.web.data.services.jpa.JpaJobSearchServiceImpl
-
Get the hostname a job is running on.
- getJobHost(String) - Method in interface com.netflix.genie.web.services.JobSearchService
-
Get the hostname a job is running on.
- getJobId() - Method in interface com.netflix.genie.agent.cli.ArgumentDelegates.JobRequestArguments
-
- getJobMetadata() - Method in interface com.netflix.genie.agent.cli.ArgumentDelegates.JobRequestArguments
-
- getJobMetadata(String) - Method in interface com.netflix.genie.client.apis.JobService
-
Method to get the metadata information for a job.
- getJobMetadata(String) - Method in class com.netflix.genie.client.JobClient
-
Method to get the metadata information for the job.
- getJobMetadata(String) - Method in class com.netflix.genie.web.controllers.JobRestController
-
Get the metadata information about a job.
- getJobMetadata(String) - Method in class com.netflix.genie.web.data.services.jpa.JpaJobSearchServiceImpl
-
Get the metadata about a job.
- getJobMetadata(String) - Method in interface com.netflix.genie.web.services.JobSearchService
-
Get the metadata about a job.
- getJobName() - Method in interface com.netflix.genie.agent.cli.ArgumentDelegates.JobRequestArguments
-
- getJobOutput(String, String, HttpServletRequest, HttpServletResponse) - Method in class com.netflix.genie.web.controllers.JobRestController
-
Get the job output directory.
- getJobRequest(String) - Method in interface com.netflix.genie.client.apis.JobService
-
Method to get the JobRequest for a job.
- getJobRequest(String) - Method in class com.netflix.genie.client.JobClient
-
Method to get the Job Request for the job.
- getJobRequest(String) - Method in class com.netflix.genie.web.controllers.JobRestController
-
Get the original job request.
- getJobRequest(String) - Method in class com.netflix.genie.web.data.services.jpa.JpaJobPersistenceServiceImpl
-
Get the original request for a job.
- getJobRequest(String) - Method in class com.netflix.genie.web.data.services.jpa.JpaJobSearchServiceImpl
-
Get job request for given job id.
- getJobRequest(String) - Method in interface com.netflix.genie.web.services.JobPersistenceService
-
Get the original request for a job.
- getJobRequest(String) - Method in interface com.netflix.genie.web.services.JobSearchService
-
Get job request for given job id.
- getJobs(String, String, String, Set<String>, Set<String>, String, String, String, String, Long, Long, Long, Long, String, String) - Method in interface com.netflix.genie.client.apis.JobService
-
Method to get all jobs from Genie.
- getJobs() - Method in class com.netflix.genie.client.JobClient
-
Method to get a list of all the jobs.
- getJobs(String, String, String, Set<String>, Set<String>, String, String, String, String, Long, Long, Long, Long) - Method in class com.netflix.genie.client.JobClient
-
Deprecated.
- getJobs(String, String, String, Set<String>, Set<String>, String, String, String, String, Long, Long, Long, Long, String, String) - Method in class com.netflix.genie.client.JobClient
-
Method to get a list of all the jobs from Genie for the query parameters specified.
- getJobSetup() - Method in interface com.netflix.genie.agent.cli.ArgumentDelegates.JobRequestArguments
-
- getJobSpecification() - Method in interface com.netflix.genie.agent.execution.ExecutionContext
-
Get the job specification.
- getJobSpecification(String) - Method in interface com.netflix.genie.agent.execution.services.AgentJobService
-
Given a job id retrieve the job specification from the server.
- getJobSpecification(String) - Method in class com.netflix.genie.web.data.services.jpa.JpaJobPersistenceServiceImpl
-
Get the saved job specification for the given job.
- getJobSpecification(JobSpecificationRequest, StreamObserver<JobSpecificationResponse>) - Method in class com.netflix.genie.web.rpc.grpc.services.impl.v4.GRpcJobServiceImpl
-
Assuming a specification has already been resolved the agent will call this API with a job id to fetch the
specification.
- getJobSpecification(String) - Method in interface com.netflix.genie.web.services.AgentJobService
-
Get a job specification if has been resolved.
- getJobSpecification(String) - Method in class com.netflix.genie.web.services.impl.AgentJobServiceImpl
-
Get a job specification if has been resolved.
- getJobSpecification(String) - Method in interface com.netflix.genie.web.services.JobPersistenceService
-
Get the saved job specification for the given job.
- getJobsPropertiesDefaults() - Static method in class com.netflix.genie.web.properties.JobsProperties
-
Create a JobsProperties initialized with default values (for use in tests).
- getJobStatus(String) - Method in interface com.netflix.genie.client.apis.JobService
-
Method to get Job status.
- getJobStatus(String) - Method in class com.netflix.genie.client.JobClient
-
Method to fetch the status of a job.
- getJobStatus(String) - Method in class com.netflix.genie.web.controllers.JobRestController
-
Get the status of the given job if it exists.
- getJobStatus(String) - Method in class com.netflix.genie.web.data.services.jpa.JpaJobPersistenceServiceImpl
-
Get the status for a job with the given id
.
- getJobStatus(String) - Method in class com.netflix.genie.web.data.services.jpa.JpaJobSearchServiceImpl
-
Deprecated.
- getJobStatus(String) - Method in interface com.netflix.genie.web.services.JobPersistenceService
-
Get the status for a job with the given id
.
- getJobStatus(String) - Method in interface com.netflix.genie.web.services.JobSearchService
-
- getJobStderr(String) - Method in interface com.netflix.genie.client.apis.JobService
-
Method to fetch the stderr of a job from Genie.
- getJobStderr(String) - Method in class com.netflix.genie.client.JobClient
-
Method to fetch the stderr of a job from Genie.
- getJobStdout(String) - Method in interface com.netflix.genie.client.apis.JobService
-
Method to fetch the stdout of a job from Genie.
- getJobStdout(String) - Method in class com.netflix.genie.client.JobClient
-
Method to fetch the stdout of a job from Genie.
- getJobTags() - Method in interface com.netflix.genie.agent.cli.ArgumentDelegates.JobRequestArguments
-
- getJobVersion() - Method in interface com.netflix.genie.agent.cli.ArgumentDelegates.JobRequestArguments
-
- getKillFlag() - Static method in class com.netflix.genie.common.internal.jobs.JobConstants
-
Returns the appropriate flag to append to kill command based on the OS.
- getKillSource() - Method in class com.netflix.genie.agent.execution.services.KillService.KillEvent
-
- getLastModifiedTime(String) - Method in interface com.netflix.genie.web.services.FileTransfer
-
Returns the last modified time of the file with the given path.
- getLastModifiedTime(String) - Method in class com.netflix.genie.web.services.impl.HttpFileTransferImpl
-
Returns the last modified time of the file with the given path.
- getLastModifiedTime(String) - Method in class com.netflix.genie.web.services.impl.LocalFileTransferImpl
-
Returns the last modified time of the file with the given path.
- getLastModifiedTime(String) - Method in class com.netflix.genie.web.services.impl.S3FileTransferImpl
-
Returns the last modified time of the file with the given path.
- getLock(File) - Method in class com.netflix.genie.agent.utils.locks.impl.FileLockFactory
-
Get a lock locking the provided File object.
- getLogger() - Static method in class com.netflix.genie.agent.cli.UserConsole
-
Get the LOGGER visible to user on the console.
- getManifest(String) - Method in interface com.netflix.genie.web.services.AgentFileStreamService
-
Returns the manifest for a given job, boxed in an Optional
.
- getMapper() - Static method in class com.netflix.genie.common.util.GenieObjectMapper
-
Get the preconfigured Object Mapper used across Genie for consistency.
- getMd5() - Method in class com.netflix.genie.common.internal.dto.DirectoryManifest.ManifestEntry
-
Get the MD5 hash of the file (as 32 hex characters) if it was calculated.
- getMd5() - Method in class com.netflix.genie.common.internal.dto.v4.files.JobFileState
-
Get the MD5 hash of the file (as 32 hex characters) if it was calculated.
- getMemory() - Method in class com.netflix.genie.common.dto.Command
-
Get the default amount of memory (in MB) to use for jobs which use this command.
- getMemory() - Method in class com.netflix.genie.common.dto.JobExecution
-
Get the amount of memory (in MB) of the job.
- getMemory() - Method in class com.netflix.genie.common.dto.JobRequest
-
Get the amount of memory (in MB) requested to run this job with.
- getMemory() - Method in class com.netflix.genie.common.internal.dto.v4.Command
-
Get the default amount of memory (in MB) to use for jobs which use this command.
- getMemory() - Method in class com.netflix.genie.common.internal.dto.v4.CommandRequest
-
Get the default amount of memory (in MB) to use for jobs which use this command.
- getMemory() - Method in class com.netflix.genie.web.data.entities.CommandEntity
-
Get the default memory for a job using this command.
- getMemoryUsed() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get the amount of memory (in MB) that this job is/was run with.
- getMemoryUsed() - Method in interface com.netflix.genie.web.data.entities.projections.JobExecutionProjection
-
Get the amount of memory (in MB) that this job is/was run with.
- getMetadata() - Method in class com.netflix.genie.common.dto.CommonDTO
-
Get the metadata of this resource as a JSON Node.
- getMetadata() - Method in interface com.netflix.genie.common.internal.dto.v4.AgentJobRequest
-
Get the metadata a user has supplied for the job including things like name, tags, etc.
- getMetadata() - Method in interface com.netflix.genie.common.internal.dto.v4.ApiJobRequest
-
Get the metadata a user has supplied for the job including things like name, tags, etc.
- getMetadata() - Method in class com.netflix.genie.common.internal.dto.v4.CommonMetadata
-
Get the metadata of this resource as a JSON Node.
- getMetadata() - Method in class com.netflix.genie.web.data.entities.BaseEntity
-
Get the metadata of this entity which is unstructured JSON.
- getMetadata() - Method in interface com.netflix.genie.web.data.entities.projections.BaseProjection
-
Get the metadata of this entity which is unstructured JSON.
- getMetadata() - Method in interface com.netflix.genie.web.data.entities.projections.v4.V4JobRequestProjection
-
Get the metadata of this entity which is unstructured JSON.
- getMidnightUTC() - Static method in class com.netflix.genie.web.tasks.TaskUtils
-
Get exactly midnight (00:00:00.000) UTC for the current day.
- getMimeType() - Method in class com.netflix.genie.common.internal.dto.DirectoryManifest.ManifestEntry
-
Get the mime type of this file if it was calculated.
- getMinimumVersion() - Method in class com.netflix.genie.web.properties.AgentFilterProperties
-
Get the (dynamic) property value representing the minimum agent version allowed to connect.
- getName() - Method in class com.netflix.genie.common.internal.dto.v4.Criterion
-
Get the name of the resource desired if it exists.
- getName() - Method in class com.netflix.genie.web.data.entities.CriterionEntity
-
Get the name this criterion was using if there was one.
- getName() - Method in interface com.netflix.genie.web.data.entities.projections.BaseProjection
-
Get the name of the resource.
- getName() - Method in interface com.netflix.genie.web.data.entities.projections.JobSearchProjection
-
Get the name of the job.
- getName() - Method in interface com.netflix.genie.web.data.entities.projections.v4.V4JobRequestProjection
-
Get the name of the resource.
- getNumActiveJobs() - Method in class com.netflix.genie.web.services.impl.JobMetricsServiceImpl
-
Get the number of jobs active on this node.
- getNumActiveJobs() - Method in class com.netflix.genie.web.services.impl.JobStateServiceImpl
-
Get the number of jobs active on this node.
- getNumActiveJobs() - Method in interface com.netflix.genie.web.services.JobMetricsService
-
Get the number of jobs active on this node.
- getNumAgentConnectionsOnServer(String) - Method in class com.netflix.genie.web.data.services.jpa.JpaAgentConnectionPersistenceServiceImpl
-
Get the number of active agent connections on Genie server with the given hostname
.
- getNumAgentConnectionsOnServer(String) - Method in interface com.netflix.genie.web.services.AgentConnectionPersistenceService
-
Get the number of active agent connections on Genie server with the given hostname
.
- getNumAttachments() - Method in class com.netflix.genie.common.dto.JobMetadata
-
Get the number of attachments.
- getNumAttachments() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get the number of attachments.
- getNumAttachments() - Method in interface com.netflix.genie.web.data.entities.projections.JobMetadataProjection
-
Get the number of attachments.
- getNumConnectedAgents() - Method in interface com.netflix.genie.web.services.AgentMetricsService
-
Get the number of agents currently connected to this server.
- getNumConnectedAgents() - Method in class com.netflix.genie.web.services.impl.AgentMetricsServiceImpl
-
Get the number of agents currently connected to this server.
- getNumDirectories() - Method in class com.netflix.genie.common.internal.dto.DirectoryManifest
-
Get the total number of directories in this manifest.
- getNumFiles() - Method in class com.netflix.genie.common.internal.dto.DirectoryManifest
-
Get the total number of files in this manifest.
- getOperandArguments(String[]) - Static method in class com.netflix.genie.agent.cli.Util
-
Get a subset of argument after the double dash (a.k.a.
- getOptionArguments(String[]) - Static method in class com.netflix.genie.agent.cli.Util
-
Get a subset of arguments before the double dash (a.k.a.
- getOrder() - Method in class com.netflix.genie.web.aspect.DataServiceRetryAspect
-
- getParent() - Method in class com.netflix.genie.common.internal.dto.DirectoryManifest.ManifestEntry
-
Get the relative path from root of the parent of this entry if there was one.
- getPid() - Method in class com.netflix.genie.common.internal.dto.v4.AgentClientMetadata
-
Get the process id of the Agent on the host it is running on.
- getProcessId() - Method in class com.netflix.genie.common.dto.JobExecution
-
Get the process id for this job execution as Optional.
- getProcessId() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get the process id of the job.
- getProcessId() - Method in interface com.netflix.genie.web.data.entities.projections.JobExecutionProjection
-
Get the process id of the job.
- getRegion() - Method in class com.netflix.genie.common.internal.aws.s3.BucketProperties
-
Get the Regions
this bucket is in.
- getRemainingPath(HttpServletRequest) - Static method in class com.netflix.genie.web.controllers.ControllerUtils
-
Get the remaining path from a given request.
- getRequestAgentClientHostname() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get the hostname of the agent that requested this job be run if there was one.
- getRequestAgentClientPid() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get the PID of the agent that requested this job be run if there was one.
- getRequestAgentClientVersion() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get the version of the agent that requested this job be run if there was one.
- getRequestApiClientHostname() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get the request api client hostname.
- getRequestApiClientHostname() - Method in interface com.netflix.genie.web.data.entities.projections.JobMetadataProjection
-
Get the request api client hostname.
- getRequestApiClientUserAgent() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get the user agent.
- getRequestApiClientUserAgent() - Method in interface com.netflix.genie.web.data.entities.projections.JobMetadataProjection
-
Get the user agent.
- getRequestedAgentConfig() - Method in interface com.netflix.genie.common.internal.dto.v4.AgentJobRequest
-
Get the requested agent configuration.
- getRequestedAgentConfig() - Method in interface com.netflix.genie.common.internal.dto.v4.ApiJobRequest
-
Get the requested agent configuration.
- getRequestedAgentConfigExt() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get the extension configuration of a job agent configuration.
- getRequestedAgentConfigExt() - Method in interface com.netflix.genie.web.data.entities.projections.v4.V4JobRequestProjection
-
Get the extension configuration of a job agent configuration.
- getRequestedAgentEnvironment() - Method in interface com.netflix.genie.common.internal.dto.v4.ApiJobRequest
-
Get the environment parameters the user requested to be associated with the Agent.
- getRequestedAgentEnvironmentExt() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get the extension configuration of a job agent environment.
- getRequestedAgentEnvironmentExt() - Method in interface com.netflix.genie.web.data.entities.projections.v4.V4JobRequestProjection
-
Get the extension configuration of a job agent environment.
- getRequestedApplications() - Method in interface com.netflix.genie.web.data.entities.projections.JobRequestProjection
-
Get any applications requested by their id.
- getRequestedApplications() - Method in interface com.netflix.genie.web.data.entities.projections.v4.V4JobRequestProjection
-
Get any applications requested by their id.
- getRequestedArchiveLocationPrefix() - Method in class com.netflix.genie.common.internal.dto.v4.JobArchivalDataRequest
-
Get the prefix for the uri where the Agent should archive the job directory after the job finishes.
- getRequestedArchiveLocationPrefix() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get the archive location prefix uri for a job.
- getRequestedArchiveLocationPrefix() - Method in interface com.netflix.genie.web.data.entities.projections.v4.V4JobRequestProjection
-
Get the archive location prefix uri for a job.
- getRequestedCpu() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get the number of CPU's requested to run this job.
- getRequestedCpu() - Method in interface com.netflix.genie.web.data.entities.projections.JobRequestProjection
-
Get the number of CPU's requested to run this job.
- getRequestedCpu() - Method in interface com.netflix.genie.web.data.entities.projections.v4.V4JobRequestProjection
-
Get the number of CPU's requested to run this job.
- getRequestedEnvironmentVariables() - Method in class com.netflix.genie.common.internal.dto.v4.AgentEnvironmentRequest
-
Get the environment variables requested by the user to be added to the job runtime.
- getRequestedEnvironmentVariables() - Method in interface com.netflix.genie.web.data.entities.projections.v4.V4JobRequestProjection
-
Get all the environment variables that were requested be added to the Job Runtime environment by the user.
- getRequestedId() - Method in interface com.netflix.genie.common.internal.dto.v4.CommonRequest
-
Get the ID the user has requested for this resource if one was added.
- getRequestedJobArchivalData() - Method in interface com.netflix.genie.common.internal.dto.v4.AgentJobRequest
-
Get the requested job archival agent configuration parameters.
- getRequestedJobArchivalData() - Method in interface com.netflix.genie.common.internal.dto.v4.ApiJobRequest
-
Get the requested job archival agent configuration parameters.
- getRequestedJobCpu() - Method in class com.netflix.genie.common.internal.dto.v4.AgentEnvironmentRequest
-
Get the number of CPU cores requested by the user for the job process.
- getRequestedJobDirectoryLocation() - Method in class com.netflix.genie.common.internal.dto.v4.AgentConfigRequest
-
Get the location where the Agent should place the job directory when it runs.
- getRequestedJobDirectoryLocation() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get the requested directory on disk where the Genie job working directory should be placed if a user asked to
override the default.
- getRequestedJobDirectoryLocation() - Method in interface com.netflix.genie.web.data.entities.projections.v4.V4JobRequestProjection
-
Get the requested directory on disk where the Genie job working directory should be placed if a user asked to
override the default.
- getRequestedJobMemory() - Method in class com.netflix.genie.common.internal.dto.v4.AgentEnvironmentRequest
-
Get the amount of memory requested by the user to launch the job process with.
- getRequestedMemory() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get the memory requested to run this job with.
- getRequestedMemory() - Method in interface com.netflix.genie.web.data.entities.projections.JobRequestProjection
-
Get the memory requested to run this job with.
- getRequestedMemory() - Method in interface com.netflix.genie.web.data.entities.projections.v4.V4JobRequestProjection
-
Get the memory requested to run this job with.
- getRequestedTimeout() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get the timeout (in seconds) requested by the user for this job.
- getRequestedTimeout() - Method in interface com.netflix.genie.web.data.entities.projections.JobRequestProjection
-
Get the timeout (in seconds) requested by the user for this job.
- getRequestedTimeout() - Method in interface com.netflix.genie.web.data.entities.projections.v4.V4JobRequestProjection
-
Get the timeout (in seconds) requested by the user for this job.
- getResolvableStatuses() - Static method in enum com.netflix.genie.common.dto.JobStatus
-
Get an unmodifiable set of all the statuses from which a job can be marked resolved.
- getResource(String, Path, URI) - Method in interface com.netflix.genie.web.services.AgentFileStreamService
-
Returns a Resource for the given job file boxed in an Optional
.
- getResources() - Method in interface com.netflix.genie.common.internal.dto.v4.CommonRequest
-
Get the resources the user requested for the job during execution if any.
- getRoleARN() - Method in class com.netflix.genie.common.internal.aws.s3.BucketProperties
-
Get the ARN of the role to assume from this instance when working with the given bucket.
- getRoot() - Method in class com.netflix.genie.web.controllers.RootRestController
-
Get a simple HAL+JSON object which represents the various links available in Genie REST API as an entry point.
- getRpcTimeout() - Method in interface com.netflix.genie.agent.cli.ArgumentDelegates.ServerArguments
-
- getRunningJobsCount() - Method in interface com.netflix.genie.web.data.entities.aggregates.UserJobResourcesAggregate
-
Get the number of running jobs for the user.
- getScheduleType() - Method in class com.netflix.genie.web.tasks.GenieTask
-
Get the type of scheduling mechanism which should be used to schedule this task.
- getScheduleType() - Method in class com.netflix.genie.web.tasks.job.JobMonitor
-
Get the type of scheduling mechanism which should be used to schedule this task.
- getScheduleType() - Method in class com.netflix.genie.web.tasks.leader.AgentJobCleanupTask
-
Get the type of scheduling mechanism which should be used to schedule this task.
- getScheduleType() - Method in class com.netflix.genie.web.tasks.leader.ClusterCheckerTask
-
Get the type of scheduling mechanism which should be used to schedule this task.
- getScheduleType() - Method in class com.netflix.genie.web.tasks.leader.DatabaseCleanupTask
-
Get the type of scheduling mechanism which should be used to schedule this task.
- getScheduleType() - Method in class com.netflix.genie.web.tasks.leader.UserMetricsTask
-
Get the type of scheduling mechanism which should be used to schedule this task.
- getServerHost() - Method in interface com.netflix.genie.agent.cli.ArgumentDelegates.ServerArguments
-
- getServerPort() - Method in interface com.netflix.genie.agent.cli.ArgumentDelegates.ServerArguments
-
- getSetupFile() - Method in class com.netflix.genie.common.dto.ExecutionEnvironmentDTO
-
Get the setup file.
- getSetupFile() - Method in class com.netflix.genie.common.internal.dto.v4.ExecutionEnvironment
-
Get the setup file location if there is one.
- getSetupFile() - Method in class com.netflix.genie.web.data.entities.BaseEntity
-
Get the setup file for this resource.
- getSetupFile() - Method in interface com.netflix.genie.web.data.entities.projections.SetupFileProjection
-
Get the setup file for this resource.
- getSetupFile() - Method in interface com.netflix.genie.web.data.entities.projections.v4.ExecutionResourceProjection
-
Get the setup file for this entity.
- getSetupFile() - Method in interface com.netflix.genie.web.data.entities.projections.v4.JobSpecificationProjection
-
Get the setup file for this resource.
- getSetupFile() - Method in interface com.netflix.genie.web.data.entities.projections.v4.V4JobRequestProjection
-
Get the setup file for this resource.
- getSourceFileUris() - Method in interface com.netflix.genie.agent.execution.services.DownloadService.Manifest
-
Get the set of URI s (source files) that were added to the manifest.
- getStarted() - Method in class com.netflix.genie.common.dto.Job
-
Get the time the job started.
- getStarted() - Method in class com.netflix.genie.common.dto.search.JobSearchResult
-
Get the time the job started.
- getStarted() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get when the job was started.
- getStarted() - Method in interface com.netflix.genie.web.data.entities.projections.JobProjection
-
Get when the job was started.
- getStarted() - Method in interface com.netflix.genie.web.data.entities.projections.JobSearchProjection
-
Get the time the job started if it has started.
- getStateActionErrors() - Method in interface com.netflix.genie.agent.execution.ExecutionContext
-
Get the list of state actions that failed during execution, if any.
- getStatic() - Method in class com.netflix.genie.web.properties.AwsCredentialsProperties.SpringCloudAwsRegionProperties
-
Get the region.
- getStatus() - Method in class com.netflix.genie.common.internal.dto.v4.Criterion
-
Get the desired status of the resource if it has been set by the creator.
- getStatus() - Method in class com.netflix.genie.web.data.entities.CriterionEntity
-
Get the status this criterion was using if there was one.
- getStatus() - Method in interface com.netflix.genie.web.data.entities.projections.JobStatusProjection
-
Get the job status.
- getStatusMsg() - Method in class com.netflix.genie.common.dto.Job
-
Get the current status message.
- getStatusMsg() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get the current status message of the job.
- getStatusMsg() - Method in interface com.netflix.genie.web.data.entities.projections.JobProjection
-
Get the current status message of the job.
- getStdErrSize() - Method in class com.netflix.genie.common.dto.JobMetadata
-
Get the size of standard error for this job.
- getStdErrSize() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get the size of standard error for this job.
- getStdErrSize() - Method in interface com.netflix.genie.web.data.entities.projections.JobMetadataProjection
-
Get the size of standard error for this job.
- getStdOutSize() - Method in class com.netflix.genie.common.dto.JobMetadata
-
Get the size of standard out for this job.
- getStdOutSize() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get the size of standard out for this job.
- getStdOutSize() - Method in interface com.netflix.genie.web.data.entities.projections.JobMetadataProjection
-
Get the size of standard out for this job.
- getTag(String) - Method in interface com.netflix.genie.web.data.services.jpa.JpaTagPersistenceService
-
Get a tag entity reference for the given tag string.
- getTag(String) - Method in class com.netflix.genie.web.data.services.jpa.JpaTagPersistenceServiceImpl
-
Get a tag entity reference for the given tag string.
- getTags() - Method in class com.netflix.genie.common.internal.dto.v4.CommonMetadata
-
Get the tags associated with this resource.
- getTags() - Method in class com.netflix.genie.common.internal.dto.v4.Criterion
-
Get the set of tags the creator desires the resource to have if any were set.
- getTags() - Method in interface com.netflix.genie.web.data.entities.projections.JobCommonFieldsProjection
-
Get the tags for the job.
- getTags() - Method in interface com.netflix.genie.web.data.entities.projections.v4.V4JobRequestProjection
-
Get the tags for the job.
- getTags(Set<String>) - Method in interface com.netflix.genie.web.data.services.jpa.JpaTagPersistenceService
-
Get all the tag entity references that match the input set of tag strings.
- getTags(Set<String>) - Method in class com.netflix.genie.web.data.services.jpa.JpaTagPersistenceServiceImpl
-
Get all the tag entity references that match the input set of tag strings.
- getTagsForApplication(String) - Method in interface com.netflix.genie.client.apis.ApplicationService
-
Method to get tags for a application in Genie.
- getTagsForApplication(String) - Method in class com.netflix.genie.client.ApplicationClient
-
Method to get all the tags for a application.
- getTagsForApplication(String) - Method in class com.netflix.genie.web.controllers.ApplicationRestController
-
Get all the tags for a given application.
- getTagsForApplication(String) - Method in class com.netflix.genie.web.data.services.jpa.JpaApplicationPersistenceServiceImpl
-
Get the set of tags associated with the application with given
id.
- getTagsForApplication(String) - Method in interface com.netflix.genie.web.services.ApplicationPersistenceService
-
Get the set of tags associated with the application with given
id.
- getTagsForCluster(String) - Method in interface com.netflix.genie.client.apis.ClusterService
-
Method to get tags for a cluster in Genie.
- getTagsForCluster(String) - Method in class com.netflix.genie.client.ClusterClient
-
Method to get all the tags for a cluster.
- getTagsForCluster(String) - Method in class com.netflix.genie.web.controllers.ClusterRestController
-
Get all the tags for a given cluster.
- getTagsForCluster(String) - Method in class com.netflix.genie.web.data.services.jpa.JpaClusterPersistenceServiceImpl
-
Get the set of tags associated with the cluster with given
id.
- getTagsForCluster(String) - Method in interface com.netflix.genie.web.services.ClusterPersistenceService
-
Get the set of tags associated with the cluster with given
id.
- getTagsForCommand(String) - Method in interface com.netflix.genie.client.apis.CommandService
-
Method to get tags for a command in Genie.
- getTagsForCommand(String) - Method in class com.netflix.genie.client.CommandClient
-
Method to get all the tags for a command.
- getTagsForCommand(String) - Method in class com.netflix.genie.web.controllers.CommandRestController
-
Get all the tags for a given command.
- getTagsForCommand(String) - Method in class com.netflix.genie.web.data.services.jpa.JpaCommandPersistenceServiceImpl
-
Get the set of tags associated with the command with given
id.
- getTagsForCommand(String) - Method in interface com.netflix.genie.web.services.CommandPersistenceService
-
Get the set of tags associated with the command with given
id.
- getTargetDirectories() - Method in interface com.netflix.genie.agent.execution.services.DownloadService.Manifest
-
Get the set of directories that contain all the target files.
- getTargetFiles() - Method in interface com.netflix.genie.agent.execution.services.DownloadService.Manifest
-
Get the set of files representing expected target location for files to be downloaded.
- getTargetLocation(URI) - Method in interface com.netflix.genie.agent.execution.services.DownloadService.Manifest
-
Return the target location for a given source URI.
- getTimeout() - Method in interface com.netflix.genie.agent.cli.ArgumentDelegates.JobRequestArguments
-
- getTimeout() - Method in class com.netflix.genie.common.dto.JobExecution
-
Get the timeout date for this job after which if it is still running the system will attempt to kill it.
- getTimeout() - Method in class com.netflix.genie.common.dto.JobRequest
-
Get the amount of time requested (in seconds) before this job is timed out on the server.
- getTimeout() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get the date this job will be killed due to exceeding its set timeout duration.
- getTimeout() - Method in interface com.netflix.genie.web.data.entities.projections.JobExecutionProjection
-
Get the date this job will be killed due to exceeding its set timeout duration.
- getTimeoutRequested() - Method in class com.netflix.genie.common.internal.dto.v4.AgentConfigRequest
-
Get the amount of time (in seconds) after the job starts that the agent should timeout and kill the job.
- getToken(String, Map<String, String>) - Method in interface com.netflix.genie.client.apis.TokenService
-
A method to retrieve oauth tokens from the server.
- getToken() - Method in class com.netflix.genie.client.security.oauth2.TokenFetcher
-
Method that returns the OAuth credentials.
- getTotalSizeOfAttachments() - Method in class com.netflix.genie.common.dto.JobMetadata
-
Get the total size of the attachments.
- getTotalSizeOfAttachments() - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Get the total size of the attachments.
- getTotalSizeOfAttachments() - Method in interface com.netflix.genie.web.data.entities.projections.JobMetadataProjection
-
Get the total size of the attachments.
- getTotalSizeOfFiles() - Method in class com.netflix.genie.common.internal.dto.DirectoryManifest
-
Get the total size of the files contained in this manifest.
- getTransferManager(AmazonS3URI) - Method in class com.netflix.genie.common.internal.aws.s3.S3ClientFactory
-
Get a TransferManager
instance for use with the given s3URI
.
- getTrigger() - Method in class com.netflix.genie.web.tasks.GenieTask
-
Get the Trigger which this task should be scheduled with.
- getTrigger() - Method in class com.netflix.genie.web.tasks.job.JobMonitor
-
Get the Trigger which this task should be scheduled with.
- getTrigger() - Method in class com.netflix.genie.web.tasks.leader.DatabaseCleanupTask
-
Get the Trigger which this task should be scheduled with.
- getType() - Method in class com.netflix.genie.common.dto.Application
-
Get the type of this application.
- getType() - Method in class com.netflix.genie.common.internal.dto.v4.ApplicationMetadata
-
Get the type of this application.
- getType() - Method in class com.netflix.genie.web.data.entities.ApplicationEntity
-
Get the type of this application.
- getUniqueId() - Method in class com.netflix.genie.web.data.entities.CriterionEntity
-
Get the unique id this criterion was using if there was one.
- getUniqueId() - Method in interface com.netflix.genie.web.data.entities.projections.JobExecutionProjection
-
Get the unique identifier of this job execution.
- getUniqueId() - Method in interface com.netflix.genie.web.data.entities.projections.JobMetadataProjection
-
Get the unique identifier of this job execution.
- getUniqueId() - Method in interface com.netflix.genie.web.data.entities.projections.JobSearchProjection
-
Get the unique identifier of the job.
- getUniqueId() - Method in interface com.netflix.genie.web.data.entities.projections.UniqueIdProjection
-
Get the unique identifier for this entity.
- getUniqueId() - Method in interface com.netflix.genie.web.data.entities.projections.v4.ExecutionResourceProjection
-
Get the unique identifier for this entity.
- getUniqueId() - Method in interface com.netflix.genie.web.data.entities.projections.v4.V4JobRequestProjection
-
Get the unique identifier for this entity.
- getUpdated() - Method in class com.netflix.genie.common.dto.BaseDTO
-
Get the update time.
- getUpdated() - Method in class com.netflix.genie.web.data.entities.AuditEntity
-
Get the time this entity was updated.
- getUpdated() - Method in interface com.netflix.genie.web.data.entities.projections.AuditProjection
-
Get when this entity was updated.
- getURI() - Method in class com.netflix.genie.web.resources.agent.AgentFileResourceImpl
- getURL() - Method in class com.netflix.genie.web.resources.agent.AgentFileResourceImpl
- getUsedMemory() - Method in interface com.netflix.genie.web.data.entities.aggregates.UserJobResourcesAggregate
-
Get the total amount of memory used by all running jobs for the user.
- getUsedMemory() - Method in class com.netflix.genie.web.services.impl.JobMetricsServiceImpl
-
Get the amount of memory currently used by jobs in MB.
- getUsedMemory() - Method in class com.netflix.genie.web.services.impl.JobStateServiceImpl
-
Get the amount of memory currently used by jobs in MB.
- getUsedMemory() - Method in interface com.netflix.genie.web.services.JobMetricsService
-
Get the amount of memory currently used by jobs in MB.
- getUser() - Method in interface com.netflix.genie.agent.cli.ArgumentDelegates.JobRequestArguments
-
- getUser() - Method in interface com.netflix.genie.web.data.entities.aggregates.UserJobResourcesAggregate
-
Get the user name.
- getUser() - Method in interface com.netflix.genie.web.data.entities.projections.BaseProjection
-
Get the user who created the resource.
- getUser() - Method in interface com.netflix.genie.web.data.entities.projections.JobSearchProjection
-
Get the user who ran or is running the job.
- getUser() - Method in interface com.netflix.genie.web.data.entities.projections.v4.V4JobRequestProjection
-
Get the user who created the resource.
- getUserAgent() - Method in class com.netflix.genie.common.dto.JobMetadata
-
Get the user agent.
- getUserAgent() - Method in class com.netflix.genie.common.internal.dto.v4.ApiClientMetadata
-
Get the user agent string for the client.
- getUserInfo(HttpServletRequest) - Method in class com.netflix.genie.ui.controllers.UserRestController
-
Get the information about the current session user.
- getUserJobResourcesAggregates() - Method in interface com.netflix.genie.web.data.repositories.jpa.JpaJobRepository
-
Returns resources usage for each user that has a running job.
- getUserLimit(String) - Method in class com.netflix.genie.web.properties.JobsActiveLimitProperties
-
Get the maximum number of jobs a user is allowed to run concurrently.
- getUserResourcesSummaries() - Method in class com.netflix.genie.web.data.services.jpa.JpaJobSearchServiceImpl
-
Get a map of summaries of resources usage for each user with at least one running job.
- getUserResourcesSummaries() - Method in interface com.netflix.genie.web.services.JobSearchService
-
Get a map of summaries of resources usage for each user with at least one running job.
- getVersion() - Method in class com.netflix.genie.common.internal.dto.v4.AgentClientMetadata
-
Get the running version of the agent if it was set.
- getVersion() - Method in class com.netflix.genie.common.internal.dto.v4.Criterion
-
Get the version of the resource desired if it exists.
- getVersion() - Method in class com.netflix.genie.web.data.entities.CriterionEntity
-
Get the version this criterion was using if there was one.
- getVersion() - Method in interface com.netflix.genie.web.data.entities.projections.BaseProjection
-
Get the version.
- getVersion() - Method in interface com.netflix.genie.web.data.entities.projections.v4.V4JobRequestProjection
-
Get the version.
- getWhitelistedVersions() - Method in class com.netflix.genie.web.properties.AgentFilterProperties
-
Get the (dynamic) property value containing a regular expression used to whitelist agent versions.
- globalAgentArguments() - Method in class com.netflix.genie.agent.cli.JCommanderAutoConfiguration
-
Provide a GlobalAgentArguments
bean.
- grouping - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- GROUPING - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- GROUPING_INSTANCE - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- groupingInstance - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- Groups() - Constructor for class com.netflix.genie.security.saml.SAMLProperties.Attributes.Groups
-
- GRpcAgentFileStreamServiceImpl - Class in com.netflix.genie.agent.execution.services.impl.grpc
-
- GRpcAgentJobKillServiceImpl - Class in com.netflix.genie.agent.execution.services.impl.grpc
-
- GRpcAgentJobKillServiceImpl(JobKillServiceGrpc.JobKillServiceFutureStub, KillService, TaskExecutor) - Constructor for class com.netflix.genie.agent.execution.services.impl.grpc.GRpcAgentJobKillServiceImpl
-
Constructor.
- GRpcAutoConfiguration - Class in com.netflix.genie.agent.rpc
-
Spring auto configuration for gRPC components.
- GRpcAutoConfiguration() - Constructor for class com.netflix.genie.agent.rpc.GRpcAutoConfiguration
-
- GRpcJobKillServiceImpl - Class in com.netflix.genie.web.rpc.grpc.services.impl.v4
-
Service to kill agent jobs.
- GRpcJobKillServiceImpl(JobSearchService) - Constructor for class com.netflix.genie.web.rpc.grpc.services.impl.v4.GRpcJobKillServiceImpl
-
Constructor.
- GRpcJobServiceImpl - Class in com.netflix.genie.web.rpc.grpc.services.impl.v4
-
Extension of JobServiceGrpc.JobServiceImplBase
to provide
functionality for resolving and fetching specifications for jobs to be run by the Genie Agent.
- GRpcJobServiceImpl(AgentJobService, JobServiceProtoConverter, JobServiceProtoErrorComposer) - Constructor for class com.netflix.genie.web.rpc.grpc.services.impl.v4.GRpcJobServiceImpl
-
Constructor.
- GRpcPingServiceImpl - Class in com.netflix.genie.web.rpc.grpc.services.impl.v4
-
Implementation of the Ping service definition.
- GRpcServerProperties - Class in com.netflix.genie.web.properties
-
Properties related to Genie's gRPC server functionality.
- GRpcServerProperties() - Constructor for class com.netflix.genie.web.properties.GRpcServerProperties
-
- GRpcServicesAutoConfiguration - Class in com.netflix.genie.agent.execution.services.impl.grpc
-
Spring auto configuration for the various gRPC services required for an agent to communicate with the Genie server.
- GRpcServicesAutoConfiguration() - Constructor for class com.netflix.genie.agent.execution.services.impl.grpc.GRpcServicesAutoConfiguration
-
- jCommander(GlobalAgentArguments, List<AgentCommandArguments>) - Method in class com.netflix.genie.agent.cli.JCommanderAutoConfiguration
-
Provide a JCommander
bean.
- JCommanderAutoConfiguration - Class in com.netflix.genie.agent.cli
-
Auto configuration for configuring JCommander
to parse CLI arguments of the Agent.
- JCommanderAutoConfiguration() - Constructor for class com.netflix.genie.agent.cli.JCommanderAutoConfiguration
-
- Job - Class in com.netflix.genie.common.dto
-
Read only data transfer object representing a Job in the Genie system.
- Job(Job.Builder) - Constructor for class com.netflix.genie.common.dto.Job
-
Constructor used by the builder.
- Job.Builder - Class in com.netflix.genie.common.dto
-
A builder to create jobs.
- JOB_DIRECTORY_LOCATION - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- JOB_EXCEEDED_STDERR_LENGTH - Static variable in class com.netflix.genie.common.dto.JobStatusMessages
-
Job killed because maximum stderr length was exceeded.
- JOB_EXCEEDED_STDOUT_LENGTH - Static variable in class com.netflix.genie.common.dto.JobStatusMessages
-
Job killed because maximum stdout length was exceeded.
- JOB_EXCEEDED_TIMEOUT - Static variable in class com.netflix.genie.common.dto.JobStatusMessages
-
Job killed because maximum run time was exceeded.
- JOB_EXECUTION_DTO_KEY - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
Key used for look up of Job Execution DTO in a Context Map for workflows.
- JOB_EXECUTION_ENV_KEY - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
Key used for look up of Job Execution environment object in a Context Map for workflows.
- JOB_FAILED - Static variable in class com.netflix.genie.common.dto.JobStatusMessages
-
Job terminated with non-zero exit code.
- JOB_FAILURE_AND_KILL_HANDLER_LOGIC - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
An object the encapsulates the kill handling logic to be added to the for each job.
- JOB_FINISHED_SUCCESSFULLY - Static variable in class com.netflix.genie.common.dto.JobStatusMessages
-
Job completed successfully.
- JOB_ID - Static variable in class com.netflix.genie.web.data.entities.AgentConnectionEntity_
-
- JOB_KILLED_BY_USER - Static variable in class com.netflix.genie.common.dto.JobStatusMessages
-
Job killed by user.
- JOB_PROCESS_NOT_FOUND - Static variable in class com.netflix.genie.common.dto.JobStatusMessages
-
Job killed, could not check on the process.
- jobAgentLogFilePath(File) - Static method in class com.netflix.genie.agent.utils.PathUtils
-
Compose the path to the agent log file for a job (after it has been relocated inside the job directory).
- jobApplicationDirectoryPath(File, String) - Static method in class com.netflix.genie.agent.utils.PathUtils
-
Compose the path to an application directory inside a job directory.
- jobApplicationsDirectoryPath(File) - Static method in class com.netflix.genie.agent.utils.PathUtils
-
Compose the path to the applications directory inside a job directory.
- JobApplicationsProjection - Interface in com.netflix.genie.web.data.entities.projections
-
Projection to return just the applications associated with a given job.
- JobArchivalDataRequest - Class in com.netflix.genie.common.internal.dto.v4
-
Job archival options for the Genie agent.
- JobArchivalDataRequest.Builder - Class in com.netflix.genie.common.internal.dto.v4
-
- JobArchiveException - Exception in com.netflix.genie.common.internal.exceptions
-
Exception thrown in case there is a problem with archiving files.
- JobArchiveException(String) - Constructor for exception com.netflix.genie.common.internal.exceptions.JobArchiveException
-
Constructor with message.
- JobArchiveException(String, Throwable) - Constructor for exception com.netflix.genie.common.internal.exceptions.JobArchiveException
-
Constructor with message and cause.
- JobArchiveLocationProjection - Interface in com.netflix.genie.web.data.entities.projections
-
A projection which only returns the archive location for a job.
- JobArchiver - Interface in com.netflix.genie.common.internal.services
-
Implementations of this interface should be able to a write job files to a WritableResource
root location.
- jobArchiveService(List<JobArchiver>, DirectoryManifest.Factory) - Method in class com.netflix.genie.common.internal.configs.CommonServicesAutoConfiguration
-
- JobArchiveService - Interface in com.netflix.genie.common.internal.services
-
A service which is responsible for taking the files related to running a Genie job and backing them up to a different
location.
- JobArchiveServiceImpl - Class in com.netflix.genie.common.internal.services.impl
-
- JobArchiveServiceImpl(List<JobArchiver>, DirectoryManifest.Factory) - Constructor for class com.netflix.genie.common.internal.services.impl.JobArchiveServiceImpl
-
Constructor.
- jobClient(ManagedChannel) - Method in class com.netflix.genie.agent.rpc.GRpcAutoConfiguration
-
Provide a prototype bean definition for a
JobServiceGrpc.JobServiceFutureStub
.
- JobClient - Class in com.netflix.genie.client
-
Client library for the Job Service.
- JobClient(Retrofit, int) - Constructor for class com.netflix.genie.client.JobClient
-
Constructor.
- JobClient(String, List<Interceptor>, GenieNetworkConfiguration) - Constructor for class com.netflix.genie.client.JobClient
-
- jobClusterDirectoryPath(File, String) - Static method in class com.netflix.genie.agent.utils.PathUtils
-
Compose the path to the cluster directory inside a job directory.
- JobClusterProjection - Interface in com.netflix.genie.web.data.entities.projections
-
Projection to return just the cluster for a given job.
- jobCommandDirectoryPath(File, String) - Static method in class com.netflix.genie.agent.utils.PathUtils
-
Compose the path to the command directory inside a job directory.
- JobCommandProjection - Interface in com.netflix.genie.web.data.entities.projections
-
Projection to return just the command for a given job.
- JobCommonFieldsProjection - Interface in com.netflix.genie.web.data.entities.projections
-
Projection for common fields between pre 3.3.0 JobRequest and Job entities.
- JobCompletionHandler - Class in com.netflix.genie.web.tasks.job
-
Handles the job finished event.
- JobCompletionHandler(JobCompletionService) - Constructor for class com.netflix.genie.web.tasks.job.JobCompletionHandler
-
Constructor.
- jobCompletionService(JobPersistenceService, JobSearchService, JobArchiveService, Resource, MailService, MeterRegistry, JobsProperties, RetryTemplate) - Method in class com.netflix.genie.web.configs.GenieServicesAutoConfiguration
-
- JobCompletionService - Class in com.netflix.genie.web.tasks.job
-
A class that has the methods to perform various tasks when a job completes.
- JobCompletionService(JobPersistenceService, JobSearchService, JobArchiveService, Resource, MailService, MeterRegistry, JobsProperties, RetryTemplate) - Constructor for class com.netflix.genie.web.tasks.job.JobCompletionService
-
Constructor.
- JobConstants - Class in com.netflix.genie.common.internal.jobs
-
A class holding some constants to be used everywhere.
- JobConstants() - Constructor for class com.netflix.genie.common.internal.jobs.JobConstants
-
Protected constructor for utility class.
- jobCoordinatorService(JobPersistenceService, JobKillService, JobStateService, JobSearchService, JobsProperties, ApplicationPersistenceService, ClusterPersistenceService, CommandPersistenceService, JobSpecificationService, MeterRegistry, GenieHostInfo) - Method in class com.netflix.genie.web.configs.GenieServicesAutoConfiguration
-
Get an instance of the JobCoordinatorService.
- JobCoordinatorService - Interface in com.netflix.genie.web.services
-
Job Coordination APIs.
- JobCoordinatorServiceImpl - Class in com.netflix.genie.web.services.impl
-
Implementation of the JobCoordinatorService APIs.
- JobCoordinatorServiceImpl(JobPersistenceService, JobKillService, JobStateService, JobsProperties, ApplicationPersistenceService, JobSearchService, ClusterPersistenceService, CommandPersistenceService, JobSpecificationService, MeterRegistry, String) - Constructor for class com.netflix.genie.web.services.impl.JobCoordinatorServiceImpl
-
Constructor.
- jobDirectoryLocation - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- jobDirectoryManifestCache() - Method in class com.netflix.genie.common.internal.configs.CommonServicesAutoConfiguration
-
Provide a Cache<Path, DirectoryManifest>
named "jobDirectoryManifestCache" if no override is defined.
- jobDirectoryManifestProtoConverter() - Method in class com.netflix.genie.common.internal.configs.ProtoConvertersAutoConfiguration
-
Provide a bean for proto conversion of agent job directory manifest objects if one isn't already defined.
- JobDirectoryManifestProtoConverter - Class in com.netflix.genie.common.internal.dto.v4.converters
-
Converts
DirectoryManifest
from/to
AgentManifestMessage
in order to transport manifests
over gRPC.
- JobDirectoryManifestProtoConverter(ObjectMapper) - Constructor for class com.netflix.genie.common.internal.dto.v4.converters.JobDirectoryManifestProtoConverter
-
Constructor.
- jobDirectoryManifestService(DirectoryManifest.Factory, Cache<Path, DirectoryManifest>) - Method in class com.netflix.genie.common.internal.configs.CommonServicesAutoConfiguration
-
- JobDirectoryManifestService - Interface in com.netflix.genie.common.internal.services
-
- JobDirectoryManifestServiceImpl - Class in com.netflix.genie.common.internal.services.impl
-
Implementation of
JobDirectoryManifestService
that caches manifests produced by the factory for a few
seconds, thus avoiding re-calculating the same for subsequent requests (e.g.
- JobDirectoryManifestServiceImpl(DirectoryManifest.Factory, Cache<Path, DirectoryManifest>, boolean) - Constructor for class com.netflix.genie.common.internal.services.impl.JobDirectoryManifestServiceImpl
-
Constructor.
- jobDirectoryServerService(ResourceLoader, JobPersistenceService, JobFileService, AgentFileStreamService, MeterRegistry, JobDirectoryManifestService) - Method in class com.netflix.genie.web.configs.GenieServicesAutoConfiguration
-
- JobDirectoryServerService - Interface in com.netflix.genie.web.services
-
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 - Class in com.netflix.genie.web.services.impl
-
- JobDirectoryServerServiceImpl(ResourceLoader, JobPersistenceService, JobFileService, AgentFileStreamService, MeterRegistry, JobDirectoryManifestService) - Constructor for class com.netflix.genie.web.services.impl.JobDirectoryServerServiceImpl
-
Constructor.
- JobDoneFile - Class in com.netflix.genie.web.jobs
-
Class that represents the structure of the genie.done file created when a job is done.
- JobDoneFile() - Constructor for class com.netflix.genie.web.jobs.JobDoneFile
-
- JobEntity - Class in com.netflix.genie.web.data.entities
-
A row in jobs table.
- JobEntity() - Constructor for class com.netflix.genie.web.data.entities.JobEntity
-
Default Constructor.
- JobEntity_ - Class in com.netflix.genie.web.data.entities
-
- JobEntity_() - Constructor for class com.netflix.genie.web.data.entities.JobEntity_
-
- jobEntityConfigPath(Path) - Static method in class com.netflix.genie.agent.utils.PathUtils
-
Compose the path to the configurations directory for a given entity.
- jobEntityDependenciesPath(Path) - Static method in class com.netflix.genie.agent.utils.PathUtils
-
Compose the path to the dependencies directory for a given entity.
- JobExecution - Class in com.netflix.genie.common.dto
-
All information needed to show state of a running job.
- JobExecution(JobExecution.Builder) - Constructor for class com.netflix.genie.common.dto.JobExecution
-
Constructor used by the builder build() method.
- JobExecution.Builder - Class in com.netflix.genie.common.dto
-
A builder to create job requests.
- JobExecutionEnvironment - Class in com.netflix.genie.web.jobs
-
Encapsulates the details of the job, cluster , command and applications needed to run a job.
- JobExecutionEnvironment.Builder - Class in com.netflix.genie.web.jobs
-
A builder to create Job Execution Environment objects.
- JobExecutionListener - Interface in com.netflix.genie.agent.execution.statemachine.listeners
-
Interface for StateMachineListener for JobExecutionStateMachine.
- JobExecutionProjection - Interface in com.netflix.genie.web.data.entities.projections
-
Projection with the data present in a Genie JobExecutionEntity from pre-3.3.0.
- JobExecutionResource - Class in com.netflix.genie.web.hateoas.resources
-
HATEOAS resource representation of a Job Execution.
- JobExecutionResource(JobExecution) - Constructor for class com.netflix.genie.web.hateoas.resources.JobExecutionResource
-
Constructor.
- JobExecutionResourceAssembler - Class in com.netflix.genie.web.hateoas.assemblers
-
Assembles Job Request resources out of JobRequest DTOs.
- JobExecutionResourceAssembler() - Constructor for class com.netflix.genie.web.hateoas.assemblers.JobExecutionResourceAssembler
-
- JobExecutionStateMachine - Interface in com.netflix.genie.agent.execution.statemachine
-
Interface JobExecutionStateMachine.
- jobExecutionStateMachine(StateMachine<States, Events>) - Method in class com.netflix.genie.agent.execution.statemachine.StateMachineAutoConfiguration
-
- jobExists(String) - Method in class com.netflix.genie.web.services.impl.JobStateServiceImpl
-
Returns true if the job exists locally.
- jobExists(String) - Method in interface com.netflix.genie.web.services.JobStateService
-
Returns true if the job exists locally.
- JobFailureAndKillHandlerLogicTask - Class in com.netflix.genie.web.jobs.workflow.impl
-
This class is responsible for adding the kill handling logic to run.sh.
- JobFailureAndKillHandlerLogicTask(MeterRegistry) - Constructor for class com.netflix.genie.web.jobs.workflow.impl.JobFailureAndKillHandlerLogicTask
-
Constructor.
- jobFileService(Resource) - Method in class com.netflix.genie.web.configs.GenieServicesAutoConfiguration
-
- JobFileService - Interface in com.netflix.genie.web.services
-
A service for dealing with the files associated with a job run via Genie.
- JobFileState - Class in com.netflix.genie.common.internal.dto.v4.files
-
Representation of the metadata for a job file on a given underlying storage system.
- JobFileState(String, long, String) - Constructor for class com.netflix.genie.common.internal.dto.v4.files.JobFileState
-
Constructor.
- JobFinishedEvent - Class in com.netflix.genie.web.events
-
An event thrown when a job is completed.
- JobFinishedEvent(String, JobFinishedReason, String, Object) - Constructor for class com.netflix.genie.web.events.JobFinishedEvent
-
Constructor.
- JobFinishedReason - Enum in com.netflix.genie.web.events
-
An enumeration representing the various reasons a JobFinishedEvent would be sent.
- jobGenieDirectoryPath(File) - Static method in class com.netflix.genie.agent.utils.PathUtils
-
Compose the path to the genie directory inside a job directory.
- jobGenieLogsDirectoryPath(File) - Static method in class com.netflix.genie.agent.utils.PathUtils
-
Compose the path to the genie logs directory inside a job directory.
- jobId - Static variable in class com.netflix.genie.web.data.entities.AgentConnectionEntity_
-
- JobIdUnavailableException - Exception in com.netflix.genie.agent.execution.exceptions
-
Exception thrown by AgentJobService when trying to reserve an ID that has already been used.
- JobIdUnavailableException(String) - Constructor for exception com.netflix.genie.agent.execution.exceptions.JobIdUnavailableException
-
Constructor with message.
- JobIdUnavailableException(String, Throwable) - Constructor for exception com.netflix.genie.agent.execution.exceptions.JobIdUnavailableException
-
Constructor with message and cause.
- jobKickoffTask(JobsProperties, Executor, GenieHostInfo, MeterRegistry) - Method in class com.netflix.genie.web.configs.GenieJobWorkflowAutoConfiguration
-
Create an Job Kickoff Task bean that runs the job.
- JobKickoffTask - Class in com.netflix.genie.web.jobs.workflow.impl
-
Implementation of the workflow task for processing job information for genie mode.
- JobKickoffTask(boolean, boolean, Executor, String, MeterRegistry) - Constructor for class com.netflix.genie.web.jobs.workflow.impl.JobKickoffTask
-
Constructor.
- jobKillClient(ManagedChannel) - Method in class com.netflix.genie.agent.rpc.GRpcAutoConfiguration
-
Provide a prototype bean definition for a
JobKillServiceGrpc.JobKillServiceFutureStub
.
- jobKillLogicTask(MeterRegistry) - Method in class com.netflix.genie.web.configs.GenieJobWorkflowAutoConfiguration
-
Create a task that adds logic to handle kill requests to a job.
- JobKillReasonFile - Class in com.netflix.genie.web.jobs
-
Class that represents the structure of the kill-reason file created when a job is killed.
- JobKillReasonFile(String) - Constructor for class com.netflix.genie.web.jobs.JobKillReasonFile
-
Constructor, annotated for Jackson.
- jobKillService(JobKillServiceV3, JobKillServiceV4, JobPersistenceService) - Method in class com.netflix.genie.web.configs.GenieServicesAutoConfiguration
-
Get an local implementation of the JobKillService.
- JobKillService - Interface in com.netflix.genie.web.services
-
Interface for services to kill jobs.
- JobKillServiceImpl - Class in com.netflix.genie.web.services.impl
-
Implementation of the JobKillService interface.
- JobKillServiceImpl(JobKillServiceV3, JobKillServiceV4, JobPersistenceService) - Constructor for class com.netflix.genie.web.services.impl.JobKillServiceImpl
-
Constructor.
- jobKillServiceV3(GenieHostInfo, JobSearchService, Executor, JobsProperties, GenieEventBus, Resource, ObjectMapper, ProcessChecker.Factory) - Method in class com.netflix.genie.web.configs.GenieServicesAutoConfiguration
-
Get an local implementation of the JobKillService.
- JobKillServiceV3 - Class in com.netflix.genie.web.services.impl
-
A JobKillService that attempts to kill genie 3.0 jobs running on the local node.
- JobKillServiceV3(String, JobSearchService, Executor, boolean, GenieEventBus, Resource, ObjectMapper, ProcessChecker.Factory) - Constructor for class com.netflix.genie.web.services.impl.JobKillServiceV3
-
Constructor.
- JobKillServiceV4 - Interface in com.netflix.genie.web.services
-
Interface for services to kill V4 jobs.
- JobLauncher - Class in com.netflix.genie.web.jobs
-
Class to wrap launching a job in an asynchronous thread from the HTTP request thread to free up the system to
respond to the user.
- JobLauncher(JobSubmitterService, JobRequest, Cluster, Command, List<Application>, int, MeterRegistry) - Constructor for class com.netflix.genie.web.jobs.JobLauncher
-
Constructor.
- JobLaunchException - Exception in com.netflix.genie.agent.execution.exceptions
-
Exception during job launch.
- JobLaunchException(String) - Constructor for exception com.netflix.genie.agent.execution.exceptions.JobLaunchException
-
Construct with message.
- JobLaunchException(String, Throwable) - Constructor for exception com.netflix.genie.agent.execution.exceptions.JobLaunchException
-
Construct with message and cause.
- JobMetadata - Class in com.netflix.genie.common.dto
-
Additional metadata associated with a Job Request such as client host, user agent, etc.
- JobMetadata(JobMetadata.Builder) - Constructor for class com.netflix.genie.common.dto.JobMetadata
-
Constructor used only through the builder.
- JobMetadata - Class in com.netflix.genie.common.internal.dto.v4
-
Metadata supplied by a user for a job.
- JobMetadata.Builder - Class in com.netflix.genie.common.dto
-
Builder for creating a JobMetadata instance.
- JobMetadata.Builder - Class in com.netflix.genie.common.internal.dto.v4
-
A builder to create job user metadata instances.
- JobMetadataProjection - Interface in com.netflix.genie.web.data.entities.projections
-
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.
- JobMetadataResource - Class in com.netflix.genie.web.hateoas.resources
-
HATEOAS resource representation of a Job Metadata object.
- JobMetadataResource(JobMetadata) - Constructor for class com.netflix.genie.web.hateoas.resources.JobMetadataResource
-
Constructor.
- JobMetadataResourceAssembler - Class in com.netflix.genie.web.hateoas.assemblers
-
Assembles Job Request resources out of JobRequest DTOs.
- JobMetadataResourceAssembler() - Constructor for class com.netflix.genie.web.hateoas.assemblers.JobMetadataResourceAssembler
-
- JobMetricsService - Interface in com.netflix.genie.web.services
-
A service which returns metrics for active jobs.
- JobMetricsServiceImpl - Class in com.netflix.genie.web.services.impl
-
A default implementation of the job count service which uses the job search service to find the running jobs on
the host.
- JobMetricsServiceImpl(JobSearchService, String) - Constructor for class com.netflix.genie.web.services.impl.JobMetricsServiceImpl
-
Constructor.
- JobMonitor - Class in com.netflix.genie.web.tasks.job
-
Given a process id this class will check if the job client process is running or not.
- JobMonitoringCoordinator - Class in com.netflix.genie.web.tasks.job
-
A Task to monitor running jobs on a Genie node.
- JobMonitoringCoordinator(GenieHostInfo, JobSearchService, GenieEventBus, TaskScheduler, MeterRegistry, Resource, JobsProperties, JobSubmitterService, ProcessChecker.Factory) - Constructor for class com.netflix.genie.web.tasks.job.JobMonitoringCoordinator
-
Constructor.
- jobPersistenceService(JpaTagPersistenceService, JpaFilePersistenceService, JpaApplicationRepository, JpaClusterRepository, JpaCommandRepository, JpaJobRepository) - Method in class com.netflix.genie.web.configs.GenieJpaAutoConfiguration
-
- JobPersistenceService - Interface in com.netflix.genie.web.services
-
Interfaces for providing persistence functions for jobs other than search.
- jobProcessorTask(AttachmentService, MeterRegistry, GenieFileTransferService) - Method in class com.netflix.genie.web.configs.GenieJobWorkflowAutoConfiguration
-
Create an Job Task bean that processes Job information provided by user.
- JobProjection - Interface in com.netflix.genie.web.data.entities.projections
-
Projection for the fields originally available in pre-3.3.0 JobEntity classes.
- JobRequest - Class in com.netflix.genie.common.dto
-
All information needed to make a request to run a new job.
- JobRequest - Class in com.netflix.genie.common.internal.dto.v4
-
All details a user will provide to Genie in order to run a job.
- JobRequest(String, ExecutionEnvironment, List<String>, JobMetadata, ExecutionResourceCriteria, AgentEnvironmentRequest, AgentConfigRequest, JobArchivalDataRequest) - Constructor for class com.netflix.genie.common.internal.dto.v4.JobRequest
-
Constructor.
- JobRequest.Builder - Class in com.netflix.genie.common.dto
-
A builder to create job requests.
- jobRequestArguments(MainCommandArguments) - Method in class com.netflix.genie.agent.cli.CliAutoConfiguration
-
- jobRequestConverter(Validator) - Method in class com.netflix.genie.agent.cli.CliAutoConfiguration
-
- JobRequestConverter - Class in com.netflix.genie.agent.cli
-
Convert job request arguments delegate into an AgentJobRequest.
- JobRequestConverter.ConversionException - Exception in com.netflix.genie.agent.cli
-
Exception thrown in case of conversion error due to resulting object failing validation.
- JobRequestMetadata - Class in com.netflix.genie.common.internal.dto.v4
-
Metadata gathered by the system as part of any
JobRequest
.
- JobRequestMetadata(ApiClientMetadata, AgentClientMetadata, int, long) - Constructor for class com.netflix.genie.common.internal.dto.v4.JobRequestMetadata
-
Constructor.
- JobRequestProjection - Interface in com.netflix.genie.web.data.entities.projections
-
Projection to reproduce the JobRequest entity fields which were was a table present before 3.3.0.
- JobRequestResource - Class in com.netflix.genie.web.hateoas.resources
-
HATEOAS resource representation of a Job Request.
- JobRequestResource(JobRequest) - Constructor for class com.netflix.genie.web.hateoas.resources.JobRequestResource
-
Constructor.
- JobRequestResourceAssembler - Class in com.netflix.genie.web.hateoas.assemblers
-
Assembles Job Request resources out of JobRequest DTOs.
- JobRequestResourceAssembler() - Constructor for class com.netflix.genie.web.hateoas.assemblers.JobRequestResourceAssembler
-
- JobReservationException - Exception in com.netflix.genie.agent.execution.exceptions
-
Failure to reserve a job id for reasons other than the specified job id being already used.
- JobReservationException(String) - Constructor for exception com.netflix.genie.agent.execution.exceptions.JobReservationException
-
Constructor with message.
- JobReservationException(String, Throwable) - Constructor for exception com.netflix.genie.agent.execution.exceptions.JobReservationException
-
Constructor with message and cause.
- JobResource - Class in com.netflix.genie.web.hateoas.resources
-
HATEOAS resource representation of a Job.
- JobResource(Job) - Constructor for class com.netflix.genie.web.hateoas.resources.JobResource
-
Constructor.
- JobResourceAssembler - Class in com.netflix.genie.web.hateoas.assemblers
-
Assembles Job resources out of job DTOs.
- JobResourceAssembler() - Constructor for class com.netflix.genie.web.hateoas.assemblers.JobResourceAssembler
-
- JobRestController - Class in com.netflix.genie.web.controllers
-
REST end-point for supporting jobs.
- JobRestController(JobCoordinatorService, JobSearchService, AttachmentService, ApplicationResourceAssembler, ClusterResourceAssembler, CommandResourceAssembler, JobResourceAssembler, JobRequestResourceAssembler, JobExecutionResourceAssembler, JobMetadataResourceAssembler, JobSearchResultResourceAssembler, GenieHostInfo, RestTemplate, JobDirectoryServerService, JobsProperties, MeterRegistry, JobPersistenceService, AgentRoutingService) - Constructor for class com.netflix.genie.web.controllers.JobRestController
-
Constructor.
- JOBS_URL_SUFFIX - Static variable in interface com.netflix.genie.client.apis.JobService
-
Path to Jobs.
- JOBS_USER_LIMIT - Static variable in class com.netflix.genie.web.util.MetricsConstants.TagKeys
-
Key to tag the user concurrent job limit.
- JobsActiveLimitProperties - Class in com.netflix.genie.web.properties
-
Properties related to number of active jobs per user.
- JobsActiveLimitProperties() - Constructor for class com.netflix.genie.web.properties.JobsActiveLimitProperties
-
- JobScheduledEvent - Class in com.netflix.genie.web.events
-
Event when a job is scheduled to be executed.
- JobScheduledEvent(String, Future<?>, int, Object) - Constructor for class com.netflix.genie.web.events.JobScheduledEvent
-
Constructor.
- JobsCleanupProperties - Class in com.netflix.genie.web.properties
-
Properties related to cleanup for jobs.
- JobsCleanupProperties() - Constructor for class com.netflix.genie.web.properties.JobsCleanupProperties
-
- jobsDir() - Method in class com.netflix.genie.test.web.configs.IntegrationTestingConfiguration
-
Returns a temporary directory as the jobs resource.
- jobsDir(ResourceLoader, JobsProperties) - Method in class com.netflix.genie.web.configs.GenieApiAutoConfiguration
-
Get the jobs dir as a Spring Resource.
- JobSearchProjection - Interface in com.netflix.genie.web.data.entities.projections
-
Projection to return only the fields desired for a job with search results.
- JobSearchResult - Class in com.netflix.genie.common.dto.search
-
This class represents the subset of data returned from a Job when a search for Jobs is conducted.
- JobSearchResult(String, String, String, JobStatus, Instant, Instant, String, String) - Constructor for class com.netflix.genie.common.dto.search.JobSearchResult
-
Constructor.
- JobSearchResultResource - Class in com.netflix.genie.web.hateoas.resources
-
HATEOAS resource representation of a Job.
- JobSearchResultResource(JobSearchResult) - Constructor for class com.netflix.genie.web.hateoas.resources.JobSearchResultResource
-
Constructor.
- JobSearchResultResourceAssembler - Class in com.netflix.genie.web.hateoas.assemblers
-
Assembles Job resources out of job search result DTOs.
- JobSearchResultResourceAssembler() - Constructor for class com.netflix.genie.web.hateoas.assemblers.JobSearchResultResourceAssembler
-
- jobSearchService(JpaJobRepository, JpaClusterRepository, JpaCommandRepository) - Method in class com.netflix.genie.web.configs.GenieJpaAutoConfiguration
-
- JobSearchService - Interface in com.netflix.genie.web.services
-
Interface for searching jobs.
- JobService - Interface in com.netflix.genie.client.apis
-
An interface that provides all methods needed for the Genie job client implementation.
- jobServiceProtoConverter() - Method in class com.netflix.genie.common.internal.configs.ProtoConvertersAutoConfiguration
-
Provide a bean for proto conversion of job service objects if one isn't already defined.
- JobServiceProtoConverter - Class in com.netflix.genie.common.internal.dto.v4.converters
-
Converter of proto messages for the JobServiceGrpc.JobServiceImplBase
service to
and from V4 DTO POJO's.
- JobServiceProtoConverter() - Constructor for class com.netflix.genie.common.internal.dto.v4.converters.JobServiceProtoConverter
-
- JobsForwardingProperties - Class in com.netflix.genie.web.properties
-
Properties related to job forwarding.
- JobsForwardingProperties() - Constructor for class com.netflix.genie.web.properties.JobsForwardingProperties
-
- JobsLocationsProperties - Class in com.netflix.genie.web.properties
-
Properties for various job related locations.
- JobsLocationsProperties() - Constructor for class com.netflix.genie.web.properties.JobsLocationsProperties
-
- JobsMaxProperties - Class in com.netflix.genie.web.properties
-
Properties related to maximum values allowed for various components of running jobs.
- JobsMaxProperties() - Constructor for class com.netflix.genie.web.properties.JobsMaxProperties
-
- JobsMemoryProperties - Class in com.netflix.genie.web.properties
-
Properties pertaining to how much memory jobs can use on Genie.
- JobsMemoryProperties() - Constructor for class com.netflix.genie.web.properties.JobsMemoryProperties
-
- JobSpecification - Class in com.netflix.genie.common.internal.dto.v4
-
This DTO represents all the information needed to execute a job by the Genie Agent.
- JobSpecification(List<String>, JobSpecification.ExecutionResource, JobSpecification.ExecutionResource, JobSpecification.ExecutionResource, List<JobSpecification.ExecutionResource>, Map<String, String>, boolean, File, String) - Constructor for class com.netflix.genie.common.internal.dto.v4.JobSpecification
-
Constructor.
- JobSpecification.ExecutionResource - Class in com.netflix.genie.common.internal.dto.v4
-
Common representation of resources used for job execution e.g.
- JobSpecificationProjection - Interface in com.netflix.genie.web.data.entities.projections.v4
-
Projection of the database fields which make up the required elements of a job specification.
- JobSpecificationResolutionException - Exception in com.netflix.genie.agent.execution.exceptions
-
Exception thrown by AgentJobService.
- JobSpecificationResolutionException(String) - Constructor for exception com.netflix.genie.agent.execution.exceptions.JobSpecificationResolutionException
-
Constructor with message.
- JobSpecificationResolutionException(String, Throwable) - Constructor for exception com.netflix.genie.agent.execution.exceptions.JobSpecificationResolutionException
-
Constructor with message and cause.
- jobSpecificationService(ApplicationPersistenceService, ClusterPersistenceService, CommandPersistenceService, List<ClusterLoadBalancer>, MeterRegistry, JobsProperties) - Method in class com.netflix.genie.web.configs.GenieServicesAutoConfiguration
-
- JobSpecificationService - Interface in com.netflix.genie.web.services
-
Service API definition and helper methods for working with Genie Job Specifications to be used by the Agent.
- JobSpecificationServiceImpl - Class in com.netflix.genie.web.services.impl
-
Implementation of the JobSpecificationService APIs.
- JobSpecificationServiceImpl(ApplicationPersistenceService, ClusterPersistenceService, CommandPersistenceService, List<ClusterLoadBalancer>, MeterRegistry, JobsProperties) - Constructor for class com.netflix.genie.web.services.impl.JobSpecificationServiceImpl
-
Constructor.
- jobsProperties(JobsCleanupProperties, JobsForwardingProperties, JobsLocationsProperties, JobsMaxProperties, JobsMemoryProperties, JobsUsersProperties, ExponentialBackOffTriggerProperties, JobsActiveLimitProperties) - Method in class com.netflix.genie.web.configs.GenieServicesAutoConfiguration
-
Collection of properties related to job execution.
- JobsProperties - Class in com.netflix.genie.web.properties
-
All properties related to jobs in Genie.
- JobsProperties(JobsCleanupProperties, JobsForwardingProperties, JobsLocationsProperties, JobsMaxProperties, JobsMemoryProperties, JobsUsersProperties, ExponentialBackOffTriggerProperties, JobsActiveLimitProperties) - Constructor for class com.netflix.genie.web.properties.JobsProperties
-
Constructor.
- JobStartedEvent - Class in com.netflix.genie.web.events
-
An event fired when a new job is started on a node.
- JobStartedEvent(JobExecution, Object) - Constructor for class com.netflix.genie.web.events.JobStartedEvent
-
Constructor.
- JobStateService - Interface in com.netflix.genie.web.services
-
A service which defines the three basic stages of a job.
- JobStateServiceImpl - Class in com.netflix.genie.web.services.impl
-
A Service to monitor the state of locally run jobs.
- JobStateServiceImpl(JobSubmitterService, TaskScheduler, GenieEventBus, MeterRegistry) - Constructor for class com.netflix.genie.web.services.impl.JobStateServiceImpl
-
Constructor.
- JobStatus - Enum in com.netflix.genie.common.dto
-
Possible statuses for a Job.
- JobStatusMessages - Class in com.netflix.genie.common.dto
-
Constant strings for status message attached to a job after it terminates.
- JobStatusProjection - Interface in com.netflix.genie.web.data.entities.projections
-
Projection for returning only the status of a given job.
- jobStdErrPath(File) - Static method in class com.netflix.genie.agent.utils.PathUtils
-
Compose the path to the standard error log file for a job.
- jobStdOutPath(File) - Static method in class com.netflix.genie.agent.utils.PathUtils
-
Compose the path to the standard output log file for a job.
- jobSubmitterService(JobPersistenceService, GenieEventBus, List<WorkflowTask>, Resource, MeterRegistry) - Method in class com.netflix.genie.web.configs.GenieServicesAutoConfiguration
-
Get a implementation of the JobSubmitterService that runs jobs locally.
- JobSubmitterService - Interface in com.netflix.genie.web.services
-
Interface to hand off job execution based on different environments.
- JobsUsersProperties - Class in com.netflix.genie.web.properties
-
Properties related to users running jobs.
- JobsUsersProperties() - Constructor for class com.netflix.genie.web.properties.JobsUsersProperties
-
- JobTask - Class in com.netflix.genie.web.jobs.workflow.impl
-
Implementation of the workflow task for processing job information for genie mode.
- JobTask(AttachmentService, MeterRegistry, GenieFileTransferService) - Constructor for class com.netflix.genie.web.jobs.workflow.impl.JobTask
-
Constructor.
- JpaAgentConnectionPersistenceServiceImpl - Class in com.netflix.genie.web.data.services.jpa
-
JPA implementation of AgentConnectionPersistenceService.
- JpaAgentConnectionPersistenceServiceImpl(JpaAgentConnectionRepository) - Constructor for class com.netflix.genie.web.data.services.jpa.JpaAgentConnectionPersistenceServiceImpl
-
Constructor.
- JpaAgentConnectionRepository - Interface in com.netflix.genie.web.data.repositories.jpa
-
JPA repository for active agent-to-server connections.
- JpaApplicationPersistenceServiceImpl - Class in com.netflix.genie.web.data.services.jpa
-
JPA based implementation of the ApplicationPersistenceService.
- JpaApplicationPersistenceServiceImpl(JpaTagPersistenceService, JpaFilePersistenceService, JpaApplicationRepository, JpaClusterRepository, JpaCommandRepository) - Constructor for class com.netflix.genie.web.data.services.jpa.JpaApplicationPersistenceServiceImpl
-
Default constructor.
- JpaApplicationRepository - Interface in com.netflix.genie.web.data.repositories.jpa
-
Application repository.
- JpaApplicationSpecs - Class in com.netflix.genie.web.data.repositories.jpa.specifications
-
Specifications for JPA queries.
- JpaBaseRepository<E extends BaseEntity> - Interface in com.netflix.genie.web.data.repositories.jpa
-
A common repository for inheritance of common methods for Entities extending BaseEntity.
- JpaClusterPersistenceServiceImpl - Class in com.netflix.genie.web.data.services.jpa
-
Implementation of the ClusterPersistenceService interface using JPA.
- JpaClusterPersistenceServiceImpl(JpaTagPersistenceService, JpaFilePersistenceService, JpaApplicationRepository, JpaClusterRepository, JpaCommandRepository) - Constructor for class com.netflix.genie.web.data.services.jpa.JpaClusterPersistenceServiceImpl
-
Default constructor.
- JpaClusterRepository - Interface in com.netflix.genie.web.data.repositories.jpa
-
Cluster repository.
- JpaClusterSpecs - Class in com.netflix.genie.web.data.repositories.jpa.specifications
-
Specifications for JPA queries.
- JpaCommandPersistenceServiceImpl - Class in com.netflix.genie.web.data.services.jpa
-
Implementation of the CommandPersistenceService interface.
- JpaCommandPersistenceServiceImpl(JpaTagPersistenceService, JpaFilePersistenceService, JpaApplicationRepository, JpaClusterRepository, JpaCommandRepository) - Constructor for class com.netflix.genie.web.data.services.jpa.JpaCommandPersistenceServiceImpl
-
Default constructor.
- JpaCommandRepository - Interface in com.netflix.genie.web.data.repositories.jpa
-
Command repository.
- JpaCommandSpecs - Class in com.netflix.genie.web.data.repositories.jpa.specifications
-
Specifications for JPA queries.
- JpaFilePersistenceService - Interface in com.netflix.genie.web.data.services.jpa
-
- JpaFilePersistenceServiceImpl - Class in com.netflix.genie.web.data.services.jpa
-
JPA based implementation of the FilePersistenceService interface.
- JpaFilePersistenceServiceImpl(JpaFileRepository) - Constructor for class com.netflix.genie.web.data.services.jpa.JpaFilePersistenceServiceImpl
-
Constructor.
- JpaFileRepository - Interface in com.netflix.genie.web.data.repositories.jpa
-
Repository for file references.
- JpaJobPersistenceServiceImpl - Class in com.netflix.genie.web.data.services.jpa
-
JPA implementation of the job persistence service.
- JpaJobPersistenceServiceImpl(JpaTagPersistenceService, JpaFilePersistenceService, JpaApplicationRepository, JpaClusterRepository, JpaCommandRepository, JpaJobRepository) - Constructor for class com.netflix.genie.web.data.services.jpa.JpaJobPersistenceServiceImpl
-
Constructor.
- JpaJobRepository - Interface in com.netflix.genie.web.data.repositories.jpa
-
Job repository.
- JpaJobSearchServiceImpl - Class in com.netflix.genie.web.data.services.jpa
-
JPA implementation of the Job Search Service.
- JpaJobSearchServiceImpl(JpaJobRepository, JpaClusterRepository, JpaCommandRepository) - Constructor for class com.netflix.genie.web.data.services.jpa.JpaJobSearchServiceImpl
-
Constructor.
- JpaJobSpecs - Class in com.netflix.genie.web.data.repositories.jpa.specifications
-
Specifications for JPA queries.
- JpaServiceUtils - Class in com.netflix.genie.web.data.services.jpa
-
Utility methods for JPA services.
- JpaSpecificationUtils - Class in com.netflix.genie.web.data.repositories.jpa.specifications
-
Utility methods for the specification classes.
- JpaTagPersistenceService - Interface in com.netflix.genie.web.data.services.jpa
-
- JpaTagPersistenceServiceImpl - Class in com.netflix.genie.web.data.services.jpa
-
JPA based implementation of the TagPersistenceService interface.
- JpaTagPersistenceServiceImpl(JpaTagRepository) - Constructor for class com.netflix.genie.web.data.services.jpa.JpaTagPersistenceServiceImpl
-
Constructor.
- JpaTagRepository - Interface in com.netflix.genie.web.data.repositories.jpa
-
Repository for tags.
- JsonUtils - Class in com.netflix.genie.common.util
-
Utility methods for interacting with JSON.
- JsonUtils() - Constructor for class com.netflix.genie.common.util.JsonUtils
-
Protected constructor for a utility class.
- jwtConsumer(PublicKey, PingFederateValidator) - Method in class com.netflix.genie.security.oauth2.pingfederate.PingFederateJWTConfig
-
The jwtConsumer class which will be used to verify and parse the JWT token from ping federate.
- jwtPublicKey(String) - Method in class com.netflix.genie.security.oauth2.pingfederate.PingFederateJWTConfig
-
The public key used to verify the signatures of JWT tokens.
- S3_JOB_ARCHIVER_PRECEDENCE - Static variable in class com.netflix.genie.common.internal.configs.AwsAutoConfiguration
-
Constant for the precedence of the S3 job archive implementation for others to reference if need be.
- S3ClientFactory - Class in com.netflix.genie.common.internal.aws.s3
-
An AmazonS3
client factory class.
- S3ClientFactory(AWSCredentialsProvider, AwsRegionProvider, Environment) - Constructor for class com.netflix.genie.common.internal.aws.s3.S3ClientFactory
-
Constructor.
- s3ClientFactory(AWSCredentialsProvider, AwsRegionProvider, Environment) - Method in class com.netflix.genie.common.internal.configs.AwsAutoConfiguration
-
- s3FileTransferImpl(S3ClientFactory, MeterRegistry, S3FileTransferProperties) - Method in class com.netflix.genie.web.configs.aws.GenieAwsS3AutoConfiguration
-
Returns a bean which has an s3 implementation of the File Transfer interface.
- S3FileTransferImpl - Class in com.netflix.genie.web.services.impl
-
An implementation of the FileTransferService interface in which the remote locations are on Amazon S3.
- S3FileTransferImpl(S3ClientFactory, MeterRegistry, S3FileTransferProperties) - Constructor for class com.netflix.genie.web.services.impl.S3FileTransferImpl
-
Constructor.
- S3FileTransferProperties - Class in com.netflix.genie.web.properties
-
Properties for S3FileTransfer.
- S3FileTransferProperties() - Constructor for class com.netflix.genie.web.properties.S3FileTransferProperties
-
- s3JobArchiver(S3ClientFactory) - Method in class com.netflix.genie.common.internal.configs.AwsAutoConfiguration
-
Provide an implementation of
JobArchiver
to handle archiving
to S3.
- S3JobArchiverImpl - Class in com.netflix.genie.common.internal.services.impl
-
- S3JobArchiverImpl(S3ClientFactory) - Constructor for class com.netflix.genie.common.internal.services.impl.S3JobArchiverImpl
-
Constructor.
- S3ProtocolResolver - Class in com.netflix.genie.common.internal.aws.s3
-
This class implements the ProtocolResolver
interface.
- S3ProtocolResolver(S3ClientFactory, TaskExecutor) - Constructor for class com.netflix.genie.common.internal.aws.s3.S3ProtocolResolver
-
Constructor.
- s3ProtocolResolver(AwsS3ResourceLoaderProperties, S3ClientFactory) - Method in class com.netflix.genie.common.internal.configs.AwsAutoConfiguration
-
Provide an protocol resolver which will allow resources with s3:// prefixes to be resolved by the
application ResourceLoader
provided this bean is eventually added to the
context via the
ConfigurableApplicationContext.addProtocolResolver(ProtocolResolver)
method.
- S3ProtocolResolverRegistrar - Class in com.netflix.genie.common.internal.aws.s3
-
A class which takes an instance of
S3ProtocolResolver
and adds it to the Spring
ApplicationContext
set of
ProtocolResolver
.
- S3ProtocolResolverRegistrar(S3ProtocolResolver) - Constructor for class com.netflix.genie.common.internal.aws.s3.S3ProtocolResolverRegistrar
-
Constructor.
- s3ProtocolResolverRegistrar(S3ProtocolResolver) - Method in class com.netflix.genie.common.internal.configs.AwsAutoConfiguration
-
Configurer bean which will add the
S3ProtocolResolver
to the set of
ProtocolResolver
in the
application context.
- S3RetryProperties() - Constructor for class com.netflix.genie.web.properties.RetryProperties.S3RetryProperties
-
- samlAuthenticationProvider(SAMLUserDetailsService) - Method in class com.netflix.genie.security.saml.SAMLConfig
-
Parses the response SAML messages.
- samlBootstrap() - Static method in class com.netflix.genie.security.saml.SAMLConfig
-
Initialization of OpenSAML library.
- SAMLConfig - Class in com.netflix.genie.security.saml
-
Security configuration for SAML based authentication.
- SAMLConfig() - Constructor for class com.netflix.genie.security.saml.SAMLConfig
-
- samlEntryPoint() - Method in class com.netflix.genie.security.saml.SAMLConfig
-
Entry point to initialize authentication, default values taken from properties file.
- samlFilter() - Method in class com.netflix.genie.security.saml.SAMLConfig
-
Define the security filter chain in order to support SSO Auth by using SAML 2.0.
- samlIDPDiscovery() - Method in class com.netflix.genie.security.saml.SAMLConfig
-
Setup the IDP discovery service.
- samlLogger() - Method in class com.netflix.genie.security.saml.SAMLConfig
-
The Logger used by the SAML package.
- samlLogoutFilter() - Method in class com.netflix.genie.security.saml.SAMLConfig
-
Overrides default logout processing filter with the one processing SAML messages.
- samlLogoutProcessingFilter() - Method in class com.netflix.genie.security.saml.SAMLConfig
-
Filter to handle logout requests.
- SAMLProperties - Class in com.netflix.genie.security.saml
-
Class to bind properties to for SAML configurations.
- SAMLProperties() - Constructor for class com.netflix.genie.security.saml.SAMLProperties
-
- SAMLProperties.Attributes - Class in com.netflix.genie.security.saml
-
Contains attributes from the SAML assertion.
- SAMLProperties.Attributes.Groups - Class in com.netflix.genie.security.saml
-
Contains attribute information regarding groups from the SAML assertion.
- SAMLProperties.Attributes.User - Class in com.netflix.genie.security.saml
-
Attributes about the user.
- SAMLProperties.Idp - Class in com.netflix.genie.security.saml
-
Class containing information about the SAML IDP.
- SAMLProperties.Keystore - Class in com.netflix.genie.security.saml
-
Information about the keystore used to sign requests to the IDP.
- SAMLProperties.Keystore.DefaultKey - Class in com.netflix.genie.security.saml
-
Information about the default key inside the keystore.
- SAMLProperties.LoadBalancer - Class in com.netflix.genie.security.saml
-
Information about an optional load balancer this service could sit behind.
- SAMLProperties.Sp - Class in com.netflix.genie.security.saml
-
Information about the service provider from the IDP.
- SAMLUserDetailsServiceImpl - Class in com.netflix.genie.security.saml
-
Get the user and roles from a SAML certificate.
- SAMLUserDetailsServiceImpl(SAMLProperties, MeterRegistry) - Constructor for class com.netflix.genie.security.saml.SAMLUserDetailsServiceImpl
-
Constructor.
- samlWebSSOHoKProcessingFilter() - Method in class com.netflix.genie.security.saml.SAMLConfig
-
Filter to process holder of key sso requests.
- samlWebSSOProcessingFilter() - Method in class com.netflix.genie.security.saml.SAMLConfig
-
Processing filter for WebSSO profile messages.
- save(String, String, InputStream) - Method in interface com.netflix.genie.web.services.AttachmentService
-
Save a given attachment for a job for later retrieval.
- save(String, String, InputStream) - Method in class com.netflix.genie.web.services.impl.FileSystemAttachmentService
-
Save a given attachment for a job for later retrieval.
- saveAgentConnection(String, String) - Method in class com.netflix.genie.web.data.services.jpa.JpaAgentConnectionPersistenceServiceImpl
-
Store a new connection currently active from the given agent to the given node.
- saveAgentConnection(String, String) - Method in interface com.netflix.genie.web.services.AgentConnectionPersistenceService
-
Store a new connection currently active from the given agent to the given node.
- saveJobRequest(JobRequest, JobRequestMetadata) - Method in class com.netflix.genie.web.data.services.jpa.JpaJobPersistenceServiceImpl
-
Save the job request information.
- saveJobRequest(JobRequest, JobRequestMetadata) - Method in interface com.netflix.genie.web.services.JobPersistenceService
-
Save the job request information.
- saveJobSpecification(String, JobSpecification) - Method in class com.netflix.genie.web.data.services.jpa.JpaJobPersistenceServiceImpl
-
Save the given job specification details for a job.
- saveJobSpecification(String, JobSpecification) - Method in interface com.netflix.genie.web.services.JobPersistenceService
-
Save the given job specification details for a job.
- schedule(String, JobRequest, Cluster, Command, List<Application>, int) - Method in class com.netflix.genie.web.services.impl.JobStateServiceImpl
-
Schedules the job.
- schedule(String, JobRequest, Cluster, Command, List<Application>, int) - Method in interface com.netflix.genie.web.services.JobStateService
-
Schedules the job.
- scheduler - Variable in class com.netflix.genie.web.services.impl.JobStateServiceImpl
-
- SCOPE_KEY - Static variable in class com.netflix.genie.security.oauth2.pingfederate.PingFederateRemoteTokenServices
-
- SCOPE_KEY - Static variable in class com.netflix.genie.security.oauth2.pingfederate.PingFederateUserAuthenticationConverter
-
- SCRIPT_FILE_DESTINATION_PROPERTY - Static variable in class com.netflix.genie.web.properties.ScriptLoadBalancerProperties
-
Where the script should be stored on local disk.
- SCRIPT_FILE_SOURCE_PROPERTY - Static variable in class com.netflix.genie.web.properties.ScriptLoadBalancerProperties
-
The source location of the script.
- SCRIPT_LOAD_BALANCER_PRECEDENCE - Static variable in class com.netflix.genie.web.configs.GenieClusterLoadBalancerAutoConfiguration
-
- scriptLoadBalancer(AsyncTaskExecutor, TaskScheduler, GenieFileTransferService, Environment, ObjectMapper, MeterRegistry) - Method in class com.netflix.genie.web.configs.GenieClusterLoadBalancerAutoConfiguration
-
Produce the
ScriptLoadBalancer
instance to use for this Genie node if it was configured by the user.
- ScriptLoadBalancer - Class in com.netflix.genie.web.services.loadbalancers.script
-
An implementation of the ClusterLoadBalancer interface which uses user a supplied script to make decisions based
on the list of clusters and the job request supplied.
- ScriptLoadBalancer(AsyncTaskExecutor, TaskScheduler, GenieFileTransferService, Environment, ObjectMapper, MeterRegistry) - Constructor for class com.netflix.genie.web.services.loadbalancers.script.ScriptLoadBalancer
-
Constructor.
- ScriptLoadBalancerProperties - Class in com.netflix.genie.web.properties
-
- ScriptLoadBalancerProperties() - Constructor for class com.netflix.genie.web.properties.ScriptLoadBalancerProperties
-
- SecurityConditions - Class in com.netflix.genie.security
-
Container class for all the security conditions we want to use.
- SecurityConditions() - Constructor for class com.netflix.genie.security.SecurityConditions
-
- SecurityConditions.AnySecurityEnabled - Class in com.netflix.genie.security
-
A class used to enable the security config any time any of the supported security platforms is enabled.
- SecurityConfig - Class in com.netflix.genie.security
-
Primary Genie Security configuration for all but only x509 client certification.
- SecurityConfig() - Constructor for class com.netflix.genie.security.SecurityConfig
-
- SecurityInterceptor - Interface in com.netflix.genie.client.interceptors
-
An interface whose implementation is supposed to modify the HTTP Request by adding Security credentials.
- SecurityUtils - Class in com.netflix.genie.security
-
Utility methods for common functionality in security configurations that ONLY configure security on API paths.
- SecurityUtils() - Constructor for class com.netflix.genie.security.SecurityUtils
-
Protected constructor for utility class.
- SELECT_FOR_UPDATE_UNUSED_FILES_SQL - Static variable in interface com.netflix.genie.web.data.repositories.jpa.JpaFileRepository
-
The query used to select any dangling file references.
- SELECT_FOR_UPDATE_UNUSED_TAGS_SQL - Static variable in interface com.netflix.genie.web.data.repositories.jpa.JpaTagRepository
-
This is the query used to find the ids of tags that aren't referenced by any of the other tables.
- selectCluster(Set<Cluster>, JobRequest) - Method in interface com.netflix.genie.web.services.ClusterLoadBalancer
-
Return best cluster to run job on.
- selectCluster(Set<Cluster>, JobRequest) - Method in class com.netflix.genie.web.services.impl.RandomizedClusterLoadBalancerImpl
-
Return best cluster to run job on.
- selectCluster(Set<Cluster>, JobRequest) - Method in class com.netflix.genie.web.services.loadbalancers.script.ScriptLoadBalancer
-
Return best cluster to run job on.
- SEMICOLON_SYMBOL - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
Semicolon symbol.
- sendEmail(String, String, String) - Method in class com.netflix.genie.web.services.impl.DefaultMailServiceImpl
-
Method to send emails.
- sendEmail(String, String, String) - Method in class com.netflix.genie.web.services.impl.MailServiceImpl
-
- sendEmail(String, String, String) - Method in interface com.netflix.genie.web.services.MailService
-
Method to send emails.
- SERVER_HOSTNAME - Static variable in class com.netflix.genie.web.data.entities.AgentConnectionEntity_
-
- serverArguments() - Method in class com.netflix.genie.agent.cli.CliAutoConfiguration
-
- serveResource(String, URL, String, HttpServletRequest, HttpServletResponse) - Method in class com.netflix.genie.web.services.impl.JobDirectoryServerServiceImpl
-
Given the request
this API will write the resource to response
if possible.
- serveResource(String, URL, String, HttpServletRequest, HttpServletResponse) - Method in interface com.netflix.genie.web.services.JobDirectoryServerService
-
Given the request
this API will write the resource to response
if possible.
- serverHostname - Static variable in class com.netflix.genie.web.data.entities.AgentConnectionEntity_
-
- serviceOperation() - Method in class com.netflix.genie.web.aspect.SystemArchitecture
-
A service operation is the execution of any method defined on a
service class/interface.
- ServicesAutoConfiguration - Class in com.netflix.genie.agent.execution.services.impl
-
Spring auto configuration for the service tier of an Agent process.
- ServicesAutoConfiguration() - Constructor for class com.netflix.genie.agent.execution.services.impl.ServicesAutoConfiguration
-
- setApplicationContext(ApplicationContext) - Method in class com.netflix.genie.common.internal.aws.s3.S3ProtocolResolverRegistrar
- setApplicationContext(ApplicationContext) - Method in class com.netflix.genie.web.resources.agent.AgentFileProtocolResolverRegistrar
- setApplications(List<ApplicationEntity>) - Method in class com.netflix.genie.web.data.entities.CommandEntity
-
Sets the applications for this command.
- setApplications(List<ApplicationEntity>) - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Set the applications used to run this job.
- setApplicationsForCommand(String, List<String>) - Method in interface com.netflix.genie.client.apis.CommandService
-
Method to override and set applications for a command in Genie.
- setApplicationsForCommand(String, List<String>) - Method in class com.netflix.genie.web.controllers.CommandRestController
-
Set the applications for the given command.
- setApplicationsForCommand(String, List<String>) - Method in class com.netflix.genie.web.data.services.jpa.JpaCommandPersistenceServiceImpl
-
Set the applications for the command.
- setApplicationsForCommand(String, List<String>) - Method in interface com.netflix.genie.web.services.CommandPersistenceService
-
Set the applications for the command.
- setBeanClassLoader(ClassLoader) - Method in class com.netflix.genie.web.events.GenieEventBusImpl
- setBeanFactory(BeanFactory) - Method in class com.netflix.genie.web.events.GenieEventBusImpl
- setClaimedJobId(String) - Method in interface com.netflix.genie.agent.execution.ExecutionContext
-
Set the job id of a successfully claimed job.
- setCluster(ClusterEntity) - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Set the cluster this job ran on.
- setClusterCriteria(List<CriterionEntity>) - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Set the cluster criteria set for this job.
- setClusters(Set<ClusterEntity>) - Method in class com.netflix.genie.web.data.entities.CommandEntity
-
Set the clusters this command is available on.
- setCommand(CommandEntity) - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Set the command used to run this job.
- setCommandArgs(List<String>) - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Set the command arguments to use with this job.
- setCommandCriterion(CriterionEntity) - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Set the command criterion.
- setCommands(List<CommandEntity>) - Method in class com.netflix.genie.web.data.entities.ClusterEntity
-
Sets the commands for this cluster.
- setCommandsForCluster(String, List<String>) - Method in interface com.netflix.genie.client.apis.ClusterService
-
Method to override and set commands for a cluster in Genie.
- setCommandsForCluster(String, List<String>) - Method in class com.netflix.genie.web.controllers.ClusterRestController
-
Set the commandIds for a given cluster.
- setCommandsForCluster(String, List<String>) - Method in class com.netflix.genie.web.data.services.jpa.JpaClusterPersistenceServiceImpl
-
Update the set of command files associated with the cluster with
given id.
- setCommandsForCluster(String, List<String>) - Method in interface com.netflix.genie.web.services.ClusterPersistenceService
-
Update the set of command files associated with the cluster with
given id.
- setConfigs(Set<FileEntity>) - Method in class com.netflix.genie.web.data.entities.ApplicationEntity
-
Set all the files associated as configuration files for this application.
- setConfigs(Set<FileEntity>) - Method in class com.netflix.genie.web.data.entities.ClusterEntity
-
Set all the files associated as configuration files for this cluster.
- setConfigs(Set<FileEntity>) - Method in class com.netflix.genie.web.data.entities.CommandEntity
-
Set all the files associated as configuration files for this cluster.
- setConfigs(Set<FileEntity>) - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Set all the files associated as configuration files for this job.
- setCurrentJobStatus(JobStatus) - Method in interface com.netflix.genie.agent.execution.ExecutionContext
-
Set the current job status.
- setDependencies(Set<FileEntity>) - Method in class com.netflix.genie.web.data.entities.ApplicationEntity
-
Set all the files associated as dependency files for this application.
- setDependencies(Set<FileEntity>) - Method in class com.netflix.genie.web.data.entities.ClusterEntity
-
Set all the files associated as dependency files for this cluster.
- setDependencies(Set<FileEntity>) - Method in class com.netflix.genie.web.data.entities.CommandEntity
-
Set all the files associated as dependency files for this cluster.
- setDependencies(Set<FileEntity>) - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Set all the files associated as dependency files for this job.
- setDescription(String) - Method in class com.netflix.genie.web.data.entities.BaseEntity
-
Set the description of this entity.
- setEnvironment(Environment) - Method in class com.netflix.genie.web.properties.AgentFilterProperties
- setEnvironment(Environment) - Method in class com.netflix.genie.web.properties.JobsActiveLimitProperties
- setEnvironmentVariables(Map<String, String>) - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Set the environment variables for the job.
- setExecutable(List<String>) - Method in class com.netflix.genie.web.data.entities.CommandEntity
-
Set the executable and any default arguments for this command.
- setFinalJobStatus(JobStatus) - Method in interface com.netflix.genie.agent.execution.ExecutionContext
-
Set the job status.
- setFinished(Instant) - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Set the finishTime for the job.
- setJobCompletionInformation(String, int, JobStatus, String, Long, Long) - Method in class com.netflix.genie.web.data.services.jpa.JpaJobPersistenceServiceImpl
-
Method to set all job completion information for a job execution.
- setJobCompletionInformation(String, int, JobStatus, String, Long, Long) - Method in interface com.netflix.genie.web.services.JobPersistenceService
-
Method to set all job completion information for a job execution.
- setJobDirectory(File) - Method in interface com.netflix.genie.agent.execution.ExecutionContext
-
Set the job directory.
- setJobEnvironment(Map<String, String>) - Method in interface com.netflix.genie.agent.execution.ExecutionContext
-
Set the job environment variables map.
- setJobRunningInformation(String, int, long, Instant) - Method in class com.netflix.genie.web.data.services.jpa.JpaJobPersistenceServiceImpl
-
Update the job with information for the running job process.
- setJobRunningInformation(String, int, long, Instant) - Method in interface com.netflix.genie.web.services.JobPersistenceService
-
Update the job with information for the running job process.
- setJobSpecification(JobSpecification) - Method in interface com.netflix.genie.agent.execution.ExecutionContext
-
Set the job specification.
- setJsonField(JsonNode, Consumer<String>) - Static method in class com.netflix.genie.web.data.entities.v4.EntityDtoConverters
-
Given a JSON node convert it to a string representation and hand it to the consumer.
- setMemoryAndTask(String, int, Future<?>) - Method in class com.netflix.genie.web.services.impl.JobStateServiceImpl
-
- setMetadata(String) - Method in class com.netflix.genie.web.data.entities.BaseEntity
-
Set the JSON metadata of this entity.
- setName(String) - Method in class com.netflix.genie.web.data.entities.CriterionEntity
-
Set the name this criterion used.
- setRegion(String) - Method in class com.netflix.genie.common.internal.aws.s3.BucketProperties
-
Set the AWS region from a string name representation e.g.
- setRequestedEnvironmentVariables(Map<String, String>) - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Set the requested environment variables.
- setRestTemplate(RestTemplate) - Method in class com.netflix.genie.security.oauth2.pingfederate.PingFederateRemoteTokenServices
-
Set the rest operations to use.
- setRetryListeners(RetryListener[]) - Method in class com.netflix.genie.web.aspect.DataServiceRetryAspect
-
Sets the retry listeners for the retry template in use.
- setRoleARN(String) - Method in class com.netflix.genie.common.internal.aws.s3.BucketProperties
-
Set the ARN of the role to assume from this instance when working with the given bucket.
- setSetupFile(FileEntity) - Method in class com.netflix.genie.web.data.entities.BaseEntity
-
Set the setup file for this entity.
- setStarted(Instant) - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Set the start time for the job.
- setStatic(String) - Method in class com.netflix.genie.web.properties.AwsCredentialsProperties.SpringCloudAwsRegionProperties
-
Set the static value for the region this instance is running in.
- setStatus(String) - Method in class com.netflix.genie.web.data.entities.CriterionEntity
-
Set the status this criterion used.
- setStdErrSize(Long) - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Set the total size in bytes of the std err file for this job.
- setStdOutSize(Long) - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Set the total size in bytes of the std out file for this job.
- setTags(Set<TagEntity>) - Method in class com.netflix.genie.web.data.entities.ApplicationEntity
-
Set all the tags associated to this application.
- setTags(Set<TagEntity>) - Method in class com.netflix.genie.web.data.entities.ClusterEntity
-
Set all the tags associated to this cluster.
- setTags(Set<TagEntity>) - Method in class com.netflix.genie.web.data.entities.CommandEntity
-
Set all the tags associated to this cluster.
- setTags(Set<TagEntity>) - Method in class com.netflix.genie.web.data.entities.CriterionEntity
-
Set all the tags associated to this criterion.
- setTags(Set<TagEntity>) - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Set all the tags associated to this job.
- setTimeout(Instant) - Method in class com.netflix.genie.web.data.entities.JobEntity
-
Set the date this job will be killed due to exceeding its set timeout duration.
- setUniqueId(String) - Method in class com.netflix.genie.web.data.entities.CriterionEntity
-
Set the unique id this criterion used.
- SETUP_FILE - Static variable in class com.netflix.genie.web.data.entities.BaseEntity_
-
- setupFile - Static variable in class com.netflix.genie.web.data.entities.BaseEntity_
-
- SetupFileProjection - Interface in com.netflix.genie.web.data.entities.projections
-
Projection for returning the setup file of a given entity.
- setUpJobAction(ExecutionContext, DownloadService, AgentJobService, AgentHeartBeatService, AgentJobKillService, AgentFileStreamService, ArgumentDelegates.CleanupArguments) - Method in class com.netflix.genie.agent.execution.statemachine.actions.StateMachineActionsAutoConfiguration
-
Provide a lazy SetUpJobAction
bean.
- SetUpJobException - Exception in com.netflix.genie.agent.execution.exceptions
-
Exception during the set up of a job.
- SetUpJobException(String) - Constructor for exception com.netflix.genie.agent.execution.exceptions.SetUpJobException
-
Construct with message.
- SetUpJobException(String, Throwable) - Constructor for exception com.netflix.genie.agent.execution.exceptions.SetUpJobException
-
Construct with a message and a cause.
- setVersion(String) - Method in class com.netflix.genie.web.data.entities.CriterionEntity
-
Set the version this criterion used.
- sharedAgentTaskExecutor() - Method in class com.netflix.genie.agent.configs.AgentAutoConfiguration
-
Get a lazy task executor bean which may be shared by different components if one isn't already defined.
- shutdownAction(ExecutionContext, JobArchiveService) - Method in class com.netflix.genie.agent.execution.statemachine.actions.StateMachineActionsAutoConfiguration
-
Provide a ShutdownAction
bean.
- SimpleLoggingInterceptor - Class in com.netflix.genie.web.rpc.grpc.interceptors
-
Proof of concept server interceptor that logs gRPC requests and errors.
- SimpleLoggingInterceptor() - Constructor for class com.netflix.genie.web.rpc.grpc.interceptors.SimpleLoggingInterceptor
-
- soapBinding() - Method in class com.netflix.genie.security.saml.SAMLConfig
-
A SOAP binding to use.
- SOURCE - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
Bash source command.
- Sp() - Constructor for class com.netflix.genie.security.saml.SAMLProperties.Sp
-
- splitV3CommandExecutableForV4(Connection) - Static method in class com.netflix.genie.web.data.utils.H2Utils
-
Split the existing command executable on any whitespace characters and insert them into the
command_executable_arguments
table in order.
- SpringCloudAwsRegionProperties() - Constructor for class com.netflix.genie.web.properties.AwsCredentialsProperties.SpringCloudAwsRegionProperties
-
- ssoCircleExtendedMetadataProvider(SAMLProperties) - Method in class com.netflix.genie.security.saml.SAMLConfig
-
Setup the extended metadata delegate for the IDP.
- start(String, Path) - Method in interface com.netflix.genie.agent.execution.services.AgentFileStreamService
-
Start the service.
- start(String) - Method in interface com.netflix.genie.agent.execution.services.AgentHeartBeatService
-
Starts the service.
- start(String) - Method in interface com.netflix.genie.agent.execution.services.AgentJobKillService
-
Start listening for job termination notification.
- start(String, Path) - Method in class com.netflix.genie.agent.execution.services.impl.grpc.GRpcAgentFileStreamServiceImpl
-
Start the service.
- start(String) - Method in class com.netflix.genie.agent.execution.services.impl.grpc.GRpcAgentJobKillServiceImpl
-
- start() - Method in interface com.netflix.genie.agent.execution.statemachine.JobExecutionStateMachine
-
Starts the state machine and returns.
- started - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- STARTED - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- startLeadership(ContextRefreshedEvent) - Method in class com.netflix.genie.web.tasks.leader.LocalLeader
-
Event listener for when a context is started up.
- StateAction - Interface in com.netflix.genie.agent.execution.statemachine.actions
-
Interface types for individual state actions.
- StateAction.CleanupJob - Interface in com.netflix.genie.agent.execution.statemachine.actions
-
CLEANUP_JOB state action interface.
- StateAction.ConfigureAgent - Interface in com.netflix.genie.agent.execution.statemachine.actions
-
CONFIGURE_AGENT state action interface.
- StateAction.HandleError - Interface in com.netflix.genie.agent.execution.statemachine.actions
-
HANDLE_ERROR state action interface.
- StateAction.Initialize - Interface in com.netflix.genie.agent.execution.statemachine.actions
-
INITIALIZE state action interface.
- StateAction.LaunchJob - Interface in com.netflix.genie.agent.execution.statemachine.actions
-
LAUNCH_JOB state action interface.
- StateAction.MonitorJob - Interface in com.netflix.genie.agent.execution.statemachine.actions
-
MONITOR_JOB state action interface.
- StateAction.ResolveJobSpecification - Interface in com.netflix.genie.agent.execution.statemachine.actions
-
RESOLVE_JOB_SPECIFICATION state action interface.
- StateAction.SetUpJob - Interface in com.netflix.genie.agent.execution.statemachine.actions
-
SETUP_JOB state action interface.
- StateAction.Shutdown - Interface in com.netflix.genie.agent.execution.statemachine.actions
-
SHUTDOWN state action interface.
- stateChanged(State<States, Events>, State<States, Events>) - Method in class com.netflix.genie.agent.execution.statemachine.listeners.LoggingListener
- stateContext(StateContext<States, Events>) - Method in class com.netflix.genie.agent.execution.statemachine.listeners.LoggingListener
- stateEntered(State<States, Events>) - Method in class com.netflix.genie.agent.execution.statemachine.listeners.LoggingListener
- stateExited(State<States, Events>) - Method in class com.netflix.genie.agent.execution.statemachine.listeners.LoggingListener
- stateMachine(Collection<Pair<States, StateAction>>, Collection<Triple<States, Events, States>>, Collection<States>, Collection<JobExecutionListener>) - Method in class com.netflix.genie.agent.execution.statemachine.StateMachineAutoConfiguration
-
Provide a lazy StateMachine
instance configured with the current model expected for job execution.
- StateMachineActionsAutoConfiguration - Class in com.netflix.genie.agent.execution.statemachine.actions
-
Spring auto configuration to provide beans for all available actions within the Agent job execution state machine.
- StateMachineActionsAutoConfiguration() - Constructor for class com.netflix.genie.agent.execution.statemachine.actions.StateMachineActionsAutoConfiguration
-
- StateMachineAutoConfiguration - Class in com.netflix.genie.agent.execution.statemachine
-
- StateMachineAutoConfiguration() - Constructor for class com.netflix.genie.agent.execution.statemachine.StateMachineAutoConfiguration
-
- stateMachineError(StateMachine<States, Events>, Exception) - Method in class com.netflix.genie.agent.execution.statemachine.listeners.LoggingListener
- stateMachineStarted(StateMachine<States, Events>) - Method in class com.netflix.genie.agent.execution.statemachine.listeners.LoggingListener
- stateMachineStopped(StateMachine<States, Events>) - Method in class com.netflix.genie.agent.execution.statemachine.listeners.LoggingListener
- States - Enum in com.netflix.genie.agent.execution.statemachine
-
JobExecutionStateMachine states.
- statesWithActions(StateAction.Initialize, StateAction.ConfigureAgent, StateAction.ResolveJobSpecification, StateAction.SetUpJob, StateAction.LaunchJob, StateAction.MonitorJob, StateAction.CleanupJob, StateAction.Shutdown, StateAction.HandleError) - Method in class com.netflix.genie.agent.execution.statemachine.StateMachineAutoConfiguration
-
Provide a lazy bean which is a collection of all the states the state machine should contain which have an
associated action.
- statesWithErrorTransition() - Method in class com.netflix.genie.agent.execution.statemachine.StateMachineAutoConfiguration
-
Provide a bean with a collection of states which should have transitions to an error action when an error occurs.
- status - Static variable in class com.netflix.genie.web.data.entities.ApplicationEntity_
-
- STATUS - Static variable in class com.netflix.genie.web.data.entities.ApplicationEntity_
-
- status - Static variable in class com.netflix.genie.web.data.entities.ClusterEntity_
-
- STATUS - Static variable in class com.netflix.genie.web.data.entities.ClusterEntity_
-
- status - Static variable in class com.netflix.genie.web.data.entities.CommandEntity_
-
- STATUS - Static variable in class com.netflix.genie.web.data.entities.CommandEntity_
-
- status - Static variable in class com.netflix.genie.web.data.entities.CriterionEntity_
-
- STATUS - Static variable in class com.netflix.genie.web.data.entities.CriterionEntity_
-
- status - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- STATUS - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- STATUS - Static variable in class com.netflix.genie.web.util.MetricsConstants.TagKeys
-
Key to tag the status of a request or operation.
- STATUS_MSG - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- statusMsg - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- STD_ERR_SIZE - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- STD_OUT_SIZE - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- STDERR_LOG_FILE_NAME - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
Stderr Filename generated by Genie after running a job.
- STDERR_REDIRECT - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
unix stderr symbol.
- stdErrSize - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- STDOUT_LOG_FILE_NAME - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
Stdout Filename generated by Genie after running a job.
- STDOUT_REDIRECT - Static variable in class com.netflix.genie.common.internal.jobs.JobConstants
-
unix stdout symbol.
- stdOutSize - Static variable in class com.netflix.genie.web.data.entities.JobEntity_
-
- stop() - Method in interface com.netflix.genie.agent.execution.services.AgentFileStreamService
-
Stop the service.
- stop() - Method in interface com.netflix.genie.agent.execution.services.AgentHeartBeatService
-
Stop the service.
- stop() - Method in interface com.netflix.genie.agent.execution.services.AgentJobKillService
-
Stop the service.
- stop() - Method in class com.netflix.genie.agent.execution.services.impl.grpc.GRpcAgentFileStreamServiceImpl
-
Stop the service.
- stop() - Method in class com.netflix.genie.agent.execution.services.impl.grpc.GRpcAgentJobKillServiceImpl
-
- stop() - Method in interface com.netflix.genie.agent.execution.statemachine.JobExecutionStateMachine
-
Force an early termination of the state machine, in response to user submitting a kill via API or ctrl-c.
- stopLeadership(ContextClosedEvent) - Method in class com.netflix.genie.web.tasks.leader.LocalLeader
-
Before the application shuts down need to turn off leadership activities.
- StreamBuffer - Class in com.netflix.genie.web.util
-
A temporary in-memory structure to hold in-transit data.
- StreamBuffer() - Constructor for class com.netflix.genie.web.util.StreamBuffer
-
Constructor.
- STRING - Static variable in class com.netflix.genie.test.suppliers.RandomSuppliers
-
Get a random String.
- SUBMIT_INIT_FAILURE - Static variable in class com.netflix.genie.common.dto.JobStatusMessages
-
Job failed with unexpected exception during initialization.
- SUBMIT_PRECONDITION_FAILURE - Static variable in class com.netflix.genie.common.dto.JobStatusMessages
-
Job precondition was not satisfied during initialization.
- submitJob(JobRequest) - Method in interface com.netflix.genie.client.apis.JobService
-
Method to submit a job to Genie.
- submitJob(JobRequest) - Method in class com.netflix.genie.client.JobClient
-
Submit a job to genie using the jobRequest provided.
- submitJob(JobRequest, String, String, HttpServletRequest) - Method in class com.netflix.genie.web.controllers.JobRestController
-
Submit a new job.
- submitJob(JobRequest, MultipartFile[], String, String, HttpServletRequest) - Method in class com.netflix.genie.web.controllers.JobRestController
-
Submit a new job with attachments.
- submitJob(JobRequest, Cluster, Command, List<Application>, int) - Method in class com.netflix.genie.web.services.impl.LocalJobRunner
-
Submit the job for appropriate execution based on environment.
- submitJob(JobRequest, Cluster, Command, List<Application>, int) - Method in interface com.netflix.genie.web.services.JobSubmitterService
-
Submit the job for appropriate execution based on environment.
- submitJobWithAttachments(JobRequest, List<MultipartBody.Part>) - Method in interface com.netflix.genie.client.apis.JobService
-
Submit a job with attachments.
- submitJobWithAttachments(JobRequest, Map<String, InputStream>) - Method in class com.netflix.genie.client.JobClient
-
Submit a job to genie using the jobRequest and attachments provided.
- SUCCESS - Static variable in class com.netflix.genie.web.util.MetricsConstants.TagValues
-
Tag value to denote success (used with TagKeys.STATUS).
- SUCCESS_EXIT_CODE - Static variable in class com.netflix.genie.common.dto.JobExecution
-
The exit code that will be set to indicate a job has succeeded.
- successLogoutHandler() - Method in class com.netflix.genie.security.saml.SAMLConfig
-
Handler for successful logout.
- successRedirectHandler() - Method in class com.netflix.genie.security.saml.SAMLConfig
-
Handler deciding where to redirect user after successful login.
- SwaggerProperties - Class in com.netflix.genie.web.properties
-
Properties related to Genie and swagger.
- SwaggerProperties() - Constructor for class com.netflix.genie.web.properties.SwaggerProperties
-
- SYSTEM_CRASHED_WHILE_JOB_STARTING - Static variable in class com.netflix.genie.common.dto.JobStatusMessages
-
Job is undefined intermediate state caused by a crash during setup.
- SystemArchitecture - Class in com.netflix.genie.web.aspect
-
Application pointcut expressions.
- SystemArchitecture() - Constructor for class com.netflix.genie.web.aspect.SystemArchitecture
-