Sharq Server - A flexible rate limited queueing system

  •        314

SHARQ is a flexible, open source, rate limited queuing system. Based on the Leaky Bucket Algorithm, SHARQ lets you create queues dynamically and update their rate limits in real time. SHARQ consists of two components - the core component and the server component. The SHARQ core is built on Redis, using Python and Lua, and the SHARQ Server is built using Flask and Gevent and talks HTTP.

http://sharq.io
https://github.com/plivo/sharq-server

Tags
Implementation
License
Platform

   




Related Projects

ratelimit - A Golang blocking leaky-bucket rate limit implementation


This package provides a Golang implementation of the leaky-bucket rate limit algorithm. This implementation refills the bucket based on the time elapsed between requests instead of requiring an interval clock to fill the bucket discretely.Create a rate limiter with a maximum number of operations to perform per second. Call Take() before each operation. Take will sleep until you can continue.

couchdb-lager - Mirror of Apache CouchDB


for the backend:```erlang{lager, [ {handlers, [ {lager_console_backend, [info, {lager_default_formatter, [time," [",severity,"] ", message, "\n"]}]}, {lager_file_backend, [{file, "error.log"}, {level, error}, {formatter, lager_default_formatter}, {formatter_config, [date, " ", time," [",severity,"] ",pid, " ", message, "\n"]}]}, {lager_file_backend, [{file, "console.log"}, {level, info}]} ]}]}.```Included is lager_default_formatter. This provides a generic, default formatting fo

Queue-Leaky - Release history of Queue-Leaky


Release history of Queue-Leaky

Bucketeer - HTTP service for leaky-bucket style rate limiting


HTTP service for leaky-bucket style rate limiting

Tibco Message Admin


Tibco Message Admin allows you to purge a queue, list messages in a queue, save a message from a queue to a file, edit the message in memory and send to another (or same) queue, load message from a file and send it to a queue



localjob - Simple, self-contained background queue built on top of SysV message queues.


Localjob is a simple, self-contained background queue built on top of System V message queues (SysV Message Queue => SysV MQ for short). The SysV message queue API is implemented by the kernel. It's very stable and performant.This means workers and the app pushing to the queue must reside on the same machine. It's the sqlite of background queues. Here's a post about how it works. You can run Localjob either as a seperate process, or as a thread in your app.

Celery - Distributed Task Queue


Celery is an asynchronous task queue/job queue based on distributed message passing. It is focused on real-time operation, but supports scheduling as well. The execution units, called tasks, are executed concurrently on a single or more worker servers using multiprocessing, Eventlet, or gevent. Tasks can execute asynchronously (in the background) or synchronously (wait until ready).

RocketMQ - Distributed messaging and streaming data platform


Apache RocketMQ is a distributed messaging and streaming platform with low latency, high performance and reliability, trillion-level capacity and flexible scalability.

cherami-server - Distributed, scalable, durable, and highly available message queue system.


Cherami is a distributed, scalable, durable, and highly available message queue system we developed at Uber Engineering to transport asynchronous tasks.This repo contains the source code of Cherami server, cross-zone replicator server, and several tools. Your application needs to use the client to interact with the server. The client can be found here.

mongo-queue-java - Java message queue using MongoDB as a backend


Java message queue using MongoDB as a backend Adheres to the 1.0.0 specification.

lightMQ - a message queue server


a message queue server

chainmq - ChainMQ is a Message/Work Queue Server, wire-protocol compatible with Beanstalkd


ChainMQ is a Message/Work Queue Server, wire-protocol compatible with Beanstalkd

echoq - a simple, lightweight message queue server


a simple, lightweight message queue server

ucmq - A simple HTTP message queue server


A simple HTTP message queue server

memqueue - in-memory message queue server with revisions & expirations


in-memory message queue server with revisions & expirations

mq_server - Message Queue Server


Message Queue Server

erlmq - A binlog based message queue server that just works.


A binlog based message queue server that just works.

mq-bundle - A Message Queue Server for Symfony


A Message Queue Server for Symfony

lineup - A minimalistic message queue server, in Go


A minimalistic message queue server, in Go

fibernet - Message Queue/C++/Lua based game server


Message Queue/C++/Lua based game server