18 Repos
Infrastructure for managing asynchronous task execution and message processing.
Explore 18 awesome GitHub repositories matching software engineering & architecture · Job Queues. Refine with filters or upvote what's useful.
This project is a community-driven directory that aggregates essential software projects and educational content for the Node.js ecosystem. It functions as a centralized knowledge base and discovery index, designed to simplify the navigation of a fragmented technical landscape by providing a structured collection of high-quality links, tools, and learning materials. The repository distinguishes itself through a decentralized, peer-reviewed curation model. By utilizing standard version control workflows and pull requests, the community ensures that all listed resources undergo human verificati
Features robust infrastructure solutions for managing asynchronous task execution and message processing.
Bull is a Node.js library for managing distributed jobs and message queues using Redis as the primary data store. It functions as a distributed task worker, job scheduler, and priority queue manager designed to handle asynchronous workloads across multiple processes. The project distinguishes itself by providing a persistent communication channel that decouples servers through the exchange of serializable data objects. It ensures distributed system reliability by detecting stalled tasks and recovering from process crashes to ensure every queued job is completed. The system covers a broad ran
Provides infrastructure for managing asynchronous task execution by enqueueing serializable data objects.
This tool is a command-line utility designed for automated web resource discovery, fuzzing, and application structure mapping. It functions as a security-focused scanner that identifies hidden files, directories, parameters, and virtual hosts by injecting payloads into HTTP requests. By systematically testing how servers handle various inputs, it assists in mapping the architecture of web applications and uncovering potential security vulnerabilities. The tool distinguishes itself through a highly concurrent engine that manages asynchronous request execution and recursive job orchestration. I
Manages a dynamic queue of discovery tasks that automatically spawns new scan passes when specific directory structures are identified.
algorithm-base is an educational library and study guide designed for simulating algorithms and studying data structures. It functions as an execution visualizer that renders step-by-step state changes and pointer updates through animated simulations to illustrate how data movement works. The project distinguishes itself by mapping conceptual logic directly to multi-language source code implementations. It utilizes a comparative analysis framework to evaluate different algorithmic strategies based on stability, time complexity, and space complexity, while organizing problems by underlying mec
Demonstrates enqueueing and dequeueing elements using animations to simulate the first-in-first-out mechanism.
Inbox Zero is an AI-powered email automation platform and inbox organizer. It uses large language models to automatically categorize, label, and archive emails, while providing a conversational interface for managing workflows and drafting responses through natural language. The project distinguishes itself by integrating real-time calendar availability into its drafting process and generating AI-summarized meeting briefings. It supports a pluggable AI provider interface with model fallback chains, allowing it to connect to various cloud or local LLM providers. Users can also control their in
Executes high-volume background tasks like bulk cleaning and AI categorization using a durable job queue.
Hangfire is a background job scheduler and distributed task queue for .NET applications. It serves as a job orchestration framework that offloads heavy processing to background workers using a SQL-backed processor to manage job state across multiple servers. The framework distinguishes itself through reliable task scheduling, where job metadata and arguments are persisted in an external database to ensure tasks survive application restarts. It supports advanced orchestration patterns, including the ability to chain dependent tasks so that a child job triggers automatically upon the successful
Provides a robust system for enqueueing method calls and arguments to be processed asynchronously.
Redis is a high-performance in-memory key-value store that functions as a distributed cache, message broker, and NoSQL database. It provides sub-millisecond read and write access to data stored in RAM and can operate as a vector database for indexing high-dimensional embeddings. The system supports a wide range of data storage and synchronization primitives, including the management of strings, hashes, lists, sets, and JSON documents. It enables real-time data operations through atomic transactions, hybrid persistence using snapshots and append-only logs, and high-availability configurations
Implements distributed task queues using streams and consumer groups to ensure single-processing of jobs.
Romm is a self-hosted game library manager and ROM management web interface. It serves as a central server for storing and categorizing game files and emulator firmware, providing a web-based browser to organize collections through automated library scanning and metadata retrieval. The project distinguishes itself by integrating a web-based emulator frontend that uses WebAssembly to play games directly in the browser. It further provides a game save synchronization server that uses SSH-based synchronization to transfer save states and progress between the server and registered handheld device
Uses a Redis-backed queue to process long-running operations and asynchronous jobs in the background.
ytdlnis is a mobile application that serves as a graphical client for the yt-dlp engine on Android. It functions as a media downloader and manager, providing a user interface to retrieve video and audio from websites. The project distinguishes itself by integrating directly with the Android system share menu and intents to trigger background downloads from external apps. It includes a dedicated authentication cookie manager to import and sync browser session data, enabling the retrieval of private, age-restricted, or premium content. The application covers broad capability areas including au
Allows users to pause, cancel, or reorder tasks within the active download queue.
Databasus is a self-hosted backup platform that automates PostgreSQL backups, verifies their restorability, and stores them across multiple destinations while managing team access with role-based permissions. It combines on-the-fly AES-256-GCM encryption, cron-driven scheduling, job-queue-based verification, multi-destination storage, WAL streaming, throwaway container restore testing, and workspace-based role access control into a unified backup system. The platform distinguishes itself through automatic backup verification that restores each backup into a temporary database container for in
Dispatches verification tasks to a queue for distributed, asynchronous restore testing.
Persepolis is a Python-based download manager and graphical user interface for the aria2 engine. It functions as a concurrent file downloader that splits files into multiple chunks to be retrieved simultaneously, maximizing available network bandwidth. The application integrates a media extraction engine to resolve direct URLs, enabling the retrieval of video and audio content from various online streaming platforms and hosting services. It provides tools for download queue management and automation, including the ability to schedule specific start times or define time windows for downloads
Organizes pending download tasks into a managed queue to control the order and number of active transfers.
Scraperr ist eine selbstgehostete Plattform für Web-Scraping und Crawling, die für die Extraktion strukturierter Daten von Websites mittels XPath-Selektoren entwickelt wurde. Sie fungiert als containerisiertes System zur Verwaltung von Scraping-Jobs über eine Queue und zur Analyse der resultierenden Inhalte mittels künstlicher Intelligenz. Das Projekt zeichnet sich durch seine Kubernetes-native Architektur aus, die eine skalierbare Bereitstellung und Verwaltung über Paketmanager ermöglicht. Es enthält eine Crawling-Engine, die Domain-Level-Spidering unterstützt, um verlinkte Seiten zu entdecken, sowie einen Datenanalysator, der künstliche Intelligenz zur Abfrage extrahierter Webinhalte nutzt. Die Plattform deckt ein breites Spektrum an Funktionen ab, einschließlich automatisierter Datenextraktion, Bulk-Web-Crawling und Download von Mediendateien. Sie bietet Tools zur Visualisierung gescrapter Daten in Tabellen, zur Konfiguration benutzerdefinierter Request-Header zur Nachahmung von Browser-Identitäten und zum Export von Ergebnissen in CSV- oder Markdown-Formate. Die Anwendung unterstützt anpassbare Installationsparameter und Versions-Updates über Kubernetes-Deployment-Konfigurationen.
Manages bulk scraping tasks through a sequential job queue to ensure reliable data collection.
ace-step-ui is an AI music production workspace and interface for generating, editing, and organizing synthetic audio tracks and vocals. It provides a technical control panel for managing prompts, seeds, and style parameters to produce high-quality audio. The project includes a digital audio workstation interface for trimming and fading files, alongside an audio stem separation tool that splits mixed tracks into individual components such as drums, bass, and vocals. It also features a music video creator for generating visual content and procedural album art to accompany generated music. The
Manages a sequence of high-compute audio generation requests using asynchronous job queues.
Bee-queue ist ein Node.js-Hintergrundverarbeitungssystem, das Redis für Job-Queueing und Persistenz verwendet. Es wurde entwickelt, um rechenintensive Aufgaben vom Haupt-Execution-Thread auf Hintergrund-Worker auszulagern und so die Reaktionsfähigkeit der Anwendung aufrechtzuerhalten. Das Projekt bietet verteilte Job-Verarbeitung, die es Worker-Nodes ermöglicht, über mehrere Prozesse hinweg zu laufen, um große Mengen an Aufgaben gleichzeitig zu bewältigen. Es stellt eine zuverlässige Aufgabenausführung durch automatische Retries und die Wiederherstellung hängengebliebener Prozesse sicher. Der Funktionsumfang umfasst asynchrones Task-Scheduling für verzögerte Jobs, Concurrency-Control für Worker-Nodes und Job-Lifecycle-Management. Es enthält Tools zur Überwachung des Queue-Status, zur Verfolgung des Job-Fortschritts und zum Abrufen von Ergebnissen basierend auf dem Job-Zustand. Das System unterstützt Bulk-Job-Enqueuing zur Reduzierung des Netzwerk-Overheads und ermöglicht benutzerdefinierte Job-Identifikatoren sowie konfigurierbare Backoff-Strategien für fehlgeschlagene Aufgaben.
Creates and stores tasks in a persistent store for asynchronous processing.
Pauses or resumes job execution based on network type, requiring connectivity or unmetered connections.
pg-boss is a background task scheduler and distributed task queue that uses PostgreSQL as a reliable message broker for asynchronous job processing. It provides a system for distributing work across multiple application instances, ensuring exactly-once delivery through atomic database transactions. The project includes a cron job scheduler for automating recurring tasks and a PostgreSQL pub-sub system for fan-out event distribution. It also features a web-based management dashboard for monitoring queue statistics and controlling job lifecycles, including manual retries and cancellations. Cap
Provides a web interface for monitoring queue statistics and manually retrying or cancelling jobs.
Bull-board is a web-based administrative interface and dashboard for visualizing, monitoring, and managing asynchronous job queues in Node.js. It serves as a control panel for background job administrators to oversee queue processing and manage the lifecycle of tasks powered by BullMQ, Bull, and Redis. The project distinguishes itself by providing a pluggable interface that integrates with various web server frameworks as middleware. It utilizes an adapter-based system to provide unified administrative controls across different queue backends and includes authentication guards to secure the d
Allows pausing or resuming job processing at the queue level to regulate the flow of workloads.
AnyCrawl is an AI-powered data extractor, automated web crawler, and headless browser orchestrator. It serves as a web content extraction API and a gateway that connects crawling and scraping tools to language models using a standardized API protocol. The project specializes in converting unstructured website content into structured JSON or markdown optimized for AI assistants. It utilizes language models and JSON schemas to pull specific information into validated formats and provides capabilities for AI page summarization and LLM-optimized content extraction. The system manages comprehensi
Implements an asynchronous job queue to manage and monitor concurrent crawling tasks independently.