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

Class AgentConnectionTrackingServiceImpl

java.lang.Object

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

All Implemented Interfaces:

AgentConnectionTrackingService, org.springframework.boot.actuate.info.InfoContributor

public class AgentConnectionTrackingServiceImpl
extends Object
implements AgentConnectionTrackingService, org.springframework.boot.actuate.info.InfoContributor

This service keeps track of agent connections and heartbeats. It notifies the downstream AgentRoutingService of connected/disconnected agents while hiding details of connections, disconnections, missed heartbeats.

Since:

4.0.0

Constructor Summary

Constructors

Constructor	Description
AgentConnectionTrackingServiceImpl(AgentRoutingService agentRoutingService, org.springframework.scheduling.TaskScheduler taskScheduler, AgentConnectionTrackingServiceProperties serviceProperties)	Constructor.

Method Summary

Modifier and Type	Method	Description
void	contribute(org.springframework.boot.actuate.info.Info.Builder builder)
long	getConnectedAgentsCount()	Get the count of locally connected agents.
void	notifyDisconnected(String streamId, String claimedJobId)	Handle a disconnection.
void	notifyHeartbeat(String streamId, String claimedJobId)	Handle a heartbeat.

Methods inherited from class java.lang.Object

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

Constructor Details

AgentConnectionTrackingServiceImpl

public AgentConnectionTrackingServiceImpl(AgentRoutingService agentRoutingService,
 org.springframework.scheduling.TaskScheduler taskScheduler,
 AgentConnectionTrackingServiceProperties serviceProperties)

Constructor.

Parameters:

agentRoutingService - the agent routing service

taskScheduler - the task scheduler

serviceProperties - the service properties

Method Details

notifyHeartbeat

public void notifyHeartbeat(String streamId,
 String claimedJobId)

Handle a heartbeat.

Specified by:

notifyHeartbeat in interface AgentConnectionTrackingService

Parameters:

streamId - the unique id of the connection

claimedJobId - the job id claimed by the agent

notifyDisconnected

public void notifyDisconnected(String streamId,
 String claimedJobId)

Handle a disconnection.

Specified by:

notifyDisconnected in interface AgentConnectionTrackingService

Parameters:

streamId - the unique id of the connection

claimedJobId - the job id claimed by the agent

getConnectedAgentsCount

public long getConnectedAgentsCount()

Get the count of locally connected agents.

Specified by:

getConnectedAgentsCount in interface AgentConnectionTrackingService

Returns:

the number of agents connected.

contribute

public void contribute(org.springframework.boot.actuate.info.Info.Builder builder)

Specified by:

contribute in interface org.springframework.boot.actuate.info.InfoContributor