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 ist eine hochgradige Android-Kamerabibliothek und ein Hardware-Wrapper für die Aufnahme von Fotos und Videos. Sie bietet eine Abstraktionsschicht für das Management der Kamerahardware und eine Media-Capture-API für die Aufnahme von hochauflösenden Videos und RAW-Fotos mit konfigurierbaren Bitraten und Auflösungen. Das Projekt verfügt über ein Echtzeit-Kamerafilter-Framework und einen Preview-Manager. Diese Systeme ermöglichen die Anwendung benutzerdefinierter Shader und visueller Effekte auf Live-Kamerastreams sowie das Rendern von Previews mit anpassbaren Seitenverhältnissen, Overlays und Kompositionsrastern. Die Bibliothek deckt eine breite Palette an Hardware-Steuerungen ab, einschließlich Sensorauswahl, Zoom, Belichtung und Autofokus. Sie verwaltet zudem Medienverarbeitungsaufgaben wie Filter-Chaining, grafisches Watermarking und das Einbetten von geografischen Standortmetadaten in EXIF-Daten. Das Toolkit enthält ein System zum Anfordern und Verwalten der notwendigen Android-Systemberechtigungen, die für die Initialisierung der Kamerahardware erforderlich sind.

CliWrap ist eine asynchrone Prozess-Manager- und Wrapper-Bibliothek für Kindprozesse, mit der externe Befehle ausgeführt und Command-Line-Interfaces in Anwendungen integriert werden können. Sie bietet ein Framework zum Starten externer Programme mittels asynchroner Muster, zur Verwaltung von Kindprozessen und zur Validierung von Exit-Codes. Die Bibliothek zeichnet sich dadurch aus, dass sie Standard-Input-, Output- und Error-Streams an Speicherpuffer oder Echtzeit-Event-Streams weiterleiten kann. Sie ermöglicht die Echtzeit-Überwachung von Prozess-Output-Zeilen und unterstützt das Beenden von Prozessen über Cancellation-Tokens. Das Projekt deckt ein breites Spektrum an Funktionen für das externe Prozessmanagement ab, einschließlich der Konfiguration von Umgebungsvariablen, der Umleitung von Standard-Streams und der Erfassung von Prozess-Output zur weiteren Verwendung als Daten innerhalb einer Anwendung.

GPUImage2 ist ein Swift-Framework für die Anwendung von Echtzeit-Filtern und Effekten auf Bilder und Videos unter Verwendung der GPU. Es bietet eine Echtzeit-Videofilter-Bibliothek, eine Engine für Bildgeometrie-Manipulation und eine OpenGL-Shading-Pipeline zur Verarbeitung visueller Daten auf Grafikhardware. Das Framework ermöglicht die Konstruktion von visuellen Effekt-Pipelines durch das Verketten von Bildquellen zu Konsumenten in sequentiellen Abläufen. Es unterstützt die Entwicklung benutzerdefinierter Fragment- und Vertex-Shader für maßgeschneiderte Bildverarbeitung und bietet die Möglichkeit, diese Operationen in wiederverwendbaren Einheiten über graphbasierte Gruppierung zu bündeln. Kompetenzbereiche umfassen Farbanpassung, geometrische Manipulation und die Generierung synthetischer Bilder. Das System unterstützt zudem Composite-Image-Layering, wodurch mehrere Bildquellen unter Verwendung von Alpha-Blending und Chroma-Keying kombiniert werden können.

Appium Desktop ist eine grafische Benutzeroberfläche zum Konfigurieren und Verwalten eines Appium-Servers zur Automatisierung von Tests mobiler Anwendungen. Er dient als plattformübergreifender Automatisierungsmanager zur Steuerung von Sitzungen über verschiedene mobile Betriebssysteme und Cloud-Anbieter hinweg. Die Anwendung enthält einen Mobile-App-Inspektor zur Analyse von Anwendungs-Quellbäumen und zur Identifizierung von Elementattributen, neben einem Test-Skript-Rekorder, der Benutzerinteraktionen erfasst, um Automatisierungscode zu generieren. Das Tool deckt Serveradministration und Lifecycle-Kontrolle ab, was die Verwaltung von Netzwerkkonfigurationen und Umgebungsvariablen über gespeicherte Presets ermöglicht. Es bietet Observability durch Echtzeit-Server-Log-Monitoring und Sitzungsmanagement-Funktionen, um neue Sitzungen zu initialisieren oder an bestehende anzuknüpfen. Zudem erleichtert es die Konnektivität zu Remote-Cloud-Testplattformen.

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 ist ein auf eBPF basierendes Toolset für Laufzeitsicherheit und Observability, das für Linux- und Kubernetes-Umgebungen entwickelt wurde. Es fungiert als Security-Policy-Manager, Observability-Agent und Enforcement-Engine, die sich in Kernel-Funktionen und Tracepoints einklinkt, um Privilegieneskalationen, Container-Ausbrüche und unbefugte Systemaktivitäten zu erkennen. Das Projekt zeichnet sich durch seine Fähigkeit zur Echtzeit-Durchsetzung auf Kernel-Ebene aus, wodurch bösartige Prozesse synchron beendet oder Rückgabewerte von Funktionen noch vor Abschluss eines Systemaufrufs modifiziert werden können. Es bietet eine tiefe Kubernetes-Integration durch die Synchronisierung von Container-Identitäten und die direkte Zuordnung von Low-Level-Kernel-Ereignissen zu Pods und Namespaces. Die weiteren Funktionen umfassen eine umfassende Systemaufruf-Prüfung (Auditing), die Verfolgung von Netzwerkverbindungen und die Überwachung der Dateiintegrität. Das System unterstützt ein dynamisches Policy-Management und bietet Diagnosetools zur Überwachung der BPF-Performance und Ressourcennutzung. Das Deployment wird in Kubernetes-Clustern über Helm-Charts sowie durch eigenständige Container und native Betriebssystempakete unterstützt.

pyalgotrade ist eine Python-Bibliothek für algorithmischen Handel, die für die Entwicklung, das Backtesting und die Ausführung automatisierter Handelsstrategien konzipiert ist. Sie bietet ein umfassendes Framework für das Backtesting von Finanzstrategien, eine Bibliothek für technische Analyse zur Berechnung mathematischer Indikatoren sowie Konnektoren für die Integration von Kryptobörsen. Das Projekt zeichnet sich durch die Unterstützung von sentimentbasiertem Handel durch die Integration von Social-Media-Feeds und Keyword-Streams in Echtzeit aus. Es bietet ein Visualisierungstool für quantitativen Handel zum Plotten von Preisverläufen und Portfolio-Equity-Kurven sowie parallele Parameteroptimierung zur Identifizierung der effektivsten Strategieeinstellungen. Die Bibliothek deckt ein breites Spektrum an Funktionen ab, darunter den Aufbau von Finanzdaten-Pipelines für die Aufnahme und Resampling von Marktdaten, das Order-Lifecycle-Management für Live- und Paper-Trading sowie quantitative Performance-Analysen zur Berechnung risikoadjustierter Renditen und Drawdowns. Sie enthält zudem Tools für technische Analysen, wie Volatilitätsbänder und Momentum-Indikatoren, sowie Simulationen, die Order-Slippage und Transaktionsgebühren berücksichtigen.

ogl ist eine WebGL-Grafikbibliothek und 3D-Szenengraph-Engine für das Rendern dreidimensionaler Szenen. Sie bietet ein leichtgewichtiges Framework zur Verwaltung von Geometrien und zur Koordination räumlicher Transformationen innerhalb eines hierarchischen Systems. Das Projekt umfasst ein PBR-Shader-System zur Erstellung realistischer Materialien und ein GPGPU-Berechnungs-Framework für die Durchführung groß angelegter Allzweckberechnungen und Partikelsimulationen auf dem Grafikprozessor. Zudem bietet es eine Post-Processing-Suite zur Anwendung visueller Filter auf gerenderte Szenen mittels Frame-Buffern. Die Bibliothek deckt umfassendere Funktionen ab, darunter 3D-Mathematikoperationen, den Import und die Animation von 3D-Assets sowie Benutzerinteraktion durch Raycasting und Kamerasteuerung.

Imageflow is a high-performance image manipulation library and composition engine available as a C-compatible library, a command-line image processor, and a dynamic image processing server. It provides the means to decode, encode, and apply complex visual transformations to images through programmatic interfaces, JSON job files, or on-the-fly URL query strings. The system distinguishes itself through a graph-based processing pipeline that allows for single-pass multi-format encoding, generating multiple image sizes and formats from a single decode to reduce overhead. It further features a res

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

This repository is a collection of sample applications and reference projects for integrating on-device machine learning APIs into mobile applications. It provides implementation examples for both Android and iOS, demonstrating how to embed computer vision and natural language processing models. The project covers the implementation of mobile computer vision, including text recognition, face detection, and barcode scanning. It includes workflows for real-time image processing and the integration of pre-trained models that process data locally on the device.

SwiftBar ist ein macOS-Menüleisten-Anpassungstool und ein Plugin-basierter Statusmonitor, der die Ausgabe ausführbarer Skripte und Shell-Befehle direkt in der System-Menüleiste anzeigt. Es fungiert als Shell-Skript-Dashboard, das Echtzeitdaten und Skriptergebnisse als interaktive Menüpunkte und Dropdowns rendert. Das Projekt zeichnet sich dadurch aus, dass es als Automatisierungsschnittstelle fungiert, die sich in System-Shortcuts und externe URL-Schemata integriert, um Aktionen auszulösen und Statusanzeigen zu aktualisieren. Es unterstützt die Installation von Community-Skripten und das Paketieren komplexer Plugin-Assets in lokale Verzeichnisse. Das System deckt ein breites Spektrum an Funktionen ab, einschließlich metadatengesteuertem Rendering für Schriftarten und Farben, intervallbasiertem Polling und Echtzeit-Datenstreaming sowie die Integration eingebetteter Web-Views innerhalb der Menüoberfläche. Es bietet zudem Zugriff auf Umgebungsvariablen für dynamische Logik und ermöglicht es, Skriptausführungsergebnisse in einem Terminal-Emulator für Debugging-Zwecke zu starten.