Crate forge_runtime

Crate forge_runtime 

Source

Re-exports§

pub use cluster::GracefulShutdown;
pub use cluster::HeartbeatConfig;
pub use cluster::HeartbeatLoop;
pub use cluster::InFlightGuard;
pub use cluster::LeaderConfig;
pub use cluster::LeaderElection;
pub use cluster::LeaderGuard;
pub use cluster::NodeCounts;
pub use cluster::NodeRegistry;
pub use cluster::ShutdownConfig;
pub use cron::CronEntry;
pub use cron::CronRecord;
pub use cron::CronRegistry;
pub use cron::CronRunner;
pub use cron::CronStatus;
pub use dashboard::DashboardApi;
pub use dashboard::DashboardAssets;
pub use dashboard::DashboardConfig;
pub use dashboard::DashboardPages;
pub use dashboard::DashboardState;
pub use dashboard::create_api_router;
pub use dashboard::create_dashboard_router;
pub use db::Database;
pub use function::FunctionExecutor;
pub use function::FunctionRegistry;
pub use function::FunctionRouter;
pub use function::RouteResult;
pub use gateway::AuthMiddleware;
pub use gateway::GatewayConfig;
pub use gateway::GatewayServer;
pub use gateway::RpcError;
pub use gateway::RpcHandler;
pub use gateway::RpcRequest;
pub use gateway::RpcResponse;
pub use gateway::TracingMiddleware;
pub use jobs::JobDispatcher;
pub use jobs::JobExecutor;
pub use jobs::JobQueue;
pub use jobs::JobRecord;
pub use jobs::JobRegistry;
pub use jobs::Worker;
pub use jobs::WorkerConfig;
pub use migrations::MigrationExecutor;
pub use migrations::MigrationGenerator;
pub use migrations::SchemaDiff;
pub use observability::Alert;
pub use observability::AlertCondition;
pub use observability::AlertEvaluator;
pub use observability::AlertRule;
pub use observability::AlertSeverity;
pub use observability::AlertStatus;
pub use observability::AlertStore;
pub use observability::ForgeTracingLayer;
pub use observability::LogCollector;
pub use observability::LogStore;
pub use observability::LogsConfig;
pub use observability::MetricsCollector;
pub use observability::MetricsConfig;
pub use observability::MetricsStore;
pub use observability::ObservabilityConfig;
pub use observability::ObservabilityState;
pub use observability::PartitionConfig;
pub use observability::PartitionGranularity;
pub use observability::PartitionManager;
pub use observability::SystemMetricsCollector;
pub use observability::SystemMetricsSnapshot;
pub use observability::TraceCollector;
pub use observability::TraceStore;
pub use observability::TraceSummary;
pub use observability::TracesConfig;
pub use rate_limit::RateLimiter;
pub use realtime::AdaptiveTracker;
pub use realtime::AdaptiveTrackingConfig;
pub use realtime::AdaptiveTrackingStats;
pub use realtime::ChangeListener;
pub use realtime::InvalidationEngine;
pub use realtime::SessionManager;
pub use realtime::SubscriptionManager;
pub use realtime::WebSocketConfig;
pub use realtime::WebSocketServer;
pub use workflow::EventStore;
pub use workflow::WorkflowEntry;
pub use workflow::WorkflowExecutor;
pub use workflow::WorkflowRecord;
pub use workflow::WorkflowRegistry;
pub use workflow::WorkflowScheduler;
pub use workflow::WorkflowSchedulerConfig;
pub use workflow::WorkflowStepRecord;
pub use sqlx;

Modules§

cluster
cron
dashboard
db
function
gateway
jobs
migrations
Database migration system.
observability
rate_limit
realtime
testing
Testing utilities for FORGE applications.
workflow

Macros§

assert_err
Assert that a result is Err.
assert_err_variant
Assert that an error matches a specific variant.
assert_job_dispatched
Assert that a job was dispatched.
assert_ok
Assert that a result is Ok.
assert_workflow_started
Assert that a workflow was started.