tandem-server 0.6.5

HTTP server for Tandem engine APIs
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

pub mod adapters;
pub mod definition;
mod durable_io;
mod outbox_reconcile;
pub mod phases;
pub mod reliability;
pub mod scheduler;
pub mod store;
pub mod types;
pub mod waits;

pub use adapters::{
    automation_status_to_stateful, stateful_run_from_automation_v2, stateful_run_from_workflow,
    workflow_status_to_stateful,
};
pub use definition::{
    automation_definition_snapshot_hash, automation_definition_version,
    automation_run_definition_fields, automation_run_definition_metadata,
    automation_run_definition_snapshot_hash_mismatch, ensure_automation_run_definition_metadata,
    stable_definition_snapshot_hash, stamp_automation_run_definition_metadata,
};
pub use phases::*;
pub use reliability::{
    list_stateful_compensations, list_stateful_dead_letters, list_stateful_outbox,
    list_stateful_tool_effects, load_stateful_reliability, mark_compensation_status,
    mark_dead_letter_disposition, operator_principal, record_external_action_reliability_bridge,
    stateful_reliability_path_from_runtime_events_path, upsert_stateful_compensation,
    upsert_stateful_dead_letter, upsert_stateful_outbox, upsert_stateful_tool_effect,
    StatefulCompensationRecord, StatefulCompensationStatus, StatefulDeadLetterRecord,
    StatefulDeadLetterStatus, StatefulOutboxRecord, StatefulOutboxStatus, StatefulRecoveryOption,
    StatefulReliabilityQuery, StatefulReliabilityStoragePaths, StatefulReliabilityStoreFile,
    StatefulToolEffectRecord, StatefulToolEffectStatus,
};
pub use scheduler::{
    process_due_stateful_waits, StatefulWaitSchedulerConfig, StatefulWaitSchedulerOutcome,
    StatefulWaitSchedulerTick,
};
pub use store::{
    append_stateful_run_event, append_stateful_run_event_once,
    append_stateful_run_event_once_with_next_seq, list_stateful_run_snapshots,
    load_stateful_run_events, next_stateful_run_event_seq, query_stateful_run_events,
    read_stateful_run_snapshot, read_stateful_run_snapshot_for_run, stateful_run_event_seq_by_id,
    stateful_run_snapshot_path, write_stateful_run_snapshot, StatefulRunEventQuery,
    StatefulRuntimeStoragePaths,
};
pub use types::*;
pub use waits::{
    begin_claimed_stateful_wait_reminder_completion,
    begin_claimed_stateful_wait_timeout_completion, begin_claimed_stateful_wait_wake_completion,
    cancel_stateful_wait_after_phase_guard_denial, claim_due_stateful_wait,
    claim_matching_stateful_webhook_wait, due_stateful_waits,
    finish_claimed_stateful_wait_completion, finish_claimed_stateful_wait_reminder_completion,
    list_stateful_waits, load_stateful_waits, mark_stateful_wait_timeout_result,
    mark_stateful_wait_woken, release_claimed_stateful_wait,
    stateful_webhook_wait_match_from_metadata, stateful_webhook_wait_metadata,
    upsert_stateful_wait, StatefulWaitQuery,
};