You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@maka.apache.org by wy...@apache.org on 2026/10/16 10:15:19 UTC
(maka) 01/06: refactor(event-log): stop loading unused observation queues
This is an automated email from the ASF dual-hosted git repository.
M4n5ter pushed a commit to branch rust-preview
in repository https://gitbox.apache.org/repos/asf/maka.git
commit c3d909b3c7f59d436e81716f7acf559eb4b5ceec
Author: Wang <m4...@gmail.com>
AuthorDate: Fri Oct 16 17:58:53 2026 +0800
refactor(event-log): stop loading unused observation queues
Keep queue reads on the existing independent revisioned API instead of loading and decoding admissions for every session projection.
Generated-by: Codex
---
platform/event-log/src/observation.rs | 5 -----
1 file changed, 5 deletions(-)
diff --git a/platform/event-log/src/observation.rs b/platform/event-log/src/observation.rs
index 5e66987a87..74763f9703 100644
--- a/platform/event-log/src/observation.rs
+++ b/platform/event-log/src/observation.rs
@@ -40,7 +40,6 @@ pub struct SessionObservation<T> {
pub active_streams: Vec<AssistantStreamSeed>,
pub compacting: bool,
pub pending_interactions: Vec<InteractionRecord>,
- pub message_queue: crate::message_queue::MessageQueue,
}
/// Projection-only read: no stream offset aggregation on token wakeups.
@@ -49,7 +48,6 @@ pub struct SessionProjection<T> {
pub root_turn: Option<turns::TurnBoundary>,
pub through_sequence: u64,
pub pending_interactions: Vec<InteractionRecord>,
- pub message_queue: crate::message_queue::MessageQueue,
}
/// Cheap invalidation basis for an observer, not a delivery or replay cursor.
@@ -161,7 +159,6 @@ impl EventLog {
root_turn,
through_sequence,
pending_interactions,
- message_queue,
}) = read_projection(&mut transaction, &session_id).await?
else {
return Ok(None);
@@ -178,7 +175,6 @@ impl EventLog {
active_streams,
compacting,
pending_interactions,
- message_queue,
}))
})
})
@@ -268,7 +264,6 @@ async fn read_projection<T: DeserializeOwned + Send>(
root_turn: turns::read(connection, session_id, None).await?,
through_sequence: high_water(connection).await?,
pending_interactions: crate::interactions::pending(connection, session_id).await?,
- message_queue: crate::message_queue::read(connection, session_id).await?,
}))
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@maka.apache.org
For additional commands, e-mail: commits-help@maka.apache.org