Filter By
250 Resources
Golang Messaging
Server-sent live updates: protocol and reference implementation
Protocol and Reference Implementation Mercure is a protocol allowing to push data updates to web browsers and other HTTP clients in a convenient, fast
redisqueue provides a producer and consumer of a queue that uses Redis streams
redisqueue redisqueue provides a producer and consumer of a queue that uses Redis streams. Features A Producer struct to make enqueuing messages easy.
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
🐇 Easy to use socket lib for Golang
Hare Sockets 🐇 Hare is a user-friendly lib for sockets in Golang. You can send and listen to TCP connections with a few lines of code. Contents Insta
An n:m message multiplexer written in Go
What is Gollum? Gollum is an n:m multiplexer that gathers messages from different sources and broadcasts them to a set of destinations. Gollum origina
The implementation of the pattern observer
Event This is package implements pattern-observer Fast example import ( "github.com/agoalofalife/event" ) func main() { // create struct e := even
Emits events in Go way, with wildcard, predicates, cancellation possibilities and many other good wins
Emitter The emitter package implements a channel-based pubsub pattern. The design goals are to use Golang concurrency model instead of flat callbacks
💨 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
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
Scalable real-time messaging server in language-agnostic way
Centrifugo is a scalable real-time messaging server in language-agnostic way. Centrifugo works in conjunction with application backend written in any
Temporal service and CLI
Temporal Temporal is a microservice orchestration platform which enables developers to build scalable applications without sacrificing productivity or
A push notification server written in Go (Golang).
gorush A push notification micro server using Gin framework written in Go (Golang) and see the demo app. Contents gorush Contents Support Platform Fea
Mizu - API traffic viewer for Kubernetes enabling you to view all API communication between microservices
The API Traffic Viewer for Kubernetes A simple-yet-powerful API traffic viewer f
socket.io library for golang, a realtime application framework.
go-socket.io go-socket.io is library an implementation of Socket.IO in Golang, which is a realtime application framework. Current this library support
franz-go - A complete Apache Kafka client written in Go
franz-go contains a feature complete, pure Go library for interacting with Kafka from 0.8.0 through 2.8.0+. Producing, consuming, transacting, administrating, etc.
A non-dependent, online configuration, GO-developed, API gateway
GateKeeper GateKeeper 是一个 Go 编写的不依赖分布式数据库的 API 网关，使用它可以高效进行服务代理，支持在线化热更新服务配置 以及 纯文件方式服务配置，支持主动探测方式自动剔除故障节点以及手动方式关闭下游节点流量，还可以通过自定义中间件方式灵活拓展其他功能。 特性 内容
:notes: Minimalist websocket framework for Go
melody 🎶 Minimalist websocket framework for Go. Melody is websocket framework based on github.com/gorilla/websocket that abstracts away the tedious p
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
Cadence is a distributed, scalable, durable, and highly available orchestration engine to execute asynchronous long-running business logic in a scalable and resilient way.
Cadence Visit cadenceworkflow.io to learn about Cadence. This repo contains the source code of the Cadence server. To implement workflows, activities
A wrapper of streadway/amqp that provides reconnection logic and sane defaults
go-rabbitmq Wrapper of streadway/amqp that provides reconnection logic and sane defaults. Hit the project with a star if you find it useful ⭐ Supporte
通过企业微信向微信推送消息的配置文档、直推函数和可自行搭建的在线服务代码。可以看成Server酱的开源替代方案之一。
Wecom酱 通过企业微信向微信推送消息的解决方案。包括： 配置说明（本页下方） 推送函数（支持多种语言，见本页下方） 自行搭建的在线服务源码 PHP版搭建说明 Go版说明 企业微信应用消息配置说明 优点： 一次配置，持续使用 配置好以后，只需要微信就能收消息，不再需要安装企业微信客户端 PS：消息
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
The official Go package for NSQ
go-nsq The official Go package for NSQ. Docs See godoc and the main repo apps directory for examples of clients built using this package. Tests Tests
Sarama is a Go library for Apache Kafka 0.8, and up.
sarama Sarama is an MIT-licensed Go client library for Apache Kafka version 0.8 (and later). Getting started API documentation and examples are availa
Send SSE when files change
ssentr Send SSE when files change. Setup: $ cat Caddyfile http://localhost:8085 route /reload { header Access-Control-Allow-Origin * header Access-C
[Go] Lightweight eventbus with async compatibility for Go
EventBus Package EventBus is the little and lightweight eventbus with async compatibility for GoLang. Installation Make sure that Go is installed on y
Modern CLI for Apache Kafka, written in Go.
Kaf Kafka CLI inspired by kubectl & docker Install Install from source: go get -u github.com/birdayz/kaf/cmd/kaf Install binary: curl https://raw.git
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
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 client for NATS, the cloud native messaging system.
NATS - Go Client A Go client for the NATS messaging system. Installation # Go client go get github.com/nats-io/nats.go/ # Server go get github.com/na
Gin best practices, gin development scaffolding, too late to explain, get on the bus.
Table of Contents generated with DocToc gin_scaffold 现在开始 文件分层 log / redis / mysql / http.client 常用方法 swagger文档生成 gin_scaffold Gin best practices, gin
Asynq: simple, reliable, and efficient distributed task queue in Go
Asynq Overview Asynq is a Go library for queueing tasks and processing them asynchronously with workers. It's backed by Redis and is designed to be sc
Build platforms that flexibly mix SQL, batch, and stream processing paradigms
Overview Gazette makes it easy to build platforms that flexibly mix SQL, batch, and millisecond-latency streaming processing paradigms. It enables tea
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:
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 h
⚡ HTTP/2 Apple Push Notification Service (APNs) push provider for Go — Send push notifications to iOS, tvOS, Safari and OSX apps, using the APNs HTTP/2 protocol.
APNS/2 APNS/2 is a go package designed for simple, flexible and fast Apple Push Notifications on iOS, OSX and Safari using the new HTTP/2 Push provide
ntfy is a super simple pub-sub notification service. It allows you to send desktop notifications via scripts.
ntfy ntfy (pronounce: notify) is a super simple pub-sub notification service. It allows you to send desktop and (soon) phone notifications via scripts
A Go interface to ZeroMQ version 4
A Go interface to ZeroMQ version 4. Warning Starting with Go 1.14, on Unix-like systems, you will get a lot of interrupted signal calls. See the top o
🎓 Ozon Go Course
Ozon Go Course (1st stream 2021) Добро пожаловать! Гайд для студентов Программа курса Go-разработки interactive material Материалы перед началом Презе
Uniqush is a free and open source software system which provides a unified push service for server side notification to apps on mobile devices.
Homepage Download Blog/News @uniqush Introduction Uniqush (\ˈyü-nə-ku̇sh\ "uni" pronounced as in "unified", and "qush" pronounced as in "cushion") is
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
Enterprise Network Flow Collector (IPFIX, sFlow, Netflow)
High-performance, scalable and reliable IPFIX, sFlow and Netflow collector (written in pure Golang). Features IPFIX RFC7011 collector sFLow v5 raw hea
Gue is Golang queue on top of PostgreSQL that uses transaction-level locks.
Gue is Golang queue on top of PostgreSQL that uses transaction-level locks.
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
Memlog - A Kafka log structure inspired in-memory and append-only data structure
Benchmark with log size 1000 go test -bench=. -cpu 1,2,4,8,16 -benchmem goos: darwin goarch: amd64 pkg: github.com/embano1/memlog cpu: Intel(R) Core(T
Apache Kafka Web UI for exploring messages, consumers, configurations and more with a focus on a good UI & UX.
Kowl - Apache Kafka Web UI Kowl (previously known as Kafka Owl) is a web application that helps you to explore messages in your Apache Kafka cluster a
Easy to use distributed event bus similar to Kafka
chukcha Easy to use distributed event bus similar to Kafka. The event bus is designed to be used as a persistent intermediate storage buffer for any k
A dead simple Go library for sending notifications to various messaging services.
A dead simple Go library for sending notifications to various messaging services. About Notify arose from my own need for one of my api server running
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
RabbitMQ wire tap and swiss army knife
rabtap - RabbitMQ wire tap Swiss army knife for RabbitMQ. Tap/Pub/Sub messages, create/delete/bind queues and exchanges, inspect broker. Contents Feat
golang long polling library. Makes web pub-sub easy via HTTP long-poll server :smiley: :coffee: :computer:
golongpoll Golang long polling library. Makes web pub-sub easy via an HTTP long-poll server. New in v1.1 Deprecated CreateManager and CreateCustomMana
ZenQ - A low-latency thread-safe queue in golang implemented using a lock-free ringbuffer
ZenQ A low-latency thread-safe queue in golang implemented using a lock-free ringbuffer Features Much faster than native channels in both SPSC (single
franz-go contains a high performance, pure Go library for interacting with Kafka from 0.8.0 through 2.7.0+. Producing, consuming, transacting, administrating, etc.
franz-go - Apache Kafka client written in Go Franz-go is an all-encompassing Apache Kafka client fully written Go. This library aims to provide every
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