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

Class AgentServicesAutoConfiguration

java.lang.Object

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

@Configuration
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
AgentFilterServiceImpl	agentFilterService(java.util.List<AgentMetadataInspector> agentMetadataInspectorsList) A AgentFilterService implementation that federates the decision to a set of AgentMetadataInspectors.
AgentJobService	agentJobService(JobPersistenceService jobPersistenceService, JobResolverService jobResolverService, AgentFilterService agentFilterService, io.micrometer.core.instrument.MeterRegistry meterRegistry) Get a AgentJobService instance if there isn't already one.
AgentMetricsServiceImpl	agentMetricsService(GenieHostInfo genieHostInfo, AgentConnectionPersistenceService agentConnectionPersistenceService, io.micrometer.core.instrument.MeterRegistry registry) Provide an implementation of AgentMetricsService if one hasn't been provided.
AgentRoutingService	agentRoutingService(AgentConnectionPersistenceService agentConnectionPersistenceService, 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 AgentJobService agentJobService(JobPersistenceService jobPersistenceService,
                                                                                                     JobResolverService jobResolverService,
                                                                                                     AgentFilterService agentFilterService,
                                                                                                     io.micrometer.core.instrument.MeterRegistry meterRegistry)

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

Parameters:

jobPersistenceService - The persistence service to use

jobResolverService - The specification service to use

agentFilterService - The agent filter service to use

meterRegistry - The metrics registry to use

Returns:

An AgentJobServiceImpl instance.

agentRoutingService

@Bean
 @ConditionalOnMissingBean(value=AgentRoutingService.class)
public AgentRoutingService agentRoutingService(AgentConnectionPersistenceService agentConnectionPersistenceService,
                                                                                                                 GenieHostInfo genieHostInfo)

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

Parameters:

agentConnectionPersistenceService - The persistence service to use for agent connections

genieHostInfo - The local genie host information

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.

agentMetricsService

@Bean
 @ConditionalOnMissingBean(value=AgentMetricsService.class)
public AgentMetricsServiceImpl agentMetricsService(GenieHostInfo genieHostInfo,
                                                                                                                     AgentConnectionPersistenceService agentConnectionPersistenceService,
                                                                                                                     io.micrometer.core.instrument.MeterRegistry registry)

Provide an implementation of AgentMetricsService if one hasn't been provided.

Parameters:

genieHostInfo - The Genie host information

agentConnectionPersistenceService - Implementation of AgentConnectionPersistenceService to get information about running agents in the ecosystem

registry - The metrics repository

Returns:

An instance of AgentMetricsServiceImpl