mirror of
https://github.com/Icinga/icinga2.git
synced 2026-07-15 11:51:07 -04:00
393724bb2a
`DiagnosticInformation()` wasn't able to take a `std::exception_ptr` due to the missing conversion on older boost versions, so now everything uses the std::exception_ptr instead. There are still a few reasons to use `boost::exception` in some places, but for exception pointers, the standard one should be better in most cases and almost never requires to include an extra header.
58 lines
1.7 KiB
C++
58 lines
1.7 KiB
C++
// SPDX-FileCopyrightText: 2012 Icinga GmbH <https://icinga.com>
|
|
// SPDX-License-Identifier: GPL-2.0-or-later
|
|
|
|
#ifndef GELFWRITER_H
|
|
#define GELFWRITER_H
|
|
|
|
#include "perfdata/gelfwriter-ti.hpp"
|
|
#include "perfdata/perfdatawriterconnection.hpp"
|
|
#include "icinga/checkable.hpp"
|
|
#include "base/configobject.hpp"
|
|
#include "base/workqueue.hpp"
|
|
|
|
namespace icinga
|
|
{
|
|
|
|
/**
|
|
* An Icinga Gelf writer for Graylog.
|
|
*
|
|
* @ingroup perfdata
|
|
*/
|
|
class GelfWriter final : public ObjectImpl<GelfWriter>
|
|
{
|
|
public:
|
|
DECLARE_OBJECT(GelfWriter);
|
|
DECLARE_OBJECTNAME(GelfWriter);
|
|
|
|
static void StatsFunc(const Dictionary::Ptr& status, const Array::Ptr& perfdata);
|
|
|
|
protected:
|
|
void OnConfigLoaded() override;
|
|
void Start(bool runtimeCreated) override;
|
|
void Resume() override;
|
|
void Pause() override;
|
|
|
|
private:
|
|
PerfdataWriterConnection::Ptr m_Connection;
|
|
Locked<PerfdataWriterConnection::Ptr> m_LockedConnection;
|
|
WorkQueue m_WorkQueue{10000000, 1};
|
|
Shared<boost::asio::ssl::context>::Ptr m_SslContext;
|
|
|
|
boost::signals2::connection m_HandleCheckResults, m_HandleNotifications, m_HandleStateChanges;
|
|
|
|
void CheckResultHandler(const Checkable::Ptr& checkable, const CheckResult::Ptr& cr);
|
|
void NotificationToUserHandler(const Checkable::Ptr& checkable, NotificationType notificationType, const CheckResult::Ptr& cr,
|
|
const String& author, const String& commentText, const String& commandName);
|
|
void StateChangeHandler(const Checkable::Ptr& checkable, const CheckResult::Ptr& cr);
|
|
|
|
String ComposeGelfMessage(const Dictionary::Ptr& fields, const String& source, double ts);
|
|
void SendLogMessage(const Checkable::Ptr& checkable, const String& gelfMessage);
|
|
|
|
void AssertOnWorkQueue();
|
|
|
|
void ExceptionHandler(std::exception_ptr exp);
|
|
};
|
|
|
|
}
|
|
|
|
#endif /* GELFWRITER_H */
|