cr0nixx/leakybucket

An implementation of the Leaky Bucket algorithm.

LeakyBucket

Leaky Bucket is an algorithm which works as follows:, _(*1)

1. There is a bucket.
2. The bucket has a defined leak and defined capacity.
3. The bucket leaks at a constant rate.
4. Overflows when full, will not add other drops to the bucket.

Install

php composer.phar require "pskuza/leakybucket", _(*2)

Usage

Basic usage

``` php <?php, <sub>(*3)</sub>

use LeakyBucket\LeakyBucket; use LeakyBucket\Storage\RedisStorage;, <sub>(*4)</sub>

// Define which storage to use $storage = new RedisStorage();, <sub>(*5)</sub>

// Define the bucket $settings = [ 'capacity' => 10, 'leak' => 1 ];, <sub>(*6)</sub>

// Create the bucket $bucket = new LeakyBucket('example-bucket', $storage, $settings);, <sub>(*7)</sub>

// Fill the bucket $bucket->fill(); $bucket->save();, <sub>(*8)</sub>

// Check if it's full if ($bucket->isFull()) { header('HTTP/1.1 429 Too Many Requests'); die(', <sub>(*9)</sub>

429 Too Many Requests

You seem to be doing a lot of requests. You\'re now cooling down., <sub>(*10)</sub>

'); }, <sub>(*11)</sub>

// ..., <sub>(*12)</sub>

### For memcached use
``` php
<?php

use LeakyBucket\LeakyBucket;
use LeakyBucket\Storage\MemcachedStorage;

// Define which storage to use
$storage = new MemcachedStorage();

Other functionality

You can also do great stuff with it through the methods that LeakyBucket provides., <sub>(*13)</sub>

``` php // Get capacity information $capacityTotal = $bucket->getCapacity(); $capacityLeft = $bucket->getCapacityLeft(); $capacityUsed = $bucket->getCapacityUsed();, <sub>(*14)</sub>

// Get the drops/second that the bucket leaks $leakPerSecond = $bucket->getLeak();, <sub>(*15)</sub>

// Get the last timestamp from when the bucket was updated $timestamp = $bucket->getLastTimestamp();, <sub>(*16)</sub>

// Set additional data $bucket->setData( [ 'timeout' => 3600 ] );, <sub>(*17)</sub>

// Set additional data $data = $bucket->getData();, <sub>(*18)</sub>

// Update the bucket with the leaked drops $bucket->leak();, <sub>(*19)</sub>

// Remove excess drops $bucket->overflow();, <sub>(*20)</sub>

// Update the bucket's timestamp manually $bucket->touch();, <sub>(*21)</sub>

// Fill the bucket with one drop $bucket->fill();, <sub>(*22)</sub>

// Fill the bucket with 5 drops $bucket->fill(5);, <sub>(*23)</sub>

// Spill one drop from the bucket $bucket->spill();, <sub>(*24)</sub>

// Spill 5 drops from the bucket $bucket->spill(5);, <sub>(*25)</sub>

// Remove the bucket's content $bucket->reset();, <sub>(*26)</sub>

// Force save $bucket->save(); ```, <sub>(*27)</sub>

Contributing

You can contribute by forking the repo and creating pull requests. You can also create issues or feature requests., <sub>(*28)</sub>

Checklist

1. Your code complies with the PSR-2 standards. (check using the php-cs-checker)
2. Your code is fully tested and PHPUnit tests are also supplied.
3. Your code passes in TravisCI build.
4. By contributing your code, you agree to license your contribution under the MIT license.

Boring legal stuff

This project is licensed under the MIT license. LICENSE file can be found in this repository., <sub>(*29)</sub>