2 dépôts
Operations for initializing and deleting the underlying database structures that represent named queues.
Distinct from Queue Management: Focuses on the creation and destruction of the queue entity itself rather than prioritizing tasks within a queue.
Explore 2 awesome GitHub repositories matching devops & infrastructure · Queue Lifecycle Management. Refine with filters or upvote what's useful.
PGMQ est un système de file d'attente de messages léger implémenté en tant qu'extension PostgreSQL pour gérer les tâches asynchrones. Il fonctionne comme un courtier de messages basé sur une base de données qui exploite PostgreSQL pour le stockage persistant, les opérations atomiques et la livraison pilotée par notification. Le système fournit un modèle de file d'attente compatible SQS avec des délais de visibilité et une livraison différée. Il prend en charge un ordre strict premier entré, premier sorti (FIFO) via des clés de groupe et une récupération par lots pour garantir le traitement séquentiel des tâches liées. Le projet couvre un cycle de vie complet des messages, y compris la production, la consommation via des opérations de dépilement atomique et la gestion administrative telle que la purge des files d'attente et le contrôle du cycle de vie. Il inclut des capacités de routage via des modèles basés sur des sujets et des fonctionnalités de fiabilité comme la mise en file d'attente des messages morts (dead letter queueing), l'archivage des messages et la logique de réessai. Des outils de surveillance sont fournis pour suivre les métriques opérationnelles telles que la longueur de la file d'attente et le débit.
Implements administrative tools for creating and deleting the database tables used for queue storage.
Oban is a distributed, database-backed task processor for Elixir applications. It functions as a reliable job queue that leverages relational databases as the primary source of truth for scheduling, persistence, and state management. By utilizing the database for coordination, it ensures that background tasks remain durable across system restarts and consistent across distributed clusters. The system distinguishes itself through its use of database-level primitives to manage cluster-wide operations. It employs listen-notify messaging to trigger immediate worker wake-ups, bypassing the need fo
Allows programmatic control over starting, pausing, or resuming queues for maintenance and demand management.