com.netflix.genie.web.spring.autoconfigure.agent.services

Class AgentServicesAutoConfiguration

java.lang.Object

com.netflix.genie.web.spring.autoconfigure.agent.services.AgentServicesAutoConfiguration

@Configuration
 @EnableConfigurationProperties(value=AgentConfigurationProperties.class)
public class AgentServicesAutoConfiguration
extends java.lang.Object

Auto configuration for services needed in the agent module.

Since:

4.0.0

Constructor Summary

Constructors

Constructor and Description
AgentServicesAutoConfiguration()

Method Summary

Modifier and Type	Method and Description
AgentConfigurationServiceImpl	agentConfigurationService(AgentConfigurationProperties agentConfigurationProperties, org.springframework.core.env.Environment environment) Provide a AgentConfigurationService if one is not defined.
AgentConnectionTrackingService	agentConnectionTrackingService(AgentRoutingService agentRoutingService, org.springframework.scheduling.TaskScheduler taskScheduler) Get an implementation of AgentConnectionTrackingService if one hasn't already been defined.
AgentFilterServiceImpl	agentFilterService(java.util.List<AgentMetadataInspector> agentMetadataInspectorsList) A AgentFilterService implementation that federates the decision to a set of AgentMetadataInspectors.
AgentJobServiceImpl	agentJobService(DataServices dataServices, JobResolverService jobResolverService, AgentFilterService agentFilterService, AgentConfigurationService agentConfigurationService, io.micrometer.core.instrument.MeterRegistry meterRegistry) Get a AgentJobService instance if there isn't already one.
AgentRoutingService	agentRoutingServiceCurator(GenieHostInfo genieHostInfo, org.apache.curator.x.discovery.ServiceDiscovery<AgentRoutingServiceCuratorDiscoveryImpl.Agent> serviceDiscovery, org.springframework.scheduling.TaskScheduler taskScheduler, org.apache.curator.framework.listen.Listenable<org.apache.curator.framework.state.ConnectionStateListener> listenableCuratorConnectionState, io.micrometer.core.instrument.MeterRegistry registry) Get an implementation of AgentRoutingService if one hasn't already been defined.
AgentRoutingService	agentRoutingServicePersistence(PersistenceService persistenceService, GenieHostInfo genieHostInfo) Get an implementation of AgentRoutingService 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

AgentServicesAutoConfiguration

public AgentServicesAutoConfiguration()

Method Detail

agentJobService

@Bean
 @ConditionalOnMissingBean(value=AgentJobService.class)
public AgentJobServiceImpl agentJobService(DataServices dataServices,
                                                                                                         JobResolverService jobResolverService,
                                                                                                         AgentFilterService agentFilterService,
                                                                                                         AgentConfigurationService agentConfigurationService,
                                                                                                         io.micrometer.core.instrument.MeterRegistry meterRegistry)

Get a AgentJobService instance if there isn't already one.

Parameters:

dataServices - The DataServices instance to use

jobResolverService - The specification service to use

agentFilterService - The agent filter service to use

agentConfigurationService - The agent configuration service

meterRegistry - The metrics registry to use

Returns:

An AgentJobServiceImpl instance.

agentConnectionTrackingService

@Bean
 @ConditionalOnMissingBean(value=AgentConnectionTrackingService.class)
public AgentConnectionTrackingService agentConnectionTrackingService(AgentRoutingService agentRoutingService,
                                                                                                                                                  @Qualifier(value="genieTaskScheduler")
                                                                                                                                                  org.springframework.scheduling.TaskScheduler taskScheduler)

Get an implementation of AgentConnectionTrackingService if one hasn't already been defined.

Parameters:

agentRoutingService - the agent routing service

taskScheduler - the task scheduler

Returns:

A AgentConnectionTrackingServiceImpl instance

agentRoutingServicePersistence

@Bean
 @ConditionalOnMissingBean(value={AgentRoutingService.class,org.apache.curator.x.discovery.ServiceDiscovery.class})
public AgentRoutingService agentRoutingServicePersistence(PersistenceService persistenceService,
                                                                                                                                                                                    GenieHostInfo genieHostInfo)

Get an implementation of AgentRoutingService if one hasn't already been defined. This bean is created if Zookeeper is disabled. This implementation stores connections using persistence service.

Parameters:

persistenceService - The persistence service to use for agent connections

genieHostInfo - The local genie host information

Returns:

A AgentRoutingServiceImpl instance

agentRoutingServiceCurator

@Bean
 @ConditionalOnBean(value=org.apache.curator.x.discovery.ServiceDiscovery.class)
 @ConditionalOnMissingBean(value=AgentRoutingService.class)
public AgentRoutingService agentRoutingServiceCurator(GenieHostInfo genieHostInfo,
                                                                                                                                                                                                         org.apache.curator.x.discovery.ServiceDiscovery<AgentRoutingServiceCuratorDiscoveryImpl.Agent> serviceDiscovery,
                                                                                                                                                                                                         @Qualifier(value="genieTaskScheduler")
                                                                                                                                                                                                         org.springframework.scheduling.TaskScheduler taskScheduler,
                                                                                                                                                                                                         org.apache.curator.framework.listen.Listenable<org.apache.curator.framework.state.ConnectionStateListener> listenableCuratorConnectionState,
                                                                                                                                                                                                         io.micrometer.core.instrument.MeterRegistry registry)

Get an implementation of AgentRoutingService if one hasn't already been defined. This bean is created if Zookeeper is enabled, it uses Curator's ServiceDiscovery.

Parameters:

genieHostInfo - The local genie host information

serviceDiscovery - The Zookeeper Curator service discovery

taskScheduler - The task scheduler

listenableCuratorConnectionState - the connection state listenable

registry - The metrics registry

Returns:

A AgentRoutingServiceImpl instance

agentFilterService

@Bean
 @ConditionalOnMissingBean(value=AgentFilterService.class)
public AgentFilterServiceImpl agentFilterService(java.util.List<AgentMetadataInspector> agentMetadataInspectorsList)

A AgentFilterService implementation that federates the decision to a set of AgentMetadataInspectors.

Parameters:

agentMetadataInspectorsList - the list of inspectors.

Returns:

An AgentFilterService instance.

agentConfigurationService

@Bean
 @ConditionalOnMissingBean(value=AgentConfigurationService.class)
public AgentConfigurationServiceImpl agentConfigurationService(AgentConfigurationProperties agentConfigurationProperties,
                                                                                                                                       org.springframework.core.env.Environment environment)

Provide a AgentConfigurationService if one is not defined.

Parameters:

agentConfigurationProperties - the service properties

environment - the environment

Returns:

a AgentConfigurationService instance