Projects sharing features with EventStore

Rails Event Store is a library for implementing event sourcing and command query responsibility segregation patterns within Ruby applications. It functions as a framework for capturing all application state changes as an immutable sequence of events, providing a permanent and verifiable history of system operations. The library provides a messaging infrastructure that decouples business logic by broadcasting domain events through a central bus. This architecture allows for the execution of handlers either immediately or asynchronously, ensuring that heavy processing tasks do not block the pri

Livestore is a reactive state management framework that utilizes a local SQLite database to store and synchronize application data. It provides an event-sourced state store that processes typed events through materializer functions to derive and persist application state. The framework implements offline-first data synchronization using a push-pull engine and append-only event logs to maintain consistency between clients and servers. It includes a real-time presence system for tracking user activity and shared session status across connected clients. The system covers a broad capability surf

go-coffeeshop is an event-driven microservices architecture designed to manage the end-to-end lifecycle of customer orders. It coordinates independent services using asynchronous messaging patterns to handle business workflows, background processing, and order fulfillment tracking. The project utilizes a HashiCorp stack for infrastructure, employing Nomad, Consul, and Vault for service orchestration and secret storage. Infrastructure is managed through declarative automation using Terraform to ensure consistent and repeatable deployment of compute resources and networking. The system include

Kungfu is a quantitative trading development framework that provides a hybrid Python and C++ runtime. It is designed for building, testing, and executing mathematical trading models and algorithmic strategies. The system centers on a high-performance architecture featuring append-only event journaling and deterministic event replay. These capabilities allow recorded data streams to be reproduced using the same semantics as live execution for high-precision simulation. To minimize latency, the framework utilizes zero-copy cross-language memory sharing and schema-based data consistency to elimi

Mercure is an HTTP-based message broker and real-time pub/sub server that routes asynchronous data updates to authorized subscribers. It functions as a centralized hub that receives data via standard HTTP requests and broadcasts it to web clients using the Server-Sent Events protocol. The project distinguishes itself by replacing WebSockets with a unidirectional HTTP connection, leveraging HTTP/2 and HTTP/3 for multiplexed, low-latency delivery. It implements a secure access control layer using JSON Web Tokens and JSON Web Signatures to validate the identity of publishers and subscribers, and

Cube is a time-series analytics platform and event data store designed for real-time performance monitoring. It functions as a metrics engine that ingests timestamped event streams and persists raw logs to enable the computation of statistical summaries, quantiles, and histograms. The system distinguishes itself through a reactive processing model that automatically invalidates metric caches when new events arrive, ensuring query results remain current. It supports both real-time event streaming via persistent connections and the calculation of post hoc statistics from stored event sets. The

ag-ui is an agent-frontend interoperability layer and communication protocol designed to connect AI agent backends with web and mobile user interfaces. It provides a standardized event-driven framework for exchanging messages, session state, and tool calls, utilizing a generative UI framework to render dynamic interface components and structured content triggered by an agent. The project distinguishes itself through an SSE-based event streamer that delivers real-time incremental model responses and reasoning telemetry. It enables bi-directional state synchronization and allows remote agents t

This project is a reference implementation of domain-driven design patterns and a sample of command query responsibility segregation. It provides a collection of event-driven microservices that demonstrate the practical application of architectural principles for structuring complex software systems. The implementation separates read and write models through an event journal and organizes services into bounded contexts to maintain clear functional boundaries. It coordinates business logic by dispatching and consuming domain events to synchronize different modules. The project covers a range

This project is a cross-platform messaging client that implements a secure, real-time communication protocol. It provides a comprehensive development toolkit, including a database library and messaging SDK, which allows for the creation of custom messaging applications that maintain synchronized state across multiple devices. The core architecture relies on an asynchronous event-driven model to ensure responsive performance while managing persistent local database synchronization with server-side state. The client distinguishes itself through a robust end-to-end encryption layer that supports

Deepagents is an LLM agent orchestration platform and stateful application server designed for deploying and managing AI agents built with computational graphs. It provides a containerized runtime environment that handles agent execution, state persistence, and the versioning of AI assistants. The platform distinguishes itself through deep integration with the Model Context Protocol, allowing agents to function as servers that expose tools and capabilities to external clients. It features a sophisticated observability suite for capturing execution traces, performing LLM-based evaluations agai

Reaction is an event-driven, headless commerce platform designed to decouple backend business logic from the frontend presentation layer. It utilizes an API-first architecture with a GraphQL data layer to manage online sales and retail operations. The platform supports multi-tenant resource sharing, allowing multiple independent storefronts to be hosted and managed within a single installation. It features a plugin-based extension system that enables the integration of third-party services and custom business logic through composable workflows. The system covers core retail capabilities incl

ServiceStack is a high-performance .NET web framework designed for building type-safe APIs using strongly-typed request and response objects. It functions as a message-based API engine that decouples business logic from the transport layer, allowing services to be exposed via multiple protocols including HTTP, gRPC, and various message queue providers. The framework is distinguished by its type-safe API generator, which produces native client SDKs and data transfer objects from service metadata across multiple languages. It also includes a distributed service gateway for microservices orchest

php-amqplib is a PHP library that implements the AMQP protocol to enable communication between applications and message brokers. It provides the necessary tools to integrate PHP applications with RabbitMQ for sending and receiving messages across decoupled services. The library supports a wide range of messaging patterns, including asynchronous task processing, event-driven architectures, and remote procedure calls using correlation identifiers. It manages the full message lifecycle through publishing, queue declaration, and flexible consumption models using either push-based subscriptions or

RavenDB is a multi-model NoSQL document database designed for high-performance, ACID-compliant data storage. It persists structured information as schema-flexible JSON documents and utilizes a unit-of-work session pattern to track entity changes and batch modifications into atomic transactions. The platform is built on a distributed architecture that supports horizontal scaling through sharding and ensures high availability via multi-node, master-to-master cluster replication. The database distinguishes itself through a self-optimizing query engine that automatically creates and maintains ind

This repository provides a comprehensive library of code examples for implementing event-driven, serverless backend architectures. It serves as a practical guide for building scalable cloud-native applications that execute logic in isolated environments, triggered by infrastructure events or HTTP requests rather than persistent server processes. The collection demonstrates how to leverage managed infrastructure to automate backend workflows, including the use of asynchronous task queuing to maintain system stability during high traffic. It highlights patterns for secure API hosting, enabling

Hazelcast is a distributed data platform that combines an in-memory data grid with a stream processing engine to support real-time analytics and event-driven applications. It functions as a partitioned, distributed key-value store that replicates data across cluster nodes to provide low-latency access and high availability. The platform also serves as a distributed SQL query engine, allowing users to execute standard SQL statements against both in-memory datasets and external data sources. What distinguishes Hazelcast is its use of a distributed consensus subsystem to maintain strongly consis

EventBus is a publish-subscribe messaging library designed to facilitate decoupled communication between components in Java applications. It functions as a central hub where producers dispatch events that are routed to subscribers based on the class type of the payload. By using annotation-based markers, the system maps event handlers to specific data types, allowing different parts of an application to exchange information without requiring direct references between classes. The library distinguishes itself through a focus on performance and execution control. It utilizes a compile-time inde

The AWS Cloud Development Kit is an infrastructure-as-code framework that enables developers to define and provision cloud resources using familiar programming languages. By utilizing construct-based synthesis, it translates high-level, object-oriented code into declarative templates, allowing for the automated management of complex cloud environments through a centralized, code-driven control plane. The framework distinguishes itself through its ability to model infrastructure as a dependency-aware resource graph, ensuring that components are provisioned and updated in the correct order. It

This project is a Kubernetes operator designed for deploying and managing production PostgreSQL database clusters using declarative configurations. It functions as a controller that synchronizes the actual state of database clusters with a desired state, providing a system for high availability orchestration, automated backup and recovery, and containerized database administration. The operator distinguishes itself through a comprehensive data protection suite that supports point-in-time recovery, multi-mode backups to cloud object storage, and cluster cloning. It ensures continuous availabil

Mercury is a framework for transforming Jupyter notebooks into interactive web applications, a notebook execution API, and a static site generator. It functions as a self-hosted application server that allows users to deploy password-protected notebooks as functional user interfaces without writing frontend code. The system distinguishes itself by mapping notebook widgets to a reactive web interface and synchronizing live application sessions across multiple users in real time. It enables remote execution of notebooks via an API to retrieve computation results as structured data and supports

Elasticvue is a management user interface and graphical dashboard for Elasticsearch clusters. It serves as a cluster browser and administration tool, providing a visual way to monitor cluster health, manage indices, and browse documents without writing raw JSON. The project is delivered as a cross-platform application, available as a browser extension, a standalone desktop application, or a containerized web service via Docker. The interface covers cluster administration, including the management of shards, aliases, and snapshot repositories for backups. It also includes data exploration too

yacysearchserver is a decentralized indexing system and peer-to-peer search engine. It functions as a distributed web crawler and intranet search appliance that allows for the discovery and indexing of web content without reliance on a central authority. The project enables the creation of private search portals for indexing internal websites and file systems. It utilizes a peer-to-peer network to share search indices and distribute query routing across multiple server instances, scaling search results through decentralized index management. The system covers recursive web crawling, web co

This platform is a comprehensive, white-label software suite designed for launching and managing on-demand food delivery services. It provides a unified ecosystem that connects customers, restaurant staff, and delivery riders through integrated mobile and web interfaces, supported by a centralized backend infrastructure that synchronizes data and business logic across all user roles. The system distinguishes itself through its focus on self-hosted deployment, granting operators full control over their data, backups, and server environments. It supports multi-vertical business models, allowing

CAP is a .NET distributed transaction framework and event bus designed to manage asynchronous communication in microservices. It implements the outbox pattern to ensure eventual consistency and reliable message delivery by persisting messages in local database tables until transactions commit. The framework includes a distributed message monitor and web dashboard for tracking the status of sent and received messages. It provides tools for event traffic visualization, distributed request tracing, and the ability to manually trigger retries for failed delivery attempts. The system supports var

The .NET Reactive Extensions Library is a framework for composing, querying, and transforming asynchronous data streams. It provides a non-blocking implementation of the observer pattern to manage notifications and data flows between producers and consumers, functioning as an event stream processing library. The project applies LINQ-style querying and filtering operators to asynchronous sequences. This allows for the handling of event-driven programming patterns by utilizing composable operators to process notifications as they occur. The library covers asynchronous data streaming and non-bl

Vert.x is a reactive polyglot framework and asynchronous programming library for the Java Virtual Machine. It functions as an event-driven networking framework and toolkit for building non-blocking applications. The system enables the development of high-concurrency network services and event-driven microservices. It supports the creation of reactive services using multiple languages running on the JVM. The framework covers a wide range of capabilities including the management of HTTP and TCP network protocols, non-blocking file system access, and the integration of reactive clients.

This project is a collection of educational resources and step-by-step tutorials for Java backend development. It provides implementation guides for building web services and applications using the Spring Boot framework, focusing on the development of data streams and concurrent tasks. The repository includes technical walkthroughs for Kubernetes cluster automation, specifically regarding the creation of custom operators and admission controllers. It also serves as a manual for cloud native integration, covering the packaging of applications into containers and the use of distributed event me