fco/circuitbreaker

CircuitBreaker

use CircuitBreaker;

CircuitBreaker.config:  # set new defaults
    :2retries,
    :3failures,
    :1000timeout,
    :10000reset-time
;

sub cbreaker is circuit-breaker{:default<ERROR>} {
    sleep rand * 2;
    $data
}

my Promise @proms;
my $counter = 0;

loop {
    @proms .= grep: Planned;
    for @proms.elems ..^ 5 {
        @proms.push: cbreaker($counter++).then: {printf "\r% 10s => %d", .result, @proms.elems}
    }
    await Promise.anyof: @proms
}

use CircuitBreaker;

CircuitBreaker.config:  # set new defaults
    :2retries,
    :3failures,
    :1000timeout,
    :10000reset-time
;

my &cbreaker := circuit-breaker :default<ERROR>, -> $data {
    sleep rand * 2;
    $data
}

my Promise @proms;
my $counter = 0;

loop {
    @proms .= grep: Planned;
    for @proms.elems ..^ 5 {
        @proms.push: cbreaker($counter++).then: {printf "\r% 10s => %d", .result, @proms.elems}
    }
    await Promise.anyof: @proms
}

use CircuitBreaker;

my &cbreaker := circuit-breaker :default<ERROR>, -> $data {
    sleep rand * 2;
    $data
}

&cbreaker.config:   # configure de defined circuitbreaker
    :2retries,
    :3failures,
    :1000timeout,
    :10000reset-time
;

use CircuitBreaker;

my &my-circuit-breaker := CircuitBreaker.new:   # create a new object
    :2retries,
    :3failures,
    :1000timeout,
    :10000reset-time,
    :exec(-> *@pars, :$of {
        "do something"
    })
;

my $response = await my-circuit-breaker "my", "list". :of<parameters>;

Testing:

use Test;
use CircuitBreaker;
my $*CircuitBreakerMock = CircuitBreaker.mock-router;

my &cbreaker := circuit-breaker :name<test>, -> $name {
    "do something with $name"
}

is await(cbreaker "my name"), "do something with my name", "It shouldn't timeout";

$*CircuitBreakerMock.test.should-timeout(:once);

dies-ok { await cbreaker "my name" }, "It should timeout";