Struct P2pStateManager 

pub struct P2pStateManager { /* private fields */ }

State manager that handles P2P metadata operations.

Wraps the metadata backend abstraction and provides a simpler API for common operations. Configure via MX_METADATA_BACKEND env var.

Implementations

impl P2pStateManager

pub fn new() -> Self

Create a new state manager, resolving backend config from the environment.

Configure via MX_METADATA_BACKEND (required) and REDIS_URL / MX_REDIS_HOST / MX_REDIS_PORT (for Redis).

pub fn with_config(config: BackendConfig) -> Self

Create a new state manager with an explicit backend configuration.

pub async fn connect(&self) -> MetadataResult<String>

Initialize the backend connection. Returns the backend type name on success.

pub async fn publish_metadata( &self, identity: &SourceIdentity, worker_id: &str, worker: WorkerMetadata, ) -> MetadataResult<()>

Publish metadata for a source instance.

pub async fn get_metadata( &self, source_id: &str, worker_id: &str, ) -> MetadataResult<Option<ModelMetadataRecord>>

Get full tensor metadata for one specific instance.

pub async fn list_workers( &self, source_id: Option<String>, status_filter: Option<SourceStatus>, ) -> MetadataResult<Vec<SourceInstanceInfo>>

List available source instances, optionally filtered by status.

pub async fn remove_metadata(&self, source_id: &str) -> MetadataResult<()>

Remove metadata by mx_source_id.

pub async fn remove_worker( &self, source_id: &str, worker_id: &str, ) -> MetadataResult<()>

Remove a single worker by source_id and worker_id.

pub async fn list_sources(&self) -> MetadataResult<Vec<(String, String)>>

List all registered source IDs and model names.

pub async fn update_worker_status( &self, source_id: &str, worker_id: &str, worker_rank: u32, status: SourceStatus, ) -> MetadataResult<()>

Update the status of a worker within its stored metadata record.

Trait Implementations

impl Clone for P2pStateManager

fn clone(&self) -> P2pStateManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for P2pStateManager

fn default() -> Self

Returns the “default value” for a type.