Struct ObsCallsiteRegistry 

pub struct ObsCallsiteRegistry { /* private fields */ }

Process-local callsite registry. Spec 31 § 3.2.

Concurrent access is allowed: the bridge writes once per first-sight callsite and reads once per envelope. DashMap matches CLAUDE.md guidance on concurrent maps.

Implementations

impl ObsCallsiteRegistry

pub fn new() -> Self

Empty registry.

pub fn len(&self) -> usize

Number of registered callsites.

pub fn is_empty(&self) -> bool

True if no callsites are registered.

pub fn insert_if_absent( &self, record: CallsiteRecord, ) -> (Arc<CallsiteRecord>, bool)

Insert record if absent. Returns (record, was_new) where was_new == true only when this call inserted the record. Spec 31 § 3.3.

pub fn get(&self, id: u64) -> Option<Arc<CallsiteRecord>>

Look up a record by id.

pub fn snapshot(&self) -> Vec<Arc<CallsiteRecord>>

Iterate records (snapshot — drops Refs before returning).

Trait Implementations

impl Debug for ObsCallsiteRegistry

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

Formats the value using the given formatter.

impl Default for ObsCallsiteRegistry

fn default() -> ObsCallsiteRegistry

Returns the “default value” for a type.