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
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
|
#!/usr/bin/perl
use v5.14; # package NAME {BLOCK}
use warnings;
use Test2::V0;
use Metrics::Any '$metrics';
package Metrics::Any::Adapter::localTestAdapter {
use base "Metrics::Any::AdapterBase::Stored";
# push to an array
sub store_distribution
{
my ( undef, $storage, $amount ) = @_;
push @$storage, $amount;
return $storage;
}
# summarize
sub store_timer
{
my ( undef, $storage, $duration ) = @_;
$storage->{total} += $duration;
$storage->{count} += 1;
return $storage;
}
}
use Metrics::Any::Adapter 'localTestAdapter';
{
$metrics->make_counter( counter => );
$metrics->make_distribution( distribution => );
$metrics->make_gauge( gauge => );
$metrics->make_timer( timer => );
$metrics->inc_counter( counter => );
$metrics->report_distribution( distribution => 1 );
$metrics->report_distribution( distribution => 3 );
$metrics->report_distribution( distribution => 5 );
$metrics->inc_gauge_by( gauge => 5 );
$metrics->report_timer( timer => 2 );
$metrics->report_timer( timer => 4 );
# Also test labels
$metrics->make_counter( labeled_counter =>
labels => [qw( x y )],
);
$metrics->inc_counter( labeled_counter => { x => 10, y => 20 } );
my @walkdata;
Metrics::Any::Adapter->adapter->walk( sub {
my ( $type, $name, $labels, $value ) = @_;
push @walkdata, [ $type, $name, $labels, $value ];
} );
is( \@walkdata, [
[ counter => counter => [], 1 ],
[ distribution => distribution => [], [ 1, 3, 5 ] ],
[ gauge => gauge => [], 5 ],
[ counter => labeled_counter => [ x => 10, y => 20 ], 1 ],
[ timer => timer => [], { total => 6, count => 2 } ],
], 'metrics to ->walk' );
}
# batch mode is supported
{
Metrics::Any::Adapter->adapter->clear_values;
my $called;
my $batch_ok = $metrics->add_batch_mode_callback( sub {
$called++;
$metrics->inc_counter_by( counter => 100 );
$metrics->set_gauge_to( gauge => 25 );
} );
ok( $batch_ok, 'Stored adapter supports batch mode' );
ok( !$called, 'Batch mode callback not yet invoked' );
my @walkdata;
Metrics::Any::Adapter->adapter->walk( sub {
my ( $type, $name, $labels, $value ) = @_;
push @walkdata, [ $type, $name, $labels, $value ];
} );
is( \@walkdata, [
[ counter => counter => [], 100 ],
[ gauge => gauge => [], 25 ],
], 'metrics to ->walk contained batch-reported values' );
ok( $called, 'Batch mode callback invoked by ->walk' );
}
done_testing;
|
