Mojo::Redis - asynchronous Redis client for Mojolicious.
use Mojo::Redis;
my $redis = Mojo::Redis->new(server => '127.0.0.1:6379');
# Execute some commands
$redis->ping(
sub {
my ($redis, $res) = @_;
if ($res) {
print "Got result: ", $res->[0], "\n";
}
else {
print "Error: ", $redis->error, "\n";
}
}
);
# Work with keys
$redis->set(key => 'value');
$redis->get(
key => sub {
my ($redis, $res) = @_;
print "Value of 'key' is $res->[0]\n";
}
);
# Cleanup connection
$redis->quit(sub { shift->stop });
# Start IOLoop (in case it is not started yet)
$redis->start;
Create new Mojo::IOLoop instance if you need to get blocked in a Mojolicious application.
use Mojolicious::Lite;
use Mojo::Redis;
get '/' => sub {
my $self = shift;
my $redis = Mojo::Redis->new(ioloop => Mojo::IOLoop->new);
my $value;
$redis->set(foo => 'bar')->get(
foo => sub {
my ($redis, $result) = @_;
$redis->quit->stop;
return app->log->error($redis->error) unless $result;
$value = $result->[0];
}
)->start;
$self->render(text => qq(Foo value is "$value"));
};
app->start;
Mojo::Redis is an asynchronous client to Redis for Mojo.
Mojo::Redis implements the following attributes.
my $server = $redis->server;
$redis = $redis->server('127.0.0.1:6379');
Redis
server connection string, defaults to '127.0.0.1:6379'.
my $ioloop = $redis->ioloop;
$redis = $redis->ioloop(Mojo::IOLoop->new);
Loop object to use for io operations, by default a Mojo::IOLoop singleton object will be used.
my $timeout = $redis->timeout;
$redis = $redis->timeout(100);
Maximum amount of time in seconds a connection can be inactive before being dropped, defaults to 300
.
my $encoding = $redis->encoding;
$redis = $redis->encoding('UTF-8');
Encoding used for stored data, defaults to UTF-8
.
use Protocol::Redis::XS;
$redis->protocol_redis("Protocol::Redis::XS");
Protocol::Redis implementation' constructor for parsing. By default Protocol::Redis will be used. Parser library must support APIv1.
Using Protocol::Redis::XS instead of default choice can speedup parsing.
Mojo::Redis supports Redis' methods.
$redis->set(key => 'value);
$redis->get(key => sub { ... });
For more details take a look at execute
method.
Also Mojo::Redis implements the following ones.
$redis = $redis->connect;
Connect to Redis
server.
$redis = $redis->execute("ping" => sub{
my ($redis, $result) = @_;
# Process result
});
$redis->execute(lrange => ["test", 0, -1] => sub {...});
$redis->execute(set => [test => "test_ok"]);
Execute specified command on Redis
server. If error occurred during request $result will be set to undef, error string can be obtained with $redis->error.
$redis->execute("ping" => sub {
my ($redis, $result) = @_;
die $redis->error unless defined $result;
});
Returns error occurred during command execution. Note that this method returns error code just from current command and can be used just in callback.
$redis->on_error(sub{
my $redis = shift;
warn 'Redis error ', $redis->error, "\n";
});
Executes if error occurred. Called before commands callbacks.
$redis->start;
Starts IOLoop. Shortcut for $redis->ioloop->start;
Protocol::Redis, Mojolicious, Mojo::IOLoop
#ru.pm on irc.perl.org
https://github.com/und3f/mojox-redis
Sergey Zasenko, [email protected]
.
Copyright (C) 2010-2011, Sergey Zasenko
This program is free software, you can redistribute it and/or modify it under the terms of the Artistic License version 2.0.