6 dépôts
Concurrent processing of binary network data using an event dispatcher to reduce tail latency.
Distinct from Concurrent Data Processors: Focuses on the event-driven dispatching of binary messages rather than general data processing.
Explore 6 awesome GitHub repositories matching data & databases · Event-Driven Message Dispatching. Refine with filters or upvote what's useful.
brpc is a high-performance C++ RPC framework and network programming library designed for building distributed systems. It functions as a multi-protocol RPC server capable of hosting and detecting multiple communication protocols, including gRPC, Thrift, HTTP, Redis, and Memcached, on a single TCP port. The project distinguishes itself through high-throughput data transport and memory efficiency, utilizing RDMA-based transport to bypass the kernel TCP stack and zero-copy memory management to eliminate data duplication. It also implements the Raft algorithm for consensus-based state replicatio
Handles binary data concurrently using an event dispatcher to minimize long-tail latency.
whatsmeow is a Go library that implements the WhatsApp multidevice protocol, providing direct access to the binary node serialization, WebSocket-based connection management, and Signal‑Protocol encryption that underpin WhatsApp’s messaging infrastructure. It maintains persistent, low-latency connections across multiple devices, handles session credentials independently for each device, and processes incoming events through an event‑driven dispatch system for messages, receipts, and presence updates. The library differentiates itself through comprehensive client‑side state management: it cache
Processes incoming WhatsApp events through a callback-based event dispatcher for messages, receipts, and presence updates.
FirebaseChat est une application de chat en temps réel et un client de messagerie serverless qui synchronise instantanément les conversations et les messages entre les clients. Il fournit une interface utilisateur pour un système de messagerie reposant sur un magasin de documents NoSQL hébergé dans le cloud. Le projet implémente un système de chat en temps réel via l'intégration d'un backend Firebase, permettant des workflows de messagerie instantanée et la synchronisation des données entre les clients connectés. L'application gère les données en utilisant un stockage NoSQL sans schéma et une modélisation de données basée sur les documents. Elle utilise une connexion persistante pour la synchronisation de la base de données et gère les mises à jour d'état via une distribution de messages pilotée par les événements et une projection d'état côté client.
Triggers UI updates and notifications using an event-driven dispatch system based on backend data changes.
SSH.NET is a .NET library that implements the SSH-2 protocol for encrypted remote connections and secure file transfers. It provides a complete SSH-2 protocol stack implementation with a channel multiplexing engine that manages multiple concurrent channels over a single connection, supporting simultaneous shell sessions, remote command execution, SFTP transfers, and port forwarding tunnels. The library includes a pluggable authentication pipeline supporting password, public key, certificate, keyboard-interactive, and multi-factor authentication combinations. The library distinguishes itself t
Dispatches SSH protocol messages and session events through a subscription-based handler system for extensible message processing.
OpenMQTTGateway est une passerelle IoT multi-protocole et une interface matérielle conçue pour les appareils ESP32 et ESP8266. Il sert de pont qui convertit les signaux Bluetooth Low Energy, Radio Fréquence et Infrarouge en messages MQTT standardisés pour une utilisation dans les systèmes de domotique. Le projet fournit des capacités de pontage spécifiques pour les signaux radio 433MHz, 315MHz et 868MHz, ainsi que pour les commandes LoRa et Infrarouge. Il inclut un détecteur de présence Bluetooth qui surveille les publicités des appareils pour suivre la proximité et l'emplacement des personnes ou des objets. Le système gère l'agrégation des capteurs IoT via un balayage passif et un sondage radio asynchrone, convertissant les données binaires brutes en formats JSON via un décodage de charge utile spécifique au matériel. Il prend également en charge le routage de commandes bidirectionnel pour gérer les appareils sans fil connectés et les prises intelligentes.
Triggers MQTT publishing routines immediately upon the detection and decoding of valid hardware signals.
Melody is a WebSocket server framework designed to upgrade HTTP connections into bidirectional streams. It functions as a session manager and binary streaming library that facilitates real-time data exchange between a server and multiple remote clients. The project features a broadcast engine that optimizes multi-client transmissions through wire-representation caching. It includes a dedicated session management system for attaching custom state to persistent network connections and an upgrade handler that validates handshake headers. The framework covers broad capability areas including eve
Provides an event dispatcher to route incoming binary network frames to specific handler functions efficiently.