pub struct ReadMessageQueueResult {
pub rows: Vec<ReadMessageQueueRow>,
}Expand description
Successful payload for Payload::ReadMessageQueue.
One ReadMessageQueueRow per consumed message_queue row,
in oldest-first id order. Each row’s content_ids are the
message_queue_contents.ids for that row’s slots; the row’s
rich_content is the CLI’s reconstructed payload for that
row alone (no cross-row separator splicing — callers join if
they want a unified User message).
Two consumers:
- Startup snapshot (
run_agent_loop): joins every row’s parts with"\n\n"separators, flattenscontent_ids, and stamps the result onto the firstAssistantResponseChunk.request_message_ids. ApiQueueDelegate(agents logs read subscribe-style per-tool-response delivery): keeps rows separate so each gets converted to its ownVec<ContentBlock>and surfaces row-by-row on tool responses.
The downstream LogWriter resolves each id’s kind at write
time (SQL CASE against message_queue_contents.kind) to
dispatch the right logs.message_table variant — kinds don’t
need to ride on the wire.
Fields§
§rows: Vec<ReadMessageQueueRow>Trait Implementations§
Source§impl Clone for ReadMessageQueueResult
impl Clone for ReadMessageQueueResult
Source§fn clone(&self) -> ReadMessageQueueResult
fn clone(&self) -> ReadMessageQueueResult
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for ReadMessageQueueResult
impl Debug for ReadMessageQueueResult
Source§impl<'de> Deserialize<'de> for ReadMessageQueueResult
impl<'de> Deserialize<'de> for ReadMessageQueueResult
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Source§impl JsonSchema for ReadMessageQueueResult
impl JsonSchema for ReadMessageQueueResult
Source§fn schema_id() -> Cow<'static, str>
fn schema_id() -> Cow<'static, str>
Returns a string that uniquely identifies the schema produced by this type. Read more
Source§fn json_schema(generator: &mut SchemaGenerator) -> Schema
fn json_schema(generator: &mut SchemaGenerator) -> Schema
Generates a JSON Schema for this type. Read more
Source§fn inline_schema() -> bool
fn inline_schema() -> bool
Whether JSON Schemas generated for this type should be included directly in parent schemas,
rather than being re-used where possible using the
$ref keyword. Read moreAuto Trait Implementations§
impl Freeze for ReadMessageQueueResult
impl RefUnwindSafe for ReadMessageQueueResult
impl Send for ReadMessageQueueResult
impl Sync for ReadMessageQueueResult
impl Unpin for ReadMessageQueueResult
impl UnsafeUnpin for ReadMessageQueueResult
impl UnwindSafe for ReadMessageQueueResult
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> DeserializeOwned for Twhere
T: for<'de> Deserialize<'de>,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more