Struct Client 

pub struct Client { /* private fields */ }

The main client for interacting with the modelexpress_server via gRPC

Implementations

impl Client

pub async fn new(config: Config) -> CommonResult<Self>

Create a new client with the given configuration

pub async fn new_with_cache( config: Config, cache_config: CacheConfig, ) -> CommonResult<Self>

Create a new client with cache configuration

pub async fn delete_model_on_server( &mut self, model_name: &str, provider: ModelProvider, ) -> CommonResult<()>

Delete a model’s record from the server-side registry. This complements removing the model’s local files, so a cleared model does not leave behind a stale DOWNLOADED record that would satisfy a later download request without re-fetching the files.

pub async fn get_model_path( &self, model_name: &str, provider: ModelProvider, ) -> Result<PathBuf>

pub async fn health_check(&mut self) -> CommonResult<Status>

Get the server health status

pub async fn send_request<T: DeserializeOwned>( &mut self, action: impl Into<String>, payload: Option<HashMap<String, Value>>, ) -> CommonResult<T>

Send a request to the server

pub async fn request_model_on_server( &mut self, model_name: impl Into<String>, provider: ModelProvider, ignore_weights: bool, ) -> CommonResult<()>

Request a model on the server at its default revision.

pub async fn request_model_on_server_revision( &mut self, model_name: impl Into<String>, provider: ModelProvider, ignore_weights: bool, revision: Option<&str>, ) -> CommonResult<Option<String>>

Request a model on the server at a specific branch, tag, or commit SHA.

Returns the immutable revision the server resolved the request to, or None for providers that do not expose revisions.

pub async fn request_model( &mut self, model_name: impl Into<String>, provider: ModelProvider, ignore_weights: bool, ) -> CommonResult<()>

Request a model through the client, using the server as the source of truth. When shared_storage is disabled, files will be streamed from server to client.

pub async fn request_model_revision( &mut self, model_name: impl Into<String>, provider: ModelProvider, ignore_weights: bool, revision: Option<&str>, ) -> CommonResult<ModelDownloadResult>

Request a model at a specific branch, tag, or commit SHA, reporting the snapshot path and the immutable revision the request resolved to.

When shared_storage is disabled, files are streamed from the server into the local cache under that resolved revision.

pub async fn request_model_with_smart_fallback( model_name: impl Into<String>, provider: ModelProvider, config: Config, ignore_weights: bool, ) -> CommonResult<()>

Request a model with automatic server fallback, creating client connection only if needed. This function will try to download via server if possible, otherwise download directly only if the initial client connection cannot be established.

pub async fn request_model_with_smart_fallback_revision( model_name: impl Into<String>, provider: ModelProvider, config: Config, ignore_weights: bool, revision: Option<&str>, ) -> CommonResult<ModelDownloadResult>

Revision-aware Client::request_model_with_smart_fallback. The direct-download fallback honours the same revision, so a pinned request cannot silently land on a different commit just because the server was unreachable.