5 dépôts
Synchronizing event streams across multiple server instances using external distributed data stores.
Distinct from Stream Event Synchronizers: None of the candidates cover distributed synchronization via external stores like Redis or Kafka for server instances.
Explore 5 awesome GitHub repositories matching data & databases · Distributed Event Synchronization. Refine with filters or upvote what's useful.
Yoga is a GraphQL server framework and runtime-agnostic HTTP handler used to build and deploy GraphQL APIs. It functions as a toolkit for managing schemas and resolvers, providing a spec-compliant environment for hosting APIs across diverse JavaScript runtimes, including Node.js, Deno, Bun, and serverless cloud environments. The project distinguishes itself through its ability to act as an Apollo Federation gateway, composing multiple subgraphs into a single unified supergraph. It also serves as a dedicated subscription server, delivering real-time data streaming via both WebSockets and Serve
Integrates external datastores like Redis or Kafka to synchronize event streams across multiple server instances.
MISP is an open-source threat intelligence sharing platform designed for collecting, storing, and distributing structured threat indicators and intelligence. At its core, it provides a distributed synchronization protocol for transferring events between instances, an attribute-based correlation engine that links matching indicators across events, and a REST API with an OpenAPI specification for programmatic access to threat data. The platform uses formal data formats for JSON, taxonomy, galaxy, and object templates to enable compatibility across tools and communities. The platform distinguish
Transfers published events to configured remote instances subject to distribution rules and push settings.
ServiceStack est un framework web .NET haute performance conçu pour construire des API typées en utilisant des objets de requête et de réponse fortement typés. Il fonctionne comme un moteur d'API basé sur les messages qui découple la logique métier de la couche de transport, permettant aux services d'être exposés via plusieurs protocoles incluant HTTP, gRPC et divers fournisseurs de files d'attente de messages. Le framework se distingue par son générateur d'API typé, qui produit des SDK clients natifs et des objets de transfert de données (DTO) à partir des métadonnées de service dans plusieurs langages. Il inclut également une passerelle de service distribuée pour l'orchestration de microservices, un ORM code-first pour traduire directement les objets C# en enregistrements de base de données, et un système centralisé de gestion des identités et des accès pour un accès sécurisé basé sur des jetons. Sa surface de capacités plus large couvre la messagerie asynchrone et le streaming d'événements en temps réel via Pub-Sub et Server-Sent Events. Il fournit une prise en charge complète de la sérialisation des données pour des formats tels que JSON, XML, ProtoBuf et MessagePack, aux côtés de flux d'authentification intégrés incluant JWT, clés API et authentification step-up. L'outillage supplémentaire inclut la génération automatisée d'API CRUD, l'exécution de tâches en arrière-plan et des modèles de tableau de bord administratif.
Synchronizes event notifications across multiple load-balanced application servers using a Redis backend.
Ce projet sert d'architecture de référence complète et de guide des meilleures pratiques pour développer des applications scalables avec le framework Spring Boot. Il fournit un plan structurel pour le développement backend Java, se concentrant sur l'implémentation d'API découplées et l'établissement de standards architecturaux. Le projet détaille spécifiquement la création de starters personnalisés et de modules d'auto-configuration pour simplifier l'intégration de bibliothèques tierces. Il fournit également un plan de déploiement pour packager les applications sous forme de jars exécutables et optimiser les builds en couches pour les environnements cloud conteneurisés. La surface de capacités couvre l'optimisation des performances via le cache mémoire et le traitement asynchrone, ainsi que la synchronisation de systèmes distribués utilisant des verrous distribués et des courtiers de messages. La couverture inclut également la gestion de la persistance des données, les migrations de bases de données, la planification de tâches automatisées et l'implémentation de la programmation orientée aspect pour les préoccupations transversales.
Implements distributed synchronization using external stores like Redis or Kafka to ensure data consistency across server instances.
Indigo est un framework et une boîte à outils basés sur Go conçus pour construire, héberger et mettre à l'échelle des services au sein de l'écosystème AT Protocol. Il fournit l'infrastructure fondamentale pour le réseautage social décentralisé, permettant aux développeurs d'implémenter des services de relais, de gérer des dépôts utilisateur signés cryptographiquement et de gérer la résolution d'identité dans des environnements fédérés. Le projet se distingue par une architecture robuste qui découple l'hébergement de contenu de la découverte, permettant une modération indépendante et une génération de flux algorithmique. Il utilise un stockage adressé par le contenu et des structures de dépôt basées sur des arbres de Merkle pour garantir l'intégrité des données, tandis que sa génération de schéma pilotée par lexique crée automatiquement des structures typées pour la communication inter-services. En mappant les identifiants lisibles par l'homme à des identifiants décentralisés, le système maintient une propriété utilisateur vérifiable et une portabilité de compte entre des fournisseurs d'hébergement indépendants. Au-delà de son identité de base, le projet couvre une surface complète pour gérer l'état distribué, incluant le streaming d'événements en temps réel, la synchronisation et la modération automatisée. Il fournit des outils étendus pour la simulation d'activité réseau, la télémétrie opérationnelle et l'indexation des flux de données globaux. Le framework est conçu pour les environnements de production, offrant des options de déploiement conteneurisées et des points de terminaison de diagnostic pour surveiller la santé de la synchronisation et les performances du système.
Synchronizes distributed state by broadcasting signed repository updates through real-time event streams with historical backfill.