Class HeartbeatKey
java.lang.Object
com.linkedin.davinci.stats.ingestion.heartbeat.HeartbeatKey
Composite key for the flattened heartbeat timestamp map.
Identity is (storeName, version, partition, region). The SLO classification
labels writeType, chunkingStatus, locality, replicationMode
are passenger fields: resolved once when the caller (SIT) builds the key, carried along the
per-record hot path to avoid repeated derivation, and intentionally excluded from
equals(java.lang.Object)/hashCode.
-
Constructor Summary
ConstructorsConstructorDescriptionHeartbeatKey(String storeName, int version, int partition, String region) Lookup-only constructor: builds a key without the SLO labels.HeartbeatKey(String storeName, int version, int partition, String region, VeniceStoreWriteType writeType, VeniceChunkingStatus chunkingStatus, VeniceRegionLocality locality) Deprecated.HeartbeatKey(String storeName, int version, int partition, String region, VeniceStoreWriteType writeType, VeniceChunkingStatus chunkingStatus, VeniceRegionLocality locality, VeniceReplicationMode replicationMode) -
Method Summary
Modifier and TypeMethodDescriptionbooleanPublic accessor for cross-package tests; the package-private field is the canonical source.Public accessor for cross-package tests; the package-private field is the canonical source.Public accessor for cross-package tests; the package-private field is the canonical source.Public accessor for cross-package tests; the package-private field is the canonical source.inthashCode()toString()
-
Constructor Details
-
HeartbeatKey
Lookup-only constructor: builds a key without the SLO labels. Use only when the resulting key is consumed for identity (map lookup, equality) and never flows to per-record OTel emission. The canonical hot-path constructor is the 8-arg variant below — that one is what the SIT/PCS pipeline uses so each record carries pre-resolved enum references. -
HeartbeatKey
@Deprecated public HeartbeatKey(String storeName, int version, int partition, String region, VeniceStoreWriteType writeType, VeniceChunkingStatus chunkingStatus, VeniceRegionLocality locality) Deprecated.use the 8-arg constructor so the key also carriesVeniceReplicationMode. Retained for source/binary compatibility with existing callers of this previously-canonical 7-arg constructor. Since keys built here can still reach per-record OTel emission (e.g. viarecordLeaderRecordTimestamp/recordFollowerRecordTimestamp), which rejects anulldimension value,replicationModedefaults toVeniceReplicationMode.ACTIVE_ACTIVErather thannull. Active-active is the safer default because it is the stricter/superset classification: it never claims a cross-region-replicated store is exempt from AA overhead. -
HeartbeatKey
public HeartbeatKey(String storeName, int version, int partition, String region, VeniceStoreWriteType writeType, VeniceChunkingStatus chunkingStatus, VeniceRegionLocality locality, VeniceReplicationMode replicationMode)
-
-
Method Details
-
getWriteType
Public accessor for cross-package tests; the package-private field is the canonical source. -
getChunkingStatus
Public accessor for cross-package tests; the package-private field is the canonical source. -
getLocality
Public accessor for cross-package tests; the package-private field is the canonical source. -
getReplicationMode
Public accessor for cross-package tests; the package-private field is the canonical source. -
equals
-
hashCode
public int hashCode() -
toString
-
VeniceReplicationMode.