Awesome GitHub RepositoriesShared Message Contracts

FastStream is an asynchronous Python framework designed for building event-driven microservices. It provides a unified abstraction layer for interacting with various message brokers, enabling developers to manage event production and consumption through a consistent interface while maintaining access to native provider-specific features. The framework centers on a decorator-based routing model that binds application logic directly to broker topics, supported by a built-in dependency injection container that resolves resources at runtime. The framework distinguishes itself through its deep int

Messenger is an asynchronous messaging system and event-driven communication layer designed to exchange events between decoupled components. It functions as an inter-process communication tool that removes direct dependencies between services by routing messages through a middleware layer. The system implements a pub-sub messaging model where components subscribe to specific event types and receive notifications when those events are triggered. It utilizes a central dispatcher to route asynchronous events from producers to registered subscribers. The project provides capabilities for distrib

هذا المشروع هو تطبيق .NET لإطار عمل gRPC، يوفر نظاماً لتنفيذ الوظائف على خوادم بعيدة كما لو كانت استدعاءات محلية. يعمل كإطار عمل لاستدعاء الإجراءات البعيدة (RPC) عالي الأداء يستخدم HTTP/2 لاتصال الخدمة وبروتوكولات الاتصال الثنائية لضمان تبادل فعال للبيانات. يتضمن التطبيق وكيل gRPC-Web، الذي يعمل كطبقة ترجمة لتمكين التطبيقات القائمة على المتصفح من التواصل مع خدمات gRPC من خلال طلبات متوافقة مع الويب. كما يدعم إنشاء شبكات خدمة HTTP/2 لربط الخدمات المصغرة الموزعة بزمن انتقال منخفض. يغطي إطار العمل مجموعة واسعة من القدرات، بما في ذلك التسلسل الثنائي عبر Protobuf، وتوليد العقود المكتوبة بقوة، ودعم أنماط RPC الأحادية والمتدفقة. ويوفر ميزات استضافة خادم وإدارة عميل شاملة، إلى جانب أدوات إدارة حركة المرور مثل موازنة التحميل من جانب العميل وإعادة محاولة الاستدعاء التلقائية. يتم توفير دعم تشغيلي إضافي من خلال أمان نقل TLS، والتحكم في الوصول على مستوى الطريقة، وأدوات المراقبة بما في ذلك مراقبة صحة الخدمة وتسجيل التشخيص.

Ergo is a distributed actor framework for Go that implements the Erlang distribution protocol, enabling the construction of resilient, concurrent applications that can communicate transparently with Erlang/OTP nodes. At its core, it provides an actor model with isolated lightweight processes, priority-ordered mailboxes, and a meta-process architecture that separates blocking I/O from sequential message handling to prevent actor freezing. The framework includes a Raft-inspired cluster consensus system for leader election and automatic failover, along with OTP-style supervision trees that organi