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 consumer::{Consumer, ConsumerRegistry};
25pub use creator_coordinator::{ArticlePerformance, CreatorCoordinator, CreatorDashboard};
26pub use event_coordinator::{BatchIngestResult, EntityHistory, EntitySnapshot, EventCoordinator};
27pub use exactly_once::{ExactlyOnceConfig, ExactlyOnceRegistry, ExactlyOnceStats};
28pub use payment_coordinator::{PaymentCoordinator, PurchaseResult};
29pub use pipeline::{Pipeline, PipelineConfig, PipelineManager, PipelineOperator, PipelineStats};
30pub use projection::{
31    EntitySnapshotProjection, EventCounterProjection, Projection, ProjectionManager,
32};
33pub use replay::{ReplayManager, ReplayProgress, StartReplayRequest, StartReplayResponse};
34pub use schema::{
35    CompatibilityMode, RegisterSchemaRequest, RegisterSchemaResponse, SchemaRegistry,
36    SchemaRegistryConfig, ValidateEventRequest, ValidateEventResponse,
37};
38pub use schema_evolution::{EvolutionAction, SchemaEvolutionManager, SchemaEvolutionStats};
39pub use vector_search::{
40    BatchIndexResult, IndexEventRequest, IndexStats, SemanticSearchRequest, SemanticSearchResponse,
41    SemanticSearchResultItem, VectorSearchConfig, VectorSearchService,
42};
43pub use webhook::{
44    DeliveryStatus, RegisterWebhookRequest, UpdateWebhookRequest, WebhookDelivery, WebhookRegistry,
45    WebhookSubscription,
46};