Skip to main content

allsource_core/application/services/
mod.rs

1// Application services layer
2// Contains business logic orchestration and domain service implementations
3
4pub mod analytics;
5pub mod audit_logger;
6pub mod creator_coordinator;
7pub mod event_coordinator;
8pub mod payment_coordinator;
9pub mod pipeline;
10pub mod projection;
11pub mod replay;
12pub mod schema;
13pub mod vector_search;
14pub mod webhook;
15// v0.14: Durable subscriptions
16pub mod consumer;
17// v2.0: Advanced features
18pub mod exactly_once;
19pub mod schema_evolution;
20
21// Re-exports for convenience
22pub use analytics::AnalyticsEngine;
23pub use audit_logger::{AuditLogger, RequestContext};
24pub use creator_coordinator::{ArticlePerformance, CreatorCoordinator, CreatorDashboard};
25pub use event_coordinator::{BatchIngestResult, EntityHistory, EntitySnapshot, EventCoordinator};
26pub use exactly_once::{ExactlyOnceConfig, ExactlyOnceRegistry, ExactlyOnceStats};
27pub use payment_coordinator::{PaymentCoordinator, PurchaseResult};
28pub use pipeline::{Pipeline, PipelineConfig, PipelineManager, PipelineOperator, PipelineStats};
29pub use projection::{
30    EntitySnapshotProjection, EventCounterProjection, Projection, ProjectionManager,
31};
32pub use replay::{ReplayManager, ReplayProgress, StartReplayRequest, StartReplayResponse};
33pub use schema::{
34    CompatibilityMode, RegisterSchemaRequest, RegisterSchemaResponse, SchemaRegistry,
35    SchemaRegistryConfig, ValidateEventRequest, ValidateEventResponse,
36};
37pub use schema_evolution::{EvolutionAction, SchemaEvolutionManager, SchemaEvolutionStats};
38pub use vector_search::{
39    BatchIndexResult, IndexEventRequest, IndexStats, SemanticSearchRequest, SemanticSearchResponse,
40    SemanticSearchResultItem, VectorSearchConfig, VectorSearchService,
41};
42pub use consumer::{Consumer, ConsumerRegistry};
43pub use webhook::{
44    DeliveryStatus, RegisterWebhookRequest, UpdateWebhookRequest, WebhookDelivery, WebhookRegistry,
45    WebhookSubscription,
46};