Merge pull request #14 from keyko-io/feature/flat-event-record

Add flat event record until the fix in the kafka connector
keyko-io · Apr 6, 2020 · 45f8004 · 45f8004
2 parents 662367d + 89e655c
commit 45f8004
Show file tree

Hide file tree

Showing 3 changed files with 212 additions and 2 deletions.
diff --git a/README.md b/README.md
@@ -41,6 +41,7 @@ The AVRO implementation of the schemas can be found in the **src/main/resources/
 * BlockRecord.avsc	
 * EventBlockRecord.avsc	
 * EventRecord.avsc	
+* FlatEventRecord.avsc	
 * LogRecord.avsc
 * LogRecordTopicsFlattened.avsc
 * NumberParameter.avsc	

diff --git a/pom.xml b/pom.xml
@@ -7,7 +7,7 @@
     <groupId>io.keyko.monitoring</groupId>
     <artifactId>schemas</artifactId>
     <packaging>jar</packaging>
-    <version>0.3.1</version>
+    <version>0.3.2</version>
     <name>Web3 Monitoring Schemas</name>
     <url>https://github.com/keyko-io/web3-monitoring-schemas</url>
 
@@ -101,7 +101,8 @@
                             <imports>
                                 <import>${project.basedir}/src/main/resources/avro/NumberParameter.avsc</import>
                                 <import>${project.basedir}/src/main/resources/avro/StringParameter.avsc</import>
-                                <import>${project.basedir}/src/main/resources/avro/EventsRecord.avsc</import>
+                                <import>${project.basedir}/src/main/resources/avro/EventRecord.avsc</import>
+                                <import>${project.basedir}/src/main/resources/avro/FlatEventRecord.avsc</import>
                                 <import>${project.basedir}/src/main/resources/avro/ViewRecord.avsc</import>
                                 <import>${project.basedir}/src/main/resources/avro/BlockRecord.avsc</import>
                                 <import>${project.basedir}/src/main/resources/avro/LogRecordRecord.avsc</import>

diff --git a/src/main/resources/avro/FlatEventRecord.avsc b/src/main/resources/avro/FlatEventRecord.avsc
@@ -0,0 +1,208 @@
+{
+  "namespace": "io.keyko.monitoring.schemas",
+  "type": "record",
+  "name": "FlatEventRecord",
+  "fields": [
+    {
+      "name": "id",
+      "type": "string"
+    },
+    {
+      "name": "name",
+      "type": "string"
+    },
+    {
+      "name": "contractName",
+      "type": "string",
+      "default": ""
+    },
+    {
+      "name": "filterId",
+      "type": "string"
+    },
+    {
+      "name": "nodeName",
+      "type": "string"
+    },
+    {
+      "name": "indexed_param_name_0",
+      "type": "string",
+      "default": ""
+    },
+    {
+      "name": "indexed_param_type_0",
+      "type": "string",
+      "default": ""
+    },
+    {
+      "name": "indexed_param_value_0",
+      "type": "string",
+      "default": ""
+    },
+    {
+      "name": "indexed_param_name_1",
+      "type": "string",
+      "default": ""
+    },
+    {
+      "name": "indexed_param_type_1",
+      "type": "string",
+      "default": ""
+    },
+    {
+      "name": "indexed_param_value_1",
+      "type": "string",
+      "default": ""
+    },
+    {
+      "name": "indexed_param_name_2",
+      "type": "string",
+      "default": ""
+    },
+    {
+      "name": "indexed_param_type_2",
+      "type": "string",
+      "default": ""
+    },
+    {
+      "name": "indexed_param_value_2",
+      "type": "string",
+      "default": ""
+    },
+    {
+      "name": "indexed_param_name_3",
+      "type": "string",
+      "default": ""
+    },
+    {
+      "name": "indexed_param_type_3",
+      "type": "string",
+      "default": ""
+    },
+    {
+      "name": "indexed_param_value_3",
+      "type": "string",
+      "default": ""
+    },
+    {
+      "name": "non_indexed_param_name_0",
+      "type": "string",
+      "default": ""
+    },
+    {
+      "name": "non_indexed_param_type_0",
+      "type": "string",
+      "default": ""
+    },
+    {
+      "name": "non_indexed_param_value_0",
+      "type": "string",
+      "default": ""
+    },
+    {
+      "name": "non_indexed_param_name_1",
+      "type": "string",
+      "default": ""
+    },
+    {
+      "name": "non_indexed_param_type_1",
+      "type": "string",
+      "default": ""
+    },
+    {
+      "name": "non_indexed_param_value_1",
+      "type": "string",
+      "default": ""
+    },
+    {
+      "name": "non_indexed_param_name_2",
+      "type": "string",
+      "default": ""
+    },
+    {
+      "name": "non_indexed_param_type_2",
+      "type": "string",
+      "default": ""
+    },
+    {
+      "name": "non_indexed_param_value_2",
+      "type": "string",
+      "default": ""
+    },
+    {
+      "name": "non_indexed_param_name_3",
+      "type": "string",
+      "default": ""
+    },
+    {
+      "name": "non_indexed_param_type_3",
+      "type": "string",
+      "default": ""
+    },
+    {
+      "name": "non_indexed_param_value_3",
+      "type": "string",
+      "default": ""
+    },
+    {
+      "name": "non_indexed_param_name_4",
+      "type": "string",
+      "default": ""
+    },
+    {
+      "name": "non_indexed_param_type_4",
+      "type": "string",
+      "default": ""
+    },
+    {
+      "name": "non_indexed_param_value_4",
+      "type": "string",
+      "default": ""
+    },
+    {
+      "name": "transactionHash",
+      "type": "string"
+    },
+    {
+      "name": "logIndex",
+      "type": "string",
+      "java-class": "java.math.BigInteger"
+    },
+    {
+      "name": "blockNumber",
+      "type": "long"
+    },
+    {
+      "name": "blockHash",
+      "type": "string"
+    },
+    {
+      "name": "address",
+      "type": "string"
+    },
+    {
+      "name": "status",
+      "type": {
+        "name": "FlatContractEventStatus",
+        "type": "enum",
+        "symbols": [
+          "UNCONFIRMED",
+          "CONFIRMED",
+          "INVALIDATED"
+        ]
+      }
+    },
+    {
+      "name": "eventSpecificationSignature",
+      "type": "string"
+    },
+    {
+      "name": "networkName",
+      "type": "string"
+    },
+    {
+      "name": "retries",
+      "type": "int"
+    }
+  ]
+}