Struct ActivePacks 

pub struct ActivePacks { /* private fields */ }

Atomically swapped view of live tenant runtimes.

Reads are lock-free via ArcSwap. Mutations serialize on write_lock so a read-modify-write swap (e.g. a watcher reload preserving revision entries) cannot interleave with a concurrent insert and clobber the other’s update.

Implementations

impl ActivePacks

pub fn new() -> ActivePacks

pub fn load_pack(&self, tenant: &str) -> Option<Arc<TenantRuntime>>

Look up the tenant-only (legacy) runtime. Compatibility helper for the pre-revision-routing path; see load_revision.

pub fn load_revision( &self, tenant: &str, deployment_id: DeploymentId, bundle_id: BundleId, revision_id: RevisionId, ) -> Option<Arc<TenantRuntime>>

Look up the runtime for a specific deployment/bundle/revision.

pub fn snapshot(&self) -> Arc<HashMap<RuntimeKey, Arc<TenantRuntime>>>

pub fn insert_pack(&self, tenant: &str, runtime: Arc<TenantRuntime>)

Insert (or replace) a single tenant-only runtime, preserving all other entries — including revision-keyed ones.

pub fn insert_revision( &self, tenant: &str, deployment_id: DeploymentId, bundle_id: BundleId, revision_id: RevisionId, runtime: Arc<TenantRuntime>, ) -> Result<(), Error>

Insert (or replace) a single revision-keyed runtime, preserving every other entry — the tenant-only legacy entry and sibling revisions alike. This is the producer the deployment warm path calls once a revision’s packs are loaded; the pack watcher’s replace_legacy then carries the entry across tenant-pack reloads untouched.

Fails closed when the runtime’s identity does not match the key it would be stored under: a wiring bug that files one tenant’s runtime under another tenant’s revision (breaking isolation) or stores a runtime whose telemetry reports a different revision than it routes (breaking rollout attribution) is rejected here rather than silently serving traffic under the wrong identity. Pairs with TenantRuntime::load_revision, which derives the runtime’s rollout identity from these same ids.

pub fn replace_legacy(&self, legacy: HashMap<RuntimeKey, Arc<TenantRuntime>>)

Swap in a freshly-resolved set of tenant-only (legacy) runtimes while carrying over every revision-keyed entry. Used by the pack watcher, whose index is authoritative for tenant packs but not for deployment revisions.

pub fn remove_revision( &self, tenant: &str, deployment_id: DeploymentId, bundle_id: BundleId, revision_id: RevisionId, ) -> Option<Arc<TenantRuntime>>

Remove and return the runtime for a single revision-keyed entry, preserving every other entry (legacy and revision alike). Used by the drain coordinator (gtc op revisions drain) after the drain window closes to tear down exactly the one revision being retired. None if no such entry was present — idempotent for safe re-runs.

pub fn replace(&self, next: HashMap<RuntimeKey, Arc<TenantRuntime>>)

Replace the entire map, dropping every entry (legacy and revision alike). Used for full host stop.

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

Trait Implementations

impl Default for ActivePacks

fn default() -> ActivePacks

Returns the “default value” for a type.