harn-vm 0.7.34

Async bytecode virtual machine for the Harn programming language
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

pub mod dispatcher;
pub mod event;
pub mod flow_control;
pub mod inbox;
pub mod registry;
pub mod test_util;
pub mod topics;
pub mod worker_queue;

pub use dispatcher::{
    append_dispatch_cancel_request, clear_dispatcher_state, snapshot_dispatcher_stats,
    DispatchCancelRequest, DispatchError, DispatchOutcome, DispatchStatus, Dispatcher,
    DispatcherDrainReport, DispatcherStatsSnapshot, RetryPolicy, TriggerRetryConfig,
};
pub use event::{
    provider_metadata, redact_headers, register_provider_schema, registered_provider_metadata,
    registered_provider_schema_names, reset_provider_catalog, reset_provider_catalog_with,
    A2aPushPayload, CronEventPayload, ExtensionProviderPayload, GenericWebhookPayload,
    GitHubEventPayload, HeaderRedactionPolicy, LinearEventPayload, NotionEventPayload,
    NotionPolledChangeEvent, ProviderCatalog, ProviderCatalogError, ProviderId, ProviderMetadata,
    ProviderOutboundMethod, ProviderPayload, ProviderRuntimeMetadata, ProviderSchema,
    ProviderSecretRequirement, SignatureStatus, SignatureVerificationMetadata, SlackEventPayload,
    StreamEventPayload, TenantId, TraceId, TriggerEvent, TriggerEventId,
};
pub use flow_control::{
    parse_flow_control_duration, TriggerBatchConfig, TriggerConcurrencyConfig,
    TriggerDebounceConfig, TriggerExpressionSpec, TriggerFlowControlConfig,
    TriggerPriorityOrderConfig, TriggerRateLimitConfig, TriggerSingletonConfig,
    TriggerThrottleConfig,
};
pub use inbox::{InboxIndex, DEFAULT_INBOX_RETENTION_DAYS};
pub use registry::{
    begin_in_flight, binding_autonomy_budget_would_exceed, binding_budget_would_exceed,
    binding_version_as_of, clear_orchestrator_budget, clear_trigger_registry, drain,
    dynamic_deregister, dynamic_register, expected_predicate_cost_usd_micros, finish_in_flight,
    install_manifest_triggers, install_orchestrator_budget, micros_to_usd,
    note_autonomous_decision, note_orchestrator_budget_cost, orchestrator_budget_would_exceed,
    pin_trigger_binding, record_predicate_cost_sample, reset_binding_budget_windows,
    resolve_live_or_as_of, resolve_live_trigger_binding, resolve_trigger_binding_as_of,
    snapshot_orchestrator_budget, snapshot_trigger_bindings, unpin_trigger_binding, usd_to_micros,
    OrchestratorBudgetConfig, OrchestratorBudgetSnapshot, RecordedTriggerBinding,
    TriggerBindingSnapshot, TriggerBindingSource, TriggerBindingSpec,
    TriggerBudgetExhaustionStrategy, TriggerDispatchOutcome, TriggerHandlerSpec, TriggerId,
    TriggerMetricsSnapshot, TriggerPredicateSpec, TriggerPredicateState, TriggerRegistryError,
    TriggerState,
};
pub use test_util::{run_trigger_harness_fixture, TriggerHarnessResult, TRIGGER_TEST_FIXTURES};
pub use topics::{
    TRIGGERS_LIFECYCLE_TOPIC, TRIGGER_ATTEMPTS_TOPIC, TRIGGER_CANCEL_REQUESTS_TOPIC,
    TRIGGER_DLQ_TOPIC, TRIGGER_INBOX_CLAIMS_TOPIC, TRIGGER_INBOX_ENVELOPES_TOPIC,
    TRIGGER_INBOX_LEGACY_TOPIC, TRIGGER_OPERATION_AUDIT_TOPIC, TRIGGER_OUTBOX_TOPIC,
};
pub use worker_queue::{
    claims_topic_name as worker_claims_topic_name, job_topic_name as worker_job_topic_name,
    response_topic_name as worker_response_topic_name, ClaimedWorkerJob, WorkerQueue,
    WorkerQueueClaimHandle, WorkerQueueEnqueueReceipt, WorkerQueueJob, WorkerQueueJobState,
    WorkerQueuePriority, WorkerQueueResponseRecord, WorkerQueueState, WorkerQueueSummary,
    WORKER_QUEUE_CATALOG_TOPIC,
};