75 |
confess dump($ok) unless $ok eq "+OK\r\n"; |
confess dump($ok) unless $ok eq "+OK\r\n"; |
76 |
} |
} |
77 |
|
|
78 |
|
sub _sock_send_bulk { |
79 |
|
my ( $self, $command, $key, $value ) = @_; |
80 |
|
print $sock "$command $key " . length($value) . "\r\n$value\r\n"; |
81 |
|
_sock_ok(); |
82 |
|
} |
83 |
|
|
84 |
|
|
85 |
=head1 Connection Handling |
=head1 Connection Handling |
86 |
|
|
87 |
=head2 quit |
=head2 quit |
117 |
=cut |
=cut |
118 |
|
|
119 |
sub set { |
sub set { |
120 |
my ( $self, $k, $v, $new ) = @_; |
my ( $self, $key, $value, $new ) = @_; |
121 |
print $sock "SET" . ( $new ? 'NX' : '' ) . " $k " . length($v) . "\r\n$v\r\n"; |
$self->_sock_send_bulk( "SET" . ( $new ? 'NX' : '' ), $key, $value ); |
|
_sock_ok(); |
|
122 |
} |
} |
123 |
|
|
124 |
=head2 get |
=head2 get |
255 |
_sock_result(); |
_sock_result(); |
256 |
} |
} |
257 |
|
|
258 |
|
=head1 Commands operating on lists |
259 |
|
|
260 |
|
=head2 rpush |
261 |
|
|
262 |
|
$r->rpush( $key, $value ); |
263 |
|
|
264 |
|
=cut |
265 |
|
|
266 |
|
sub rpush { |
267 |
|
my ( $self, $key, $value ) = @_; |
268 |
|
$self->_sock_send_bulk('RPUSH', $key, $value); |
269 |
|
} |
270 |
|
|
271 |
=head1 AUTHOR |
=head1 AUTHOR |
272 |
|
|
273 |
Dobrica Pavlinusic, C<< <dpavlin at rot13.org> >> |
Dobrica Pavlinusic, C<< <dpavlin at rot13.org> >> |