Module varlink 

Varlink RPC service exposing repository operations over a Unix socket. Varlink RPC service for cfsctl.

Exposes a subset of repository operations over a Unix-socket varlink interface (org.composefs.Repository) so that integration tests and external callers can consume structured replies instead of scraping the human-oriented CLI output.

Repositories are accessed through opaque u64 handles: a client calls OpenRepository to obtain a handle, passes it to every subsequent method, and frees it with CloseRepository. No repository is opened at startup, so every call must carry a handle. Each handle stores an already-opened Repository<ObjectID> monomorphized over the digest algorithm detected at open time, wrapped in an Arc so the streaming Pull method can move an owned clone into its 'static reply stream.

The zlink server serializes Service::handle calls (a single task holds one &mut self borrow at a time), so the handle table is a plain HashMap with no interior locking.

Modules

layer_sync

Reply types for the layer-sync methods of the org.composefs.Oci interface, gated behind the oci feature (they depend on [composefs_oci::layer_sync]).

oci

Varlink support for the OCI interface (org.composefs.Oci).

proxy

Typed Rust client bindings (the native-API mirror of the on-the-wire varlink interfaces). These let a Rust consumer — the integration tests today, and a future cfsctl-as-client — call the service with generated, type-checked proxy methods, in addition to the wire protocol exercised by external clients such as varlinkctl.

service_impl 🔒

Structs

ActivatedListener 🔒

A Listener that yields a single pre-connected socket, then blocks forever.

CfsctlService 🔒

Varlink service implementation backing the org.composefs.Repository (and, with the oci feature, org.composefs.Oci) interfaces.

FsckReply

Result of a repository consistency check, mirrored for the varlink wire format.

GcReply

Result of a garbage-collection run for the varlink wire format.

HandleEntry 🔒

A single entry in the service’s open-repository table.

ImageObjectsReply

Reply listing the objects referenced by a single image.

ImageRefEntry

A single image reference entry.

InitRepositoryReply

Reply from initializing a repository.

ListImageRefsReply

Reply listing all named image references in the repository.

MountParams

Options for a Mount call. All fields are optional for forward compatibility — new mount options can be added without breaking the wire format.

MountReply

Reply for a Mount call — just an fd_index referencing the mount fd.

OpenOptions 🔒

Process-wide repository open options, fixed at startup.

OpenRepositoryReply

Reply carrying an opaque repository handle and basic repository metadata.

Enums

ActivatedSocket 🔒

An inherited socket-activation fd, classified by its listening state.

OpenRepo 🔒

An opened repository, monomorphized over its detected hash algorithm.

RepositoryError

Errors that may be returned by the org.composefs.Repository interface.

Functions

run_compute_id 🔒

Compute the composefs image ID for an OCI image.

run_fsck 🔒

Open the repository and run an fsck.

run_gc 🔒

Run garbage collection (or a dry run) on a repository.

run_image_objects 🔒

Collect the objects referenced by an image.

run_init_repository 🔒

Initialize (or verify) a repository at path with the given algorithm.

run_inspect 🔒

Inspect a single OCI image.

run_list_image_refs

Collect all named image references from the repository.

run_list_images 🔒

OCI helper functions backing the org.composefs.Oci interface, gated behind the oci feature.

run_mount 🔒

run_oci_fsck 🔒

Run an OCI-aware consistency check on a repository.

run_oci_mount 🔒

run_tag 🔒

Tag a manifest digest with a name.

run_untag 🔒

Remove a tag.

serve 🔒

Serve service on the appropriate socket, auto-detecting the source.

serve_activated 🔒

Serve service on an already-obtained socket-activated connected listener.

serve_on_listener 🔒

Serve service on a listening [zlink::unix::Listener] inside a [tokio::task::LocalSet].

spawn_in_process 🔒

Spawn a CfsctlService in-process over a Unix socket pair for testing.

try_activated_listener 🔒

Try to classify a socket-activation fd inherited from the service manager.