13 Repos
Implementations of real-time data push mechanisms using persistent HTTP connections.
Distinguishing note: Focuses on server-sent events for real-time updates rather than general message queuing.
Explore 13 awesome GitHub repositories matching web development · Event Streaming. Refine with filters or upvote what's useful.
This project is a cross-platform desktop media player that aggregates music content from multiple online sources into a unified local playback interface. It provides a comprehensive system for managing media playback and retrieving structured lyric data, including time-synced, translated, and romanized versions. The application distinguishes itself through an integrated local network server and a custom protocol handler, which allow external software, scripts, and web browsers to interact with the player. These features enable remote control of playback operations, real-time monitoring of med
Maintains persistent connections to push real-time playback status updates and metadata changes to connected client applications.
Fingerprint is a visitor identification and fraud detection platform that generates persistent, unique identifiers by analyzing browser and device attributes. By extracting technical signals from the client environment, it enables reliable user tracking across sessions without relying on traditional cookies. The platform distinguishes itself through its focus on high-accuracy identification and security-first architecture. It employs edge-side proxying to bypass ad-blockers and privacy restrictions, ensuring consistent data collection. To maintain data integrity, it uses cryptographic payload
Streams identification results to external endpoints in real-time to support automated fraud prevention workflows.
Mastra is an orchestration framework designed for building, deploying, and managing autonomous AI agents and multi-agent systems. It provides a comprehensive suite of primitives for creating resilient AI applications, including durable workflow orchestration, event-driven agent loops, and semantic memory management. By integrating these core components, the platform enables developers to build complex, multi-step processes that can reason about goals and execute tasks without manual intervention. The framework distinguishes itself through its focus on observability and secure, isolated execut
Provides real-time updates on background task lifecycles through event streams for monitoring and integration.
LangChain.js is a framework for building, executing, and monitoring stateful agentic applications. It provides an orchestration engine that models workflows as directed graphs, allowing developers to connect language models, data sources, and external tools into modular, multi-step processes. The platform distinguishes itself through its focus on stateful execution and human-in-the-loop control. It manages agent lifecycles by persisting execution state across threads, enabling fault tolerance and the ability to pause workflows at designated breakpoints for manual review or modification. This
Exposes unified event-streaming APIs and WebSockets to provide granular updates and command workflows during agent execution.
Quarkus is a Kubernetes-native Java framework designed for building high-performance, memory-efficient applications. It utilizes ahead-of-time native compilation to transform Java code into standalone, optimized binaries that eliminate the need for a virtual machine, enabling rapid startup and reduced memory consumption. By performing code augmentation during the build phase, it shifts heavy processing tasks away from runtime, ensuring that applications are optimized for cloud-native environments. The framework distinguishes itself through a unified approach to reactive and imperative program
Implements server-sent events over HTTP to provide real-time updates to browser-based clients.
Beehive ist eine selbst gehostete Integrationsplattform und Event-Automatisierungs-Engine. Sie fungiert als Plugin-basierter Workflow-Orchestrator, der unabhängige Service-Plugins verknüpft, um die Datenbewegung zwischen externen APIs und Hardware zu automatisieren. Das System fungiert als IoT-Hardware-Controller zur Verwaltung netzwerkfähiger Steckdosen, intelligenter Beleuchtung und serieller Port-Geräte via TTY oder COM. Es dient zudem als HTTP-Webhook-Gateway, das eingehende Anfragen empfängt, um interne Workflows und externe Benachrichtigungen auszulösen. Funktionsbereiche umfassen eventgesteuerte Workflow-Automatisierung mit filterbasiertem Routing und template-basiertem Daten-Mapping. Die Plattform unterstützt plattformübergreifendes Benachrichtigungs-Routing, digitale Inhaltsverteilung via RSS und soziale Medien sowie Infrastruktur-Observability durch die Bereitstellung von Prometheus-Metriken und Heartbeat-Gesundheitsüberwachung. Die Anwendung ist als binäre ausführbare Datei verfügbar und für containerbasierte Bereitstellung paketiert.
Uses conditional logic to determine if an event should proceed to the next action in an automation sequence.
Emits agent responses as granular, resumable event streams over SSE with persistent storage for reconnection.
Cronicle is a distributed job scheduler that replaces traditional cron with a browser-based management interface. It runs scheduled tasks across a cluster of servers with automatic failover, using a custom cron parser that intersects day-of-month and day-of-week constraints when both are specified. The system executes jobs through a plugin framework that runs command-line scripts in any language, communicating via JSON over standard input and output. The scheduler provides a web-based real-time dashboard for monitoring running jobs with live logs, resource usage charts, and progress updates.
Provides a CLI command to check whether the scheduler daemon is currently running or stopped.
Inngest is a durable execution framework and event-driven automation engine designed to orchestrate background workflows. It enables developers to build resilient, stateful processes by memoizing function steps, ensuring that long-running tasks can automatically resume from the last successful operation after failures, timeouts, or infrastructure restarts. The platform distinguishes itself through its event-driven architecture, which uses a schema-validated bus to trigger functions and coordinate complex, multi-step logic. It employs an onion-model middleware approach for cross-cutting concer
Provides real-time data streaming to clients that automatically rolls back and retries if a workflow step fails.
Incus is a unified orchestration platform for managing system containers, OCI application containers, and virtual machines through a single control plane. It brings together cluster infrastructure management, secure multi-tenancy, software-defined networking, and pluggable storage backend orchestration into one cohesive system exposed via a full REST API and command-line interface. What distinguishes Incus is its ability to run multiple instance types side by side—full Linux system containers, OCI application containers, and QEMU virtual machines—all managed with consistent tooling. Networkin
Streams lifecycle and real-time events over a WebSocket connection exposed through a system socket.
orpc is a contract-first API development framework for TypeScript that starts with a shared contract definition and generates type-safe clients and servers from that single source of truth. It guarantees end-to-end type safety, meaning inputs, outputs, errors, and streaming data are all checked at compile time across the client–server boundary. What distinguishes orpc from typical RPC frameworks is its ability to export contracts as OpenAPI specifications, to optimize server-side rendering by calling API handlers directly inside the server process, and to support real‑time bidirectional commu
Persists events for configurable durations so clients resume missed events after reconnection.
This project provides a translation layer and set of adapters designed to bridge AI agents with the Model Context Protocol. It functions as an integration layer that allows agents to operate as protocol-compliant servers and enables the conversion of protocol-based tools into formats compatible with agent frameworks and logic graphs. The adapters facilitate tool interoperability by wrapping external protocol tools for use within agent workflows and exposing internal agent capabilities to any client implementing the Model Context Protocol. This creates a communication bridge that supports inte
Implements resumable event streams over SSE for agent threads, including sequence-based reconnection to replay missed data.
MadelineProto is an asynchronous PHP library that provides a programmatic interface for interacting with the Telegram API using the MTProto protocol, the same protocol used by official Telegram clients. It functions as both a Telegram bot SDK and a userbot automation library, enabling PHP applications to connect to Telegram as either a bot account or a regular user account, sending and receiving messages, media, and other data directly without relying on the Bot API intermediary. The library is built on an event-driven architecture with Amp v3 fiber-based concurrency, allowing for non-blockin
Processes Telegram updates through a stable attribute-based filter system instead of legacy methods.