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–19 of 19 · Most stars
Process execution for humans
- nodejs
- spawn
- exec
- spawned-processes
Your go-to microservice framework for any situation, from the creator of Netty et al. You can build any type of microservice leveraging your favorite technologies, including gRPC, Thrift, Kotlin, Retrofit, Reactive Streams, Spring Boot and Dropwizard.
A lightweight stream processing library for Go
The Scala HTTP client you always wanted!
- scala
- http
- httpclient
- interpolator
Node-core streams for userland
A networking framework that evolves with your application
- java
- reactive
- reactive-streams
- microservices
zerocode-tdd is a community-developed, free, open-source, outcome-driven automated testing framework for Data Pipelines, ETL, REST API, Kafka(Data Streams), Databases and Load scenarios. all defined in simple JSON or YAML — with zero coding.
- soap
- assertions
- java
- api
Apache StreamPipes - A self-service (Industrial) IoT toolbox to enable non-technical users to connect, analyze and explore IoT data streams.
Microservices library - scalecube-services is a high throughput, low latency reactive microservices library built to scale. It features: API-Gateways, service-discovery, service-load-balancing, the architecture supports plug-and-play service communication modules and features. built to provide performance and low-latency real-time stream-processing
- microservices
- reactive-streams
- distributed-systems
- service-mesh
Streaming reactive and dataflow graphs in Python
- python
- python3
- stream
- data-pipeline
SPX is a graphics control client for HTML and OGraf templates for live video productions and live streams using CasparCG, OBS, vMix, or similar software.
- casparcg
- client
- controller
- server
LittleHorse Server: Business-as-Code Platform for Microservices, Workflows, and Agents
Evented I/O streams for Swift
A stream that emits multiple other streams one after another (streams3)
- stream
- nodejs
- javascript
- multistream
Debug Vinyl file streams to see what files are run through your Gulp pipeline
akka http gremlin 3 websocket connector
- scala
- backpressure
- bulk-loader
- akka-streams
Deno KV file system, compatible with Deno deploy. Saves files in 64kb chunks. You can organize files into directories. You can control the KB/s rate for saving and reading files, rate limit, user space limit and limit concurrent operations, useful for controlling uploads/downloads. Makes use of Web Streams API.
Typed, zero-dependency CSV parser and encoder for TypeScript. Streams with flat memory and runs on Node, browsers, Deno, Bun, and edge.