Lib.rs

› Search #distributed-data #dora #distributed #dataflow-oriented #robotic

  1. governor

    A rate-limiting implementation in Rust

    v0.10.4 2.6M #rate-limiting #gcra #no-std

  2. differential-dataflow

    An incremental data-parallel dataflow platform

    v0.18.0 4.4K #timely-dataflow #dataflow #differential

  3. timely

    A low-latency data-parallel dataflow system in Rust

    v0.25.1 5.1K #timely-dataflow #dataflow

  4. hotpath

    async Rust profiler with memory and data-flow insights - quickly find and debug performance bottlenecks

    v0.9.2 1.8K #metrics-monitoring #profiling #statistics #bounded-channel #dataflow #async-stream #debugging #mpsc #memory-management #async-channel

  5. geodesy

    A platform for experiments with geodetic transformations and data flow

    v0.14.0 1.8K #cartography #geography #geospatial

  6. spirt

    Shader-focused IR to target, transform and translate from

    v0.4.0 3.4K #shader-compiler #spir-v #shader

  7. communication-layer-request-reply

    dora goal is to be a low latency, composable, and distributed data flow

    v0.3.13 2.8K #dataflow #low-latency #distributed-data #composable #low-latency-data #real-time-communication #robotic #dora #dataflow-oriented #distributed-communication

  8. dora-openai-proxy-server

    dora goal is to be a low latency, composable, and distributed data flow

    v0.3.12 500 #artificial-intelligence #dataflow #low-latency #distributed #dora #message-format #robotic #distributed-data #dataflow-oriented #robotics

  9. cargo-tally

    Cargo subcommand for drawing graphs of the number of dependencies on a crate over time

    v1.0.71 110 #cargo-subcommand #cargo #subcommand

  10. timely_logging

    Common timely logging infrastructure

    v0.25.1 5.1K #timely-dataflow #dataflow #logging #timely

  11. dataflow-rs

    A lightweight, rule-driven workflow engine for building powerful data processing pipelines and nanoservices in Rust. Extend it with your custom tasks to create robust, maintainable services.

    v2.0.3 270 #workflow-engine #workflow-orchestration #rule-engine #nanoservice #orchestration

  12. pusherator

    Push-based version of Rust iterators

    v0.0.12 15K #iterator #construct #framework #stream-processing #push-based #distributed-systems #hydro #intermediate-representation #memory-safety #dataflow

  13. shared-memory-server

    dora goal is to be a low latency, composable, and distributed data flow

    v0.3.13 750 #shared-memory #dataflow #low-latency #distributed-data #composable #low-latency-data #dora #robotic #dataflow-oriented #robotics

  14. dora-runtime

    dora goal is to be a low latency, composable, and distributed data flow

    v0.3.13 2.1K #dataflow #low-latency #distributed #python-integration #composable #distributed-data #dora #robotic #dataflow-oriented #robotics

  15. dora-record

    dora goal is to be a low latency, composable, and distributed data flow

    v0.3.12 1.5K #dataflow #low-latency-data #distributed-data #apache-arrow #dora #logging #data-logging

  16. communication-layer-pub-sub

    dora goal is to be a low latency, composable, and distributed data flow

    v0.3.12 3.3K #dataflow #low-latency #distributed-data #low-latency-data #composable #real-time-communication #artificial-intelligence #dora #robotic #dataflow-oriented

  17. graphix-compiler

    A dataflow language for UIs and network programming, compiler

    v0.2.2 #compiler #dataflow-programming-language #reactive-dataflow #graphix #language-for-ui #netidx #reactive-programming #network-programming #reactive-ui #functional-reactive-programming

  18. dora-cli

    dora goal is to be a low latency, composable, and distributed data flow

    v0.3.13 2.2K #low-latency #dataflow #distributed-data #artificial-intelligence #python #robotic #dataflow-oriented #robotics #low-latency-data #ros2

  19. aws-sdk-groundstation

    AWS SDK for AWS Ground Station

    v1.94.0 #ground-station #aws-sdk #satellite-communication #api-reference #downlink #aws-client

  20. dora-message

    dora goal is to be a low latency, composable, and distributed data flow

    v0.6.0 800 #dataflow #low-latency #distributed #dora #composable #shared-memory #distributed-data #dora-rs #robotic #dataflow-oriented

  21. graphix-stdlib

    A dataflow language for UIs and network programming, standard library

    v0.2.3 #dataflow-programming-language #graphix #reactive-dataflow #ui #standard #netidx #network-programming #functional-reactive-programming #gx #language-for-ui

  22. dora-arrow-convert

    dora goal is to be a low latency, composable, and distributed data flow

    v0.3.13 800 #dataflow #low-latency-data #distributed #artificial-intelligence #dora #robotic #distributed-data #memory-data #dataflow-oriented #ros2

  23. dora-daemon

    dora goal is to be a low latency, composable, and distributed data flow

    v0.3.13 2.3K #dataflow #low-latency #distributed-data #artificial-intelligence #low-latency-data #shared-memory #dora #robotic #dataflow-oriented #robotics

  24. hugr-llvm

    A general and extensible crate for lowering HUGRs into LLVM IR

    v0.25.0 5.5K #llvm-ir #hugr #quantinuum #quantum

  25. feldera-ir

    Intermediate representation types for Feldera Programs

    v0.212.0 #ir #dbsp #calcite #compiler

  26. mech-interpreter

    The Mech language runtime

    v0.2.72 #mech-language #run-time #dataflow #programming-language #dataflow-programming

  27. rapx

    A static analysis platform for use-after-free, memory leakage detection, etc

    v0.6.22 #static-analysis #detect #platform #logging #cargo-clean #memory-safety #env-var #call-graph #cargo-check #cargo-rustc

  28. hugr-passes

    Compiler passes for Quantinuum's HUGR

    v0.25.0 6.6K #hugr #quantinuum #quantum

  29. fosr

    Fos-R (Forger Of Security Records) is an AI-based synthetic network traffic generator

    v0.1.2 #traffic-generator #network-traffic #network-security #synthetic #pcap-file #forger #file-generator #file-generation

  30. reactive_graph

    A fine-grained reactive graph for building user interfaces

    v0.2.12 54K #reactive-ui #reactive-systems #effect #graph-node #subscriber #reactivity #observer #mutating #dataflow

  31. mzprof

    A dataflow profiler for Materialize

    v0.2.1 190 #profiler #materialize #dataflow #pprof #collect #sql-url #duration-seconds

  32. libdd-data-pipeline

    Trace exporter package allowing sending data from datadog SDKs to the Trace Agent

    v1.0.0 1.8K #data-pipeline #datadog #statistics #trace-exporter #agent #telemetry #apm #obfuscation

  33. google-datapipelines1

    A complete library to interact with Datapipelines (protocol v1)

    v6.0.0+20240616 500 #google-api #data-pipelines #protocols

  34. flowlang

    A dataflow oriented programming meta-language in JSON supporting functions written in rust, python, javascript, java, and flow

    v0.3.27 5.9K #java #python #dataflow #javascript #control-command #dataflow-programming #functional-programming #meta-language #mcp #data-object

  35. graphix-rt

    A dataflow language for UIs and network programming, runtime

    v0.2.2 #dataflow-programming-language #graphix #ui #update #run-time #network-programming #netidx #gx #dataflow-graph #reactive-dataflow

  36. mx-message

    A fast, type-safe Rust implementation of MXMessage for parsing MX messages

    v3.1.4 190 #iso-20022 #message-parser #mx #parser

  37. pumps

    Eager streams for Rust

    v0.1.0 #async-pipeline #pipeline #async

  38. dfir_rs

    DFIR runtime for Rust, used by Hydro

    v0.15.0 15K #hydro #dataflow #run-time #state #framework #distributed-systems #intermediate-representation

  39. decy-ownership

    Ownership and lifetime inference for C-to-Rust conversion (CRITICAL)

    v1.0.2 #static-analysis #transpiler #c #rust #compiler

  40. dora-coordinator

    dora goal is to be a low latency, composable, and distributed data flow

    v0.3.13 2.2K #dataflow #low-latency #composable #low-latency-data #distributed #distributed-data #dora #robotics #data-transfer #zenoh

  41. ironbeam

    A batch processing clone of Apache Beam in Rust

    v1.1.0 #gzip #metrics-collection #data-pipeline #csv #parquet #parallel-execution #checkpointing #execution-pipeline #batch-processing #beam

  42. flowistry

    Modular information flow analysis

    v0.5.44 2.6K #flow-analysis #ide-plugin #dataflow #compiler-plugin #compute #static-analysis

  43. flow-rs-leptos

    Leptos framework integration for Flow-RS

    v0.1.0-beta.2 #reactive #graph-visualization #reactive-graph #visualization #wasm

  44. timely_communication

    Communication layer for timely dataflow

    v0.25.1 5.0K #timely-dataflow #dataflow #timely

  45. dfir_lang

    Hydro's Dataflow Intermediate Representation (DFIR) implementation

    v0.15.0 #dfir #intermediate-representation #hydro #dataflow #construct #ide #distributed-systems #hf

  46. hydro_std

    Standard library of distributed systems building blocks for Hydro

    v0.15.0 #distributed-systems #hydro #building-block #stream-processing #framework #distributed-applications #processing-stream #intermediate-representation #memory-safety #dataflow

  47. logicline

    Logic processing engine

    v0.1.8 #graph-visualization #visualization #monads

  48. fluvio-stream-model

    Fluvio Event Stream Model

    v0.50.1 1.6K #fluvio #event-stream #stream-processing #distributed-systems #real-time-data-processing #stream-processing-engine #cloud-native #event-streaming #dataflow #wasm

  49. graphix-shell

    A dataflow language for UIs and network programming

    v0.2.3 #dataflow-programming-language #ui #graphix #networking #netidx #language-for-ui #repl #network-programming #gx #charts

  50. fluvio-stream-dispatcher

    Fluvio Event Stream access

    v0.50.1 1.5K #event-streaming #fluvio #stream-processing #data-processing #real-time-data-processing #event-stream #distributed-systems #stream-processing-engine #cloud-native #dataflow

  51. flow-rs-core

    Core data structures and algorithms for Flow-RS

    v0.1.0-beta.2 #reactive #graph-visualization #visualization #reactive-graph #wasm

  52. fluvio-types

    Fluvio common types and objects

    v0.50.1 36K #fluvio #distributed-systems #stream-processing #data-processing #cloud-native #real-time-data-processing #dataflow #wasm #event-processing #stream-processing-engine

  53. terminal-print

    dora goal is to be a low latency, composable, and distributed data flow

    v0.3.12 500 #dataflow #low-latency #distributed-data #terminal #dora #text-to-speech

  54. dora-operator-api

    dora goal is to be a low latency, composable, and distributed data flow

    v0.3.13 2.6K #dataflow #low-latency-data #distributed #distributed-data #artificial-intelligence #dora #robotic #dataflow-oriented #robotics #ros2

  55. fluvio-package-index

    Fluvio Package Index

    v0.50.1 1.3K #fluvio #stream-processing #latest #cloud-native #data-processing #distributed-systems #real-time-data-processing #dataflow #stream-processing-engine #streaming-processing

  56. timely_bytes

    Disjoint mutable byte slices from a common allocation

    v0.25.1 5.3K #timely-dataflow #dataflow #byte #timely

  57. dora-core

    dora goal is to be a low latency, composable, and distributed data flow

    v0.3.13 750 #dataflow #low-latency-data #distributed #composable #distributed-data #robotics

  58. differential-dogs3

    Advanced join patterns in differential dataflow

    v0.18.0 2.6K #dataflow #join #query #differential #collection #respond #timely-dataflow #forms

  59. pulse-ops

    Built-in operators and combinators for Pulse dataflows — map, filter, join, window, and custom processing logic

    v0.1.2 #event-time #stream-processing #pulse #operator #parquet #rocksdb #kafka #local-first #windowing #flink

  60. agility

    A powerful and elegant reactive programming library for Rust, inspired by category theory

    v0.1.1 #category-theory #frp #async #signal

  61. neuronic

    Real-time graphical visualization of Caryatid message bus flow

    v0.1.0 #message-bus #monitoring #visualization #caryatid #gui

  62. differential-dataflow-master

    An incremental data-parallel dataflow platform

    v0.13.0-dev.1 3.4K #timely-dataflow #dataflow #differential

  63. mech

    programming language for building reactive systems like robots, games, and animations

    v0.2.73 #reactive-programming #mech-language #dataflow-programming #dataflow #run-time

  64. codas-flow

    Low-latency, high-throughput bounded queues ("data flows") for (a)synchronous and event-driven systems

    v0.5.1 240 #ring-buffer #lock-free #event-driven #codas #actor

  65. melodium

    Flow-oriented language & tool, focusing on treatments applied on data, allowing high scalability and massive parallelization safely

    v0.9.1 #scalability #dataflow-parallelization #signal #async #dataflow #async-signal

  66. plcviz

    PLC code visualization - graphs, dependencies, and documentation

    v0.3.3 #svg #l5x #visualization #plc

  67. renoir

    Reactive Network of Operators In Rust

    v0.6.0 #operator #stream-processing #reactive #distributed-systems #block #dataflow #parallel-data-processing #dataflow-graph #dataflow-programming #distributed-data-processing

  68. waffle

    Wasm Analysis Framework For Lightweight Experiments

    v0.1.1 2.5K #wasm-framework #ssa-ir #wasm-bytecode #experiment #wasm-compiler

  69. dora-download

    dora goal is to be a low latency, composable, and distributed data flow

    v0.3.13 #dataflow #low-latency #distributed-data #low-latency-data #composable #dora #robotic #dataflow-oriented #robotics #ros2

  70. dora-operator-api-c

    C API implementation for Dora Operator

    v0.3.13 2.5K #dataflow #dora #robotic #operator #api #distributed #dataflow-oriented #robotics #artificial-intelligence #ros2

  71. susumu

    Revolutionary functional language making data flow visible through arrow syntax

    v0.2.0 160 #visual-programming #functional #arrow-flow #programming-language #functional-programming #data-flow

  72. dora-node-api

    dora goal is to be a low latency, composable, and distributed data flow

    v0.3.13 750 #dataflow #shared-memory #low-latency #distributed #distributed-data #dora #low-latency-data #node-api #robotic #dataflow-oriented

  73. dora-rerun

    dora goal is to be a low latency, composable, and distributed data flow

    v0.3.7-rc0 500 #dataflow #low-latency #re-run #dora #low-latency-data #distributed #visualization #distributed-data #robotics

  74. aimdb-core

    Core database engine for AimDB - async in-memory data synchronization with bidirectional connectors

    v0.4.0 #in-memory-database #embedded-database #sync #database

  75. flarrow-layout

    flarrow (flow + arrow) is a rust runtime/framework for building dataflow applications

    v0.3.1 #dataflow #node #layout #framework #run-time #flarrow #tokio-runtime #apache-arrow

  76. flarrow-builtins

    flarrow (flow + arrow) is a rust runtime/framework for building dataflow applications

    v0.3.1 420 #tokio-runtime #dataflow #node #framework #flarrow #arrow-format #apache-arrow

  77. dora-node-api-c

    dora goal is to be a low latency, composable, and distributed data flow

    v0.3.13 2.2K #node-api #dataflow #low-latency #artificial-intelligence #dora #distributed #distributed-data #low-latency-data #robotic #dataflow-oriented

  78. compositor

    An interactive environment for the Compose language

    v0.1.2 #compose #interactive #language #stack-based #functional-programming #dataflow #execution-context #concatenative #composing #predictable

  79. fts-solver

    A reference solver for flow trading optimization

    v0.5.1 800 #trading #reference #optimization #auction #flow #trade #fts

  80. dora-operator-api-python

    dora goal is to be a low latency, composable, and distributed data flow

    v0.3.13 2.1K #dataflow #python #low-latency-data #distributed-data #composable #dora #robotic #dataflow-oriented #robotics #ros2

  81. reflexo-typst-shim

    A compatibility layer for Typst release and mainline versions

    v0.5.4 #typst #compatibility #browser #svg-rendering #nodejs #server-side-rendering #markdown #mainline #wasm #typst-preview

  82. dora-operator-api-types

    dora goal is to be a low latency, composable, and distributed data flow

    v0.3.13 #dataflow #low-latency #distributed #low-latency-data #distributed-data #dora #robotic #dataflow-oriented #arrow-format #robotics

  83. flarrow-runtime

    flarrow (flow + arrow) is a rust runtime/framework for building dataflow applications

    v0.3.1 410 #apache-arrow #dataflow #node #framework #flarrow #tokio-runtime #arrow-format #scheme-plugin #flows

  84. pipeline-dsl

    Pipeline DSL types and re-exports of #[pipeline]/#[stage]

    v0.1.0 #pipeline #dag #macro #dataflow #workflow

  85. dora-ros2-bridge

    ROS2 bridge for dora-rs

    v0.3.13 310 #ros2 #dora-rs #bridge #artificial-intelligence #message #gpu

  86. dora-tracing

    dora goal is to be a low latency, composable, and distributed data flow

    v0.3.13 750 #dataflow #low-latency #artificial-intelligence #composable #distributed #dora #distributed-data #open-telemetry #dataflow-oriented #robotic

  87. pulse-core

    Core runtime and dataflow engine for Pulse — defines execution graph, operators, and streaming primitives

    v0.1.2 #prometheus #stream-processing #event-time #parquet #operator #rocksdb #kafka #local-first #metrics #watermarks

  88. node-flow

    Runtime-agnostic, asynchronous node-based framework for building composable flows

    v0.2.0 #flows #node #node-based #composable #runtime-agnostic #dataflow #data-pipeline #flow-control

  89. flowistry_ide

    Information Flow in the IDE for Rust

    v0.5.44 1.6K #flowistry #static-analysis #ide #flow-analysis #dataflow #visual-studio-code #ide-plugin

  90. arroyo-udf-common

    Common utilities for the Arroyo UDF FFI API

    v0.2.1 140 #sql #event-processing #data #streaming

  91. qust

    finance quantative reserach

    v0.1.5 500 #tick-data #kline #trading #manager #finance #quantative #dataflow #backtest #trading-strategies #notebook

  92. flarrow-api

    flarrow (flow + arrow) is a rust runtime/framework for building dataflow applications

    v0.3.1 420 #dataflow #node #apache-arrow #framework #run-time #flarrow #tokio-runtime

  93. protoflow

    implements flow-based programming (FBP) for Rust using Protocol Buffers messages

    v0.4.3 2.1K #protobuf #fbp #flow

  94. noria

    Client bindings for Noria

    v0.6.1 #sql #database #dataflow #back-end #storage-sql

  95. timely-master

    A low-latency data-parallel dataflow system in Rust

    v0.13.0-dev.1 3.4K #timely-dataflow #dataflow #timely

  96. erdos

    platform for developing self-driving cars and robotics applications

    v0.4.0 #robotics #dataflow #driving #autonomos #data-flow

  97. timely-communication-master

    Communication layer for timely dataflow

    v0.13.0-dev.1 3.4K #timely-dataflow #dataflow #timely

  98. strop

    stochastically generates machine code

    v0.3.0 180 #brute-force #compiler-optimization #subroutine #random #machine #assembly #assembly-instructions

  99. iridis

    framework that lets you define and build dataflow applications with ease

    v0.4.0 500 #define #url-scheme #dataflow #framework #run-time #file-ext #plugin-api

  100. prk_async_dataflow

    An asynchronous dataflow processing library for Rust with SIMD-accelerated JSON parsing and AI agent capabilities

    v0.2.3 330 #ai-agent #json #simd-json #async

  101. rigs

    A orchestration framework for rig

    v0.0.8 420 #orchestration #rig #agent

  102. dora-rav1e

    dora goal is to be a low latency, composable, and distributed data flow

    v0.3.11-rc1 #dataflow #distributed #low-latency #dora #composable #robotic #distributed-data #dataflow-oriented #robotics #ros2

  103. dora-metrics

    dora goal is to be a low latency, composable, and distributed data flow

    v0.3.13 300 #dataflow #low-latency #distributed #low-latency-data #distributed-data #artificial-intelligence #dora #robotic #open-telemetry #dataflow-oriented

  104. pyridis-examples

    iridis, with python

    v0.3.5 #iridis #python #async-io #pyridis #node #python-script #pyridis-api #py #dataflow

  105. chemrust-core

    The core modules defining the flow and structs of data in computational chemistry routines

    v0.5.1 550 #computational-chemistry #struct #dataflow #model #traits

  106. googleapis-tonic-google-dataflow-v1beta3

    A Google APIs client library generated by tonic-build

    v0.29.0 #google-cloud-platform #google-api #gcp #api

  107. iridis-runtime-core

    iridis is a framework that lets you define and build dataflow applications with ease

    v0.4.0 490 #iridis #define #run-time #dataflow #node #plugin-api

  108. arcon

    A runtime for writing streaming applications

    v0.2.1 #streaming #stream-processing #run-time #arrow #conf #dataflow

  109. flowr

    Runners for compiled 'flow' programs

    v0.142.0 410 #graphical-user-interface #dataflow #runner #coordinator #execution #function-execution #flows #debugging #iced #gui

  110. hydroflow_deploy_integration

    hydro_deploy integration for Hydroflow

    v0.12.0 320 #framework #hydroflow #dataflow #run-time #hydro-deploy #distributed #intermediate-representation #distributed-systems #memory-safety #dfir

  111. timely-logging-master

    Common timely logging infrastructure

    v0.13.0-dev.1 3.5K #timely-dataflow #dataflow #logging #timely

  112. falcon

    A Binary Analysis Framework in Rust

    v0.5.5 120 #binary-analysis #framework #pe #x86-64 #translator #arm64 #mips #fixed-point #pe-analysis #dataflow

  113. flowcore

    Structures shared between runtime and clients

    v0.142.0 750 #file-provider #wasm #debugging #dataflow #context

  114. compose_core

    The Compose Language implementation

    v0.1.2 #stack #concatenative #programs #language #composing #stack-based #execution-context #functional-programming #dataflow

  115. flarrow-message

    flarrow (flow + arrow) is a rust runtime/framework for building dataflow applications

    v0.3.1 #dataflow #framework #flarrow #run-time #applications #tokio-runtime #apache-arrow #flarrow-runtime #node-client #node-api

  116. flarrow-url

    flarrow (flow + arrow) is a rust runtime/framework for building dataflow applications

    v0.2.2 110 #dataflow #node #run-time #framework #building #flarrow #tokio-runtime #apache-arrow

  117. timely-container-master

    Container abstractions for Timely

    v0.13.0-dev.1 3.4K #timely-dataflow #container #abstraction #system

  118. infect

    Intent/effect/task - A variation on the Model View Intent (MVI) and State Action Model (SAM) paradigms

    v0.0.30 190 #dataflow #applications #unidirectional #model

  119. zenoh-flow

    Zenoh-based data flow programming framework for computations that span from the cloud to the device

    v0.5.0-alpha.4 310 #dataflow #zenoh #deployment #dataflow-programming #computation #directed-graph #declaration #declarative-programming #happen

  120. flarrow-flows

    flarrow (flow + arrow) is a rust runtime/framework for building dataflow applications

    v0.3.1 #dataflow #flows #framework #applications #arrow #flarrow #tokio-runtime #apache-arrow #flarrow-runtime #node-client

  121. flowstdlib

    The standard library of functions and flows for 'flow' programs

    v0.142.0 550 #flows #dataflow #standard #programs #wasm #control-flow #data-control

  122. std-mel

    Mélodium standard library

    v0.9.1 #scalability #dataflow-parallelization #signal #dataflow #async #async-signal

  123. sdf-metadata

    metadata definition for core sdf

    v0.14.0 1.4K #define #sdf #metadata

  124. ux-dataflow

    Data Processing Library

    v0.1.2 #data-stream #dataframe #data-structures #datatable

  125. timely-bytes-master

    Disjoint mutable byte slices from a common allocation

    v0.13.0-dev.1 3.5K #timely-dataflow #dataflow #byte #timely

  126. melodium-common

    Common Mélodium elements and traits

    v0.9.1 230 #scalability #dataflow-parallelization #async-signal #dataflow #signal

  127. flarrow-file-ext

    flarrow (flow + arrow) is a rust runtime/framework for building dataflow applications

    v0.3.1 #dataflow #apache-arrow #framework #run-time #flarrow #arrow-format #tokio-runtime

  128. actyx_sdk

    Tools for interacting with the services of an Actyx node

    v0.3.0 #event-sourcing #decentralized #distributed

  129. protoflow-syntax

    Protoflow implements flow-based programming (FBP) for Rust using Protocol Buffers messages

    v0.4.3 1.3K #protobuf #protoflow #fbp

  130. reflexo-typst2hast

    The hast intermediate representation for rehype

    v0.7.0-rc2 #browser #typst #server-side-rendering #document #intermediate-representation #hast #nodejs #svg #dataflow #wasm

  131. flarrow-url-scheme

    flarrow (flow + arrow) is a rust runtime/framework for building dataflow applications

    v0.3.1 #dataflow #framework #arrow #flarrow #run-time #scheme-plugin #tokio-runtime #apache-arrow

  132. actyxos_sdk

    Tools for interacting with the services of an ActyxOS node

    v0.6.0 #event-sourcing #decentralized #distributed

  133. protoflow-blocks

    Protoflow implements flow-based programming (FBP) for Rust using Protocol Buffers messages

    v0.4.3 1.3K #protobuf #protoflow #fbp

  134. fs-mel

    Mélodium core filesystem interaction library

    v0.9.1 #scalability #dataflow-parallelization #async #signal #dataflow #async-signal

  135. moose

    Encrypted learning and data processing framework

    v0.2.2 #machine-learning #secure-computation #data-science #distributed #cryptography

  136. rusoto_groundstation

    AWS SDK for Rust - AWS Ground Station @ 2019-05-23

    v0.48.0 #aws-sdk #ground-station #aws

  137. json-mel

    Mélodium JSON data processing library

    v0.9.1 #scalability #async #dataflow-parallelization #signal #dataflow #async-signal

  138. process-mel

    Mélodium external process management library

    v0.9.1 #scalability #signal #dataflow-parallelization #dataflow #async #async-signal

  139. sdf-imports

    Stateful Dataflow import pkg utilities

    v0.14.0 1.4K #stateful-dataflow #import #utilities

  140. melodium-engine

    Mélodium core engine and executor implementation

    v0.9.1 #dataflow-parallelization #scalability #signal #async #dataflow #async-signal

  141. malstrom

    distributed, stateful stream processing framework written in Rust

    v0.1.0 #stream-data #framework #data #distributed-data #distributed

  142. dataflow

    data processing library, primarily for machine learning

    v0.4.0 #data-pipeline #machine-learning #data-loader #machine-learning-data #statically-typed

  143. melodium-repository

    Repository managment crate for Mélodium, with dependency resolution and retrieval

    v0.9.1 #scalability #dataflow-parallelization #async #signal #dataflow #async-signal

  144. plumber-rs

    The basic library for Plumber servlet written in Rust

    v0.1.2 #servlets #dataflow-programming

  145. pyridis-message

    iridis, with python

    v0.3.5 #iridis #python #async-io #dataflow-graph #message #pyridis #python-script

  146. iridis-layout

    iridis is a framework that lets you define and build dataflow applications with ease

    v0.4.0 #iridis #dataflow #define #dataflow-graph #node #plugin-api

  147. pyridis-api

    iridis, with python

    v0.3.5 100 #iridis #python #query #py #dataflow #pyridis #queryables #python-script #async-io

  148. hydroflow_lang

    Hydroflow's Surface Syntax implementation

    v0.10.0 140 #hydroflow #hydro #dataflow #syntax #construct #ide #hf #intermediate-representation

  149. flowc

    A compiler for 'flow' programs

    v0.142.0 490 #dataflow #connection #wasm #compiler #flows #debugging #date #flowr #compiler-optimization

  150. hydro_optimize

    Automatic decoupling and partitioning

    v0.13.0 #hydro #decoupling #automatic #framework #partitioning #distributed #distributed-systems #stream-processing #intermediate-representation #dataflow

  151. nimble-ordered-datagram

    Nimble Ordered Datagram

    v0.0.17-dev 450 #datagram #networking #game

  152. flarrow-url-default

    flarrow (flow + arrow) is a rust runtime/framework for building dataflow applications

    v0.2.2 110 #tokio-runtime #dataflow #framework #building #arrow #flarrow #apache-arrow

  153. iridis-builtins

    iridis is a framework that lets you define and build dataflow applications with ease

    v0.4.0 480 #iridis #dataflow #define #framework #build #plugin-api

  154. melodium-distribution

    Mélodium language parsing and semantic analyser

    v0.9.1 #scalability #dataflow-parallelization #dataflow #signal #async #async-signal

  155. cortex-ai

    An asynchronous flow-based processing framework for building flexible data pipelines with conditional branching and error handling

    v0.1.9 #data-pipeline #artificial-intelligence #conditional #flow-component #branch #async-pipeline #async-data #data-processing-pipeline #flow-based #dataflow

  156. torq_lang

    A programming language for concurrent dataflow

    v0.1.2 190 #artificial-intelligence #programming-language #dataflow #torq #big-data-analytics #dataflow-programming #concurrency

  157. inexor-rgf-core-reactive

    Inexor - Reactive Graph Flow - Core - Reactive

    v0.9.1 360 #reactive-graph-flow #reactive-programming #graph-database #inexor #graphql #flow-control-graph #ecs #knowledge-graph #document-store #dataflow

  158. net-mel

    Mélodium network utilities library

    v0.9.1 #scalability #async #dataflow-parallelization #dataflow #signal #async-signal

  159. regex-mel

    Mélodium regex library

    v0.9.1 #scalability #dataflow #signal #async #dataflow-parallelization #async-signal

  160. sql-mel

    Mélodium SQL library

    v0.9.1 #scalability #dataflow-parallelization #dataflow #signal #parallelization #async-signal

  161. ddshow

    Timely and Differential dataflow log analysis and vizualization

    v0.2.2 #timely-dataflow #dataflow #differential #tdiag #timely

  162. fluvio-system-util

    Fluvio System components

    v0.1.1 #fluvio #stream-processing #distributed-systems #data-processing #cloud-native #system-utilities #stream-processing-engine #real-time-data-processing #dataflow #streaming-processing

  163. hydroflow

    Hydro's low-level dataflow runtime and IR

    v0.10.0 140 #hydro #dataflow #service #lattice #documentation #dataflow-programming #dsl

  164. encoding-mel

    Mélodium text encode/decode library

    v0.9.1 #dataflow-parallelization #scalability #async #signal #async-signal #dataflow

  165. iridis-file-ext

    iridis is a framework that lets you define and build dataflow applications with ease

    v0.4.0 490 #file-extension #iridis #plugin-api #define #dataflow #dataflow-graph

  166. distrib-mel

    Mélodium distribution library

    v0.9.1 #scalability #async #dataflow-parallelization #dataflow #signal #async-signal

  167. flowrlib

    Flow Runner Library (flowrlib) for 'flow' programs

    v0.95.0 #dataflow #debugging #runner #wasm #metrics #run-time-execution #producing #coordinating #manifest-file

  168. melodium-lang

    Mélodium language parsing and semantic analyser

    v0.9.1 #scalability #dataflow-parallelization #async #dataflow #signal #async-signal

  169. mijit

    Experimental JIT compiler generator

    v0.2.4 #jit-compiler #interpreter #experimental #write #domain-specific-language #bee #beetle

  170. noria-server

    The Noria data-flow database server

    v0.6.0 #sql #database #dataflow #storage-sql

  171. iridis-url-scheme

    iridis is a framework that lets you define and build dataflow applications with ease

    v0.4.0 480 #url-scheme #iridis #dataflow #define #framework #plugin-api

  172. work-mel

    Mélodium distant work library

    v0.9.1 #scalability #dataflow-parallelization #dataflow #async-signal #parallelization

  173. calyx-opt

    Compiler Infrastructure for Hardware Accelerator Generation

    v0.7.1 200 #compiler-infrastructure #hardware-accelerator #ir #compiler

  174. noria-dataflow

    Internal noria-server crate

    v0.6.0 #web-apps #dataflow #noria-server #internal

  175. noir-compute

    Network of Operators In Rust

    v0.2.0 #data-processing #stream-processing #operator #distributed-data-processing #block #noir #distributed-systems #dataflow-graph #dataflow-programming

  176. log-mel

    Mélodium logging library

    v0.9.1 #scalability #async-signal #dataflow-parallelization #dataflow #async

  177. melodium-loader

    Loading engine for Mélodium, with dependency resolution and retrieval

    v0.9.1 #scalability #dataflow-parallelization #async #dataflow #signal #async-signal

  178. cicd-mel

    Mélodium CI/CD library

    v0.9.1 #scalability #dataflow-parallelization #async #dataflow #signal #async-signal

  179. iridis-flows

    iridis is a framework that lets you define and build dataflow applications with ease

    v0.3.4 150 #iridis #define #dataflow #framework #ease #plugin-api

  180. iridis-api

    iridis is a framework that lets you define and build dataflow applications with ease

    v0.3.4 #iridis #define #dataflow #framework #node #plugin-api

  181. sdfg

    standard sdf guest

    v0.14.0 3.6K #sdf #guest

  182. http-mel

    Mélodium HTTP library

    v0.9.1 #scalability #dataflow-parallelization #signal #dataflow #async #async-signal

  183. hydroflow_cli_integration

    hydro_cli integration for Hydroflow

    v0.5.2 430 #hydroflow #dataflow #stream-processing #service #hydro #intermediate-representation #memory-safety #dfir #distributed

  184. zenoh-flow-daemon

    The Zenoh-Flow daemon exposes a Zenoh-Flow runtime on Zenoh

    v0.6.0-alpha 300 #zenoh-flow #dataflow #daemon #run-time #computation #flows #dataflow-programming

  185. caseformat

    Power flow case data format

    v0.2.0 380 #file-format #power-flow #case #validation #dataflow #serialization

  186. iridis-node

    iridis is a framework that lets you define and build dataflow applications with ease

    v0.4.0 #define #iridis #dataflow #framework #ease #plugin-api

  187. qust-ds

    a part of crate qust

    v0.1.6 260 #tick-data #qust #save #position #notebook #part-of-qust #dataflow #kline #trading #backtest

  188. noria-mir

    Internal noria-server crate

    v0.6.0 #internal #dataflow #web-apps

  189. flurx

    Create reactive asynchronous data flow

    v0.1.6 700 #dataflow #async #reactive #reactor #async-data

  190. sdf-common

    Stateful Dataflow constants and common utils

    v0.14.0 #dataflow #stateful-dataflow #constant

  191. fluvio-controlplane

    Fluvio control plane API

    v0.6.0 #fluvio #control-plane #distributed-systems #stream-processing #api #cloud-native #dataflow #real-time-data-processing #wasm

  192. mako

    main Sidekick AI data processing library

    v0.3.0 #artificial-intelligence #data-processing #tokenize #data-loader #machine-learning #batch-processing #dataflow #sidekick #tokenized

  193. tdiag-connect

    Helpers to obtain traces suitable for diagnostics from timely / differential

    v0.2.0 #timely-dataflow #computation #diagnostics #tdiag #differential #tcp-socket #event-stream #single-threaded

  194. mech-core

    The Mech language runtime

    v0.2.73 130 #mech-language #dataflow-programming-language #run-time #dataflow

  195. google-dataflow1_b4

    A complete library to interact with dataflow (protocol v1b4)

    v0.1.5+20150401 #google-api #dataflow #web-api #google

  196. nature-demo

    Demo to show how to use Nature

    v1.5.0 100 #nature #demo #show #system #business #dataflow

  197. dpc

    A compiler for Minecraft datapacks

    v0.2.5 #minecraft-datapack #minecraft #datapack #compiler

  198. noria-common

    Internal noria-server crate

    v0.6.0 #dataflow #internal #web-apps

    199. Try searching with DuckDuckGo or on crates.io.

  199. iridis-message

    iridis is a framework that lets you define and build dataflow applications with ease

    v0.4.0 #iridis #define #dataflow #framework #build #plugin-api

  200. inexor-rgf-plugin-json

    Inexor - Reactive Graph Flow - Plugin - JSON

    v0.9.1 #reactive-graph-flow #reactive-programming #graph-database #inexor #json-plugin #document-store #json-processing #dataflow #web-server #git

  201. javascript-mel

    Mélodium JavaScript language library

    v0.9.1 #scalability #signal #dataflow-parallelization #dataflow #async #async-signal

  202. tdiag

    Tools to inspect a timely-dataflow computation

    v0.2.0 #timely-dataflow #computation #diagnostics #logging #source #command-line-interface

  203. zfctl

    Zenoh-Flow: a Zenoh-based data flow programming framework for computations that span from the cloud to the device

    v0.6.0-alpha 300 #zenoh-flow #dataflow #computation #cloud #dataflow-programming #directed-graph

  204. fluvio-runner-local

    Fluvio Engine Runner

    v0.3.0 #fluvio #stream-processing #distributed-systems #data-processing #wasm #dataflow #real-time #real-time-processing #data-pipeline

  205. timely_sort

    Sorting infrastructure for timely dataflow

    v0.1.6 1.3K #radix-sorting #sorting #timely-dataflow #dataflow #timely

  206. ddshow-types

    FFI-safe types for ddshow

    v0.2.2 #timely-dataflow #ddshow #dataflow #differential #timely

  207. iridis-examples

    iridis is a framework that lets you define and build dataflow applications with ease

    v0.3.4 #iridis #define #dataflow #framework #ease #plugin-api

  208. inexor-rgf-model-string

    Inexor - Reactive Graph Flow - Model - String

    v0.9.1 #reactive-graph-flow #reactive-programming #inexor #model #data-processing #git #dataflow

  209. melodium-doc

    Documentation generator for Mélodium projects

    v0.9.1 #scalability #signal #dataflow-parallelization #dataflow #async #async-signal

  210. arkflow-plugin

    High-performance Rust flow processing engine

    v0.1.0 #stream-processing #data #stream-processing-engine #sql #protobuf #dataflow #kafka #mqtt #batch-processing #processing-stream

  211. qust-api

    a part of crate qust

    v0.1.5 100 #qust #trading-strategies #manager #position #action #part-of-qust #dataflow #tick-data #kline #backtest

  212. st2-logformat

    Adapter-agnostic definitions for data types used by ST2

    v0.1.0 #stream-processing #st2 #log-record #timely-dataflow #computation #logging #pag #critical-path

  213. melodium-share

    Mélodium language parsing and semantic analyser

    v0.9.1 #scalability #dataflow #dataflow-parallelization #signal #async #async-signal

  214. actyxos_data_flow

    Tools for exporting live data from ActyxOS to external systems

    v0.1.0 #event-sourcing #decentralized #distributed

  215. declarative-dataflow

    A reactive query engine built on Differential Dataflow

    v0.2.0 #datalog #graphql #dataflow #differential #query

  216. liblisa-enc

    automated discovery and analysis of the ISA of a CPU

    v0.1.0 #lib-lisa #x86-64 #semantic #discovery-and-analysis #encoding #infer #cpu-isa #instr

  217. cargo-zenoh-flow

    Zenoh-Flow: a Zenoh-based data flow programming framework for computations that span from the cloud to the device

    v0.5.0-alpha.4 #zenoh #dataflow #computation #spans #cloud #dataflow-programming

  218. provider

    A content provider for 'flow' tools

    v0.34.7 #url #content #iops #browser #resolve #dataflow

  219. dge-runtime

    executing distributed computational graph

    v0.2.0 #computational-graph #rabbitmq #distributed #execution #executing #dataflow #message-queue #graph-node #distributed-computing #computation-graph

  220. flow_impl

    Definition of an Implementation trait for flow functions, and a derive macro

    v0.21.0 #macro-derive #traits #define #executed #dataflow

  221. zenoh-flow-plugin

    Zenoh-Flow: a Zenoh-based data flow programming framework for computations that span from the cloud to the device

    v0.5.0-alpha.4 #zenoh-flow #dataflow #computation #spans #dataflow-programming #cloud-data

  222. mech-server

    server and client for hosting Mech programs on a websocket

    v0.0.4 #mech-language #dataflow-programming #dataflow #run-time #programming-language

  223. flowing

    flow graph processing library

    v0.2.1 #graph #dataflow-programming #data-processing #dsp #flowgraph

  224. melodium-core

    Core implementation for compiled Mélodium elements

    v0.9.1 130 #scalability #signal #dataflow-parallelization #async #dataflow #async-signal

  225. tributary

    Data streams

    v0.1.0 #stream #reactive-dataflow #graphs

  226. ddshow-sink

    allow setting ddshow loggers for timely dataflow programs

    v0.2.2 #ddshow #timely-dataflow #dataflow #differential #timely

  227. qust-io

    a part of crate qust

    v0.1.5 100 #qust #kline #order #tick #flow #part-of-qust #dataflow #backtest #tick-data #live-trading

  228. flowr-utilities

    A set of utilities for tests and examples

    v0.142.0 260 #testing #utilities #dataflow #flows #running

  229. flowide

    A (WIP) IDE for 'flow' programs

    v0.31.0 #ide #ui #programs #flow #dataflow #gtk3

  230. flow-mel

    Mélodium core flow control library

    v0.7.1 #scalability #dataflow-parallelization #dataflow #async #signal #async-signal

  231. wolf-derivation-graph

    Adds support for memoizing data flow graphs to wolf-graph

    v0.1.0 #dataflow #data-flow-graph #dataflow-graph

  232. flowrstructs

    Structures shared between runtime and clients

    v0.34.6 #wasm #shared #dataflow #client #struct

  233. qust-stra

    a part of crate qust

    v0.1.5 100 #qust #kline #backtest #order #action #part-of-qust #dataflow #tick-data #live-trading

  234. dfir_datalog_core

    Datalog implementation for DFIR

    v0.13.0 #dfir #dataflow #framework #distributed #datalog #distributed-systems #hydro #stream-processing #intermediate-representation #memory-safety

  235. conv-mel

    Mélodium core types conversion library

    v0.7.1 #scalability #dataflow-parallelization #async #dataflow #signal #async-signal

  236. hydroflow_datalog_core

    Datalog implementation for Hydroflow

    v0.10.0 140 #hydroflow #logic-programming #datalog #dataflow #hydro #stream-processing #intermediate-representation #memory-safety #dfir #distributed

  237. tange

    Scalable Task-based Parallelism Framework

    v0.1.1 #parallel #dataflow #concurrency #thread #thread-concurrency

  238. dfir_macro

    Macro for using Hydro's Data Flow Intermediate Representation (DFIR)

    v0.15.0 #hydro #intermediate-representation #dataflow #dfir #framework #distributed #distributed-systems

  239. yapall

    Pointer Analysis for LLVM

    v0.1.2 #llvm #pointers #call-graph #analysis #dataflow #function-call

  240. whale_fall

    a code generator based on data flow style

    v1.0.0 #flow-style #dataflow #codegen #whale

  241. tange-collection

    Dataflow computation

    v0.1.2 #dataflow #parallel #thread #performance #concurrency #thread-concurrency

  242. dag_compute

    construction of arbitrary computation DAGs and the expression of dataflow graphs

    v0.1.0 #dataflow #computation-graph #dag

  243. dora-operator-api-macros

    Rust API Macros for Dora Operator

    v0.3.13 2.4K #dora #distributed #robotic #api #dataflow #dataflow-oriented #robotics #artificial-intelligence #ros2 #gpu

  244. flarrow-runtime-core

    flarrow (flow + arrow) is a rust runtime/framework for building dataflow applications

    v0.3.1 #dataflow #node #framework #run-time #applications #flarrow #tokio-runtime #apache-arrow

  245. hotpath-macros

    async Rust profiler with memory and data-flow insights - quickly find and debug performance bottlenecks. Proc macros crate.

    v0.9.2 1.8K #hotpath #profiling #debugging #dataflow #mpsc #memory-management #benchmark #memory-profiling #memory-profiler #code-block