Struct TunTapEngine 

pub struct TunTapEngine { /* private fields */ }

The decode → filter → handler → model → write pipeline.

Transport-free by construction: it consumes frames from an mpsc::Receiver and produces them into an mpsc::Sender. The real device fills those channels from a TUN/TAP file descriptor; a test fills them itself. Both run this code.

Implementations

impl TunTapEngine

pub fn new( cfg: TunTapConfig, interface: impl Into<String>, llm_client: OllamaClient, state: Arc<AppState>, status_tx: UnboundedSender<String>, server_id: ServerId, ) -> Self

Build a pipeline for interface under cfg.

pub fn stats(&self) -> Arc<TunTapStats>

The counters this pipeline will update.

pub fn spawn_over_channels(self) -> ChannelLink

Run the pipeline over a pair of channels, on its own task.

This is the unprivileged entry point: it is the whole event → handler → action path with the file descriptor replaced by two mpsc ends, which is how the pipeline is exercised without root.

pub async fn run(self, ingress: Receiver<Vec<u8>>, egress: Sender<Vec<u8>>)

The pipeline itself. Returns when the ingress channel closes.