Explorar o código

feat(bridges): introduce DynamoDB definition files from v4

firest %!s(int64=2) %!d(string=hai) anos
pai
achega
bfc2920a55

+ 15 - 0
lib-ee/emqx_ee_bridge/priv/dynamo/mqtt_acked.json

@@ -0,0 +1,15 @@
+{
+    "TableName": "mqtt_acked",
+    "KeySchema": [
+        { "AttributeName": "topic", "KeyType": "HASH" },
+        { "AttributeName": "clientid", "KeyType": "RANGE" }
+    ],
+    "AttributeDefinitions": [
+        { "AttributeName": "topic", "AttributeType": "S" },
+        { "AttributeName": "clientid", "AttributeType": "S" }
+    ],
+    "ProvisionedThroughput": {
+        "ReadCapacityUnits": 5,
+        "WriteCapacityUnits": 5
+    }
+}

+ 13 - 0
lib-ee/emqx_ee_bridge/priv/dynamo/mqtt_client.json

@@ -0,0 +1,13 @@
+{
+    "TableName": "mqtt_client",
+    "KeySchema": [
+        { "AttributeName": "clientid", "KeyType": "HASH" }
+    ],
+    "AttributeDefinitions": [
+        { "AttributeName": "clientid", "AttributeType": "S" }
+    ],
+    "ProvisionedThroughput": {
+        "ReadCapacityUnits": 5,
+        "WriteCapacityUnits": 5
+    }
+}

+ 13 - 0
lib-ee/emqx_ee_bridge/priv/dynamo/mqtt_clientid_msg_map.json

@@ -0,0 +1,13 @@
+{
+    "TableName": "mqtt_clientid_msg_map",
+    "KeySchema": [
+        { "AttributeName": "clientid", "KeyType": "HASH" }
+    ],
+    "AttributeDefinitions": [
+        { "AttributeName": "clientid", "AttributeType": "S" }
+    ],
+    "ProvisionedThroughput": {
+        "ReadCapacityUnits": 5,
+        "WriteCapacityUnits": 5
+    }
+}

+ 13 - 0
lib-ee/emqx_ee_bridge/priv/dynamo/mqtt_msg.json

@@ -0,0 +1,13 @@
+{
+    "TableName": "mqtt_msg",
+    "KeySchema": [
+        { "AttributeName": "id", "KeyType": "HASH" }
+    ],
+    "AttributeDefinitions": [
+        { "AttributeName": "id", "AttributeType": "S" }
+    ],
+    "ProvisionedThroughput": {
+        "ReadCapacityUnits": 5,
+        "WriteCapacityUnits": 5
+    }
+}

+ 13 - 0
lib-ee/emqx_ee_bridge/priv/dynamo/mqtt_retain.json

@@ -0,0 +1,13 @@
+{
+    "TableName": "mqtt_retain",
+    "KeySchema": [
+        { "AttributeName": "topic", "KeyType": "HASH" }
+    ],
+    "AttributeDefinitions": [
+        { "AttributeName": "topic", "AttributeType": "S" }
+    ],
+    "ProvisionedThroughput": {
+        "ReadCapacityUnits": 5,
+        "WriteCapacityUnits": 5
+    }
+}

+ 16 - 0
lib-ee/emqx_ee_bridge/priv/dynamo/mqtt_sub.json

@@ -0,0 +1,16 @@
+{
+    "TableName": "mqtt_sub",
+    "KeySchema": [
+        { "AttributeName": "clientid", "KeyType": "HASH" },
+        { "AttributeName": "topic", "KeyType": "RANGE" }
+    ],
+    "AttributeDefinitions": [
+        { "AttributeName": "clientid", "AttributeType": "S" },
+        { "AttributeName": "topic", "AttributeType": "S" }
+    ],
+    "ProvisionedThroughput": {
+        "ReadCapacityUnits": 5,
+        "WriteCapacityUnits": 5
+    }
+}
+

+ 13 - 0
lib-ee/emqx_ee_bridge/priv/dynamo/mqtt_topic_msg_map.json

@@ -0,0 +1,13 @@
+{
+    "TableName": "mqtt_topic_msg_map",
+    "KeySchema": [
+        { "AttributeName": "topic", "KeyType": "HASH" }
+    ],
+    "AttributeDefinitions": [
+        { "AttributeName": "topic", "AttributeType": "S" }
+    ],
+    "ProvisionedThroughput": {
+        "ReadCapacityUnits": 5,
+        "WriteCapacityUnits": 5
+    }
+}