com.netflix.genie.web.agent.services.impl

Class AgentRoutingServiceSingleNodeImpl

java.lang.Object

com.netflix.genie.web.agent.services.impl.AgentRoutingServiceSingleNodeImpl

All Implemented Interfaces:

AgentRoutingService

@Validated
public class AgentRoutingServiceSingleNodeImpl
extends java.lang.Object
implements AgentRoutingService

Implementation of AgentRoutingService that assumes a single Genie node and tracks connections in-memory.

Since:

4.0.0

Constructor Summary

Constructors

Constructor and Description
AgentRoutingServiceSingleNodeImpl(GenieHostInfo genieHostInfo) Constructor.

Method Summary

Modifier and Type	Method and Description
java.util.Optional<java.lang.String>	getHostnameForAgentConnection(@NotBlank java.lang.String jobId) Look up the hostname of the Genie node currently handling the agent connection for a given job.
void	handleClientConnected(@NotBlank java.lang.String jobId) Handle a new agent connection.
void	handleClientDisconnected(@NotBlank java.lang.String jobId) Handle connected agent disconnection.
boolean	isAgentConnected(java.lang.String jobId) Whether the agent executing a given job is currently connected.
boolean	isAgentConnectionLocal(@NotBlank java.lang.String jobId) Tells whether the agent running a given job is connected to the local node.

Methods inherited from class java.lang.Object

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

Constructor Detail

AgentRoutingServiceSingleNodeImpl

public AgentRoutingServiceSingleNodeImpl(GenieHostInfo genieHostInfo)

Constructor.

Parameters:

genieHostInfo - local genie node host information

Method Detail

getHostnameForAgentConnection

public java.util.Optional<java.lang.String> getHostnameForAgentConnection(@NotBlank
                                                                          @NotBlank java.lang.String jobId)

Look up the hostname of the Genie node currently handling the agent connection for a given job.

Specified by:

getHostnameForAgentConnection in interface AgentRoutingService

Parameters:

jobId - the job id

Returns:

a boxed hostname string, empty if the connection for the given job id is not found

isAgentConnectionLocal

public boolean isAgentConnectionLocal(@NotBlank
                                      @NotBlank java.lang.String jobId)

Tells whether the agent running a given job is connected to the local node.

Specified by:

isAgentConnectionLocal in interface AgentRoutingService

Parameters:

jobId - the job id

Returns:

true if the agent has an active connection to this node

handleClientConnected

public void handleClientConnected(@NotBlank
                                  @NotBlank java.lang.String jobId)

Handle a new agent connection.

Specified by:

handleClientConnected in interface AgentRoutingService

Parameters:

jobId - the job id the connected agent is running

handleClientDisconnected

public void handleClientDisconnected(@NotBlank
                                     @NotBlank java.lang.String jobId)

Handle connected agent disconnection.

Specified by:

handleClientDisconnected in interface AgentRoutingService

Parameters:

jobId - the job id the disconnected agent is running

isAgentConnected

public boolean isAgentConnected(java.lang.String jobId)

Whether the agent executing a given job is currently connected.

Specified by:

isAgentConnected in interface AgentRoutingService

Parameters:

jobId - the job id

Returns:

true if an agent running the job is connected