summaryrefslogtreecommitdiffstats
path: root/lib/db_ido/dbobject.hpp
diff options
context:
space:
mode:
authorDaniel Baumann <daniel.baumann@progress-linux.org>2024-04-13 11:32:39 +0000
committerDaniel Baumann <daniel.baumann@progress-linux.org>2024-04-13 11:32:39 +0000
commit56ae875861ab260b80a030f50c4aff9f9dc8fff0 (patch)
tree531412110fc901a5918c7f7442202804a83cada9 /lib/db_ido/dbobject.hpp
parentInitial commit. (diff)
downloadicinga2-56ae875861ab260b80a030f50c4aff9f9dc8fff0.tar.xz
icinga2-56ae875861ab260b80a030f50c4aff9f9dc8fff0.zip
Adding upstream version 2.14.2.upstream/2.14.2upstream
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'lib/db_ido/dbobject.hpp')
-rw-r--r--lib/db_ido/dbobject.hpp112
1 files changed, 112 insertions, 0 deletions
diff --git a/lib/db_ido/dbobject.hpp b/lib/db_ido/dbobject.hpp
new file mode 100644
index 0000000..399b77d
--- /dev/null
+++ b/lib/db_ido/dbobject.hpp
@@ -0,0 +1,112 @@
+/* Icinga 2 | (c) 2012 Icinga GmbH | GPLv2+ */
+
+#ifndef DBOBJECT_H
+#define DBOBJECT_H
+
+#include "db_ido/i2-db_ido.hpp"
+#include "db_ido/dbreference.hpp"
+#include "db_ido/dbquery.hpp"
+#include "db_ido/dbtype.hpp"
+#include "icinga/customvarobject.hpp"
+#include "base/configobject.hpp"
+
+namespace icinga
+{
+
+enum DbObjectUpdateType
+{
+ DbObjectCreated,
+ DbObjectRemoved
+};
+
+enum DbObjectType
+{
+ DbObjectTypeHost = 1,
+ DbObjectTypeService = 2,
+ DbObjectTypeHostGroup = 3,
+ DbObjectTypeServiceGroup = 4,
+ DbObjectTypeHostEscalation = 5,
+ DbObjectTypeServiceEscalation = 6,
+ DbObjectTypeHostDependency = 7,
+ DbObjectTypeServiceDependency = 8,
+ DbObjectTypeTimePeriod = 9,
+ DbObjectTypeContact = 10,
+ DbObjectTypeContactGroup = 11,
+ DbObjectTypeCommand = 12,
+ DbObjectTypeEndpoint = 13,
+ DbObjectTypeZone = 14,
+};
+
+/**
+ * A database object.
+ *
+ * @ingroup ido
+ */
+class DbObject : public Object
+{
+public:
+ DECLARE_PTR_TYPEDEFS(DbObject);
+
+ static void StaticInitialize();
+
+ void SetObject(const ConfigObject::Ptr& object);
+ ConfigObject::Ptr GetObject() const;
+
+ String GetName1() const;
+ String GetName2() const;
+ intrusive_ptr<DbType> GetType() const;
+
+ virtual Dictionary::Ptr GetConfigFields() const = 0;
+ virtual Dictionary::Ptr GetStatusFields() const = 0;
+
+ static DbObject::Ptr GetOrCreateByObject(const ConfigObject::Ptr& object);
+
+ struct QueryCallbacks {
+ std::function<void(const DbQuery&)> Query;
+ std::function<void(const std::vector<DbQuery>&)> MultipleQueries;
+ };
+
+ static boost::signals2::signal<void (const DbQuery&)> OnQuery;
+ static boost::signals2::signal<void (const std::vector<DbQuery>&)> OnMultipleQueries;
+ static boost::signals2::signal<void (const std::function<void (const QueryCallbacks&)>&)> OnMakeQueries;
+
+ void SendConfigUpdateHeavy(const Dictionary::Ptr& configFields);
+ void SendConfigUpdateLight();
+ void SendStatusUpdate();
+ void SendVarsConfigUpdateHeavy();
+ void SendVarsStatusUpdate();
+
+ double GetLastConfigUpdate() const;
+ double GetLastStatusUpdate() const;
+
+ virtual String CalculateConfigHash(const Dictionary::Ptr& configFields) const;
+
+protected:
+ DbObject(intrusive_ptr<DbType> type, String name1, String name2);
+
+ virtual void OnConfigUpdateHeavy();
+ virtual void OnConfigUpdateLight();
+ virtual void OnStatusUpdate();
+
+ static String HashValue(const Value& value);
+
+private:
+ String m_Name1;
+ String m_Name2;
+ intrusive_ptr<DbType> m_Type;
+ ConfigObject::Ptr m_Object;
+ double m_LastConfigUpdate;
+ double m_LastStatusUpdate;
+
+ static void StateChangedHandler(const ConfigObject::Ptr& object);
+ static void VarsChangedHandler(const CustomVarObject::Ptr& object);
+ static void VersionChangedHandler(const ConfigObject::Ptr& object);
+
+ static std::mutex& GetStaticMutex();
+
+ friend class DbType;
+};
+
+}
+
+#endif /* DBOBJECT_H */