Skip to content
Open-Source Registry

Search 51 packages

Found
Build behaviour
Packages1–30 of 51VersionFindingsDescriptionDownloadsWhen
substreams-abis cargo2.0.0clean Substreams ABIs15K2d ago
tycho-substreams cargo0.8.2clean Tycho substreams development kit, contains tycho-indexer block changes model and helper functions for common indexing tasks.12K2d ago
substreams-bitcoin-core cargo3.0.0clean Substreams development kit for Bitcoin chains, contains Firehose Block model and helpers.4.3K1d ago
substreams-bitcoin cargo3.0.0clean Substreams development kit for Bitcoin chains, contains Firehose Block model and helpers.3.9K1d ago
crabka-client-streams cargo0.4.1clean KIP-1071 Kafka Streams rebalance-protocol client for Apache Kafka in Rust7911d ago
fv-streams-ops cargo0.7.0clean Stateful streaming operators for FusionVault Streams: event-time tumbling and sliding windows with keyed incremental aggregation, session windows, stream…1081d ago
fv-streams-engine cargonot built 0.7.0 did not buildThe FusionVault Streams engine: runs a stream pipeline continuously over Kafka with N independent consumer threads, stateful operators from fv-streams-ops,…1031d ago
fv-streams-exchange cargo0.7.0clean 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…991d ago
fv-streams-sql cargo0.7.0clean 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…691d ago
fv-streams cargonot built 0.7.0 did not buildThe FusionVault Streams standalone runner: run a stream pipeline defined in one TOML file against Kafka or Redpanda with no control plane, including the…671d ago
fv-streams-types cargo0.7.0clean The contract of FusionVault Streams: the control-plane seam, the task-facing source/sink/operator contract, the decode policy and meta columns, the settings…371d ago
fv-streams-state cargo0.7.0clean 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…301d ago
fv-streams-formats cargo0.7.0clean 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…271d ago
fv-streams-runtime cargo0.7.0clean The dataflow runtime of FusionVault Streams: tasks over bounded in-memory edges carrying Arrow batches, watermarks and barriers in band; epochs; the…261d ago
fv-streams-connectors cargo0.7.0clean The connectors of FusionVault Streams — Kafka, files and object stores, Iceberg, database lookup tables, Arrow Flight, the Nexmark generator, the blackhole —…241d ago
toml cargo1.1.7+spec-1.1.0clean A native Rust encoder and decoder of TOML-formatted files and streams. Providesimplementations of the standard Serialize/Deserialize traits for TOML data…977M3h ago
ntex-io cargo3.13.2clean Utilities for abstracting io streams783K13h ago
ntex-tls cargo4.3.1clean An implementation of SSL streams for ntex backed by OpenSSL680K15h ago
rama-boring-tokio cargo0.6.12clean An implementation of SSL streams for Tokio backed by BoringSSL in function of Rama287K8h ago
ntex-dispatcher cargo4.3.0clean Utilities for abstracting io streams dispatcher119K15h ago
tokio-process-tools cargo0.11.3clean Correctness-focused async subprocess orchestration for Tokio: bounded output, multi-consumer streams, output detection, guaranteed cleanup and graceful…39K1d ago
baracuda-driver cargo0.0.1-alpha.86clean Safe Rust wrappers for the CUDA Driver API (devices, contexts, streams, events, memory, kernels, graphs).22K23h ago
moq-json cargo0.5.8clean JSON publishing over MoQ tracks: snapshot/delta (RFC 7396 merge patch) objects, or append-log record streams.22K2d ago
cubecl-environment cargo0.11.0clean Environment compatibility layer for CubeCL: sync primitives, futures, streams, config and persistence across std, no-std, wasm and tokio14K1d ago
vgi-rpc-macros cargo0.31.3clean Proc-macros for vgi-rpc: #[service], #[unary], #[producer], #[exchange], #[derive(VgiArrow)], #[derive(StreamState)]13K10h ago
kanade-backend cargo0.64.02 vulnerabilities 2axum + SQLite projection backend for the kanade endpoint-management system. Hosts /api/* and the embedded SPA dashboard, projects JetStream streams into…4.7K13h ago
onepipeline cargo0.63.0clean Execute a task DAG over oneagentgraph and onevcs, merging their event streams into one.4.7K15h ago
arete-macros cargo0.31.0clean Proc-macros for defining Arete streams4.4K10h ago
oxideav-mjpeg cargo0.1.12clean Pure-Rust JPEG / Motion-JPEG codec for oxideav — standalone still-image API (probe / info / decode / encode, RGB8 and RGBA8 in and out); baseline,…4.1K1d ago
fakecloud-kinesis cargo0.50.0clean Kinesis Data Streams implementation for FakeCloud2.5K1d ago