mirror of
https://github.com/Icinga/icinga2.git
synced 2025-04-08 17:05:25 +02:00
2e8c8809ea
Adds a new configuration variable in keeping with the graphite writer which defaults to false to save network bandwidth. All metrics currently supported by graphite are now available to InfluxDB. I added in some formatting functions, to handle integers and booleans as we know and control their types, and the supporting regexes in the sanity checker. Updating to InfluxDB 0.13.X started giving 400 errors due to the missing Host header in HTTP/1.1 requests. HttpRequest has been updated to auto- magically add the host and port to these requests if not explicitly stated by the client code. The exception code has been cleaned up to break out of the function early if such a condition is raised, this avoids unnecessarily executing code which will ultimately fail. fixes #11912 Signed-off-by: Gunnar Beutner <gunnar.beutner@netways.de>
74 lines
2.9 KiB
C++
74 lines
2.9 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 Checkable::Ptr& checkable, const CheckResult::Ptr& cr, double ts);
|
|
void SendMetric(const Dictionary::Ptr& tmpl, const String& label, const Dictionary::Ptr& fields, double ts);
|
|
void FlushTimeout(void);
|
|
void Flush(void);
|
|
|
|
static String FormatInteger(const int val);
|
|
static String FormatBoolean(const bool val);
|
|
|
|
static String EscapeKey(const String& str);
|
|
static String EscapeField(const String& str);
|
|
|
|
Stream::Ptr Connect(void);
|
|
};
|
|
|
|
}
|
|
|
|
#endif /* INFLUXDBWRITER_H */
|