6 repository-uri
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 is a real-time chat application and serverless messaging client that synchronizes conversations and messages instantly across clients. It provides a user interface for a messaging system backed by a cloud-hosted NoSQL document store. The project implements a real-time chat system through the integration of a Firebase backend, allowing for instant messaging workflows and the synchronization of data across connected clients. The application manages data using schema-less NoSQL storage and document-based data modeling. It utilizes a persistent connection for database synchronizatio
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 is a multi-protocol IoT gateway and hardware interface designed for ESP32 and ESP8266 devices. It serves as a bridge that converts Bluetooth Low Energy, Radio Frequency, and Infrared signals into standardized MQTT messages for use in home automation systems. The project provides specific bridging capabilities for 433MHz, 315MHz, and 868MHz radio signals, as well as LoRa and Infrared commands. It includes a Bluetooth presence detector that monitors device advertisements to track the proximity and location of people or objects. The system handles IoT sensor aggregation through
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.