Awesome GitHub RepositoriesReal-Time Event Processing

Pomelo is a distributed Node.js game server framework designed for building scalable multiplayer game backends and real-time web applications. It employs a multi-process architecture to distribute application logic horizontally across a cluster of machines, enabling high concurrency and balanced network traffic. The framework utilizes a WebSocket communication layer to manage bidirectional data exchange between diverse web clients and server clusters. It incorporates a remote procedure call system for triggering functions across remote server processes and uses Protocol Buffers for binary ser

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

Rx.NET is a reactive programming framework and library for the .NET ecosystem used to compose asynchronous and event-based programs. It provides an observable data stream API that treats live sequences of information as collections, allowing developers to coordinate asynchronous event workflows using a declarative syntax. The project functions as an extension of language integrated query patterns to asynchronous streams. This allows for the filtering and transformation of asynchronous notifications and event sequences through the application of query operators. The framework covers asynchron

Faust is a Python library for building distributed stream processing applications that integrate with Kafka. It functions as an asynchronous stream processor designed to handle high-throughput event streams and real-time data analysis using asynchronous functions. The system operates as a distributed stream processor and state store, utilizing sharding and partitioned topics to scale processing workloads horizontally across multiple worker nodes. It maintains state through a replicated key-value storage system backed by local databases to ensure high availability and fast recovery. The frame

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

This project is a business rules management system and rule engine designed to define, execute, and manage complex business logic decoupled from application source code. It provides a business logic compiler that transforms human-readable rule definitions into executable models for high-performance runtime evaluation. The system includes a complex event processing engine for analyzing real-time data streams to identify temporal patterns and a decision model and notation executor that processes structured logic based on industry standards for deterministic results. It utilizes an inference eng

OpenPanel is a self-hosted product analytics platform designed for tracking user behavior and visualizing product metrics on private infrastructure. It provides a comprehensive system for collecting events across web, mobile, and server environments while ensuring complete ownership of data. The platform distinguishes itself through a privacy-first approach, utilizing cookieless event tracking and regional data residency to simplify regulatory compliance. It integrates large language models via the Model Context Protocol, enabling users to query behavioral data and analyze trends using natura

CameraView هي مكتبة كاميرا Android عالية المستوى وغلاف للأجهزة مصمم لالتقاط الصور ومقاطع الفيديو. توفر طبقة تجريد لإدارة أجهزة الكاميرا و API لالتقاط الوسائط لتسجيل فيديو عالي الدقة وصور RAW بمعدلات بت ودقة قابلة للتكوين. يتميز المشروع بإطار عمل لمرشحات الكاميرا في الوقت الفعلي ومدير معاينة. تسمح هذه الأنظمة بتطبيق تظليل مخصص وتأثيرات مرئية على تدفقات الكاميرا الحية وعرض المعاينات بنسب عرض إلى ارتفاع قابلة للتخصيص، وتراكبات، وشبكات تكوين. تغطي المكتبة مجموعة واسعة من عناصر التحكم في الأجهزة، بما في ذلك اختيار المستشعر، والتكبير، والتعرض، والتركيز التلقائي. كما تدير مهام معالجة الوسائط مثل تسلسل المرشحات، والعلامات المائية الرسومية، وتضمين بيانات الموقع الجغرافي الوصفية في بيانات EXIF. تتضمن مجموعة الأدوات نظاماً لطلب وإدارة أذونات نظام Android اللازمة المطلوبة لتهيئة أجهزة الكاميرا.

CliWrap is an asynchronous process manager and child process wrapper library used to execute external commands and integrate command line interfaces into applications. It provides a framework for launching external programs using asynchronous patterns, managing child processes, and validating exit codes. The library distinguishes itself through its ability to route standard input, output, and error streams to memory buffers or real-time event streams. It enables real-time monitoring of process output lines and supports process termination via cancellation tokens. The project covers a broad r

GPUImage2 هو إطار عمل Swift لتطبيق المرشحات والتأثيرات في الوقت الفعلي على الصور والفيديو باستخدام GPU. يوفر مكتبة مرشحات فيديو في الوقت الفعلي، ومحرك معالجة هندسة الصور، وخط أنابيب تظليل OpenGL لمعالجة البيانات المرئية على أجهزة الرسومات. يمكن إطار العمل من بناء خطوط أنابيب التأثيرات المرئية عن طريق ربط مصادر الصور بالمستهلكين في تدفقات متسلسلة. يدعم تطوير تظليلات الأجزاء والرؤوس المخصصة لمعالجة الصور المخصصة ويوفر القدرة على تجميع هذه العمليات في وحدات قابلة لإعادة الاستخدام عبر التجميع القائم على الرسم البياني. تشمل مجالات القدرات ضبط الألوان، والمعالجة الهندسية، وإنشاء الصور الاصطناعية. يدعم النظام أيضاً طبقات الصور المركبة، مما يسمح بدمج مصادر صور متعددة باستخدام مزج الشفافية (alpha blending) ومفتاح الكروما (chroma keying).

Appium Desktop هي واجهة مستخدم رسومية لتهيئة وإدارة خادم Appium لأتمتة اختبارات تطبيقات الأجهزة المحمولة. تعمل كمدير أتمتة عبر المنصات للتحكم في الجلسات عبر أنظمة تشغيل الأجهزة المحمولة ومزودي السحابة المختلفين. يتضمن التطبيق مفتش تطبيقات الأجهزة المحمولة لتحليل أشجار مصادر التطبيقات وتحديد سمات العناصر، إلى جانب مسجل نصوص الاختبار الذي يلتقط تفاعلات المستخدم لإنشاء كود الأتمتة. تغطي الأداة إدارة الخادم والتحكم في دورة الحياة، مما يسمح بإدارة تكوينات الشبكة ومتغيرات البيئة من خلال إعدادات مسبقة محفوظة. وتوفر القابلية للملاحظة عبر مراقبة سجل الخادم في الوقت الفعلي وقدرات إدارة الجلسة لتهيئة جلسات جديدة أو الإرفاق بجلسات موجودة. كما تسهل الاتصال بمنصات اختبار السحابة عن بُعد.

Jitsu is an open-source customer data platform designed to orchestrate event data pipelines. It captures, transforms, and routes behavioral data from web and server sources into data warehouses and analytics tools, providing a unified infrastructure for managing event streams. The platform distinguishes itself through its focus on self-hosted, containerized operations that grant users full control over their data security and privacy. It features a robust identity resolution engine that stitches disparate user identifiers into persistent profiles across sessions and devices, alongside program

Tetragon هي مجموعة أدوات أمنية ومراقبة تعتمد على eBPF مصممة لبيئات Linux وKubernetes. تعمل كمدير لسياسات الأمان، وعميل للمراقبة، ومحرك لفرض القواعد، حيث ترتبط بوظائف النواة (Kernel functions) ونقاط التتبع لاكتشاف تصعيد الامتيازات، وهروب الحاويات، والأنشطة غير المصرح بها في النظام. يتميز المشروع بقدرته على فرض القواعد في الوقت الفعلي داخل النواة، مما يسمح بإنهاء العمليات الضارة بشكل متزامن أو تعديل قيم إرجاع الوظائف قبل اكتمال استدعاء النظام. يوفر تكاملاً عميقاً مع Kubernetes من خلال مزامنة هويات الحاويات وربط أحداث النواة منخفضة المستوى مباشرة بـ Pods وNamespaces. تغطي قدراته الأوسع تدقيق استدعاءات النظام الشامل، وتتبع اتصالات الشبكة، ومراقبة سلامة الملفات. يدعم النظام إدارة السياسات الديناميكية ويوفر أدوات تشخيصية لمراقبة أداء BPF واستخدام الموارد. يتم دعم النشر عبر مجموعات Kubernetes باستخدام Helm charts، بالإضافة إلى الحاويات المستقلة وحزم أنظمة التشغيل الأصلية.

pyalgotrade is a Python algorithmic trading library designed for developing, backtesting, and executing automated trading strategies. It provides a comprehensive framework for financial strategy backtesting, a technical analysis library for computing mathematical indicators, and connectors for cryptocurrency exchange integration. The project distinguishes itself by supporting sentiment-based trading through the integration of real-time social media feeds and keyword streams. It features a quantitative trading visualization tool for plotting price action and portfolio equity curves, along with

ogl هي مكتبة رسومات WebGL ومحرك رسم بياني للمشاهد ثلاثية الأبعاد مصمم لعرض المشاهد ثلاثية الأبعاد. توفر إطار عمل خفيف الوزن لإدارة الهندسة وتنسيق التحويلات المكانية داخل نظام هرمي. يتضمن المشروع نظام تظليل PBR لإنشاء مواد واقعية وإطار عمل حسابي GPGPU لإجراء عمليات حسابية عامة واسعة النطاق ومحاكاة الجسيمات على معالج الرسومات. كما يتميز بمجموعة معالجة لاحقة لتطبيق مرشحات مرئية على المشاهد المعروضة عبر مخازن الإطارات (frame buffers). تغطي المكتبة إمكانيات أوسع بما في ذلك عمليات الرياضيات ثلاثية الأبعاد، واستيراد وتحريك الأصول ثلاثية الأبعاد، وتفاعل المستخدم من خلال تقنيات raycasting وعناصر التحكم في الكاميرا.

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

Riemann is a Clojure-based event stream processor and real-time analytics engine. It functions as a network telemetry pipeline and extensible event router that ingests, transforms, and routes event data from distributed systems. The system uses a domain-specific language to compute metrics and statistical patterns over continuous streams, enabling network trend analysis and real-time alerting. It supports dynamic plugin loading from the classpath and allows for live configuration reloading without interrupting active event streams. Capabilities include centralized telemetry aggregation, even

هذا المستودع عبارة عن مجموعة من تطبيقات العينة ومشاريع المرجع لدمج واجهات برمجة تطبيقات تعلم الآلة على الجهاز في تطبيقات الهاتف المحمول. يوفر أمثلة تنفيذ لكل من Android و iOS، مما يوضح كيفية تضمين نماذج رؤية الكمبيوتر ومعالجة اللغات الطبيعية. يغطي المشروع تنفيذ رؤية الكمبيوتر على الهاتف المحمول، بما في ذلك التعرف على النص، واكتشاف الوجه، ومسح الباركود. يتضمن سير عمل لمعالجة الصور في الوقت الفعلي وتكامل النماذج المدربة مسبقاً التي تعالج البيانات محلياً على الجهاز.

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