Awesome GitHub RepositoriesReal-time Data Subscriptions

graphql-engine is an automated GraphQL API engine that transforms database tables and relationships into a queryable GraphQL schema. It functions as a federation gateway and mapper, instantly generating APIs with built-in filtering, pagination, and mutations from existing databases and remote schemas. The project distinguishes itself through a fine-grained access control layer that enforces row-level and field-level permissions. It further provides a real-time data subscription server that converts standard queries into live streams and a system for triggering event-driven webhooks and notifi

RethinkDB is a distributed, document-oriented database designed to store and manage JSON-formatted data across scalable clusters. It utilizes a custom log-structured storage engine with B-Tree indexing to ensure high-performance disk I/O and data persistence. The system maintains high availability through automatic sharding and replication, employing a primary-replica voting consensus mechanism to handle node failures and ensure consistent cluster operations. A defining characteristic of the platform is its reactive changefeed engine, which allows applications to subscribe to live data update

Telegraf is a modular, cross-platform telemetry pipeline designed to collect, process, and route metrics from diverse infrastructure, applications, and hardware. It functions as a server-side middleware that normalizes heterogeneous data into a unified format, enabling consistent monitoring across complex environments. By utilizing a plugin-driven architecture, the agent manages the entire lifecycle of telemetry data from initial ingestion to final transmission. The project distinguishes itself through a declarative, configuration-driven execution model that allows users to define complex dat

Dexie.js is a wrapper library for IndexedDB that provides a simplified interface for managing and querying structured data within the browser. It functions as a browser database manager used to maintain persistent application state and store binary blobs and records. The project serves as an offline-first data store that synchronizes browser data with remote servers to maintain consistency across sessions. It also acts as a reactive database store by monitoring data changes in real time to trigger automatic user interface updates, and functions as a client-side search engine for indexing and

AI-Trader is a framework for managing autonomous trading agents and executing simulated financial operations. It provides a structured environment for registering and authenticating agents, tracking their reputation, and managing simulated capital balances within a competitive market ecosystem. The platform distinguishes itself through integrated social trading and collaborative investment capabilities. Users can follow experienced participants to automatically mirror their market positions, or organize into teams to execute shared strategies, vote on collective investment proposals, and comp

Dice is a low-latency key-value store based on Valkey that functions as a hierarchical storage engine. It combines a high-speed memory store with a tiered cache system to manage data across multiple storage levels. The system extends memory capacity by implementing a disk-backed cache that automatically persists evicted items to disk and restores them during cache misses. This storage tiering balances retrieval speed and operational cost by distributing data between fast memory and slower disk storage. The engine includes a query subscription service that monitors specific data patterns and

DiceDB is a distributed cache manager and hierarchical storage engine based on a Valkey key-value store. It functions as a high-availability key-value cluster that balances performance and cost by distributing data across memory and disk tiers. The system supports working sets larger than available RAM by persisting evicted keys to disk and restoring them on demand. It also includes a real-time query subscription system that notifies clients when data matching specific criteria is updated. The project provides distributed cache coordination through master node health monitoring and quorum-ba

gqlgen is a schema-first Go library designed to build type-safe GraphQL servers. It functions as a code generation engine that transforms declarative GraphQL schema definitions into strongly-typed Go source code, ensuring strict alignment between the API contract and the underlying implementation. The framework distinguishes itself through its deep integration with the Go type system and its highly extensible build pipeline. By using schema-first development, it automates the creation of server boilerplate and resolver stubs, allowing developers to map schema fields directly to Go structs and

AI Town is a TypeScript-based simulation engine used to create virtual environments where autonomous characters interact and socialize. It functions as a framework for orchestrating multiple AI agents within a persistent digital world, utilizing language models and a game engine to drive character behavior and social interactions. The project differentiates itself through a dedicated agent sandbox and a vector database agent store, which allow for the management of agent memories and world state. It integrates generative AI for background music and provides tools for simulation world design,

RisingWave is a cloud-native streaming database and real-time analytics engine that uses standard SQL to process continuous data streams. It functions as a streaming data lakehouse, combining the capabilities of a streaming SQL database with a platform that integrates streaming ingestion with open table formats. The system is distinguished by its use of the PostgreSQL wire protocol, allowing it to integrate with existing SQL tools and drivers. It employs a decoupled compute and storage architecture, persisting streaming state and materialized views in cloud object storage to enable independen

Horizon is a realtime API server and RethinkDB backend designed to push database changes instantly to front-end clients. It utilizes a WebSocket data streaming API to synchronize data between the database and user interfaces without requiring manual polling. The project integrates an OAuth identity manager for verifying user identities through third-party providers and a role-based access control system to define granular permissions for viewing or modifying database documents. It is delivered as a containerized backend framework, allowing the server and its dependencies to be deployed as a p

Vue Apollo is a GraphQL integration library for Vue applications that connects Vue components to GraphQL APIs using Apollo Client. It provides a reactive data layer for querying, mutating, and subscribing to data from GraphQL endpoints, with automatic cache updates and real-time subscription support. The library offers multiple API surfaces for working with GraphQL data, including slot-based declarative components, composable functions for the Composition API, and Options API integration. It handles the full lifecycle of GraphQL operations, from automatic data fetching with reactive queries t

هذا المشروع عبارة عن مكتبة عميل JavaScript و SDK للتفاعل مع Notion REST API. يوفر طرقاً وأدوات مكتوبة (typed) لإدارة الصفحات وقواعد البيانات وموارد مساحة العمل برمجياً داخل بيئة Notion. تتضمن SDK أدوات لتنفيذ تدفقات تفويض OAuth 2.0 لمنح تطبيقات الطرف الثالث الوصول إلى محتوى مساحة العمل. تتميز بآليات للتعامل مع التصفح القائم على المؤشر عبر المكررات غير المتزامنة وتنفذ عمليات إعادة المحاولة مع التراجع الأسي لإدارة حدود المعدل وأخطاء الخادم العابرة. تغطي المكتبة مجموعة واسعة من القدرات، بما في ذلك إدارة مخطط قاعدة البيانات، ومزامنة محتوى الصفحة، ورفع أصول الوسائط. كما توفر دعماً لاسترجاع ملف تعريف المستخدم، واشتراكات الأحداث في الوقت الفعلي عبر خطافات الويب، والتحقق من صحة الاستجابة الآمنة للنوع باستخدام حراس نوع TypeScript.

ShareJS هي قاعدة بيانات مستندات تعاونية ومحرك مزامنة مصمم لإدارة الحالة المشتركة في الوقت الفعلي. توفر محرك مزامنة التحويل التشغيلي لتمكين التحرير المتزامن لبيانات النص العادي وJSON، وواجهة برمجة تطبيقات RESTful للمزامنة لإدارة حالات المستندات عبر HTTP. يتميز النظام بطبقة مزامنة بيانات تعتمد على وضع عدم الاتصال أولاً (offline-first) تقوم بوضع التعديلات المحلية في قائمة انتظار أثناء قطع الاتصال وتدفع التعديلات تلقائياً عند إعادة الاتصال. كما يتضمن طبقة تحكم في الوصول للوسيط تعترض طلبات قاعدة البيانات لفرض سياسات الأمان وإعادة كتابة الطلبات. تغطي المنصة مجموعة واسعة من الإمكانيات بما في ذلك اشتراكات الاستعلام المباشر، وإشعارات التغيير في الوقت الفعلي، ومزامنة المحتوى المتزامن. تسمح هذه المكونات بإنشاء خلاصات بيانات حيث يتم إخطار العملاء فوراً عند تحديث المستندات الخلفية التي تطابق استعلامات معينة.

FluidFramework هو إطار عمل للتعاون في الوقت الفعلي ومحرك لمزامنة الحالة الموزعة. يوفر مكتبة نموذج بيانات تعاونية ونظام مستندات متزامن سحابيًا مصمم لنسخ هياكل البيانات عبر العملاء المتصلين باستخدام عمليات مرتبة لضمان الاتساق النهائي. يستخدم إطار العمل بنية ترحيل بين العميل والخادم لتوجيه العمليات واستمراريتها دون الحاجة إلى منطق عمل مخصص من جانب الخادم. يدير دورة حياة جلسات التعاون من خلال حاويات بيانات مشتركة وينفذ استراتيجيات حل التعارضات، مثل "آخر كاتب يفوز"، جنبًا إلى جنب مع آليات التحديث المتفائل للحفاظ على تجربة مستخدم سريعة الاستجابة. تغطي مجالات القدرات مزامنة البيانات الهرمية، وأزواج المفتاح والقيمة، وتحرير النصوص في الوقت الفعلي. يتضمن النظام آليات لتنسيق الإجراءات الحصرية، واشتراكات الحالة في الوقت الفعلي لتحديثات واجهة المستخدم، وإدارة المستندات السحابية المتكاملة لتخزين بيانات التطبيق على منصات المؤسسات. يتضمن المشروع محاكاة خدمة محلية لنماذج أولية للميزات التعاونية دون الحاجة إلى نشر سحابي.

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

async-graphql is a type-safe framework for building specification-compliant GraphQL servers in Rust. It uses procedural macros to automatically generate schemas from native language structures, ensuring consistency between the data model and the API specification. The project provides native support for Apollo Federation v2, allowing entities and fields to be shared and resolved across multiple distributed subgraphs. It also implements real-time data streaming via WebSocket subscriptions and asynchronous event streams. The framework includes a wide array of capabilities for schema design, su

Pothos is a code-first GraphQL schema builder and framework designed for type-safe development. It allows developers to construct schemas using typed definitions in TypeScript, eliminating the need for external code generation steps. The framework distinguishes itself through a dedicated data mapper that connects GraphQL types to relational databases and ORMs, such as Prisma, while optimizing query resolution. It provides a full implementation of the Relay specification, including global object identification and cursor-based pagination. The project covers several core capability areas, incl

This project is an interactive educational platform and comprehensive curriculum designed to teach developers how to build, query, and integrate GraphQL APIs into full-stack applications. It provides a structured learning environment for mastering core concepts such as schema design, query execution, and the implementation of data-driven interfaces. The platform distinguishes itself by focusing on the practical application of real-time data synchronization and backend architecture. It guides users through the process of connecting frontend frameworks to relational databases, implementing role