18 Repos
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 18 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 ist ein Node.js-Wrapper für FFmpeg, der eine flüssige Schnittstelle zur Ausführung von Medienbefehlen und zur Dateiverarbeitung bietet. Er fungiert als Prozessmanager, der den Lebenszyklus externer FFmpeg-Binärdateien handhabt und programmatisches Medien-Transcoding, Video-Thumbnail-Generierung und Metadaten-Extraktion via ffprobe ermöglicht. Die Bibliothek zeichnet sich durch einen Befehls-Builder aus, der JavaScript-Methodenaufrufe in Befehlszeilenargumente übersetzt. Sie bietet ereignisgesteuerte Fortschrittsüberwachung zur Verfolgung verarbeiteter Frames und Durchsatz sowie die Möglichkeit, verarbeitete Mediendaten direkt an beschreibbare Streams für die Echtzeit-Handhabung weiterzuleiten. Das Projekt deckt ein breites Spektrum an Medienverarbeitungsfunktionen ab, einschließlich Kodierungskonfiguration für Audio- und Videoeigenschaften, komplexe Filtergraph-Definitionen für visuelle und Audio-Effekte sowie Eingabeverwaltung zum Zusammenführen mehrerer Quellen. Es enthält zudem Werkzeuge zur Untersuchung von Mediencontainern und Streams, um technische Metadaten abzurufen.
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.
Mixitup ist eine abhängigkeitsfreie DOM-Element-Animationsbibliothek und Grid-Layout-Engine. Sie dient als clientseitiger Inhaltsfilter und datengesteuerter UI-Controller, der darauf ausgelegt ist, den reibungslosen visuellen Übergang von HTML-Elementen während Einfüge-, Entfernungs- und Sortieroperationen zu verwalten. Das System ist auf die Erstellung interaktiver Galerie-Schnittstellen und dynamischer Inhaltsfilterung spezialisiert. Es ermöglicht die Reorganisation von Elementen unter Verwendung benutzerdefinierter Attribute oder zufälliger Sequenzen, während die Anordnung und Sichtbarkeit von Schnittstellenelementen mit einem zugrunde liegenden Datenmodell synchronisiert wird. Über die Filterung und Sortierung hinaus deckt die Bibliothek das DOM-Element-Management ab, einschließlich des dynamischen Einfügens und Entfernens von Zielen. Sie bietet Funktionen zum Animieren von Container-Größenänderungen, zum Definieren benutzerdefinierter Animationseffekte und zur Verwendung nicht-linearer Stagger-Effekte für das Erscheinen von Elementen.
Returns a promise or executes a callback when asynchronous layout operations complete.
snarkOS ist eine verteilte Laufzeitumgebung und eine Zero-Knowledge-Proof-Blockchain, die für die Bereitstellung und Verwaltung von Anwendungen entwickelt wurde, die auf kryptografischen Zero-Knowledge-Primitiven basieren. Es fungiert als dezentrales Ledger, das Zero-Knowledge-Proofs verwendet, um Zustandsübergänge und Transaktionen zu verifizieren, ohne private Daten preiszugeben. Das System nutzt ein Bonded-Account-Konsensnetzwerk, bei dem Validatoren Vermögenswerte als Sicherheit hinterlegen, um einen globalen Zustand zu sichern. Es verfügt über ein verschlüsseltes Zustands-Ledger zur privaten Verfolgung von Anwendungsdaten und einen GPU-beschleunigten Prover, der rechenintensive kryptografische Berechnungen auf Grafikhardware auslagert, um die Proving-Geschwindigkeit zu erhöhen. Das Projekt bietet eine rollenbasierte Node-Hierarchie, bestehend aus Validator-, Core- und Prover-Nodes. Der Funktionsumfang deckt den Betrieb dezentraler Nodes, die Synchronisation von Peer-to-Peer-Netzwerken und die Verwaltung verschlüsselter Anwendungszustände ab. Zusätzliche Tools umfassen ein Command-Line-Interface für die Node-Steuerung, Telemetrie zur Überwachung der Konsens-Teilnahme und die Möglichkeit, lokale Entwicklungsnetzwerke zu booten.
Tracks the outcome and participation of distributed consensus actions using system logs and API endpoints.
java-tron ist eine Java-Implementierung eines Tron-Blockchain-Full-Nodes. Es bietet die Kerninfrastruktur für den Betrieb eines Netzwerkknotens, die Validierung von Transaktionen und die Erstellung von Blöcken. Das Projekt enthält eine Proof-of-Stake-Konsens-Engine, eine verteilte Ledger-Datenbank und eine Smart-Contract-Runtime zur Verwaltung von On-Chain-Zustandsübergängen. Das System zeichnet sich durch die Unterstützung von Full- und Lite-Node-Operationen aus und nutzt State-Snapshots, um die Synchronisierung zu beschleunigen und Hardwareanforderungen zu reduzieren. Es verfügt über eine Multi-Engine-Datenbankabstraktion, die Speicher-Migration, Partitionierung und Pruning über verschiedene physische Festplatten hinweg ermöglicht, um die Performance zu optimieren. Die Software deckt ein breites Spektrum an Blockchain-Funktionen ab, einschließlich digitalem Asset-Management, Netzwerk-Governance durch Repräsentantenwahlen und die Ausführung programmierbarer Logik via Virtual Machine. Sie stellt Blockchain-Daten und -Funktionen über ein Gateway bereit, das HTTP-, gRPC- und JSON-RPC-Protokolle unterstützt. Das Projekt bietet Tools zur Initialisierung von Netzwerkknoten, zur Bereitstellung privater Blockchain-Umgebungen und zur Verwaltung verschlüsselter Account-Keystores.
Tracks representative rotations and block production metrics to monitor consensus operations.
Dieses Projekt ist ein Java-Messaging-SDK, das entwickelt wurde, um den Echtzeit-Datenaustausch zwischen Anwendungen und Message-Brokern zu erleichtern. Es fungiert als MQTT-Client-Bibliothek und bietet die notwendigen Tools zur Implementierung von Publish-Subscribe-Messaging-Mustern innerhalb verteilter Systeme und internetverbundener Geräteumgebungen. Die Bibliothek zeichnet sich durch ihren Fokus auf belastbare Netzwerkkonnektivität und zuverlässige Nachrichtenübermittlung aus. Sie verwaltet persistente Verbindungen über interne Zustandsmaschinen, die automatische Wiederverbindungen und Keep-Alive-Heartbeats handhaben, was Stabilität in Umgebungen mit intermittierendem Netzwerkzugriff sicherstellt. Anwendungen können spezifische Quality-of-Service-Level konfigurieren, um Datenintegrität zu garantieren, von Fire-and-Forget bis hin zu Exactly-Once-Zustellung, und Last-Will-and-Testament-Konfigurationen nutzen, um unerwartete Client-Verbindungsabbrüche zu handhaben. Das Framework unterstützt hochvolumige Datenverarbeitung durch die Verwendung nicht-blockierender, asynchroner Kommunikationsprimitive. Es ermöglicht Entwicklern, Nachrichten über themenbasierte Abonnements zu routen, einschließlich Unterstützung für Wildcard-Muster, während der Fortschritt einzelner Operationen über tokenbasierte Handles verfolgt wird. Die Bibliothek wird als Standard-Java-Entwicklungskit für die Integration in breitere Messaging- und IoT-Infrastrukturen vertrieben.
Provides handle objects to monitor the progress and completion status of asynchronous message delivery operations.