An open-source engine that turns continuous content streams into search and monitoring. Durable ingestion, hybrid search, alerts, and plugins for formats, models and business rules.
Repository Index
47,133 repositories indexed
1–23 of 23 · Most stars
A high-performance observability data pipeline.
- logs
- metrics
- observability
- forwarder
Logstash - transport and process your logs, events, or other data
StreamAlert is a serverless, realtime data analysis framework which empowers you to ingest, analyze, and alert on data from any environment, using datasources and alerting logic you define.
- security
- kinesis
- serverless
- terraform
🦎 A lightweight, streaming-native, multi-protocol gateway for AI, APIs, and real-time data. Route LLM requests across providers, govern MCP tools, and connect Kafka, MQTT, and HTTP through one high-performance engine with shared security and observability.
The Scala HTTP client you always wanted!
- scala
- http
- httpclient
- interpolator
pmacct is a small set of multi-purpose passive network monitoring tools [NetFlow IPFIX sFlow libpcap BGP BMP RPKI IGP Streaming Telemetry].
- netflow
- ipfix
- sflow
- bgp
Real-time monitoring of audio-over-IP streams, supporting AES67, RAVENNA, and ST2110-30 standards for live sound, studio, and broadcast applications.
- aes67
- dante
- aoip
- audio
OpenMessaging Specification
- queue
- transaction
- pull
- push
Cloud-native continuous backup for PostgreSQL - WAL/base-backup streaming, compression, encryption, retention, and monitoring in a single binary.
Daggy - Data Aggregation Utility and C/C++ developer library for data streams catching
- serverless-framework
- streaming
- stream-processing
- qt
Ada Utility Library - Composing streams, processes, logs, serialization, encoders and more
- logging
- process
- streams
- serializer
Realistic synthetic events for testing, demos, and pipelines — streamed live or generated in bulk
- clickhouse
- data-engineering
- data-generation
- devops
CLI tool to monitor downstream load on DOCSIS cable networks
- docsis
- load-monitoring
- awk-script
- tc4400
Elixir library to log custom application metrics, in a well-structured, human and machine readable format, for use by downstream log processing systems (Librato, Reimann, etc...)
- elixir
- metrics
- librato
☝️ go-graphql subscription over Kafka/Redis/NSQ example
The complete toolkit for building AI agents in JavaScript. Lightweight core, React & Terminal UIs, autonomous runtime, tools, skills, memory, RAG and observability. Plug-and-play from chat UI to full agents.
Output metrics from K6 to AWS Timestream
- k6
- k6-extension
- k6-output
- timestream
A common lisp logging library providing context sensitive logging of more than just strings to more than just local files / output streams
Vert.x implementation of a Hystrix Events Metrics Stream
A set of C# libraries for streamlined microservice development: audit, caching, outbox, CAP, MassTransit (events & config), idempotency, specifications, security, and other useful utilities. Packages: https://www.nuget.org/profiles/dex
- at-least-once
- audit
- cache-control
- cap
A production-grade messaging abstraction for Go. It provides a unified API to decouple business logic from various brokers including Kafka, RabbitMQ, RocketMQ, NATS, Redis, and AWS SQS. Featuring built-in OpenTelemetry integration and engineered for high reliability.
Production-grade Server-Sent Events (SSE) for Fiber v3. Event coalescing, priority lanes, topic wildcards, adaptive throttling, built-in auth, Prometheus metrics, graceful drain.
- event-streaming
- fasthttp
- fiber
- gofiber