diff options
author | franck cuny <franck@lumberjaph.net> | 2010-03-30 15:36:02 +0200 |
---|---|---|
committer | franck cuny <franck@lumberjaph.net> | 2010-03-30 15:36:02 +0200 |
commit | 397a9dc9fcfd3e61de12bcf6e7e39ca660155348 (patch) | |
tree | a397a4bfc708f156b7c13eec3762320f7e5b9993 /lib/Plack/Middleware/APIRateLimit/Backend/Redis.pm | |
parent | remove Moose, update call method, return remaining seconds instead of epoch t... (diff) | |
download | plack-middleware-apiratelimit-397a9dc9fcfd3e61de12bcf6e7e39ca660155348.tar.gz |
update POD, fix redis backend
Diffstat (limited to '')
-rw-r--r-- | lib/Plack/Middleware/APIRateLimit/Backend/Redis.pm | 31 |
1 files changed, 15 insertions, 16 deletions
diff --git a/lib/Plack/Middleware/APIRateLimit/Backend/Redis.pm b/lib/Plack/Middleware/APIRateLimit/Backend/Redis.pm index e647f6a..2bb6251 100644 --- a/lib/Plack/Middleware/APIRateLimit/Backend/Redis.pm +++ b/lib/Plack/Middleware/APIRateLimit/Backend/Redis.pm @@ -3,41 +3,40 @@ package Plack::Middleware::APIRateLimit::Backend::Redis; use Moose; extends 'Plack::Middleware::APIRateLimit::Backend'; -use AnyEvent::Redis; +use Redis; has store => ( is => 'rw', - isa => 'AnyEvent::Redis', + isa => 'Redis', lazy => 1, default => sub { - return AnyEvent::Redis->new( - host => '127.0.0.1', - port => 6378, + return Redis->new( + server => '127.0.0.1:6379' ); } ); sub BUILD { - my $self = shift; - if (scalar @_) { - $self->store(AnyEvent::Redis->new(@_)); + my ( $self, $opt ) = @_; + if ($opt) { + $self->store( Redis->new(%$opt) ); } return $self; } sub get { my ( $self, $key ) = @_; - my $val = $self->store->get($key)->recv; - if ( !$val ) { - $self->store->set( $key => 1 )->recv; - $val = 1; - } - return $val; + $self->store->get($key); +} + +sub set { + my ($self, $key, $value) = @_; + $self->store->set($key, $value); } sub incr { - my ($self, $key) = @_; - return $self->store->incr($key)->recv; + my ( $self, $key ) = @_; + $self->store->incr($key); } 1; |