awesome-repositories.com
Blog
awesome-repositories.com

Entdecke die besten Open-Source-Repositories mit KI-gestützter Suche.

EntdeckenKuratierte SuchenOpen-Source-AlternativenSelf-hosted SoftwareBlogSitemap
ProjektÜber unsRanking-MethodikPresseMCP-Server
RechtlichesDatenschutzAGB
© 2026 Bringes Technology SRL·VAT RO45896025·hello@awesome-repositories.com
·

13 Repos

Awesome GitHub RepositoriesEvent Streaming

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.

Awesome Event Streaming GitHub Repositories

Finde die besten Repos mit KI.Wir suchen mit KI nach den am besten passenden Repositories.
  • lyswhut/lx-music-desktopAvatar von lyswhut

    lyswhut/lx-music-desktop

    51,592Auf GitHub ansehen↗

    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.

    TypeScriptelectronjavascriptmusic-player
    Auf GitHub ansehen↗51,592
  • fingerprintjs/fingerprintjsAvatar von fingerprintjs

    fingerprintjs/fingerprintjs

    27,334Auf GitHub ansehen↗

    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.

    TypeScriptaudio-fingerprintingbrowserbrowser-fingerprint
    Auf GitHub ansehen↗27,334
  • mastra-ai/mastraAvatar von mastra-ai

    mastra-ai/mastra

    21,221Auf GitHub ansehen↗

    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.

    TypeScriptagentsaichatbots
    Auf GitHub ansehen↗21,221
  • langchain-ai/langchainjsAvatar von langchain-ai

    langchain-ai/langchainjs

    17,818Auf GitHub ansehen↗

    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.

    TypeScript
    Auf GitHub ansehen↗17,818
  • quarkusio/quarkusAvatar von quarkusio

    quarkusio/quarkus

    15,479Auf GitHub ansehen↗

    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.

    Javacloud-nativehacktoberfestjava
    Auf GitHub ansehen↗15,479
  • muesli/beehiveAvatar von muesli

    muesli/beehive

    6,476Auf GitHub ansehen↗

    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.

    Go
    Auf GitHub ansehen↗6,476
  • voltagent/voltagentAvatar von VoltAgent

    VoltAgent/voltagent

    6,020Auf GitHub ansehen↗

    Emits agent responses as granular, resumable event streams over SSE with persistent storage for reconnection.

    TypeScriptagentsaiai-agents
    Auf GitHub ansehen↗6,020
  • jhuckaby/cronicleAvatar von jhuckaby

    jhuckaby/Cronicle

    5,745Auf GitHub ansehen↗

    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.

    JavaScript
    Auf GitHub ansehen↗5,745
  • inngest/inngestAvatar von inngest

    inngest/inngest

    5,499Auf GitHub ansehen↗

    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.

    Go
    Auf GitHub ansehen↗5,499
  • lxc/incusAvatar von lxc

    lxc/incus

    4,893Auf GitHub ansehen↗

    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.

    Gocloudcontainershacktoberfest
    Auf GitHub ansehen↗4,893
  • middleapi/orpcAvatar von middleapi

    middleapi/orpc

    4,862Auf GitHub ansehen↗

    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.

    TypeScriptapibunjscloudflare-worker
    Auf GitHub ansehen↗4,862
  • langchain-ai/langchain-mcp-adaptersAvatar von langchain-ai

    langchain-ai/langchain-mcp-adapters

    3,366Auf GitHub ansehen↗

    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.

    Pythonlangchainlanggraphmcp
    Auf GitHub ansehen↗3,366
  • danog/madelineprotoAvatar von danog

    danog/MadelineProto

    3,344Auf GitHub ansehen↗

    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.

    PHPamphpasyncbot
    Auf GitHub ansehen↗3,344
  1. Home
  2. Web Development
  3. Event Streaming

Unter-Tags erkunden

  • Daemon1 Sub-TagStreams lifecycle and real-time events over a WebSocket connection exposed through a system socket. **Distinct from Event Streaming:** Distinct from Event Streaming: focuses on daemon-level lifecycle events streamed over WebSocket, not general data push.
  • IdentificationPushes visitor identification data to external endpoints in real-time for asynchronous processing. **Distinct from Event Streaming:** Focuses on streaming identification-specific events, distinct from general real-time data streaming.
  • Resumable Event Streams1 Sub-TagGranular, resumable event streams over SSE with persistent storage for reconnection after client disconnect. **Distinct from Event Streaming:** Distinct from Event Streaming: focuses on resumable, persistent SSE streams for agent responses, not general real-time data push.
  • Task Event Filters1 Sub-TagMechanisms for restricting event streams to specific agents or tasks. **Distinct from Event Streaming:** Focuses on filtering task-specific event streams rather than general event streaming.