t/10_riak.t


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

#!/usr/bin/perl

use Scope::Guard;
use Test::More 'no_plan';

#BEGIN {
#    plan skip_all => 'Please set KIOKU_RIAK_URI to a Riak instance URI' unless $ENV{KIOKU_RIAK_URI};
#    plan 'no_plan';
#}

use ok 'KiokuDB';
use ok 'KiokuDB::Backend::Riak';

use KiokuDB::Test;

use AnyEvent::Riak;

my $db = AnyEvent::Riak->new(
    host => 'http://localhost:8098',
    path => 'jiak',
);

my $bucket = $db->list_bucket('kiokudb')->recv;
foreach my $key (@{$bucket->{keys}}) {
    $db->delete('kiokudb', $key)->recv;
}

run_all_fixtures(
    KiokuDB->new(
        backend => KiokuDB::Backend::Riak->new(
            db => $db,
            bucket => 'kiokudb',
        ),
    )
);