121 Resources
Golang message-broker Libraries
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 Go script that makes your GitHub contribution activity panel look awesome! Display a message !
GitHub contributions generator A script written in Go, which goal is to make your GitHub contributions graph the way you want it to be. The goal of th
Priority queue with message-group based partitioning and equal attention guarantee for each message group based on Redis
redis-ordered-queue-go Priority queue with message-group based partitioning and equal attention guarantee for each message group based on Redis What i
Msg is gRPC-based backend for messaging written in golang.
Msg Msg is gRPC-based backend for messaging written in golang. Goals Future goals: Implement message service which will allow users to send messages t
go-actor is a lightweight message framework using actor model
go-actor go-actor is a lightweight message framework using actor model 初衷 想能在代码逻辑上方便的写无锁的同步rpc调用代码,同时又不会阻塞住其他服务对这个Actor的调用 一个Actor可以有多种身份,想能比较方便的分类管理A
Linter for Go's fmt.Errorf message
wrapmsg wrapmsg is Go code linter. this enforces fmt.Errorf's message when you wrap error. Example // OK 👍🏻 if err := pkg.Cause(); err != nil { re
go broker interface,you can use kafka,redis,pulsar etc.
broker go broker interface,you can use kafka,redis,pulsar etc. pulsar in docker run pulsar in docker docker run -dit \ --name pulsar-sever \ -p 6650:
Messagebus - Simple Message Bus Written in Golang
MessageBus Simple Message Bus Written in Golang How to Use go get gopkg.io/Usada
Totsugen - Generate emphasis message with golang
totsugen Requirements Go 1.17+ Run $ go run main.go -value {value} # ex: go run
Git-now-playing - Git commits are the new AIM status messages
git-now-playing git-now-playing is an attempt to bring some of the panache of th
Smq - Simple MQTT Broker with golang
Simple MQTT Broker 关于 Golang MQTT Broker, Version 3.1.1, and Compatible for ecli
Go-snake - Go CLI implementation of Snake game, using channels
go-snake 🐍 Go CLI implementation of Snake game, using channels. NB: this code w
Auto send check-in message to Slack channel at a specific time.
Auto Slack Check-in auto-slack-checkin is a command line interface (CLI) that sends check-in or check-out message for you while you are sleeping 🛌.
Fetch gas stations prices from Tankerkönig api with Orion Context Broker persistence
tankerkoenig-fuel-machinery - Fetch gas stations from tankerkoenig api and persist them into an Orion Context Broker Scope This project aims to fetch
An out-of-the-box cryptographic message communication.
An out-of-the-box cryptographic message communication.
Go-commitlinter - simple commit message linter
go-commitlinter go-commitlinter is simple commit message linter. Quick Start go
A Multi Consumer per Message Queue with persistence and Queue Stages.
CrimsonQ A Multi Consumer per Message Queue with persistence and Queue Stages. Under Active Development Crimson Queue allows you to have multiple cons
Compute and print message digest hash values from stdin.
Compute and print message digest hash values from stdin.
Tradingview-2-exchange - Place buy/sell orders in exchange(binance) when trading view strategy raise alert message
TradingView-2-Exchange This application is used to place a buy/sell order in Bin
A CLI to replace your git commit command, so your git message can partially follow the Conventional Changelog ecosystem
COMMIT CLI A CLI to replace your git commit command, so your git message can partially follow the Conventional Changelog ecosystem. And yes, it is bui
Read metrics from a Message Queue in Json format and expose them in a Prometheus compatible format
mq2prom Read metrics from a Message Queue in Json format and expose them in a Prometheus compatible format. Currently only works for MQTT compatible M
Speaker command reads aloud the text message. It supports multilingual voice reading
speaker - Read the text aloud speaker command reads aloud the text message. It supports multilingual voice reading. If you want the time signal, the s
Streamhub: a toolkit crafted for streaming-powered applications written in Go
✉️ Streamhub Streamhub is a toolkit crafted for streaming-powered applications w
TiDB Mesh: Implement Multi-Tenant Keyspace by Decorating Message between Components
TiDB Mesh: Implement Multi-Tenant Keyspace by Decorating Message between Compone
Freebase - Proof of concept microservice for A2S INFO message caching
Freebase A sensible albeit primitive A2S_INFO cache service written in Go. Proof
Toolkit - Collection of useful patterns
toolkit Introduction These patterns can you use to solve common problems when designing an application or system. Requirements golang =1.11.x - The G
NotifyTool - A message forwarding service for http to websocket
notifyTool this is a message forwarding service for http to websocket task webso
Mcopa - A library allows for parsing an email message into a more convenient form than the net/mail provides
Mail content parsing This library allows for parsing an email message into a mor
Alertmanager go message broker - A simple message broker made to integrate with alertmanager/prometheus
Alertmanager message broker Prerequisites Go 1.16+ Sqllite driver About: The alertmanager message broker is a project made to meet some of my needs to
Peer-to-peer encrypted message exchange
Constellation Constellation is a self-managing, peer-to-peer system in which each node: Hosts a number of NaCl (Curve25519) public/private key pairs.
A simple, secure self-destructing message service, using HashiCorp Vault product as a backend
sup3rS3cretMes5age! A simple, secure self-destructing message service, using Has
A simple Slack message tool for the CLI written in Go
heka A simple Slack message tool for the CLI written in Go Report Bug · Request
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
Provide cloud-edge message synergy solutions for companies and individuals.the cloud-edge message system based on NATS.
Swarm This project is a cloud-edge synergy solution based on NATS. quikly deploy cloud deploy on k8s #pull the project. git clone https://github.com/g
Industrial IoT Messaging and Device Management Platform
Mainflux Mainflux is modern, scalable, secure, open-source, and patent-free IoT cloud platform written in Go. It accepts user and thing (sensor, actua
Simple docker container to publish a fixed message to a specified queue. Created to be used with k8s CRON scheduling.
RabbitMQ Publish CRON Simple docker container to publish a fixed message to a specified rabbitmq exchange. Created to be used as part of a Kubernetes
A demonstration of the transactional outbox messaging pattern (+ Log Trailing) with Amazon DynamoDB (+ Streams) written in Go
🎇 Gluon A composable message bus for Event-Driven systems written in Go.
Message relay written in golang for PostgreSQL and Apache Kafka
Message Relay Message relay written in golang for PostgreSQL and Apache Kafka Requirements Docker and Docker Compose Local installation and using dock
A swiss army knife CLI tool for interacting with Kafka, RabbitMQ and other messaging systems.
plumber is a CLI devtool for inspecting, piping, massaging and redirecting data in message systems like Kafka, RabbitMQ , GCP PubSub and many more. [1
MQTT Datasource for Grafana allows streaming data from any MQTT broker running either locally or remotely.
MQTT data source for Grafana The MQTT data source plugin allows you to visualize streaming MQTT data from within Grafana. This datasource is under act
gRPC service - Golang School Project
Задание 2 Создать репозиторий именование которого указано в таблице прогресса Описать сущность {domain}.{Subdomain} и {domain}.{Subdomain}Event в inte
Tool for collect statistics from AMQP (RabbitMQ) broker. Good for cloud native service calculation.
amqp-statisticator Tool for collect statistics around your AMQP broker. For example RabbitMQ expose a lot information trought the management API, but
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
Basic implementation of WhatsApp message counter by participant.
Whatsapp Group Message Counter This is a learning project to get familiar with some topics related to Golang. make sure to have your exported file on
Use pingser to create client and server based on ICMP Protocol to send and receive custom message content.
pingser Use pingser to create client and server based on ICMP Protocol to send and receive custom message content. examples source code: ./examples Us
go - Kafka protobuf message producer
Kafka prtobuf message producer This project is used to produce protobuf messages message to given kafka topic UseCase Integration testing Debugging Mo
Connect, Subscribe and Publish over MQTT broker to check its status.
MQTT Blackbox Exporter Introduction In each probe it sends a message over MQTT broker and then wait for getting it over subscription. By measuring thi
Discord bot to check if a URL attached on a message is part of the verified list
OCM URL Verify Bot Checks the url included in a discord message. Displays a verified status when the domain of the url attached is in the verified-dom
KubeMQ is a Kubernetes native message queue broker
KubeMQ Community is the open-source version of KubeMQ, the Kubernetes native message broker. More about KubeMQ
Encode and decode binary message and file formats in Go
Encode and Decode Binary Formats in Go This module wraps the package encoding/binary of the Go standard library and provides the missing Marshal() and
A message based command library for DiscordGo
A simple message command library for DiscordGo, inspired by discord.py.
A lightweight, distributed and reliable message queue based on Redis
nmq A lightweight, distributed and reliable message queue based on Redis Get Started Download go get github.com/inuggets/nmq Usage import "github.com
Go server for STOMP message protocol
Stomper A Go message queue implementing the STOMP protocol. Done Frame parsing TODO Server connection protocol Define interface for queueing Implement
Zenvia API - Golang SDK
Zenvia API - Golang SDK Zenvia API (2.0) Why? This project is part of my personal portfolio, so, I'll be happy if you could provide me any feedback ab
A great util to format you git commit message!
A great util to format you git commit message!
Command Line Tool for decrypting armored pgp messages
Decrypt-PGP-Message A simple command line tool for decrypting armored pgp messages How to build? make build How to use? Usage: -key=path to your pr
github-actions-merger is github actions that merges pull request with commit message including pull request labels.
github-actions-merger github-actions-merger is github actions that merges pull request with commit message including pull request labels. Usage Write
stratus is a cross-cloud identity broker that allows workloads with an identity issued by one cloud provider to exchange this identity for a workload identity issued by another cloud provider.
stratus stratus is a cross-cloud identity broker that allows workloads with an identity issued by one cloud provider to exchange this identity for a w
Backend for Ribbit, Broker API Reference App
Ribbit Reference Implementation (Backend) The reference implementation for the backend of a broker-dealer trading application with the Alpaca Broker A
Distributed Lab 3: Message Broker in Go
Distributed Lab 3: Message Broker in Go Using the lab sheet There are two ways to use the lab sheet, you can either: create a new repo from this templ
ChizBroker is a fast and simple GRPC based implementation of kafka.
Chiz Broker: a broker for fun ChizBroker is a fast and simple GRPC based implementation of kafka. Features: Ready to be deployed on kubernetes Prometh
Simple golang script for getting VK message statistics
vk-message-counter Simple golang script for getting VK message statistics Example package main import ( "fmt" "github.com/joho/godotenv" counter "
HSDP Metrics alerts webhook broker and CF events forwarder for Microsoft Teams
hsdp-events Microservice helper to translate HSDP Metrics webhooks to Microsoft Teams webhooks Configuration Environment Description EVENTS_TOKEN Rand
Testing message queues with RabbitMQ
Rabbit-MessageQueue Just a repository of RabbitMQ simple usage for queueing messages. You can use this as a sender or a receiver. More information is
A markov chain for Discord message dumps using https://github.com/fr3fou/polo
discord-markov-chain A markov chain for Discord message dumps using https://github.com/fr3fou/polo Download If you have a go installed, just clone the
Prometheus Common Data Exporter can parse JSON, XML, yaml or other format data from various sources (such as HTTP response message, local file, TCP response message and UDP response message) into Prometheus metric data.
Prometheus Common Data Exporter Prometheus Common Data Exporter 用于将多种来源(如http响应报文、本地文件、TCP响应报文、UDP响应报文)的Json、xml、yaml或其它格式的数据，解析为Prometheus metric数据。
An embeddable lightweight Go/Golang MQTT broker(server) for IoT.
Snple MQTT 简体中文 Note: The API of this library is still unstable and has not been sufficiently tested, please do not use it in production environments.
Golang module/tool for decoding proto buffer without message definition.
Golang module/tool for decoding proto buffer without message definition.
A script written to automatically send whatsapp messages
whatsapp-auto-message A script written to automatically send whatsapp messages Config Dosyasını Ayarlama { "numbers": "phone_numbers.txt", "sleep": 2,
GopherSay allow you to display a message said by a cute random Gopher.
GopherSay About Welcome in GopherSay! GopherSay is inspired by Cowsay program. GopherSay allow you to display a message said by a cute random Gopher.
Encode and Decode Message Length Indicators for TCP/IP socket based protocols
SimpleMLI A Message Length Indicator Encoder/Decoder Message Length Indicators (MLI) are commonly used in communications over raw TCP/IP sockets. This
command-line tool to publish, subscribe, and process messages for AMQP 0.9.1 compliant message brokers
Bunny A BSD licenced, go-powered CLI tool for publishing and subscribing to RabbitMQ
🐺 Deploy Databases and Services Easily for Development and Testing Pipelines.
Peanut provides an API and a command line tool to deploy and configure the commonly used services like databases, message brokers, graphing tools ... etc. It perfectly suited for development, manual testing, automated testing pipelines where mocking is not possible and test drives.
Sandglass is a distributed, horizontally scalable, persistent, time sorted message queue.
Sandglass is a distributed, horizontally scalable, persistent, time ordered message queue. It was developed to support asynchronous tasks and message
A realtime distributed messaging platform
Source: https://github.com/nsqio/nsq Issues: https://github.com/nsqio/nsq/issues Mailing List: [email protected] IRC: #nsq on freenode Docs:
The Xiaomi message push service is a system-level channel on MIUI and is universal across the platform, which can provide developers with stable, reliable, and efficient push services.
Go-Push-API MiPush、JiPush、UMeng MiPush The Xiaomi message push service is a system-level channel on MIUI and is universal across the platform, which c
Flexible message router add-on for go-telegram-bot-api library.
telemux Flexible message router add-on for go-telegram-bot-api library. Table of contents Motivation Features Minimal example Documentation Changelog
GTA(Go Task Async) is a lightweight reliable asynchronous task and transaction message library for Golang
GTA (Go Task Async) is a lightweight and reliable asynchronous task and transaction message library for by golang.
Chanify is a safe and simple notification tools. This repository is command line tools for Chanify.
Chanify is a safe and simple notification tools. For developers, system administrators, and everyone can push notifications with API.
Inspr is an application mesh for simple, fast and secure development of distributed applications.
Inspr is an engine for running distributed applications, using multiple communication patterns such as pub sub and more, focused on type consistency a
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
Machinery is an asynchronous task queue/job queue based on distributed message passing.
Machinery Machinery is an asynchronous task queue/job queue based on distributed message passing. V2 Experiment First Steps Configuration Lock Broker
High-Performance server for NATS, the cloud native messaging system.
NATS is a simple, secure and performant communications system for digital systems, services and devices. NATS is part of the Cloud Native Computing Fo
A realtime distributed messaging platform
Source: https://github.com/nsqio/nsq Issues: https://github.com/nsqio/nsq/issues Mailing List: [email protected] IRC: #nsq on freenode Docs:
Use Consul to do service discovery, use gRPC +kafka to do message produce and consume. Use redis to store result.
目录 gRPC/consul/kafka简介 gRPC+kafka的Demo gRPC+kafka整体示意图 限流器 基于redis计数器生成唯一ID kafka生产消费 kafka生产消费示意图 本文kafka生产消费过程 基于pprof的性能分析Demo 使用pprof统计CPU/HEAP数据的
💨A well crafted go packages that help you build robust, reliable, maintainable microservices.
Hippo A Microservices Toolkit. Hippo is a collection of well crafted go packages that help you build robust, reliable, maintainable microservices. It
ChanBroker, a Broker for goroutine, is simliar to kafka
Introduction chanbroker, a Broker for goroutine, is simliar to kafka In chanbroker has three types of goroutine: Producer Consumer(Subscriber) Broker
Distributed WebSocket broker
dSock dSock is a distributed WebSocket broker (in Go, using Redis). Clients can authenticate & connect, and you can send text/binary message as an API
A pluggable backend API that enforces the Event Sourcing Pattern for persisting & broadcasting application state changes
A pluggable "Application State Gateway" that enforces the Event Sourcing Pattern for securely persisting & broadcasting application state changes
HARAQA - High Availability Routing And Queueing Application
haraqa is designed to be a developer friendly, scalable message queue for data persistence and real-time data streaming between microservices. Haraqa provides high-throughput, low-latency, fault-tolerant pipelines for architectures of any size.
A pluggable backend API that enforces the Event Sourcing Pattern for persisting & broadcasting application state changes
A pluggable "Application State Gateway" that enforces the Event Sourcing Pattern for securely persisting & broadcasting application state ch
Declarative streaming ETL for mundane tasks, written in Go
Benthos is a high performance and resilient stream processor, able to connect various sources and sinks in a range of brokering patterns and perform hydration, enrichments, transformations and filters on payloads.
Hermes is a tiny MQTT compatible broker written in Go.
Hermes Hermes is a tiny MQTT compatible broker written in Go. The goals of the project are as below Easy to compile, and run Tiny footprint Extensible
Display a message in morse code on your capslock LED, keyboard backlight or using your screen brightness!
halp halp is a command line utility that lets you display messages in morse code on your capslock LED, keyboard backlight (if you have it) or using yo
A single binary, simple, message queue.
MiniQueue A stupid simple, single binary message queue using HTTP/2. Most messaging workloads don't require enormous amounts of data, endless features
A lightweight transactional message bus on top of RabbitMQ
grabbit A lightweight transactional message bus on top of RabbitMQ supporting: Supported Messaging Styles One Way (Fire and forget) Publish/Subscribe
A minimalistic message queue server, in Go
lineup, a tiny queue server lineup is a very simple queue server. all it does is serve a binary-safe priority queue with a simple protocol insp
A standard way to wrap a proto message
Welcome to Pletter 👋 A standard way to wrap a proto message Pletter was born with a single mission: To standardize wrapping protocol buffer messages.
An easy-to-use XChaCha20-encryption wrapper for io.ReadWriteCloser (even lossy UDP) using ECDH key exchange algorithm, ED25519 signatures and Blake3+Poly1305 checksums/message-authentication for Go (golang). Also a multiplexer.
Quick start Prepare keys (on both sides): [ -f ~/.ssh/id_ed25519 ] && [ -f ~/.ssh/id_ed25519.pub ] || ssh-keygen -t ed25519 scp ~/.ssh/id_ed25519.pub