vriska/hydra
0
0
Fork 0
forked from lix-project/hydra
Code Pull requests Activity

Merge pull request #692 from knl/emit-hostname-with-influxdb-metrics

Browse source 
Add host tag to InfluxDB metrics
This commit is contained in:
Eelco Dolstra 2020-06-10 10:57:17 +02:00 committed by GitHub
parent 6168e7fa44 01ae944c80
commit 1831866a52
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 8 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
src/lib/Hydra/Plugin/InfluxDBNotification.pm
View file

@ -3,9 +3,8 @@ package Hydra::Plugin::InfluxDBNotification;
use strict; use strict;
use parent 'Hydra::Plugin'; use parent 'Hydra::Plugin';
use HTTP::Request; use HTTP::Request;
# use JSON;
use LWP::UserAgent; use LWP::UserAgent;
# use Hydra::Helper::CatalystUtils; use Sys::Hostname::Long;
sub isEnabled { sub isEnabled {
my ($self) = @_; my ($self) = @_;
@ -67,6 +66,11 @@ sub toBuildStatusClass {
} }
} }
# Get the hostname. If we can't, we swallow the exception from hostname.
my $hostname = eval {
hostname_long;
};
# Syntax # Syntax
# build_status,job=my-job status=failed,result=dependency-failed duration=123i # build_status,job=my-job status=failed,result=dependency-failed duration=123i
# | -------------------- -------------- | # | -------------------- -------------- |
@ -81,6 +85,8 @@ sub createLine {
foreach my $tag (sort keys %$tagSet) { foreach my $tag (sort keys %$tagSet) {
push @tags, "$tag=$tagSet->{$tag}"; push @tags, "$tag=$tagSet->{$tag}";
} }
# we add host tag to all outputs
push @tags, "host=$hostname" if defined $hostname;
my @fields = (); my @fields = ();
foreach my $field (sort keys %$fieldSet) { foreach my $field (sort keys %$fieldSet) {
push @fields, "$field=$fieldSet->{$field}"; push @fields, "$field=$fieldSet->{$field}";