Struct Scheduler 

pub struct Scheduler { /* private fields */ }

Wraps GraphHandle with a scheduler-oriented API. All state lives in the GraphActor; this is a coordination facade.

Implementations

impl Scheduler

pub fn new(handle: GraphHandle) -> Self

pub async fn get_ready(&self) -> Vec<NodeId>

Returns currently runnable node IDs.

pub async fn claim(&self, id: NodeId) -> bool

Claim a node for execution. Returns true if this caller won the race.

pub async fn complete(&self, id: NodeId, result: Value)

Mark a node completed with its result.

pub async fn fail(&self, id: NodeId, error: String)

Mark a node failed.

pub async fn snapshot(&self) -> Option<GraphSnapshot>

Get a snapshot of current graph state.

pub fn handle(&self) -> &GraphHandle

Access the underlying GraphHandle (for mutations).