Struct CacheAgent 

pub struct CacheAgent { /* private fields */ }

Shared state for an agent hosted by the process that owns a build session.

Transport listeners deliberately live in the embedder so the session lifecycle owns them. This type only contains ecosystem-independent CAS and protocol logic.

Implementations

impl CacheAgent

pub fn new(cache_dir: impl Into<PathBuf>, version: impl Into<Arc<str>>) -> Self

Create an agent backed by the cache rooted at cache_dir.

pub fn new_remote( cache_dir: impl Into<PathBuf>, version: impl Into<Arc<str>>, remote: AgentRemoteCache, ) -> Self

Create an agent with local-first access to a remote action cache.

pub fn new_remote_with_download_limit( cache_dir: impl Into<PathBuf>, version: impl Into<Arc<str>>, remote: AgentRemoteCache, max_remote_download_bytes: u64, ) -> Self

Create a remote agent with a cumulative download budget for the session.

pub async fn begin_task(&self, task: &str) -> Result<String>

Load the last committed action manifest for a task into this session.

pub async fn prefetch_task(&self, task: &str) -> Result<String>

Load a task and finish its prefetch, surfacing remote lookup failures.

pub async fn cancel_prefetches(&self)

Cancel speculative downloads before the owning session exits.

pub async fn commit_task(&self, run: &str) -> Result<()>

Atomically publish the completed actions collected by a task run.

pub fn stats(&self) -> AgentStats

Return a snapshot of this session’s cache activity.

pub async fn handle_requests( &self, requests: impl IntoIterator<Item = AgentRequest>, ) -> Vec<AgentResponse>

Handle requests without a transport connection.

Persistent wrappers use this entry point when Cargo invokes mbx outside an orchestrated session. It intentionally has the same response semantics as Self::handle_connection, while leaving framing and the version handshake to callers that actually cross a process boundary.

pub async fn handle_connection<S>(&self, stream: S) -> Result<()>

where S: AsyncRead + AsyncWrite + Unpin,

Serve newline-delimited protocol requests on an authenticated session stream.

Trait Implementations

impl Clone for CacheAgent

fn clone(&self) -> CacheAgent

Returns a duplicate of the value.

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

Performs copy-assignment from source.