Awesome GitHub RepositoriesReal-time Stream Monitors

This project is a general-purpose command-line filter that provides an interactive interface for processing standard input streams. It enables real-time fuzzy searching, data selection, and transformation, allowing users to navigate complex information or file systems directly within their terminal. By utilizing a pipe-oriented architecture, it integrates into existing shell pipelines and workflows to facilitate efficient data exploration. What distinguishes this tool is its highly extensible, event-driven design that allows for deep integration with external processes. It supports asynchrono

This project is a feature-rich Go client library designed for interacting with Redis. It serves as a comprehensive interface for managing remote data stores, enabling developers to execute standard database commands, handle complex data structures, and perform asynchronous operations within Go applications. The library distinguishes itself through its support for advanced Redis capabilities, including connection pooling, pipelining, and transactional integrity. It provides specialized primitives for managing distributed clusters, including automated topology updates and request routing to sha

Guidance is a generative AI orchestration framework designed to manage complex interactions with language models by embedding programmatic control directly into the prompt generation process. It functions as a prompt programming environment that allows developers to interleave raw text with executable logic, enabling the construction of sophisticated, multi-step agentic workflows. The framework distinguishes itself through grammar-constrained token sampling and stateful stream interception, which restrict the model's output distribution based on formal language rules. By enforcing these const

This project is a cross-platform machine learning inference engine designed to execute pre-trained models across diverse operating systems and hardware environments. It functions as a standardized execution framework that manages the entire lifecycle of model inference, from loading and graph optimization to hardware-accelerated execution and generative sequence management. The runtime distinguishes itself through a highly modular architecture that decouples model logic from hardware-specific kernels. By utilizing an execution provider abstraction, it enables developers to offload computation

This project is a cross-platform media aggregator and streaming API wrapper designed to retrieve live broadcast data from various video platforms. It functions as a unified interface for fetching direct playback URLs and real-time chat logs, enabling the development of custom broadcast monitoring and interactive streaming applications. The tool distinguishes itself by providing a consistent data extraction layer that normalizes disparate video source formats into a unified structure. By parsing stream links through targeted network requests, it allows developers to integrate live broadcast me

webpack-dashboard is a terminal-based build monitor and asset viewer designed for the Webpack development process. It provides a command line interface to track compilation status, monitor development server activity, and organize build errors for debugging. The tool integrates as a Webpack plugin to intercept compilation events and extract asset metadata. It utilizes a terminal-UI layout engine and state-driven rendering to display build progress and logs in a structured grid of dynamic windows. The system includes capabilities for real-time build log visualization and asset filtering using

This project is a Python wrapper for the TA-Lib C library, serving as a financial technical analysis library and quantitative trading tool. It provides a collection of mathematical functions designed to analyze market price movements, identify trading signals, and recognize candlestick patterns within financial data. The library focuses on the computation of trend, momentum, and volume metrics. It includes specialized tools for candlestick pattern recognition to detect recurring price action shapes in both historical and real-time data. The system integrates with NumPy arrays to process cont

DouyinLiveRecorder is a multi-platform live stream recorder designed to monitor and save broadcasts from various global streaming platforms to local storage. It functions as an automated stream watchdog that continuously tracks broadcast statuses to initiate recording immediately when a stream goes live. The tool is a proxy-aware capture system capable of routing network requests through external servers to access and record content restricted to specific geographic regions. It utilizes platform-specific resolvers to map API patterns to stream identifiers, ensuring content can be archived fro

Crucix is an open-source intelligence system comprising an OSINT aggregator, a geospatial intelligence dashboard, and an LLM intelligence agent. It functions as a real-time signal monitor and automated alerting system designed to collect, analyze, and visualize geopolitical, economic, and satellite data from diverse open-source intelligence sources. The system utilizes large language models to synthesize intelligence feeds, generate actionable trade ideas, and classify signal priority with confidence scores. It features a geospatial visualization interface that plots intelligence events, such

Flyte is a Kubernetes-based machine learning orchestrator and containerized pipeline manager designed for coordinating AI workflows and data pipelines. It functions as an engine for defining and executing resilient pipelines, utilizing a data lineage tracker to maintain immutable execution states and ensure reproducible outputs. The platform distinguishes itself by packaging individual tasks into separate containers to ensure dependency isolation and environment consistency. It provides specialized capabilities for machine learning, including the transformation of trained models into scalable

Mediasoup is a selective forwarding unit used for real-time media routing. It enables the development of low-latency audio and video communication systems by routing streams between participants without transcoding. The project provides embedded media routing logic that can be integrated directly into an application. It supports simulcast and quality layering, allowing the system to adapt resolution and bitrate based on real-time bandwidth estimations to maintain connection stability. The capability surface includes media track management for audio, video, and screen capture, as well as bidi

open source、high performance、industrial rtsp streaming server,a lot of optimization on streaming relay,KeyFrame cache,RESTful,and web management,also EasyDarwin support distributed load balancing,a simple streaming media cloud platform architecture.

bililive-go is an automated broadcast archivist and recording tool designed specifically for Bilibili live streams. It functions as a monitoring service that tracks broadcast status and automatically captures live video content to local storage based on target identifiers. The system features a web-based manager that allows for the remote configuration of recording targets and global settings via a browser interface. It supports the simultaneous recording of multiple streams and provides real-time status alerts through external messaging services when broadcasts start, end, or encounter error

يوفر هذا المشروع وثائق تقنية وأدلة مرجعية للتداول الفوري، بما في ذلك مواصفات بروتوكولات REST، و WebSocket، و FIX. يعمل كمورد شامل للتكامل مع نقاط نهاية التداول الفوري لتنفيذ الصفقات، والاستعلام عن بيانات الحساب، وجلب إحصائيات السوق. يتميز المشروع بدعم الاتصال على مستوى المؤسسات من خلال معيار تبادل المعلومات المالية (FIX) والترميز الثنائي البسيط لتقليل زمن الوصول وحجم الحمولة. كما يتضمن بيئة تجريبية (Sandbox) مخصصة للتحقق من منطق التداول والاستراتيجيات دون مخاطر مالية. تغطي الوثائق مجموعة واسعة من القدرات، بما في ذلك بث بيانات السوق في الوقت الفعلي، وإدارة شاملة لدورة حياة الطلبات والصفقات، ومراقبة الحساب. كما تفصل أنواع الطلبات المعقدة، وتوجيه الطلبات الذكي، وقواعد التداول الصارمة فيما يتعلق بالتحقق من السعر والكمية. يحتوي المستودع على مراجع API مفصلة، ودليل تكامل بروتوكول FIX، ومواصفات بيانات سوق WebSocket لتوجيه المطورين أثناء التنفيذ.

exllamav2 هي مكتبة استنتاج عالية الأداء مصممة لتشغيل نماذج اللغات الكبيرة محلياً على وحدات معالجة الرسومات (GPUs) المخصصة للمستهلكين. توفر مشغلاً مسرعاً بواسطة GPU وأدوات تكميم لتمكين تنفيذ النموذج دون الاعتماد على خدمات الحوسبة السحابية. يتميز المشروع بأداة تكميم تضغط النماذج إلى معدلات بت مختلطة بين اثنين وثمانية بت لتقليل متطلبات ذاكرة الفيديو (VRAM). يتميز بمولد نصوص مجمع يتعامل مع الطلبات المجمعة ويزيل تكرار بيانات ذاكرة التخزين المؤقت لزيادة الإنتاجية. تغطي المكتبة سطح قدرة واسعاً بما في ذلك تدفق الرموز غير المتزامن للمخرجات في الوقت الفعلي، وتنفيذ نواة GPU مخصصة لعمليات الجبر الخطي، وتعيين الذاكرة المحلية للوصول منخفض زمن الوصول إلى أوزان النموذج.

Console هي أداة إدارة تعتمد على الويب لمراقبة وإدارة مجموعات Kafka. توفر واجهة رسومية لإدارة المواضيع (topics)، ومجموعات المستهلكين، وتدفقات البيانات في الوقت الفعلي. يتضمن المشروع مديرين مخصصين لـ Kafka Connect و Schema Registry، مما يسمح بنشر موصلات البيانات وحوكمة مخططات البيانات. يتميز بلوحة تحكم للمجموعة لتتبع صحة الوسطاء (brokers)، واستخدام التخزين، وحالة الرفوف، إلى جانب واجهة للتحكم في الوصول القائم على الأدوار وفحص سجلات التدقيق. تغطي المنصة تصفح البيانات وتصفيتها، وتنسيق مجموعات المستهلكين، وبناء خطوط أنابيب البيانات. كما تدعم مراقبة مهام تحويل البيانات وإدارة أذونات المستخدم عبر محرك سياسات مركزي.

PRAW هو مكتبة Python للتعامل مع واجهة برمجة تطبيقات Reddit، ويعمل كعميل REST API وزاحف لبيانات وسائل التواصل الاجتماعي. يوفر واجهة برمجية لجلب البيانات، وإدارة محتوى الحساب، والتفاعل مع المنصة. تنفذ المكتبة عميل OAuth 2.0 شاملاً يدعم تدفقات تفويض متعددة، بما في ذلك كلمات المرور، والتدفقات الضمنية، ورموز التحديث، بالإضافة إلى وصول الضيف للقراءة فقط. يتميز بجدولة طلبات تراعي حدود المعدل (rate-limit-aware) التي تتبع تقييد الخادم لمنع استنفاد حصة API، ويستخدم كائنات تحميل كسول (lazy-loading) لجلب البيانات فقط عند الوصول إلى سمات محددة. تغطي القدرات إدارة المجتمع والمستخدمين، وبث المشاركات في الوقت الفعلي عبر المولدات، واستخراج سلاسل النقاش المتداخلة. تتضمن مجموعة الأدوات أيضاً إدارة المحتوى لإنشاء المنشورات والتعليقات، إلى جانب خيارات تكوين الشبكة للجلسات المخصصة وتوجيه الوكيل (proxy routing).

Tribeca هي منصة تداول عملات رقمية مبنية على Node.js مصممة للتداول عالي التردد وصناعة السوق الآلية. تعمل كمحرك تنفيذ منخفض زمن الوصول يقوم بأتمتة عملية توفير السيولة والتقاط فروق الأسعار عبر بورصات عملات رقمية متعددة. يستخدم النظام طبقة اتصال لبث بيانات السوق في الوقت الفعلي وتنفيذ الصفقات عبر اتصالات شبكة مستمرة. ويستخدم تكاملاً قائماً على المحولات لتطبيع واجهات برمجة التطبيقات (APIs) المتنوعة للمنصات في تنسيق موحد، مما يسمح بنشاط منسق عبر العديد من منصات العملات الرقمية المختلفة. تتضمن المنصة مختبراً استراتيجياً (backtester) للتحقق من صحة الاستراتيجيات مقابل البيانات التاريخية ولوحة تحكم مرئية لمراقبة المراكز النشطة ومعلمات التسعير. تغطي القدرات الإضافية تنفيذ الأوامر القائم على الأحداث، وتتبع المراكز القائم على الحالة، وتخزين قاعدة بيانات مستمر لتدقيق سجلات التداول.

Dinky is a real-time data platform for developing, deploying, and operating streaming applications based on Apache Flink. It functions as a SQL streaming IDE and a real-time data pipeline orchestrator, providing a web-based environment for writing and verifying queries with integrated logic plan visualization and lineage tracking. The platform acts as a distributed cluster manager, allowing the registration, monitoring, and administration of multiple processing clusters from a centralized interface. It also serves as a change data capture integration tool, synchronizing real-time database cha

Curlie is a terminal-based HTTP client and debugging tool used for executing network requests and interacting with REST APIs. It provides a command line interface for sending requests using simplified syntax, with a specific focus on interacting with JSON services. The tool distinguishes itself by converting simplified interactive requests into standard curl commands for external reproduction and sharing. It also features unbuffered data streaming to monitor server responses in real time as they arrive. The project covers a broad range of API testing capabilities, including request prototypi