Proxmox/pve-manager
5
0
Fork 0
Code Pull Requests Releases Activity

add graphite plugin V2

Browse Source 
Signed-off-by: Alexandre Derumier <aderumier@odiso.com>
This commit is contained in:
Alexandre Derumier 2015-06-23 11:20:35 +02:00 committed by Dietmar Maurer
parent 448c4aaa67
commit 567bb543a7
3 changed files with 86 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

89
PVE/Status/Graphite.pm
View File

@ -7,6 +7,8 @@ use PVE::Status::Plugin;
# example config (/etc/pve/status.cfg)
#graphite:
# graphiteserver test
# port 2003
# path proxmox.mycluster
# disable 0
#
@ -19,8 +21,16 @@ sub type {
sub properties {
return {
graphiteserver => {
type => 'string',
description => "External graphite statistic server",
type => 'string', format => 'dns-name',
description => "External graphite statistic server dns name",
},
port => {
type => 'integer',
description => "graphite server port",
},
path => {
type => 'string', format => 'graphite-path',
description => "root graphite path (ex: proxmox.mycluster.mykey)",
},
};
}
@ -28,33 +38,90 @@ sub properties {
sub options {
return {
graphiteserver => {},
port => { optional => 1 },
path => { optional => 1 },
disable => { optional => 1 },
};
}
# Plugin implementation
sub update_node_status {
my ($plugin_config, $node, $data) = @_;
my ($class, $plugin_config, $node, $data, $ctime) = @_;
write_graphite_hash($plugin_config, $data, $ctime, "nodes.$node");
# implement me
}
sub update_qemu_status {
my ($plugin_config, $vmid, $data) = @_;
# implement me
my ($class, $plugin_config, $vmid, $data, $ctime) = @_;
write_graphite_hash($plugin_config, $data, $ctime, "qemu.$vmid");
}
sub update_lxc_status {
my ($plugin_config, $vmid, $data) = @_;
my ($class, $plugin_config, $vmid, $data, $ctime) = @_;
# implement me
write_graphite_hash($plugin_config, $data, $ctime, "lxc.$vmid");
}
sub update_storage_status {
my ($plugin_config, $storeid, $data) = @_;
my ($class, $plugin_config, $nodename, $storeid, $data, $ctime) = @_;
# implement me
write_graphite_hash($plugin_config, $data, $ctime, "storages.$nodename.$storeid");
}
sub write_graphite_hash {
my ($plugin_config, $d, $ctime, $object) = @_;
my $host = $plugin_config->{graphiteserver};
my $port = $plugin_config->{port} ? $plugin_config->{port} : 2003;
my $path = $plugin_config->{path} ? $plugin_config->{path} : 'proxmox';
my $carbon_socket = IO::Socket::IP->new(
PeerAddr => $host,
PeerPort => $port,
Proto => 'udp',
);
write_graphite($carbon_socket, $d, $ctime, $path.".$object");
$carbon_socket->close() if $carbon_socket;
}
sub write_graphite {
my ($carbon_socket, $d, $ctime, $path) = @_;
for my $key (keys %$d) {
my $value = $d->{$key};
my $oldpath = $path;
$key =~ s/\./-/g;
$path .= ".$key";
if ( defined $value ) {
if ( ref $value eq 'HASH' ) {
write_graphite($carbon_socket, $value, $ctime, $path);
}else {
$carbon_socket->send( "$path $value $ctime" );
}
}
$path = $oldpath;
}
}
PVE::JSONSchema::register_format('graphite-path', \&pve_verify_graphite_path);
sub pve_verify_graphite_path {
my ($path, $noerr) = @_;
my $regex = "([a-zA-Z0-9]([a-zA-Z0-9\-]*[a-zA-Z0-9])?)";
if ($path !~ /^(${regex}\.)*${regex}$/) {
return undef if $noerr;
die "value does not look like a valid graphite path\n";
}
return $path;
}
1;

8
PVE/Status/Plugin.pm
View File

@ -48,25 +48,25 @@ sub parse_section_header {
}
sub update_node_status {
my ($plugin_config, $node, $data) = @_;
my ($class, $plugin_config, $node, $data, $ctime) = @_;
die "please implement inside plugin";
}
sub update_qemu_status {
my ($plugin_config, $vmid, $data) = @_;
my ($class, $plugin_config, $vmid, $data, $ctime) = @_;
die "please implement inside plugin";
}
sub update_lxc_status {
my ($plugin_config, $vmid, $data) = @_;
my ($class, $plugin_config, $vmid, $data, $ctime) = @_;
die "please implement inside plugin";
}
sub update_storage_status {
my ($plugin_config, $storeid, $data) = @_;
my ($class, $plugin_config, $nodename, $storeid, $data, $ctime) = @_;
die "please implement inside plugin";
}

8
bin/pvestatd
View File

@ -119,7 +119,7 @@ sub update_node_status {
next if $plugin_config->{disable};
my $plugin = PVE::Status::Plugin->lookup($plugin_config->{type});
my $d = {}; # fixme: what data?
$plugin->update_node_status($plugin_config, $nodename, $d);
$plugin->update_node_status($plugin_config, $nodename, $d, $ctime);
}
}
@ -197,7 +197,7 @@ sub update_qemu_status {
my $plugin_config = $status_cfg->{ids}->{$id};
next if $plugin_config->{disable};
my $plugin = PVE::Status::Plugin->lookup($plugin_config->{type});
$plugin->update_qemu_status($plugin_config, $vmid, $d);
$plugin->update_qemu_status($plugin_config, $vmid, $d, $ctime);
}
}
}
@ -244,7 +244,7 @@ sub update_lxc_status {
my $plugin_config = $status_cfg->{ids}->{$id};
next if $plugin_config->{disable};
my $plugin = PVE::Status::Plugin->lookup($plugin_config->{type});
$plugin->update_lxc_status($plugin_config, $vmid, $d);
$plugin->update_lxc_status($plugin_config, $vmid, $d, $ctime);
}
}
}
@ -274,7 +274,7 @@ sub update_storage_status {
my $plugin_config = $status_cfg->{ids}->{$id};
next if $plugin_config->{disable};
my $plugin = PVE::Status::Plugin->lookup($plugin_config->{type});
$plugin->update_storage_status($plugin_config, $storeid, $d);
$plugin->update_storage_status($plugin_config, $nodename, $storeid, $d, $ctime);
}
}
}