17 #ifndef _BackendOpenTSDB_H_ 18 #define _BackendOpenTSDB_H_ 22 #include <unordered_map> 24 #include "UObject_SK.h" 25 #include "SMInterface.h" 26 #include "SharedMemory.h" 27 #include "extensions/Extensions.h" 28 #include "UTCPStream.h" 104 const std::string& prefix =
"opentsdb" );
108 static std::shared_ptr<BackendOpenTSDB>
init_opendtsdb(
int argc,
const char*
const* argv,
110 const std::string& prefix =
"opentsdb" );
113 static void help_print(
int argc,
const char*
const* argv );
115 inline std::shared_ptr<LogAgregator> getLogAggregator()
119 inline std::shared_ptr<DebugStream> log()
134 virtual void askSensors( UniversalIO::UIOCommand cmd )
override;
138 virtual std::string getMonitInfo()
const override;
140 void init( xmlNode* cnode );
144 std::shared_ptr<SMInterface> shm;
148 const std::string name;
149 const std::string tags;
151 ParamInfo(
const std::string& _name,
const std::string& _tags ):
152 name(_name), tags(_tags) {}
155 std::string tsdbPrefix;
156 std::string tsdbTags;
157 std::unordered_map<uniset::ObjectId, ParamInfo> tsdbParams;
159 timeout_t bufSyncTime = { 5000 };
160 size_t bufSize = { 100 };
161 bool timerIsOn = {
false };
162 timeout_t reconnectTime = { 5000 };
163 std::string lastError;
168 std::deque<std::string> buf;
171 std::shared_ptr<UTCPStream> tcp;
172 std::string host = {
"localhost" };
182 #endif // _BackendOpenTSDB_H_ Definition: CallbackTimer.h:29
Definition: BackendOpenTSDB.h:99
Definition: MessageType.h:168
Definition: MessageType.h:124
Definition: BackendOpenTSDB.h:146
static std::shared_ptr< BackendOpenTSDB > init_opendtsdb(int argc, const char *const *argv, uniset::ObjectId shmID, const std::shared_ptr< SharedMemory > &ic=nullptr, const std::string &prefix="opentsdb")
Definition: BackendOpenTSDB.cc:173
Definition: MessageType.h:211
static void help_print(int argc, const char *const *argv)
Definition: BackendOpenTSDB.cc:139
Definition: UObject_SK.h:28
long ObjectId
Definition: UniSetTypes_i.idl:30