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 este o bibliotecă de server GraphQL și un motor de scheme pentru Rust. Oferă un toolkit pentru construirea de API-uri type-safe prin maparea structurilor de date native Rust către obiecte, input-uri și scalari GraphQL. Proiectul funcționează ca un motor de execuție care poate procesa interogări și mutații fie printr-un server de rețea, fie ca un motor headless pentru execuție locală. Biblioteca este agnostică față de runtime, permițându-i să facă legătura între procesarea GraphQL și diverse framework-uri web asincrone Rust. Include un framework de subscripții care gestionează conexiunile WebSocket persistente pentru a trimite actualizări de date în timp real către clienți. Motorul acoperă o suprafață largă de capabilități, inclusiv exportul limbajului de schemă, gestionarea contextului de stare partajată pentru dependency injection și o abordare code-first pentru definirea resolverelor. De asemenea, suportă integrarea tipurilor de date specializate, cum ar fi zecimalele și timestamp-urile, pentru a evita conversiile manuale de date.

Reactor Core este un toolkit de programare reactivă și o fundație non-blocking pentru compunerea pipeline-urilor de date asincrone pe JVM. Servește drept framework de procesare a fluxurilor asincrone și sistem de gestionare a backpressure-ului, permițând dezvoltatorilor să transforme, filtreze și combine secvențe de evenimente în timp ce reglează fluxul de date între producători și consumatori pentru a preveni epuizarea resurselor. Biblioteca se diferențiază printr-un sistem sofisticat de programare a concurenței și control al fluxului bazat pe cerere. Decuplează procesarea semnalelor de firele de execuție specifice folosind un registru de scheduler și oferă mecanisme pentru propagarea metadatelor imutabile conștiente de context peste limitele asincrone. De asemenea, dispune de instrumente specializate pentru capturarea urmelor la momentul asamblării și programarea timpului virtual pentru a facilita testarea operatorilor bazați pe timp. Proiectul acoperă o gamă largă de capabilități, inclusiv procesarea funcțională a datelor pentru agregarea și windowing-ul secvențelor, o varietate de strategii de recuperare a erorilor precum reîncercările cu backoff exponențial și utilitare pentru a conecta API-urile legacy de tip callback sau sincrone în fluxuri reactive. Oferă, de asemenea, instrumente pentru monitorizarea pipeline-ului și o suită de instrumente de testare pentru verificarea secvențelor de semnale.

Acest proiect oferă documentație tehnică și ghiduri de referință pentru tranzacționarea spot, incluzând specificații pentru protocoalele REST, WebSocket și FIX. Servește ca o resursă cuprinzătoare pentru integrarea cu endpoint-urile de tranzacționare spot pentru a executa tranzacții, a interoga datele contului și a prelua statistici de piață. Proiectul se distinge prin suportul pentru conectivitate de nivel instituțional prin standardul Financial Information eXchange și codificarea binară simplă pentru a reduce latența și dimensiunea payload-ului. Include, de asemenea, un mediu sandbox dedicat pentru validarea logicii și strategiilor de tranzacționare fără risc financiar. Documentația acoperă o gamă largă de capabilități, inclusiv streaming-ul datelor de piață în timp real, gestionarea cuprinzătoare a ciclului de viață al comenzilor și tranzacțiilor și monitorizarea contului. Detaliază, de asemenea, tipuri complexe de comenzi, rutarea inteligentă a comenzilor și reguli stricte de tranzacționare privind validarea prețului și a cantității. Repository-ul conține referințe API detaliate, un ghid de integrare a protocolului FIX și o specificație a datelor de piață WebSocket pentru a orienta dezvoltatorii în timpul implementării.

tqsdk-python este un SDK și framework de tranzacționare cantitativă conceput pentru dezvoltarea de strategii automatizate pentru futures, opțiuni și acțiuni folosind Python. Acesta funcționează ca un motor de tranzacționare algoritmică și API de date financiare de piață, oferind instrumentele necesare pentru a backtest-a strategii, a analiza date istorice și a executa tranzacții live prin mai multe conturi de brokeraj. Proiectul se distinge printr-o bibliotecă specializată de analiză a opțiunilor care calculează Greeks, volatilitatea implicită și suprafețele de volatilitate folosind modelul Black-Scholes. Suportă în continuare tipare complexe de execuție a ordinelor, cum ar fi TWAP, Iceberg și POV, pentru a minimiza impactul asupra pieței în timpul intrării și ieșirii din poziții. SDK-ul acoperă o suprafață largă de capabilități, inclusiv regăsirea datelor de piață în timp real și istorice, gestionarea riscului cantitativ și monitorizarea portofoliului. Încorporează un model de execuție asincron pentru streaming-ul datelor și programarea sarcinilor, alături de instrumente pentru simularea tranzacționării multi-activ și analiza performanței. Biblioteca oferă o interfață grafică bazată pe web pentru monitorizarea strategiei și vizualizarea datelor.

Strawberry is a type-safe GraphQL library for Python that enables the design of schemas using Python type annotations and dataclasses. It functions as an asynchronous GraphQL server and execution engine, providing a bridge to expose schemas across ASGI-compliant web frameworks such as FastAPI, Django, Flask, and Litestar. The project implements GraphQL Federation, allowing for the creation of distributed schemas and entities that merge into a unified supergraph across multiple services. It also includes a dedicated toolkit for the Relay specification, supporting global object identification a

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.

Acest proiect este un portal de documentație API pentru schimburi de criptomonede. Oferă o referință tehnică pentru integrarea cu interfețele REST și WebSocket pentru tranzacționarea activelor digitale și streaming-ul datelor de piață. Site-ul servește ca o referință API REST cu descrieri ale endpoint-urilor bazate pe schemă și exemple de request-response, alături de un ghid de flux de date WebSocket pentru primirea actualizărilor live ale order book-ului și feed-urilor de preț. Documentația este implementată ca un site static bazat pe markdown, cu indexare de căutare client-side și navigare ierarhică. Utilizează generarea de conținut bazată pe schemă și încorporarea activelor legate pentru a menține consistența în specificațiile tehnice.

Tribeca este o platformă de tranzacționare a criptomonedelor Node.js concepută pentru tranzacționarea de înaltă frecvență și market making automatizat. Acesta funcționează ca un motor de execuție cu latență scăzută care automatizează procesul de furnizare a lichidității și capturare a spread-urilor de preț pe mai multe burse de criptomonede. Sistemul folosește un strat de conectivitate pentru a transmite date de piață în timp real și a executa tranzacții prin conexiuni de rețea persistente. Utilizează o integrare bazată pe adaptoare pentru a normaliza API-urile diverse ale platformelor într-un format unificat, permițând activități coordonate pe mai multe burse de criptomonede diferite. Platforma include un backtester algoritmic pentru validarea strategiilor pe baza datelor istorice și un tablou de bord vizual pentru monitorizarea pozițiilor active și a parametrilor de cotare. Capabilitățile suplimentare acoperă execuția ordinelor bazată pe evenimente, urmărirea pozițiilor bazată pe stare și stocarea persistentă în baza de date pentru auditarea înregistrărilor de tranzacționare.

XChange este o bibliotecă de integrare a schimburilor de criptomonede și un wrapper API care oferă o interfață unificată pentru conectarea la mai multe schimburi de criptomonede. Servește drept interfață de tranzacționare multi-schimb și un streamer de date de piață, normalizând datele brute de la diverși furnizori în obiecte de date standardizate. Proiectul se distinge printr-un sistem de normalizare bazat pe adaptoare și un model de streaming WebSocket reactiv conceput pentru a primi actualizări de preț și volum în timp real, minimizând în același timp utilizarea firelor de execuție. Include un handler de autentificare dedicat pentru gestionarea cheilor API, a nonces-urilor de cerere și a magazinelor de încredere SSL personalizate pentru a securiza conexiunile cu serverele private. Biblioteca acoperă domenii funcționale, inclusiv monitorizarea pieței în timp real, gestionarea conturilor private și executarea tranzacțiilor pe diferite platforme. Oferă utilitare atât pentru accesul la datele publice de piață, cât și pentru servicii de cont privat autentificate.

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