Struct NamedPipe 

pub struct NamedPipe {
    pub name: String,
    pub capacity: usize,
    pub created_at: DateTime<Utc>,
    pub receiver_count: AtomicU32,
    pub sender_count: AtomicU32,
    pub ttl_after_empty: Duration,
    pub last_active: RwLock<Instant>,
    /* private fields */
}

A named pipe with channel-based message delivery.

Fields

name: String

Pipe name.

capacity: usize

Channel capacity.

created_at: DateTime<Utc>

When the pipe was created.

receiver_count: AtomicU32

Number of connected receivers.

sender_count: AtomicU32

Number of connected senders.

ttl_after_empty: Duration

TTL after all references are dropped.

last_active: RwLock<Instant>

Last time the pipe was actively used.

Implementations

impl NamedPipe

pub fn info(&self) -> PipeInfo

Get a serializable info snapshot.

pub fn is_expired(&self) -> bool

Check if the pipe has expired (no references and TTL elapsed).