OSSS.ai.events.emitter

OSSS.ai.events.emitter

Enhanced Event System for OSSS.

This module provides an enhanced event-driven architecture with multi-axis agent classification, correlation context propagation, and production-ready event sinks for observability and future service extraction.

EventEmitter

Fan-out async event emitter that forwards WorkflowEvent objects to sinks. Safe for use from both async and sync contexts.

emit(event) async

Emit an event to all sinks. Never raises (observability must not crash app).

get_global_event_emitter()

Lazily create a default global emitter. Default sinks are safe: console + in-memory.