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

Acest proiect este un sistem de gestionare a regulilor de afaceri și un motor de reguli conceput pentru a defini, executa și gestiona logica de afaceri complexă decuplată de codul sursă al aplicației. Acesta oferă un compilator de logică de afaceri care transformă definițiile regulilor lizibile pentru oameni în modele executabile pentru evaluare în runtime de înaltă performanță. Sistemul include un motor de procesare a evenimentelor complexe pentru analizarea fluxurilor de date în timp real în vederea identificării tiparelor temporale și un executor de modele și notații de decizie care procesează logica structurată pe baza standardelor din industrie pentru rezultate deterministe. Utilizează un motor de inferență care suportă forward și backward chaining pentru a automatiza deciziile prin evaluarea dependențelor logice complexe. Platforma acoperă o gamă largă de capabilități, inclusiv gestionarea sesiunilor de reguli, analiza dependențelor regulilor și vizualizarea logicii de execuție. De asemenea, dispune de instrumente pentru monitorizarea performanței regulilor, traducerea formatului regulilor și recuperarea stării sesiunii printr-un strat de persistență pluggable.

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 este o bibliotecă Android de nivel înalt pentru cameră și un wrapper hardware conceput pentru capturarea de fotografii și videoclipuri. Oferă un strat de abstractizare pentru gestionarea hardware-ului camerei și un API de captură media pentru înregistrarea video de înaltă rezoluție și fotografii RAW cu bitrate-uri și rezoluții configurabile. Proiectul dispune de un framework de filtre pentru cameră în timp real și un manager de previzualizare. Aceste sisteme permit aplicarea de shadere personalizate și efecte vizuale fluxurilor video live ale camerei și randarea previzualizărilor cu aspect ratio-uri, overlay-uri și grile de compoziție personalizabile. Biblioteca acoperă o gamă largă de controale hardware, inclusiv selecția senzorului, zoom, expunere și auto-focus. De asemenea, gestionează sarcini de procesare media, cum ar fi înlănțuirea filtrelor, aplicarea de watermark-uri grafice și încorporarea metadatelor de locație geografică în datele EXIF. Toolkit-ul include un sistem pentru solicitarea și gestionarea permisiunilor de sistem Android necesare pentru inițializarea hardware-ului camerei.

CliWrap este o bibliotecă de tip wrapper pentru procese secundare și un manager de procese asincron, utilizat pentru a executa comenzi externe și a integra interfețe de linie de comandă în aplicații. Oferă un framework pentru lansarea programelor externe folosind tipare asincrone, gestionarea proceselor secundare și validarea codurilor de ieșire. Biblioteca se distinge prin capacitatea de a direcționa fluxurile standard de intrare, ieșire și eroare către buffere de memorie sau fluxuri de evenimente în timp real. Permite monitorizarea în timp real a liniilor de ieșire ale proceselor și suportă terminarea proceselor prin token-uri de anulare. Proiectul acoperă o gamă largă de capabilități de gestionare a proceselor externe, inclusiv configurarea variabilelor de mediu, redirecționarea fluxurilor standard și capturarea ieșirii proceselor pentru a fi utilizată ca date în cadrul unei aplicații.

GPUImage2 este un framework Swift pentru aplicarea filtrelor și efectelor în timp real asupra imaginilor și videoclipurilor folosind GPU-ul. Oferă o bibliotecă de filtre video în timp real, un motor de manipulare a geometriei imaginii și un pipeline de shading OpenGL pentru procesarea datelor vizuale pe hardware grafic. Framework-ul permite construirea de pipeline-uri de efecte vizuale prin înlănțuirea surselor de imagine către consumatori în fluxuri secvențiale. Suportă dezvoltarea de shadere personalizate de fragment și vertex pentru procesarea imaginilor bespoke și oferă capacitatea de a bundle-ui aceste operațiuni în unități reutilizabile prin grupare bazată pe grafuri. Domeniile de capabilitate includ ajustarea culorilor, manipularea geometrică și generarea de imagini sintetice. Sistemul suportă, de asemenea, stratificarea imaginilor compozite, permițând combinarea mai multor surse de imagine folosind alpha blending și chroma keying.

Appium Desktop este o interfață grafică pentru configurarea și gestionarea unui server Appium pentru automatizarea testelor aplicațiilor mobile. Servește ca un manager de automatizare cross-platform pentru controlul sesiunilor pe diferite sisteme de operare mobile și furnizori cloud. Aplicația include un inspector de aplicații mobile pentru analizarea arborilor sursă ai aplicațiilor și identificarea atributelor elementelor, alături de un recorder de scripturi de testare care capturează interacțiunile utilizatorului pentru a genera cod de automatizare. Instrumentul acoperă administrarea serverului și controlul ciclului de viață, permițând gestionarea configurațiilor de rețea și a variabilelor de mediu prin presetări salvate. Oferă observabilitate prin monitorizarea log-urilor serverului în timp real și capabilități de gestionare a sesiunilor pentru a inițializa sesiuni noi sau a se atașa la cele existente. De asemenea, facilitează conectivitatea la platforme de testare cloud la distanță.

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 este un set de instrumente pentru securitatea runtime și observabilitate bazat pe eBPF, conceput pentru medii Linux și Kubernetes. Acesta funcționează ca un manager de politici de securitate, agent de observabilitate și motor de impunere a regulilor, conectându-se la funcțiile kernel-ului și la tracepoint-uri pentru a detecta escaladarea privilegiilor, evadarea din containere și activitățile neautorizate ale sistemului. Proiectul se distinge prin capacitatea de a efectua impunerea regulilor în timp real, direct în kernel, permițând terminarea sincronă a proceselor malițioase sau modificarea valorilor returnate de funcții înainte ca un apel de sistem să se finalizeze. Oferă o integrare profundă cu Kubernetes prin sincronizarea identităților containerelor și maparea evenimentelor de nivel scăzut din kernel direct către pod-uri și namespace-uri. Capabilitățile sale mai largi acoperă auditarea completă a apelurilor de sistem, monitorizarea conexiunilor de rețea și verificarea integrității fișierelor. Sistemul suportă gestionarea dinamică a politicilor și oferă instrumente de diagnosticare pentru monitorizarea performanței BPF și a utilizării resurselor. Deployment-ul este suportat în clustere Kubernetes prin Helm charts, precum și prin containere standalone și pachete native pentru sistemele de operare.

pyalgotrade este o bibliotecă Python pentru tranzacționare algoritmică, concepută pentru dezvoltarea, backtesting-ul și execuția strategiilor de tranzacționare automatizate. Oferă un framework cuprinzător pentru backtesting-ul strategiilor financiare, o bibliotecă de analiză tehnică pentru calcularea indicatorilor matematici și conectori pentru integrarea cu exchange-uri de criptomonede. Proiectul se distinge prin suportul pentru tranzacționarea bazată pe sentiment, prin integrarea fluxurilor de social media în timp real și a fluxurilor de cuvinte cheie. Dispune de un instrument de vizualizare a tranzacționării cantitative pentru reprezentarea grafică a evoluției prețurilor și a curbelor de capital, alături de optimizarea paralelă a parametrilor pentru a identifica cele mai eficiente setări ale strategiei. Biblioteca acoperă o gamă largă de capabilități, inclusiv construirea de pipeline-uri de date financiare pentru ingestia și resamplarea datelor de piață, gestionarea ciclului de viață al ordinelor atât pentru tranzacționarea live, cât și pentru cea de tip paper trading, și analiza performanței cantitative pentru calcularea randamentelor ajustate la risc și a drawdown-urilor. Include, de asemenea, instrumente pentru analiză tehnică, cum ar fi benzile de volatilitate și indicatorii de momentum, precum și simulări care iau în calcul slippage-ul ordinelor și comisioanele de tranzacționare.

ogl este o bibliotecă grafică WebGL și un motor de scenă 3D (scene graph) conceput pentru randarea scenelor tridimensionale. Oferă un framework lightweight pentru gestionarea geometriilor și coordonarea transformărilor spațiale într-un sistem ierarhic. Proiectul include un sistem de shadere PBR pentru crearea de materiale realiste și un framework de calcul GPGPU pentru efectuarea de calcule de uz general la scară largă și simulări de particule pe procesorul grafic. De asemenea, dispune de o suită de post-procesare pentru aplicarea filtrelor vizuale scenelor randate prin frame buffer-e. Biblioteca acoperă capabilități mai largi, inclusiv operații matematice 3D, importarea și animarea activelor 3D și interacțiunea utilizatorului prin raycasting și controlul camerei.

Imageflow este o bibliotecă de manipulare a imaginilor și un motor de compoziție de înaltă performanță, disponibil ca bibliotecă compatibilă C, procesor de imagini command-line și server dinamic de procesare a imaginilor. Oferă mijloacele de a decoda, coda și aplica transformări vizuale complexe imaginilor prin interfețe programatice, fișiere de job JSON sau query strings de URL. Sistemul se distinge printr-un pipeline de procesare bazat pe grafuri care permite codarea multi-format într-o singură trecere, generând dimensiuni și formate multiple de imagini dintr-o singură decodare pentru a reduce overhead-ul. De asemenea, dispune de un motor de decodare cu resurse limitate care impune limite stricte de memorie și dimensiune pentru a preveni epuizarea resurselor și atacurile de tip denial-of-service. Proiectul acoperă o gamă largă de capabilități de manipulare, inclusiv redimensionarea, decuparea, rotirea și filtrarea culorilor. Suportă sarcini avansate de compoziție, cum ar fi adăugarea de watermark-uri, generarea de canvas-uri goale și randarea formelor geometrice, alături de corecția automată a culorilor și ajustarea balansului de alb folosind analiza histogramelor. Logica de bază este expusă prin binding-uri de tip foreign function interface pentru integrare cross-language.

Riemann este un procesor de fluxuri de evenimente și un motor de analiză în timp real bazat pe Clojure. Acesta funcționează ca o conductă de telemetrie de rețea și un router de evenimente extensibil care preia, transformă și direcționează datele de evenimente din sisteme distribuite. Sistemul utilizează un limbaj specific domeniului (DSL) pentru a calcula metrici și tipare statistice pe fluxuri continue, permițând analiza tendințelor de rețea și alertarea în timp real. Suportă încărcarea dinamică a plugin-urilor din classpath și permite reîncărcarea configurației în direct, fără a întrerupe fluxurile de evenimente active. Capabilitățile includ agregarea centralizată a telemetriei, etichetarea metadatelor evenimentelor și indexarea stării evenimentelor. Sistemul gestionează distribuția fluxurilor de evenimente prin divizare, procesare în loturi (batching) și filtrare, oferind în același timp transport securizat în rețea prin criptare și autentificare.

Acest repository este o colecție de aplicații eșantion și proiecte de referință pentru integrarea API-urilor de machine learning on-device în aplicațiile mobile. Oferă exemple de implementare atât pentru Android, cât și pentru iOS, demonstrând cum să încorporați modele de computer vision și procesare a limbajului natural. Proiectul acoperă implementarea computer vision-ului mobil, inclusiv recunoașterea textului, detectarea feței și scanarea codurilor de bare. Include workflow-uri pentru procesarea imaginilor în timp real și integrarea modelelor pre-antrenate care procesează datele local pe dispozitiv.

SwiftBar este un personalizator de bară de meniu macOS și un monitor de stare bazat pe plugin-uri care afișează output-ul scripturilor executabile și al comenzilor shell direct în bara de meniu a sistemului. Funcționează ca un dashboard de scripturi shell, randând date în timp real și rezultate ale scripturilor sub formă de elemente de meniu interactive și dropdown-uri. Proiectul se distinge prin faptul că acționează ca o interfață de automatizare care se integrează cu scurtăturile de sistem și schemele URL externe pentru a declanșa acțiuni și a actualiza indicatorii de stare. Suportă instalarea de scripturi create de comunitate și împachetarea activelor complexe de plugin-uri în directoare locale. Sistemul acoperă o gamă largă de capabilități, inclusiv randarea bazată pe metadate pentru fonturi și culori, polling bazat pe intervale și streaming de date în timp real, precum și integrarea vizualizărilor web încorporate în interfața meniului. De asemenea, oferă acces la variabilele de mediu pentru logica dinamică și permite lansarea rezultatelor execuției scripturilor într-un emulator de terminal pentru depanare.