Package com.netflix.genie.agent.execution.services.impl

Class ServicesAutoConfiguration

java.lang.Object

com.netflix.genie.agent.execution.services.impl.ServicesAutoConfiguration

@Configuration
@EnableConfigurationProperties(AgentProperties.class)
@AutoConfigureAfter(AwsAutoConfiguration.class)
public class ServicesAutoConfiguration
extends java.lang.Object

Spring auto configuration for the service tier of an Agent process.

Since:

4.0.0

Constructor Summary

Constructors

Constructor	Description
ServicesAutoConfiguration()

Method Summary

Modifier and Type	Method	Description
DownloadService	downloadService(FetchingCacheService fetchingCacheService)	Provide a lazy DownloadService bean if one hasn't already been defined.
FetchingCacheService	fetchingCacheService(org.springframework.core.io.ResourceLoader resourceLoader, ArgumentDelegates.CacheArguments cacheArguments, FileLockFactory fileLockFactory, org.springframework.core.task.TaskExecutor taskExecutor)	Provide a lazy FetchingCacheService instance if one hasn't already been defined.
com.netflix.genie.agent.execution.services.impl.JobMonitorServiceImpl	jobMonitorService(KillService killService, JobDirectoryManifestCreatorService manifestCreatorService, AgentJobService agentJobService, org.springframework.scheduling.TaskScheduler taskScheduler, AgentProperties agentProperties)	Provide a lazy JobMonitorService bean if one hasn't already been defined.
JobSetupService	jobSetupService(DownloadService downloadService, AgentProperties agentProperties)	Provide a lazy JobSetupService bean if one hasn't already been defined.
KillService	killService(com.netflix.genie.agent.execution.statemachine.ExecutionContext executionContext, AgentProperties agentProperties)	Provide a lazy KillService bean if one hasn't already been defined.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ServicesAutoConfiguration

public ServicesAutoConfiguration()

Method Detail

downloadService

@Bean
@Lazy
@ConditionalOnMissingBean(DownloadService.class)
public DownloadService downloadService(FetchingCacheService fetchingCacheService)

Provide a lazy DownloadService bean if one hasn't already been defined.

Parameters:

fetchingCacheService - The cache service to use

Returns:

A DownloadServiceImpl instance

fetchingCacheService

@Bean
@Lazy
@ConditionalOnMissingBean(FetchingCacheService.class)
public FetchingCacheService fetchingCacheService(org.springframework.core.io.ResourceLoader resourceLoader,
                                                 ArgumentDelegates.CacheArguments cacheArguments,
                                                 FileLockFactory fileLockFactory,
                                                 @Qualifier("sharedAgentTaskExecutor")
                                                 org.springframework.core.task.TaskExecutor taskExecutor)
                                          throws java.io.IOException

Provide a lazy FetchingCacheService instance if one hasn't already been defined.

Parameters:

resourceLoader - The Spring Resource loader to use

cacheArguments - The cache command line arguments to use

fileLockFactory - The file lock factory to use

taskExecutor - The task executor to use

Returns:

A FetchingCacheServiceImpl instance

Throws:

java.io.IOException - On error creating the instance

killService

@Bean
@Lazy
@ConditionalOnMissingBean(KillService.class)
public KillService killService(com.netflix.genie.agent.execution.statemachine.ExecutionContext executionContext,
                               AgentProperties agentProperties)

Provide a lazy KillService bean if one hasn't already been defined.

Parameters:

executionContext - the execution context

agentProperties - the agent properties

Returns:

A KillServiceImpl instance

jobSetupService

@Bean
@Lazy
@ConditionalOnMissingBean(JobSetupService.class)
public JobSetupService jobSetupService(DownloadService downloadService,
                                       AgentProperties agentProperties)

Provide a lazy JobSetupService bean if one hasn't already been defined.

Parameters:

downloadService - the download service

agentProperties - the agent properties

Returns:

A JobSetupServiceImpl instance

jobMonitorService

@Bean
@Lazy
@ConditionalOnMissingBean(JobMonitorService.class)
public com.netflix.genie.agent.execution.services.impl.JobMonitorServiceImpl jobMonitorService(KillService killService,
                                                                                               JobDirectoryManifestCreatorService manifestCreatorService,
                                                                                               AgentJobService agentJobService,
                                                                                               @Qualifier("sharedAgentTaskScheduler")
                                                                                               org.springframework.scheduling.TaskScheduler taskScheduler,
                                                                                               AgentProperties agentProperties)

Provide a lazy JobMonitorService bean if one hasn't already been defined.

Parameters:

killService - the kill service

manifestCreatorService - the manifest creator service

agentJobService - the agent job service

taskScheduler - the task scheduler

agentProperties - the agent properties

Returns:

A JobMonitorServiceImpl instance