From 94525a03db699a24a7ee9c50a53d4acd7cd5466b Mon Sep 17 00:00:00 2001 From: garnier-quentin Date: Tue, 5 Feb 2019 15:02:46 +0100 Subject: [PATCH] WIP: centreon connector 3.0 vmware --- apps/vmware/connector/mode/statconnectors.pm | 78 ++++++++-- apps/vmware/connector/mode/statushost.pm | 143 ++++++++++++++++--- 2 files changed, 188 insertions(+), 33 deletions(-) diff --git a/apps/vmware/connector/mode/statconnectors.pm b/apps/vmware/connector/mode/statconnectors.pm index 8ca6bca43..4646e8de0 100644 --- a/apps/vmware/connector/mode/statconnectors.pm +++ b/apps/vmware/connector/mode/statconnectors.pm @@ -20,14 +20,54 @@ package apps::vmware::connector::mode::statconnectors; -use base qw(centreon::plugins::mode); +use base qw(centreon::plugins::templates::counter); use strict; use warnings; +use Digest::MD5 qw(md5_hex); + +sub set_counters { + my ($self, %options) = @_; + + $self->{maps_counters_type} = [ + { name => 'global', type => 0, skipped_code => { -10 => 1 } }, + { name => 'container', type => 1, cb_prefix_output => 'prefix_container_output', message_multiple => 'All containers are ok' }, + ]; + + $self->{maps_counters}->{global} = [ + { label => 'total-requests', set => { + key_values => [ { name => 'requests', diff => 1 } ], + output_template => 'Total %s requests', + perfdatas => [ + { label => 'requests', value => 'requests_absolute', template => '%s', + min => 0, label_extra_instance => 1 }, + ], + } + }, + ]; + + $self->{maps_counters}->{container} = [ + { label => 'requests', set => { + key_values => [ { name => 'requests', diff => 1 } ], + output_template => '%s requests', + perfdatas => [ + { label => 'requests', value => 'requests_absolute', template => '%s', + min => 0, label_extra_instance => 1 }, + ], + } + }, + ]; +} + +sub prefix_container_output { + my ($self, %options) = @_; + + return "Container '" . $options{instance_value}->{display} . "' : "; +} sub new { my ($class, %options) = @_; - my $self = $class->SUPER::new(package => __PACKAGE__, %options); + my $self = $class->SUPER::new(package => __PACKAGE__, %options, statefile => 1); bless $self, $class; $self->{version} = '1.0'; @@ -37,18 +77,24 @@ sub new { return $self; } -sub check_options { +sub manage_selection { my ($self, %options) = @_; - $self->SUPER::init(%options); -} -sub run { - my ($self, %options) = @_; - $self->{connector} = $options{custom}; + $self->{global} = { requests => 0 }; + $self->{container} = {}; + my $response = $options{custom}->execute(params => $self->{option_results}, + command => 'stats'); - $self->{connector}->add_params(params => $self->{option_results}, - command => 'stats'); - $self->{connector}->run(); + foreach my $container_name (keys %{$response->{data}}) { + $self->{container}->{$container_name} = { + display => $container_name, + requests => $response->{data}->{$container_name}->{requests} + }; + $self->{global}->{requests} += $response->{data}->{$container_name}->{requests}; + } + + $self->{cache_name} = "cache_vmware_" . $options{custom}->get_id() . '_' . $self->{mode} . '_' . + (defined($self->{option_results}->{filter_counters}) ? md5_hex($self->{option_results}->{filter_counters}) : md5_hex('all')); } 1; @@ -61,6 +107,16 @@ Get number of requests for each connectors (information from daemon. Not VMWare) =over 8 +=item B<--warning-*> + +Threshold warning. +Can be: 'total-requests', 'requests'. + +=item B<--critical-*> + +Threshold critical. +Can be: 'total-requests', 'requests'. + =back =cut diff --git a/apps/vmware/connector/mode/statushost.pm b/apps/vmware/connector/mode/statushost.pm index e8ec5b782..f891665d4 100644 --- a/apps/vmware/connector/mode/statushost.pm +++ b/apps/vmware/connector/mode/statushost.pm @@ -20,10 +20,72 @@ package apps::vmware::connector::mode::statushost; -use base qw(centreon::plugins::mode); +use base qw(centreon::plugins::templates::counter); use strict; use warnings; +use centreon::plugins::templates::catalog_functions qw(catalog_status_threshold); + +sub custom_status_output { + my ($self, %options) = @_; + + my $msg = 'status ' . $self->{result_values}->{status}; + return $msg; +} + +sub custom_status_calc { + my ($self, %options) = @_; + + $self->{result_values}->{status} = $options{new_datas}->{$self->{instance} . '_state'}; + return 0; +} + +sub custom_overall_output { + my ($self, %options) = @_; + + my $msg = 'overall status is ' . $self->{result_values}->{overall_status}; + return $msg; +} + +sub custom_overall_calc { + my ($self, %options) = @_; + + $self->{result_values}->{overall_status} = $options{new_datas}->{$self->{instance} . '_overall_status'}; + return 0; +} + +sub set_counters { + my ($self, %options) = @_; + + $self->{maps_counters_type} = [ + { name => 'host', type => 1, cb_prefix_output => 'prefix_host_output', message_multiple => 'All ESX Hosts are ok' }, + ]; + + $self->{maps_counters}->{host} = [ + { label => 'status', threshold => 0, set => { + key_values => [ { name => 'state' } ], + closure_custom_calc => $self->can('custom_status_calc'), + closure_custom_output => $self->can('custom_status_output'), + closure_custom_perfdata => sub { return 0; }, + closure_custom_threshold_check => \&catalog_status_threshold, + } + }, + { label => 'overall-status', threshold => 0, set => { + key_values => [ { name => 'overall_status' } ], + closure_custom_calc => $self->can('custom_overall_calc'), + closure_custom_output => $self->can('custom_overall_output'), + closure_custom_perfdata => sub { return 0; }, + closure_custom_threshold_check => \&catalog_status_threshold, + } + }, + ]; +} + +sub prefix_host_output { + my ($self, %options) = @_; + + return "Host '" . $options{instance_value}->{display} . "' : "; +} sub new { my ($class, %options) = @_; @@ -31,34 +93,45 @@ sub new { bless $self, $class; $self->{version} = '1.0'; - $options{options}->add_options(arguments => - { - "esx-hostname:s" => { name => 'esx_hostname' }, - "filter" => { name => 'filter' }, - "scope-datacenter:s" => { name => 'scope_datacenter' }, - "scope-cluster:s" => { name => 'scope_cluster' }, - "disconnect-status:s" => { name => 'disconnect_status', default => 'unknown' }, - }); + $options{options}->add_options(arguments => { + "esx-hostname:s" => { name => 'esx_hostname' }, + "filter" => { name => 'filter' }, + "scope-datacenter:s" => { name => 'scope_datacenter' }, + "scope-cluster:s" => { name => 'scope_cluster' }, + "unknown-status:s" => { name => 'unknown_status', default => '%{status} !~ /^connected$/i' }, + "warning-status:s" => { name => 'warning_status', default => '' }, + "critical-status:s" => { name => 'critical_status', default => '' }, + "unknown-overall-status:s" => { name => 'unknown_overall_status', default => '%{overall_status} =~ /gray/i' }, + "warning-overall-status:s" => { name => 'warning_overall_status', default => '%{overall_status} =~ /yellow/i' }, + "critical-overall-status:s" => { name => 'critical_overall_status', default => '%{overall_status} =~ /red/i' }, + }); + return $self; } sub check_options { my ($self, %options) = @_; - $self->SUPER::init(%options); - - if ($self->{output}->is_litteral_status(status => $self->{option_results}->{disconnect_status}) == 0) { - $self->{output}->add_option_msg(short_msg => "Wrong disconnect-status status option '" . $self->{option_results}->{disconnect_status} . "'."); - $self->{output}->option_exit(); - } + $self->SUPER::check_options(%options); + + $self->change_macros(macros => ['unknown_status', 'warning_status', 'critical_status', + 'unknown_overall_status', 'warning_overall_status', 'critical_overall_status']); } -sub run { +sub manage_selection { my ($self, %options) = @_; - $self->{connector} = $options{custom}; - $self->{connector}->add_params(params => $self->{option_results}, - command => 'statushost'); - $self->{connector}->run(); + $self->{host} = {}; + my $response = $options{custom}->execute(params => $self->{option_results}, + command => 'statushost'); + + foreach my $host_id (keys %{$response->{data}}) { + my $host_name = $response->{data}->{$host_id}->{name}; + $self->{host}->{$host_name} = { + display => $host_name, + state => $response->{data}->{$host_id}->{state}, + overall_status => $response->{data}->{$host_id}->{overall_status}, + }; + } } 1; @@ -88,9 +161,35 @@ Search in following datacenter(s) (can be a regexp). Search in following cluster(s) (can be a regexp). -=item B<--disconnect-status> +=item B<--unknown-status> -Status if ESX host disconnected (default: 'unknown'). +Set warning threshold for status (Default: '%{status} !~ /^connected$/i'). +Can used special variables like: %{status} + +=item B<--warning-status> + +Set warning threshold for status (Default: ''). +Can used special variables like: %{status} + +=item B<--critical-status> + +Set critical threshold for status (Default: ''). +Can used special variables like: %{status} + +=item B<--unknown-overall-status> + +Set warning threshold for status (Default: '%{overall_status} =~ /gray/i'). +Can used special variables like: %{overall_status} + +=item B<--warning-overall-status> + +Set warning threshold for status (Default: '%{overall_status} =~ /yellow/i'). +Can used special variables like: %{overall_status} + +=item B<--critical-overall-status> + +Set critical threshold for status (Default: '%{overall_status} =~ /red/i'). +Can used special variables like: %{overall_status} =back