#Pubsub

Showing 53 of 53 repositories tagged #pubsub, ranked by stars

binwiederhier
binwiederhier
ntfy

Send push notifications to your phone or desktop using PUT/POST

Score
100
β˜… 31.6k β‘‚ 1.4k +373/day
Go
dapr
dapr
dapr

Dapr is a portable runtime for building distributed applications across cloud and edge, combining event-driven architecture with workflow orchestration.

Score
95
β˜… 25.9k β‘‚ 2.1k +4/day
Go
centrifugal
centrifugal
centrifugo

Scalable real-time messaging server in a language-agnostic way. Self-hosted alternative to Pubnub, Pusher, Ably, socket.io, Phoenix.PubSub, SignalR. Set up once and forever.

Score
90
β˜… 10.5k β‘‚ 715 +12/day
Go
uNetworking
uNetworking
uWebSockets.js

ΞΌWebSockets for Node.js back-ends :metal:

Score
100
β˜… 9.1k β‘‚ 627 β€”
C++
deepstreamIO
deepstreamIO
deepstream.io

deepstream.io server

Score
75
β˜… 7.2k β‘‚ 384 β€”
TypeScript
SocketCluster
SocketCluster
socketcluster

Highly scalable realtime pub/sub and RPC framework

Score
100
β˜… 6.2k β‘‚ 321 β€”
JavaScript
permitio
permitio
opal

Policy and data administration, distribution, and real-time updates on top of Policy Agents (OPA, Cedar, ...)

Score
100
β˜… 5.5k β‘‚ 286 β€”
Python
emitter-io
emitter-io
emitter

High performance, distributed and low latency publish-subscribe platform.

Score
86
β˜… 4.0k β‘‚ 359 β€”
Go
nytimes
nytimes
gizmo

A Microservice Toolkit from The New York Times

Score
76
β˜… 3.8k β‘‚ 225 β€”
Go
svix
svix
svix-webhooks

The open source and enterprise-ready webhooks service πŸ¦€

Score
100
β˜… 3.3k β‘‚ 258 +5/day
Rust
liftbridge-io
liftbridge-io
liftbridge

Kafka-style message streaming in Go. Built on NATS. Single binary, no JVM, no ZooKeeper.

Score
81
β˜… 2.8k β‘‚ 118 +1/day
Go
eclipse-iceoryx
eclipse-iceoryx
iceoryx2

Eclipse iceoryx2β„’ - the zero-copy data plane with a Rust core

Score
50
β˜… 2.4k β‘‚ 163 +1/day
Rust
apache
apache
eventmesh

EventMesh is a new generation serverless event middleware for building distributed event-driven applications.

Score
93
β˜… 1.7k β‘‚ 651 β€”
Java
cirospaciari
cirospaciari
socketify.py

Bringing Http/Https and WebSockets High Performance servers for PyPy3 and Python3

Score
0
β˜… 1.7k β‘‚ 62 +1/day
Python
serverless
serverless
event-gateway

React to any event with serverless functions across clouds

Score
43
β˜… 1.6k β‘‚ 97 β€”
Go
lileio
lileio
lile

Easily generate gRPC services in Go ⚑️

Score
38
β˜… 1.5k β‘‚ 85 β€”
Go
centrifugal
centrifugal
centrifuge

Real-time messaging library for Go. The simplest way to add feature-rich and scalable WebSocket support to your application. The core of Centrifugo server.

Score
71
β˜… 1.4k β‘‚ 118 +4/day
Go
joshnuss
joshnuss
svelte-persisted-store

A Svelte store that persists to localStorage

Score
50
β˜… 1.2k β‘‚ 39 +1/day
TypeScript
rmqtt
rmqtt
rmqtt

MQTT Server/MQTT Broker - Scalable Distributed MQTT Message Broker for IoT in the 5G Era

Score
0
β˜… 975 β‘‚ 120 +2/day
Rust
mosn
mosn
layotto

A fast and efficient cloud native application runtime

Score
62
β˜… 852 β‘‚ 174 β€”
Go
hemerajs
hemerajs
hemera

πŸ”¬ Writing reliable & fault-tolerant microservices in Node.js https://hemerajs.github.io/hemera/

Score
71
β˜… 808 β‘‚ 68 β€”
JavaScript
valkey-io
valkey-io
valkey-glide

An open source Valkey client library that supports Valkey, and Redis open source 6.2, 7.0 and 7.2. Valkey GLIDE is designed for reliability, optimized performance, and high-availability, for Valkey and Redis OSS based applications. GLIDE is a multi language client library, written in Rust with programming language bindings, such as Java and Python

Score
57
β˜… 760 β‘‚ 165 β€”
Java
nanomsg
nanomsg
mangos

mangos is a pure Golang implementation of nanomsg's "Scalablilty Protocols"

Score
52
β˜… 757 β‘‚ 82 +1/day
Go
apache
apache
pulsar-client-go

Apache Pulsar Go Client Library

Score
67
β˜… 742 β‘‚ 381 β€”
Go
jcuga
jcuga
golongpoll

golang long polling library. Makes web pub-sub easy via HTTP long-poll servers and clients :smiley: :coffee: :computer:

Score
33
β˜… 668 β‘‚ 61 β€”
Go
kubemq-io
kubemq-io
kubemq-community

KubeMQ is a Kubernetes native message queue broker

Score
29
β˜… 666 β‘‚ 46 β€”
Go
andywer
andywer
pg-listen

πŸ“‘ PostgreSQL LISTEN & NOTIFY for node.js that finally works.

Score
25
β˜… 634 β‘‚ 35 β€”
TypeScript
nats-io
nats-io
nats-operator

NATS Operator for Kubernetes (deprecated)

Score
64
β˜… 568 β‘‚ 110 β€”
Go
EchoVault
EchoVault
SugarDB

Embeddable and distributed in-memory alternative to Redis.

Score
24
β˜… 540 β‘‚ 46 +1/day
Go
alash3al
alash3al
wsify

A very simple general purpose websocket server that does the job

Score
19
β˜… 525 β‘‚ 53 β€”
Go
cskr
cskr
pubsub

A simple pubsub package for go.

Score
14
β˜… 454 β‘‚ 63 β€”
Go
elsoul
elsoul
souls

🚧Deprecated. Evolved to SLV https://slv.dev/ πŸš§πŸ•Ί SOULs πŸ’ƒ Build Serverless Apps faster like Rails. Powered by Ruby GraphQL, Active Record, RSpec, RuboCop, and Google Cloud.

Score
57
β˜… 330 β‘‚ 3 β€”
Ruby
thisistonydang
thisistonydang
liveview-svelte-pwa

Local-First LiveView Svelte ToDo App

Score
0
β˜… 298 β‘‚ 32 β€”
Elixir
jandelgado
jandelgado
rabtap

RabbitMQ wire tap and swiss army knife

Score
48
β˜… 285 β‘‚ 18 +1/day
Go
apache
apache
pulsar-helm-chart

Official Apache Pulsar Helm Chart

Score
86
β˜… 238 β‘‚ 259 β€”
Shell
GoogleCloudPlatform
GoogleCloudPlatform
df-ml-anomaly-detection

Streaming Anomaly Detection Solution by using Pub/Sub, Dataflow, BQML & Cloud DLP

Score
0
β˜… 192 β‘‚ 49 β€”
Java
funkygao
funkygao
gafka

A full ecosystem that is built around kafka powered by golang

Score
0
β˜… 100 β‘‚ 20 β€”
Go
dhanushkamath
dhanushkamath
Burgernaut

A distributed message-based food ordering system developed with RabbitMQ, Node.js, Express and MongoDB

Score
21
β˜… 99 β‘‚ 37 β€”
JavaScript
streamnative
streamnative
charts

StreamNative Helm Charts Repository: Apache Pulsar, Pulsar Operators, StreamNative Platform, Function Mesh

Score
79
β˜… 80 β‘‚ 69 β€”
Go Template
liftbridge-io
liftbridge-io
go-liftbridge

Go client for Liftbridge. https://github.com/liftbridge-io/liftbridge

Score
10
β˜… 73 β‘‚ 19 β€”
Go
Atheer-Ganayem
Atheer-Ganayem
SnapWS

Minimal WebSocket library for Go.

Score
5
β˜… 71 β‘‚ 0 β€”
Go
TheAlphamerc
TheAlphamerc
empty_widget

Custom_Empty widget is flutter plugin which is designed to notify user about some event.

Score
0
β˜… 71 β‘‚ 34 β€”
Dart
google
google
grizzly

End-to-end DataOps platform deployed by Terraform.

Score
14
β˜… 69 β‘‚ 11 β€”
Python
streamr-dev
streamr-dev
core-api

Old Corea-milestone centralized backend now obsolete as everything is decentralized.

Score
100
β˜… 50 β‘‚ 9 β€”
Groovy
eolszewski
eolszewski
ipfs-pubsub-chatroom

Simple IPFS Pubsub chatroom built on React

Score
0
β˜… 47 β‘‚ 2 β€”
JavaScript
GoogleCloudPlatform
GoogleCloudPlatform
market-data-transcoder

ffmpeg for market data

Score
0
β˜… 46 β‘‚ 7 β€”
Python
jay-johnson
jay-johnson
celery-connectors

Want to handle 100,000 messages in 90 seconds? Celery and Kombu are that awesome - Multiple publisher-subscriber demos for processing json or pickled messages from Redis, RabbitMQ or AWS SQS. Includes Kombu message processors using native Producer and Consumer classes as well as ConsumerProducerMixin workers for relay publish-hook or caching

Score
7
β˜… 40 β‘‚ 7 β€”
Python
NucleusEngineering
NucleusEngineering
hack-your-pipe

Efficient streaming data ingestion, transformation & activation

Score
0
β˜… 28 β‘‚ 3 β€”
Python
apache
apache
eventmesh-dashboard

Apache EventMesh Dashboard

Score
50
β˜… 24 β‘‚ 21 β€”
Java
MohamedAYassin
MohamedAYassin
PeerLink

PeerLink is a high-performance distributed file sharing platform built for scale. It uses a microservices architecture, native C++ acceleration, and real-time cluster communication to transfer data across nodes with low latency, fault tolerance, and automatic load balancing.

Score
43
β˜… 22 β‘‚ 0 β€”
TypeScript
freepik-company
freepik-company
binwatch

BinWatch is a tool to subscribe to a MySQL binlog and track changes that occur in database tables. These changes are processed and sent to supported connectors in real-time.

Score
29
β˜… 20 β‘‚ 1 β€”
Go
liftbridge-io
liftbridge-io
liftbridge-api

Protobuf definitions for the Liftbridge gRPC API. https://github.com/liftbridge-io/liftbridge

Score
36
β˜… 15 β‘‚ 14 β€”
Python
dgzlopes
dgzlopes
python-liftbridge

WIP: Python client for Liftbridge.

Score
0
β˜… 10 β‘‚ 5 β€”
Python
Related Topics
#golang#messaging#go#cloud-native#websocket#streaming#realtime#kubernetes#grpc#redis#nats#event-driven

Β© 2026 GitRepoTrend Β· GitHub repositories by topic Β· Updated weekly