Shim extension for containerd

Rust crate to ease runtime v2 shim implementation.

It replicates same shim.Run API offered by containerd's shim v2 runtime implementation written in Go.

Look and feel

The API is very similar to the one offered by Go version:

```rust

[derive(Clone)]

struct Service { exit: ExitSignal, }

impl shim::Shim for Service { type Error = shim::Error; type T = Service;

fn new(
    _runtime_id: &str,
    _id: &str,
    _namespace: &str,
    _publisher: shim::RemotePublisher,
    _config: &mut shim::Config,
) -> Self {
    Service {
        exit: ExitSignal::default(),
    }
}

fn start_shim(&mut self, opts: shim::StartOpts) -> Result<String, shim::Error> {
    let address = shim::spawn(opts, Vec::new())?;
    Ok(address)
}

fn wait(&mut self) {
    self.exit.wait();
}

fn get_task_service(&self) -> Self::T {
    self.clone()
}

}

impl shim::Task for Service { fn connect( &self, _ctx: &TtrpcContext, _req: api::ConnectRequest, ) -> TtrpcResult { info!("Connect request"); Ok(api::ConnectResponse { version: String::from("example"), ..Default::default() }) }

fn shutdown(&self, _ctx: &TtrpcContext, _req: api::ShutdownRequest) -> TtrpcResult<api::Empty> {
    info!("Shutdown request");
    self.exit.signal(); // Signal to shutdown shim server
    Ok(api::Empty::default())
}

}

fn main() { shim::run::("io.containerd.empty.v1") }

```

How to use with containerd

Note: All operations are in the root directory of rust-extensions.

With shim v2 runtime:

bash $ cargo build --example skeleton $ sudo cp ./target/debug/examples/skeleton /usr/local/bin/containerd-shim-skeleton-v1 $ sudo ctr run --rm --runtime io.containerd.skeleton.v1 -t docker.io/library/hello-world:latest hello

Or if on 1.6+

bash $ cargo build --example skeleton $ sudo ctr run --rm --runtime ./target/debug/examples/skeleton docker.io/library/hello-world:latest hello

Or manually:

``` $ touch log

Run containerd in background

$ sudo TTRPC_ADDRESS="/var/run/containerd/containerd.sock.ttrpc" \ cargo run --example skeleton -- \ -namespace default \ -id 1234 \ -address /var/run/containerd/containerd.sock \ -publish-binary ./bin/containerd \ start unix:///var/run/containerd/eb8e7d1c48c2a1ec.sock

$ cargo build --example shim-proto-connect $ sudo ./target/debug/examples/shim-proto-connect unix:///var/run/containerd/eb8e7d1c48c2a1ec.sock Connecting to unix:///var/run/containerd/eb8e7d1c48c2a1ec.sock... Sending Connect request... Connect response: version: "example" Sending Shutdown request... Shutdown response: ""

$ cat log [INFO] server listen started [INFO] server started [INFO] Shim successfully started, waiting for exit signal... [INFO] Connect request [INFO] Shutdown request [INFO] Shutting down shim instance [INFO] close monitor [INFO] listener shutdown for quit flag [INFO] ttrpc server listener stopped [INFO] listener thread stopped [INFO] begin to shutdown connection [INFO] connections closed [INFO] reaper thread exited [INFO] reaper thread stopped ```

Running on Windows

```powershell

Run containerd in background

$env:TTRPC_ADDRESS="\.\pipe\containerd-containerd.ttrpc"

$ cargo run --example skeleton -- -namespace default -id 1234 -address "\.\pipe\containerd-containerd" start \.\pipe\containerd-shim-17630016127144989388-pipe

(Optional) Run the log collector in a separate command window

note: log reader won't work if containerd is connected to the named pipe, this works when running manually to help debug locally

$ cargo run --example windows-log-reader \.\pipe\containerd-shim-default-1234-log Reading logs from: \.\pipe\containerd-shim-default-1234-log

$ cargo run --example shim-proto-connect \.\pipe\containerd-shim-17630016127144989388-pipe Connecting to \.\pipe\containerd-shim-17630016127144989388-pipe... Sending Connect request... Connect response: version: "example" Sending Shutdown request... Shutdown response: "" ```

Supported Platforms

Currently, following OSs and hardware architectures are supported, and more efforts are needed to enable and validate other OSs and architectures. - Linux - Mac OS - Windows