Awesome GitHub RepositoriesRetry State Tracking

Tenacity is a Python retry library and fault tolerance framework designed to automatically re-execute failing functions based on custom conditions, wait intervals, and stop criteria. It provides a mechanism to apply retry logic to both synchronous functions and asynchronous coroutines. The library implements exponential backoff to increase delays between retries, helping to manage transient network failures and prevent the overloading of services. Its capabilities cover the definition of retry conditions based on exception types or return values, as well as the enforcement of duration limits

Fluent Bit ist ein Cloud-nativer Log-Shipper und einheitlicher Telemetrie-Collector, der als ressourceneffiziente Datenpipeline konzipiert ist. Er nimmt Logs, Metriken und Traces aus mehreren Quellen auf und verarbeitet sie in Echtzeit, bevor die Daten an externe Speicher-Backends weitergeleitet werden. Das Projekt fungiert als Echtzeit-Stream-Prozessor und OpenTelemetry-Log-Prozessor, der in der Lage ist, Daten mithilfe von SQL und bedingter Logik zu transformieren und zu filtern. Es fungiert zudem als verteilter Tracing-Agent, der Traces sampeln kann, um das Datenvolumen zu reduzieren und gleichzeitig vollständige Anforderungspfade zu bewahren. Das System bietet eine zuverlässige Datenübermittlung durch dateisystembasiertes Buffering und zustandsbehaftete Wiederholungslogik, um Datenverlust bei Ausfällen zu verhindern. Seine modulare Architektur unterstützt steckbare Eingabe- und Ausgabe-Plugins, metadatengesteuertes Routing und die Möglichkeit, Funktionen über gemeinsam genutzte Bibliotheken zu erweitern. Die Software kann als Container über verschiedene CPU-Architekturen und Betriebssysteme hinweg bereitgestellt werden.

Flyte is a Kubernetes-based machine learning orchestrator and containerized pipeline manager designed for coordinating AI workflows and data pipelines. It functions as an engine for defining and executing resilient pipelines, utilizing a data lineage tracker to maintain immutable execution states and ensure reproducible outputs. The platform distinguishes itself by packaging individual tasks into separate containers to ensure dependency isolation and environment consistency. It provides specialized capabilities for machine learning, including the transformation of trained models into scalable

Dieses Projekt ist eine JavaScript-Integrationsbibliothek für Analysedaten und ein Client-Side-Event-Collector, der entwickelt wurde, um Nutzerverhalten aufzuzeichnen und diese Daten über eine einheitliche Schnittstelle an verschiedene Analyse-Dienste von Drittanbietern zu verteilen. Es fungiert als Customer Data Platform, die Nutzer identifiziert, Merkmale verwaltet und Event-Streams an verschiedene Analysetools und Data Warehouses weiterleitet. Die Bibliothek zeichnet sich durch einen Multi-Destination-Event-Router und HTTP-Tracking-Middleware aus, die Event-Payloads vor der Übertragung abfängt und modifiziert. Sie implementiert Identitätsmanagement-Primitive für die Nutzeridentifizierung, Identitäts-Aliasing zur Zusammenführung von Profilen sowie Cross-Subdomain-Tracking durch Speicherung von Identifikatoren auf der Top-Level-Domain. Das System deckt ein breites Spektrum an Funktionen ab, darunter die Überwachung von Nutzerinteraktionen wie Seitenaufrufe, Formularübermittlungen und Link-Klicks sowie das Tracking von Marketingkampagnen durch Extraktion von UTM-Parametern. Für eine hohe Zuverlässigkeit nutzt es Event-Request-Batching, auf Local Storage basierende Retry-Queues mit exponentiellem Backoff sowie Browser-Keepalive-Flags, um die Datenerfassung bei Seitenumleitungen sicherzustellen. Die Bibliothek unterstützt zudem Tracking-Pixel für Umgebungen, die die JavaScript-Ausführung einschränken, und bietet Mechanismen zur Verschleierung von Integrations-URLs, um Request-Blockierungen zu verhindern.

WePush ist ein Multi-Channel-Benachrichtigungs-Gateway und Massen-Nachrichten-Dispatcher, der für den Versand personalisierter Benachrichtigungen über SMS-Anbieter, E-Mail, soziale Plattformen und Unternehmenskommunikationskanäle entwickelt wurde. Es fungiert als Enterprise-Messaging-Hub, der Benachrichtigungen über eine einheitliche Schnittstelle leitet, einschließlich eines zentralen Managers für mehrere Cloud-SMS-Anbieter. Das System enthält eine Engine zur Zeitplanung von Benachrichtigungen, um Zustellungen zu bestimmten zukünftigen Zeitpunkten auszulösen. Es unterstützt die Verwaltung mehrerer Konten, sodass Benutzer zwischen verschiedenen Dienstanbieter-Identitäten wechseln können, um Benachrichtigungen von verschiedenen Konten aus zu versenden. Die Plattform bietet Funktionen zur Personalisierung von Nachrichteninhalten durch ein Vorlagensystem und verwaltet groß angelegte Aussendungen über den Import von Empfängerlisten. Zudem integriert sie eine Zustellungshistorie, um den Status gesendeter Benachrichtigungen zu überwachen und den erneuten Versand fehlgeschlagener Nachrichten zu verwalten.

This is a Go library that implements a leaky-bucket algorithm to control the frequency of operations and requests per second. It serves as a concurrent request throttler that blocks calling threads until request slots become available to maintain a steady execution rate. The project includes a traffic burst controller that allows the accumulation of unspent request capacity, permitting short-term spikes in volume while maintaining a defined long-term average rate. The library provides capabilities for operation frequency limiting, request interval enforcement, and application resource protec

Dies ist ein Web-basierter, adaptiver Touch-Typing-Trainer, der entwickelt wurde, um Nutzern zu helfen, das Zehnfingersystem durch personalisierte Übungen zu meistern. Er fungiert als heuristischer Tipp-Tutor, der benutzerdefinierte Lektionen basierend auf individuellen Tastenanschlag-Statistiken und Genauigkeitsdaten generiert. Die Anwendung nutzt adaptives Skill-Modeling, um die schwierigsten Tasten für einen Nutzer zu priorisieren, und sagt die Anzahl der Lektionen voraus, die erforderlich sind, um spezifische Zielgeschwindigkeiten zu erreichen. Ein Performance-Dashboard wandelt rohe Tipp-Statistiken in grafische Darstellungen um, um Lernfortschritt und Kompetenz im Zeitverlauf zu visualisieren. Das System deckt die Echtzeit-Eingabeverarbeitung zur Berechnung von sofortiger Genauigkeit und Geschwindigkeit ab sowie die Verfolgung langfristiger Performance-Metriken, um den Tipp-Fortschritt zu überwachen.

This is a Go library providing a framework for managing repetitive task execution and implementing exponential backoff strategies. It serves as a concurrency tool designed to prevent system overload during failures by retrying operations with increasing delays. The project implements a retry strategy framework that manages attempt limits and timeouts during unstable network or system calls. It specifically provides an implementation of the exponential backoff algorithm to handle failing operations. The library covers reliability patterns for mitigating transient failures and service outages,

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

Spring Retry is a Java library that provides exception handling, automated operation reattempts, backoff strategies, and recovery mechanisms for application workflows. It handles transient operation failures through declarative annotations, programmatic templates, stateful context storage, and fallback recovery paths. The library controls retry behavior by specifying attempt counts, timeouts, and inclusion or exclusion rules for specific exception types. It pauses execution between attempts using fixed, exponential, or randomized backoff intervals, and caches retry state outside the call stac