Agent for collecting, processing, aggregating, and writing metrics, logs, and other arbitrary data.
- telegraf
- monitoring
- time-series
- metrics
47,133 repositories indexed
1–17 of 17 · Most stars
Agent for collecting, processing, aggregating, and writing metrics, logs, and other arbitrary data.
Workflow Engine for Kubernetes
Building event-driven applications the easy way in Go.
Fancy stream processing made operationally mundane
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues and Storage
A lightweight stream processing library for Go
Lightweight data stream processing engine for IoT edge
Build platforms that flexibly mix SQL, batch, and stream processing paradigms
Lightweight stream processing engine for IoT
A Go port of the Java Streams API. Type-safe and functional Go Streams processing
Machine is a workflow/pipeline library for processing data
Distributed batch data processing framework
Lightweight SQL-based stream processing engine for IoT edge.
Unlimited job queue for go, using a pool of concurrent workers processing the job queue entries
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.
A simple embeddable scripting language which supports concurrent event processing.
A light-weight package for in-app micro batch processing