| Collection documentation | Contained in the Collection distribution. |
Collection::Memcached - class for collections of data, stored in Memcached.
use Collection::Memcached;
use Cache::Memcached;
$memd = new Cache::Memcached {
'servers' => [ "127.0.0.1:11211" ],
'debug' => 0,
'compress_threshold' => 10_000,
};
$memd->set_compress_threshold(10_000);
$memd->enable_compress(0);
my $collection = new Collection::Memcached:: $memd;
...
my $collection_prefix = new Collection::Memcached:: $memd, 'prefix';
Class for collections of data, stored in Memcached.
Creates a new Collection::Memcached object. Keys transparently autoprefixed with <prefix> if provided.
my $collection_prefix = new Collection::Memcached:: $memd, 'prefix';
Collection, README
Zahatski Aliaksandr, <zag@cpan.org>
Copyright (C) 2005-2008 by Zahatski Aliaksandr
This library is free software; you can redistribute it and/or modify it under the same terms as Perl itself, either Perl version 5.8.8 or, at your option, any later version of Perl 5 you may have available.
| Collection documentation | Contained in the Collection distribution. |
package Collection::Memcached;
use Collection; use Collection::Utl::Base; use Data::Dumper; use Collection::Utl::ActiveRecord; use strict; use warnings; our @ISA = qw(Collection); our $VERSION = '0.01'; attributes qw/ _mem_cache _ns /; sub _init { my $self = shift; my $memd = shift || return undef; if ( my $ns = shift ) { $self->_ns($ns); } $self->_mem_cache($memd); $self->SUPER::_init(); return 1; } sub _delete { my $self = shift; my @ids = @_; my $memd = $self->_mem_cache; my $ns = $self->_ns; if ( defined $ns ) { #auto prefix keys foreach my $id (@ids) { $id = $ns . $id; } } $memd->delete($_) for @ids; #return array of deleted [@_]; } sub _create { my $self = shift; my %to_save = @_; my $memd = $self->_mem_cache; my $ns = $self->_ns; $ns = '' unless defined $ns; my %res = (); while ( my ( $key, $val ) = each %to_save ) { $memd->set( $ns . $key, $val ) && $res{$key}++; } return \%res; } sub _fetch { my $self = shift; my @ids = @_; my $ns = $self->_ns; if ( defined $ns ) { #auto prefix keys foreach my $id (@ids) { $id = $ns . $id; } } my $memd = $self->_mem_cache; my $res = $memd->get_multi(@ids); if ( defined $ns ) { my $tmp_res = {}; my $ns_len = length $ns; while ( my ( $keyns, $val ) = each %$res ) { my $key = substr( $keyns, $ns_len, length($keyns) - $ns_len ); $tmp_res->{$key} = $val; } $res = $tmp_res; } $res; } sub _prepare_record { my ( $self, $key, $ref ) = @_; my %hash; tie %hash, 'Collection::Utl::ActiveRecord', hash => $ref; return \%hash; } sub _store { my $self = shift; my $in = shift; my $memd = $self->_mem_cache; my $ns = $self->_ns; $ns = '' unless defined $ns; while ( my ( $key, $val ) = each %$in ) { $memd->set( $ns . $key, $val ); } } sub commit { my $self = shift; } sub list_ids { my $self = shift; return [ keys %{ $self->_obj_cache() } ]; } 1; __END__