[incubator-eventmesh] branch storage-api updated: [ISSUE #1323] Add cloudevents classes for connector-storage module

[mi...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

mikexue pushed a commit to branch storage-api
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git


The following commit(s) were added to refs/heads/storage-api by this push:
     new da7c3656 [ISSUE #1323] Add cloudevents classes for connector-storage module
     new 1e5b9ed4 Merge pull request #1354 from githublaohu/storage-api-pull
da7c3656 is described below

commit da7c36569774f17be093be8639e1dbd6505db1bf
Author: laohu <27...@qq.com>
AuthorDate: Wed Sep 21 10:31:47 2022 +0800

    [ISSUE #1323] Add cloudevents classes for connector-storage module
---
 .../api/connector/storage/data/CloudEventInfo.java | 40 ++++++++++++++++++++++
 .../storage/data/CloudEventStateEnums.java         |  5 +++
 2 files changed, 45 insertions(+)

diff --git a/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/connector/storage/data/CloudEventInfo.java b/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/connector/storage/data/CloudEventInfo.java
new file mode 100644
index 00000000..dfa7e2c4
--- /dev/null
+++ b/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/connector/storage/data/CloudEventInfo.java
@@ -0,0 +1,40 @@
+package org.apache.eventmesh.api.connector.storage.data;
+
+import java.time.LocalDateTime;
+import java.util.Map;
+import java.util.Set;
+
+import lombok.Data;
+
+@Data
+public class CloudEventInfo {
+
+    private Long cloudEventId;
+
+    private Long id;
+
+    private String cloudEventType;
+
+    private String producerGroupName;
+
+    private LocalDateTime createTime;
+
+    private Set<String> eventTag;
+
+    private Map<String, String> eventExtensions;
+
+    private String eventData;
+
+    private String replyData;
+
+    private Map<String, String> consumeLocation;
+
+    private CloudEventStateEnums cloudEventState;
+
+    private CloudEventStateEnums replyState;
+
+    private LocalDateTime updateTime;
+
+    private LocalDateTime consumeTime;
+
+}
diff --git a/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/connector/storage/data/CloudEventStateEnums.java b/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/connector/storage/data/CloudEventStateEnums.java
new file mode 100644
index 00000000..6d0f9d38
--- /dev/null
+++ b/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/connector/storage/data/CloudEventStateEnums.java
@@ -0,0 +1,5 @@
+package org.apache.eventmesh.api.connector.storage.data;
+
+public enum CloudEventStateEnums {
+
+}


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org