Package com.linkedin.davinci.kafka.consumer

Class DolStamp

java.lang.Object
com.linkedin.davinci.kafka.consumer.DolStamp
public class DolStamp extends Object
Tracks Declaration of Leadership (DoL) state during STANDBY to LEADER transition. DoL mechanism ensures the new leader is fully caught up with VT before switching to remote VT or RT.

  • Constructor Details

    • DolStamp

      public DolStamp(long leadershipTerm, String hostId)

  • Method Details

    • getLeadershipTerm

      public long getLeadershipTerm()

    • getHostId

      public String getHostId()

    • isDolProduced

      public boolean isDolProduced()

    • setDolProduced

      public void setDolProduced(boolean dolProduced)

    • isDolConsumed

      public boolean isDolConsumed()

    • setDolConsumed

      public void setDolConsumed(boolean dolConsumed)

    • getDolProduceFuture

      public CompletableFuture<PubSubProduceResult> getDolProduceFuture()

    • setDolProduceFuture

      public void setDolProduceFuture(CompletableFuture<PubSubProduceResult> dolProduceFuture)

    • isDolComplete

      public boolean isDolComplete()

    • getProduceStartTimeMs

      public long getProduceStartTimeMs()

    • getLatencyMs

      public long getLatencyMs()
      Calculate latency from DoL production start to now.
      Returns:
      latency in milliseconds

    • toString

      public String toString()
      Overrides:
      toString in class Object