helix-driver-host 0.1.2

Helix Native 与 FFI 共用的存储、网络和执行驱动
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

//! Shared host driver pieces for PC Tauri and Flutter FFI.

pub mod batch_sink;
pub mod codec;
pub mod dispatch;
pub mod engine;
pub mod http_cross;
pub mod http_envelope;
pub mod instrument;
pub mod lifecycle;
pub mod local_store;
pub mod metrics;
pub mod network;
mod network_debug;
#[cfg(test)]
mod network_lifecycle_tests;
pub mod ops;
pub mod otel;
pub mod owned_effect;
pub mod pools;
pub mod reconnect;
pub mod spawner;
pub mod storage;
mod tick_ingress;
pub mod timer;
pub mod trace;
pub mod upload;
pub mod upsert_sql;

pub use batch_sink::BatchSink;
pub use codec::{rows_from_reply_bytes, rows_to_reply_bytes};
pub use engine::{
    register_transport, run_engine_loop, run_engine_loop_stamped, EngineDeps,
    TransportRegistration, TransportTable, TransportTraceSink,
};
pub use http_cross::{AuthTokenRegistry, CrossCuttingHttp, HttpOutcomeObserver};
pub use http_envelope::{base64_encode, run_http_envelope};
pub use instrument::RecordingSink;
pub use lifecycle::{
    LifecycleCapability, LifecycleContext, LifecycleObservation, LifecycleStage, LifecycleState,
    LifecycleStatus, LifecycleTraceSink, LifecycleTraceStats, LifecycleTracker, TickId,
    LIFECYCLE_LINK_CAPACITY, LIFECYCLE_TRACE_QUEUE_CAPACITY,
};
pub use local_store::{
    BackendScope, LocalStoreError, LocalStoreIdentity, LocalStoreLocator, LocalStorePaths,
};
pub use metrics::{
    production_metric_ids, record_im_business_event, AsyncMetricSink, BatchMetricExporter,
    BoundedMetricRuntime, LabelKey, MetricAvailability, MetricEvent, MetricExporterState, MetricId,
    MetricKind, MetricLabel, MetricLabels, MetricRuntimeConfig, MetricRuntimeSnapshot,
    NoopMetricSink, RecordOutcome, ShutdownOutcome, ALLOWED_LABEL_KEYS, CANARY_METRIC_IDS,
    REQUIRED_METRIC_IDS,
};
pub use network::{
    HostHeaderRegistry, HostNetworkConfig, PreparedHttpRequest, SharedHttpClient, SharedWsClient,
    WsConnectionActivation,
};
pub use ops::{
    classify_port_error, execute_storage_ops, execute_storage_ops_atomic, table_set_key,
};
pub use otel::{HostOtelConfig, HostOtelRuntime, HostSpanSnapshot, TraceDirection, TraceIdentity};
pub use owned_effect::{consume_effects, OwnedEffect};
pub use reconnect::{spawn_reconnect_supervisor, ReconnectPolicy, ReconnectTraceSink};
pub use spawner::{BoundedSpawner, Job, Overflow};
pub use storage::HostStorage;
pub use tick_ingress::{
    tick_ingress_channel, tick_ingress_channel_observed, TickIngressReceiver, TickIngressSender,
};
pub use timer::TimerRegistry;
pub use trace::{
    CommandTraceQueue, TraceCarrier, TraceCarrierError, TraceHooks, TraceHooksImpl, TraceScope,
};
pub use upload::SharedFileUploader;

/// per-table-set Persist worker 的有界 job 队列深度上限。
///
/// 超过此值时 dispatch 侧 `.await` 阻塞主循环，将背压传导到 tick_tx（cap=256）。
/// 这恢复了旧实现"磁盘慢则入站慢"的背压链，同时避免死锁（PortReply 走独立通道）。
pub const PERSIST_QUEUE_CAP: usize = 1024;

/// Http / HttpFire BoundedSpawner 的有界队列深度上限。
///
/// 必达 Http（Block）满时 `send().await` 把背压传导回 tick_tx；
/// HttpFire（DropNewest）满时 try_send 失败即丢当前条目（满即丢最新来的）+ warn（自愈靠 cursor-gate 重发）。
pub const HTTP_QUEUE_CAP: usize = 1024;