Struct TenantHandle 

pub struct TenantHandle { /* private fields */ }

Stable handle returned by TenantRegistry::register. Clones share the same underlying state, so multiple producer threads inside one tenant can publish through their own handles.

Implementations

impl TenantHandle

pub fn id(&self) -> u32

Stable tenant id; maps onto the ring-slot TENANT_WORD.

pub fn label(&self) -> &str

Human-readable label supplied at registration time.

pub fn base_opcode(&self) -> u32

First opcode this tenant owns.

pub fn global_opcode(&self, local: u32) -> Result<u32, TenantError>

Convert a tenant-local opcode to the global opcode used in the ring slot. Caller enforces local < opcode_cap().

Errors

Returns TenantError::OpcodeOutOfRange when the local value is outside the reserved window.

pub fn publish_slot( &self, ring_bytes: &mut [u8], slot_idx: u32, local_opcode: u32, args: &[u32], ) -> Result<(), TenantError>

Publish a slot into the tenant’s ring with a tenant-local opcode. Convenience wrapper that composes Megakernel::publish_slot with tenant bookkeeping.

Errors

• TenantError::Revoked if the tenant was unregistered.
• TenantError::OpcodeOutOfRange if local_opcode is outside the tenant’s window.
• TenantError::Pipeline when the underlying publish_slot rejects (e.g., slot still in-flight).

pub fn published_count(&self) -> u64

Number of slots this tenant has ever published.

pub fn drained_count(&self) -> u64

Number of slots this tenant has observed drained (via note_drained).

pub fn max_outstanding_slots(&self) -> u64

Maximum host-visible slots this tenant may keep outstanding.

pub fn reserve_staging_bytes(&self, byte_count: u64) -> Result<(), TenantError>

Reserve staging bytes against this tenant’s quota.

pub fn release_staging_bytes(&self, byte_count: u64) -> Result<(), TenantError>

Release staging bytes previously reserved by this tenant.

pub fn reserve_resident_handles( &self, handle_count: u64, ) -> Result<(), TenantError>

Reserve resident handles against this tenant’s quota.

pub fn release_resident_handles( &self, handle_count: u64, ) -> Result<(), TenantError>

Release resident handles previously reserved by this tenant.

pub fn quota_counters(&self) -> TenantQuotaCounters

Snapshot quota counters for this tenant.

pub fn runtime_counters(&self) -> TenantRuntimeCounters

Snapshot host-visible runtime counters for this tenant.

pub fn note_drained(&self, count: u64)

Mark count slots as drained. The host pump that observes DONE_COUNT calls this when it sees the global counter advance past the tenant’s last-published cursor.

pub fn quiesce(&self, max_spins: u64) -> Result<(), TenantError>

Block-style quiesce: bounded backoff until every published slot has been drained or max_spins polls elapse.

Errors

Returns TenantError::QuiesceTimeout when max_spins iterations pass without full drain. The outstanding count at timeout is included for diagnostics.

Trait Implementations

impl Clone for TenantHandle

fn clone(&self) -> TenantHandle

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TenantHandle

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.