Skip to main content

Crate forge_core

Crate forge_core 

Source

Re-exports§

pub use auth::Claims;
pub use auth::ClaimsBuilder;
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 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::DbConn;
pub use function::ForgeMutation;
pub use function::ForgeQuery;
pub use function::FunctionInfo;
pub use function::FunctionKind;
pub use function::JobDispatch;
pub use function::JobInfoLookup;
pub use function::MutationContext;
pub use function::OutboxBuffer;
pub use function::PendingJob;
pub use function::PendingWorkflow;
pub use function::QueryContext;
pub use function::RequestMetadata;
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 job::ForgeJob;
pub use job::JobContext;
pub use job::JobInfo;
pub use job::JobPriority;
pub use job::JobStatus;
pub use job::RetryConfig;
pub use rate_limit::RateLimitConfig;
pub use rate_limit::RateLimitHeaders;
pub use rate_limit::RateLimitKey;
pub use rate_limit::RateLimitResult;
pub use realtime::Change;
pub use realtime::ChangeOperation;
pub use realtime::Delta;
pub use realtime::ReadSet;
pub use realtime::SessionId;
pub use realtime::SessionInfo;
pub use realtime::SessionStatus;
pub use realtime::SubscriptionId;
pub use realtime::SubscriptionInfo;
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::HasTenant;
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::ParallelBuilder;
pub use workflow::ParallelResults;
pub use workflow::SuspendReason;
pub use workflow::WorkflowContext;
pub use workflow::WorkflowEvent;
pub use workflow::WorkflowEventSender;
pub use workflow::WorkflowInfo;
pub use workflow::WorkflowStatus;

Modules§

auth
Authentication and JWT handling.
cluster
Cluster coordination and node management.
config
cron
daemon
env
Typesafe environment variable access for FORGE functions.
error
function
http
HTTP client with circuit breaker pattern.
job
rate_limit
realtime
Real-time subscription system.
schema
Schema definition and registration system.
tenant
testing
Testing utilities for FORGE applications.
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_variant
Assert that an error matches a specific variant.
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.