fieldstat easy

2 files changed, 102 insertions, 0 deletions

diff --git a/include/fieldstat/fieldstat_easy.h b/include/fieldstat/fieldstat_easy.h
new file mode 100644
index 0000000..9a356a7
--- /dev/null
+++ b/include/fieldstat/fieldstat_easy.h
@@ -0,0 +1,94 @@
+#pragma once
+#include <stddef.h>
+#include "fieldstat.h" // for fieldstat_tag
+
+#ifdef __cplusplus
+extern "C"
+{
+#endif
+
+struct fieldstat_easy;
+
+struct fieldstat_easy *fieldstat_easy_new(int max_thread_num, const struct fieldstat_tag *tags, size_t n_tag);
+void fieldstat_easy_free(struct fieldstat_easy *fse);
+// both data of accumulated and delta will be output.
+int fieldstat_easy_enable_auto_output(struct fieldstat_easy *pthis, const char *output_path, int interval_second);
+int fieldstat_easy_register_counter(struct fieldstat_easy *fse, const char *name);
+int fieldstat_easy_register_histogram(struct fieldstat_easy *fse, const char *name, long long lowest_trackable_value, long long highest_trackable_value, int significant_figures);
+// buff is a json string of accumulated data. 
+void fieldstat_easy_output(const struct fieldstat_easy *fse, char **buff, size_t *buff_len);
+
+int fieldstat_easy_counter_incrby(struct fieldstat_easy *fse, int thread_id, int metric_id, const struct fieldstat_tag *tags, size_t n_tag, long long increment);
+int fieldstat_easy_histogram_record(struct fieldstat_easy *fse, int thread_id, int metric_id, const struct fieldstat_tag *tags, size_t n_tag, long long value);
+
+#ifdef __cplusplus
+}
+#endif
+
+
+/*
+关于输出delta：
+fs_write;
+fs_accumulate;
+fs_delta;
+
+一个在write上register的metric，同样会随merge进入accumulate，delta的metric 名字后面希望跟一个delta，但是因为它是切换过来的，而且最终要加到accumulate上，所以。。。
+delta的形成一定靠reset。
+
+输出的时候，acc 和 delta的本来分别在两个json上，但是文件里只有一个json。
+最好提供一个exportPair 的接口，由json聚合。如果输出两个json，我还要读出来再写一套，更恶心了。
+
+另外一个方法，干脆给histogram算差值，这样是不是更干净一点？从算法上讲，histogram没道理不能算差。
+然后就变成fs_write, fs_reading. 最终的输出是一个总量。
+这个方法总体很好，但是需要我在exporter上保存metric数据，依赖metric。光这一条就可以直接否了方案。
+
+这个easy自己维护一套metric呢？查询到的histogram和counter都merge，然后改名，再merge进来。。。这个改名就特别莫名其妙，输出的东西当然要输出自己来搞。
+算了，调用两遍exporter得了，然后我把一个的加到另外一个上？这样的问题是我要用cjson来解，真的不要，太恶心了。。
+
+还是搞个duo吧..?
+
+不行，因为我真的没办法保证acc 和 delta的cell一样，delta的cell是调用者来搞的， 太容易顺序错了。于是counter history 那套是必须的。
+不过传入delta而不是由exporter保留，这部分还是对的。如果还是想要这个history，那么exporter就还得是有状态的，不然总不能每次都拿delta重建一份。（感觉就重建一份吧）
+算了，果然只能这样了。。
+
+那么干脆每次都新来一个acc呢？我记录acc，合成acc，delta咋办？也不对。
+得得得得，算delta这个逃不掉了。
+
+提供一个fieldstat减法怎么样？首先hll不支持减。另外我不希望动fs4的接口。
+
+
+ ---------------------------------- plan1 --------------------------------- 
+改动最小，性能影响最大，所有的还都得搞两份
+
+instance = new()
+register_metric(i,"A");
+intance_delt
+register_metric(i_delta, "A_delta");
+counter_incyby(instance, id, 1);
+counter_incyby(instance_delta, id, 1);
+
+
+dst = merge(instance);
+dst_delta = merge(instance_delta);
+
+merge(dst, dst_delta)
+
+
+ ---------------------------------- plan2 --------------------------------- 
+ // 最莫名其妙，而且merge 改起来容易出问题
+instance_delta = new()
+incyby
+
+instance = merge_and_add_delta(instance_delta)  // 新增接口
+
+
+---------------------------------- plan3 --------------------------------- 
+// 仅仅需要修改exporter，但是编码量比较大，选择这种。export只有一遍，而merge是每个线程一遍，还是慢export吧
+json_total = exporter_export_duo(acc, delta); // 新增接口
+
+
+ ---------------------------------- plan4 --------------------------------- 
+enable-delta()
+histogram_decode()
+histogram_substract()
+*/
\ No newline at end of file
diff --git a/include/fieldstat/fieldstat_exporter.h b/include/fieldstat/fieldstat_exporter.h
index 2eafb0e..c7fa80c 100644
--- a/include/fieldstat/fieldstat_exporter.h
+++ b/include/fieldstat/fieldstat_exporter.h
@@ -36,6 +36,14 @@ void fieldstat_json_exporter_export_array(const struct fieldstat_json_exporter *
     Outputting delta value is time-consuming.
 */
 void fieldstat_json_exporter_enable_delta(struct fieldstat_json_exporter *exporter);
+/*
+    let json exporter output delta value by the side of the original value(accumulated). Instead of let exporter record the delta value, user can provide the delta value by this function.
+    All the delta metrics are provided through argument `instance_delta`.
+    `instance` and `instance_delta` must has exactly the same configurations, including the metrics and cubes. 
+    since this function is only used by fieldstat_easy, users are not expected to use this function directly. As a result, the configuration check is not implemented.    
+    return NULL when instance has no cell records.
+*/
+char *fieldstat_json_exporter_export_with_delta(struct fieldstat_json_exporter *exporter, const struct fieldstat *instance, const struct fieldstat *instance_delta, const struct timeval *timestamp);
 
 #ifdef __cplusplus
 }