Struct FileSystemContext 

pub struct FileSystemContext { /* private fields */ }

Shared connection context for Goosefs filesystem operations.

A single FileSystemContext instance should be created per Goosefs cluster and shared across all BaseFileSystem, GoosefsFileInStream, and GoosefsFileWriter instances that connect to that cluster.

The context owns:

• One persistent gRPC channel to the Master
• One persistent gRPC channel to the WorkerManager service
• One WorkerClientPool shared across all readers and writers
• One WorkerRouter that tracks live workers and routes block reads

Implementations

impl FileSystemContext

pub async fn connect(config: GoosefsConfig) -> Result<Arc<Self>>

Build a FileSystemContext by connecting to the Goosefs cluster.

Establishes persistent connections to the Master and WorkerManager, fetches the initial worker list, and starts a background refresh task.

This is the only call that performs network I/O. All subsequent operations on the context are zero-cost Arc clones.

pub fn acquire_master(&self) -> Arc<MasterClient>

Return the shared MasterClient (zero-cost Arc clone).

pub fn acquire_worker_manager(&self) -> Arc<WorkerManagerClient>

Return the shared WorkerManagerClient (zero-cost Arc clone).

pub fn acquire_worker_pool(&self) -> Arc<WorkerClientPool>

Return the shared WorkerClientPool (zero-cost Arc clone).

pub fn acquire_router(&self) -> Arc<WorkerRouter>

Return the shared WorkerRouter (zero-cost Arc clone).

pub fn acquire_inquire_client(&self) -> Arc<dyn MasterInquireClient>

Return the shared MasterInquireClient (zero-cost Arc clone).

pub fn config(&self) -> &GoosefsConfig

Return the configuration used to build this context.

pub fn acquire_config_refresher(&self) -> Arc<ConfigRefresher>

Return the shared ConfigRefresher (zero-cost Arc clone).

Use this to query the current transparent acceleration switch values or to trigger a config reload check.

pub fn refresh_transparent_acceleration_switch( &self, ) -> TransparentAccelerationSwitch

Refresh the transparent acceleration switch by reloading config if expired.

Convenience wrapper around ConfigRefresher::refresh_transparent_acceleration_switch(). Mirrors Java’s AbstractCompatibleFileSystem.refreshTransparentAccelerationSwitch().

pub async fn close(&self) -> Result<()>

Gracefully shut down the context.

Aborts the background refresh task and marks the context as closed. Idempotent — safe to call multiple times.

pub fn is_closed(&self) -> bool

Return true if close() has been called.

Trait Implementations

impl Drop for FileSystemContext

fn drop(&mut self)

Executes the destructor for this type.