Added version number to outer layer of pserver stats data object via a new stats payload. Updated docs accordingly.

Updated hpserver to include created_at and version entries into its stats data

Author: giltirn

app/hpserver.cpp

@@ -140,6 +140,8 @@ int main (int argc, char ** argv){
     stat_sender.add_payload(new PSstatSenderGlobalAnomalyStatsPayload(&global_func_stats[0]));
     stat_sender.add_payload(new PSstatSenderGlobalCounterStatsPayload(&global_counter_stats[0]));
     stat_sender.add_payload(new PSstatSenderGlobalAnomalyMetricsPayload(&global_anom_metrics[0]));
+    stat_sender.add_payload(new PSstatSenderCreatedAtTimestampPayload); //add 'created_at' timestamp
+    stat_sender.add_payload(new PSstatSenderVersionPayload); //add 'created_at' timestamp
     stat_sender.run_stat_sender(args.ws_addr, args.stat_outputdir);
 
     //Start communicating with the AD instances

app/pserver.cpp

@@ -205,6 +205,7 @@ int main (int argc, char ** argv){
     stat_sender.add_payload(new PSstatSenderGlobalCounterStatsCombinePayload(global_counter_stats));
     stat_sender.add_payload(new PSstatSenderGlobalAnomalyMetricsCombinePayload(global_anom_metrics));
     stat_sender.add_payload(new PSstatSenderCreatedAtTimestampPayload); //add 'created_at' timestamp
+    stat_sender.add_payload(new PSstatSenderVersionPayload); //add 'created_at' timestamp
     stat_sender.run_stat_sender(args.ws_addr, args.stat_outputdir);
 
     //Register a signal handler that prevents the application from exiting on SIGTERM; instead this signal will be handled by ZeroMQ and will cause the pserver to shutdown gracefully

include/chimbuko/pserver/PSstatSender.hpp

@@ -46,6 +46,16 @@ namespace chimbuko{
     void add_json(nlohmann::json &into) const override;
   };
 
+  /**
+   * @brief A payload to insert a "version" entry into the record
+   */
+  struct PSstatSenderVersionPayload: public PSstatSenderPayloadBase{
+    /**
+     * @brief Add the version number into the 'into'
+     */
+    void add_json(nlohmann::json &into) const override;
+  };
+
 
   /**
    * @brief A class that periodically sends aggregate statistics to the visualization module via curl using a background thread

src/pserver/PSstatSender.cpp

@@ -11,6 +11,10 @@ void PSstatSenderCreatedAtTimestampPayload::add_json(nlohmann::json &into) const
         std::chrono::system_clock::now().time_since_epoch() ).count();
 }
 
+void PSstatSenderVersionPayload::add_json(nlohmann::json &into) const{
+  into["version"] = 2;
+}
+
 PSstatSender::PSstatSender(size_t send_freq) 
   : m_stat_sender(nullptr), m_stop_sender(false), m_bad(false), m_send_freq(send_freq)
 {