Crate tenzro_events 

Real-time event streaming, subscriptions, and webhook delivery for Tenzro Network

This crate provides a unified event model across all VMs and subsystems with monotonic sequencing, cursor-based replay, and rich filtering.

Architecture

VM Executors / Consensus / Token / Identity
    | in-process callbacks
    v
EventBus (ring buffer, broadcast channels)
    +-- Subscribers (unfiltered or filtered)
    +-- Future: gRPC, WebSocket, Webhook, Persistence

Re-exports

pub use types::TenzroEvent;

pub use types::EventEnvelope;

pub use types::EventFilter;

pub use types::EventType;

pub use types::VmType;

pub use types::SubscriptionId;

pub use types::SubscriptionConfig;

pub use types::event_type_name;

pub use bus::EventBus;

pub use bus::EventBusConfig;

pub use bus::EventBusStats;

pub use bus::EventBusError;

pub use bus::EventSubscriber;

pub use bus::FilteredEventSubscriber;

pub use bus::StatsSnapshot;

Modules

bus

EventBus — high-performance event distribution hub

types

Core event types for the Tenzro event streaming system

Constants

CF_EVENTS

RocksDB column family for event storage

CF_EVENT_INDEX

RocksDB column family for event index

CF_WEBHOOKS

RocksDB column family for webhook configuration

DEFAULT_BUS_CAPACITY

Default event bus capacity (number of events in ring buffer)

DEFAULT_RETENTION_SECS

Default event store retention (7 days in seconds)

VERSION

Event streaming crate version