···

       
15
       
 
       
has 'collection' => ( is => 'ro', isa => 'MongoDB::Collection' );

     

       
16
       
 
       
has 'db_name'    => ( is => 'ro', isa => 'Str', default => 'chi' );

     

       
17
       
 
       
has 'safe'       => ( is => 'rw', isa => 'Bool', default => 0 );

     

       
18
       
-
       
has 'use_oid'    => ( is => 'rw', isa => 'Bool', default => 0 );

     

       
19
       
 
       


     

       
20
       
 
       
__PACKAGE__->meta->make_immutable();

     

       
21
       
 
       


     
···

       
36
       
 
       


     

       
37
       
 
       
sub fetch {

     

       
38
       
 
       
    my ( $self, $key ) = @_;

     

       
39
       
-
       
    $key =

     

       
40
       
-
       
      ( $self->{use_oid} )

     

       
41
       
-
       
      ? MongoDB::OID->new( value => unpack( "H*", $key ) )

     

       
42
       
-
       
      : $key;

     

       
43
       
 
       


     

       
44
       
 
       
    my $results = $self->collection->find_one( { _id => $key }, { data => 1 } );

     

       
45
       
 
       
    return ($results) ? $results->{data} : undef;

     
···

       
47
       
 
       


     

       
48
       
 
       
sub store {

     

       
49
       
 
       
    my ( $self, $key, $data ) = @_;

     

       
50
       
-
       
    $key =

     

       
51
       
-
       
      ( $self->{use_oid} )

     

       
52
       
-
       
      ? MongoDB::OID->new( value => unpack( "H*", $key ) )

     

       
53
       
-
       
      : $key;

     

       
54
       
 
       


     

       
55
       
 
       
    $self->collection->save( { _id => $key, data => $data },

     

       
56
       
 
       
        { safe => $self->{safe} } );

     
···

       
59
       
 
       


     

       
60
       
 
       
sub remove {

     

       
61
       
 
       
    my ( $self, $key ) = @_;

     

       
62
       
-
       
    $key =

     

       
63
       
-
       
      ( $self->{use_oid} )

     

       
64
       
-
       
      ? MongoDB::OID->new( value => unpack( "H*", $key ) )

     

       
65
       
-
       
      : $key;

     

       
66
       
 
       


     

       
67
       
 
       
    $self->collection->remove( { _id => $key }, { safe => $self->{safe} } );

     

       
68
       
 
       
    return;

     
···

       
74
       
 
       
}

     

       
75
       
 
       


     

       
76
       
 
       
sub get_keys {

     

       
77
       
-
       
    return ( !shift->{use_oid} )

     

       
78
       
-
       
      ? map { $_->{_id} } shift->collection->find( {}, { _id => 1 } )->all

     

       
79
       
-
       
      : croak 'Cannot get keys when converting keys to OID';

     

       
80
       
 
       
}

     

       
81
       
 
       


     

       
82
       
 
       
sub get_namespaces {

     
···

       
140
       
 
       
=item safe

     

       
141
       
 
       


     

       
142
       
 
       
Optional flag to confirm insertion/removal. This will slow down writes significantly.

     

       
143
       
-
       


     

       
144
       
-
       
=item use_oid

     

       
145
       
-
       


     

       
146
       
-
       
Optional flag to convert key to OID. This speeds up gets, slows retrieval, and removes the ability to get_keys.

     

       
147
       
 
       


     

       
148
       
 
       
=back

     

       
149
       
 
       


     

···

       
15
       
 
       
has 'collection' => ( is => 'ro', isa => 'MongoDB::Collection' );

     

       
16
       
 
       
has 'db_name'    => ( is => 'ro', isa => 'Str', default => 'chi' );

     

       
17
       
 
       
has 'safe'       => ( is => 'rw', isa => 'Bool', default => 0 );

     

       
0
       
 
       

     

       
18
       
 
       


     

       
19
       
 
       
__PACKAGE__->meta->make_immutable();

     

       
20
       
 
       


     
···

       
35
       
 
       


     

       
36
       
 
       
sub fetch {

     

       
37
       
 
       
    my ( $self, $key ) = @_;

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
38
       
 
       


     

       
39
       
 
       
    my $results = $self->collection->find_one( { _id => $key }, { data => 1 } );

     

       
40
       
 
       
    return ($results) ? $results->{data} : undef;

     
···

       
42
       
 
       


     

       
43
       
 
       
sub store {

     

       
44
       
 
       
    my ( $self, $key, $data ) = @_;

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
45
       
 
       


     

       
46
       
 
       
    $self->collection->save( { _id => $key, data => $data },

     

       
47
       
 
       
        { safe => $self->{safe} } );

     
···

       
50
       
 
       


     

       
51
       
 
       
sub remove {

     

       
52
       
 
       
    my ( $self, $key ) = @_;

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
53
       
 
       


     

       
54
       
 
       
    $self->collection->remove( { _id => $key }, { safe => $self->{safe} } );

     

       
55
       
 
       
    return;

     
···

       
61
       
 
       
}

     

       
62
       
 
       


     

       
63
       
 
       
sub get_keys {

     

       
64
       
+
       
    map { $_->{_id} } shift->collection->find( {}, { _id => 1 } )->all;

     

       
0
       
 
       

     

       
0
       
 
       

     

       
65
       
 
       
}

     

       
66
       
 
       


     

       
67
       
 
       
sub get_namespaces {

     
···

       
125
       
 
       
=item safe

     

       
126
       
 
       


     

       
127
       
 
       
Optional flag to confirm insertion/removal. This will slow down writes significantly.

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
128
       
 
       


     

       
129
       
 
       
=back

     

       
130