Struct IPCTransport 

pub struct IPCTransport {
    SocketPath: Option<PathBuf>,
    PipeName: Option<String>,
    Configuration: TransportConfig,
    Connected: Arc<RwLock<bool>>,
    Statistics: Arc<RwLock<TransportStats>>,
}

IPC transport for local process communication.

Fields

SocketPath: Option<PathBuf>

Unix domain socket path (macOS/Linux).

PipeName: Option<String>

Named pipe identifier (Windows).

Configuration: TransportConfig

Transport configuration.

Connected: Arc<RwLock<bool>>

Whether the transport is currently connected.

Statistics: Arc<RwLock<TransportStats>>

Transport statistics.

Implementations

impl IPCTransport

pub fn New() -> Result<Self>

Creates a new IPC transport using the default socket path.

pub fn WithSocketPath<P: AsRef<Path>>(SocketPath: P) -> Result<Self>

Creates a new IPC transport with a custom Unix domain socket path.

fn DefaultSocketPath() -> PathBuf

Returns the default socket path for the current platform.

pub fn GetSocketPath(&self) -> Option<&Path>

Returns the socket path (Unix only).

pub async fn GetStatistics(&self) -> TransportStats

Returns a snapshot of transport statistics.

async fn CleanupSocket(&self) -> Result<()>

Removes the socket file if it exists.

Trait Implementations

impl Clone for IPCTransport

fn clone(&self) -> IPCTransport

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for IPCTransport

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

Formats the value using the given formatter.

impl TransportStrategy for IPCTransport

type Error = IPCTransportError

Error type for this transport

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

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

Connect to the transport endpoint

fn send<'life0, 'life1, 'async_trait>( &'life0 self, request: &'life1 [u8], ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>, Self::Error>> + Send + 'async_trait>>

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

Send a request and receive a response

fn send_no_response<'life0, 'life1, 'async_trait>( &'life0 self, data: &'life1 [u8], ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

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

Send data without expecting a response (fire and forget)

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

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

Close the transport connection

fn is_connected(&self) -> bool

Check if the transport is connected

fn transport_type(&self) -> TransportType

Get the transport type identifier