21 repository-uri
Mechanisms for emitting incremental updates from a pending promise before final resolution.
Distinct from Progress Tracking: Candidates focus on network transfers or education milestones, not the programmatic promise-level progress interface.
Explore 21 awesome GitHub repositories matching software engineering & architecture · Asynchronous Progress Tracking. Refine with filters or upvote what's useful.
FoundationDB is an ACID-compliant distributed transactional key-value store. It functions as a scalable database engine that ensures strict serializability and data consistency across a cluster of servers using a shared-nothing architecture. The system is distinguished by its multi-region replication capabilities, allowing data to be synchronized across different datacenters for high availability and disaster recovery. It utilizes optimistic concurrency control to manage distributed transactions and employs a majority-based coordination system to maintain cluster state. The platform provides
Tracks the state of pending operations and retrieves values or errors through polling, blocking, or callbacks.
q is a JavaScript promise library and asynchronous flow controller designed to manage non-blocking operations. It serves as a system for coordinating parallel tasks and sequencing asynchronous workflows through task chaining and error propagation. The library distinguishes itself with specialized debugging tools that capture long stack traces across asynchronous jumps and monitor unhandled rejections to prevent silent failures. It also functions as a remote object proxy, forwarding method calls to remote targets and routing responses back through promises. The project provides comprehensive
Allows pending promises to emit incremental progress updates to notify handlers of task completion percentage.
This is a Raft consensus library and distributed consensus engine implemented in Go. It provides the primitives necessary to build fault-tolerant distributed services by implementing a replicated state machine that ensures a group of servers agree on a shared system state through leader election and log replication. The project distinguishes itself through a pluggable architecture for storage backends and snapshot storage, decoupling the consensus logic from physical persistence. It includes specialized mechanisms for leadership transfer, protocol version management to support rolling upgrade
Implements tracking for cluster actions to block execution until operations complete or error.
The inspector is a diagnostic and validation tool for the Model Context Protocol. It provides an interactive interface and a transport proxy to discover, inspect, and execute the tools, prompts, and resources provided by an MCP server. The project serves as a debugger and compliance tester to verify that server implementations adhere to the protocol specification and JSON-RPC standards. It allows for real-time monitoring of message exchanges and logs between clients and servers across various transport layers, such as standard input/output and Server-Sent Events. The tool covers a broad rang
Sends asynchronous notifications containing completion percentages to provide real-time updates on long-running operations.
Model Context Protocol is a standardized framework for connecting large language models to external data sources and executable tools. It enables the creation of a universal interface where servers expose tools, resources, and prompts that can be discovered and utilized by various AI clients. The protocol utilizes a JSON-RPC message system that is transport-agnostic, supporting both standard input/output for local processes and HTTP with server-sent events for remote connections. It emphasizes security and control by delegating model sampling to the client to keep API keys secure from servers
Sends incremental status updates and progress percentages for asynchronous tasks using unique tokens.
This project is a centralized API specification registry and governance framework. It serves as a source of truth for structured API schemas, gRPC definitions, and data models used to maintain consistency across a large ecosystem of services. The system functions as a multi-language client generator, transforming standardized interface definitions into executable source code and language-specific libraries. This process ensures that client libraries and technical documentation remain synchronized by deriving them directly from the original interface definitions. The project also covers the m
Provides mechanisms for tracking the progress of long-running tasks through a polling mechanism.
BullMQ is a Redis-backed message queue library and background processor designed for distributed task queueing. It functions as a distributed queue manager and task scheduler, utilizing Redis to manage asynchronous job processing and persistence. The system distinguishes itself through its role as a job workflow orchestrator, enabling the definition of complex parent-child job dependencies and hierarchies for multi-step workflows. It provides sandboxed process execution to isolate heavy workloads and prevent event loop blocking, alongside distributed rate limiting to protect downstream servic
Emits numeric or object updates during job execution to notify listeners of completion state.
node-fluent-ffmpeg este un wrapper Node.js pentru FFmpeg care oferă o interfață fluentă pentru executarea comenzilor media și procesarea fișierelor. Funcționează ca un manager de procese care gestionează ciclul de viață al binarilor FFmpeg externe, permițând transcodarea media programatică, generarea de miniaturi video și extragerea metadatelor prin ffprobe. Biblioteca se distinge printr-un constructor de comenzi care traduce apelurile de metode JavaScript în argumente de linie de comandă. Dispune de monitorizarea progresului bazată pe evenimente pentru a urmări cadrele procesate și throughput-ul, precum și capacitatea de a direcționa datele media procesate direct către fluxuri inscriptibile (writable streams) pentru manipulare în timp real. Proiectul acoperă capabilități largi de procesare media, inclusiv configurarea codificării pentru proprietățile audio și video, definiții complexe de filtergraph pentru efecte vizuale și audio, și gestionarea intrărilor pentru concatenarea mai multor surse. Include, de asemenea, instrumente pentru sondarea containerelor și fluxurilor media pentru a recupera metadate tehnice.
Emits incremental progress updates based on processed frames and timestamps parsed from the process output.
Subsync is a subtitle synchronization tool that aligns subtitle timing to video audio tracks or other synchronized subtitle files. It functions as an audio-based aligner and timing validator to ensure dialogue and captions match during playback. The system utilizes audio-text cross-correlation to match voice activity peaks in audio tracks against subtitle timestamps. It includes a remote media sync client that retrieves files from external servers using standard network protocols for local processing. To ensure accuracy, the tool calculates confidence scores to block updates that fall below
Uses a handler mechanism to report incremental alignment and extraction progress from the core to the UI.
Riverpod is a reactive state management framework for Dart that manages application state through providers which automatically track dependencies and rebuild dependents when values change. It functions as an asynchronous data caching library, caching results of async operations and exposing loading, error, and data states to widgets without manual future handling. The framework includes a provider composition system that combines multiple providers into derived values that recompute automatically when any dependency changes, along with code generation for state providers that reduces boilerpl
Initiates an asynchronous callback via a mutation object and tracks its execution state for UI feedback.
Unstract is an unstructured data extraction system and ETL pipeline orchestrator that uses large language models to convert documents, images, and scans into structured JSON. It provides a document extraction API for integrating these capabilities into external automation tools and includes a Model Context Protocol server to connect AI agents to structured information retrieval. The system ensures data accuracy through a verification tool featuring dual-model verification and human-in-the-loop review with coordinate-based document highlighting. It utilizes natural language extraction schemas
Provides a dedicated endpoint for clients to poll the status and retrieve results of asynchronous document extraction requests.
Monitors the asynchronous processing status and progress percentage of document collections.
This repository provides a collection of reference implementations, toolkits, and orchestration tools for training and deploying large-scale AI models on Cloud TPU hardware. It serves as a framework for managing the lifecycle of accelerator clusters, including hardware orchestration and the provisioning of high-performance compute infrastructure for machine learning workloads. The project specifically enables the pre-training of foundation models, large language models, and complex reasoning architectures through distributed training toolkits and multi-host scaling recipes. It further provide
Monitors the state of asynchronous hardware operations and provides capabilities to cancel or delete them.
zvec is an embedded vector database engine and indexing library designed for high-dimensional similarity search. It functions as a hybrid search engine and a retrieval-augmented generation knowledge base, allowing for the storage and retrieval of dense and sparse vectors. The system is distinguished by its hybrid retrieval pipeline, which fuses vector similarity, full-text keyword matching, and scalar metadata filtering into single query operations. It supports a plugin-based model integration system for registering custom embedding models and rerankers, as well as language bindings for nativ
Tracks the real-time building progress and status of vector indexes.
Effector is a reactive state management library and data flow orchestrator designed for building complex, event-driven applications. It models application logic as a directed acyclic graph, where state updates and asynchronous side effects propagate automatically through declarative pipelines. By decoupling business logic from user interface layers, it allows developers to maintain state in independent containers that communicate via standard interfaces, ensuring the system remains framework-agnostic. The library distinguishes itself through its robust support for isolated execution scopes, w
Tracks the progress and resolution of pending asynchronous operations via polling, blocking, or callbacks.
Effector is a reactive state management library designed for building complex, event-driven applications. It functions as a data flow engine that models application logic as a directed acyclic graph, ensuring that state updates propagate automatically through interconnected nodes. By utilizing atomic state updates and declarative unit composition, the library maintains data consistency and provides a predictable execution model for managing application state. The project distinguishes itself through its framework-agnostic architecture, which decouples business logic from user interface implem
Tracks ongoing computations and pauses execution until all triggered asynchronous effects complete.
Mixitup este o bibliotecă de animație a elementelor DOM fără dependențe și un motor de layout de tip grid. Servește drept filtru de conținut client-side și controler UI bazat pe date, conceput pentru a gestiona tranziția vizuală fluidă a elementelor HTML în timpul operațiunilor de inserare, eliminare și sortare. Sistemul se specializează în crearea de interfețe de galerie interactive și filtrarea dinamică a conținutului. Permite reorganizarea elementelor folosind atribute personalizate sau secvențe aleatorii, sincronizând în același timp aranjarea și vizibilitatea elementelor interfeței cu un model de date subiacent. Dincolo de filtrare și sortare, biblioteca acoperă gestionarea elementelor DOM, inclusiv inserarea și eliminarea dinamică a țintelor. Oferă capabilități pentru animarea redimensionării containerului, definirea de efecte de animație personalizate și utilizarea de „stagger-uri” non-liniare pentru apariția elementelor.
Returns a promise or executes a callback when asynchronous layout operations complete.
snarkOS este un mediu de runtime distribuit și un blockchain cu dovezi zero-knowledge, conceput pentru implementarea și gestionarea aplicațiilor care se bazează pe primitive criptografice zero-knowledge. Acesta funcționează ca un registru descentralizat care utilizează dovezi zero-knowledge pentru a verifica tranzițiile de stare și tranzacțiile fără a dezvălui date private. Sistemul utilizează o rețea de consens cu conturi garantate (bonded-account), unde validatorii blochează activele drept colateral pentru a securiza o stare globală. Dispune de un registru de stare criptat pentru a urmări datele aplicației în mod privat și un prover accelerat prin GPU care descarcă calculele criptografice grele către hardware-ul grafic pentru a crește viteza de dovedire. Proiectul oferă o ierarhie de noduri bazată pe roluri, constând în noduri validator, core și prover. Suprafața sa de capabilități acoperă operarea descentralizată a nodurilor, sincronizarea rețelei peer-to-peer și gestionarea stării criptate a aplicației. Instrumentele suplimentare includ o interfață de linie de comandă pentru controlul nodurilor, telemetrie pentru monitorizarea participării la consens și capacitatea de a boota rețele locale de dezvoltare.
Tracks the outcome and participation of distributed consensus actions using system logs and API endpoints.
java-tron este o implementare Java a unui nod complet de blockchain Tron. Acesta oferă infrastructura de bază pentru rularea unui nod de rețea, validarea tranzacțiilor și producerea blocurilor. Proiectul include un motor de consens proof-of-stake, o bază de date de registru distribuit și un runtime de smart contract pentru a gestiona tranzițiile de stare on-chain. Sistemul se distinge prin suportul său pentru operațiuni de nod complet și lite, utilizând snapshot-uri de stare pentru a accelera sincronizarea și a reduce cerințele hardware. Dispune de o abstractizare a bazei de date multi-motor care permite migrarea stocării, partiționarea și curățarea pe diferite discuri fizice pentru a optimiza performanța. Software-ul acoperă o gamă largă de capabilități blockchain, inclusiv gestionarea activelor digitale, guvernanța rețelei prin alegeri reprezentative și execuția logicii programabile prin intermediul unei mașini virtuale. Expune datele și funcțiile blockchain printr-un gateway care suportă protocoalele HTTP, gRPC și JSON-RPC. Proiectul oferă instrumente pentru inițializarea nodurilor de rețea, implementarea mediilor blockchain private și gestionarea keystore-urilor de cont criptate.
Tracks representative rotations and block production metrics to monitor consensus operations.
tapkulibrary is a collection of reusable user interface elements and layout utilities for building native iOS applications. It provides a modular set of building blocks, including a custom graphics framework, networking toolkits, and specialized interface components. The library includes a dedicated media gallery component for creating 3D perspective coverflow galleries and swipeable lists, as well as a grid-based calendar interface for monthly event layouts and date selection. The toolkit covers asynchronous network communication, allowing for data request scheduling on background threads.
Tracks the progress and resolution of pending asynchronous network operations.