asupersync 0.3.4

Spec-first, cancel-correct, capability-secure async runtime for Rust.
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
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132

//! Core types for the Asupersync runtime.
//!
//! This module contains the fundamental types used throughout the runtime:
//!
//! - [`id`]: Identifier types (`RegionId`, `TaskId`, `ObligationId`, `Time`)
//! - [`outcome`]: Four-valued outcome type with severity lattice
//! - [`cancel`]: Cancellation reason and kind types
//! - [`budget`]: Budget type with product semiring semantics + min-plus curves
//! - [`policy`]: Policy trait for outcome aggregation
//! - [`symbol`]: Symbol types for RaptorQ-based distributed layer
//! - [`resource`]: Resource limits and symbol buffer pools
//! - [`rref`]: Region-owned reference for Send tasks

pub mod budget;
pub mod builder;
pub mod cancel;
pub mod id;
pub mod outcome;
pub mod policy;
pub mod pressure;
pub mod resource;
pub mod rref;
pub mod slo_policy;
pub mod symbol;
pub mod symbol_set;
pub mod task_context;
pub mod typed_symbol;
pub mod wasm_abi;

pub use budget::{
    Budget, CapabilityBudget, CapabilityBudgetDimension, CapabilityBudgetRefusal,
    CapabilityBudgetRequirements, CurveBudget, CurveError, MinPlusCurve, backlog_bound,
    delay_bound,
};
pub use builder::{BuildError, BuildResult};
pub use cancel::{
    CancelAttributionConfig, CancelKind, CancelPhase, CancelReason, CancelWitness,
    CancelWitnessError,
};
pub use id::{ObligationId, RegionId, TaskId, Time};

// Canonical FrankenSuite identifiers.
//
// `TraceId` here is the 128-bit timestamped identifier defined in
// `franken_kernel` (timestamp_ms in the high 48 bits + 80 bits of randomness,
// hex-serialized). It is the canonical "TraceId" for EvidenceLedger linkage
// and any new code that needs to correlate runtime decisions with persistent
// audit records.
//
// Two narrower internal trace identifiers exist in different modules and
// serve distinct purposes — they are NOT interchangeable with this one
// (br-asupersync-dwtjto). Both have been renamed away from the bare
// `TraceId` symbol so the canonical one re-exported below owns it:
//
//   * `crate::observability::cancellation_tracer::CancellationTraceId` —
//     `u64` auto-counter used purely for in-process cancellation
//     propagation traces. No timestamp, no cross-process meaning.
//     Renamed from `TraceId` in br-asupersync-z2m22w.
//
//   * `crate::trace::distributed::id::DistTraceId` — `{high: u64, low: u64}`
//     W3C-formatted (32 hex chars) distributed trace context. Locked by
//     a golden snapshot (`canonical_trace_id_serialization`) so the
//     wire format cannot drift. Renamed from `TraceId` in br-asupersync-v4az2y.
//
// New code that wants a "TraceId" should reach for this one. Migration
// of the two purpose-specific types is tracked under follow-up beads
// rather than a single sweeping rename, because their field shapes and
// serialization semantics differ in ways that golden tests pin in place.
pub use franken_kernel::{DecisionId, PolicyId, SchemaVersion, TraceId};
pub use outcome::{Outcome, OutcomeError, PanicPayload, Severity, join_outcomes};
pub use policy::Policy;
pub use pressure::SystemPressure;
pub use rref::{RRef, RRefAccess, RRefAccessWitness, RRefError};
pub use slo_policy::{
    SLO_POLICY_BUNDLE_SCHEMA_VERSION, SLO_POLICY_COMPILER_SCHEMA_VERSION,
    SLO_POLICY_PROOF_REPORT_SCHEMA_VERSION, SLO_POLICY_RUNTIME_APPLICATION_SCHEMA_VERSION,
    SloCompiledAdmission, SloCompiledAdmissionDecision, SloCompiledBrownoutStage,
    SloCompiledBrownoutStep, SloCompiledBudget, SloCompiledNoWinReceipt, SloCompiledPolicy,
    SloCompiledPolicyProvenance, SloCompiledPolicyStatus, SloLatencyObjective, SloLatencyUnit,
    SloNoWinFallback, SloOptionalWorkClass, SloPolicyBundle, SloPolicyCapacityEvidence,
    SloPolicyCompilerBlocker, SloPolicyCompilerBlockerKind, SloPolicyProvenance,
    SloPolicyRedaction, SloPolicyValidationIssue, SloPolicyValidationIssueKind,
    SloPolicyValidationReport, SloProofCommand, SloProofNoWinReceipt, SloProofReport,
    SloProofReportIssue, SloProofReportIssueKind, SloProofReportProvenance, SloProofReportRow,
    SloProofReportStatus, SloProofReportStatusCounts, SloProofReportValidation,
    SloResourcePressureThresholds, SloRuntimeAdmissionIssueKind, SloRuntimeAdmissionOutcome,
    SloRuntimeAdmissionRequest, SloRuntimeAdmissionStatus, SloRuntimeOptionalWorkApplication,
    SloRuntimeOptionalWorkDecision, SloRuntimePolicyApplication, SloRuntimePolicyApplicationIssue,
    SloRuntimePolicyApplicationIssueKind, SloRuntimePolicyApplicationProvenance,
    SloRuntimePolicyApplicationValidation, SloRuntimePolicyDecision, SloWorkloadClass,
    slo_proof_report_status_counts, validate_slo_policy_bundle_json,
    validate_slo_proof_report_json, validate_slo_runtime_policy_application_json,
};
pub use symbol::{DEFAULT_SYMBOL_SIZE, ObjectId, ObjectParams, Symbol, SymbolId, SymbolKind};
pub use symbol_set::{
    BlockProgress, ConcurrentSymbolSet, InsertResult, SymbolSet, ThresholdConfig,
};
pub use task_context::{CheckpointState, CxInner, MAX_MASK_DEPTH};
pub use typed_symbol::{
    DeserializationError, Deserializer, SerdeCodec, SerializationError, SerializationFormat,
    Serializer, TYPED_SYMBOL_HEADER_LEN, TYPED_SYMBOL_MAGIC, TypeDescriptor, TypeMismatchError,
    TypeRegistry, TypedDecoder, TypedEncoder, TypedSymbol,
};
pub use wasm_abi::{
    NextjsAntiPattern, NextjsBootstrapPhase, NextjsBootstrapState, NextjsBootstrapTransitionError,
    NextjsBootstrapTransitionRecord, NextjsBootstrapTrigger, NextjsBoundaryMode, NextjsCapability,
    NextjsComponentPlacement, NextjsIntegrationSnapshot, NextjsNavigationType,
    NextjsRenderEnvironment, NextjsRuntimeFallback, ProgressiveLoadSlot, ProgressiveLoadSnapshot,
    RacerSnapshot, RacerState, ReactHookDiagnosticEvent, ReactHookKind, ReactHookPhase,
    ReactHookTransitionError, ReactProviderConfig, ReactProviderPhase, ReactProviderSnapshot,
    ReactProviderState, ReactProviderTransitionError, SuspenseBoundaryState,
    SuspenseDiagnosticEvent, SuspenseTaskConfig, SuspenseTaskSnapshot, TaskDepChangePolicy,
    TransitionTaskState, UseCancellationConfig, UseCancellationSnapshot, UseRaceConfig,
    UseRaceSnapshot, UseScopeConfig, UseScopeSnapshot, UseTaskConfig, UseTaskSnapshot,
    UseTaskStatus, WASM_ABI_MAJOR_VERSION, WASM_ABI_MINOR_VERSION,
    WASM_ABI_SIGNATURE_FINGERPRINT_V1, WASM_ABI_SIGNATURES_V1, WasmAbiBoundaryEvent,
    WasmAbiCancellation, WasmAbiChangeClass, WasmAbiCompatibilityDecision, WasmAbiErrorCode,
    WasmAbiFailure, WasmAbiOutcomeEnvelope, WasmAbiPayloadShape, WasmAbiRecoverability,
    WasmAbiSignature, WasmAbiSymbol, WasmAbiValue, WasmAbiVersion, WasmAbiVersionBump,
    WasmAbortInteropSnapshot, WasmAbortInteropUpdate, WasmAbortPropagationMode,
    WasmBoundaryEventLog, WasmBoundaryState, WasmBoundaryTransitionError, WasmDispatchError,
    WasmDispatcherDiagnostics, WasmExportDispatcher, WasmExportResult, WasmFetchBuilder,
    WasmFetchRequest, WasmHandleKind, WasmHandleRef, WasmOutcomeExt, WasmScopeEnterBuilder,
    WasmScopeEnterRequest, WasmTaskCancelRequest, WasmTaskSpawnBuilder, WasmTaskSpawnRequest,
    apply_abort_signal_event, apply_runtime_cancel_phase_event, classify_wasm_abi_compatibility,
    is_capability_available, is_valid_bootstrap_transition, is_valid_hook_transition,
    is_valid_provider_transition, is_valid_wasm_boundary_transition,
    outcome_to_error_boundary_action, outcome_to_suspense_state, outcome_to_transition_state,
    required_wasm_abi_bump, validate_bootstrap_transition, validate_hook_transition,
    validate_provider_transition, validate_wasm_boundary_transition,
    wasm_abi_signature_fingerprint, wasm_boundary_state_for_cancel_phase,
};