Struct AudienceIndex 

pub struct AudienceIndex { /* private fields */ }

Resolves any telemetry id -> its owning process’s audience, from Postgres, cached and TTL-bounded. See the module doc comment for the full rationale.

Implementations

impl AudienceIndex

pub fn new( pool: Pool<Postgres>, max_entries: u64, ttl: Duration, default_audience: Arc<str>, ) -> AudienceIndex

pub async fn resolve( &self, id: Uuid, kind: IdKind, ) -> Result<OwnerAudience, Error>

Resolves a single id. A thin wrapper over Self::resolve_many – always at least as cheap, and the batch path is where the actual query lives.

pub async fn resolve_many( &self, ids: &[Uuid], kind: IdKind, ) -> Result<HashMap<Uuid, OwnerAudience>, Error>

Resolves a batch of ids of the same kind in at most one round trip (cache misses only). Unknown is never cached – a miss may just mean “not ingested yet”, and caching it would both pin a wrong answer and let a caller pollute the cache with random ids.

Trait Implementations

impl Debug for AudienceIndex

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

Formats the value using the given formatter.