Struct MasterClient 

pub struct MasterClient { /* private fields */ }

Client for Goosefs FileSystemMasterClientService (Master:9200).

In HA mode, the client holds a reference to the MasterInquireClient and can automatically re-discover the Primary Master when RPCs fail.

Authentication

The client supports NOSASL and SIMPLE authentication modes. When config.auth_type is Simple, the client performs a SASL PLAIN handshake after establishing the gRPC channel, then injects a channel-id metadata header into all subsequent RPCs.

Implementations

impl MasterClient

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

Connect to the Goosefs Master.

In single-master mode, connects directly to config.master_addr. In HA mode (multiple addresses in config.master_addrs), uses PollingMasterInquireClient to discover the Primary first.

Authentication is performed according to config.auth_type.

pub async fn connect_with_inquire( config: &GoosefsConfig, inquire_client: Arc<dyn MasterInquireClient>, ) -> Result<Self>

Connect using an externally-provided MasterInquireClient.

This is useful when sharing a single inquire client across multiple client types (e.g. MasterClient + WorkerManagerClient).

pub fn from_channel(channel: Channel, config: GoosefsConfig) -> Self

Create from an existing tonic channel (useful for testing / channel sharing).

Note: This bypasses authentication. The channel is wrapped with a no-op channel-id interceptor for API compatibility.

pub async fn get_status(&self, path: &str) -> Result<FileInfo>

Get the file/directory status (equivalent to stat / head).

pub async fn list_status( &self, path: &str, recursive: bool, ) -> Result<Vec<FileInfo>>

List the contents of a directory. Returns all FileInfo entries.

This wraps a server-side streaming RPC — the server sends multiple ListStatusPResponse messages, each containing a batch of FileInfo.

pub async fn create_file( &self, path: &str, options: CreateFilePOptions, ) -> Result<FileInfo>

Create a new file. Returns the FileInfo of the created file.

pub async fn complete_file( &self, path: &str, ufs_length: Option<i64>, operation_id: Option<FsOpPId>, ) -> Result<()>

Mark a file as completed (called after all blocks are written).

Idempotent operation ID

operation_id is used by the Master for exactly-once semantics: if the RPC is retried after a network hiccup the Master detects the duplicate via FsOpPId and returns success without applying the operation twice.

The caller (GoosefsFileWriter) generates a fresh uuid::Uuid at construction time and reuses it across all complete_file calls for the same write session. The UUID is split into two i64 halves via Uuid::as_u64_pair():

(high, low) = uuid.as_u64_pair()
FsOpPId { most_significant_bits: high as i64,
          least_significant_bits: low  as i64 }

This matches Java UUID.getMostSignificantBits() / getLeastSignificantBits() as verified in DefaultFileSystemMaster.completeFile().

Note on Go SDK bug

The Go SDK base_filesystem.go:394-400 accepts an operationID parameter but never writes it to the proto request. The Rust implementation fixes this: operation_id is always wired into CompleteFilePOptions.

pub async fn remove_blocks(&self, block_ids: Vec<i64>) -> Result<()>

Request the Master to free block metadata for the given block IDs.

This is the preferred cleanup path for GoosefsFileWriter::cancel(): it removes only the block metadata on the Master without touching the file-system namespace entry (the INCOMPLETE inode).

Falls back to delete_with_options(unchecked=true) when this RPC fails.

Java authority

Matches FileSystemMasterClientServiceHandler.removeBlocks() → DefaultFileSystemMaster.removeBlocks(blockIds).

pub async fn delete_with_options( &self, path: &str, opts: DeleteOptions, ) -> Result<()>

Delete a file or directory with fine-grained options.

Prefer this over the legacy delete wrapper when you need unchecked or goosefs_only semantics.

See DeleteOptions for field semantics and Java authority notes.

pub async fn delete(&self, path: &str, recursive: bool) -> Result<()>

Delete a file or directory (simple recursive wrapper).

For unchecked or goosefs_only deletion use delete_with_options directly.

pub async fn rename(&self, src: &str, dst: &str) -> Result<()>

Rename (move) a file or directory.

pub async fn create_directory(&self, path: &str, recursive: bool) -> Result<()>

Create a directory (recursive by default).

Sets a default mode of 0755 (rwxr-xr-x) so that the corresponding UFS directory created by Goosefs has usable permissions.

pub async fn schedule_async_persistence( &self, path: &str, persistence_wait_time: Option<i64>, ) -> Result<()>

Schedule asynchronous persistence for a file. This will persist the file to the underlying storage system.

pub fn config(&self) -> &GoosefsConfig

Get a reference to the underlying config.

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

Get a reference to the underlying inquire client.

Useful for sharing the same inquire client with WorkerManagerClient.

Trait Implementations

impl Clone for MasterClient

fn clone(&self) -> MasterClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.