Crate eventuali_core

Crate eventuali_core 

Source

Re-exports§

pub use event::Event;
pub use event::EventData;
pub use event::EventId;
pub use event::EventMetadata;
pub use aggregate::Aggregate;
pub use aggregate::AggregateId;
pub use aggregate::AggregateVersion;
pub use store::EventStore;
pub use store::EventStoreConfig;
pub use store::EventStoreImpl;
pub use store::create_event_store;
pub use error::EventualiError;
pub use error::Result;
pub use proto::ProtoSerializer;
pub use streaming::EventStreamer;
pub use streaming::EventStreamReceiver;
pub use streaming::StreamEvent;
pub use streaming::Subscription;
pub use streaming::SubscriptionBuilder;
pub use streaming::InMemoryEventStreamer;
pub use streaming::EventStreamProcessor;
pub use streaming::Projection;
pub use streaming::ProjectionProcessor;
pub use streaming::SagaHandler;
pub use streaming::SagaProcessor;
pub use snapshot::AggregateSnapshot;
pub use snapshot::SnapshotStore;
pub use snapshot::SnapshotService;
pub use snapshot::SnapshotConfig;
pub use snapshot::SnapshotCompression;
pub use snapshot::SnapshotMetadata;
pub use snapshot::SqliteSnapshotStore;
pub use security::EventEncryption;
pub use security::KeyManager;
pub use security::EncryptionKey;
pub use security::EncryptedEventData;
pub use security::EncryptionAlgorithm;
pub use tenancy::TenantId;
pub use tenancy::TenantInfo;
pub use tenancy::TenantConfig;
pub use tenancy::TenantMetadata;
pub use tenancy::TenantIsolation;
pub use tenancy::IsolatedEventStore;
pub use tenancy::TenantScope;
pub use tenancy::TenantQuota;
pub use tenancy::ResourceType;
pub use tenancy::TenantManager;
pub use tenancy::TenantOperations;
pub use tenancy::TenantAwareEventStorage;
pub use tenancy::TenantStorageMetrics;
pub use tenancy::TenantEventBatch;
pub use tenancy::TenantScopedProjection;
pub use tenancy::TenantProjectionManager;
pub use tenancy::TenantProjectionRegistry;
pub use tenancy::TenantProjectionMetrics;
pub use performance::ConnectionPool;
pub use performance::PoolConfig;
pub use performance::PoolStats;
pub use performance::WalConfig;
pub use performance::WalOptimizer;
pub use performance::WalStats;
pub use performance::WalSynchronousMode;
pub use performance::WalJournalMode;
pub use performance::TempStoreMode;
pub use performance::AutoVacuumMode;
pub use performance::benchmark_wal_configurations;
pub use observability::ObservabilityService;
pub use observability::ObservabilityServiceBuilder;
pub use observability::ObservabilityConfig;
pub use observability::TelemetryProvider;
pub use observability::TracingService;
pub use observability::TraceContext;
pub use observability::EventTrace;
pub use observability::MetricsCollector;
pub use observability::PrometheusExporter;
pub use observability::EventMetrics;
pub use observability::PerformanceMetrics;
pub use observability::StructuredLogger;
pub use observability::LogLevel;
pub use observability::LogContext;
pub use observability::CorrelationLogger;
pub use observability::CorrelationId;
pub use observability::CorrelationContext;
pub use observability::CorrelationTracker;
pub use observability::generate_correlation_id;
pub use store::postgres::PostgreSQLBackend;
pub use store::sqlite::SQLiteBackend;

Modules§

aggregate
error
event
Core event types and structures for the Eventuali event sourcing library.
observability
Observability module for comprehensive monitoring, tracing, and metrics collection.
performance
Performance optimization modules for Eventuali
proto
security
Security module providing encryption, digital signatures, audit trails, RBAC, and GDPR compliance
snapshot
store
Event store implementations and abstractions.
streaming
Real-time event streaming and projections.
tenancy
Multi-tenancy module providing tenant isolation, scoped operations, and resource management