List of all items
Structs
- cluster::GracefulShutdown
- cluster::HeartbeatConfig
- cluster::HeartbeatLoop
- cluster::InFlightGuard
- cluster::LeaderConfig
- cluster::LeaderElection
- cluster::LeaderGuard
- cluster::NodeCounts
- cluster::NodeRegistry
- cluster::ShutdownConfig
- cron::CronEntry
- cron::CronRecord
- cron::CronRegistry
- cron::CronRunner
- cron::CronRunnerConfig
- daemon::DaemonEntry
- daemon::DaemonRegistry
- daemon::DaemonRunner
- daemon::DaemonRunnerConfig
- db::Database
- function::cache::QueryCache
- function::executor::ExecutionResult
- function::executor::FunctionExecutor
- function::registry::FunctionRegistry
- function::router::FunctionRouter
- gateway::AuthConfig
- gateway::AuthMiddleware
- gateway::GatewayConfig
- gateway::GatewayServer
- gateway::RpcError
- gateway::RpcHandler
- gateway::RpcRequest
- gateway::RpcResponse
- gateway::SseConfig
- gateway::SseQuery
- gateway::SseState
- gateway::TracingMiddleware
- gateway::jwks::JsonWebKey
- gateway::jwks::JwksClient
- gateway::jwks::JwksResponse
- jobs::JobDispatcher
- jobs::JobExecutor
- jobs::JobQueue
- jobs::JobRecord
- jobs::JobRegistry
- jobs::Worker
- jobs::WorkerConfig
- migrations::AppliedMigration
- migrations::DiffEntry
- migrations::Migration
- migrations::MigrationExecutor
- migrations::MigrationGenerator
- migrations::MigrationRunner
- migrations::MigrationStatus
- migrations::SchemaDiff
- migrations::SystemMigration
- observability::ActiveConnectionsGauge
- observability::HttpMetrics
- observability::JobMetrics
- observability::TelemetryConfig
- rate_limit::RateLimiter
- realtime::AdaptiveTracker
- realtime::AdaptiveTrackingConfig
- realtime::AdaptiveTrackingStats
- realtime::ChangeListener
- realtime::InvalidationConfig
- realtime::InvalidationEngine
- realtime::JobData
- realtime::ListenerConfig
- realtime::Reactor
- realtime::ReactorConfig
- realtime::ReactorStats
- realtime::RealtimeConfig
- realtime::SessionManager
- realtime::SessionServer
- realtime::SessionStats
- realtime::SubscriptionManager
- realtime::WorkflowData
- realtime::WorkflowStepData
- testing::MockHttp
- testing::MockHttpBuilder
- testing::MockRequest
- testing::MockResponse
- testing::TestConfig
- testing::TestContext
- testing::TestContextBuilder
- webhook::WebhookEntry
- webhook::WebhookRegistry
- webhook::WebhookState
- workflow::EventStore
- workflow::WorkflowEntry
- workflow::WorkflowExecutor
- workflow::WorkflowRecord
- workflow::WorkflowRegistry
- workflow::WorkflowScheduler
- workflow::WorkflowSchedulerConfig
- workflow::WorkflowStepRecord
Enums
- cron::CronStatus
- function::registry::FunctionEntry
- function::router::RouteResult
- gateway::SsePayload
- gateway::jwks::JwksError
- migrations::DiffAction
- observability::TelemetryError
- realtime::RealtimeMessage
Macros
- assert_err
- assert_err_variant
- assert_job_dispatched
- assert_ok
- assert_workflow_started
- testing::assert_err
- testing::assert_err_variant
- testing::assert_job_dispatched
- testing::assert_ok
- testing::assert_workflow_started
Functions
- gateway::build_auth_context_from_claims
- gateway::rpc_multipart_handler
- gateway::sse_handler
- gateway::sse_job_subscribe_handler
- gateway::sse_subscribe_handler
- gateway::sse_unsubscribe_handler
- gateway::sse_workflow_subscribe_handler
- migrations::extract_version
- migrations::get_all_system_sql
- migrations::get_builtin_migrations
- migrations::get_system_migrations
- migrations::is_system_migration
- migrations::load_migrations_from_dir
- observability::db::extract_table_name
- observability::db::instrumented_query
- observability::db::record_pool_metrics
- observability::db::record_query_duration
- observability::init_telemetry
- observability::record_http_request
- observability::record_job_execution
- observability::set_active_connections
- observability::shutdown_telemetry
- testing::assert_job_status
- testing::assert_json_matches
- testing::assert_workflow_status
- testing::error_contains
- testing::validation_error_for_field
- webhook::webhook_handler
Type Aliases
- daemon::BoxedDaemonHandler
- db::DatabasePool
- function::registry::BoxedMutationFn
- function::registry::BoxedQueryFn
- webhook::BoxedWebhookHandler