54 Resources
Golang pubsub Libraries
A gRPC based pub/sub messaging system
Arrebato Arrebato is a gRPC based pub/sub messaging system with an emphasis on strong message typing & message verification using public-key cryptogra
CLI tool for generating random messages with rules & publishing to the cloud services (SQS,SNS,PUB/SUB and etc.)
Randomsg A CLI tool to generate random messages and publish to cloud services like (SQS,SNS,PUB/SUB and etc.). TODO Generation of nested objects is no
A lightweight event collection system.
Honeypot A self-contained, multi-protocol streaming event collection system with ambitions to be as boring as benthos. Honeypot is primarily built for
CQRS & Event-Sourcing Framework for Go.
goes - Event-Sourcing Framework goes is a collection of interfaces, tools, and backend implementations that allow you to write event-sourced applicati
Pubsub-go - Go-redis pubsub with websocket
go-redis pubsub with websocket # start a local dev server $ make dev
ZeroMQ core engine in C++, implements ZMTP/3.1
ZeroMQ Welcome The ZeroMQ lightweight messaging kernel is a library which extends the standard socket interfaces with features traditionally provided
Libp2p chat with discovery and pubsub
Dicovery - pubsub chat with libp2p How to test Run boostrap node $ go run main/main.go --port 35005 --nick boot --pk XDLjuaVJ2yKQ2zHMmsee5PGHtDHmkkvFA
Monad, Functional Programming features for Golang
fpGo Monad, Functional Programming features for Golang Active Branches: For Generics version(=go1.18):generics For NonGenerics version(=go1.17):non-
Pubsub - A simple pubsub package for go.
Package pubsub implements a simple multi-topic pub-sub library. Install pubsub with, go get github.com/cskr/pubsub This repository is a go module and
Simple-messaging - Brokerless messaging. Pub/Sub. Producer/Consumer. Pure Go. No C.
Simple Messaging Simple messaging for pub/sub and producer/consumer. Pure Go! Usage Request-Response Producer: consumerAddr, err := net.ResolveTCPAddr
Parked: PubSub queuing with long-polling subscribers (not bound to http)
Parked: PubSub with long polling in Go The package longpoll provides an implementation of the long-polling mechanism of the PubSub pattern. Although t
Publish and subscribe functionality within a single process in Go.
pubsub import "github.com/juju/pubsub/v2" Package pubsub provides publish and subscribe functionality within a single process. A message as far as a
Dapr SDK for go
Dapr SDK for Go Client library to help you build Dapr application in Go. This client supports all public Dapr APIs while focusing on idiomatic Go expe
Dead simple and performant message broadcaster (pubsub) for Go
caster caster is a dead simple and performant message broadcaster for Go with context support. It uses the publisher and subscriber pattern (pubsub) t
Sample program of GCP pub/sub client with REST API
GCP pub/sub sample using REST API in Go GCP pub/sub publisher and subscriber sample programs. These use REST API and don't use pub/sub client library
Nonblocking broadcast chan for golang
broadcast_linkedlist nonblocking broadcast chan 利用close(chan)的特性,来实现广播效果 example
Google pub/sub service easy way to use
easy pubsub Installation go get github.com/buraksecer/go-easy-pubsub v0.0.2 Example Firstly, you must Init new topic operation. topic.Init(clientId)
rpipe relays message between child process and redis pubsub channel.
rpipe rpipe relays message between child process and redis pubsub channel. rpipe subscribes Redis channel named HOSTNAME. rpipe spawns child process a
High performance, distributed and low latency publish-subscribe platform.
Emitter: Distributed Publish-Subscribe Platform Emitter is a distributed, scalable and fault-tolerant publish-subscribe platform built with MQTT proto
Automatically stop GCE instances
auto-stop-gce-instances Architecture How to deploy 1. Deploy Pub/Sub $ gcloud pubsub topics create $PUBSUB_NAME 2. Deploy Cloud Functions $ gcloud fu
This is a small API that provides basic REST endpoints to shorten a URL
This is a small API that provides basic REST endpoints to shorten a URL, get information about the URL, update the URL, and get statistics on most accessed URLs.
xyz, is a tool for automating actions based on events from various sources used by streamers.
Streaming Automation Software Support · Download · Report Bug · Request Feature What is xyz? xyz, is a tool for automating actions based on events fro
Just a PubSub Websocket Server
Eventual Agent Just a PubSub Websocket Server The eventual agent allows cluster local apps to subscribe and publish over network. Goals Provide a WebS
a quick golang implementation of google pubsub subscriber for testing with the emulator.
gosub a quick golang implementation of google pubsub subscriber for testing with the emulator. it does one thing which is subscribing to a topic and r
The server-pubsub is the main backend of DATAVOC project that manages all the other web-server modules of the same project such as the processor
server-pubsub The server-pubsub is the main backend of DATAVOC project that manages all the other web-server modules of the same project such as the p
Fulfills a GitHub workflow_job webhooks into a Pub/Sub queue.
GitHub Workflow Job to Pub/Sub The GitHub Workflow Job to Pub/Sub is a small service that fulfills a GitHub workflow_job webhook. When a job is queued
Real-time messaging library for Go with scalability in mind.
This library has no v1 release, API still evolves. Use with strict versioning. Before v1 release patch version updates only have backwards compatible
pubsub controller using kafka and base on sarama. Easy controll flow for actions streamming, event driven.
Psub helper for create system using kafka to streaming and events driven base. Install go get github.com/teng231/psub have 3 env variables for config
Distributed cache and in-memory key/value data store.
Distributed cache and in-memory key/value data store. It can be used both as an embedded Go library and as a language-independent service.
RPC over libp2p pubsub with error handling
go-libp2p-pubsub-rpc RPC over libp2p pubsub with error handling Table of Contents Background Install Usage Contributing Changelog License Background g
This is a Pub/Sub for the Watermill project which uses the Bolt database.
Watermill Bolt Pub/Sub This is a Pub/Sub for the Watermill project which uses the Bolt database.
decentralized kv store based on pubsub in libp2p
pointers decentralized kv store based on pubsub in libp2p Protocol Specification Over View The pointer would receive updates from pubsub network and b
Graphik is a Backend as a Service implemented as an identity-aware document & graph database with support for gRPC and graphQL
Graphik is a Backend as a Service implemented as an identity-aware, permissioned, persistant document/graph database & pubsub server written in Go.
Apache Pulsar Go Client Library
Apache Pulsar Go Client Library A Go client library for the Apache Pulsar project. Goal This projects is developing a pure-Go client library for Pulsa
A Microservice Toolkit from The New York Times
Gizmo Microservice Toolkit This toolkit provides packages to put together server and pubsub daemons with the following features: Standardized configur
Simple, high-performance event streaming broker
Styx Styx is a simple and high-performance event streaming broker. It aims to provide teams of all sizes with a simple to operate, disk-persisted publ
Easily generate gRPC services in Go ⚡️
Lile is a application generator (think create-react-app, rails new or django startproject) for gRPC services in Go and a set of tools/libraries. The p
Collection of personal Dapr demos (bindings, state, pub/sub, service-to-service invocation)
Dapr demos Collection of personal Dapr demos. Note, some of these demos require latest version of Dapr, Ingress gateway, Observability components, or
Async management of servers, containers, workstations...basically anything that runs an operating system.
steward What is it ? Command And Control anything asynchronously. Send shell commands to control your servers by passing a message that will have guar
Dapr is a portable, event-driven, runtime for building distributed applications across cloud and edge.
Dapr is a portable, serverless, event-driven runtime that makes it easy for developers to build resilient, stateless and stateful microservices that run on the cloud and edge and embraces the diversity of languages and developer frameworks.
A Microservice Toolkit from The New York Times
Gizmo Microservice Toolkit This toolkit provides packages to put together server and pubsub daemons with the following features: Standardized configur
Kiara is a Go equivalent of Phoenix PubSub that makes it easy for Go applications to communicate with each other.
Kiara is a Go equivalent of Phoenix PubSub that makes it easy for Go applications to communicate with each other. Examples Basic Usage Custom Co
Google Cloud Client Libraries for Go.
Google Cloud Client Libraries for Go Go packages for Google Cloud Platform services. import "cloud.google.com/go" To install the packages on your syst
A simple pubsub package for go.
Package pubsub implements a simple multi-topic pub-sub library. Install pubsub with, go get github.com/cskr/pubsub This repository is a go module and
Go simple async message bus
🚌 message-bus Go simple async message bus. 📖 ABOUT Contributors: Rafał Lorenz Want to contribute ? Feel free to send pull requests! Have problems, b
mangos is a pure Golang implementation of nanomsg's "Scalablilty Protocols"
mangos Mangos™ is an implementation in pure Go of the SP (“Scalability Protocols”) messaging system. These are colloquially known as a “nanomsg”. ❗ Th
:incoming_envelope: A fast Message/Event Hub using publish/subscribe pattern with support for topics like* rabbitMQ exchanges for Go applications
Hub 📨 A fast enough Event Hub for go applications using publish/subscribe with support patterns on topics like rabbitMQ exchanges. Table of Contents
🔊Minimalist message bus implementation for internal communication
🔊 Bus Bus is a minimalist event/message bus implementation for internal communication. It is heavily inspired from my event_bus package for Elixir la
💨 A real time messaging system to build a scalable in-app notifications, multiplayer games, chat apps in web and mobile apps.
Beaver A Real Time Messaging Server. Beaver is a real-time messaging server. With beaver you can easily build scalable in-app notifications, realtime
A Microservice Toolkit from The New York Times
Gizmo Microservice Toolkit This toolkit provides packages to put together server and pubsub daemons with the following features: Standardized configur
Lightweight, fault-tolerant message streams.
Liftbridge provides lightweight, fault-tolerant message streams by implementing a durable stream augmentation for the NATS messaging system. It extend
High performance, distributed and low latency publish-subscribe platform.
Emitter: Distributed Publish-Subscribe Platform Emitter is a distributed, scalable and fault-tolerant publish-subscribe platform built with MQTT proto
Distributed cache and in-memory key/value data store. It can be used both as an embedded Go library and as a language-independent service.
Olric Distributed cache and in-memory key/value data store. It can be used both as an embedded Go library and as a language-independent service. With