ClassFlowInfluxDBv2.h 922 B

1234567891011121314151617181920212223242526272829303132333435363738394041
  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, measurement;
  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. public:
  20. ClassFlowInfluxDBv2();
  21. ClassFlowInfluxDBv2(std::vector<ClassFlow*>* lfc);
  22. ClassFlowInfluxDBv2(std::vector<ClassFlow*>* lfc, ClassFlow *_prev);
  23. string GetInfluxDBMeasurement();
  24. bool ReadParameter(FILE* pfile, string& aktparamgraph);
  25. bool doFlow(string time);
  26. string name(){return "ClassFlowInfluxDBv2";};
  27. };
  28. #endif //CLASSFINFLUXDBv2_H
  29. #endif //ENABLE_INFLUXDB