How this analysis was created: This summary and feature list were written by an AI model that read the project's README and public documentation pages. Each feature links to the documentation it came from; stars, license and language come straight from the GitHub API. The model does not read the source code, and the analysis is refreshed when the project is re-analysed. Learn more on our About page.
Benthos is a declarative stream processor and data integration pipeline used to route, transform, and filter information between disparate services. It functions as an at-least-once message broker and change data capture engine, using a transaction model to guarantee message delivery despite system crashes or server faults. The system is defined by an observability-first approach, featuring built-in HTTP health probes, performance metrics export, and distributed request flow tracing. It utilizes a plugin architecture that allows the core engine to be extended with custom binaries for new inpu
A lightweight stream processing library for Go
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
A Golang based high performance, scalable and distributed workflow framework
The main features of s8sg/goflow are: Data Processing and Streams.
Open-source alternatives to s8sg/goflow include: itsubaki/gostream. jeffail/benthos — Benthos is a declarative stream processor and data integration pipeline used to route, transform, and filter… reugn/go-streams — A lightweight stream processing library for Go. threedotslabs/watermill — Watermill is a Go library for building event-driven applications. It provides a framework for implementing… uber/cadence — Cadence is a distributed workflow orchestration engine designed to execute long-running, asynchronous business logic…