Struct GraphRuntime 

pub struct GraphRuntime { /* private fields */ }

Implementations

impl GraphRuntime

pub fn new() -> Self

pub fn with_limits(limits: RuntimeLimits) -> Self

pub fn with_correlation_id(self, correlation_id: impl Into<String>) -> Self

pub fn restore(events: Vec<GraphEventRecord>) -> Result<Self, ReplayError>

pub fn branch_id(&self) -> &str

pub fn graph(&self) -> &StateGraph

pub fn events(&self) -> &[GraphEventRecord]

pub fn register( &mut self, behavior: Arc<dyn Behavior>, ) -> Result<(), RuntimeError>

pub fn emit( &mut self, event: GraphEvent, ) -> Result<GraphEventRecord, RuntimeError>

pub fn run_goal( &mut self, goal: impl Into<String>, ) -> Result<GraphEventRecord, RuntimeError>

pub fn propose_patch( &mut self, patch: GraphPatch, causation_id: Option<String>, ) -> Result<bool, RuntimeError>

pub fn fork_at(&self, sequence_exclusive: u64) -> Result<Self, RuntimeError>

pub fn diff(&self, other: &Self) -> GraphDiff

pub fn strict_replay( records: &[GraphEventRecord], ) -> Result<StateGraph, ReplayError>

pub fn check_external( &self, event: &ExternalEvent, ) -> Result<Option<ExternalProjectionOutcome>, RuntimeError>

Validate sequence and idempotency before constructing a projection.

pub fn project_external( &mut self, event: ExternalEvent, patch: GraphPatch, ) -> Result<ExternalProjectionOutcome, RuntimeError>

Atomically append a graph patch and its durable external-stream cursor.

Trait Implementations

impl Default for GraphRuntime

fn default() -> Self

Returns the “default value” for a type.