File Coverage

blib/lib/Database/Async/Backoff.pm

Criterion	Covered	Total	%
statement	23	28	82.1
branch	2	4	50.0
condition	0	2	0.0
subroutine	7	10	70.0
pod	0	7	0.0
total	32	51	62.7

package Database::Async::Backoff;

use strict;
use warnings;

our $VERSION = '0.017'; # VERSION

=head1 NAME

Database::Async::Backoff - support for backoff algorithms in L

=head1 DESCRIPTION

=cut

use Future::AsyncAwait;
my %class_for_type;

sub new {
    my ($class, %args) = @_;
    bless \%args, $class
}

sub initial_delay { shift->{initial_delay} }
sub max_delay { shift->{max_delay} }

async sub next {
    my ($self, $code) = @_;
    return $self->{delay} ||= 1;
}

async sub reset {
    my ($self) = @_;
    $self->{delay} = 0;
    $self
}

sub register {
    my ($class, %args) = @_;
    for my $k (keys %args) {
        $class_for_type{$k} = $args{$k}
    }
    $class
}

sub instantiate {
    my ($class, %args) = @_;
    my $type = delete $args{type}
        or die 'backoff type required';
    my $target_class = $class_for_type{$type}
        or die 'unknown backoff type ' . $type;
    return $target_class->new(%args);
}

1;