251 Resources
MessageBus Simple Message Bus Written in Golang How to Use go get gopkg.io/Usada
🎇 Gluon A composable message bus for Event-Driven systems written in Go.
PR notifier Use GitHub Actions to notify Slack that a pull request is opened since DAYS_BEFORE days. Usage Add the following YAML to your new GitHub A
About The Project GRAPHQL Project for Event Planning Building the project with l
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
Apache Kafka My study repo for Apache Kafka. Based on this tutorial. Contents Overview Key Terms Event Topic Producer Consumer Partition Getting Start
gomaxscale Go library that allows consuming from MaxScale CDC listener. Useful f
kudruk Channels are widely used as queues. kudruk (means queue in Turkish) helps you to easily create queue with channel and manage the data in the qu
Bookings Solução de cadastro de usuários e reservas. Tecnologias Utilizadas Golang MongoDB RabbitMQ Github Actions Docker Hub Docker Kubernetes Digita
nats-kv-101 Basic kick the tires on NATS Key-Value API (Go) Usage # Get ./mybucket -s "nats://vbox1.tinghus.net" -creds "/home/todd/lab/nats-cluster1/
Producer Consumer This project was created with the purpose of implementing a multi-process synchronization problem. The result is determined by the v
tankerkoenig-fuel-machinery - Fetch gas stations from tankerkoenig api and persist them into an Orion Context Broker Scope This project aims to fetch
NATS Subject Profiler Example Connect it to the demo NATS server. nats-subject-p
Topictool CLI Tool to manage topic labels on Github repositories Installation go
This service consumes events about new posts in go blog (go.dev) from message broker (rabbitmq) (gbu-scanner service publishes these events) and sends notifications to websocket and grpc streams consumers.
liblokinet-go Experimental go binding for liblokinet This is not stable, this is
Experiments using Go 1.18beta1's Generic typings and the Segmentio kafka-go consumer client
Govent is an event bus framework for DDD event source implement. Govent can also solve the package circular dependency problem.
APACHE KAFKA "O Apache Kafka é uma plataforma distribuída de streaming de eventos open-source que é utilizada por milhares de empresas para uma alta p
Github notification polybar widget This tool is meant to be used with Polybar, in order to let the user know when they have notifications on Github. R
go-pub-sub A simple in-process pub/sub for golang Motivation Call it somewhere between "I spent no more than 5 minutes looking for one that existed" a
Simple Messaging Simple messaging for pub/sub and producer/consumer. Pure Go! Usage Request-Response Producer: consumerAddr, err := net.ResolveTCPAddr
Troon Checker and SMS Sender Clone this repo: git clone https://github.com/Cobra
shopify-pe ---------- A tiny inventory management web-application. DESCRIPTION The API backend for this application is written in `go'. It handle
[gdq] Golang Delay Queue GDQ is a library that leverage db or cache to be setup as a delay queue. For current version, Only redis can adapt to this li
github.com/eth-p/clout (Command Line Output) clout is a package that helps you print user-friendly output messages from your Go command line applicati
visits-tracker A simple visits tracker built using Go and Redis Let me note that this is a really bad idea if you are not backing up Redis since it li
Kafka prtobuf message producer This project is used to produce protobuf messages message to given kafka topic UseCase Integration testing Debugging Mo
Ademco For Go A lightweight golang library for dealing with Contact-ID and Ademco messaging formats. Installation install via go get $ go get github.c
VIGIA MIGRAR O HOUSEKEEPER PARA O PYTHON Programa para processamento de metadado
go-cruise-control It's client library (written in Golang) for interacting with Linkedin Cruise Control using its HTTP API. Supported Cruise Control ve
kafka-go Motivations We rely on both Go and Kafka a lot at Segment. Unfortunately, the state of the Go client libraries for Kafka at the time of this
url_handler Give it an url and it will open it how you want. Browers are anoying so when I can, I open links with dedicated programs. I started out us
Arjun's Urgent Notification Backend This is intended to let people urgently noti
sqscat sqscat is "netcat for SQS". You can use sqscat to receive from and send messages to SQS queue. sqscat uses newline as the delimiter between mes
Docker-compose stand with RabbitMQ and sender/reciever. About First app is a producer that sends messages (1 per second / while-true loop), the second
Sim Sim is a command-line tool that manages program symlinks in $XDG_BIN_HOME. Get started Run make install. Make sure your PATH contains $XDG_BIN_HOM
kfchc / Kafka Connect HealthCheck Kafka Connect (connectors / tasks) HealthCheck
Bhojpur MDM - Mobile Device Manager The Bhojpur MDM is a software-as-a-service product used as a Mobile Device Manager based on Bhojpur.NET Platform f
Big Queue on Go This is a simple big queue and implementation in kafka, rabbit and aws sqs. Publish in a topic in kafka: Use NewPublisher method to cr
recvsms - use free sms services through cli You can think of recvsms as yt-dl for free sms services. It will support many SMS "backends" eventually. I
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
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
Notifie Server Notifie Server is a learning list notifier. E.g; If you want to l
Получить номер последнего заказа, способ оплаты, способ доставки SELECT virtuemart_order_id FROM ce7l3_virtuemart_orders ORDER BY virtuemart_order_id
Golang Push Notification Simple system push notification for android/fcm and apn
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
shredder shredds Fixed column file to avro/kafka . Implementation uses Avro schema and multicore Speed around 220mb/sec per Core using 4 core on a 1Gb
Go PostgreSQL О проекте Этот репозиторий представляет собой реализацию REST API сервиса для просмотра видео роликов. Используемы технологии Go Postgre
UHub subscriber and publisher package main import ( "fmt" uhub "github.com/u
broadcast_linkedlist nonblocking broadcast chan 利用close(chan)的特性,来实现广播效果 example
Apache Kafka Go Testing Apache Kafka using Go. Instructions Provision the single node Kafka cluster using Docker: docker-compose -p apache-kafka-go up
queue A basic event queue (and publisher/subscriber) in go. Installation go get github.com/jimjibone/queue Queue Usage Queue is a channel-based FIFO q
FIFO Queue Thread-safe, lightweight, tested FIFO queue with fixed size, which is built upon list for performance ;-) This implement is inspired by htt