Struct ConsistencyEngine 

pub struct ConsistencyEngine { /* private fields */ }

Consistency engine for coordinating state across all protocols

The engine maintains unified state per workspace and broadcasts state changes to all registered protocol adapters. This ensures that all protocols reflect the same persona, scenario, reality level, and entity state.

Implementations

impl ConsistencyEngine

pub fn new() -> Self

Create a new consistency engine

pub async fn register_adapter( &self, adapter: Arc<dyn ProtocolAdapter + Send + Sync>, )

Register a protocol adapter

Adapters are notified of all state changes for their protocol.

pub async fn get_or_create_state(&self, workspace_id: &str) -> UnifiedState

Get or create unified state for a workspace

pub async fn get_state(&self, workspace_id: &str) -> Option<UnifiedState>

Get unified state for a workspace (returns None if not found)

pub async fn set_active_persona( &self, workspace_id: &str, persona: PersonaProfile, ) -> Result<()>

Set active persona for a workspace

This updates the unified state and broadcasts the change to all protocol adapters, ensuring all protocols use the new persona.

pub async fn set_active_scenario( &self, workspace_id: &str, scenario_id: String, ) -> Result<()>

Set active scenario for a workspace

pub async fn set_reality_level( &self, workspace_id: &str, level: RealityLevel, ) -> Result<()>

Set reality level for a workspace

pub async fn set_reality_ratio( &self, workspace_id: &str, ratio: f64, ) -> Result<()>

Set reality continuum ratio for a workspace

pub async fn register_entity( &self, workspace_id: &str, entity: EntityState, ) -> Result<()>

Register or update an entity

Entities are tracked across all protocols. When an entity is created via HTTP, it becomes immediately available in GraphQL, gRPC, etc. Also automatically adds the entity to the persona graph if a persona_id is present.

pub async fn get_entity( &self, workspace_id: &str, entity_type: &str, entity_id: &str, ) -> Option<EntityState>

Get entity by type and ID

pub async fn find_related_entities( &self, workspace_id: &str, persona_id: &str, target_entity_type: &str, relationship_type: Option<&str>, ) -> Vec<EntityState>

Find related entities using the persona graph

Given a persona ID and entity type, finds all related entities of the target type by traversing the persona graph.

Arguments

• workspace_id - Workspace identifier
• persona_id - Starting persona ID
• target_entity_type - Entity type to find (e.g., “order”, “payment”)
• relationship_type - Optional relationship type filter (e.g., “has_orders”)

Returns

Vector of entity states matching the criteria

pub async fn activate_chaos_rule( &self, workspace_id: &str, rule: Value, ) -> Result<()>

Activate a chaos rule

pub async fn deactivate_chaos_rule( &self, workspace_id: &str, rule_name: &str, ) -> Result<()>

Deactivate a chaos rule

pub async fn update_protocol_state( &self, workspace_id: &str, protocol: Protocol, protocol_state: ProtocolState, ) -> Result<()>

Update protocol state

pub async fn get_protocol_state( &self, workspace_id: &str, protocol: Protocol, ) -> Option<ProtocolState>

Get protocol state

pub fn subscribe_to_events( &self, _workspace_id: Option<&str>, ) -> Receiver<StateChangeEvent>

Subscribe to state change events

Returns a receiver that will receive all state change events for the specified workspace (or all workspaces if None).

pub async fn restore_state(&self, state: UnifiedState) -> Result<()>

Restore unified state from a snapshot

This replaces the current state for a workspace with the provided state. All protocol adapters will be notified of the state changes.

Trait Implementations

impl Default for ConsistencyEngine

fn default() -> Self

Returns the “default value” for a type.