forge-core 0.9.0

Core types and traits for the Forge framework
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74

//! Core types, traits, and contexts for the Forge framework.
//!
//! This crate defines all handler traits ([`function::ForgeQuery`], [`function::ForgeMutation`],
//! [`job::ForgeJob`], [`cron::ForgeCron`], [`workflow::ForgeWorkflow`], [`daemon::ForgeDaemon`],
//! [`webhook::ForgeWebhook`], [`mcp::ForgeMcpTool`]), execution contexts, error types,
//! configuration, and testing infrastructure.
//!
//! Library code depends on `forge-core` for types. The runtime (`forge-runtime`) implements
//! the execution engine. Proc macros (`forge-macros`) generate trait implementations.

pub mod auth;
pub mod cluster;
pub mod config;
pub mod cron;
pub mod daemon;
pub mod env;
pub mod error;
pub mod function;
pub mod http;
pub mod job;
pub mod mcp;
pub mod oauth;
pub mod rate_limit;
pub mod realtime;
pub mod schema;
pub mod signals;
pub mod tenant;
pub mod types;
pub mod util;
pub mod webhook;
pub mod workflow;

// Testing utilities
pub mod testing;

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