6 repositorios
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 es una aplicación de chat en tiempo real y un cliente de mensajería serverless que sincroniza conversaciones y mensajes instantáneamente entre clientes. Proporciona una interfaz de usuario para un sistema de mensajería respaldado por un almacén de documentos NoSQL alojado en la nube. El proyecto implementa un sistema de chat en tiempo real mediante la integración de un backend de Firebase, permitiendo flujos de trabajo de mensajería instantánea y la sincronización de datos entre clientes conectados. La aplicación gestiona los datos utilizando almacenamiento NoSQL sin esquema y modelado de datos basado en documentos. Utiliza una conexión persistente para la sincronización de la base de datos y gestiona las actualizaciones de estado mediante el despacho de mensajes basado en eventos y la proyección de estado del lado del cliente.
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 es un gateway IoT multiprotocolo e interfaz de hardware diseñado para dispositivos ESP32 y ESP8266. Sirve como un puente que convierte señales de Bluetooth Low Energy, radiofrecuencia e infrarrojos en mensajes MQTT estandarizados para su uso en sistemas de domótica. El proyecto proporciona capacidades de puente específicas para señales de radio de 433MHz, 315MHz y 868MHz, así como comandos LoRa e infrarrojos. Incluye un detector de presencia Bluetooth que monitorea los anuncios de dispositivos para rastrear la proximidad y ubicación de personas u objetos. El sistema maneja la agregación de sensores IoT mediante escaneo pasivo y sondeo de radio asíncrono, convirtiendo datos binarios crudos en formatos JSON mediante la decodificación de carga útil específica del hardware. También soporta el enrutamiento de comandos bidireccional para gestionar dispositivos inalámbricos conectados y enchufes inteligentes.
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.