Stateful streaming operators for FusionVault Streams: event-time tumbling and sliding windows with keyed incremental aggregation, session windows, stream…
Async Rust client for the X (Twitter) API: OAuth1, OAuth2 PKCE, bearer tokens, media upload, streaming. xdk is X's SDK name; this is an independent project,…
The FusionVault Streams engine: runs a stream pipeline continuously over Kafka with N independent consumer threads, stateful operators from fv-streams-ops,…
The FusionVault Streams internal exchange: Arrow-IPC-carrying frames over kernel TCP on tokio, with N flows per worker pair, one owner task per socket…
The SQL front door for FusionVault Streams: a streaming SQL statement parses to a small typed logical plan and lowers to the same topology the TOML frontend…
The alchemy grammar plugin and language for the tabnas parsing engine (declarative streaming transducers and renderers), and the types tabnas transducers and…
The FusionVault Streams standalone runner: run a stream pipeline defined in one TOML file against Kafka or Redpanda with no control plane, including the…
Reference command-line feature store over wickra-feature-store-core: fold a FeatureSpec over per-symbol CSV candle files and emit the feature matrix as JSON,…
The contract of FusionVault Streams: the control-plane seam, the task-facing source/sink/operator contract, the decode policy and meta columns, the settings…
The checkpoint state of FusionVault Streams: epochs, manifests and the epoch store — in memory, or an object store (local directory, S3) — the durable half of…
The file formats of FusionVault Streams: Arrow IPC, Parquet, CSV and JSON lines as one writer/reader shape over the arrow-rs codecs — the format axis of the…