Struct XetCommon 

pub struct XetCommon {
    pub file_ingestion_semaphore: Arc<Semaphore>,
    pub file_download_semaphore: Arc<Semaphore>,
    pub reconstruction_download_buffer: Arc<AdjustableSemaphore>,
    pub active_downloads: Arc<AtomicU64>,
    /* private fields */
}

Holds global values that are shared across the entire runtime.

Accessible via XetRuntime::current().common().

Fields

file_ingestion_semaphore: Arc<Semaphore>

Limits the number of files being ingested (cleaned/uploaded) concurrently.

file_download_semaphore: Arc<Semaphore>

Limits the number of files being downloaded concurrently.

reconstruction_download_buffer: Arc<AdjustableSemaphore>

Limits total memory used for buffering data during reconstruction downloads.

active_downloads: Arc<AtomicU64>

Tracks the number of currently active file downloads for dynamic buffer scaling.

Implementations

impl XetCommon

pub fn new(config: &XetConfig) -> Self

Creates a new XetCommon instance with the given configuration.

pub fn get_or_create_reqwest_client<F>( &self, tag: String, create_client_fn: F, ) -> Result<Client>

where F: FnOnce() -> Result<Client, Error>,

Gets or creates a reqwest client, using a tag to identify the client type.

Arguments

• tag - A string identifier for the client (e.g., “tcp” for regular, socket path for UDS)
• create_client_fn - A function that creates the client if needed

Returns

Returns a clone of the cached client if the tag matches, or creates a new client if the tag differs.

Trait Implementations

impl Debug for XetCommon

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

Formats the value using the given formatter.