Struct AirServiceProvider 

pub struct AirServiceProvider {
    client: Arc<AirClient>,
}

High-level provider over AirClient. Holds the client in an Arc so consumers can share one channel across the application.

Fields

client: Arc<AirClient>

Shared underlying gRPC client.

Implementations

impl AirServiceProvider

pub async fn Authenticate( &self, username: String, password: String, provider: String, ) -> Result<String, AirError>

Authenticates a user against the named provider ("github", "gitlab", "microsoft", …) and returns the session token on success.

impl AirServiceProvider

pub async fn CheckForUpdates( &self, current_version: String, channel: String, ) -> Result<Option<Struct>, AirError>

Checks for an available update on the given channel ("stable" / "beta" / "nightly").

Returns Ok(Some(info)) when an update is offered and Ok(None) when the daemon reports no update.

impl AirServiceProvider

pub async fn DownloadUpdate( &self, url: String, destination_path: String, checksum: String, ) -> Result<Struct, AirError>

Downloads an update package to destination_path. The optional checksum is forwarded as-is; an empty string skips server-side verification.

impl AirServiceProvider

pub async fn DownloadFile( &self, url: String, destination_path: String, checksum: String, ) -> Result<Struct, AirError>

Downloads url to destination_path. The optional checksum is forwarded for server-side verification; an empty string skips verification.

impl AirServiceProvider

pub async fn DownloadStream( &self, url: String, headers: HashMap<String, String>, ) -> Result<Struct, AirError>

Starts a streaming download from url. The returned wrapper yields DownloadStreamDTO::Struct items until chunk.completed == true.

impl AirServiceProvider

pub async fn GetFileInfo(&self, path: String) -> Result<Struct, AirError>

Returns metadata for the file at path (size, mime type, checksum, modified time).

impl AirServiceProvider

pub async fn IndexFiles( &self, path: String, patterns: Vec<String>, exclude_patterns: Vec<String>, max_depth: u32, ) -> Result<Struct, AirError>

Indexes files under path. patterns includes globs to match; exclude_patterns filters those out. max_depth of 0 is unlimited.

impl AirServiceProvider

pub async fn SearchFiles( &self, query: String, path: String, max_results: u32, ) -> Result<Vec<Struct>, AirError>

Searches for query under path. max_results of 0 is unlimited.

impl AirServiceProvider

pub async fn GetMetrics( &self, metric_type: Option<String>, ) -> Result<Struct, AirError>

Fetches daemon metrics. metric_type of None returns all counters; common values are "performance", "resources", "requests".

impl AirServiceProvider

pub async fn GetStatus(&self) -> Result<Struct, AirError>

Fetches the daemon’s runtime status snapshot.

impl AirServiceProvider

pub async fn GetResourceUsage(&self) -> Result<Struct, AirError>

Returns the daemon’s current resource-usage snapshot.

impl AirServiceProvider

pub async fn SetResourceLimits( &self, memory_limit_mb: u32, cpu_limit_percent: u32, disk_limit_mb: u32, ) -> Result<(), AirError>

Sets memory / CPU / disk caps on the daemon.

• memory_limit_mb - memory budget in MB
• cpu_limit_percent - 0-100
• disk_limit_mb - disk budget in MB

impl AirServiceProvider

pub async fn GetConfiguration( &self, section: String, ) -> Result<HashMap<String, String>, AirError>

Reads a configuration section as a key/value map. Common sections: "grpc", "authentication", "updates".

impl AirServiceProvider

pub async fn UpdateConfiguration( &self, section: String, updates: HashMap<String, String>, ) -> Result<(), AirError>

Writes the key/value pairs in updates to the named configuration section. Keys not in updates are left untouched.

impl AirServiceProvider

pub async fn ApplyUpdate( &self, version: String, update_path: String, ) -> Result<(), AirError>

Applies the update package at update_path and tags it with version for the daemon’s bookkeeping.

impl AirServiceProvider

pub async fn new(address: String) -> Result<Self, AirError>

Connects to the Air daemon at address and returns a ready-to-use provider.

Errors

Forwards any error from AirClient::new.

pub async fn NewDefault() -> Result<Self, AirError>

Connects using DEFAULT_AIR_SERVER_ADDRESS.

pub fn FromClient(Client: Arc<AirClient>) -> Self

Wraps an existing AirClient handle. Useful when the gRPC channel is created elsewhere or shared with a non-provider call site.

pub fn Client(&self) -> &Arc<AirClient>

Shared reference to the underlying client.

pub fn IsConnected(&self) -> bool

Whether the underlying client is connected.

pub fn Address(&self) -> &str

Address of the Air daemon.

Trait Implementations

impl Clone for AirServiceProvider

fn clone(&self) -> AirServiceProvider

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AirServiceProvider

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.