Struct ChainManager 

pub struct ChainManager { /* private fields */ }

Manager for multiple conversation chains.

Provides operations for creating, accessing, and managing multiple conversation state machines. Ported from DLM’s ChainManager.

Example

let mut manager = ChainManager::new();

// Create a chain with auto-generated ID
let chain_id = manager.create_chain(None);

// Create a chain with specific ID
let chain_id = manager.create_chain(Some("my-chain".to_string()));

// Get chain for operations
if let Some(chain) = manager.get_chain_mut(&chain_id) {
    chain.split(some_node)?;
}

// Merge two chains
manager.merge_chains(&chain1, &chain2)?;

Implementations

impl ChainManager

pub fn new() -> Self

Create a new chain manager with default config.

pub fn with_config(config: ChainManagerConfig) -> Self

Create a new chain manager with specific config.

pub fn create_chain( &mut self, chain_id: Option<ChainId>, ) -> Result<ChainId, ChainManagerError>

Create a new conversation chain.

If chain_id is None, a unique ID is generated. Returns the chain ID.

pub fn create_chain_from_graph( &mut self, chain_id: Option<ChainId>, graph: TrajectoryGraph, ) -> Result<ChainId, ChainManagerError>

Create a chain from an existing graph.

pub fn get_chain(&self, chain_id: &ChainId) -> Option<&BranchStateMachine>

Get a chain by ID (immutable).

pub fn get_chain_mut( &mut self, chain_id: &ChainId, ) -> Option<&mut BranchStateMachine>

Get a chain by ID (mutable).

pub fn get_metadata(&self, chain_id: &ChainId) -> Option<&ChainMetadata>

Get chain metadata.

pub fn get_metadata_mut( &mut self, chain_id: &ChainId, ) -> Option<&mut ChainMetadata>

Get mutable chain metadata.

pub fn contains(&self, chain_id: &ChainId) -> bool

Check if a chain exists.

pub fn chain_ids(&self) -> impl Iterator<Item = &ChainId>

Get all chain IDs.

pub fn chain_count(&self) -> usize

Get number of chains.

pub fn active_chain(&self) -> Option<&ChainId>

Get the currently active chain ID.

pub fn set_active_chain( &mut self, chain_id: ChainId, ) -> Result<(), ChainManagerError>

Set the active chain.

pub fn get_active_chain(&self) -> Option<&BranchStateMachine>

Get the active chain (immutable).

pub fn get_active_chain_mut(&mut self) -> Option<&mut BranchStateMachine>

Get the active chain (mutable).

pub fn delete_chain(&mut self, chain_id: &ChainId) -> bool

Delete a chain.

pub fn merge_chains( &mut self, from: &ChainId, into: &ChainId, ) -> Result<(), ChainManagerError>

Merge two chains.

The from chain is merged into into, and then deleted.

pub fn split_chain( &mut self, chain_id: &ChainId, node_id: NodeId, ) -> Result<ChainId, ChainManagerError>

Split a chain at a node, creating a new chain.

Returns the ID of the new chain.

pub fn cleanup_inactive(&mut self, threshold: Duration)

Cleanup inactive chains.

Removes chains that haven’t been accessed within the threshold.

pub fn deactivate_chain( &mut self, chain_id: &ChainId, ) -> Result<(), ChainManagerError>

Mark a chain as inactive.

pub fn reactivate_chain( &mut self, chain_id: &ChainId, ) -> Result<(), ChainManagerError>

Reactivate a chain.

pub fn stats(&self) -> ChainManagerStats

Get statistics about all managed chains.

pub fn all_metadata(&self) -> impl Iterator<Item = &ChainMetadata>

Get all metadata.

pub fn find_by_tag(&self, tag: &str) -> Vec<&ChainId>

Find chains by tag.

pub fn find_by_title(&self, query: &str) -> Vec<&ChainId>

Find chains by title (partial match).

Trait Implementations

impl Default for ChainManager

fn default() -> Self

Returns the “default value” for a type.