harn-vm 0.8.2

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
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83

pub mod dispatcher;
pub mod event;
pub mod flow_control;
pub mod inbox;
pub mod registry;
pub mod scheduler;
pub mod streaming;
pub mod test_util;
pub mod topics;
pub mod webhook_intake;
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::{
    install_provider_catalog, 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 scheduler::{
    in_flight_by_key as scheduler_in_flight_by_key,
    ready_stats_by_key as scheduler_ready_stats_by_key, FairnessKey, ReadyKeyStats, SchedulableJob,
    SchedulerKeyStat, SchedulerPolicy, SchedulerSnapshot, SchedulerState, SchedulerStrategy,
    DEFAULT_STARVATION_AGE_MS,
};
pub use streaming::{
    stream_fixture_event, stream_window_summary, StreamBackpressureConfig, StreamFlowConfig,
    StreamGateConfig, StreamGateOutcome, StreamGateRecord, StreamOverflowPolicy,
    StreamStatusSnapshot, StreamThrottleConfig, StreamTriggerConfig, StreamTriggerRuntime,
    StreamWindowConfig, StreamWindowEnvelope, StreamWindowMode, TRIGGER_STREAM_GATE_TOPIC,
    TRIGGER_STREAM_STATUS_TOPIC, TRIGGER_STREAM_WINDOWS_TOPIC,
};
pub use test_util::{run_trigger_harness_fixture, TriggerHarnessResult, TRIGGER_TEST_FIXTURES};
pub use topics::{
    classify_trigger_dlq_error, 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 webhook_intake::{
    build_request as build_webhook_intake_request, clear_webhook_intake_state,
    deregister_webhook_intake, feed_webhook_intake, intake_for_path, recent_webhook_deliveries,
    register_webhook_intake, snapshot_webhook_intakes, HmacAlgorithm, SignatureEncoding,
    WebhookIntakeConfig, WebhookIntakeError, WebhookIntakeId, WebhookIntakeOutcome,
    WebhookIntakeRequest, WebhookIntakeSnapshot, WebhookIntakeStatus,
};
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, WorkerQueueInspectSnapshot, WorkerQueueJob,
    WorkerQueueJobState, WorkerQueuePriority, WorkerQueueResponseRecord, WorkerQueueState,
    WorkerQueueSummary, WORKER_QUEUE_CATALOG_TOPIC,
};