Struct CacheAgent 

pub struct CacheAgent { /* private fields */ }

Shared state for an agent hosted by the top-level mise run process.

Transport listeners deliberately live in mise so the task-run 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 async fn begin_task(&self, task: &str) -> Result<String>

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

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 candidate manifest collected by a successful task.

pub fn stats(&self) -> AgentStats

Return a snapshot of this session’s cache activity.

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.