Struct GcCoordinator 

pub struct GcCoordinator { /* private fields */ }

Coordinator for distributed garbage collection.

Implementations

impl GcCoordinator

pub fn new(config: GcConfig) -> Self

Create a new GC coordinator with the given configuration.

pub fn report_active_blobs(&mut self, report: NodeBlobReport)

Receive a node’s report of its active and pinned blob sets.

pub fn run_gc_cycle(&mut self) -> GcCycleResult

Run a full GC cycle: compute the global active set, identify unreferenced blobs, respect the grace period, and return the cycle result.

pub fn pin_blob(&mut self, hash: [u8; 32])

Pin a blob to prevent it from being collected.

pub fn unpin_blob(&mut self, hash: [u8; 32])

Unpin a blob, allowing it to be collected if unreferenced.

pub fn register_blob(&mut self, hash: [u8; 32])

Register a new blob in the known set as active.

pub fn get_status(&self, hash: &[u8; 32]) -> Option<&BlobStatus>

Query the status of a blob.

pub fn prune_stale_nodes(&mut self) -> Vec<NodeId>

Remove reports from nodes whose timestamps are older than the stale threshold.

pub fn collection_history(&self) -> &[CollectionEvent]

Return the collection history log.