File Coverage

blib/lib/Zabbix/Check/Supervisor.pm

Criterion	Covered	Total	%
statement	19	48	39.5
branch	0	14	0.0
condition			n/a
subroutine	6	12	50.0
pod	0	1	0.0
total	25	75	33.3

package Zabbix::Check::Supervisor;
=head1 NAME

Zabbix::Check::Supervisor - Zabbix check for Supervisor service

=head1 VERSION

version 1.11

=head1 SYNOPSIS

Zabbix check for Supervisor service

=cut
use strict;
use warnings;
use v5.10.1;
use Lazy::Utils;

use Zabbix::Check;


BEGIN
{
	require Exporter;
	our $VERSION     = '1.11';
	our @ISA         = qw(Exporter);
	our @EXPORT      = qw(_installed _running _worker_discovery _worker_status);
	our @EXPORT_OK   = qw();
}


our ($supervisorctl) = whereis('supervisorctl');
our ($supervisord) = whereis('supervisord');
our ($python) = whereis('python');


sub get_statuses
{
	return unless $supervisorctl;
	my $result = file_cache("all", 30, sub
	{
		my $result = {};
		for (`$supervisorctl status 2>/dev/null`)
		{
			chomp;
			my ($name, $status) = /^(\S+)\s+(\S+)\s*/;
			$result->{$name} = $status;
		}
		return $result;
	});
	return $result;
}

sub _installed
{
	my $result = $supervisorctl? 1: 0;
	print $result;
	return $result;
}

sub _running
{
	my $result = 2;
	if ($supervisorctl)
	{
		system "pgrep -f '$python $supervisord' >/dev/null 2>&1";
		$result = ($? == 0)? 1: 0;
	}
	print $result;
	return $result;
}

sub _worker_discovery
{
	my @items;
	my $statuses = get_statuses();
	@items = map({ name => $_}, keys %$statuses) if $statuses;
	return print_discovery(@items);
}

sub _worker_status
{
	my ($name) = map(zbx_decode($_), @ARGV);
	return "" unless $name;
	my $result = "";
	my $statuses = get_statuses();
	$result = $statuses->{$name} if defined($statuses->{$name});
	print $result;
	return $result;
}


1;
__END__