com.netflix.genie.common.internal.configs

Class CommonServicesAutoConfiguration

java.lang.Object

com.netflix.genie.common.internal.configs.CommonServicesAutoConfiguration

@Configuration
 @EnableConfigurationProperties(value=RegexDirectoryManifestProperties.class)
public class CommonServicesAutoConfiguration
extends java.lang.Object

Auto configuration of any services that are common to both the agent and the server.

Since:

4.0.0

Field Summary

Fields

Modifier and Type	Field and Description
static int	FILE_SYSTEM_JOB_ARCHIVER_PRECEDENCE Constant allowing developers to reference the precedence in their own configuration files.

Constructor Summary

Constructors

Constructor and Description
CommonServicesAutoConfiguration()

Method Summary

Modifier and Type	Method and Description
DirectoryManifest.Factory	directoryManifestFactory(DirectoryManifest.Filter directoryManifestFilter) Provide a DirectoryManifest.Factory if no override is defined.
DirectoryManifest.Filter	directoryManifestFilter(RegexDirectoryManifestProperties properties) Provide a DirectoryManifest.Filter that filters files and/or prunes directories based on a set of regular expression patterns provided via properties.
FileSystemJobArchiverImpl	fileSystemJobArchiver() Provide a JobArchiver implementation that will copy from one place on the filesystem to another.
JobArchiveService	jobArchiveService(java.util.List<JobArchiver> jobArchivers, DirectoryManifest.Factory directoryManifestFactory) Provide a default JobArchiveService if no override is defined.
com.github.benmanes.caffeine.cache.Cache<java.nio.file.Path,DirectoryManifest>	jobDirectoryManifestCache() Provide a Cache<Path, DirectoryManifest> named "jobDirectoryManifestCache" if no override is defined.
JobDirectoryManifestCreatorServiceImpl	jobDirectoryManifestCreatorService(DirectoryManifest.Factory directoryManifestFactory, com.github.benmanes.caffeine.cache.Cache<java.nio.file.Path,DirectoryManifest> cache) Provide a JobDirectoryManifestCreatorService if no override is defined.

Methods inherited from class java.lang.Object

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

Field Detail

FILE_SYSTEM_JOB_ARCHIVER_PRECEDENCE

public static final int FILE_SYSTEM_JOB_ARCHIVER_PRECEDENCE

Constant allowing developers to reference the precedence in their own configuration files.

See Also:

Ordered, Constant Field Values

Constructor Detail

CommonServicesAutoConfiguration

public CommonServicesAutoConfiguration()

Method Detail

fileSystemJobArchiver

@Bean
 @Order(value=2147483627)
public FileSystemJobArchiverImpl fileSystemJobArchiver()

Provide a JobArchiver implementation that will copy from one place on the filesystem to another.

Returns:

A FileSystemJobArchiverImpl instance

jobArchiveService

@Bean
 @ConditionalOnMissingBean(value=JobArchiveService.class)
public JobArchiveService jobArchiveService(java.util.List<JobArchiver> jobArchivers,
                                                                                                           DirectoryManifest.Factory directoryManifestFactory)

Provide a default JobArchiveService if no override is defined.

Parameters:

jobArchivers - The ordered available JobArchiver implementations in the system

directoryManifestFactory - the job directory manifest factory

Returns:

A JobArchiveServiceImpl instance

jobDirectoryManifestCreatorService

@Bean
 @ConditionalOnMissingBean(value=JobDirectoryManifestCreatorService.class)
public JobDirectoryManifestCreatorServiceImpl jobDirectoryManifestCreatorService(DirectoryManifest.Factory directoryManifestFactory,
                                                                                                                                                                  @Qualifier(value="jobDirectoryManifestCache")
                                                                                                                                                                  com.github.benmanes.caffeine.cache.Cache<java.nio.file.Path,DirectoryManifest> cache)

Provide a JobDirectoryManifestCreatorService if no override is defined. The manifest produced by this service do not include checksum for entries and caches manifests recently created.

Parameters:

directoryManifestFactory - the factory to produce the manifest if needed

cache - the cache to use

Returns:

a JobDirectoryManifestCreatorService

jobDirectoryManifestCache

@Bean(name="jobDirectoryManifestCache")
 @ConditionalOnMissingBean(name="jobDirectoryManifestCache")
public com.github.benmanes.caffeine.cache.Cache<java.nio.file.Path,DirectoryManifest> jobDirectoryManifestCache()

Provide a Cache<Path, DirectoryManifest> named "jobDirectoryManifestCache" if no override is defined.

Returns:

a Cache

directoryManifestFactory

@Bean
 @ConditionalOnMissingBean(value=DirectoryManifest.Factory.class)
public DirectoryManifest.Factory directoryManifestFactory(DirectoryManifest.Filter directoryManifestFilter)

Provide a DirectoryManifest.Factory if no override is defined.

Parameters:

directoryManifestFilter - the filter used during manifest creation

Returns:

a directory manifest factory

directoryManifestFilter

@Bean
 @ConditionalOnMissingBean(value=DirectoryManifest.Filter.class)
public DirectoryManifest.Filter directoryManifestFilter(RegexDirectoryManifestProperties properties)

Provide a DirectoryManifest.Filter that filters files and/or prunes directories based on a set of regular expression patterns provided via properties.

Parameters:

properties - the properties

Returns:

a directory manifest filter