Struct Ipc 

pub struct Ipc { /* private fields */ }

An IPC (Inter-Process Communication) implementation using Unix domain sockets.

This struct represents the IPC transport, which allows communication between processes on the same machine using Unix domain sockets.

Features

• Asynchronous communication using Tokio’s runtime
• Supports both connection-oriented (stream) and connectionless (datagram) sockets
• Implements standard transport traits for easy integration with other components

Note: This implementation is specific to Unix-like operating systems and is not tested on Windows or other non-Unix platforms.

Implementations

impl Ipc

pub fn new(config: Config) -> Self

Creates a new Ipc transport.

Trait Implementations

impl Debug for Ipc

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for Ipc

fn default() -> Ipc

Returns the “default value” for a type.

impl Transport<PathBuf> for Ipc

type Stats = ()

The statistics for the transport (specifically its underlying IO object).

type Io = IpcStream

The result of a successful connection.

type Control = ()

Control-plane messages that modify the runtime behavior of the transport.

type Error = Error

An error that occurred when setting up the connection.

type Connect = Pin<Box<dyn Future<Output = Result<<Ipc as Transport<PathBuf>>::Io, <Ipc as Transport<PathBuf>>::Error>> + Send>>

A pending output for an outbound connection, obtained when calling Transport::connect.

type Accept = Pin<Box<dyn Future<Output = Result<<Ipc as Transport<PathBuf>>::Io, <Ipc as Transport<PathBuf>>::Error>> + Send>>

A pending output for an inbound connection, obtained when calling Transport::poll_accept.

fn local_addr(&self) -> Option<PathBuf>

Returns the local address this transport is bound to (if it is bound).

fn bind<'life0, 'async_trait>( &'life0 mut self, addr: PathBuf, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Binds to the given address.

fn connect(&mut self, addr: PathBuf) -> Self::Connect

Connects to the given address, returning a future representing a pending outbound connection.

fn poll_accept(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Accept>

Poll for incoming connections. If an inbound connection is received, a future representing a pending inbound connection is returned. The future will resolve to Transport::Accept.

fn on_control(&mut self, _ctrl: Self::Control)

Applies a control-plane message to the transport. It is expected to update internal state only and should not perform long-running operations.

impl TransportExt<PathBuf> for Ipc

fn accept(&mut self) -> Acceptor<'_, Self, PathBuf>

where Self: Sized + Unpin,

Async-friendly interface for accepting inbound connections.