Struct SrxNode 

pub struct SrxNode { /* private fields */ }

High-level SRX protocol node (client or server).

Holds the active SrxPipeline and exposes simple send / recv_from methods.

Implementations

impl SrxNode

pub fn client_connect<F>( config: SrxConfig, transport_mgr: TransportManager, exchange: F, ) -> Result<Self>

where F: FnOnce(&[u8]) -> Result<(Vec<u8>, Vec<u8>)>,

Perform a client-side handshake and build the pipeline.

exchange is a closure that carries the three handshake messages over the network (transport-agnostic so the caller can use any channel).

exchange(ClientHello) → ServerHello
exchange(ClientFinished) → ()

pub fn from_master_secret( config: SrxConfig, master: [u8; 32], transport_mgr: TransportManager, ) -> Result<Self>

Build a node directly from a shared master secret (e.g. after an external handshake or for testing).

pub fn from_session( config: SrxConfig, session: Session, aead: Arc<AeadPipeline>, transport_mgr: TransportManager, ) -> Result<Self>

Build a node from a pre-established Session and AeadPipeline.

pub async fn send(&mut self, payload: &[u8]) -> Result<TransportKind>

Send application payload through the full protocol stack.

pub async fn recv_from(&mut self, kind: TransportKind) -> Result<Vec<u8>>

Receive and decrypt from a specific transport.

pub fn process_incoming(&self, envelope: &[u8]) -> Result<Vec<u8>>

Process raw bytes received externally (e.g. from a worker queue).

pub fn prepare_outgoing(&mut self, payload: &[u8]) -> Result<Vec<u8>>

Prepare outgoing bytes without dispatching (for custom transport handling).

pub fn pipeline(&self) -> &SrxPipeline

Access the underlying pipeline.

pub fn pipeline_mut(&mut self) -> &mut SrxPipeline

Mutable access to the underlying pipeline.

pub fn config(&self) -> &SrxConfig

Access the node configuration.

pub fn replay_state(&self) -> ReplayState

Snapshot anti-replay state so it can be restored after a restart.

pub fn set_replay_state(&self, state: &ReplayState) -> Result<()>

Restore anti-replay state captured from a previous process instance.

pub fn send_signal(&mut self, signal: &Signal) -> Result<Vec<u8>>

Send a control signal through the full pipeline (encrypted, framed, mimicry-wrapped — indistinguishable from data on the wire).

pub fn process_incoming_dispatched(&self, envelope: &[u8]) -> Result<Payload>

Process raw bytes and dispatch into Payload::Data or Payload::Signal.

pub fn heal_if_needed(&mut self) -> Option<Vec<TransportKind>>

Check if self-healing should trigger and, if so, reseed and return a new transport order.

Returns Some(order) when healing was performed, None otherwise.

pub fn record_success(&mut self)

Notify the self-healing controller that traffic succeeded.

pub fn heal_count(&self) -> u32

Number of self-healing events triggered so far.

pub fn set_environment(&mut self, env: NetworkEnvironment)

Set the network environment for transport policy.

pub fn policy(&self) -> &TransportPolicy

Access the transport policy.

pub fn replay_store_metrics() -> ReplayStoreMetricsSnapshot

Snapshot CAS contention metrics for replay-store persistence.