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

Interface AgentConnectionTrackingService

All Known Implementing Classes:
AgentConnectionTrackingServiceImpl
public interface AgentConnectionTrackingService
Tracks active connections and heartbeats coming from agents actively executing a job.
Since:
4.0.0

  • Method Details

    • notifyHeartbeat

      void notifyHeartbeat(String streamId, String claimedJobId)
      Handle a heartbeat.
      Parameters:
      streamId - the unique id of the connection
      claimedJobId - the job id claimed by the agent

    • notifyDisconnected

      void notifyDisconnected(String streamId, String claimedJobId)
      Handle a disconnection.
      Parameters:
      streamId - the unique id of the connection
      claimedJobId - the job id claimed by the agent

    • getConnectedAgentsCount

      long getConnectedAgentsCount()
      Get the count of locally connected agents.
      Returns:
      the number of agents connected.