Struct Node 

pub struct Node { /* private fields */ }

ELARA Node - the runtime entity

Implementations

impl Node

pub fn new() -> Self

Create a new node with generated identity

pub fn with_config(config: NodeConfig) -> Self

Create a new node with custom configuration

pub fn with_identity(identity: Identity, config: NodeConfig) -> Self

pub fn node_id(&self) -> NodeId

Get node ID

pub fn session_id(&self) -> Option<SessionId>

Get session ID (if in session)

pub fn join_session(&mut self, session_id: SessionId, session_key: [u8; 32])

Join a session

pub fn join_session_unsecured(&mut self, session_id: SessionId)

pub fn leave_session(&mut self)

Leave current session

pub fn queue_incoming(&mut self, frame: Frame)

Queue an incoming frame for processing

pub fn pop_outgoing(&mut self) -> Option<Frame>

Get next outgoing frame (if any)

pub fn queue_local_event(&mut self, event: Event)

Queue a local event to send

pub fn queue_visual_keyframe(&mut self, state: &VisualState)

pub fn queue_visual_delta(&mut self, state: &VisualState)

pub fn queue_stream_visual_keyframe( &mut self, stream_id: u64, state: &VisualState, )

pub fn queue_stream_visual_delta(&mut self, stream_id: u64, state: &VisualState)

pub fn queue_stream_start( &mut self, stream_id: u64, metadata: Vec<u8>, timestamp: StateTime, )

pub fn queue_stream_end(&mut self, stream_id: u64, timestamp: StateTime)

pub fn queue_feed_append( &mut self, feed_state: StateId, data: Vec<u8>, timestamp: StateTime, )

pub fn queue_feed_delete(&mut self, feed_state: StateId, timestamp: StateTime)

pub fn tick(&mut self)

Execute one tick of the runtime loop This is the core 12-stage loop

pub fn visual_state(&self, node_id: NodeId) -> Option<VisualState>

pub fn visual_state_at( &mut self, node_id: NodeId, target_time: StateTime, ) -> Option<VisualState>

pub fn visual_state_now(&mut self, node_id: NodeId) -> Option<VisualState>

pub fn stream_visual_state(&self, stream_id: u64) -> Option<VisualState>

pub fn stream_visual_state_at( &mut self, stream_id: u64, target_time: StateTime, ) -> Option<VisualState>

pub fn stream_visual_state_now(&mut self, stream_id: u64) -> Option<VisualState>

pub fn feed_stream(&self, feed_state: StateId) -> FeedStream

pub fn stream_metadata(&self, stream_id: u64) -> Option<&StreamMetadata>

pub fn time_engine(&self) -> &TimeEngine

Get reference to time engine

pub fn state_engine(&self) -> &ReconciliationEngine

Get reference to state engine

pub fn state_engine_mut(&mut self) -> &mut ReconciliationEngine

Get mutable reference to state engine

pub fn stats(&self) -> &RuntimeStats

pub fn in_session(&self) -> bool

Check if node is in a session

pub fn next_event_seq(&mut self) -> u64

Get next event sequence number

Trait Implementations

impl Default for Node

fn default() -> Self

Returns the “default value” for a type.