Struct ArcAppBuilder 

pub struct ArcAppBuilder { /* private fields */ }

Application builder holding type-erased registrations for every aggregate served by the process. Each registration produces its own typed CommandBus<A> while sharing the configured storage backend.

Implementations

impl ArcAppBuilder

pub fn register_aggregate<A: Aggregate + 'static>(self) -> Self

Register a writable aggregate type. Arc creates and injects a distinct CommandBus<A> for every call.

pub fn register_projectors(self, projectors: Vec<ProjectorReg>) -> Self

Register all projectors for the most recently registered aggregate.

pub fn register_projector( self, projector: impl Projector + 'static, view: impl Into<String>, ) -> Self

Register a single projector for the most recently registered aggregate.

pub fn register_routes<F>(self, f: F) -> Self

where F: Fn(&mut ServiceConfig) + Send + Sync + 'static,

Mount the application’s own routes. Framework handlers (static assets, websocket, health) are exported from this crate for the closure to reference; the application owns which routes it mounts.

pub fn register_data<T>(self, data: Arc<T>) -> Self

where T: ?Sized + Send + Sync + 'static,

Inject shared typed state contributed by an application or plugin.

pub fn register_plugin<P: ArcPlugin>(self, plugin: P) -> Self

Register a compile-time capability package.

pub async fn setup_plugins( &self, context: &PluginSetupContext<'_>, ) -> Result<()>

Run setup hooks for every registered capability package in order.

pub fn snapshot_policy(self, policy: Option<SnapshotPolicy>) -> Self

Snapshot policy for the most recently registered aggregate.

pub async fn serve(self, app_url: String, app_port: u16) -> Result<()>

Boot the HTTP server with every registered aggregate and the application’s routes.