Awesome GitHub RepositoriesStream Subscriptions

RxSwift is a reactive programming library for Swift that provides a framework for managing push-based data flows and composing asynchronous, event-based programs. It utilizes observable sequences and functional operators to transform and filter asynchronous sequences through a declarative approach. The library is distinguished by its ability to link asynchronous data streams directly to user interface elements, automating view updates via reactive data binding. It includes specialized tools for tracking UI control properties and events on the main thread, as well as the ability to encapsulate

This project is a feature-rich Go client library designed for interacting with Redis. It serves as a comprehensive interface for managing remote data stores, enabling developers to execute standard database commands, handle complex data structures, and perform asynchronous operations within Go applications. The library distinguishes itself through its support for advanced Redis capabilities, including connection pooling, pipelining, and transactional integrity. It provides specialized primitives for managing distributed clusters, including automated topology updates and request routing to sha

RedisInsight is a graphical user interface and management tool for browsing, analyzing, and administering Redis databases. It provides a visual environment for exploring key-value data structures, managing database instances, and performing data analysis across different operating systems and deployments. The tool distinguishes itself by providing dedicated visual managers for complex operations, including a vector database manager for configuring embeddings and similarity searches, a query workbench for executing raw commands and Lua scripts, and a performance monitoring dashboard for tracki

Yoga is a GraphQL server framework and runtime-agnostic HTTP handler used to build and deploy GraphQL APIs. It functions as a toolkit for managing schemas and resolvers, providing a spec-compliant environment for hosting APIs across diverse JavaScript runtimes, including Node.js, Deno, Bun, and serverless cloud environments. The project distinguishes itself through its ability to act as an Apollo Federation gateway, composing multiple subgraphs into a single unified supergraph. It also serves as a dedicated subscription server, delivering real-time data streaming via both WebSockets and Serve

python-binance is a Python client library that provides programmatic access to the Binance cryptocurrency exchange through both REST and WebSocket APIs. It serves as a comprehensive toolkit for automated trading, account management, and market data retrieval, enabling developers to build trading bots, portfolio management tools, and data analysis applications that interact directly with the exchange. The library distinguishes itself through a dual-client architecture that separates synchronous REST calls from persistent WebSocket streams, allowing concurrent execution without blocking. It inc

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

Juniper es una biblioteca de servidor GraphQL y motor de esquemas para Rust. Proporciona un toolkit para construir APIs con seguridad de tipos mapeando estructuras de datos nativas de Rust a objetos, entradas y escalares de GraphQL. El proyecto funciona como un motor de ejecución que puede procesar consultas y mutaciones ya sea a través de un servidor de red o como un motor headless para ejecución local. La biblioteca es agnóstica al tiempo de ejecución, lo que le permite conectar el procesamiento de GraphQL con varios frameworks web asíncronos de Rust. Incluye un framework de suscripciones que gestiona conexiones WebSocket persistentes para enviar actualizaciones de datos en tiempo real a los clientes. El motor cubre una amplia superficie de capacidades, incluyendo exportación de lenguaje de esquemas, gestión de contexto de estado compartido para inyección de dependencias y un enfoque code-first para definir resolutores. También admite la integración de tipos de datos especializados como decimales y marcas de tiempo para evitar conversiones manuales de datos.

Reactor Core es un kit de herramientas de programación reactiva y una base no bloqueante para componer pipelines de datos asíncronos en la JVM. Sirve como framework de procesamiento de flujos asíncronos y sistema de gestión de contrapresión (backpressure), permitiendo a los desarrolladores transformar, filtrar y combinar secuencias de eventos mientras regulan el flujo de datos entre productores y consumidores para evitar el agotamiento de recursos. La biblioteca se diferencia por un sofisticado sistema de planificación de concurrencia y control de flujo basado en la demanda. Desacopla el procesamiento de señales de hilos específicos utilizando un registro de planificadores y proporciona mecanismos para la propagación de metadatos inmutables conscientes del contexto a través de límites asíncronos. También cuenta con herramientas especializadas para la captura de trazas en tiempo de ensamblaje y planificación de tiempo virtual para facilitar la prueba de operadores basados en el tiempo. El proyecto cubre una amplia gama de capacidades, incluyendo procesamiento funcional de datos para agregación y ventanas de secuencias, una variedad de estrategias de recuperación de errores como reintentos con retroceso exponencial y utilidades para conectar API de callback heredadas o síncronas en flujos reactivos. Además, proporciona instrumentación para el monitoreo de pipelines y un conjunto de herramientas de prueba para verificar secuencias de señales.

Este proyecto proporciona documentación técnica y guías de referencia para el trading al contado (spot trading), incluyendo especificaciones para protocolos REST, WebSocket y FIX. Sirve como un recurso integral para integrarse con endpoints de trading al contado para ejecutar operaciones, consultar datos de cuenta y obtener estadísticas de mercado. El proyecto se distingue por admitir conectividad de grado institucional a través del estándar Financial Information eXchange (FIX) y codificación binaria simple para reducir la latencia y el tamaño de la carga útil. También incluye un entorno de sandbox dedicado para validar la lógica y las estrategias de trading sin riesgo financiero. La documentación cubre una amplia gama de capacidades, incluyendo streaming de datos de mercado en tiempo real, gestión integral del ciclo de vida de órdenes y operaciones, y monitoreo de cuentas. También detalla tipos de órdenes complejos, enrutamiento inteligente de órdenes y reglas de trading estrictas con respecto a la validación de precio y cantidad. El repositorio contiene referencias detalladas de API, una guía de integración del protocolo FIX y una especificación de datos de mercado WebSocket para orientar a los desarrolladores durante la implementación.

tqsdk-python es un SDK y framework de trading cuantitativo diseñado para desarrollar estrategias automatizadas para futuros, opciones y acciones utilizando Python. Funciona como un motor de trading algorítmico y API de datos de mercado financiero, proporcionando las herramientas necesarias para realizar backtesting de estrategias, analizar datos históricos y ejecutar operaciones en vivo a través de múltiples cuentas de corretaje. El proyecto se distingue por una librería de análisis de opciones especializada que calcula griegas, volatilidad implícita y superficies de volatilidad utilizando el modelo Black-Scholes. Además, admite patrones complejos de ejecución de órdenes, como TWAP, Iceberg y POV, para minimizar el impacto en el mercado durante la entrada y salida de posiciones. El SDK cubre una amplia superficie de capacidades, incluyendo la recuperación de datos de mercado en tiempo real e históricos, gestión de riesgos cuantitativa y monitoreo de carteras. Incorpora un modelo de ejecución asíncrono para la transmisión de datos y la programación de tareas, junto con herramientas para la simulación de trading multiactivo y análisis de rendimiento. La librería proporciona una interfaz gráfica basada en web para el monitoreo de estrategias y la visualización de datos.

Strawberry es una biblioteca GraphQL con tipado fuerte para Python que permite el diseño de esquemas utilizando anotaciones de tipo y dataclasses de Python. Funciona como un servidor GraphQL asíncrono y motor de ejecución, proporcionando un puente para exponer esquemas a través de frameworks web compatibles con ASGI como FastAPI, Django, Flask y Litestar. El proyecto implementa GraphQL Federation, permitiendo la creación de esquemas y entidades distribuidas que se fusionan en un supergrafo unificado a través de múltiples servicios. También incluye un kit de herramientas dedicado para la especificación Relay, soportando la identificación global de objetos y la paginación basada en conexiones. El framework cubre un amplio conjunto de capacidades, incluyendo streaming de datos en tiempo real mediante WebSockets y Server-Sent Events, mapeo de modelos Pydantic y generación automática de código. Proporciona herramientas integradas para seguridad y observabilidad, como limitación de complejidad de consultas, control de acceso basado en roles y rastreo de métricas de ejecución. Los desarrolladores pueden realizar prototipos utilizando un servidor de desarrollo integrado con una interfaz de inspección de esquemas interactiva.

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.

Este proyecto es un portal de documentación de API de intercambio de criptomonedas. Proporciona una referencia técnica para la integración con interfaces REST y WebSocket para operar con activos digitales y transmitir datos de mercado. El sitio sirve como una referencia de API REST con descripciones de endpoints basadas en esquemas y ejemplos de solicitud-respuesta, junto con una guía de flujo de datos WebSocket para recibir actualizaciones de libros de órdenes en vivo y feeds de precios. La documentación se implementa como un sitio estático basado en markdown que cuenta con indexación de búsqueda del lado del cliente y navegación jerárquica. Utiliza generación de contenido basada en esquemas e incrustación de activos vinculados para mantener la consistencia a través de las especificaciones técnicas.

Tribeca es una plataforma de trading de criptomonedas en Node.js diseñada para trading de alta frecuencia y creación de mercado automatizada. Funciona como un motor de ejecución de baja latencia que automatiza el proceso de proporcionar liquidez y capturar spreads de precios a través de múltiples exchanges de criptomonedas. El sistema emplea una capa de conectividad para transmitir datos de mercado en tiempo real y ejecutar operaciones a través de conexiones de red persistentes. Utiliza una integración basada en adaptadores para normalizar diversas API de plataformas en un formato unificado, permitiendo una actividad coordinada a través de varios exchanges de criptomonedas diferentes. La plataforma incluye un backtester algorítmico para validar estrategias contra datos históricos y un panel de control visual para monitorear posiciones activas y parámetros de cotización. Las capacidades adicionales cubren la ejecución de órdenes basada en eventos, el seguimiento de posiciones basado en estados y el almacenamiento persistente en base de datos para auditar registros de trading.

XChange is a cryptocurrency exchange integration library and API wrapper that provides a unified interface for connecting to multiple cryptocurrency exchanges. It serves as a multi-exchange trading interface and a market data streamer, normalizing raw data from various providers into standardized data objects. The project distinguishes itself through an adapter-based normalization system and a reactive WebSocket streaming model designed to receive real-time price and volume updates while minimizing thread usage. It includes a dedicated authentication handler for managing API keys, request non

apollo-ios is a GraphQL client library for iOS and Apple platforms that enables type-safe network communication. It transforms GraphQL operations into generated Swift models, ensuring that network responses are validated at compile time to eliminate manual mapping. The library features a normalized cache manager that stores entities in a flat structure to maintain data consistency across different application views. It also optimizes network performance using hash-based persisted queries to reduce payload sizes and supports real-time data streaming via WebSockets or HTTP subscriptions. The p

Project-Lightspeed is a low-latency video relay and WebRTC live streaming server. It functions as an OBS streaming backend that ingests media streams and converts them for real-time playback in web browsers. The system operates as a WebSocket stream orchestrator, managing connection handshakes and stream authentication to coordinate signaling between the server and the client browser. It utilizes a high-speed protocol to achieve sub-second delay between the broadcast source and the viewer. The server covers media relay capabilities, including network packet relaying and the ingestion of vide

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

Binance Connector Python is a client library that provides programmatic access to the Binance cryptocurrency exchange, enabling automated trading and asset management across spot, margin, futures, and options markets. The library wraps the exchange's REST and WebSocket APIs into a Python interface with type-hinted methods, HMAC and RSA authentication, and a unified request-response pipeline for consistent error handling and rate limiting. The connector supports a broad range of exchange operations beyond core trading, including sub-account management, wallet operations, and algorithmic order

QuantMuse is an algorithmic trading platform and quantitative trading framework that integrates large language models with mathematical analysis to automate market insights and trading strategies. It functions as a system for building, backtesting, and executing strategies using both historical and real-time market data. The framework is distinguished by its use of large language models for financial analysis and sentiment extraction from news and social media. It utilizes autonomous agents with chain-of-thought reasoning to generate market intelligence and strategic reports, while employing