beam_core/
lib.rs

1pub mod api;
2pub mod api_token;
3pub mod ask;
4pub mod backend_kind;
5pub mod cli_specs;
6pub mod config;
7pub mod i18n;
8pub mod ipc;
9pub mod logging;
10pub mod paths;
11pub mod permissions;
12pub mod persist;
13pub mod schedule_parser;
14pub mod schedule_store;
15pub mod session;
16pub mod triggers;
17pub mod workflow;
18pub mod workflow_actions;
19pub mod workflow_binding;
20pub mod workflow_cold_scan;
21pub mod workflow_definition;
22pub mod workflow_orchestrator;
23pub mod workflow_output;
24pub mod workflow_projection;
25pub mod workflow_resume;
26pub mod workflow_run;
27pub mod workflow_runtime;
28pub mod workflow_sidecar;
29pub mod workflow_snapshot;
30
31/// Default terminal columns used by beam when creating zellij sessions
32/// and for reset-to-default resize operations (reference: botmux 160×50).
33pub const DEFAULT_TERMINAL_COLS: u16 = 160;
34
35/// Default terminal rows used by beam when creating zellij sessions
36/// and for reset-to-default resize operations.
37pub const DEFAULT_TERMINAL_ROWS: u16 = 50;
38
39pub use api::{
40    ApiHealth, AttemptResumeEndResponse, AttemptResumeRequest, AttemptResumeStartResponse,
41    AttentionRequest, BotSummary, CreateSessionRequest, DaemonOverview, DaemonRuntimeState,
42    FinalOutputRequest, MentionTarget, RestartSessionRequest, ResumeSessionRequest, SessionGroup,
43    SessionInputRequest, SessionLocateInfo, SessionSummary, TerminalInfo,
44};
45pub use ask::{AskOption, AskQuestion, AskRequest, AskResult, legacy_selected};
46pub use backend_kind::BackendKind;
47pub use cli_specs::{CLI_SPECS, CliSpec, cli_spec};
48pub use config::{
49    BotConfig, Config, CustomTrigger, DaemonConfig, HerdrConfig, LarkConfig, MessageQuotaConfig,
50    OncallChatBinding, QuotaEntry, ScreenAnalyzerConfig, WebConfig,
51};
52pub use ipc::{
53    CliUsageLimitKind, CliUsageLimitState, DaemonToWorker, DisplayMode, FinalOutputKind,
54    InitConfig, ScreenStatus, TermActionKey, TranscriptChoice, TuiPromptOption, WorkerToDaemon,
55};
56pub use paths::BeamPaths;
57pub use permissions::{
58    TalkEvaluation, TalkReason, can_operate, evaluate_talk, get_owner_open_id, grant_restricted,
59    is_owner,
60};
61pub use schedule_parser::{ParsedNaturalSchedule, parse_natural_schedule, parse_schedule};
62pub use schedule_store::{
63    CreateTaskInput, ParsedSchedule, ParsedScheduleKind, ScheduleChatType, ScheduleDeliver,
64    ScheduleRepeat, ScheduleStoreError, ScheduleTaskUpdate, ScheduledTask, append_output_log,
65    create_task, get_task, list_tasks, mark_run, remove_task, update_task,
66};
67pub use session::{
68    AdoptedFrom, AgentAttention, ChatMode, PendingResponseCardState, Session, SessionScope,
69    SessionStatus,
70};
71pub use triggers::{custom_trigger_rest, resolve_custom_trigger, resolve_trigger_message};
72pub use workflow::{EventDraft, EventLog, WorkflowActor, WorkflowEventEnvelope};
73pub use workflow_actions::{
74    CompleteActivityCancelInput, CompleteNodeCancelInput, CompleteRunCancelInput, CreateWaitInput,
75    DeliverCancelInput, ExpireWaitInput, RequestCancelInput, ResolveWaitInput, WaitKind,
76    WaitOnTimeout, WaitResolution, complete_activity_cancel, complete_node_cancel,
77    complete_run_cancel, create_wait, deliver_cancel, expire_wait, request_cancel, resolve_wait,
78};
79pub use workflow_binding::{
80    BindingContext, BindingError, LoopContext, resolve_bindings, resolve_bound_string,
81};
82pub use workflow_cold_scan::{ColdScanStats, ColdWorkflowRun, scan_cold_workflow_runs};
83pub use workflow_definition::{
84    DecisionNode, HostExecutorNode, HumanGate, LoopNode, LoopOutputProjection, LoopTerminate,
85    ParamDef, RetryPolicy, SubagentNode, WorkflowDefaults, WorkflowDefinition, WorkflowNode,
86    parse_workflow_definition,
87};
88pub use workflow_orchestrator::{OrchestratorAction, decide_next_actions, topological_order};
89pub use workflow_output::{
90    WORKFLOW_OUTPUT_BEGIN, WORKFLOW_OUTPUT_END, parse_workflow_output,
91    with_workflow_output_protocol,
92};
93pub use workflow_projection::{
94    EventWindow, EventWindowOpts, event_seq_from_id, infer_run_status, read_event_window,
95    read_run_events_pure,
96};
97pub use workflow_resume::{
98    PriorReconcileRecoveryOutcome, ScheduleResumeOutcome, ScheduleResumeResult,
99    recover_prior_reconcile_result, resume_schedule_dangling_effects,
100};
101pub use workflow_run::{
102    BootstrapWorkflowRunInput, RunChatBinding, WorkflowOutputRef, WorkflowRunBootstrap,
103    bootstrap_workflow_run, mint_workflow_run_id, normalize_workflow_params,
104};
105pub use workflow_runtime::{
106    HostExecutorPrepareResult, RecoveryResult, RunLoopResult, RunLoopStopReason, RunTickResult,
107    WorkflowDispatchOutcome, WorkflowDispatchRun, WorkflowDispatchSession, WorkflowExecutionHooks,
108    WorkflowRuntimeContext, complete_node_failed, complete_node_succeeded, complete_run_failed,
109    complete_run_succeeded, derive_workflow_idempotency_key, dispatch_gate, dispatch_work,
110    finish_loop, finish_loop_iteration, get_host_executor_provider_meta, run_loop, run_tick,
111    start_loop, start_loop_iteration,
112};
113pub use workflow_sidecar::{load_effect_input_sidecar, write_effect_input_sidecar};
114pub use workflow_snapshot::{
115    ActivityState, ActivityStatus, AttemptIODTO, AttemptState, AttemptTerminalDTO, BlobPreviewDTO,
116    BotSnapshot, CancelIntent, DanglingSnapshot, EffectAttemptedState, LoopIterationState,
117    LoopIterationStatus, LoopSnapshotDTO, LoopState, LoopStatus, NodeState, NodeStatus,
118    ReconcileResultState, RunSnapshotDTO, RunState, RunStatus, WaitResolutionState, WaitState,
119    read_run_snapshot,
120};
beam_core/lib.rs

beam_core/
lib.rs
