From 42c1735e7ee0e30c0c9b69e61041f487ff4a9ca6 Mon Sep 17 00:00:00 2001 From: Remi Dettai Date: Fri, 30 Aug 2024 16:35:49 +0200 Subject: [PATCH] Describe publish states --- quickwit/quickwit-ingest/src/ingest_v2/workbench.rs | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/quickwit/quickwit-ingest/src/ingest_v2/workbench.rs b/quickwit/quickwit-ingest/src/ingest_v2/workbench.rs index 23c4790f7e6..b181cb6a47a 100644 --- a/quickwit/quickwit-ingest/src/ingest_v2/workbench.rs +++ b/quickwit/quickwit-ingest/src/ingest_v2/workbench.rs @@ -40,8 +40,13 @@ use tracing::{error, warn}; use super::router::PersistRequestSummary; enum PublishState { + /// The persist request for this shard has been sent Tracked, + /// The persist request for this shard success response has been received + /// but the position has not yet been published AwaitingPublish(Position), + /// The shard has been published up to this position (might happen before + /// the persist success is received) Published(Position), }