Skip to content

Commit

Permalink
Describe publish states
Browse files Browse the repository at this point in the history
  • Loading branch information
rdettai committed Sep 2, 2024
1 parent 189ebae commit 42c1735
Showing 1 changed file with 5 additions and 0 deletions.
5 changes: 5 additions & 0 deletions quickwit/quickwit-ingest/src/ingest_v2/workbench.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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),
}

Expand Down

0 comments on commit 42c1735

Please sign in to comment.