Struct NamedPipeRegistry 

pub struct NamedPipeRegistry { /* private fields */ }

Registry of named pipes for persistent IPC channels.

Implementations

impl NamedPipeRegistry

pub fn new() -> Self

Create a new empty pipe registry.

pub fn create( &self, name: impl Into<String>, ) -> KernelResult<Receiver<KernelMessage>>

Create a named pipe with default capacity and TTL.

Returns the receiver half of the pipe channel. If a pipe with this name already exists, returns an error.

pub fn create_with_options( &self, name: impl Into<String>, capacity: usize, ttl_secs: u64, ) -> KernelResult<Receiver<KernelMessage>>

Create a named pipe with specific capacity and TTL.

pub fn connect_sender(&self, name: &str) -> KernelResult<Sender<KernelMessage>>

Connect to an existing named pipe as a sender.

Returns a sender that can push messages into the pipe.

pub async fn send(&self, name: &str, msg: KernelMessage) -> KernelResult<()>

Send a message to a named pipe.

This is a convenience method that looks up the pipe and sends directly, without requiring the caller to hold a sender.

pub fn disconnect_sender(&self, name: &str)

Disconnect a sender from a named pipe.

pub fn disconnect_receiver(&self, name: &str)

Disconnect a receiver from a named pipe.

pub fn remove(&self, name: &str) -> bool

Remove a named pipe.

pub fn exists(&self, name: &str) -> bool

Check if a named pipe exists.

pub fn list(&self) -> Vec<String>

List all pipe names.

pub fn info(&self, name: &str) -> Option<PipeInfo>

Get info about a specific pipe.

pub fn list_info(&self) -> Vec<PipeInfo>

Get info about all pipes.

pub fn len(&self) -> usize

Number of registered pipes.

pub fn is_empty(&self) -> bool

Whether the registry is empty.

pub fn cleanup_expired(&self) -> Vec<String>

Remove pipes that have expired (no references and TTL elapsed).

Returns the names of removed pipes.

Trait Implementations

impl Default for NamedPipeRegistry

fn default() -> Self

Returns the “default value” for a type.

impl Registry for NamedPipeRegistry

type Value = PipeInfo

The value returned by get.

fn get(&self, key: &str) -> Option<Self::Value>

Look up a value by its string key.

fn list_keys(&self) -> Vec<String>

Return all keys currently in the registry.

fn contains(&self, key: &str) -> bool

Check whether key is present.

fn count(&self) -> usize

Number of entries in the registry.

fn is_empty(&self) -> bool

Whether the registry is empty.