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

Este proyecto es un sistema de gestión de reglas de negocio y motor de reglas diseñado para definir, ejecutar y gestionar lógica de negocio compleja desacoplada del código fuente de la aplicación. Proporciona un compilador de lógica de negocio que transforma definiciones de reglas legibles por humanos en modelos ejecutables para una evaluación de alto rendimiento en tiempo de ejecución. El sistema incluye un motor de procesamiento de eventos complejos para analizar flujos de datos en tiempo real e identificar patrones temporales, y un ejecutor de modelos y notación de decisiones que procesa lógica estructurada basada en estándares de la industria para resultados deterministas. Utiliza un motor de inferencia que soporta encadenamiento hacia adelante y hacia atrás para automatizar decisiones evaluando dependencias lógicas complejas. La plataforma cubre un amplio rango de capacidades, incluyendo gestión de sesiones de reglas, análisis de dependencias de reglas y visualización de lógica de ejecución. También cuenta con herramientas para monitoreo del rendimiento de reglas, traducción de formatos de reglas y recuperación del estado de sesión mediante una capa de persistencia conectable.

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 es una librería de cámara de Android de alto nivel y wrapper de hardware diseñado para capturar fotos y videos. Proporciona una capa de abstracción para gestionar el hardware de la cámara y una API de captura de medios para grabar video de alta resolución y fotos RAW con tasas de bits y resoluciones configurables. El proyecto cuenta con un framework de filtros de cámara en tiempo real y un gestor de vista previa. Estos sistemas permiten la aplicación de shaders personalizados y efectos visuales a flujos de cámara en vivo y el renderizado de vistas previas con relaciones de aspecto, superposiciones y cuadrículas de composición personalizables. La librería cubre una amplia gama de controles de hardware, incluyendo selección de sensor, zoom, exposición y auto-enfoque. También gestiona tareas de procesamiento de medios como encadenamiento de filtros, marcas de agua gráficas y la incrustación de metadatos de ubicación geográfica en datos EXIF. El kit de herramientas incluye un sistema para solicitar y gestionar los permisos necesarios del sistema Android requeridos para la inicialización del hardware de la cámara.

CliWrap es una biblioteca de gestión de procesos asíncronos y envoltorio de procesos hijos, utilizada para ejecutar comandos externos e integrar interfaces de línea de comandos en aplicaciones. Proporciona un framework para lanzar programas externos mediante patrones asíncronos, gestionar procesos hijos y validar códigos de salida. La biblioteca destaca por su capacidad para enrutar flujos de entrada, salida y error estándar hacia buffers de memoria o flujos de eventos en tiempo real. Permite el monitoreo en tiempo real de las líneas de salida del proceso y admite la terminación de procesos mediante tokens de cancelación. El proyecto cubre una amplia gama de capacidades de gestión de procesos externos, incluyendo la configuración de variables de entorno, la redirección de flujos estándar y la captura de la salida del proceso para su uso como datos dentro de una aplicación.

GPUImage2 es un framework de Swift para aplicar filtros y efectos en tiempo real a imágenes y video utilizando la GPU. Proporciona una biblioteca de filtros de video en tiempo real, un motor de manipulación de geometría de imágenes y una canalización de sombreado OpenGL para procesar datos visuales en hardware gráfico. El framework permite la construcción de canalizaciones de efectos visuales mediante el encadenamiento de fuentes de imagen a consumidores en flujos secuenciales. Admite el desarrollo de sombreadores de fragmentos y vértices personalizados para el procesamiento de imágenes a medida y ofrece la capacidad de agrupar estas operaciones en unidades reutilizables mediante agrupaciones basadas en gráficos. Las áreas de capacidad incluyen el ajuste de color, la manipulación geométrica y la generación de imágenes sintéticas. El sistema también admite la superposición de imágenes compuestas, permitiendo combinar múltiples fuentes de imagen utilizando mezcla alfa y chroma keying.

Appium Desktop es una interfaz gráfica de usuario para configurar y gestionar un servidor Appium para automatizar pruebas de aplicaciones móviles. Sirve como un gestor de automatización multiplataforma para controlar sesiones a través de diferentes sistemas operativos móviles y proveedores de nube. La aplicación incluye un inspector de aplicaciones móviles para analizar árboles de fuentes de aplicaciones e identificar atributos de elementos, junto con un grabador de scripts de prueba que captura las interacciones del usuario para generar código de automatización. La herramienta cubre la administración del servidor y el control del ciclo de vida, permitiendo la gestión de configuraciones de red y variables de entorno a través de preajustes guardados. Proporciona observabilidad mediante el monitoreo de registros del servidor en tiempo real y capacidades de gestión de sesiones para inicializar nuevas sesiones o adjuntarse a las existentes. También facilita la conectividad a plataformas de pruebas en la nube remotas.

Jitsu es una plataforma de datos de clientes diseñada para recopilar, transformar y enrutar eventos de aplicaciones a almacenes de datos y herramientas de marketing. Funciona como un motor de ingesta de eventos y enrutador de almacenes de datos, capturando datos de comportamiento a través de API y SDK para su procesamiento y almacenamiento en tiempo real. La plataforma cuenta con un pipeline de datos programable en JavaScript que permite el filtrado, enriquecimiento y remodelación de los datos de eventos durante el tránsito. Incluye un sistema de unión de identidades de clientes que fusiona identificadores de usuarios anónimos y conocidos para mantener perfiles de clientes persistentes dentro de un almacén. El sistema cubre una amplia gama de capacidades, incluyendo la recopilación de eventos de múltiples fuentes desde entornos web y móviles, la evolución automática de esquemas para almacenes de destino y el enrutamiento a múltiples destinos hacia plataformas SaaS y bases de datos SQL. Proporciona un conjunto de herramientas para desarrolladores para probar la lógica de transformación y admite el despliegue a través de Kubernetes o entornos Docker autohospedados.

Tetragon es un conjunto de herramientas de observabilidad y seguridad en tiempo de ejecución basado en eBPF, diseñado para entornos Linux y Kubernetes. Funciona como un gestor de políticas de seguridad, agente de observabilidad y motor de cumplimiento que se conecta a funciones del kernel y tracepoints para detectar escalada de privilegios, escapes de contenedores y actividad no autorizada en el sistema. El proyecto se distingue por su capacidad de realizar cumplimiento en tiempo de ejecución dentro del kernel, lo que le permite terminar procesos maliciosos de forma síncrona o modificar los valores de retorno de funciones antes de que se complete una llamada al sistema. Ofrece una integración profunda con Kubernetes al sincronizar las identidades de los contenedores y mapear eventos de bajo nivel del kernel directamente a pods y namespaces. Sus capacidades más amplias cubren la auditoría integral de llamadas al sistema, el seguimiento de conexiones de red y el monitoreo de la integridad de archivos. El sistema admite la gestión dinámica de políticas y proporciona herramientas de diagnóstico para monitorear el rendimiento y la utilización de recursos de BPF. El despliegue es compatible con clústeres de Kubernetes mediante Helm charts, así como a través de contenedores independientes y paquetes nativos del sistema operativo.

pyalgotrade es una librería de trading algorítmico en Python diseñada para desarrollar, realizar backtesting y ejecutar estrategias de trading automatizadas. Proporciona un framework integral para backtesting de estrategias financieras, una librería de análisis técnico para calcular indicadores matemáticos y conectores para la integración con exchanges de criptomonedas. El proyecto se distingue por soportar trading basado en sentimiento mediante la integración de feeds de redes sociales en tiempo real y flujos de palabras clave. Incluye una herramienta de visualización de trading cuantitativo para graficar la acción del precio y curvas de capital de la cartera, junto con optimización de parámetros en paralelo para identificar la configuración de estrategia más efectiva. La librería cubre un amplio rango de capacidades, incluyendo la construcción de pipelines de datos financieros para la ingesta y remuestreo de datos de mercado, gestión del ciclo de vida de órdenes tanto para trading real como en papel (paper trading), y análisis de rendimiento cuantitativo para calcular retornos ajustados al riesgo y drawdowns. También incluye herramientas para análisis técnico, como bandas de volatilidad e indicadores de momentum, así como simulaciones que consideran el deslizamiento de órdenes (slippage) y comisiones de transacción.

ogl es una librería de gráficos WebGL y un motor de grafo de escena 3D diseñado para renderizar escenas tridimensionales. Proporciona un framework ligero para gestionar geometrías y coordinar transformaciones espaciales dentro de un sistema jerárquico. El proyecto incluye un sistema de sombreadores (shaders) PBR para crear materiales realistas y un framework de computación GPGPU para realizar cálculos de propósito general a gran escala y simulaciones de partículas en el procesador gráfico. También cuenta con una suite de post-procesamiento para aplicar filtros visuales a las escenas renderizadas mediante buffers de fotogramas. La librería cubre capacidades más amplias, incluyendo operaciones matemáticas 3D, la importación y animación de activos 3D, y la interacción del usuario mediante raycasting y controles de cámara.

Imageflow es una librería de manipulación de imágenes y motor de composición de alto rendimiento, disponible como librería compatible con C, procesador de imágenes de línea de comandos y servidor de procesamiento de imágenes dinámico. Proporciona los medios para decodificar, codificar y aplicar transformaciones visuales complejas a imágenes a través de interfaces programáticas, archivos de trabajo JSON o cadenas de consulta URL al vuelo. El sistema se distingue por un pipeline de procesamiento basado en grafos que permite la codificación multiformato en una sola pasada, generando múltiples tamaños y formatos de imagen a partir de una sola decodificación para reducir la sobrecarga. Además, cuenta con un motor de decodificación con restricciones de recursos que impone límites estrictos de memoria y dimensiones para evitar el agotamiento de recursos y ataques de denegación de servicio. El proyecto cubre una amplia gama de capacidades de manipulación, incluyendo redimensionamiento de dimensiones, recorte, rotación y filtrado de color. Soporta tareas de composición avanzadas como marcas de agua, generación de lienzos en blanco y renderizado de formas geométricas, junto con corrección de color automatizada y ajustes de balance de blancos mediante análisis de histograma. La lógica central se expone a través de bindings de interfaz de funciones externas (FFI) para la integración entre lenguajes.

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

Este repositorio es una colección de aplicaciones de muestra y proyectos de referencia para integrar APIs de machine learning en el dispositivo en aplicaciones móviles. Proporciona ejemplos de implementación tanto para Android como para iOS, demostrando cómo incrustar modelos de visión artificial y procesamiento de lenguaje natural. El proyecto cubre la implementación de visión artificial móvil, incluyendo reconocimiento de texto, detección de rostros y escaneo de códigos de barras. Incluye flujos de trabajo para el procesamiento de imágenes en tiempo real y la integración de modelos preentrenados que procesan datos localmente en el dispositivo.

SwiftBar es un personalizador de barra de menús de macOS y monitor de estado basado en plugins que muestra la salida de scripts ejecutables y comandos de shell directamente en la barra de menús del sistema. Funciona como un panel de control de scripts de shell, renderizando datos en tiempo real y resultados de scripts como elementos de menú interactivos y menús desplegables. El proyecto se distingue por actuar como una interfaz de automatización que se integra con atajos del sistema y esquemas de URL externos para activar acciones y actualizar indicadores de estado. Admite la instalación de scripts creados por la comunidad y el empaquetado de activos de plugins complejos en directorios locales. El sistema cubre una amplia gama de capacidades, incluyendo renderizado basado en metadatos para fuentes y colores, sondeo basado en intervalos y transmisión de datos en tiempo real, y la integración de vistas web incrustadas dentro de la interfaz del menú. También proporciona acceso a variables de entorno para lógica dinámica y permite que los resultados de la ejecución de scripts se lancen en un emulador de terminal para su depuración.