108 Resources
Golang event-sourcing Libraries
A lightweight eventbus that simplifies communication between goroutines,
English | 简体中文 eventbus A lightweight eventbus that simplifies communication between goroutines, it supports synchronous and asynchronous message publ
A db proxy for distributed transaction, read write splitting and sharding! Support any language! It can be deployed as a sidecar in a pod.
DBPack DBPack means a database cluster tool pack. It can be deployed as a sidecar in a pod, it shields complex basic logic, so that business developme
A lightweight event collection system.
Honeypot A self-contained, multi-protocol streaming event collection system with ambitions to be as boring as benthos. Honeypot is primarily built for
CQRS & Event-Sourcing Framework for Go.
goes - Event-Sourcing Framework goes is a collection of interfaces, tools, and backend implementations that allow you to write event-sourced applicati
This library implements the pub/sub pattern in a generic way. It uses Go's generic types to declare the type of the event.
observer This library implements the pub/sub pattern in a generic way. It uses Go's generic types to declare the type of the event. Usage go get githu
Package event-driven makes it easy for you to drive events between services
Event-Driven Event-driven architecture is a software architecture and model for application design. With an event-driven system, the capture, communic
Basic Event Streaming - Fundamentals of Kafka Studies (BESt-FunKS)
Apache Kafka My study repo for Apache Kafka. Based on this tutorial. Contents Overview Key Terms Event Topic Producer Consumer Partition Getting Start
The API backend for the HackMan hackathon event. Returns a random word associated with a unique key
The API backend for the HackMan hackathon event. Returns a random word associated with a unique key
Simple Proof of Concept REST event logger.
REST Event Logger PoC I am working on this project intermittently. I have set myself a time limit of ~3hrs which includes the time to acquire and adap
Drain-my-spot - Service draining the k8s worker node in case of spot instances related event occurrence
drain-my-spot Service draining the k8s worker node in case of spot instances rel
The Webhooks Listener-Plugin library consists of two component libraries written in GoLang
The Webhooks Listener-Plugin library consists of two component libraries written in GoLang: WebHook Listener Libraries and Plugin (Event Consumer) Libraries.
Event-planning-go - GRAPHQL Project for Event Planning
About The Project GRAPHQL Project for Event Planning Building the project with l
Prototype to show how to transform an existing (SOAP) API into a modern streaming API
vSphere Event Streaming Prototype to show how to transform an existing (SOAP) API into a modern HTTP/REST streaming API. Details The vSphere Event Str
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
Subscibe to Ethereum contranct ERC20 Transfer event
Subscribe Ethereum Transfer Subscibe to Ethereum contranct ERC20 Transfer event.
Govent is an event bus framework for DDD event source implement
Govent is an event bus framework for DDD event source implement. Govent can also solve the package circular dependency problem.
Observer - Golang event dispatch
observer go基于观察者模式的事件调度 Installation go get -u github.com/caijw-go/observer Usa
Singlestore event analytics - Evaluation of sortable ID generation schemes
Singlestore event analytics - Evaluation of sortable ID generation schemes
Eventproc - A proof-of-concept for exploring event based architecture utilizing bi-directional gRPC streams
eventproc A proof-of-concept for exploring event based architecture utilizing bi
Tools for parse JSON-like logs for collecting unique fields and events
parsefields Tool for parse JSON-like logs for collecting unique fields. Main purpose to collect JSON-data with typical events and fields it is useful
An event driven remote access trojan for experimental purposes.
erat An event driven remote access trojan for experimental purposes. This example is very simple and leverages ssh failed login events to trigger erat
A simple embeddable scripting language which supports concurrent event processing.
ECAL ECAL is an ECA (Event Condition Action) language for concurrent event processing. ECAL can define event-based systems using rules which are trigg
NJ Meetup - Build an event-driven architecture with Apache Pulsar
Meetup-YourFirstEventDrivenApp NJ Meetup - Build an event-driven architecture with Apache Pulsar Code Along bin/pulsar-admin tenants create meetup bi
Streamhub: a toolkit crafted for streaming-powered applications written in Go
✉️ Streamhub Streamhub is a toolkit crafted for streaming-powered applications w
Key event handling library for tcell - THIS IS A MIRROR - SEE LINK BELOW
cbind Key event handling library for tcell Features Set KeyEvent handlers Encode and decode KeyEvents as human-readable strings Usage // Create a new
Eye - An easy-use lib for event-driven pattern
📝 Eye Eye 是一个简单易用的事件驱动模式库。 Read me in English 🥇 功能特性 敬请期待。。。 历史版本的特性请查看 HISTOR
Gobacktest - event-driven backtesting framework written in golang
Heads up: This is a framework in development, with only basic functionality. gobacktest - Fundamental stock analysis backtesting An event-driven backt
Go-serverless-eth-event-listener - Go serverless, ethereum contract event listener with a sample contract
go-serverless-eth-event-listener This repository is for showing how to listen sm
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
Events - Event Manager - Nodejs like
events Event Manager - Nodejs like Please take a look at the TESTS, for further comprehension. Example package main import ( "errors" "fmt" "log"
Building event-driven applications the easy way in Go.
Watermill Watermill is a Go library for working efficiently with message streams. It is intended for building event driven applications, enabling even
An example Event-Driven application in Go built with Watermill library.
Event-Driven application example This is an example Event-Driven application written in Go, using Watermill. The projects aims to integrate incoming G
Go - CQRS / Event Sourcing made easy - Go
Eventhus CQRS/ES toolkit for Go. CQRS stands for Command Query Responsibility Segregation. It's a pattern that I first heard described by Greg Young.
A simple CQRS Framework for go
Flux Introduction "There is nothing called state. There are events and the story we tell about what it means." Flux allows you to quickly build an app
cqrs framework in go
CQRS framework in go Project Summary The package provides a framework for quickly implementing a CQRS style application. The framework attempts to pro
Event driven modular status-bar for dwm; written in Go & uses Unix sockets for signaling.
dwmstat A simple event-driven modular status-bar for dwm. It is written in Go & uses Unix sockets for signaling. The status bar is conceptualized as a
The simple and light self-hosted custom event analytics you were looking for.
Dead-Simple-Game-Analytics What is Dead Simple Game Analytics? An extremely simple self-hosted system to log your game analytics events. No fluff or o
Project Flogo is an open source ecosystem of opinionated event-driven capabilities to simplify building efficient & modern serverless functions, microservices & edge apps.
Project Flogo is an Open Source ecosystem for event-driven apps Ecosystem | Core | Flows | Streams | Flogo Rules | Go Developers | When to use Flogo |
connpassSearcher gets ICT event informations
connpassSearcher connpassSearcher gets ICT event informations Installation When you have installed the Go, Please execute f
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.
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
A demonstration of the transactional outbox messaging pattern (+ Log Trailing) with Amazon DynamoDB (+ Streams) written in Go.
Transactional Outbox Pattern in Amazon DynamoDB A demonstration of the transactional outbox messaging pattern (+ Log Trailing) with Amazon DynamoDB (+
A basic event queue (and publisher/subscriber) in go
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
Multi-party system for enterprise data flows. Allows developers to build decentralized applications rapidly on a blockchain-backed business network, with REST APIs and an event-driven programming model.
Hyperledger FireFly Hyperledger FireFly is an API and data orchestration layer on top of core blockchain technologies. It implements a multi-party sys
A Global event triggerer for golang. Defines functions as event with id string. Trigger the event anywhere from your project.
go-trigger Go Trigger is a global event trigger for golang. Define an event with a task specified to that event and Trigger it from anywhere you want.
Prueba de concepto: Boletia, una aplicación para venta de boletos, basada en microservicios event-driven. Desarrollada sobre AWS Serverless: Api Gateway, Lambda, DynamoDB, DynamoDB Streams
Prueba de concepto: Boletia, una aplicación para venta de boletos, basada en microservicios event-driven. Desarrollada sobre AWS Serverless: Api Gatew
Example Golang Event-Driven with kafka Microservices Choreography
Microservices Choreography A demonstration for event sourcing using Go and Kafka example Microservices Choreography. To run this project: Install Go I
gevent imply go-event which tries to make event handling easier.
gevent imply go-event which tries to make event handling easier. What does gevent want to do Async execute jobs safely without too many go routines. S
Goket (Golang Keyboard Event Tree) is a proof-of-concept code for using keyboard events trees for performing operations.
Goket Goket (Golang Keyboard Event Tree) is a proof-of-concept code for using keyboard events trees for performing operations. Its main goal is to all
ECS task event/log tracer CLI
tracer tracer is a tracing tool for Amazon ECS tasks. tracer shows events and logs of the tasks order by timestamp. example Run a task successfully an
A blank project for Go development with CDK
Welcome to your CDK Go project! This is a blank project for Go development with CDK. NOTICE: Go support is still in Developer Preview. This implies th
Monitor & detect crashes in your Kubernetes(K8s) cluster
kwatch kwatch helps you monitor all changes in your Kubernetes(K8s) cluster, detects crashes in your running apps in realtime, and publishes notificat
Go library to build event driven applications easily using AMQP as a backend.
event Go library to build event driven applications easily using AMQP as a backend. Publisher package main import ( "github.com/creekorful/event" "
Server motherboard hardware monitoring
hardware-events This software helps with the monitoring of a server motherboard. The project started when I changed the FANs on a Supermicro motherboa
SaltStack transactions tracker
Peephole Peephole is a web-based events explorer of SaltStack transactions. It can be used to watch for events on several SaltStack master nodes by GE
This example showcases an event-sourced CQRS system based on github.com/romshark/eventlog
Eventlog Example This example is showcasing an eventually consistent, fault-tolerant, event sourced system following the CQRS (Command-Query-Responsib
Ethereum event tracker
Eth-event-tracker Tracker of Ethereum events. Example package main import ( "context" "encoding/binary" "flag" "fmt" "os" "os/signal" "syscall
POC of an event-driven Go implementation
Event Driven example in Golang This POC shows an example of event-driven architecture with a working domain event broker, an event producer and a cons
Go network programming framework, supports multiplexing, synchronous and asynchronous IO mode, modular design, and provides flexible custom interfaces
Go network programming framework, supports multiplexing, synchronous and asynchronous IO mode, modular design, and provides flexible custom interfaces。The key is the transport layer, application layer protocol has nothing to do
Event Source for Direktiv and Knative
Event Source for Direktiv and Knative This repository contains ContainerSources for Knative Eventing. The following sources are available: Direktiv (I
The kprobe package allows construction of dynamic struct based on kprobe event format descriptions.
The kprobe package allows construction of dynamic struct based on kprobe event format descriptions.
An example event-driven application using Atmo and NATS
Atmo + NATS Example Project This repo is an example of using Atmo with NATS as a streaming messaging layer. In this example, Atmo connects to NATS and
Go server SDK for IBM Cloud Event Notifications service
IBM Cloud Event Notifications Go Admin SDK Go client library to interact with the various IBM Cloud Event Notifications APIs. Disclaimer: this SDK is
Bell is the simplest event system written in Go (Golang) which is based on the execution of handlers independent of the main channel.
Bell Bell is the simplest event system written in Go (Golang) which is based on the execution of handlers independent of the main channel. Written in
TriggerMesh open source event-driven integration platform powered by Kubernetes and Knative.
TriggerMesh open source event-driven integration platform powered by Kubernetes and Knative. TriggerMesh allows you to declaratively define event flows between sources and targets as well as add even filter, splitting and processing using functions.
ZITADEL - Identity Experience Platform
What Is ZITADEL ZITADEL is a "Cloud Native Identity and Access Management" solution built for the cloud era. ZITADEL uses a modern software stack cons
Walrus 🕑 Real-time event streaming platform built on top of gRPC streams
Walrus 🕑 Real-time event streaming platform built on top of gRPC streams Table of Contents About the project Built With How it works Getting Started
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
High-performance, non-blocking, event-driven, easy-to-use networking framework written in Go, support tls/http1.x/websocket.
High-performance, non-blocking, event-driven, easy-to-use networking framework written in Go, support tls/http1.x/websocket.
Fully featured, spec-compliant HTML5 server-sent events library
go-sse Lightweight, fully spec-compliant HTML5 server-sent events library. Table of contents go-sse Table of contents Installation and usage Implement
(WIP) Extremely simple unixway GitHub webhook listener for push event
(WIP) puffy Puffy is an extremely simple unixway GitHub webhook listener and handler for push events Todo Add payload signature validation (WIP) Depen
simple golang event bus structure
super simple and small event bus structure for golang that allows emissions as go routines.
AWS Cloudtrail event alerting lambda function. Send alerts to Slack, Email, or SNS.
Cloudtrail-Tattletail is a Lambda based Cloudtrail alerting tool. It allows you to write simple rules for interesting Cloudtrail events and forward those events to a number of different systems.
Go Türkiye Event Template Generator
Go Türkiye Cover Generator Etkinliklerde değişen tek şey konuşmacıların konusu, ismi, nerede çalıştıklarıyla beraber etkinliğin zamanı. Her etkinlikte
Go Server/API boilerplate using best practices DDD CQRS ES gRPC
Go Server/API boilerplate using best practices DDD CQRS ES gRPC
Write your front in Go!
Hogosuru Hogosuru is a part of a personel project and export to the community and provide a framework to easly provide write front end in go. He use a
Feishu/Lark Open API Go Sdk, Support ALL Open API and Event Callback.
lark 中文版 README Feishu/Lark Open API Go Sdk, Support ALL Open API and Event Callback. Created By Code Generation. Install go get github.com/chyroc/lar
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
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
KEDA is a Kubernetes-based Event Driven Autoscaling component. It provides event driven scale for any container running in Kubernetes
Kubernetes-based Event Driven Autoscaling KEDA allows for fine-grained autoscaling (including to/from zero) for event driven Kubernetes workloads. KED
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
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
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
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
Fast event-loop networking for Go
evio is an event loop networking framework that is fast and small. It makes direct epoll and kqueue syscalls rather than using the standard Go net pac
Open source Firebase + Heroku to develop, scale and secure serverless apps on Kubernetes
Develop, Deploy and Secure Serverless Apps on Kubernetes. Website • Docs • Support Space Cloud is a Kubernetes based serverless platform that provides
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
Dapr is a portable, event-driven, runtime for building distributed applications across cloud and edge.
Dapr is a portable, serverless, event-driven runtime that makes it easy for developers to build resilient, stateless and stateful microservices that run on the cloud and edge and embraces the diversity of languages and developer frameworks.
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.
Idiomatic Event Sourcing in Go
Event Sourcing for Go Idiomatic library to help you build Event Sourced application in Go. Please note The library is currently under development and
Golang Event Scheduling Sample Using Postgresql Database as persisting layer.
Database Based Event Scheduling Example that demonstrates super basic database based event scheduling. To run this example; Copy .env.example to .env
ftgogo - event-driven architecture demonstration application
ftgogo (food-to-gogo) is a Golang implementation of the FTGO application described in the book "Microservice Patterns" by Chris Richardson. A library edat was developed to provide for Golang many of the solutions that Eventuate, the framework used by FTGO, provides for Java.
Event-based stateful IRC client framework for Go.
GoIRC Client Framework Acquiring and Building Pretty simple, really: go get github.com/fluffle/goirc/client There is some example code that demonstra
File system event notification library on steroids.
notify Filesystem event notification library on steroids. (under active development) Documentation godoc.org/github.com/rjeczalik/notify Installation
FreeSWITCH Event Socket library for the Go programming language.
eventsocket FreeSWITCH Event Socket library for the Go programming language. It supports both inbound and outbound event socket connections, acting ei
A tiny wrapper over amqp exchanges and queues 🚌 ✨
Rabbus 🚌 ✨ A tiny wrapper over amqp exchanges and queues. In memory retries with exponential backoff for sending messages. Protect producer calls wit
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
Go simple async message bus
🚌 message-bus Go simple async message bus. 📖 ABOUT Contributors: Rafał Lorenz Want to contribute ? Feel free to send pull requests! Have problems, b
:incoming_envelope: A fast Message/Event Hub using publish/subscribe pattern with support for topics like* rabbitMQ exchanges for Go applications
Hub 📨 A fast enough Event Hub for go applications using publish/subscribe with support patterns on topics like rabbitMQ exchanges. Table of Contents