A swiss army knife CLI tool for interacting with Kafka, RabbitMQ and other messaging systems.

Lightweight eventbus for golang

An easy way to bootstrap your application with batteries included.

An in-process and in-memory PubSub, Broadcast, EventBus or Fanout implementation with type-safe topics implemented with generics. Respects context.

A distributed system built in Golang that uses the RabbitMQ's exchanges for communicating data and messages between various consumer applications that consume the data published by the various generators. The data is coordinated by a coordinator program that can be scaled up easily depending upon the traffic. These coordinators use an event-base…

A simple event bus for Go

✉️ Streams is a toolkit crafted for data-in-motion ecosystems written in Go.

EventBus, QueryBus, CommandBus, Saga

A lightweight internal Publish/Subscribe (Pub/Sub) system written in Go.

The globalevents package provides a simple and efficient mechanism for working with global events in an application. It is based on the EventBus library and implements the Publisher-Subscriber pattern.

Сервис подписок, работающий по gRPC, основанный на шине событий по принципу Publisher-Subscriber

Simple event bus written in go

Collect events from a SQLite database, create message from a protobuf schema definition and publish events to a Kafka topic.

Simple bus library

Description and payloads for common events.

gRPC-based event subscription service.

Event bus for Go

Golang event bus with simplicity in mind.

Implementation of the REST API for Effective Mobile

A generic, thread-safe, high-performance event bus for Go