forge-runtime 0.9.0

Runtime executors and gateway for the Forge framework
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59

//! Forge runtime engine.
//!
//! Implements the Axum gateway, job worker, workflow executor, cron scheduler,
//! daemon runner, reactivity system, cluster coordination, rate limiting,
//! observability, and product analytics (signals).
//!
//! The runtime wires together types from `forge-core` into a production server
//! started via `Forge::builder().auto_register().build()?.run().await`.

pub use sqlx;

pub mod cluster;
pub mod cron;
pub mod daemon;
pub mod db;
pub mod function;
pub mod gateway;
pub mod jobs;
pub mod mcp;
pub mod migrations;
pub mod observability;
pub mod rate_limit;
pub mod realtime;
pub mod signals;
pub mod testing;
pub mod webhook;
pub mod workflow;

pub use cluster::{
    GracefulShutdown, HeartbeatConfig, HeartbeatLoop, InFlightGuard, LeaderConfig, LeaderElection,
    LeaderGuard, NodeCounts, NodeRegistry, ShutdownConfig,
};
pub use cron::{CronEntry, CronRecord, CronRegistry, CronRunner, CronStatus};
pub use daemon::{DaemonEntry, DaemonRegistry, DaemonRunner, DaemonRunnerConfig};
pub use db::Database;
pub use function::{FunctionExecutor, FunctionRegistry, FunctionRouter, RouteResult};
pub use gateway::{
    AuthMiddleware, GatewayConfig, GatewayServer, RpcError, RpcHandler, RpcRequest, RpcResponse,
    TracingMiddleware,
};
pub use jobs::{
    JobDispatcher, JobExecutor, JobQueue, JobRecord, JobRegistry, Worker, WorkerConfig,
};
pub use mcp::{McpToolEntry, McpToolRegistry};
pub use migrations::{MigrationExecutor, MigrationGenerator, SchemaDiff};
pub use observability::{
    TelemetryConfig, TelemetryError, build_env_filter, init_telemetry, shutdown_telemetry,
};
pub use rate_limit::RateLimiter;
pub use realtime::{
    AdaptiveTracker, AdaptiveTrackingConfig, AdaptiveTrackingStats, ChangeListener,
    InvalidationEngine, RealtimeConfig, RealtimeMessage, SessionManager, SessionServer,
    SubscriptionManager,
};
pub use webhook::{WebhookEntry, WebhookRegistry, WebhookState, webhook_handler};
pub use workflow::{
    EventStore, WorkflowEntry, WorkflowExecutor, WorkflowRecord, WorkflowRegistry,
    WorkflowScheduler, WorkflowSchedulerConfig, WorkflowStepRecord,
};