package FakeCollectd;
=head1 NAME
FakeCollectd - Provides in-place replacement for testing L<Collectd> plugins.
=head1 SYNOPSIS
Used internally by Test::Collectd::Plugins.
=cut
use Carp qw/croak/;
require Exporter;
push @ISA, qw/Exporter/;
our %EXPORT_TAGS = (
all => [qw(
TYPE_CONFIG
TYPE_INIT
TYPE_READ
TYPE_WRITE
TYPE_SHUTDOWN
TYPE_LOG
TYPE_NOTIF
TYPE_FLUSH
TYPE_DATASET
LOG_DEBUG
LOG_INFO
LOG_NOTICE
LOG_WARNING
LOG_ERR
NOTIF_FAILURE
NOTIF_WARNING
NOTIF_OKAY
$hostname_g
$interval_g
plugin_register
plugin_dispatch_values
plugin_log
WARN
%FakeCollectd
)],
);
push @EXPORT, @{$EXPORT_TAGS{all}};
our $VERSION = "0.1000";
our $interval_g = 10;
our $hostname_g = "localhost";
our %FakeCollectd;
use constant TYPE_CONFIG => "config";
use constant TYPE_INIT => "init";
use constant TYPE_READ => "read";
use constant TYPE_WRITE => "write";
use constant TYPE_SHUTDOWN => "shutdown";
use constant TYPE_LOG => "log";
use constant TYPE_NOTIF => "notify";
use constant TYPE_FLUSH => "flush";
use constant TYPE_DATASET => "init";
use constant LOG_DEBUG => 7;
use constant LOG_INFO => 6;
use constant LOG_NOTICE => 5;
use constant LOG_WARNING => 4;
use constant LOG_ERR => 3;
use constant NOTIF_FAILURE => 1;
use constant NOTIF_WARNING => 2;
use constant NOTIF_OKAY => 4;
=head2 plugin_register (CALLBACK_TYPE, PLUGIN_NAME, CALLBACK_NAME)
Will Populate %FakeCollectd using provided arguments.
=cut
sub plugin_register {
my ($type,$name,$data) = @_;
my $caller = scalar caller 0;
$FakeCollectd{$caller}->{Name} = $name;
if ($type eq TYPE_CONFIG) {
$FakeCollectd{$name}->{Callback}->{Config} = $caller."::".$data;
} elsif ($type eq TYPE_INIT) {
$FakeCollectd{$name}->{Callback}->{Init} = $caller."::".$data;
} elsif ($type eq TYPE_READ) {
$FakeCollectd{$name}->{Callback}->{Read} = $caller."::".$data;
} else {
die "$type not supported (yet)";
}
1;
}
=head2 plugin_dispatch_values ( value_type )
Populates %FakeCollectd with the data.
=cut
sub plugin_dispatch_values {
my $caller = scalar caller 0;
unless (ref $_[0] eq "HASH") {
croak "plugin_dispatch_values $caller: dispatch can only be called using HASHREF arg";
return undef;
}
my $plugin = $_[0] -> {plugin};
unless (defined $plugin) {
croak "plugin_dispatch_values $caller: no 'plugin' key in dispatch";
return undef;
}
push @{$FakeCollectd{$plugin}->{Values}}, \@_;
1;
}
=head2 WARN
Replaces Warning function
=cut
sub WARN {
plugin_log (LOG_WARNING, @_);
}
=head2 plugin_log
Replaces log function
=cut
sub plugin_log {
eval {croak join " ", @_}
}
1;