MS-375 Add Dump implementation for Event

Former-commit-id: 20e570af1fb681f848a6fa49449e53f4fb777f34

cpp/CHANGELOG.md

@@ -26,6 +26,7 @@ Please mark all change in change log and use the ticket from JIRA.
 - MS-371 - Add TaskTableUpdatedEvent
 - MS-373 - Add resource test
 - MS-374 - Add action definition
+- MS-375 - Add Dump implementation for Event
 
 ## New Feature
 - MS-343 - Implement ResourceMgr

cpp/src/scheduler/event/CopyCompletedEvent.h

@@ -18,6 +18,14 @@ public:
     CopyCompletedEvent(std::weak_ptr<Resource> resource, TaskTableItemPtr task_table_item)
         : Event(EventType::COPY_COMPLETED, std::move(resource)),
           task_table_item_(std::move(task_table_item)) {}
+
+    inline std::string
+    Dump() const override {
+        return "<CopyCompletedEvent>";
+    }
+
+    friend std::ostream &operator<<(std::ostream &out, const CopyCompletedEvent &event);
+
 public:
     TaskTableItemPtr task_table_item_;
 };

cpp/src/scheduler/event/Event.h

@@ -5,6 +5,8 @@
  ******************************************************************************/
 #pragma once
 
+#include <memory>
+
 namespace zilliz {
 namespace milvus {
 namespace engine {
@@ -30,6 +32,13 @@ public:
         return type_;
     }
 
+    inline virtual std::string
+    Dump() const {
+        return "<Event>";
+    }
+
+    friend std::ostream &operator<<(std::ostream &out, const Event &event);
+
 public:
     EventType type_;
     std::weak_ptr<Resource> resource_;

cpp/src/scheduler/event/EventDump.cpp

+/*******************************************************************************
+ * Copyright 上海赜睿信息科技有限公司(Zilliz) - All Rights Reserved
+ * Unauthorized copying of this file, via any medium is strictly prohibited.
+ * Proprietary and confidential.
+ ******************************************************************************/
+
+#include "Event.h"
+#include "StartUpEvent.h"
+#include "CopyCompletedEvent.h"
+#include "FinishTaskEvent.h"
+#include "TaskTableUpdatedEvent.h"
+
+
+namespace zilliz {
+namespace milvus {
+namespace engine {
+
+std::ostream &operator<<(std::ostream &out, const Event &event) {
+    out << event.Dump();
+    return out;
+}
+
+std::ostream &operator<<(std::ostream &out, const StartUpEvent &event) {
+    out << event.Dump();
+    return out;
+}
+
+std::ostream &operator<<(std::ostream &out, const CopyCompletedEvent &event) {
+    out << event.Dump();
+    return out;
+}
+
+std::ostream &operator<<(std::ostream &out, const FinishTaskEvent &event) {
+    out << event.Dump();
+    return out;
+}
+
+std::ostream &operator<<(std::ostream &out, const TaskTableUpdatedEvent &event) {
+    out << event.Dump();
+    return out;
+}
+
+}
+}
+}

cpp/src/scheduler/event/FinishTaskEvent.h

@@ -18,6 +18,13 @@ public:
         : Event(EventType::FINISH_TASK, std::move(resource)),
           task_table_item_(std::move(task_table_item)) {}
 
+    inline std::string
+    Dump() const override {
+        return "<FinishTaskEvent>";
+    }
+
+    friend std::ostream &operator<<(std::ostream &out, const FinishTaskEvent &event);
+
 public:
     TaskTableItemPtr task_table_item_;
 };

cpp/src/scheduler/event/StartUpEvent.h

@@ -17,6 +17,13 @@ public:
     explicit
     StartUpEvent(std::weak_ptr<Resource> resource)
         : Event(EventType::START_UP, std::move(resource)) {}
+
+    inline std::string
+    Dump() const override {
+        return "<StartUpEvent>";
+    }
+
+    friend std::ostream &operator<<(std::ostream &out, const StartUpEvent &event);
 };
 
 }

cpp/src/scheduler/event/TaskTableUpdatedEvent.h

@@ -17,6 +17,13 @@ public:
     explicit
     TaskTableUpdatedEvent(std::weak_ptr<Resource> resource)
         : Event(EventType::TASK_TABLE_UPDATED, std::move(resource)) {}
+
+    inline std::string
+    Dump() const override {
+        return "<TaskTableUpdatedEvent>";
+    }
+
+    friend std::ostream &operator<<(std::ostream &out, const TaskTableUpdatedEvent &event);
 };