Awesome GitHub RepositoriesMessage Queue Workers

OpenFaaS is a serverless function platform that provides a container-native framework for deploying and managing event-driven code. It functions as an abstraction layer over container orchestrators, allowing developers to package code into scalable functions that run across Kubernetes clusters or edge computing environments. The platform distinguishes itself through a developer-centric runtime that utilizes standardized language templates and automated build pipelines to simplify the creation of container images. It features a central API gateway that manages request routing, authentication,

Postal is an open-source mail delivery platform designed for self-hosted sending and receiving of email using standard mail transfer protocols. It serves as a comprehensive email infrastructure that provides full delivery tracking and management of outgoing mail streams. The system includes an SMTP server manager with a web administration interface for configuring server settings and monitoring delivery status. It distinguishes its outbound traffic management through priority-based IP rotation and assignment to help maintain sender reputation. The platform covers incoming email processing an

This project is a PHP e-commerce platform and enterprise storefront framework designed for building and managing online stores. It functions as a modular PHP application and headless commerce engine, separating e-commerce business logic from frontend presentation to support multiple storefronts and devices. The system is built on a modular architecture that allows developers to add custom business logic and third-party integrations. It utilizes a service-contract-based API to ensure stability across module implementations and employs dependency-injection for object lifecycle management. Core

Gorush is a dedicated notification dispatch server used to send real-time alerts to iOS and Android mobile devices. It functions as a centralized infrastructure for hosting a notification API and managing the delivery of push messages through high-throughput queuing. The system supports both gRPC streams and HTTP endpoints to receive notification triggers and includes a command-line interface for triggering alerts without a running server process. It manages network traffic through proxy routing via HTTP or SOCKS5 and secures server communication using automated TLS certificate management. O

Simplebank is a financial services backend application built with Go that manages bank accounts and transfers. It utilizes a dual-protocol interface, providing both gRPC and REST APIs via Protocol Buffers to support different client communication requirements. The system implements a PostgreSQL data layer with versioned schema migrations and type-safe query generation. It handles financial operations through atomic fund transfers and balance change tracking to maintain consistent audit trails. The architecture includes an asynchronous task worker system using a message queue to offload long-

MISP is an open-source threat intelligence sharing platform designed for collecting, storing, and distributing structured threat indicators and intelligence. At its core, it provides a distributed synchronization protocol for transferring events between instances, an attribute-based correlation engine that links matching indicators across events, and a REST API with an OpenAPI specification for programmatic access to threat data. The platform uses formal data formats for JSON, taxonomy, galaxy, and object templates to enable compatibility across tools and communities. The platform distinguish

This is a distributed voting application designed to demonstrate a multi-service architecture. It uses stateless web frontends for submitting votes and viewing live results, with a Redis-backed queue to buffer incoming votes and a PostgreSQL database for persistent tallying. The application is built around asynchronous message queue processing, decoupling the vote submission from the tallying workflow. The project showcases how to deploy a multi-service application using container orchestration tools. It provides YAML-driven declarative deployment manifests for Docker Compose, Docker Swarm, a

protoactor-go is a framework for building concurrent and distributed systems in Go using the actor model. It provides a distributed actor system that enables isolated entities to communicate via asynchronous messaging and share state across a cluster. The framework implements a multi-language actor protocol, allowing interoperability between actors written in Go, C#, and Java. It further supports a virtual actor implementation, where actors are automatically instantiated across a network based on a unique identity. The system includes a supervision model for managing actor lifecycles and fau

Flask-SocketIO is a Flask extension that integrates the Socket.IO real-time communication protocol into Flask applications, enabling persistent bidirectional connections between servers and clients. It transparently switches between WebSocket and HTTP long-polling while maintaining a persistent session identity, and provides a full event-driven framework for real-time web application communication. The library distinguishes itself with support for namespace multiplexing, allowing event handlers to be isolated into separate namespaces with independent lifecycle and routing. It also offers room

Dramatiq is a distributed task queue and workload manager used to offload function execution to background workers. It functions as an asynchronous task orchestrator that enables the distribution of computational tasks across a cluster using a pluggable transport layer supporting RabbitMQ and Redis. The framework provides specialized tools for complex task orchestration, including the ability to link background jobs into sequences, pipelines, and barriers. It further manages distributed concurrency through the use of shared mutexes, rate limiters, and exponential backoff retries to prevent re

Ockam एक एंड-टू-एंड एन्क्रिप्शन फ्रेमवर्क और वितरित पहचान प्रदाता है जिसे एप्लिकेशन और डिवाइस के बीच सुरक्षित संचार स्थापित करने के लिए डिज़ाइन किया गया है। यह एक सुरक्षित नेटवर्क ओवरले प्रदान करता है जो ज़ीरो ट्रस्ट नेटवर्क एक्सेस को लागू करने के लिए क्रिप्टोग्राफ़िक पहचान और विशेषता-आधारित एक्सेस कंट्रोल का उपयोग करता है। यह प्रोजेक्ट मेटाडेटा-संचालित मल्टी-हॉप रूटिंग और एक प्लगेबल ट्रांसपोर्ट लेयर के माध्यम से खुद को अलग करता है, जिससे एन्क्रिप्टेड ट्रैफ़िक को वर्चुअल IP ओवरले की आवश्यकता के बिना विविध नेटवर्क टोपोलॉजी में जाने की अनुमति मिलती है। यह विशेष रूप से रॉ TCP ट्रैफ़िक को एन्क्रिप्टेड चैनलों में रैप करके लीगेसी एप्लिकेशन के लिए सुरक्षित टनलिंग को सक्षम बनाता है, जिससे आउटबाउंड रिले के माध्यम से निजी नेटवर्क कनेक्टिविटी और फ़ायरवॉल बायपास की अनुमति मिलती है। यह प्लेटफ़ॉर्म वितरित पहचान प्रबंधन, क्रिप्टोग्राफ़िक क्रेडेंशियल जारी करने और सत्यापन, और स्टेटफुल समवर्ती एक्टर्स के निष्पादन सहित क्षमताओं की एक विस्तृत श्रृंखला को कवर करता है। यह क्लाउड-स्केल नोड प्रोविज़निंग और इंफ्रास्ट्रक्चर-एज़-कोड टेम्पलेट का उपयोग करके स्वचालित तैनाती के लिए टूल भी प्रदान करता है।

Ockam एक ज़ीरो-ट्रस्ट नेटवर्किंग फ्रेमवर्क है जिसे पहचान-आधारित नेटवर्क ओवरले का उपयोग करके वितरित एप्लिकेशन के बीच डेटा ट्रांज़िट को सुरक्षित करने के लिए डिज़ाइन किया गया है। यह पारंपरिक नेटवर्क-लेयर सुरक्षा पर निर्भरता को हटाते हुए, पारस्परिक रूप से प्रमाणित और एंड-टू-एंड एन्क्रिप्टेड कनेक्शन स्थापित करने के लिए आवश्यक प्रिमिटिव्स प्रदान करता है। यह प्रोजेक्ट बड़े पैमाने पर विश्वास को प्रबंधित करने के लिए विशेषता-आधारित एक्सेस कंट्रोल और सत्यापन योग्य क्रेडेंशियल्स के उपयोग से अलग है। यह पहचान निरंतरता बनाए रखने के लिए क्रिप्टोग्राफ़िक पहचान रोटेशन लागू करता है और एन्क्लेव या क्लाउड की मैनेजमेंट सेवाओं के भीतर निजी कुंजियों को सुरक्षित करने के लिए हार्डवेयर-समर्थित की मैनेजमेंट सिस्टम के साथ एकीकृत होता है। यह प्लेटफ़ॉर्म मल्टी-हॉप बाइनरी रूटिंग और अलग-अलग नेटवर्क को जोड़ने के लिए रिले-आधारित नेटवर्क ब्रिजिंग सहित क्षमताओं की एक विस्तृत श्रृंखला को कवर करता है। यह लीगेसी TCP या Kafka ट्रैफ़िक को सुरक्षित टनल में रैप कर सकता है, जिससे निजी सेवाओं को लिसनिंग पोर्ट्स को उजागर किए बिना संवाद करने की अनुमति मिलती है। इसके अतिरिक्त, यह वितरित नोड्स में संदेशों को एसिंक्रोनस रूप से प्रोसेस करने के लिए एक स्टेटफुल एक्टर मॉडल का उपयोग करता है। तैनाती को क्लाउड वातावरण में सुरक्षित नोड्स और गेटवे के प्रोविज़निंग के लिए इंफ्रास्ट्रक्चर-एज़-कोड टेम्पलेट के माध्यम से सपोर्ट किया जाता है।

useSend is an email marketing platform and transactional delivery system built to manage bulk campaigns and individual messages using AWS SES for delivery. It provides a RESTful API, an SMTP relay gateway, and a visual management interface for designing HTML templates and coordinating email broadcasts. The platform distinguishes itself by translating legacy SMTP traffic into modern API calls and implementing an event-driven webhook system. This system pushes real-time delivery, bounce, and click notifications to external servers using HMAC-SHA256 signed payloads to ensure authenticity. The s

This project is a PHP compatibility library that provides a polyfill for the native ctype extension. It serves as a portability layer, implementing missing core language functions to ensure consistent behavior across different server environments and PHP versions. The library specializes in character type validation, recreating the behavior of native extension functions using pure PHP code. It uses runtime environment detection to identify if the native extension is missing and injects fallback implementations directly into the global namespace to prevent collisions and maintain code portabil

This project is a headless WhatsApp client and automation server that exposes multi-device functionality as a REST API gateway. It provides a centralized interface for managing multiple account sessions, automating messages, and developing bots through a standardized protocol. The system distinguishes itself by providing a secure webhook provider that forwards real-time messages and reactions to external URLs using signature verification. It includes specialized media utilities for converting images and GIFs into the WebP format required for stickers, as well as tools to simulate active user

The Cloudflare Workers Rust SDK is a toolchain and framework for building high-performance serverless functions using Rust. It compiles code into WebAssembly modules that execute within a sandboxed host environment at the edge. The project provides a typed remote procedure call system for invoking functions across different worker instances and utilizes procedural macros for mapping these distributed interfaces. It uses trait-based bindings and standardized wrappers to provide type-safe access to platform services and web-standard request and response objects. The SDK covers a broad range of

S3Scanner is a security tool for auditing public access and misconfigured permissions across S3-compatible storage providers. It functions as a storage auditor and security scanner designed to identify open buckets, enumerate publicly accessible objects, and exfiltrate data from misconfigured cloud environments. The project is distinguished by its integration with message brokers, allowing it to consume target lists for large-scale cloud infrastructure audits. It also provides utilities for dumping the entire contents of misconfigured buckets to local directories and calculating the total siz