Struct DaemonProtocolAdapter

pub struct DaemonProtocolAdapter<'s, S: Store, R, W>
where
    R: AsyncReadExt + Unpin + Send + Debug,
    W: AsyncWriteExt + Unpin + Send + Debug,
{
    pub proto: Proto,
    /* private fields */
}

Handles an incoming nix-daemon protocol connection, and forwards calls to a crate::Store.

use tokio::net::UnixListener;
use nix_daemon::nix::{DaemonStore, DaemonProtocolAdapter};

// Accept a connection.
let listener = UnixListener::bind("/tmp/nix-proxy.sock")?;
let (conn, _addr) = listener.accept().await?;

// Connect to the real store.
let mut store = DaemonStore::builder()
    .connect_unix("/nix/var/nix/daemon-socket/socket")
    .await?;

// Proxy the connection to it.
let (cr, cw) = conn.into_split();
let mut adapter = DaemonProtocolAdapter::builder(&mut store)
    .adopt(cr, cw)
    .await?;
Ok::<(),nix_daemon::Error>(adapter.run().await?)

See nix-supervisor for a more advanced example of how to use this (with a custom Store implementation).

Fields

proto: Proto

Negotiated protocol version.

Implementations

impl<'s, S: Store> DaemonProtocolAdapter<'s, S, OwnedReadHalf, OwnedWriteHalf>

pub fn builder(store: &'s mut S) -> DaemonProtocolAdapterBuilder<'s, S>

impl<'s, S: Store, R, W> DaemonProtocolAdapter<'s, S, R, W>

where R: AsyncReadExt + Unpin + Send + Debug, W: AsyncWriteExt + Unpin + Send + Debug,

pub async fn run(&mut self) -> Result<(), S::Error>

Runs the connection until the client disconnects. TODO: Cancellation.