Struct MessagesState 

pub struct MessagesState {
    pub messages: Vec<Message>,
}

Built-in state for simple chat agents

Provides a zero-config entry point for simple chat agents with a single messages field using the messages reducer semantics.

Examples

use juncture_core::state::messages::{MessagesState, Message};

let mut state = MessagesState::default();
state.messages.push(Message::human("Hello"));
state.messages.push(Message::ai("Hi there!"));

Fields

messages: Vec<Message>

Message history using append+merge+delete semantics

Implementations

impl MessagesState

pub fn try_apply_messages( &mut self, update: MessagesStateUpdate, ) -> Result<FieldsChanged, InvalidUpdateError>

Apply an update with structured error propagation for reducer violations

The messages reducer is an append+merge+delete reducer that never conflicts, so this always succeeds. Provided for trait consistency.

Errors

This method never returns an error, as the messages reducer has no write-conflict semantics. The Result return type is for API consistency with State::try_apply().

Trait Implementations

impl Clone for MessagesState

fn clone(&self) -> MessagesState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MessagesState

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

Formats the value using the given formatter.

impl Default for MessagesState

fn default() -> MessagesState

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for MessagesState

fn deserialize<__D>( __deserializer: __D, ) -> Result<MessagesState, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Node<MessagesState> for ValidationNode

fn call( &self, state: &MessagesState, _config: &RunnableConfig, ) -> Pin<Box<dyn Future<Output = Result<Command<MessagesState>, JunctureError>> + Send + '_>>

Execute the node logic

fn name(&self) -> &'static str

Get the node name

fn call_arc( &self, state: Arc<S>, config: &RunnableConfig, ) -> Pin<Box<dyn Future<Output = Result<Command<S>, JunctureError>> + Send + '_>>

Execute node logic with Arc<S> to avoid O(N) state clone.

impl Serialize for MessagesState

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.

impl State for MessagesState

type Update = MessagesStateUpdate

Partial update type generated by #[derive(State)]

type FieldVersions = FieldVersions

Field version tracking type generated by #[derive(State)].

fn apply(&mut self, update: <MessagesState as State>::Update) -> FieldsChanged

Apply an update to this state, returning which fields changed

fn reset_ephemeral(&mut self)

Reset ephemeral fields (called after each superstep)

fn field_versions(&self) -> Self::FieldVersions

Get the current field version numbers.

fn bump_versions(&mut self, _changed: &FieldsChanged)

Increment version numbers for the fields marked in changed.

fn try_apply( &mut self, update: Self::Update, ) -> Result<FieldsChanged, InvalidUpdateError>

Apply an update to this state, returning which fields changed or an error

fn finish_field(&mut self, _field_idx: usize)

Finish a specific field (called when graph execution completes)

fn consume_field(&mut self, _field_idx: usize)

Consume a specific field (called after apply_writes() per superstep)

fn consume_field_indices() -> &'static [usize]

Indices of fields that use the ephemeral reducer.

fn schema_version() -> u32

Schema version for migration

fn migrate(_from_version: u32, value: Value) -> Value

Migrate from older schema version

fn replace_field_indices() -> &'static [usize]

Indices of fields that use the replace reducer.

fn replace_after_finish_field_indices() -> &'static [usize]

Indices of fields that use the replace_after_finish reducer.

fn field_is_set(_update: &Self::Update, _field_idx: usize) -> bool

Check if a specific field is set (Some) in an update.

fn field_count() -> usize

Number of fields in this state type.

fn field_names() -> &'static [&'static str]

Names of fields in declaration order.

fn delta_channel_specs() -> &'static [(usize, usize)]

Field indices and snapshot frequencies for DeltaChannel fields.