nemo_rl.data_plane.nixl.directory#

BlobDirectory: storage-unit membership.

Deliberately tiny and not a catalog: no keys, fields, produced bits or cursors (the TransferQueue controller owns those) and no blob locations (rows live on unit gidx % N). Clients read the unit table from it.

Module Contents#

Classes#

Data#

API#

nemo_rl.data_plane.nixl.directory.ACTIVE#

‘ACTIVE’

nemo_rl.data_plane.nixl.directory.DRAINING#

‘DRAINING’

nemo_rl.data_plane.nixl.directory.DEAD#

‘DEAD’

class nemo_rl.data_plane.nixl.directory.BlobDirectory#

Initialization

register_unit(info: dict[str, Any]) → int#
set_unit_state(unit_id: int, state: str) → int#
units(min_epoch: int = 0) → tuple[int, list[dict[str, Any]]]#
epoch() → int#
stats() → dict[str, Any]#