Skip to content

Commit

Permalink
feat: Cleanup Stream events
Browse files Browse the repository at this point in the history
  • Loading branch information
@jachym-tousek-keboola
jachym-tousek-keboola committed Nov 6, 2024
1 parent f8241be commit 93dfe1c
Show file tree
Hide file tree
Showing 16 changed files with 24 additions and 368 deletions.
65 changes: 2 additions & 63 deletions schema/ext.keboola.stream.fileImport.json
View file
Original file line number Diff line number Diff line change
Expand Up @@ -22,44 +22,6 @@
},
"sinkId": {
"type": "string"
},
"statistics": {
"type": "object",
"properties": {
"firstRecordAt": {
"type": "string"
},
"lastRecordAt": {
"type": "string"
},
"recordsCount": {
"type": "integer"
},
"slicesCount": {
"type": "integer"
},
"uncompressedSize": {
"type": "integer"
},
"compressedSize": {
"type": "integer"
},
"stagingSize": {
"type": "integer"
}
},
"required": [
"firstRecordAt",
"lastRecordAt",
"recordsCount",
"slicesCount",
"uncompressedSize",
"compressedSize",
"stagingSize"
]
},
"error": {
"type": "string"
}
},
"required": [
Expand All @@ -73,21 +35,6 @@
"results": {
"type": "object",
"properties": {
"projectId": {
"type": "integer"
},
"branchId": {
"type": "integer"
},
"sourceId": {
"type": "string"
},
"streamId": {
"type": "string"
},
"sinkId": {
"type": "string"
},
"statistics": {
"type": "object",
"properties": {
Expand Down Expand Up @@ -126,19 +73,11 @@
"error": {
"type": "string"
}
},
"required": [
"projectId",
"branchId",
"sourceId",
"streamId",
"sinkId"
]
}
}
},
"required": [
"message",
"params",
"results"
"params"
]
}
65 changes: 2 additions & 63 deletions schema/ext.keboola.stream.sliceUpload.json
View file
Original file line number Diff line number Diff line change
Expand Up @@ -22,44 +22,6 @@
},
"sinkId": {
"type": "string"
},
"statistics": {
"type": "object",
"properties": {
"firstRecordAt": {
"type": "string"
},
"lastRecordAt": {
"type": "string"
},
"recordsCount": {
"type": "integer"
},
"slicesCount": {
"type": "integer"
},
"uncompressedSize": {
"type": "integer"
},
"compressedSize": {
"type": "integer"
},
"stagingSize": {
"type": "integer"
}
},
"required": [
"firstRecordAt",
"lastRecordAt",
"recordsCount",
"slicesCount",
"uncompressedSize",
"compressedSize",
"stagingSize"
]
},
"error": {
"type": "string"
}
},
"required": [
Expand All @@ -73,21 +35,6 @@
"results": {
"type": "object",
"properties": {
"projectId": {
"type": "integer"
},
"branchId": {
"type": "integer"
},
"sourceId": {
"type": "string"
},
"streamId": {
"type": "string"
},
"sinkId": {
"type": "string"
},
"statistics": {
"type": "object",
"properties": {
Expand Down Expand Up @@ -126,19 +73,11 @@
"error": {
"type": "string"
}
},
"required": [
"projectId",
"branchId",
"sourceId",
"streamId",
"sinkId"
]
}
}
},
"required": [
"message",
"params",
"results"
"params"
]
}
30 changes: 2 additions & 28 deletions schema/ext.keboola.stream.sourceCreate.json
View file
Original file line number Diff line number Diff line change
Expand Up @@ -22,9 +22,6 @@
},
"sourceName": {
"type": "string"
},
"error": {
"type": "string"
}
},
"required": [
Expand All @@ -38,37 +35,14 @@
"results": {
"type": "object",
"properties": {
"projectId": {
"type": "integer"
},
"branchId": {
"type": "integer"
},
"sourceId": {
"type": "string"
},
"streamId": {
"type": "string"
},
"sourceName": {
"type": "string"
},
"error": {
"type": "string"
}
},
"required": [
"projectId",
"branchId",
"sourceId",
"streamId",
"sourceName"
]
}
}
},
"required": [
"message",
"params",
"results"
"params"
]
}
30 changes: 2 additions & 28 deletions schema/ext.keboola.stream.sourceDelete.json
View file
Original file line number Diff line number Diff line change
Expand Up @@ -22,9 +22,6 @@
},
"sourceName": {
"type": "string"
},
"error": {
"type": "string"
}
},
"required": [
Expand All @@ -38,37 +35,14 @@
"results": {
"type": "object",
"properties": {
"projectId": {
"type": "integer"
},
"branchId": {
"type": "integer"
},
"sourceId": {
"type": "string"
},
"streamId": {
"type": "string"
},
"sourceName": {
"type": "string"
},
"error": {
"type": "string"
}
},
"required": [
"projectId",
"branchId",
"sourceId",
"streamId",
"sourceName"
]
}
}
},
"required": [
"message",
"params",
"results"
"params"
]
}
30 changes: 2 additions & 28 deletions schema/ext.keboola.stream.sourceDisable.json
View file
Original file line number Diff line number Diff line change
Expand Up @@ -22,9 +22,6 @@
},
"sourceName": {
"type": "string"
},
"error": {
"type": "string"
}
},
"required": [
Expand All @@ -38,37 +35,14 @@
"results": {
"type": "object",
"properties": {
"projectId": {
"type": "integer"
},
"branchId": {
"type": "integer"
},
"sourceId": {
"type": "string"
},
"streamId": {
"type": "string"
},
"sourceName": {
"type": "string"
},
"error": {
"type": "string"
}
},
"required": [
"projectId",
"branchId",
"sourceId",
"streamId",
"sourceName"
]
}
}
},
"required": [
"message",
"params",
"results"
"params"
]
}
30 changes: 2 additions & 28 deletions schema/ext.keboola.stream.sourceEnable.json
View file
Original file line number Diff line number Diff line change
Expand Up @@ -22,9 +22,6 @@
},
"sourceName": {
"type": "string"
},
"error": {
"type": "string"
}
},
"required": [
Expand All @@ -38,37 +35,14 @@
"results": {
"type": "object",
"properties": {
"projectId": {
"type": "integer"
},
"branchId": {
"type": "integer"
},
"sourceId": {
"type": "string"
},
"streamId": {
"type": "string"
},
"sourceName": {
"type": "string"
},
"error": {
"type": "string"
}
},
"required": [
"projectId",
"branchId",
"sourceId",
"streamId",
"sourceName"
]
}
}
},
"required": [
"message",
"params",
"results"
"params"
]
}
Loading

0 comments on commit 93dfe1c

Please sign in to comment.