add MetricsCollector

Former-commit-id: 7953c0a4374624725507b6e7578628669a245ded

cpp/src/db/insert/VectorSource.cpp

@@ -24,7 +24,7 @@ Status VectorSource::Add(const ExecutionEnginePtr &execution_engine,
                          size_t &num_vectors_added,
                          IDNumbers &vector_ids) {
 
-    server::CollectorAddMetrics metrics(n_, table_file_schema.dimension_);
+    server::CollectAddMetrics metrics(n_, table_file_schema.dimension_);
 
     num_vectors_added = current_num_vectors_added + num_vectors_to_add <= n_ ?
                         num_vectors_to_add : n_ - current_num_vectors_added;

cpp/src/metrics/Metrics.h

@@ -157,13 +157,13 @@ private:
     size_t size_;
 };
 
-class CollectorAddMetrics {
+class CollectAddMetrics {
 public:
-    CollectorAddMetrics(size_t n, uint16_t dimension) : n_(n), dimension_(dimension) {
+    CollectAddMetrics(size_t n, uint16_t dimension) : n_(n), dimension_(dimension) {
         start_time_ = METRICS_NOW_TIME;
     }
 
-    ~CollectorAddMetrics() {
+    ~CollectAddMetrics() {
         auto end_time = METRICS_NOW_TIME;
         auto total_time = METRICS_MICROSECONDS(start_time_, end_time);
         server::Metrics::GetInstance().AddVectorsPerSecondGaugeSet(static_cast<int>(n_),
@@ -177,13 +177,13 @@ private:
     uint16_t dimension_;
 };
 
-class CollectorDurationMetrics {
+class CollectDurationMetrics {
 public:
-    CollectorDurationMetrics() {
+    CollectDurationMetrics(int index_type) : index_type_(index_type) {
         start_time_ = METRICS_NOW_TIME;
     }
 
-    ~CollectorDurationMetrics() {
+    ~CollectDurationMetrics() {
         auto end_time = METRICS_NOW_TIME;
         auto total_time = METRICS_MICROSECONDS(start_time_, end_time);
         switch (index_type_) {

cpp/src/scheduler/task/SearchTask.cpp

@@ -141,7 +141,7 @@ XSearchTask::Execute() {
 
     server::TimeRecorder rc("DoSearch file id:" + std::to_string(index_id_));
 
-    server::CollectorDurationMetrics metrics(index_type_);
+    server::CollectDurationMetrics metrics(index_type_);
 
     std::vector<long> output_ids;
     std::vector<float> output_distence;

cpp/unittest/metrics/metrics_test.cpp

@@ -119,4 +119,33 @@ TEST_F(MetricTest, Metric_Tes) {
     delete [] qxb;
 };
 
+TEST_F(MetricTest, Collector_Metrics_Test){
+    engine::Status status = engine::Status::OK();
+    server::CollectInsertMetrics insert_metrics0(0, status);
+    status = engine::Status::Error("error");
+    server::CollectInsertMetrics insert_metrics1(0, status);
+
+    server::CollectQueryMetrics query_metrics(10);
+
+    server::CollectMergeFilesMetrics merge_metrics();
+
+    server::CollectBuildIndexMetrics build_index_metrics();
+
+    server::CollectExecutionEngineMetrics execution_metrics(10);
+
+    server::CollectSerializeMetrics serialize_metrics(10);
+
+    server::CollectAddMetrics add_metrics(10, 128);
+
+    server::CollectDurationMetrics duration_metrics_raw(engine::meta::TableFileSchema::RAW);
+    server::CollectDurationMetrics duration_metrics_index(engine::meta::TableFileSchema::TO_INDEX);
+    server::CollectDurationMetrics duration_metrics_delete(engine::meta::TableFileSchema::TO_DELETE);
+
+    server::CollectSearchTaskMetrics search_metrics_raw(engine::meta::TableFileSchema::RAW);
+    server::CollectSearchTaskMetrics search_metrics_index(engine::meta::TableFileSchema::TO_INDEX);
+    server::CollectSearchTaskMetrics search_metrics_delete(engine::meta::TableFileSchema::TO_DELETE);
+
+    server::MetricCollector metric_collector();
+}
+