Struct FluxManager 

pub struct FluxManager { /* private fields */ }

FLUX transference manager

Implementations

impl FluxManager

pub fn new() -> Self

pub fn create_flux( &mut self, source: RoomId, target: RoomId, timestamp: f64, payload: TransferencePayload, zeitgeist: Zeitgeist, ) -> FluxTransference

Create a FLUX transference from source to target

pub fn send_flux(&mut self, flux: FluxTransference)

Send a FLUX transference (queue it)

pub fn recv_flux_for(&mut self, target: &RoomId) -> Vec<FluxTransference>

Receive pending FLUX transferences for a target room

pub fn recv_flux(&mut self) -> Option<FluxTransference>

Receive any pending FLUX transference

pub fn update_parity( &mut self, room: &RoomId, zeitgeist: &Zeitgeist, timestamp: f64, )

Update parity state for a room (CONSTRAINT 7)

pub fn check_parity(&self, room: &RoomId) -> bool

Check if a room has valid parity (CONSTRAINT 7)

pub fn encode_zeitgeist(zeitgeist: &Zeitgeist) -> Vec<u8>

Encode zeitgeist to bytes (simplified CBOR-like format)

pub fn decode_zeitgeist(bytes: &[u8]) -> Result<Zeitgeist, String>

Decode zeitgeist from bytes

pub fn track_funnel( &self, zeitgeist: &Zeitgeist, observations: &[f64], ) -> FunnelState

Track deadband funnel for precision convergence

pub fn pending_count(&self) -> usize

Pending count

Trait Implementations

impl Default for FluxManager

fn default() -> Self

Returns the “default value” for a type.