Awesome GitHub RepositoriesDistributed Event Routers

Fluentd is a unified logging layer and distributed event router that collects, parses, and routes log data from diverse sources to various storage backends. It functions as a log forwarding agent and pipeline orchestrator, transforming raw unstructured log strings into formatted objects using structured log parsing. The project utilizes a plugin-based pipeline architecture to route data through independent input, filter, and output stages. It differentiates itself through tag-based event routing, which uses regular expression patterns to direct specific data streams to their intended destinat

Watermill is a Go library for building event-driven applications. It provides a framework for implementing event-driven architectures through a consistent interface for message publishing and subscribing, featuring a pub/sub message router and event stream processing pipelines. The library uses interface-based abstractions to decouple message producers and consumers from the underlying message broker. This allows different messaging technologies to be swapped via plugin-based broker integration. It employs a router-driven dispatch system and middleware-based pipelines to manage cross-cutting

Moleculer is a Node.js microservices framework designed for building distributed systems. It functions as a distributed service broker, task orchestrator, and service mesh framework, enabling a decentralized architecture with built-in service discovery and load balancing. The project differentiates itself through a pluggable transport layer supporting protocols such as NATS, Redis, TCP, and Kafka, as well as a dedicated microservices API gateway that maps external HTTP and WebSocket requests to internal service actions. It includes built-in fault tolerance mechanisms, including circuit breake

Riemann este un procesor de fluxuri de evenimente și un motor de analiză în timp real bazat pe Clojure. Acesta funcționează ca o conductă de telemetrie de rețea și un router de evenimente extensibil care preia, transformă și direcționează datele de evenimente din sisteme distribuite. Sistemul utilizează un limbaj specific domeniului (DSL) pentru a calcula metrici și tipare statistice pe fluxuri continue, permițând analiza tendințelor de rețea și alertarea în timp real. Suportă încărcarea dinamică a plugin-urilor din classpath și permite reîncărcarea configurației în direct, fără a întrerupe fluxurile de evenimente active. Capabilitățile includ agregarea centralizată a telemetriei, etichetarea metadatelor evenimentelor și indexarea stării evenimentelor. Sistemul gestionează distribuția fluxurilor de evenimente prin divizare, procesare în loturi (batching) și filtrare, oferind în același timp transport securizat în rețea prin criptare și autentificare.

Databus is a distributed change data capture system and database transaction log streamer. It extracts data modifications from source logs and streams them to downstream consumers to keep secondary data stores and caches consistent. The system functions as a source-agnostic data pipeline and distributed event relay. It uses a network of processes to decouple database sources from consumers, routing change streams across a network to multiple targets regardless of the original source system. The project covers real-time data synchronization and distributed pipeline monitoring. This includes t