Package com.netflix.genie.web.agent.launchers.impl

Class TitusAgentLauncherImpl

java.lang.Object

com.netflix.genie.web.agent.launchers.impl.TitusAgentLauncherImpl

All Implemented Interfaces:

AgentLauncher, org.springframework.boot.actuate.health.HealthContributor, org.springframework.boot.actuate.health.HealthIndicator

public class TitusAgentLauncherImpl
extends Object
implements AgentLauncher

Agent launcher that spawns a job in a dedicated container through Titus.

Since:

4.0.0

See Also:

• Titus OSS Project

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TitusAgentLauncherImpl.TitusAPIRetryPolicy	A retry policy that has different behavior based on the type of exception thrown by the rest client during calls to the Titus API.
static interface	TitusAgentLauncherImpl.TitusJobRequestAdapter	An interface that should be implemented by any class which wants to modify the Titus job request before it is sent.

Field Summary

Fields inherited from interface com.netflix.genie.web.agent.launchers.AgentLauncher

LAUNCH_TIMER, LAUNCHER_CLASS_EXT_FIELD, LAUNCHER_CLASS_KEY, SOURCE_HOST_EXT_FIELD

Constructor Summary

Constructors

Constructor

Description

TitusAgentLauncherImpl(org.springframework.web.client.RestTemplate restTemplate, org.springframework.retry.support.RetryTemplate retryTemplate, TitusAgentLauncherImpl.TitusJobRequestAdapter jobRequestAdapter, com.github.benmanes.caffeine.cache.Cache<String,String> healthIndicatorCache, GenieHostInfo genieHostInfo, TitusAgentLauncherProperties titusAgentLauncherProperties, BraveTracingComponents tracingComponents, org.springframework.core.env.Environment environment, io.micrometer.core.instrument.MeterRegistry registry)

Constructor.

Method Summary

Modifier and Type	Method	Description
org.springframework.boot.actuate.health.Health	health()
Optional<com.fasterxml.jackson.databind.JsonNode>	launchAgent(ResolvedJob resolvedJob, com.fasterxml.jackson.databind.JsonNode requestedLauncherExt)	Launch an agent to execute the given ResolvedJob information.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.boot.actuate.health.HealthIndicator

getHealth

Constructor Details

TitusAgentLauncherImpl

public TitusAgentLauncherImpl(org.springframework.web.client.RestTemplate restTemplate,
 org.springframework.retry.support.RetryTemplate retryTemplate,
 TitusAgentLauncherImpl.TitusJobRequestAdapter jobRequestAdapter,
 com.github.benmanes.caffeine.cache.Cache<String,String> healthIndicatorCache,
 GenieHostInfo genieHostInfo,
 TitusAgentLauncherProperties titusAgentLauncherProperties,
 BraveTracingComponents tracingComponents,
 org.springframework.core.env.Environment environment,
 io.micrometer.core.instrument.MeterRegistry registry)

Constructor.

Parameters:

restTemplate - the rest template

retryTemplate - The RetryTemplate to use when making Titus API calls

jobRequestAdapter - The implementation of TitusAgentLauncherImpl.TitusJobRequestAdapter to use

healthIndicatorCache - a cache to store metadata about recently launched jobs

genieHostInfo - the metadata about the local server and host

titusAgentLauncherProperties - the configuration properties

tracingComponents - The BraveTracingComponents instance to use for distributed tracing

environment - The application environment to pull dynamic properties from

registry - the metric registry

Method Details

launchAgent

public Optional<com.fasterxml.jackson.databind.JsonNode> launchAgent(ResolvedJob resolvedJob,
 @Nullable
 com.fasterxml.jackson.databind.JsonNode requestedLauncherExt)
                                                              throws AgentLaunchException

Launch an agent to execute the given ResolvedJob information.

Specified by:

launchAgent in interface AgentLauncher

Parameters:

resolvedJob - The ResolvedJob information for the agent to act on

requestedLauncherExt - The launcher requested extension, or null

Returns:

an optional JsonNode with the launcher context about the launched job

Throws:

AgentLaunchException - For any error launching an Agent instance to run the job

health

public org.springframework.boot.actuate.health.Health health()

Specified by:

health in interface org.springframework.boot.actuate.health.HealthIndicator