Struct Conversation 

pub struct Conversation {

    pub _id: u64,
    pub user: Principal,
    pub thread: Option<Xid>,
    pub messages: Vec<Json>,
    pub resources: Vec<Resource>,
    pub artifacts: Vec<Resource>,
    pub status: ConversationStatus,
    pub failed_reason: Option<String>,
    pub usage: Usage,
    pub steering_messages: Option<Vec<String>>,
    pub follow_up_messages: Option<Vec<String>>,
    pub child: Option<u64>,
    pub ancestors: Option<Vec<u64>>,
    pub label: Option<String>,
    pub extra: Option<Json>,
    pub period: u64,
    pub created_at: u64,
    pub updated_at: u64,
}

Conversation record stored in the memory database.

Schema version: 4

Fields

_id: u64

Unique collection identifier assigned by AndaDB.

user: Principal

Principal that owns the conversation.

thread: Option<Xid>

Optional thread identifier used to group related conversation turns.

messages: Vec<Json>

Serialized chat messages accumulated for the conversation.

resources: Vec<Resource>

The request resources used by the agent to process the conversation.

artifacts: Vec<Resource>

A collection of artifacts generated by the agent during the execution of the task.

status: ConversationStatus

Current lifecycle state of the conversation.

failed_reason: Option<String>

Failure reason recorded when the conversation did not complete.

usage: Usage

The LLM usage statistics for the conversation.

steering_messages: Option<Vec<String>>

Messages queued to interrupt the agent mid-run.

They are delivered after the current tool execution and skip remaining pending tools.

follow_up_messages: Option<Vec<String>>

Follow-up messages queued for the agent’s next safe user turn.

They are delivered with the current pending tool-call results when they finish, or at the next idle boundary when no tools are pending. Steering still takes priority.

child: Option<u64>

The child conversation ID, if this conversation has been continued. Should not be updated after set.

ancestors: Option<Vec<u64>>

The ancestor conversation IDs, ordered from root to parent. Should not be updated after creation.

label: Option<String>

An optional label for the conversation, which can be used for categorization or retrieval.

extra: Option<Json>

Extra information for future extensions.

This field is not indexed and should not be used for filtering or searching.

period: u64

The period when the conversation was created, in hours (timestamp / 3600 / 1000). It is used to index the conversation for faster retrieval by time.

created_at: u64

The timestamp when the conversation was created, in milliseconds.

updated_at: u64

The timestamp when the conversation was updated, in milliseconds.

Implementations

impl Conversation

pub fn schema() -> Result<Schema, SchemaError>

Returns the AndaDB Schema derived from this struct’s serialized fields.

The _id primary-key column is injected automatically by the schema builder. Generated by #[derive(AndaDBSchema)].

impl Conversation

pub fn append_messages(&mut self, message: Vec<Message>)

Appends messages to the serialized chat history.

pub fn to_changes(&self) -> Result<BTreeMap<String, Fv>, BoxError>

Converts mutable conversation fields into AndaDB update values.

pub fn to_delta( &self, messages_offset: usize, artifacts_offset: usize, ) -> ConversationDelta

Builds an incremental delta from borrowed conversation data.

pub fn into_delta( self, messages_offset: usize, artifacts_offset: usize, ) -> ConversationDelta

Builds an incremental delta while consuming the conversation.

Trait Implementations

impl Clone for Conversation

fn clone(&self) -> Conversation

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Conversation

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

Formats the value using the given formatter.

impl Default for Conversation

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for Conversation

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<'a> From<&'a Conversation> for ConversationRef<'a>

fn from(conversation: &'a Conversation) -> Self

Converts to this type from the input type.

impl From<&Conversation> for ConversationState

fn from(conversation: &Conversation) -> Self

Converts to this type from the input type.

impl From<Conversation> for Document

fn from(conversation: Conversation) -> Self

Converts to this type from the input type.

impl Serialize for Conversation

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.