Skip to main content

Crate netsky_db

Crate netsky_db 

Source
Expand description

Pure Rust netsky observability database.

OLTP writes use turso by default. OLAP reads snapshot JSON rows into Arrow RecordBatches and execute SQL with DataFusion.

Modules§

arrow_array
Re-exports for callers that consume query_batches results. Statically typed implementations of Arrow Arrays

Structs§

ArrowRecordBatch
A two-dimensional batch of column-oriented data with a defined schema.
CloneDispatchRecord
CommunicationEvent
CommunicationEventRecord
Db
EventRow
One row from events.
GitOperationRecord
HarvestEventRecord
IrohEventRecord
McpToolCallRecord
MessageRecord
OwnerDirectiveRecord
SourceCursorRow
One row from source_cursors.
SourceErrorRecord
TaskRecord
TaskRow
TaskUpdate
TokenUsageRecord
WatchdogEventRecord

Enums§

Direction
Error
EventStatus
Delivery lifecycle for an event. A row is first inserted with Pending before the delivery adapter runs; once the adapter returns, the row is updated to Delivered or Failed with a reason.
IrohEventType
Bounded event type for iroh_events. Analytics show connect counts, eviction pressure, and reconnect churn per peer-hash per day.
SessionEvent
SourceErrorClass
Bounded error class for source_errors. Prevents cardinality blowup from free-form strings (stack traces, paths, or human text) making it into the analytics surface. Classification happens at the call site; anything that doesn’t map cleanly goes to Unknown.

Constants§

SCHEMA_VERSION

Functions§

hash_peer_id
SHA256-truncated, URL-safe hex hash of a raw iroh NodeId. Stable across a paired peer’s identity lifetime; does NOT expose the raw ed25519 public key. The published analytics surface reads these hashes, never the raw ID.

Type Aliases§

Result