Crate helix_driver_host 

Shared host driver pieces for PC Tauri and Flutter FFI.

Re-exports

pub use batch_sink::BatchSink;

pub use engine::register_transport;

pub use engine::run_engine_loop;

pub use engine::run_engine_loop_stamped;

pub use engine::EngineDeps;

pub use engine::TransportRegistration;

pub use engine::TransportTable;

pub use engine::TransportTraceSink;

pub use http_cross::AuthTokenRegistry;

pub use http_cross::CrossCuttingHttp;

pub use http_cross::HttpOutcomeObserver;

pub use http_envelope::run_http_envelope;

pub use instrument::RecordingSink;

pub use lifecycle::LifecycleCapability;

pub use lifecycle::LifecycleContext;

pub use lifecycle::LifecycleObservation;

pub use lifecycle::LifecycleStage;

pub use lifecycle::LifecycleState;

pub use lifecycle::LifecycleStatus;

pub use lifecycle::LifecycleTraceSink;

pub use lifecycle::LifecycleTraceStats;

pub use lifecycle::LifecycleTracker;

pub use lifecycle::TickId;

pub use lifecycle::LIFECYCLE_LINK_CAPACITY;

pub use lifecycle::LIFECYCLE_TRACE_QUEUE_CAPACITY;

pub use local_store::BackendScope;

pub use local_store::LocalStoreError;

pub use local_store::LocalStoreIdentity;

pub use local_store::LocalStoreLocator;

pub use local_store::LocalStorePaths;

pub use metrics::production_metric_ids;

pub use metrics::record_gap_duration;

pub use metrics::record_im_business_event;

pub use metrics::record_message_client_terminal;

pub use metrics::record_message_e2e_view_updated;

pub use metrics::record_seq_observation;

pub use metrics::record_tick_stage_duration;

pub use metrics::AsyncMetricSink;

pub use metrics::BatchMetricExporter;

pub use metrics::BoundedMetricRuntime;

pub use metrics::ClientTerminalObservation;

pub use metrics::LabelKey;

pub use metrics::MetricAvailability;

pub use metrics::MetricEvent;

pub use metrics::MetricExporterState;

pub use metrics::MetricId;

pub use metrics::MetricKind;

pub use metrics::MetricLabel;

pub use metrics::MetricLabels;

pub use metrics::MetricRuntimeConfig;

pub use metrics::MetricRuntimeSnapshot;

pub use metrics::NoopMetricSink;

pub use metrics::RecordOutcome;

pub use metrics::ShutdownOutcome;

pub use metrics::ALLOWED_LABEL_KEYS;

pub use metrics::CANARY_METRIC_IDS;

pub use metrics::REQUIRED_METRIC_IDS;

pub use network::HostHeaderRegistry;

pub use network::HostNetworkConfig;

pub use network::PreparedHttpRequest;

pub use network::SharedHttpClient;

pub use network::SharedWsClient;

pub use network::WsConnectionActivation;

pub use ops::execute_storage_ops;

pub use ops::execute_storage_ops_atomic;

pub use ops::table_set_key;

pub use otel::HostOtelConfig;

pub use otel::HostOtelRuntime;

pub use otel::HostSpanSnapshot;

pub use otel::TraceDirection;

pub use otel::TraceIdentity;

pub use owned_effect::consume_effects;

pub use owned_effect::OwnedEffect;

pub use reconnect::spawn_reconnect_supervisor;

pub use reconnect::ReconnectPolicy;

pub use reconnect::ReconnectTraceSink;

pub use spawner::BoundedSpawner;

pub use spawner::Job;

pub use spawner::Overflow;

pub use storage::HostStorage;

pub use timer::TimerRegistry;

pub use trace::CommandTraceQueue;

pub use trace::TraceCarrier;

pub use trace::TraceCarrierError;

pub use trace::TraceHooks;

pub use trace::TraceHooksImpl;

pub use trace::TraceScope;

pub use upload::SharedFileUploader;

Modules

batch_sink

codec

Compatibility re-exports for the runtime-free core port codec.

diagnostics

专用诊断旁路：业务线程仅复制有限标量，后台批量写 Loki，身份不进入索引。

dispatch

dispatch — 一批 OwnedEffect 的分流兑现（泵核子步骤，从 engine 拆出）。

engine

engine — host 泛型事件泵壳（下沉自 native engine_loop）。

http_cross

http_cross — 出站 HTTP 横切层（鉴权注入 / outcome observer / traceparent 透传）。

http_envelope

HTTP envelope — 把 HttpRequester::request 的响应编码成 PortReply JSON 信封。

instrument

instrument — 外部宿主在投影路径插录放/日志装饰器的非侵入范例。

lifecycle

Host 侧 lifecycle correlation 合同。

local_store

Host-side local store locator.

metrics

Host-only asynchronous metrics boundary.

network

Shared HTTP and WebSocket clients for PC Tauri and Flutter FFI.

ops

Shared StorageOp execution helpers for host drivers.

otel

owned_effect

OwnedEffect — &[Effect] 借用脱离镜像。

pools

Persist / Http BoundedSpawner 构造助手（泛型 over Storage / HttpRequester）。

reconnect

spawner

BoundedSpawner — host 内通用有界并发原语（刀2-driver）。

storage

Shared rusqlite storage implementation for PC Tauri and Flutter FFI.

timer

TimerRegistry — ScheduleTimer / CancelTimer 兑现器

trace

upload

Shared local-file uploader for native and FFI host drivers.

upsert_sql

E9b：batch_upsert SQL 形状缓存（HX-C005 去 per-call 分配尾巴）。

Structs

TickIngressReceiver

TickIngressSender

生产 tick 入站发送端：时间戳、Tick 和可选 carrier 同在一个有界 mpsc 元素内。

Constants

HTTP_QUEUE_CAP

Http / HttpFire BoundedSpawner 的有界队列深度上限。

PERSIST_QUEUE_CAP

per-table-set Persist worker 的有界 job 队列深度上限。

Functions

base64_encode

Standard padded base64 used by the HTTP response envelope.

classify_port_error

Convert a driver-facing port failure into the stable module-visible class.

rows_from_reply_bytes

Decode rows_to_reply_bytes output for driver compatibility paths.

rows_to_reply_bytes

Encode storage rows as the canonical JSON array used by PortReply.

tick_ingress_channel

tick_ingress_channel_observed

创建带 command admission 指标的生产 channel，容量与原背压点完全一致。