X-Git-Url: http://git.rot13.org/?a=blobdiff_plain;f=lib%2FRedis.pm;h=d03416e779b8d47ffccdae1ac0740d099cda1890;hb=a57e5b0908eea8c9a2dbd0c0a0a36729afa5fc58;hp=4c46a664dd34d07e6337326a39510d4f924b8c23;hpb=c17c55f4d08784e06156e175996b19ba41906af4;p=perl-Redis.git diff --git a/lib/Redis.pm b/lib/Redis.pm index 4c46a66..d03416e 100644 --- a/lib/Redis.pm +++ b/lib/Redis.pm @@ -5,6 +5,7 @@ use strict; use IO::Socket::INET; use Data::Dump qw/dump/; +use Carp qw/confess/; =head1 NAME @@ -66,7 +67,7 @@ sub quit { =head2 ping - $r->ping || die "no server?"; + $r->ping || die "no server?"; =cut @@ -76,6 +77,43 @@ sub ping { die "ping failed, got ", dump($pong) unless $pong eq "+PONG\r\n"; } +=head1 Commands operating on string values + +=head2 set + + $r->set( foo => 'bar', $new ); + +=cut + +sub set { + my ( $self, $k, $v, $new ) = @_; + print $sock ( $new ? "SETNX" : "SET" ) . " $k " . length($v) . "\r\n$v\r\n"; + my $ok = <$sock>; + confess dump($ok) unless $ok eq "+OK\r\n"; +} + +=head2 get + + my $value = $r->get( 'foo' ); + +=cut + +sub get { + my ( $self, $k ) = @_; + print $sock "GET $k\r\n"; + my $len = <$sock>; +# warn "# len: ",dump($len); + return undef if $len eq "nil\r\n"; + my $v; + read($sock, $v, $len) || die $!; +# warn "# v: ",dump($v); + my $crlf; + read($sock, $crlf, 2); # skip cr/lf + return $v; +} + + + =head1 AUTHOR Dobrica Pavlinusic, C<< >>