Struct AirClient 

pub struct AirClient {
    client: Option<Arc<Mutex<AirServiceClient<Channel>>>>,
    address: String,
}

Air gRPC client wrapper.

Thread-safe via Arc<Mutex<…>>. Clones share the same underlying channel - clone is cheap (Arc ref-count bump). The address field is kept as the string the caller passed in so logs / Debug see the original form (http://[::1]:50053, etc.).

Fields

client: Option<Arc<Mutex<AirServiceClient<Channel>>>>

Underlying tonic gRPC client wrapped in Arc<Mutex<>> for shared, thread-safe access from multiple call sites.

address: String

Address of the Air daemon.

Implementations

impl AirClient

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

Authenticates a user with the Air daemon.

Arguments

• request_id - opaque correlation id; see module docs.
• username / password - credentials.
• provider - authentication provider name (e.g. "github", "gitlab", "microsoft").

Returns

On Ok, the session token string from the daemon.

impl AirClient

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

Applies an update package.

Arguments

• request_id - opaque correlation id.
• version - the version string of the update being applied.
• update_path - filesystem path of the downloaded update bundle.

impl AirClient

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

Checks for available updates.

Arguments

• request_id - opaque correlation id.
• current_version - the currently-running application version.
• channel - update channel ("stable", "beta", "nightly").

impl AirClient

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

Downloads an update package.

Arguments

• request_id - opaque correlation id.
• url - HTTPS URL of the update package.
• destination_path - local filesystem path the package writes to.
• checksum - SHA-256 hex string; empty disables verification.
• headers - extra HTTP headers (e.g. "Authorization").

impl AirClient

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

Downloads a file.

Arguments

• request_id - opaque correlation id.
• url - HTTPS URL of the file.
• destination_path - local filesystem path the file writes to.
• checksum - SHA-256 hex string; empty disables verification.
• headers - extra HTTP headers.

impl AirClient

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

Starts a streaming download.

Arguments

• request_id - opaque correlation id.
• url - HTTPS URL of the file.
• headers - extra HTTP headers (e.g. "Authorization").

impl AirClient

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

Gets extended file information.

impl AirClient

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

Indexes files in a directory.

Arguments

• request_id - opaque correlation id.
• path - root directory.
• patterns - glob include list (empty = include all).
• exclude_patterns - glob exclude list.
• max_depth - recursion bound; 0 indexes only path itself.

impl AirClient

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

Searches the index for files matching query.

Arguments

• request_id - opaque correlation id.
• query - search expression (provider-defined syntax).
• path - root path to scope the search; empty = whole index.
• max_results - hard cap on hits returned.

impl AirClient

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

Gets metrics from the Air daemon.

Arguments

• request_id - opaque correlation id.
• metric_type - optional filter ("performance" / "resources" / "requests"). None requests the full metric set.

impl AirClient

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

Gets daemon resource-usage stats.

impl AirClient

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

Gets the Air daemon status snapshot.

impl AirClient

pub async fn HealthCheck(&self) -> Result<bool, AirError>

Performs a health check on the Air daemon.

impl AirClient

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

Sets daemon resource ceilings.

Arguments

• request_id - opaque correlation id.
• memory_limit_mb - max resident memory.
• cpu_limit_percent - max CPU utilisation (whole percent).
• disk_limit_mb - max disk-usage budget.

impl AirClient

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

Reads a configuration section from the daemon.

impl AirClient

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

Updates configuration for the given section.

impl AirClient

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

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

Arguments

• address - gRPC server address (e.g. "http://[::1]:50053").

Errors

• AirError::Network if the address parses as a tonic Endpoint but the underlying connection attempt fails.
• AirError::Validation if the address string is malformed.

pub fn is_connected(&self) -> bool

Whether the client is connected to the Air daemon.

pub fn address(&self) -> &str

Address of the Air daemon.

pub(crate) fn Client(&self) -> Option<&Arc<Mutex<AirServiceClient<Channel>>>>

Borrow the underlying tonic client for issuing RPCs. Returns None when the client is disconnected. Per-domain method impls call this and then .lock().await to obtain the mutex guard before issuing the RPC.

Trait Implementations

impl Clone for AirClient

fn clone(&self) -> AirClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AirClient

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

Formats the value using the given formatter.