ClassFlowInfluxDBv2.h 971 B

12345678910111213141516171819202122232425262728293031323334353637383940414243
  1. #ifdef ENABLE_INFLUXDB
  2. #pragma once
  3. #ifndef CLASSFINFLUXDBv2_H
  4. #define CLASSFINFLUXDBv2_H
  5. #include "ClassFlow.h"
  6. #include "ClassFlowPostProcessing.h"
  7. #include <string>
  8. class ClassFlowInfluxDBv2 :
  9. public ClassFlow
  10. {
  11. protected:
  12. std::string uri, database;
  13. std::string dborg, dbtoken, dbfield;
  14. std::string OldValue;
  15. ClassFlowPostProcessing* flowpostprocessing;
  16. bool InfluxDBenable;
  17. void SetInitialParameter(void);
  18. void handleFieldname(string _decsep, string _value);
  19. void handleMeasurement(string _decsep, string _value);
  20. public:
  21. ClassFlowInfluxDBv2();
  22. ClassFlowInfluxDBv2(std::vector<ClassFlow*>* lfc);
  23. ClassFlowInfluxDBv2(std::vector<ClassFlow*>* lfc, ClassFlow *_prev);
  24. // string GetInfluxDBMeasurement();
  25. bool ReadParameter(FILE* pfile, string& aktparamgraph);
  26. bool doFlow(string time);
  27. string name(){return "ClassFlowInfluxDBv2";};
  28. };
  29. #endif //CLASSFINFLUXDBv2_H
  30. #endif //ENABLE_INFLUXDB