X-Git-Url: http://git.rot13.org/?p=perl-Redis.git;a=blobdiff_plain;f=lib%2FRedis.pm;h=3026ee79c5ec8cc2bbd39dd8f974a7f5d112124d;hp=c976c6b871b9d678e7365ec5c388898e9fc3377f;hb=ca631dea191c0a41b34fe620c3297d2c623bc06b;hpb=c34a5050d658b02796e60d898929ef1690c9c00f diff --git a/lib/Redis.pm b/lib/Redis.pm index c976c6b..3026ee7 100644 --- a/lib/Redis.pm +++ b/lib/Redis.pm @@ -3,14 +3,13 @@ package Redis; use warnings; use strict; +use IO::Socket::INET; +use Data::Dump qw/dump/; + =head1 NAME Redis - The great new Redis! -=head1 VERSION - -Version 0.01 - =cut our $VERSION = '0.01'; @@ -18,34 +17,93 @@ our $VERSION = '0.01'; =head1 SYNOPSIS -Quick summary of what the module does. - -Perhaps a little code snippet. +Pure perl bindings for L use Redis; - my $foo = Redis->new(); - ... + my $r = Redis->new(); + -=head1 EXPORT -A list of functions that can be exported. You can delete this section -if you don't export anything, such as for a purely object-oriented module. =head1 FUNCTIONS -=head2 function1 +=head2 new =cut -sub function1 { +our $sock; +my $server = '127.0.0.1:6379'; + +sub new { + my $class = shift; + my $self = {}; + bless($self, $class); + + warn "# opening socket to $server"; + + $sock ||= IO::Socket::INET->new( + PeerAddr => $server, + Proto => 'tcp', + ) || die $!; + + $self; } -=head2 function2 +=head1 Connection Handling + +=head2 quit + + $r->quit; + +=cut + +sub quit { + my $self = shift; + + close( $sock ) || warn $!; +} + +=head2 ping + + $r->ping || die "no server?"; + +=cut + +sub ping { + print $sock "PING\r\n"; + my $pong = <$sock>; + die "ping failed, got ", dump($pong) unless $pong eq "+PONG\r\n"; +} + +=head1 Commands operating on string values + +=head2 set + + $r->set( foo => 'bar' ); + +=cut + +sub set { + my ( $self, $k, $v ) = @_; + print $sock "SET $k " . length($v) . "\r\n$v\r\n"; + my $ok = <$sock>; + die dump($ok) unless $ok eq "+OK\r\n"; +} + +=head2 get + + my $value = $r->get( 'foo' ); =cut -sub function2 { +sub get { + my ( $self, $k ) = @_; + print $sock "GET $k\r\n"; + my $len = <$sock>; + my $v; + read($sock, $v, $len) || die $!; + return $v; } =head1 AUTHOR