Skip to main content

Crate forge_core

Crate forge_core 

Source

Re-exports§

pub use auth::Claims;
pub use auth::ClaimsBuilder;
pub use auth::DefaultRoleResolver;
pub use auth::RoleResolver;
pub use auth::SharedRoleResolver;
pub use auth::TokenPair;
pub use auth::default_role_resolver;
pub use cluster::ClusterInfo;
pub use cluster::LeaderInfo;
pub use cluster::LeaderRole;
pub use cluster::NodeId;
pub use cluster::NodeInfo;
pub use cluster::NodeRole;
pub use cluster::NodeStatus;
pub use config::ForgeConfig;
pub use config::McpConfig;
pub use config::SignalsConfig;
pub use context::AuthenticatedContext;
pub use context::HandlerContext;
pub use cron::CronContext;
pub use cron::CronInfo;
pub use cron::CronSchedule;
pub use cron::ForgeCron;
pub use daemon::DaemonContext;
pub use daemon::DaemonInfo;
pub use daemon::DaemonStatus;
pub use daemon::ForgeDaemon;
pub use env::EnvAccess;
pub use env::EnvProvider;
pub use env::MockEnvProvider;
pub use env::RealEnvProvider;
pub use error::ForgeError;
pub use error::Result;
pub use function::AuthContext;
pub use function::AuthTokenTtl;
pub use function::DbConn;
pub use function::ForgeConn;
pub use function::ForgeDb;
pub use function::ForgeMutation;
pub use function::ForgeQuery;
pub use function::FunctionInfo;
pub use function::FunctionKind;
pub use function::JobDispatch;
pub use function::KvHandle;
pub use function::LogLevel;
pub use function::MutationContext;
pub use function::QueryContext;
pub use function::RequestMetadata;
pub use function::TokenIssuer;
pub use function::WorkflowDispatch;
pub use http::CircuitBreakerClient;
pub use http::CircuitBreakerConfig;
pub use http::CircuitBreakerError;
pub use http::CircuitBreakerOpen;
pub use http::CircuitState;
pub use http::CircuitStatus;
pub use http::HttpClient;
pub use http::HttpRequestBuilder;
pub use job::ForgeJob;
pub use job::JobContext;
pub use job::JobInfo;
pub use job::JobPriority;
pub use job::JobStatus;
pub use job::RetryConfig;
pub use mcp::ForgeMcpTool;
pub use mcp::McpContent;
pub use mcp::McpContentBlock;
pub use mcp::McpToolAnnotations;
pub use mcp::McpToolContext;
pub use mcp::McpToolIcon;
pub use mcp::McpToolInfo;
pub use mcp::McpToolResult;
pub use pagination::Cursor;
pub use pagination::Page;
pub use pagination::PageInfo;
pub use rate_limit::ParseRateLimitKeyError;
pub use rate_limit::RateLimitConfig;
pub use rate_limit::RateLimitHeaders;
pub use rate_limit::RateLimitKey;
pub use rate_limit::RateLimitResult;
pub use realtime::AuthScope;
pub use realtime::Change;
pub use realtime::ChangeOperation;
pub use realtime::Delta;
pub use realtime::QueryGroup;
pub use realtime::QueryGroupId;
pub use realtime::ReadSet;
pub use realtime::SessionId;
pub use realtime::SessionInfo;
pub use realtime::SessionStatus;
pub use realtime::Subscriber;
pub use realtime::SubscriberId;
pub use realtime::SubscriptionId;
pub use realtime::SubscriptionState;
pub use realtime::TrackingMode;
pub use schema::FieldDef;
pub use schema::ModelMeta;
pub use schema::SchemaRegistry;
pub use schema::TableDef;
pub use tenant::TenantContext;
pub use tenant::TenantIsolationMode;
pub use types::Instant;
pub use types::LocalDate;
pub use types::LocalTime;
pub use types::Upload;
pub use webhook::ForgeWebhook;
pub use webhook::IdempotencyConfig;
pub use webhook::IdempotencySource;
pub use webhook::SignatureAlgorithm;
pub use webhook::SignatureConfig;
pub use webhook::WebhookContext;
pub use webhook::WebhookInfo;
pub use webhook::WebhookResult;
pub use webhook::WebhookSignature;
pub use workflow::ForgeWorkflow;
pub use workflow::SuspendReason;
pub use workflow::WorkflowContext;
pub use workflow::WorkflowEvent;
pub use workflow::WorkflowEventSender;
pub use workflow::WorkflowInfo;
pub use workflow::WorkflowStatus;
pub use schemars;

Modules§

auth
Authentication and JWT handling.
cluster
Cluster coordination and node management.
config
Configuration types for the Forge framework.
context
Sealed trait family for Forge handler contexts.
cron
daemon
email
Email sending trait and types.
env
Typesafe environment variable access for handler contexts.
error
function
http
HTTP client with circuit breaker pattern.
job
mcp
oauth
OAuth 2.1 Authorization Code + PKCE support.
pagination
Cursor-based pagination types for the wire format.
rate_limit
realtime
Real-time subscription system.
schema
Schema definition and registration system.
signals
Shared types for the signals pipeline (product analytics + diagnostics).
tenant
testing
types
Compile-time safe datetime and upload types for Forge.
util
Shared utility functions for the Forge framework.
webhook
Webhook handling with signature verification.
workflow

Macros§

assert_err
Assert that a result is Err.
assert_err_matches
Assert that an error matches a pattern, with an optional guard expression.
assert_err_variant
Assert that an error matches a specific variant (pattern matching, not substring).
assert_http_called
Assert that an HTTP call was made.
assert_http_not_called
Assert that an HTTP call was not made.
assert_job_dispatched
Assert that a job was dispatched.
assert_job_not_dispatched
Assert that a job was not dispatched.
assert_ok
Assert that a result is Ok.
assert_workflow_not_started
Assert that a workflow was not started.
assert_workflow_started
Assert that a workflow was started.