Struct MessagesValue 

pub struct MessagesValue { /* private fields */ }

Available on crate features functional and graph only.

Chat message container with ID-based deduplication.

Messages with the same ID are replaced (upsert semantics). The container maintains insertion order and provides O(1) dedup lookup via an internal index that is rebuilt on deserialization.

Example

use adk_graph::functional::messages::{MessagesValue, ChatMessage, MessageRole};

let mut messages = MessagesValue::new();
messages.push(ChatMessage {
    id: "msg_1".to_string(),
    role: MessageRole::User,
    content: "Hello".to_string(),
    metadata: None,
});

// Pushing a message with the same ID replaces the existing one.
messages.push(ChatMessage {
    id: "msg_1".to_string(),
    role: MessageRole::User,
    content: "Hello, updated!".to_string(),
    metadata: None,
});

assert_eq!(messages.len(), 1);
assert_eq!(messages.iter().next().unwrap().content, "Hello, updated!");

Implementations

impl MessagesValue

pub fn new() -> MessagesValue

Create an empty message collection.

pub fn push(&mut self, message: ChatMessage)

Append a message (replaces existing if same ID — upsert semantics).

pub fn extend(&mut self, messages: impl IntoIterator<Item = ChatMessage>)

Extend with multiple messages, applying upsert semantics for each.

pub fn iter(&self) -> impl Iterator<Item = &ChatMessage>

Iterate over all messages in insertion order.

pub fn by_role(&self, role: MessageRole) -> Vec<&ChatMessage>

Filter messages by role.

pub fn len(&self) -> usize

Number of messages.

pub fn is_empty(&self) -> bool

Check if empty.

Trait Implementations

impl Clone for MessagesValue

fn clone(&self) -> MessagesValue

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for MessagesValue

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Default for MessagesValue

fn default() -> MessagesValue

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for MessagesValue

fn deserialize<D>( deserializer: D, ) -> Result<MessagesValue, <D as Deserializer<'de>>::Error>

where D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for MessagesValue

fn serialize<S>( &self, serializer: S, ) -> Result<<S as Serializer>::Ok, <S as Serializer>::Error>

where S: Serializer,

Serialize this value into the given Serde serializer.