Struct GraphMapper 

pub struct GraphMapper { /* private fields */ }

Converts RIS messages to graph SourceChange events.

Implementations

impl GraphMapper

pub fn new(source_id: impl Into<String>, state: StreamState) -> Self

Create a mapper with initial state.

pub fn state(&self) -> &StreamState

Returns current state.

pub fn process_announcements( &mut self, message: &RisMessageData, ) -> Vec<SourceChange>

Process announcement entries from an UPDATE message.

pub fn process_withdrawals( &mut self, message: &RisMessageData, ) -> Vec<SourceChange>

Process withdrawals from an UPDATE message.

pub fn process_peer_state( &mut self, message: &RisMessageData, ) -> Vec<SourceChange>

Process RIS_PEER_STATE messages to upsert peer state.