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 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::ActionContext;
pub use function::AuthContext;
pub use function::ForgeAction;
pub use function::ForgeMutation;
pub use function::ForgeQuery;
pub use function::FunctionInfo;
pub use function::FunctionKind;
pub use function::JobDispatch;
pub use function::MutationContext;
pub use function::QueryContext;
pub use function::RequestMetadata;
pub use function::WorkflowDispatch;
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 observability::Alert;
pub use observability::AlertCondition;
pub use observability::AlertSeverity;
pub use observability::AlertState;
pub use observability::AlertStatus;
pub use observability::LogEntry;
pub use observability::LogLevel;
pub use observability::Metric;
pub use observability::MetricKind;
pub use observability::MetricLabels;
pub use observability::MetricValue;
pub use observability::Span;
pub use observability::SpanContext;
pub use observability::SpanKind;
pub use observability::SpanStatus;
pub use observability::TraceId;
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 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
cluster
config
cron
env
Typesafe environment variable access for FORGE functions.
error
function
job
observability
rate_limit
realtime
schema
tenant
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_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.