From b070a5ed9f804a93e4640a66af1b6dec20ff1e03 Mon Sep 17 00:00:00 2001 From: Evan Purkhiser Date: Mon, 11 Dec 2023 10:44:34 -0800 Subject: [PATCH] ref(crons): Add documentation to CheckInMessageType --- relay-server/src/actors/store.rs | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/relay-server/src/actors/store.rs b/relay-server/src/actors/store.rs index 737b86b73b..1231db9011 100644 --- a/relay-server/src/actors/store.rs +++ b/relay-server/src/actors/store.rs @@ -1024,6 +1024,11 @@ struct ProfileKafkaMessage { payload: Bytes, } +/// Used to discriminate cron monitor ingestion messages. +/// +/// There are two types of messages that end up in the ingest-monitors kafka topic, "check_in" (the +/// ones produced here in relay) and "clock_pulse" messages, which are produced externally and are +/// intended to ensure the clock continues to run even when ingestion volume drops. #[allow(dead_code)] #[derive(Debug, Serialize)] #[serde(rename_all = "snake_case")]