com.netflix.genie.web.data.repositories.jpa

Interface JpaAgentConnectionRepository

public interface JpaAgentConnectionRepository

JPA repository for active agent-to-server connections.

Since:

4.0.0

Method Summary

Modifier and Type	Method and Description
long	countByServerHostnameEquals(@NotBlank java.lang.String serverHostName) Find the number of agents currently connected to the given server identified by serverHostName.
int	deleteByServerHostnameEquals(java.lang.String serverHostName) Delete all rows associated with a given server identified by serverHostName.
java.util.Optional<AgentConnectionEntity>	findByJobId(@NotBlank java.lang.String jobId) Find entity by jobId.

Methods inherited from interface org.springframework.data.jpa.repository.JpaRepository

deleteAllInBatch, deleteInBatch, findAll, findAll, findAll, findAll, findAllById, flush, getOne, saveAll, saveAndFlush

Methods inherited from interface org.springframework.data.repository.PagingAndSortingRepository

findAll

Methods inherited from interface org.springframework.data.repository.CrudRepository

count, delete, deleteAll, deleteAll, deleteById, existsById, findById, save

Methods inherited from interface org.springframework.data.repository.query.QueryByExampleExecutor

count, exists, findAll, findOne

Methods inherited from interface org.springframework.data.jpa.repository.JpaSpecificationExecutor

count, findAll, findAll, findAll, findOne

Method Detail

findByJobId

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

Find entity by jobId.

Parameters:

jobId - job id

Returns:

an optional, containing the entity if it exists

countByServerHostnameEquals

long countByServerHostnameEquals(@NotBlank
                                 @NotBlank java.lang.String serverHostName)

Find the number of agents currently connected to the given server identified by serverHostName.

Parameters:

serverHostName - The hostname of the server to get the number of connections for

Returns:

The number of connections on the given server

deleteByServerHostnameEquals

int deleteByServerHostnameEquals(java.lang.String serverHostName)

Delete all rows associated with a given server identified by serverHostName.

Parameters:

serverHostName - The hostname of the server whose connections to purge

Returns:

the number of deleted records