Package com.linkedin.davinci.stats.ingestion.heartbeat

Class HeartbeatStat

java.lang.Object
com.linkedin.davinci.stats.ingestion.heartbeat.HeartbeatStat
public class HeartbeatStat extends Object

  • Constructor Details

    • HeartbeatStat

      public HeartbeatStat(io.tehuti.metrics.MetricConfig metricConfig, Set<String> regions)

  • Method Details

    • recordReadyToServeLeaderLag

      public void recordReadyToServeLeaderLag(String region, long delay, long endTime)
      Records the heartbeat lag for a ready-to-serve leader replica.
      Parameters:
      region - The region name
      delay - The pre-calculated delay in milliseconds
      endTime - The pre-calculated end time

    • recordReadyToServeFollowerLag

      public void recordReadyToServeFollowerLag(String region, long delay, long endTime)
      Records the heartbeat lag for a ready-to-serve follower replica.
      Parameters:
      region - The region name
      delay - The pre-calculated delay in milliseconds
      endTime - The pre-calculated end time

    • recordCatchingUpFollowerLag

      public void recordCatchingUpFollowerLag(String region, long delay, long endTime)
      Records the heartbeat lag for a catching-up follower replica.
      Parameters:
      region - The region name
      delay - The pre-calculated delay in milliseconds (0 for squelching)
      endTime - The pre-calculated end time

    • getReadyToServeLeaderLag

      public WritePathLatencySensor getReadyToServeLeaderLag(String region)

    • getReadyToServeFollowerLag

      public WritePathLatencySensor getReadyToServeFollowerLag(String region)

    • getCatchingUpFollowerLag

      public WritePathLatencySensor getCatchingUpFollowerLag(String region)