.svg){kind=icon}
emailCloud-native stream processing. Distributed stream processing engine in Rust.
Transform, filter, aggregate, and join data streams by writing SQL, with sub-second results.
Scale from zero to millions of events per second.
Arroyo is a distributed stream processing engine written in Rust, designed to efficiently perform stateful computations on streams of data. Unlike traditional batch processing, streaming engines can operate on both bounded and unbounded sources, emitting results as soon as they are available.
Related contents:
Reactive Extensions Library for JavaScript.
RxJS is a library for composing asynchronous and event-based programs by using observable sequences. It provides one core type, the Observable, satellite types (Observer, Schedulers, Subjects) and operators inspired by Array methods (map, filter, reduce, every, etc) to allow handling asynchronous events as collections.
Related contents:
Debezium is an open source distributed platform for change data capture. Start it up, point it at your databases, and your apps can start responding to all of the inserts, updates, and deletes that other apps commit to your databases. Debezium is durable and fast, so your apps can respond quickly and never miss an event, even when things go wrong.
Related contents:
Open-source framework for building asynchronous web services that interact with event streams.
FastStream is a powerful and easy-to-use Python framework for building asynchronous services interacting with event streams such as Apache Kafka, RabbitMQ, NATS and Redis.
Signals and Slots library for PHP.
Signals and slots is a mechanism introduced in Qt for communication between objects. It makes it easy to implement the observer pattern while avoiding boilerplate code. Siglot aims to provide similar features for the PHP language, with particular attention to Developer Experience (DX).
Open Source Declarative Data Orchestration. Event-Driven Declarative Orchestrator.
Infinitely scalable, event-driven, language-agnostic orchestration and scheduling platform to manage millions of workflows declaratively in code.
Kestra is a universal open-source orchestrator that makes both scheduled and event-driven workflows easy. By bringing Infrastructure as Code best practices to data, process, and microservice orchestration, you can build reliable workflows and manage them with confidence.
An API for asynchronous programming with observable streams.
ReactiveX is a combination of the best ideas from
the Observer pattern, the Iterator pattern, and functional programming.
A reliable Event Gateway for event-driven applications. A reliable event gateway for asynchronous applications. Receive events (e.g. webhooks) in your development environment
Receive, process, and deliver messages across your event-driven architecture with Hookdeck's platform for engineering teams.
Using the Hookdeck CLI, you can forward your events (e.g. webhooks) to your local web server with unlimited free and permanent event URLs. Your event history is preserved between sessions and can be viewed, replayed, or used for testing by you and your teammates.
Simplebus is a organization that helps you to use CQRS and event sourcing in your application. Get started by reading more about these concepts LINK or by digging in to common use cases LINK.
Coroutines Async Programming Framework. High Performance Programmatic Server for PHP with Async IO, Coroutines and Fibers
Build high-performance, scalable, concurrent TCP, UDP, Unix Socket, HTTP, WebSocket services with PHP and easy to use coroutine, fibers API.
Event-driven, non-blocking I/O with PHP.
ReactPHP is a low-level library for event-driven programming in PHP. At its core is an event loop, on top of which it provides low-level utilities, such as: Streams abstraction, async DNS resolver, network client/server, HTTP client/server and interaction with processes. Third-party libraries can use these components to create async network clients/servers and more.
The Distributed Application Runtime (Dapr) provides APIs that simplify microservice connectivity. Whether your communication pattern is service to service invocation or pub/sub messaging, Dapr helps you write resilient and secured microservices.
Dapr is a portable, event-driven, runtime for building distributed applications across cloud and edge.