com.netflix.genie.web.data.services

Interface AgentConnectionPersistenceService

All Known Implementing Classes:

JpaAgentConnectionPersistenceServiceImpl

@Validated
public interface AgentConnectionPersistenceService

Persistence service to store and lookup which server is a given job/agent connected to.

Since:

4.0.0

Method Summary

Modifier and Type	Method and Description
long	getNumAgentConnectionsOnServer(@NotBlank java.lang.String hostname) Get the number of active agent connections on Genie server with the given hostname.
java.util.Optional<java.lang.String>	lookupAgentConnectionServer(@NotBlank java.lang.String jobId) Lookup the hostname/address of the server with an active connection to a given agent.
void	removeAgentConnection(@NotBlank java.lang.String jobId, @NotBlank java.lang.String hostname) Remove an existing connection currently active from the given agent to the local node.
int	removeAllAgentConnectionToServer(@NotBlank java.lang.String hostname) Drop all records of agent connections to the specified hostname.
void	saveAgentConnection(@NotBlank java.lang.String jobId, @NotBlank java.lang.String hostname) Store a new connection currently active from the given agent to the given node.

Method Detail

saveAgentConnection

void saveAgentConnection(@NotBlank
                         @NotBlank java.lang.String jobId,
                         @NotBlank
                         @NotBlank java.lang.String hostname)

Store a new connection currently active from the given agent to the given node.

Parameters:

jobId - the id of a job the agent is running

hostname - the server owning the connection

removeAgentConnection

void removeAgentConnection(@NotBlank
                           @NotBlank java.lang.String jobId,
                           @NotBlank
                           @NotBlank java.lang.String hostname)

Remove an existing connection currently active from the given agent to the local node. The entity won't be deleted if it was already modified by a different server.

Parameters:

jobId - the id of a job the agent is running

hostname - the hostname expected to be associated to the connection

lookupAgentConnectionServer

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

Lookup the hostname/address of the server with an active connection to a given agent.

Parameters:

jobId - the id of a job the agent is running

Returns:

the server hostname or empty

getNumAgentConnectionsOnServer

long getNumAgentConnectionsOnServer(@NotBlank
                                    @NotBlank java.lang.String hostname)

Get the number of active agent connections on Genie server with the given hostname.

Parameters:

hostname - The server hostname to get the count for

Returns:

The number of agents currently connected to the given server

removeAllAgentConnectionToServer

int removeAllAgentConnectionToServer(@NotBlank
                                     @NotBlank java.lang.String hostname)

Drop all records of agent connections to the specified hostname. This can be used to conveniently clean data related to a host when failure of the latter is detected.

Parameters:

hostname - the server hostname

Returns:

the number of connections purged from persistent storage