com.netflix.genie.web.services

Interface AgentRoutingService

All Known Implementing Classes:

AgentRoutingServiceImpl

@Validated
public interface AgentRoutingService

Service that tracks agent connections on the local Genie node and provides routing information for agent connected to other nodes.

Since:

4.0.0

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	isAgentConnectionLocal(@NotBlank java.lang.String jobId) Tells wether the agent running a given job is connected to the local node.

Method Detail

getHostnameForAgentConnection

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.

Parameters:

jobId - the job id

Returns:

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

isAgentConnectionLocal

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

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

Parameters:

jobId - the job id

Returns:

true if the agent has an active connection to this node

handleClientConnected

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

Handle a new agent connection.

Parameters:

jobId - the job id the connected agent is running

handleClientDisconnected

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

Handle connected agent disconnection.

Parameters:

jobId - the job id the disconnected agent is running