Struct Restreamer 

pub struct Restreamer { /* private fields */ }

Shared restreamer state.

Implementations

impl Restreamer

pub fn new( buffer_limits: BufferLimits, journal: Arc<dyn NodeJournal>, core_token: impl Into<String>, keys: Option<RestreamerKeys>, ) -> Self

pub fn set_keys(&self, keys: RestreamerKeys)

pub fn uplink_notify(&self) -> Arc<Notify>

pub fn peers(&self) -> &UplinkPeers

pub fn upstream_public_keys(&self) -> Option<(PublicKeyBytes, PublicKeyBytes)>

pub fn ever_pushed_to_core(&self) -> bool

Invariant: C2 never opens connections to core.

pub fn admit_from_node( &self, node_id: &str, channel_id: u32, payload: Vec<u8>, ) -> Result<EnqueueOutcome, RestreamerError>

Admit one opaque DATA payload from a node (outer layer already optional). If keys are configured, payload is treated as outer-sealed and stripped.

pub fn open_channel(&self, node_id: &str, channel_id: u32, kind: ChannelKind)

pub fn ack(&self, node_id: &str, channel_id: u32, seq: u64)

pub fn window_credit(&self, node_id: &str, channel_id: u32) -> u32

pub fn resume( &self, node_id: &str, channel_id: u32, after: u64, ) -> Result<Vec<DrainEnvelope>, RestreamerError>

Produce drain envelopes for RESUME(after=N). Recovers gaps from the node journal.

pub async fn resume_with_uplink( &self, node_id: &str, channel_id: u32, after: u64, ) -> Result<Vec<DrainEnvelope>, RestreamerError>

Prefer live uplink journal; fall back to the configured NodeJournal.

pub fn buffered_after( &self, node_id: &str, channel_id: u32, after: u64, ) -> Vec<DrainEnvelope>

Snapshot of buffered events for a stream (no journal).

Trait Implementations

impl Clone for Restreamer

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.