Lib.rs

› Keywords #ipc #zero-copy-ipc #zenoh #distributed-systems #message-broker #robotics

#pub-sub

  1. redis

    driver for Rust

    v1.2.1 5.3M #redis-cluster #pub-sub #valkey #sentinel

  2. embassy-sync

    no-std, no-alloc synchronization primitives with async support

    v0.8.0 346K #synchronization-primitive #async-channel #pub-sub #embedded #single-consumer #waker #registering #atomic-waker #asynchronous-tasks #embassy

  3. zenoh

    Zero Overhead Pub/Sub/Query Protocol

    v1.9.0 143K #pub-sub #query #computation #protocols #rest #ros2 #zero-overhead #geo-distributed

  4. google-pubsub1

    A complete library to interact with Pubsub (protocol v1)

    v7.0.0+20251212 44K #google-api #pub-sub #web-api #google

  5. iceoryx2-bb-system-types

    iceoryx2: [internal] strong types that represents low level constructs like file, path, ip address, etc

    v0.8.1 20K #zero-copy-ipc #ipc #pub-sub

  6. gcloud-pubsub

    Google Cloud Platform pubsub client library

    v1.7.0 164K #pub-sub #google-api #gcp #google-cloud #publish-subscribe

  7. iceoryx2

    Lock-Free Zero-Copy Interprocess Communication

    v0.8.1 20K #ipc #zero-copy-ipc #pub-sub

  8. saorsa-gossip-pubsub

    Pub/sub for Saorsa Gossip: Plumtree epidemic broadcast with EAGER/IHAVE/IWANT

    v0.5.50 1.2K #pub-sub #gossip #broadcast #plumtree

  9. netidx

    Secure, fast, pub/sub messaging

    v0.32.0 260 #pub-sub #kerberos #distributed #networking

  10. zenohd

    Zenoh: The Zero Overhead Pub/Sub/Query Protocol

    v1.9.0 3.3K #distributed-storage #zenoh #pub-sub #zero-overhead #query #pub-sub-messaging #geo-distributed

  11. ralph-proto

    Shared types, error definitions, and traits for Ralph Orchestrator

    v2.9.3 #ralph #ai-agent #pub-sub #orchestration #hat #gemini-cli #kiro #agent-orchestration

  12. sockudo-ws

    Ultra-low latency WebSocket library for HFT applications

    v1.7.4 1.9K #http2 #io-uring #quic #pub-sub #http-3 #websocket-server #utf-8 #ultra-low-latency #sockudo #hft

  13. google-pubsub1_beta2

    A complete library to interact with Pubsub (protocol v1beta2)

    v7.0.0+20251212 #pub-sub #google-api #web-api

  14. speare

    actor-like thin abstraction over tokio::task and flume channels

    v0.4.3 2.5K #actor-framework #pub-sub #task #abstraction #flume #supervision #actor-like #millis #tokio-time

  15. zenoh-plugin-mqtt

    Zenoh plugin for MQTT

    v1.9.0 #zenoh #pub-sub #mqtt-server #eclipse #plugin #mqtt-client #authentication #eclipse-plugin #mqtt-topic #zero-overhead

  16. zenoh-ext

    Zenoh: extensions to the client API

    v1.9.0 14K #zenoh #pub-sub #serialization #extension #networking #distributed-systems #zero-overhead #geo-distributed #api-client #roadmap

  17. submap

    B-Tree map for pub/sub services

    v0.3.6 290 #pub-sub #subscription #b-tree

  18. zenoh-backend-s3

    Backend for Zenoh using AWS S3 API

    v1.9.0 #amazon-s3 #zenoh #storage-back-end #min-io #s3-api #aws #pub-sub

  19. mles

    distributed publish-subscribe data server

    v2.8.1 #pub-sub #websocket #protocols

  20. zenoh-runtime

    Zenoh: The Zero Overhead Pub/Sub/Query Protocol

    v1.9.0 139K #zenoh #pub-sub #zero-overhead #pub-sub-messaging #protocols #distributed-systems #distributed-storage #embedded

  21. majra

    Distributed queue & multiplex engine — pub/sub, priority queues, relay, IPC, heartbeat, and rate limiting for Rust

    v1.0.4 100 #pub-sub #relay #distributed #distributed-queue #ipc

  22. pharos

    Observer pattern which generates a futures 0.3 stream of events

    v0.5.3 689K #broadcast #pub-sub #future

  23. shove

    Async tasks via pubsub on steroids. Comes with built-in support for complex queue configurations, audit logs, autoscaling consumer groups and more.

    v0.10.2 420 #pub-sub #consumer-groups #auto-scaling #rabbitmq

  24. moq-token

    Media over QUIC - Token Generation and Validation

    v0.6.0 7.3K #jwt #quic #pub-sub #moq #token #generation-and-validation #authentication #jwk #broadcast

  25. zenobuf-cli

    Command-line tools for the Zenobuf framework - monitor topics, call services, manage parameters

    v0.3.5 #framework #zenoh #service #monitor #manage #command-line-tool #pub-sub #ros #protobuf #distributed-systems

  26. flo_stream

    Pubsub and related streams for Rust futures

    v0.7.1 1.4K #pub-sub #concurrency #future-concurrency #future

  27. maiko

    Lightweight event-driven actor runtime with topic-based pub/sub for Tokio

    v0.3.1 #pub-sub #actor #message-passing #tokio-actor #tokio

  28. tmq

    ZeroMQ bindings for Tokio

    v0.5.0 164K #pub-sub #zeromq #bindings-for-tokio #async

  29. cyclonedds

    Safe Rust wrapper for Eclipse CycloneDDS

    v1.8.0 #pub-sub #distributed #dds #middleware

  30. zenoh-plugin-remote-api

    Zenoh: The Zero Overhead Pub/Sub/Query Protocol

    v1.9.0 #zenoh #pub-sub #remote-api #zero-overhead #query #certificate #typescript

  31. zerodds-dcps

    DCPS Public API (OMG DDS 1.4 §2.2.2): DomainParticipant, Publisher, Subscriber, Topic, DataWriter, DataReader. Live-Runtime mit SPDP/SEDP/WLP, Built-in-Topics, TypeLookup-Service, Durability-Backend.

    v1.0.0-rc.1 #dds-rtps #pub-sub #rtps #dds #dcps

  32. crossbar

    Zero-copy pub/sub over shared memory. URI-addressed. O(1) transfer at any payload size.

    v1.2.0 #zero-copy-ipc #pub-sub #ipc #shared-memory #low-latency

  33. mom-rpc

    Async RPC over AMQP, DDS, MQTT, and Redis. Transport-agnostic — switch brokers via feature flags, not code.

    v0.9.3 #pub-sub #rpc #iot #async

  34. ipc-broker

    A lightweight IPC broker for Rust that supports multiple transports (TCP, Unix sockets, Named Pipes) and provides an actor model with message passing and RPC capabilities

    v1.1.3 #ipc #unix-socket #pub-sub #named-pipe #message-broker #tcp-socket #actor-model #rpc-transport #rpc-call #ctrl-c

  35. mzmq

    Minimal no_std ZMQ (ZMTP 3.1) PUB transport for embedded

    v0.1.3 #pub-sub #zeromq #zmtp #no-std #embedded

  36. iceoryx2-pal-posix

    iceoryx2: [internal] A posix layer that ensures uniform posix behavior on all platforms according to https://posix.opengroup.org

    v0.8.1 19K #ipc #zero-copy-ipc #pub-sub

  37. zenobuf-core

    A simpler ROS-like framework in Rust with Zenoh transport and Protocol Buffers

    v0.3.5 #protobuf #zenoh #pub-sub #ros #framework #distributed-systems

  38. cal-redis

    Callable Redis Implementation

    v0.1.80 4.9K #redis-cache #local-cache #pub-sub #update #websocket #moka #in-memory-cache #cache-layer

  39. danube-client

    The async client for Danube Messaging Broker platform

    v0.14.0 #message-broker #pub-sub #messaging-system #danube #event-streaming

  40. manager_handlers

    A microservice manager implementation that creates HTTP-accessible handlers with configurable replicas. Handlers communicate via an internal bus, enabling collaborative request processing in a distributed architecture.

    v0.7.2 3.1K #pub-sub #actix-web #handler #microservices

  41. emergent-client

    Client library for Emergent event-based workflow platform

    v0.13.1 #pub-sub #unix-socket #emergent #workflow-engine #primitive #event-driven #ipc #system-events #serde #event-driven-workflow

  42. iceoryx2-pal-concurrency-sync

    iceoryx2: [internal] low-level basic building blocks to implement posix mutex, condition variables etc

    v0.8.1 19K #ipc #zero-copy-ipc #pub-sub

  43. zenoh-plugin-storage-manager

    The zenoh storages plugin

    v1.9.0 1.5K #zenoh #storage #pub-sub #rest #distributed-storage #plugin-manager #distributed-systems #geo-distributed

  44. kameo_actors

    actors for kameo

    v0.5.0 21K #pub-sub #actor #actor-pool #broker #pool

  45. rust-ipfs

    IPFS node implementation

    v0.15.0 #filesystem #interplanetary #dht #discovery #pub-sub

  46. stinger-mqtt-trait

    Rust trait for defining an interface for a MQTT client

    v0.6.1 220 #mqtt-client #pub-sub #client-connection #traits #pub-sub-client #ipc #qos #mqtt-topic #life-cycle #subscribing

  47. iceoryx2-bb-elementary

    iceoryx2: [internal] elementary constructs that have (almost) no dependencies at all

    v0.8.1 19K #ipc #zero-copy-ipc #pub-sub

  48. privchat-protocol

    Protocol library for PrivChat IM — message types, RPC routes, error codes, presence, and notifications

    v0.1.1 #pub-sub #routes #error-code #rpc #notifications #presence #im #sticker #privacy #authentication

  49. mini-redis

    An incomplete implementation of a Rust client and server. Used as a larger example of an idiomatic Tokio application.

    v0.4.1 7.6K #redis-server #pub-sub #graceful-shutdown #tokio #incomplete #tcp-server #server-connection #tokio-mutex

  50. photon-ring

    Ultra-low-latency SPMC/MPMC pub/sub using stamped ring buffers. Formally sound with atomic-slots feature. no_std compatible.

    v2.5.0 #pub-sub #spmc #zero-alloc #lock-free #no-std

  51. iceoryx2-bb-posix

    iceoryx2: [internal] high level safe abstractions for low level unsafe posix constructs

    v0.8.1 19K #ipc #zero-copy-ipc #pub-sub

  52. simple_redis

    resilient redis client

    v0.6.5 #redis #pub-sub #redis-cache #cache #database

  53. iceoryx2-bb-memory

    iceoryx2: [internal] allocators and tools for memory management

    v0.8.1 27K #ipc #zero-copy-ipc #pub-sub

  54. synap-sdk

    Rust SDK for Synap - High-Performance In-Memory Key-Value Store & Message Broker

    v0.12.0 #pub-sub #message-queue #event-stream #synap #kv-store

  55. iceoryx2-bb-lock-free

    iceoryx2: [internal] lock-free containers and constructs

    v0.8.1 19K #ipc #zero-copy-ipc #pub-sub

  56. centrifuge-client

    Rust client SDK for the Centrifuge real-time messaging protocol

    v0.1.0-alpha.2 100 #websocket #pub-sub #centrifuge #centrifugo #real-time

  57. iceoryx2-cal

    iceoryx2: [internal] high-level traits and implementations that represents OS primitives in an exchangeable fashion

    v0.8.1 20K #zero-copy-ipc #ipc #pub-sub

  58. netidx-protocols

    Protocols built on top of netidx

    v0.32.0 250 #netidx #distributed-systems #publisher #data-sharing #subscriber #pub-sub #distributed-data #secure-messaging #message-broker #real-time

  59. jsonrpc-utils

    Alternative pub/sub and server implementations for jsonrpc-core

    v0.6.0 2.7K #json-rpc-server #pub-sub #jsonrpc-core #tcp-server #websocket

  60. simple-pub-sub

    message broker

    v0.1.7 500 #message-broker #pub-sub #simple

  61. zenoh-plugin-trait

    Zenoh: The Zero Overhead Pub/Sub/Query Protocol

    v1.9.0 143K #zenoh #plugin #pub-sub #traits #query #dynamic-plugin #stopping #static-plugin #zero-overhead #warnings

  62. aurora-db

    A lightweight, real-time embedded database with built-in PubSub, reactive queries, background workers, and intelligent caching

    v0.6.3 #embedded-database #pub-sub #real-time #reactive #database

  63. iceoryx2-pal-configuration

    iceoryx2: [internal] platform specific settings

    v0.8.1 21K #ipc #zero-copy-ipc #pub-sub

  64. iceoryx2-bb-testing

    iceoryx2: [internal] simple testing primitives

    v0.8.1 950 #ipc #zero-copy-ipc #pub-sub

  65. libp2p-gossipsub

    Gossipsub protocol for libp2p

    v0.49.4 324K #p2p #pub-sub #networking

  66. xoq

    X-Embodiment over QUIC - P2P and relay communication for robotics

    v0.3.6 #quic #robotics #p2p #serial-port #moq #iroh #camera-capture #relay-server #pub-sub #socket-can

  67. hdds-router

    HDDS DDS Routing Service - Domain bridging and topic transformation

    v1.1.2 #pub-sub #routing #dds #middleware #routing-middleware

  68. netidx-archive

    netidx archive file format

    v0.32.0 #archive #netidx #archive-file-format #distributed-systems #subscriber #publisher-subscriber #pub-sub #secure-messaging

  69. iceoryx2-bb-threadsafe

    iceoryx2: [internal] threadsafe non-lock-free containers and constructs

    v0.8.1 800 #ipc #zero-copy-ipc #pub-sub

  70. emergent-engine

    Event-driven workflow engine -- compose CLI tools into pub-sub pipelines with TOML

    v0.10.9 #pub-sub #event-driven #orchestration #event-driven-workflow

  71. netidx-netproto

    netidx wire protocol

    v0.32.0 290 #netidx #distributed-systems #publisher #path #server #wire-protocols #pub-sub #distributed-data #secure-messaging #message-broker

  72. atomr-cluster-tools

    Distributed pub/sub, cluster singleton, and cluster client patterns for atomr

    v0.9.2 #pub-sub #singleton #cluster

  73. iceoryx2-bb-elementary-traits

    iceoryx2: [internal] elementary traits that have (almost) no dependencies at all

    v0.8.1 15K #zero-copy-ipc #ipc #pub-sub

  74. event_bus_rs

    A runtime-agnostic, async, and thread-safe event bus for Rust

    v0.1.10 #pub-sub #event-based #messaging

  75. iceoryx2-bb-linux

    iceoryx2: [internal] high level safe abstractions for low level unsafe linux constructs

    v0.8.1 17K #ipc #zero-copy-ipc #pub-sub

  76. fp_rust

    Implement fp features for Rust

    v0.3.5 210 #pub-sub #monads #rx #optional #functional

  77. noesis-ship

    Rust NATS communication platform for multi-agent AI systems

    v0.15.2 #pub-sub #nats #multi-agent

  78. zerodds-corba-cos-event

    OMG CosEventService 1.4 — Push/Pull-Modell + EventChannelAdmin + TypedEvent (no_std + alloc)

    v1.0.0-rc.1 #dds #no-std #corba #pub-sub #cos-event

  79. zenoh-plugin-rest

    The zenoh REST plugin

    v1.9.0 2.0K #zenoh #rest #pub-sub #query #computation #geo-distributed

  80. zenoh-backend-influxdb-v1

    Backend for Zenoh using InfluxDB v1.x

    v1.9.0 #zenoh #storage-back-end #influx-db #pub-sub #credentials #zero-overhead

  81. ya-gcp

    APIs for using Google Cloud Platform services

    v0.12.0 1.2K #gcs #pub-sub #gcp

  82. netidx-value

    netidx value type

    v0.32.0 290 #netidx #value #update #read #pub-sub #secure-messaging #message-broker #data-sharing #real-time #distributed

  83. psrt

    Industrial Pub-Sub server with minimal latency and MQTT-compatible logic

    v0.3.5 #pub-sub #server-client

  84. tapaculo

    Lightweight Rust server for real-time and turn-based multiplayer communication

    v1.5.0 #multi-player #pub-sub #game-server #real-time

  85. iceoryx2-loggers

    iceoryx2: swappable logger implementations

    v0.8.1 12K #ipc #zero-copy-ipc #pub-sub

  86. mecha10-cli

    Mecha10 CLI tool

    v0.1.47 #config-json #logging #node #model #robot #pub-sub #topology #debugging #real-time-monitoring #cross-compilation

  87. mt_net

    Network communication types and pub/sub resolution in Minot

    v0.7.0 210 #pub-sub #networking #robotics

  88. zenoh-backend-influxdb-v2

    Backend for Zenoh using InfluxDB v2.x

    v1.9.0 #storage-back-end #zenoh #influx-db #pub-sub #admin #zero-overhead

  89. iceoryx2-bb-concurrency

    iceoryx2: concurrency primitives

    v0.8.1 12K #ipc #zero-copy-ipc #pub-sub

  90. turbocable-server

    High-performance WebSocket gateway for TurboCable (1M+ connections)

    v0.5.1 #prometheus #nats #jwt #gateway #messagepack #broadcast #pub-sub #jetstream #graceful-shutdown #fan-out

  91. iceoryx2-pal-os-api

    iceoryx2: [internal] OS api layer for OS specific features

    v0.8.1 12K #zero-copy-ipc #ipc #pub-sub

  92. psmatcher

    A pub/sub matcher algorithm implementation

    v0.5.0-alpha.0 #pub-sub #subscription #regex #events #matcher #matching-algorithm #tree-based #attribute-value #elementary #tree-algorithm

  93. zerodds-zenoh-bridge

    Bidirektionale Bridge zwischen ZeroDDS-DCPS und Eclipse-Zenoh: Topic-Mapping + QoS-Translation + optionaler Live-Runtime via Feature zenoh-runtime

    v1.0.0-rc.1 #zenoh #bridge #iot #pub-sub #dds

  94. msg-common

    Common functions and types for the msg crates

    v0.1.6 #distributed-systems #built #tokio #messaging #sockets #distributed-messaging #messaging-system #pub-sub #msg-rs #request-reply

  95. iceoryx2-pal-testing

    iceoryx2: [internal] simple testing primitives

    v0.8.1 190 #ipc #zero-copy-ipc #pub-sub

  96. alien-commands

    Alien Commands protocol implementation

    v1.3.5 #deployment #alien #payload #response #lease #pub-sub #service-bus #presigned

  97. iceoryx2-bb-container

    iceoryx2: IPC shared memory compatible containers

    v0.8.1 18K #ipc #zero-copy-ipc #pub-sub

  98. hermes-broker-client

    gRPC client library for the Hermes message broker — publisher and subscriber

    v0.7.0 #message-broker #pub-sub #publisher #grpc-client #tls #hermes #reconnection #fire-and-forget #mtls

  99. mqttrs

    Mqtt protocol encoding and decoding

    v0.4.1 800 #pub-sub #mqtt #codec

  100. hermes-broker-server

    gRPC server for the Hermes message broker

    v0.7.0 #grpc-server #message-broker #hermes #stream #pub-sub #mpsc #deliveries #tonic #env-vars

  101. iceoryx2-bb-log

    iceoryx2: [internal] the logger

    v0.7.0 10K #ipc #zero-copy-ipc #pub-sub

  102. alien-gcp-clients

    Deploy software into your customers' cloud accounts and keep it fully managed

    v1.3.5 #google-cloud #gcs #cloud-storage #client #pub-sub #secrets-manager #resource-manager #cloud-run #cloud-deployment #artifact-registry

  103. nanoservices-utils

    A collection of utilities for nanoservices

    v0.2.1 850 #actix #testing #axum #macro #nanoservices #dependency-injection #dal #database #pub-sub

  104. plasmite

    Persistent JSON message queues backed by plain files for local and remote IPC

    v0.6.1 #pub-sub #ipc #json

  105. nanomsg

    A high-level, Rust idiomatic wrapper around nanomsg

    v0.7.2 #pub-sub #sub #binding

  106. iceoryx2-tunnel-conformance-tests

    iceoryx2: Conformance tests for iceoryx2-tunnel

    v0.8.1 #ipc #zero-copy-ipc #pub-sub

  107. uzumibi-google

    Google Cloud extension for Uzumibi (Cloud Run metadata, Firestore, Pub/Sub, IAP JWT)

    v0.1.0 #google-cloud #jwt #uzumibi #pub-sub #cloud-run #web-framework #iap #firestore #mruby #ruby

  108. rmqtt-web-hook

    This enables RMQTT to send hook event notifications to a web service

    v0.20.0 #rmqtt #mqtt-broker #pub-sub #notifications #web-hook #message-queue #message-broker #web-services #iot #concurrency

  109. b00t-ipc

    Inter-process communication for b00t multi-agent systems

    v0.8.0 #ipc #multi-agent #b00t #message-bus #vote #multi-agent-systems #pub-sub #personality #agent-identity #crew

  110. iceoryx2-conformance-tests

    iceoryx2: Conformance tests for iceoryx2 components and extensions

    v0.8.1 #ipc #zero-copy-ipc #pub-sub

  111. forgekit-runtime

    ForgeKit runtime layer - Indexing and caching

    v0.1.2 #sdk #call-graph #semantic-search #control-flow-analysis #sqlite #dual #api-reference #pub-sub

  112. kora-pubsub

    Sharded Pub/Sub broker for Kōra

    v0.2.0 #hash #pub-sub #kora #redis #sharding #message-broker #glob #vector-search #database

  113. mecha10-nodes-simulation-bridge

    Simulation bridge node that translates between Redis pub/sub and Godot RL Agents protocol

    v0.1.25 #simulation-bridge #godot #pub-sub #rl #node #redis #mecha10 #rl-agent #command-framework #env-vars

  114. reliably

    A fully-featured real-time Rust client for Ably

    v0.3.4 #pub-sub #real-time #ably

  115. service-channel

    actor model in rust, like actix

    v0.1.2 #actor-model #actix #service #serviceless #send #pub-sub

  116. iceoryx2-tunnel-backend

    iceoryx2: traits and types for implementing tunnel backends

    v0.8.1 #zero-copy-ipc #ipc #pub-sub

  117. potential

    PubSub lib with sync and async API

    v3.0.1 #pub-sub #async

  118. bus_queue

    Lock-free Bounded non-Blocking Pub-Sub Queue

    v0.5.3 #pub-sub #lock-free-queue #lock-free #async #future

  119. gcp-rust-tools

    Comprehensive Google Cloud Platform tools for Rust: Observability (Logs, Metrics, Traces) and PubSub

    v0.2.6 #observability #pub-sub #logging #gcp #google-cloud

  120. hedwig

    message bus for Rust

    v7.2.0 120 #message-bus #pub-sub #microservices #redis

  121. solace-rs

    Unofficial Solace PubSub+ Rust Client Library. It can be used to access the services of a Solace PubSub+ Event Broker. This is a wrapper around the Solace C library. Use under your own risk…

    v0.8.0 1.7K #pub-sub #pub-sub-client #messaging

  122. iceoryx2-cal-conformance-tests

    iceoryx2: Conformance tests for iceoryx2-cal components and extensions

    v0.8.1 #zero-copy-ipc #ipc #pub-sub

  123. omnibus

    A lightweight, in-process publish/subscribe event bus for Rust

    v0.1.0 #pub-sub #broadcast #event-bus

  124. zopp-events

    Event bus abstraction for zopp

    v0.1.1 #zopp #event-bus #secret #events #abstraction #pub-sub #postgresql #redis #broadcast-channel

  125. iceoryx2-tunnel-zenoh

    iceoryx2: zenoh backend for the tunnel

    v0.8.1 #ipc #zero-copy-ipc #pub-sub

  126. klieo-bus-memory

    In-process Pubsub / RequestReply / KvStore / JobQueue impls for klieo-core

    v0.3.0 #key-value-store #job-queue #pub-sub #request-reply #in-process #process-memory #klieo #ack

  127. async_pub_sub

    aiming at making async pub-sub easier in Rust

    v0.2.1 270 #pub-sub #async

  128. iceoryx2-bb-trait-tests

    iceoryx2: [internal] tests for implementations of iceoryx2-bb traits

    v0.8.1 #zero-copy-ipc #ipc #pub-sub

  129. rustecal

    Meta-crate for rustecal: re-exports core, pubsub and service APIs

    v0.1.8 #pub-sub #ipc #middleware #ecal #rpc

  130. django-rs-signals

    Signal dispatcher for django-rs: decoupled event handling and pub/sub

    v0.1.0 #signal #django #dispatcher #events #decoupled #pub-sub #arc #orm #test-framework #template-engine

  131. clasp-lens

    LensVM WASM transform host for CLASP signal pipelines

    v4.5.0 #clasp #encryption #pub-sub #signal #transform #wasm-module #lens #automation #binary-protocol #pub-sub-messaging

  132. postvan

    A minimalistic implementation of pub/sub messaging

    v0.3.1 #events #pub-sub #actor

  133. rekt_lib

    Common lib to use the RekT protocol. See the crate homepage to check the protocol RFC.

    v0.1.13 800 #pub-sub #broker #rek-t-protocol #masivement-online

  134. klieo-bus-nats

    Production NATS JetStream + KV impls of klieo-core's bus traits

    v0.3.0 #jetstream #pub-sub #klieo #job-queue #key-value-store #request-reply #nats #dedup

  135. rmqtt-topic-rewrite

    Some legacy IoT devices can't change MQTT topics. RMQTT's topic rewriting auto-maps topics during subscribe, unsubscribe, or publish.

    v0.20.0 #mqtt-topic #pub-sub #rmqtt #message-broker #iot #message-queue

  136. zenoh-backend-influxdb

    Backend for Zenoh using InfluxDB

    v0.10.0-rc #zenoh #storage-back-end #influx-db #pub-sub #query #git #zero-overhead

  137. mles-utils

    Mles server and clients

    v1.1.7 200 #mles #pub-sub #protocols #cbor

  138. oxigdal-pubsub

    Google Cloud Pub/Sub integration for OxiGDAL - Pure Rust streaming and messaging

    v0.1.4 #pub-sub #streaming #google

  139. aurora-streams

    managing publish-subscribe channels using Tokio message passing channels

    v2.0.0-rc.2 650 #message-channel #pub-sub #tokio-based #aurora #stream #async-messaging

  140. pubsub-client-rust

    Minimal Rust pubsub client call to Google Cloud

    v0.2.0 #google-cloud #pub-sub #client #sample #call #cloud-run #cloud-pub

  141. jsonrpc-derive

    High level, typed wrapper for jsonrpc-core

    v18.0.0 193K #json-rpc-client #typed #object #high #level #io-handler #pub-sub #rpc-server

  142. azoth-bus

    Multi-consumer pub/sub bus built on Azoth primitives

    v0.2.5 #pub-sub #multi-consumer #azoth #events-bus #async-stream #notifications #stream-processing #retention-policies #logging #cargo-run

  143. iceoryx2-log-types

    iceoryx2: logger types and traits

    v0.8.1 13K #ipc #zero-copy-ipc #pub-sub

  144. emyzelium

    Wrapper for ZeroMQ's Pub-Sub with Curve+ZAP, over Tor. Peers, identified by public key, onion, and port, publish Vec<Vec<u8>> under topics to which other peers subscribe.

    v0.9.12 410 #pub-sub #zeromq #tor #peer #networking

  145. pulse-protocol

    Wire protocol definitions for Pulse realtime engine

    v0.1.1 #messagepack #wire-protocols #presence #define #engine #prometheus #pub-sub #web-transport #binary-protocol #metrics

  146. iceoryx2-cli

    CLI tools for iceoryx2

    v0.8.1 #ipc #pub-sub #zero-copy-ipc

  147. zenobuf-macros

    Procedural macros for the Zenobuf framework - derive macros for Protocol Buffer integration

    v0.3.5 #protobuf #pub-sub #framework #distributed-systems #macro-derive #zenoh #zenobuf #proc-macro #messaging-system #ros

  148. picopub

    A sync/async pub-sub library with bounded queues and backpressure using Mutex and Condvar

    v0.1.1 #pub-sub #backpressure #async #concurrency

  149. wampire

    A asynchronous WAMPv2 client and router implenting the basic WAMP profile

    v0.2.1 #pub-sub #wamp #rpc #microservices #wamp2

  150. rustecal-pubsub

    Publish/Subscribe API for Eclipse eCAL

    v0.1.9 500 #pub-sub #ipc #middleware #ecal

  151. rmqtt-bridge-egress-mqtt

    Bridge remote MQTT in egress mode

    v0.20.0 #rmqtt #mqtt #pub-sub #egress #mode #message-broker #message-queue #mqtt-broker #jwt #distributed-messaging

  152. mqtt-rs

    MQTT driver for epics-rs — publish/subscribe MQTT topics as EPICS records

    v0.17.2 #driver #pub-sub #mqtt-topic #record #mqtt-broker #epics-rs #motion-sensors #pv #ioc #rumqttc

  153. bext-realtime

    Realtime pub/sub for bext — WebSocket and SSE with optional Redis relay

    v0.2.0 #pub-sub #bext #websocket #real-time #sse

  154. iceoryx2-log

    iceoryx2: logger front-end

    v0.8.1 13K #ipc #zero-copy-ipc #pub-sub

  155. iceoryx2-tunnel

    iceoryx2: the generic tunnel implementation

    v0.8.1 #ipc #zero-copy-ipc #pub-sub

  156. probe-zmq

    Probe is a TUI ZMQ PUB/SUB monitor and debugger

    v0.3.7 550 #zeromq #pub-sub #probe #debugging #tui #keyboard

  157. agentic-comm-cli

    CLI for agentic-comm: agent communication, channels, pub/sub

    v0.1.0 #pub-sub #agentic #agent-communication #acomm #command-line-interface #cli-agent #model-context-protocol

  158. mecha10-nodes-websocket-bridge

    WebSocket bridge node that forwards Redis pub/sub to WebSocket clients

    v0.1.46 #pub-sub #websocket #redis #bridge #node #dashboard

  159. msg-socket

    Sockets for msg-rs

    v0.1.6 #pub-sub #distributed-systems #request-reply #msg-rs #tcp-connection #network-simulation #transport-layer #retries #pluggable-transport #compression

  160. pubsub-bus

    Thread-safe one-to-many publish-subscribe event system. Simple and easy to use. It just works (hopefully).

    v3.1.0 360 #pub-sub #library #events

  161. vm-pool-events

    Append-only event log with pub/sub and log streaming

    v0.1.0-alpha.1 #event-log #event-logging #pub-sub #events #streaming #event-streaming #tailing

  162. iceoryx2-services-discovery

    iceoryx2: discovery services

    v0.8.1 #ipc #zero-copy-ipc #pub-sub

  163. msg-transport

    Transports for msg-rs

    v0.1.6 #tls #distributed-systems #msg-rs #ipc #built #authentication #messaging-system #distributed-messaging #integration-tests #pub-sub

  164. nuts

    that offers a simple publish-subscribe API, featuring decoupled creation of the publisher and the subscriber

    v0.2.1 #pub-sub #events #global-data #simple-wasm

  165. evident

    Pub/Sub library using IDs to identify events

    v0.12.2 #pub-sub #events #identifying #subscriber #publisher

  166. rants

    An async NATS client library

    v0.6.0 450 #nats #pub-sub #client #pub-sub-messaging #nats-client

  167. tenvis-pulse-core

    Core types, traits, and message routing for Pulse

    v0.1.1 #presence #message-routing #pulse #pub-sub #broadcast-channel #message-channel #prometheus #lock-free-data-structures #zero-copy #messagepack

  168. iceoryx2-userland-record-and-replay

    iceoryx2: [internal] userland libraries on top of iceoryx2

    v0.8.1 #ipc #zero-copy-ipc #pub-sub

  169. salesforce_core_pubsubapi

    Generated Salesforce Pub/Sub API gRPC client (used by salesforce_core)

    v0.14.0 #pub-sub #sdk #salesforce-core #client #grpc-client #grpc-api

  170. mosquitto-rs

    An async MQTT client based on libmosquitto

    v0.11.2 160 #mqtt-client #libmosquitto #router #pub-sub #qos #vendored-openssl

  171. circulate

    Lightweight PubSub framework that supports both sync and async

    v0.5.0 250 #pub-sub #framework

  172. rustecal-types-serde

    JSON/CBOR/MessagePack type support for rustecal TypedPublisher/TypedSubscriber

    v0.1.5 470 #ipc #pub-sub #middleware #ecal #message-support

  173. mecha10-nodes-speaker

    Example speaker node for the Mecha10 robotics framework

    v0.1.39 #pub-sub #speaker #robotics #node #greeting #mecha10 #pub-sub-messaging

  174. photon-ring-metrics

    Metrics and observability wrappers for photon-ring pub/sub channels

    v2.5.0 #pub-sub #observability #ring-buffer #photon-ring #channel #mpmc #seq-lock #spmc #low-latency #ultra-low-latency

  175. mecha10-nodes-listener

    Example listener node for the Mecha10 robotics framework

    v0.1.39 #listener #node #robotics #greeting #mecha10 #pub-sub #pub-sub-messaging

  176. rustecal-types-protobuf

    Google Protobuf type support for rustecal TypedPublisher/TypedSubscriber

    v0.1.6 310 #pub-sub #ipc #middleware #ecal #message-support

  177. deliverust

    Easy to use and lightweight async pubsub context

    v0.1.0 #tokio #pub-sub #async

  178. obsidian-scheduler

    scheduling tasks with both callback and event-based timers

    v0.1.0 #task-scheduling #obsidian #callback #access-control #interval #thread-safe #pub-sub #event-based #tokio-time #arc

  179. rustecal-types-bytes

    Vec<u8> type support for rustecal TypedPublisher/TypedSubscriber

    v0.1.7 #pub-sub #ipc #middleware #ecal #message-support

  180. msg-wire

    Wire formats for msg-rs

    v0.1.6 #pub-sub #msg-rs #distributed-systems #compression #wire #authentication #distributed-messaging #messaging-system

  181. rustecal-types-string

    String type support for rustecal TypedPublisher/TypedSubscriber

    v0.1.5 #pub-sub #ipc #middleware #ecal #message-support

  182. iceoryx-rs

    Safe Rust bindings for Eclipse iceoryx - true zero-copy inter-process communication

    v0.1.0 #pub-sub #shared-memory #zero-copy

  183. tenvis-pulse-server

    High-performance realtime communication server

    v0.1.1 #prometheus #web-transport #real-time-communication #metrics #pub-sub #websocket-server #messagepack

  184. guts-realtime

    Real-time WebSocket support for Guts code collaboration platform

    v0.1.0 #real-time-collaboration #events #event-hub #notifications #subscription #guts #pub-sub #websocket #broadcasting #subscribed

  185. zenoh-bridge-remote-api

    Zenoh: The Zero Overhead Pub/Sub/Query Protocol

    v1.4.0 #zenoh #pub-sub #rest #zero-overhead #remote-api #typescript

  186. event-engine

    Framework for writing event-driven application utilizing a plugin architecture

    v0.2.0 #pub-sub #plugin #events #plugin-framework #serialization #zeromq #tcp-socket #event-based #event-driven-architecture #language-plugin

  187. agentic-comm

    Agent-to-agent and agent-to-human communication engine with channels, pub/sub, and message routing

    v0.1.0 #pub-sub #agentic #message-routing #binary-format #ai-agent #acomm #agent-communication #full-text-search #comm #model-context-protocol

  188. carrot-cake

    An a-peeling pub/sub framework

    v0.1.4 250 #amqp #pub-sub #rabbitmq #lapin

  189. wfe-valkey

    Valkey/Redis provider for distributed locking, queues, and lifecycle events in WFE

    v1.9.3 #lifecycle-events #valkey #queue #wfe #locking #distributed-lock #redis #pub-sub #life-cycle

  190. eventador

    lock-free pub/sub event-bus with sync and async APIs

    v0.0.18 #pub-sub #lock-free #events #disruptor #event-bus

  191. radixox-server

    RadixOx server - Redis-like data store

    v0.1.0 #radix-ox #pub-sub #prefix #store #server #redis #data-store #art #redis-like #valkey

  192. ncomm-publishers-and-subscribers

    NComm Publishers and Subscribers

    v1.1.4 430 #pub-sub #robotics #n-comm #middleware

  193. streamq-rs

    Official Rust SDK for the streamq message broker

    v0.1.0 #message-broker #pub-sub #websocket #sse

  194. svc-agent

    An agent library

    v0.21.0 550 #pub-sub #agent #mqtt #messaging-patterns

  195. zenoh-codec

    Internal crate for zenoh

    v1.9.0 145K #zenoh #pub-sub #embedded #query #robotics #public-api #warnings #edge-computing #distributed-systems #distributed-storage

  196. tenvis-pulse-transport

    Transport abstraction layer for Pulse (WebSocket, WebTransport)

    v0.1.1 #transport-abstraction-layer #websocket #web-transport #messagepack #pub-sub #real-time #prometheus

  197. zenoh-sync

    Internal crate for zenoh

    v1.9.0 144K #zenoh #pub-sub #version #query #protocols #robotics #public-api #warnings #zenoh-ext #distributed-storage

  198. karyon_eventemitter

    A lightweight, asynchronous event emitter for Rust

    v1.0.0-alpha.7 #pub-sub #dispatcher #async #events

  199. zenoh-buffers

    Internal crate for zenoh

    v1.9.0 144K #zenoh #buffer #robotics #warnings #deserialize #serialization #distributed-storage #edge-computing #pub-sub #ros2

  200. photon-ring-async

    Async wrappers for photon-ring pub/sub channels

    v2.5.0 #async-channel #pub-sub #photon-ring #wrapper #low-latency #waker #future-poll

  201. printnanny

    root package crate

    v0.22.0-rc.2 130 #package #root #monitoring #pub-sub #janus #mqtt #ansible #fact

  202. pubsub-rs

    powerful publish-subscribe (pubsub) system that allows multiple subscribers to receive messages published to specific topics. It is designed to be thread-safe, async-friendly, memory-efficient…

    v0.1.1 #async-channel #memory-efficient #subscriber #thread-safe #async-friendly #arc #publish-subscribe

    203. Try searching with DuckDuckGo.

  203. quarlus-events

    In-process typed event bus for Quarlus - publish/subscribe with async handlers

    v0.1.0 #pub-sub #events #async

  204. zenoh-protocol

    Internal crate for zenoh

    v1.9.0 133K #zenoh #protocols #rest #query #documentation #robotics #zenoh-ext #warnings #pub-sub #public-api

  205. mqttrs2

    Mqtt protocol encoding and decoding

    v0.1.0 #pub-sub #mqtt #codec

  206. zenoh-collections

    Internal crate for zenoh

    v1.9.0 133K #zenoh #stack #robotics #warnings #zenoh-ext #main-repository #edge-computing #public-api #pub-sub #ros2

  207. zenoh-stats

    Internal crate for zenoh

    v1.9.0 20K #zenoh #pub-sub #computation #query #storage #geo-distributed #cargo-run #distributed-systems #robotics

  208. zenoh-link-quic

    Internal crate for zenoh

    v1.9.0 121K #zenoh #pub-sub #space #query #robotics #public-api #warnings

  209. topic-stream

    Multi-topic publish-subscribe system in Rust with async support

    v0.1.2 240 #async-stream #pub-sub #broadcast

  210. elbus

    Local and network IPC bus

    v0.2.21 110 #pub-sub #ipc-bus #ipc

  211. libmsg

    A flexible and lightweight messaging library for distributed systems

    v0.1.6 #distributed-systems #messaging-system #distributed-messaging #built #flexible #pub-sub

  212. socketcluster_server

    SocketCluster protocol V1 server library

    v0.2.1 130 #websocket #pub-sub #socketcluster

  213. amqpsy

    Extremely opinionated AMQP PubSub library

    v0.1.0 350 #pub-sub #amqp #protobuf #publisher #opinionated #consumer-groups #chaos #distributed-tracing #fluent-interface #backward-compatibility

  214. zenoh-link-udp

    Internal crate for zenoh

    v1.9.0 125K #zenoh #distributed-systems #pub-sub #distributed-storage #robotics #public-api #warnings #edge-computing

  215. agentic-comm-ffi

    C-compatible FFI bindings for agentic-comm

    v0.1.0 #agentic-comm #c-compatible #message #pub-sub #store #acomm #model-context-protocol #nodejs

  216. zenoh-result

    Internal crate for zenoh

    v1.9.0 148K #zenoh #pub-sub #robotics #public-api #warnings #zenoh-ext #distributed-storage #edge-computing #main-repository #distributed-systems

  217. mercure

    A client implementation of the Mercure protocol

    v0.2.0 #pub-sub #event-source #sse #api-bindings

  218. cloud-pubsub

    Google Cloud PubSub Client

    v0.9.0 600 #google-cloud #pub-sub #google

  219. zenoh-router

    The zenoh router

    v0.5.0-beta.7 #zenoh #pub-sub #distributed-storage #stack #query #geo-distributed #zero-overhead

  220. zenoh-keyexpr

    Internal crate for zenoh

    v1.9.0 133K #zenoh #key-expression #ke #expression-parser #pub-sub

  221. mqcat

    CLI pub/sub client (supports zenoh/nats/mqtt/centrifuge)

    v0.3.0 #nats #zenoh #pub-sub #mqtt #pub-sub-client #centrifuge

  222. agp-datapath

    Core data plane functionality for AGP

    v0.7.0 1.4K #data-plane #agp #message-processing #pub-sub #datapath #message-encoder

  223. armature-events

    Event bus and pub/sub for Armature applications

    v0.1.0 #pub-sub #events #messaging

  224. zenoh-link

    Internal crate for zenoh

    v1.9.0 133K #zenoh #pub-sub #query #robotics #public-api #warnings #edge-computing #distributed-storage #main-repository #distributed-systems

  225. pub-sub-client

    Google Cloud Pub/Sub client library

    v0.12.0 #pub-sub #google-cloud #cloud-pub #message #client #pulled #deserialize #serde-json

  226. zenoh-link-unixsock_stream

    Internal crate for zenoh

    v1.9.0 120K #zenoh #pub-sub #robotics #query #public-api #warnings #distributed-storage #edge-computing #distributed-systems #main-repository

  227. zenoh-link-tcp

    Internal crate for zenoh

    v1.9.0 132K #zenoh #pub-sub #networking #robotics #public-api #warnings #distributed-systems #edge-computing #distributed-storage

  228. zenoh-link-ws

    Internal crate for zenoh

    v1.9.0 113K #zenoh #pub-sub #depend #embedded #query #robotics #public-api #warnings #edge-computing #distributed-storage

  229. redis-kiss

    A really stupid approach to managing Redis PubSub

    v0.1.4 1.0K #pub-sub #redis #kiss #connection #stupid #connection-pool

  230. subliminal

    Base crate for subliminal microservices project

    v0.0.4 #task-execution #task-manager #google-cloud #pub-sub #microservices #google-cloud-storage #google-cloud-api #executor-service #message-queue #database