Struct IPCTransportImpl 

pub struct IPCTransportImpl {
    socket_path: Option<PathBuf>,
    pipe_name: Option<String>,
    config: TransportConfig,
    connected: Arc<RwLock<bool>>,
    stats: Arc<RwLock<TransportStats>>,
}

IPC transport for local process communication

Fields

socket_path: Option<PathBuf>

Socket path

pipe_name: Option<String>

Named pipe name (Windows)

config: TransportConfig

Transport configuration

connected: Arc<RwLock<bool>>

Connection state

stats: Arc<RwLock<TransportStats>>

Transport statistics

Implementations

impl IPCTransportImpl

pub fn new() -> Result<Self>

Create a new IPC transport with default socket path

pub fn with_socket_path<P: AsRef<Path>>(socket_path: P) -> Result<Self>

Create a new IPC transport with a custom socket path

Arguments

• socket_path - Path to the Unix domain socket

Example

use std::path::Path;

use grove::Transport::IPCTransport;

let transport = IPCTransport::with_socket_path(Path::new("/tmp/grove.sock"))?;

pub fn with_config(config: TransportConfig) -> Result<Self>

Create a new IPC transport with custom configuration

fn default_socket_path() -> PathBuf

Get the default socket path for the current platform

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

Get the socket path (Unix only)

pub async fn stats(&self) -> TransportStats

Get transport statistics

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

Clean up the socket file if it exists

Trait Implementations

impl Clone for IPCTransportImpl

fn clone(&self) -> IPCTransportImpl

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for IPCTransportImpl

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

Formats the value using the given formatter.

impl TransportStrategy for IPCTransportImpl

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