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
|
#!/usr/bin/env perl
use strict;
use warnings;
use 5.012;
use lib 'lib';
BEGIN {
*CORE::GLOBAL::time = sub() {1437072205};
}
use Test::Most;
use InfluxDB::LineProtocol qw(data2line line2data);
my @faketime = ( 1437072205, 500681 );
{
no warnings 'redefine';
sub InfluxDB::LineProtocol::gettimeofday() {
wantarray ? @faketime : join( '.', @faketime );
}
};
is( InfluxDB::LineProtocol::ts_ns, '1437072205500681000', 'nanoseconds' );
is( InfluxDB::LineProtocol::ts_us, '1437072205500681', 'microsecond' );
is( InfluxDB::LineProtocol::ts_ms, '1437072205500', 'millisecond' );
is( InfluxDB::LineProtocol::ts_s, '1437072205', 'seconds' );
is( InfluxDB::LineProtocol::ts_m, '23951203', 'minutes' );
is( InfluxDB::LineProtocol::ts_h, '399186', 'hours' );
{
package TsDefault;
use Test::Most;
InfluxDB::LineProtocol->import(qw(data2line));
my $line = data2line( 'default', 1 );
is( $line,
'default value=1i 1437072205500681000',
'line with default nanosecs'
);
}
{
package TsNano;
use Test::Most;
InfluxDB::LineProtocol->import(qw(data2line precision=ns));
my $line = data2line( 'nano', 1 );
is( $line, 'nano value=1i 1437072205500681000', 'line with nanosecs' );
}
{
package TsMicro;
use Test::Most;
InfluxDB::LineProtocol->import(qw(data2line precision=us));
my $line = data2line( 'micro', 1 );
is( $line, 'micro value=1i 1437072205500681', 'line with microsecs' );
}
{
package TsMilli;
use Test::Most;
InfluxDB::LineProtocol->import(qw(data2line precision=ms));
my $line = data2line( 'milli', 1 );
is( $line, 'milli value=1i 1437072205500', 'line with milliseconds' );
}
{
package TsSec;
use Test::Most;
InfluxDB::LineProtocol->import(qw(data2line precision=s));
my $line = data2line( 'sec', 1 );
is( $line, 'sec value=1i 1437072205', 'line with seconds' );
}
{
package TsMin;
use Test::Most;
InfluxDB::LineProtocol->import(qw(data2line precision=m));
my $line = data2line( 'min', 1 );
is( $line, 'min value=1i 23951203', 'line with minutes' );
}
{
package TsHour;
use Test::Most;
InfluxDB::LineProtocol->import(qw(data2line precision=h));
my $line = data2line( 'hour', 1 );
is( $line, 'hour value=1i 399186', 'line with hours' );
}
package main;
done_testing();
|
