forked from lix-project/hydra
job: create a prometheus endpoint
Export the most recent stop time and exit status in a prometheus-friendly format.
This commit is contained in:
parent
20dd0bbe6a
commit
d5445bfc1d
|
@ -6,7 +6,7 @@ use warnings;
|
||||||
use base 'Hydra::Base::Controller::ListBuilds';
|
use base 'Hydra::Base::Controller::ListBuilds';
|
||||||
use Hydra::Helper::Nix;
|
use Hydra::Helper::Nix;
|
||||||
use Hydra::Helper::CatalystUtils;
|
use Hydra::Helper::CatalystUtils;
|
||||||
|
use Net::Prometheus;
|
||||||
|
|
||||||
sub job : Chained('/') PathPart('job') CaptureArgs(3) {
|
sub job : Chained('/') PathPart('job') CaptureArgs(3) {
|
||||||
my ($self, $c, $projectName, $jobsetName, $jobName) = @_;
|
my ($self, $c, $projectName, $jobsetName, $jobName) = @_;
|
||||||
|
@ -29,6 +29,41 @@ sub job : Chained('/') PathPart('job') CaptureArgs(3) {
|
||||||
$c->stash->{project} = $c->stash->{job}->project;
|
$c->stash->{project} = $c->stash->{job}->project;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
sub prometheus : Chained('job') PathPart('prometheus') Args(0) {
|
||||||
|
my ($self, $c) = @_;
|
||||||
|
my $job = $c->stash->{job};
|
||||||
|
my $prometheus = Net::Prometheus->new;
|
||||||
|
|
||||||
|
my $lastBuild = $job->builds->find(
|
||||||
|
{ finished => 1 },
|
||||||
|
{ order_by => 'id DESC', rows => 1, columns => [@buildListColumns] }
|
||||||
|
);
|
||||||
|
|
||||||
|
$prometheus->new_counter(
|
||||||
|
name => "hydra_job_completion_time",
|
||||||
|
help => "The most recent job's completion time",
|
||||||
|
labels => [ "project", "jobset", "job", "nixname" ]
|
||||||
|
)->labels(
|
||||||
|
$c->stash->{project}->name,
|
||||||
|
$c->stash->{jobset}->name,
|
||||||
|
$c->stash->{job}->name,
|
||||||
|
$lastBuild->nixname,
|
||||||
|
)->inc($lastBuild->stoptime);
|
||||||
|
|
||||||
|
$prometheus->new_gauge(
|
||||||
|
name => "hydra_job_failed",
|
||||||
|
help => "Record if the most recent version of this job failed (1 means failed)",
|
||||||
|
labels => [ "project", "jobset", "job", "nixname" ]
|
||||||
|
)->labels(
|
||||||
|
$c->stash->{project}->name,
|
||||||
|
$c->stash->{jobset}->name,
|
||||||
|
$c->stash->{job}->name,
|
||||||
|
$lastBuild->nixname,
|
||||||
|
)->inc($lastBuild->stoptime >= 0);
|
||||||
|
|
||||||
|
$c->stash->{'plain'} = { data => $prometheus->render };
|
||||||
|
$c->forward('Hydra::View::Plain');
|
||||||
|
}
|
||||||
|
|
||||||
sub overview : Chained('job') PathPart('') Args(0) {
|
sub overview : Chained('job') PathPart('') Args(0) {
|
||||||
my ($self, $c) = @_;
|
my ($self, $c) = @_;
|
||||||
|
|
Loading…
Reference in a new issue