Repository Index

Building event-driven applications the easy way in Go.

• watermill
• event-driven
• event-sourcing
• sagas

Fancy stream processing made operationally mundane

• message-queue
• stream-processing
• streaming-data
• message-bus

Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues and Storage

• etl
• sql
• bigquery
• cloud-native

A lightweight stream processing library for Go

• stream-processing
• pipeline
• etl
• kafka

Lightweight data stream processing engine for IoT edge

• edge
• sql
• iot
• edge-analytics

Build platforms that flexibly mix SQL, batch, and stream processing paradigms

• golang
• event-sourcing
• stream-processing
• brokers

iWF is a Workflow-As-Code microservice orchestration platform offering an orchestration coding framework and service for building resilient, fault-tolerant, scalable long-running processes

• golang
• workflow
• distributed-system
• orchestration

Lightweight stream processing engine for IoT

A Go port of the Java Streams API. Type-safe and functional Go Streams processing

• golang
• go
• stream-processing
• generics

Machine is a workflow/pipeline library for processing data

• golang
• golang-library
• golang-package
• workflow

Distributed batch data processing framework

• cassandra
• rabbitmq
• go
• batch-processing

Lightweight SQL-based stream processing engine for IoT edge.

• edge-analytics
• edge-computing
• iot
• sql

Unlimited job queue for go, using a pool of concurrent workers processing the job queue entries

• queue
• worker
• go
• rabbitmq

Ordered-concurrently a library for concurrent processing with ordered output in Go. Process work concurrently and returns output in a channel in the order of input. It is useful in concurrently processing items in a queue, and get output in the order provided by the queue.

• concurrent
• golang
• golang-library
• data-science

A simple embeddable scripting language which supports concurrent event processing.

• interpreter
• language
• embeddable-scripting-language
• object-oriented-programming

hypermatch is a high-performance ⚡ Go library designed for rapid matching of a large number of rules to events. It processes thousands of events per second 🚀 against extensive rule sets in-memory with minimal latency ⏱️.

• go
• golang
• matching
• matching-engine

A light-weight package for in-app micro batch processing

• batch
• batch-processing
• event-processing
• go