Scoria.Observe.OperatorBroadcast (scoria v0.1.2)

Copy Markdown View Source

Tenant-scoped PubSub fan-out for operator dashboard live events.

Publishes incremental trace deltas to scoria:runs:{tenant_id}. Tracks seen trace_id values per BEAM node in ETS (:scoria_observe_operator_broadcast_trace_seen) so {:trace_opened, _} is emitted only on the first span stop for a trace on this node.

Missing tenant_id drops broadcast (fail closed) with a debug log — no global topic fallback.

Summary

Functions

approval_decided(tenant_id, approval_id, status)

broadcast(tenant_id, message)

hitl_request(tenant_id, projection_map)

reset_trace_seen!()

span_delta(arg1)

span_stopped(metadata)

tenant_topic(tenant_id)