Filter By
251 Resources
Golang Messaging
High abstraction wrapper for Golang Rabbit MQ Client
GRMQ Go Rabbit MQ What are the typical use-cases of RabbitMQ broker ? We create
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 unified representation of buffered, unbuffered, and unbounded channels in Go
chann a unified representation of buffered, unbuffered, and unbounded channels in Go import "golang.design/x/chann" This package requires Go 1.18. Us
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
Scalable package delivery logistics simulator built using SingleStore and Vectorized Redpanda
Reference Architecture using SingleStore and Redpanda for global logistics 📯 INFO: For the story behind this code (and epic dashboards), check out th
provider-kafka is a Crossplane Provider that is used to manage Kafka resources.
provider-kafka provider-kafka is a Crossplane Provider that is used to manage Kafka resources. Usage Create a provider secret containing a json like t
Golang API wrapper for MangaDex v5's MVP API.
mangodex Golang API wrapper for MangaDex v5's MVP API. Full documentation is found here. This API is still in Open Beta, so testing may not be complet
A generic oplog/replication system for microservices
REST Operation Log OpLog is used as a real-time data synchronization layer between a producer and consumers. Basically, it's a generic database replic
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
websocket based messaging server written in golang
Guble Messaging Server Guble is a simple user-facing messaging and data replication server written in Go. Overview Guble is in an early state (release
A fast durable queue for Go
pqueue - a fast durable queue for Go pqueue is thread-safety, serves environments where more durability is required (e.g., outages last longer than me
Redis as backend for Queue Package
redis Redis as backend for Queue package Setup start the redis server redis-server start the redis cluster, see the config # server 01 mkdir server01
A basic presence tracker, that sends messages when the provided user's presence changed, written with discordgo
presenceTracker A basic presence tracker, that sends messages when the provided user's presence changed, written with discordgo Just put the User ID t
M3U generator for Stirr, optimized for Channels' custom channels.
Stirr for Channels This simple Docker image will generate an M3U playlist and EPG optimized for use in Channels and expose them over HTTP. Channels su
An little library to create notification files with golang.
notifile With this no library you can easily create notification files for your Go projects. These must then be stored in the directory you specify so
Gorabbit - Simple library for AMQP Rabbit MQ publish subscribe
gorabbit Rabbit MQ Publish & Subscribe Simple library for AMQP Rabbit MQ publish
Transpiled version of the CCXT exchange library to Go (Golang)
CCXT Go Transpiled CCXT exchange library from their original JavaScript source to Go (Golang). Features support 100+ cryptocurrency exchanges with a u
RabbitMQ Reconnection client
rmqconn RabbitMQ Reconnection for Golang Wrapper over amqp.Connection and amqp.Dial. Allowing to do a reconnection when the connection is broken befor
RapidMQ is a pure, extremely productive, lightweight and reliable library for managing of the local messages queue
RapidMQ RapidMQ is a pure, extremely productive, lightweight and reliable library for managing of the local messages queue in the Go programming langu
A tiny wrapper around NSQ topic and channel :rocket:
Event Bus NSQ A tiny wrapper around go-nsq topic and channel. Protect nsq calls with gobreaker. Installation go get -u github.com/rafaeljesus/nsq-even
A library for scheduling when to dispatch a message to a channel
gosd go-schedulable-dispatcher (gosd), is a library for scheduling when to dispatch a message to a channel. Implementation The implementation provides
Sending line notifications using a binary, docker or Drone CI.
drone-line Sending line notifications using a binary, docker or Drone CI. Register Line BOT API Trial Please refer to LINE Business Center. Feature Se
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
A Go interface to ZeroMQ version 3
A Go interface to ZeroMQ version 3. For ZeroMQ version 4, see: http://github.com/pebbe/zmq4 For ZeroMQ version 2, see: http://github.com/pebbe/zmq2 In
Embedded, Fast and Persistent bigqueue implementation
bigqueue bigqueue provides embedded, fast and persistent queue written in pure Go using memory mapped (mmap) files. bigqueue is now thread safe as wel
High level manegment for rabbitmq.
High level manegment for rabbitmq. Features Simple configuration bootstrap. Gracefully shutting down. Consume messages in parallel specifying a number
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
Package htmltopdf implements wkhtmltopdf Go bindings.
htmltopdf Package htmltopdf implements wkhtmltopdf Go bindings. It can be used to convert HTML documents to PDF files. The package does not use the wk
Kafka, Beanstalkd, Pulsar Pub/Sub framework
go-queue Kafka, Beanstalkd, Pulsar Pub/Sub framework.
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:
Discrete-event simulation in Go using goroutines
SimGo SimGo is a discrete event simulation framework for Go. It is similar to SimPy and aims to be easy to set up and use. Processes are defined as si
An easy-to-use CLI client for RabbitMQ.
buneary, pronounced bun-ear-y, is an easy-to-use RabbitMQ command line client for managing exchanges, managing queues and publishing messages to exchanges.
Run Buildkite Pipelines locally
bkl - Run Buildkite Pipelines locally Run buildkite pipelines locally (no buildkite.com required). Installing Either download a release binary or if y
🔥 A fast and beautiful command line tool to build API requests.
Poodle A fast and beautiful command line tool to build API requests 🦄 Check out the full Demo! Poodle is an interactive command line tool to build an
Go-notification - Realtime notification system with golang
Realtime notification system Used Apache kafka gRPC & PROTOBUF MongoDB restapi w
A go library for interacting with Google Verified SMS
verifiedsms This is a go library for interacting with the Google Verified SMS service. You'll need to already be signed up as a Verified SMS Partner t
💨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
cisasntyi: check iphone stock and send notification to your iphone
for buy iphone 13 notification cisasntyi: check iphone stock and send notification to your iphone install Bark app in your iphone first before you run
A high-level RabbitMQ driver for Golang.
grabbitmq A high-level RabbitMQ driver for Golang. Import in your project: go get github.com/shaswata56/grabbitmq Usage Demo: package main import (
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
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,
Imagine a simple, beautiful, secure, and freaking fast way to broadcast your events throw the internet
Event Superintendent Imagine a simple, beautiful, secure, and freaking fast way to broadcast your events throw the internet. That's exactly why you sh
Persistent queue in Go based on BBolt
Persistent queue Persistent queue based on bbolt DB. Supposed to be used as embeddable persistent queue to any Go application. Features: messages are
Pause / Unpause NSQ Topics and Channels
Action pause unpause empty info check Worker Pool 1 = n = len(target) 0 for unlimited pool depend on how many the targets Target Array of topics or
Korero - Send, recieve and manage messages on multiple platforms
Korero: Send, recieve and manage messages on multiple platforms Korero is a term
Simple synchronous event pub-sub package for Golang
event-go Simple synchronous event pub-sub package for Golang This is a Go language package for publishing/subscribing domain events. This is useful to
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
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.
Streamhub: a toolkit crafted for streaming-powered applications written in Go
✉️ Streamhub Streamhub is a toolkit crafted for streaming-powered applications w
Httpmq-go - Golang client for httpmq
HTTP MQ - Go Client Golang client for httpmq Table of Content 1. Introduction 2. Installation 3. Examples 4. Local Development 5. License 1. Introduct
A simple microservice which accepts incoming notifications
Notifier A simple microservice which accepts incoming notifications, and questions and redirects them to notification sinks such as Telegram, Email et
Harvit harvests data from different sources (e.g websites, APIs), converts and transforms it.
harvit Harvit harvests data from different sources (e.g websites, APIs), converts and transforms it. Contents harvit Contents Requirements Usage Examp
Insta API using Go and Mongodb
Insta-API HTTP JSON API that can be used to perform basic tasks of Creating User, Creating Post, Getting User & Post details through their Unique ID.