Struct AuditLogSubscriber 

pub struct AuditLogSubscriber { /* private fields */ }

Subscriber that persists every received event as an audit log entry.

Extracts contextual IDs (run, step, user) from the event payload for efficient filtering, and stores the full event as JSON.

Examples

use std::sync::Arc;
use ironflow_engine::notify::{AuditLogSubscriber, Event, EventPublisher};
use ironflow_store::memory::InMemoryStore;

let store = Arc::new(InMemoryStore::new());
let mut publisher = EventPublisher::new();
publisher.subscribe(
    AuditLogSubscriber::new(store),
    Event::ALL,
);

Implementations

impl AuditLogSubscriber

pub fn new(store: Arc<dyn AuditLogStore>) -> Self

Create a new subscriber backed by the given store.

Examples

use std::sync::Arc;
use ironflow_engine::notify::AuditLogSubscriber;
use ironflow_store::memory::InMemoryStore;

let store = Arc::new(InMemoryStore::new());
let subscriber = AuditLogSubscriber::new(store);

Trait Implementations

impl EventSubscriber for AuditLogSubscriber

fn name(&self) -> &str

A short identifier for this subscriber (used in logs).

fn handle<'a>(&'a self, event: &'a Event) -> SubscriberFuture<'a>

Handle a domain event.