mirror of
https://github.com/Icinga/icinga2.git
synced 2025-10-12 10:59:01 +02:00
79c1e883d1
Adds an Icinga2 object to directly interface with InfluxDB's native HTTP API. This supports optional basic authorization, and TLS transport. InfluxDB didn't appear to like having the TLS stream kept open, so instead this object buffers data points which are then flushed to InfluxDB as a batch write, either driven by a configurable timeout or threshold. As InfluxDB is a schema-less database the host and service templates are user configurable allowing both the measurement field and tags to be set by the end user via macro expansion. This allows access to tag fields from arbitrary data associated with host.vars or service.vars. If a particular value is unable to be resolved, the tag will be dropped and not transmitted to InfluxDB. Also alters URL handling to omit array brackets when only a single value is attached to a key, otherwise InfluxDB has a strop with non-standard syntax. fixes #10480 Signed-off-by: Michael Friedrich <michael.friedrich@netways.de>
68 lines
2.6 KiB
C++
68 lines
2.6 KiB
C++
/******************************************************************************
|
|
* Icinga 2 *
|
|
* Copyright (C) 2012-2016 Icinga Development Team (https://www.icinga.org/) *
|
|
* *
|
|
* This program is free software; you can redistribute it and/or *
|
|
* modify it under the terms of the GNU General Public License *
|
|
* as published by the Free Software Foundation; either version 2 *
|
|
* of the License, or (at your option) any later version. *
|
|
* *
|
|
* This program is distributed in the hope that it will be useful, *
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of *
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
|
|
* GNU General Public License for more details. *
|
|
* *
|
|
* You should have received a copy of the GNU General Public License *
|
|
* along with this program; if not, write to the Free Software Foundation *
|
|
* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA. *
|
|
******************************************************************************/
|
|
|
|
#ifndef INFLUXDBWRITER_H
|
|
#define INFLUXDBWRITER_H
|
|
|
|
#include "perfdata/influxdbwriter.thpp"
|
|
#include "icinga/service.hpp"
|
|
#include "base/configobject.hpp"
|
|
#include "base/tcpsocket.hpp"
|
|
#include "base/timer.hpp"
|
|
#include <fstream>
|
|
|
|
namespace icinga
|
|
{
|
|
|
|
/**
|
|
* An Icinga InfluxDB writer.
|
|
*
|
|
* @ingroup perfdata
|
|
*/
|
|
class InfluxdbWriter : public ObjectImpl<InfluxdbWriter>
|
|
{
|
|
public:
|
|
DECLARE_OBJECT(InfluxdbWriter);
|
|
DECLARE_OBJECTNAME(InfluxdbWriter);
|
|
|
|
static void StatsFunc(const Dictionary::Ptr& status, const Array::Ptr& perfdata);
|
|
|
|
virtual void ValidateHostTemplate(const Dictionary::Ptr& value, const ValidationUtils& utils) override;
|
|
virtual void ValidateServiceTemplate(const Dictionary::Ptr& value, const ValidationUtils& utils) override;
|
|
|
|
protected:
|
|
virtual void Start(bool runtimeCreated) override;
|
|
|
|
private:
|
|
Timer::Ptr m_FlushTimer;
|
|
Array::Ptr m_DataBuffer;
|
|
|
|
void CheckResultHandler(const Checkable::Ptr& checkable, const CheckResult::Ptr& cr);
|
|
void SendPerfdata(const Dictionary::Ptr tmpl, const CheckResult::Ptr& cr, double ts);
|
|
void SendMetric(const Dictionary::Ptr tmpl, const String& label, const String& type, double value, double ts);
|
|
void FlushTimeout(void);
|
|
void Flush(void);
|
|
|
|
Stream::Ptr Connect(void);
|
|
};
|
|
|
|
}
|
|
|
|
#endif /* INFLUXDBWRITER_H */
|