This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch STREAMPIPES-319
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git.
from 8e6ddcf [STREAMPIPES-319] Add class to provide service tags
add 9ca4b29 [hotfix] Remove wso2 maven repo from pom
add ec5f27c [STREAMPIPES-360] Improve adapter management
add eedcf48 [hotfix] Avoid selection of internally managed adapters in
installation overview
add d04a5b7 [STREAMPIPES-74] Initiate multiple attempts to start
pipelines upon startup
add e3a10e8 [STREAMPIPES-360] Remove obsolete tests
add 80b3ef3 [STREAMPIPES-360] Minor improvements in WorkerRestClient
add 1434f3f [STREAMPIPES-248] Fix document conflict when restarting
orphaned pipelines
add 6dde10a [STREAMPIPES-282] Remove empty path annotation
add a022ad0 [STREAMPIPES-361] Prevent running pipelines to be updated
add a14b76f [STREAMPIPES-362] Add live preview feature to pipeline editor
add 6c91340 [hotfix] Fix bug that prevented pipeline cached to be deleted
add 4f4a4ed [hotfix] Fix bug causing exception when building pipelines
with multiple elements of same type
add 3dc36f4 [STREAMPIPES-362] Disable preview button for empty pipelines
add a3021bb [STREAMPIPES-365] Fix bug in pipeline validation
add c040a5a [STREAMPIPES-368] Avoid duplication of visualizable pipelines
in dashboard
add 5fe0cf8 [STREAMPIPES-369] Improve user guidance in live dashboard
add 31cefac [STREAMPIPES-370] Improve modification of existing dashboard
widgets
add 40dbfd4 [STREAMPIPES-369] Improve reloading of widgets after updates
add 18aa6e6 [STREAMPIPES-370] Remove widget type from DashboardItem
add 3a18374 [STREAMPIPES-245] Avoid NullPointerException in production
config
add 49d4178 [hotfix] Show pipeline status in pipeline overview
add d04faac [STREAMPIPES-367] Allow forced stop of pipelines that fail to
be gracefully stopped
add 0310faf [STREAMPIPES-371] Fix wrong selection of pipelineId in start
pipeline dialog
add 62260ca [STREAMPIPES-372] Add pipeline health check and restore
feature
add 184bc66 [STREAMPIPES-374] Improve management of SecretStaticProperty
values
add 7538b9a [STREAMPIPES-373] Modify expected input stream for dashboard
sinks
add db0c2d4 [hotfix] Remove failed pipeline element invocations from
running instance map
add 5dcd9ef [hotfix] Do not change original pipeline name in save dialog
add bd07903 [STREAMPIPES-375] Persist position of pipeline elements on
pipeline canvas
add f7945db [STREAMPIPES-272] Allow client to subscribe to processors and
sinks
add 2a8a74c [hotfix] Sort visualizable pipeline by pipeline name
add 31cd40d [hotfix] Change widgetType reference in data explorer widget
add 17aacf9 [hotfix] Reduce logging frequency in WorkerRestClient
add 461e165 [STREAMPIPES-372] Fix pipeline health check
add 2869672 [hotfix] Remove logging output of health check
add 2115359 [STREAMPIPES-372] Update health status of pipelines in
notifications dialog
new 523925e Merge branch 'dev' into STREAMPIPES-319
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../backend/StreamPipesBackendApplication.java | 117 ++++++++++---
.../backend/StreamPipesResourceConfig.java | 3 +
.../streampipes/client/api/DataProcessorApi.java | 41 +++++
.../apache/streampipes/client/api/DataSinkApi.java | 28 +++
.../streampipes/client/model/InputStreamIndex.java | 19 +-
.../master/management/AdapterMasterManagement.java | 65 +++++--
.../management/WorkerAdministrationManagement.java | 4 +-
.../master/management/WorkerRestClient.java | 123 ++++---------
.../master/rest/AbstractAdapterResource.java | 17 +-
.../container/master/rest/AdapterResource.java | 93 ++++++----
.../master/rest/AdapterTemplateResource.java | 19 +-
.../container/master/rest/DescriptionResource.java | 59 +++----
.../container/master/rest/GuessResource.java | 32 ++--
.../master/rest/RuntimeResolvableResource.java | 8 +-
.../container/master/rest/SourcesResource.java | 33 ++--
.../container/master/rest/UnitResource.java | 17 +-
.../container/master/rest/WelcomePageMaster.java | 46 ++---
.../master/util/AdapterEncryptionService.java | 33 +---
.../management}/AdapterMasterManagementTest.java | 31 ++--
.../AdapterTemplateMasterManagementTest.java | 14 +-
.../management}/DescriptionManagementTest.java | 19 +-
.../master/management/SourcesManagementTest.java | 0
.../management/UnitMasterManagementTest.java | 0
.../master/management/WorkerRestClientTest.java | 35 +---
.../api/InvocablePipelineElementResource.java | 13 ++
.../container/init/RunningInstances.java | 14 ++
.../streampipes/model/canvas/CanvasPosition.java | 25 ++-
.../model/canvas/PipelineCanvasComment.java | 31 +++-
.../PipelineCanvasMetadata.java} | 64 ++++---
.../model/canvas/PipelineElementMetadata.java | 30 ++--
.../model/connect/adapter/AdapterDescription.java | 13 ++
.../connect/adapter/AdapterStreamDescription.java | 11 ++
.../model/dashboard/DashboardEntity.java | 1 -
.../streampipes/model/dashboard/DashboardItem.java | 11 +-
.../model/dashboard/DashboardWidgetModel.java | 47 +----
.../model/dashboard/VisualizablePipeline.java | 20 +--
.../streampipes/model/pipeline/Pipeline.java | 22 +++
.../model/pipeline/PipelineHealthStatus.java | 9 +-
.../PipelinePreviewModel.java} | 44 +++--
.../manager/execution/http/GraphSubmitter.java | 5 +-
.../manager/execution/http/PipelineExecutor.java | 59 +++----
.../execution/http/PipelineStorageService.java | 88 ++++------
.../health/PipelineElementEndpointHealthCheck.java | 35 ++--
.../manager/health/PipelineHealthCheck.java | 193 +++++++++++++++++++++
.../matching/PipelineVerificationHandler.java | 21 ++-
.../monitoring/pipeline/TopicInfoCollector.java | 5 +-
.../streampipes/manager/operations/Operations.java | 20 ++-
.../manager/preview/ActivePipelinePreviews.java | 63 +++++++
.../manager/preview/PipelinePreview.java | 125 +++++++++++++
.../streampipes/manager/secret/ISecretHandler.java | 7 +-
.../manager/secret/SecretDecrypter.java | 32 ++--
.../manager/secret/SecretEncrypter.java | 34 ++--
.../streampipes/manager/secret/SecretProvider.java | 18 +-
.../SecretService.java} | 43 +++--
.../streampipes/manager/secret/SecretVisitor.java | 116 +++++++++++++
.../manager/setup/CouchDbInstallationStep.java | 1 -
.../streampipes/manager/pipeline/StopPipeline.java | 33 ----
.../rest/impl/AbstractRestResource.java | 10 --
...Cache.java => PipelineCanvasMetadataCache.java} | 22 +--
.../rest/impl/PipelineCanvasMetadataResource.java | 106 +++++++++++
.../rest/impl/PipelineElementPreview.java | 64 +++++++
.../streampipes/rest/impl/PipelineResource.java | 20 ++-
.../rest/impl/dashboard/VisualizablePipeline.java | 94 ++++++----
.../impl/nouser/PipelineElementImportNoUser.java | 12 +-
.../rest/impl/nouser/PipelineNoUserResource.java | 2 +-
.../rest/management/PipelineManagement.java | 5 +-
.../serializers/json/AdapterSerializer.java | 14 +-
.../streampipes/storage/api/IAdapterStorage.java | 2 +-
.../streampipes/storage/api/INoSqlStorage.java | 8 +-
...ge.java => IPipelineCanvasMetadataStorage.java} | 14 +-
.../storage/api/IVisualizablePipelineStorage.java | 30 ----
.../storage/couchdb/CouchDbStorageManager.java | 20 ++-
.../storage/couchdb/impl/AdapterStorageImpl.java | 7 +-
...java => PipelineCanvasMetadataStorageImpl.java} | 38 ++--
.../impl/VisualizablePipelineStorageImpl.java | 43 -----
.../streampipes/storage/couchdb/utils/Utils.java | 113 +++++-------
streampipes-wrapper-siddhi/pom.xml | 17 +-
ui/src/app/add/add.component.ts | 22 ++-
.../endpoint-item/endpoint-item.component.html | 2 +-
.../adapter-description.component.html | 15 +-
.../adapter-description.component.ts | 10 --
.../data-marketplace.component.html | 62 ++++---
.../data-marketplace/data-marketplace.component.ts | 16 +-
.../existing-adapters.component.html | 126 ++++++++++++++
.../existing-adapters.component.scss} | 19 +-
.../existing-adapters.component.ts | 96 ++++++++++
ui/src/app/connect/connect.module.ts | 2 +
.../delete-adapter-dialog.component.html} | 0
.../delete-adapter-dialog.component.ts} | 20 +--
.../delete-pipeline-dialog.component.scss | 0
.../connect/services/data-marketplace.service.ts | 37 ++--
ui/src/app/core-model/gen/streampipes-model.ts | 125 ++++++++++---
.../components/grid/dashboard-grid.component.ts | 2 -
.../widget/dashboard-widget.component.css | 3 +-
.../widget/dashboard-widget.component.html | 51 +++---
.../widget/dashboard-widget.component.ts | 147 ++++++++++------
ui/src/app/dashboard/dashboard.component.ts | 9 +-
ui/src/app/dashboard/dashboard.module.ts | 4 +
.../add-visualization-dialog.component.html | 5 +-
.../add-visualization-dialog.component.ts | 66 ++++---
ui/src/app/dashboard/services/dashboard.service.ts | 19 +-
.../{resize.service.ts => edit-mode.service.ts} | 14 +-
.../services/refresh-dashboard.service.ts | 6 +-
...esize.service.ts => reload-pipeline.service.ts} | 14 +-
ui/src/app/dashboard/services/resize.service.ts | 6 +-
.../data-explorer-dashboard-widget.component.html | 8 +-
.../pipeline-assembly.component.html | 19 +-
.../pipeline-assembly.component.scss | 10 ++
.../pipeline-assembly.component.ts | 77 +++++---
.../pipeline-element-options.component.html | 7 +-
.../pipeline-element-preview.component.html} | 20 ++-
.../pipeline-element-preview.component.scss} | 27 +--
.../pipeline-element-preview.component.ts | 68 ++++++++
.../components/pipeline/pipeline.component.html | 11 +-
.../components/pipeline/pipeline.component.ts | 125 ++++++++-----
.../save-pipeline/save-pipeline.component.html | 4 +-
.../save-pipeline/save-pipeline.component.ts | 43 +++--
ui/src/app/editor/editor.component.html | 2 +-
ui/src/app/editor/editor.component.scss | 4 +-
ui/src/app/editor/editor.module.ts | 2 +
ui/src/app/editor/services/editor.service.ts | 41 ++++-
ui/src/app/editor/services/jsplumb.service.ts | 24 ++-
.../services/pipeline-positioning.service.ts | 76 ++++++--
.../actions/pipeline-actions.component.html | 3 +-
.../pipeline-overview.component.html | 19 ++
.../pipeline-overview.component.scss | 43 ++++-
.../pipeline-overview.component.ts | 7 +-
.../pipeline-notifications.component.html} | 19 +-
.../pipeline-notifications.component.scss} | 16 +-
.../pipeline-notifications.component.ts} | 48 ++---
.../pipeline-status-dialog.component.html | 65 +++++--
.../pipeline-status-dialog.component.scss | 34 +++-
.../pipeline-status-dialog.component.ts | 68 +++++++-
.../model/pipeline-model.ts} | 6 +-
ui/src/app/pipelines/pipelines.component.html | 6 +
ui/src/app/pipelines/pipelines.module.ts | 4 +-
.../services/pipeline-operations.service.ts | 77 +++++---
.../apis/pipeline-canvas-metadata.service.ts | 65 +++++++
.../app/platform-services/apis/pipeline.service.ts | 13 +-
ui/src/app/platform-services/platform.module.ts | 2 +
ui/src/scss/sp/pipeline-element-options.scss | 14 +-
141 files changed, 3176 insertions(+), 1549 deletions(-)
copy
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/model/Order.java
=>
streampipes-client/src/main/java/org/apache/streampipes/client/model/InputStreamIndex.java
(77%)
copy
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/model/Order.java
=>
streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master/rest/AbstractAdapterResource.java
(66%)
rename
streampipes-connect-container-master/src/test/java/org/{streampipes/connect/container/master
=>
apache/streampipes/connect/container/master/management}/AdapterMasterManagementTest.java
(86%)
rename streampipes-connect-container-master/src/test/java/org/{ =>
apache}/streampipes/connect/container/master/management/AdapterTemplateMasterManagementTest.java
(99%)
rename
streampipes-connect-container-master/src/test/java/org/{streampipes/connect/container/master
=>
apache/streampipes/connect/container/master/management}/DescriptionManagementTest.java
(94%)
rename streampipes-connect-container-master/src/test/java/org/{ =>
apache}/streampipes/connect/container/master/management/SourcesManagementTest.java
(100%)
rename streampipes-connect-container-master/src/test/java/org/{ =>
apache}/streampipes/connect/container/master/management/UnitMasterManagementTest.java
(100%)
rename streampipes-connect-container-master/src/test/java/org/{ =>
apache}/streampipes/connect/container/master/management/WorkerRestClientTest.java
(86%)
copy
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/QueryParams.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/canvas/CanvasPosition.java
(72%)
copy
ui/src/app/core-ui/image/components/image-container/image-container.component.css
=>
streampipes-model/src/main/java/org/apache/streampipes/model/canvas/PipelineCanvasComment.java
(65%)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/{dashboard/DashboardEntity.java
=> canvas/PipelineCanvasMetadata.java} (55%)
copy
streampipes-dataformat-fst/src/main/java/org/apache/streampipes/dataformat/fst/FstDataFormatFactory.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/canvas/PipelineElementMetadata.java
(65%)
copy
streampipes-client/src/main/java/org/apache/streampipes/client/api/SupportsPipelineApi.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/pipeline/PipelineHealthStatus.java
(87%)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/{message/SuccessMessage.java
=> preview/PipelinePreviewModel.java} (59%)
copy
streampipes-client/src/main/java/org/apache/streampipes/client/serializer/Serializer.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/health/PipelineElementEndpointHealthCheck.java
(53%)
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/health/PipelineHealthCheck.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/preview/ActivePipelinePreviews.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/preview/PipelinePreview.java
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/messaging/IMessageListener.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/secret/ISecretHandler.java
(81%)
copy
streampipes-rest/src/main/java/org/apache/streampipes/rest/notifications/NotificationListener.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/secret/SecretDecrypter.java
(54%)
copy
streampipes-rest/src/main/java/org/apache/streampipes/rest/notifications/NotificationListener.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/secret/SecretEncrypter.java
(53%)
copy
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/model/Order.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/secret/SecretProvider.java
(69%)
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/{matching/GroundingSelector.java
=> secret/SecretService.java} (51%)
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/secret/SecretVisitor.java
delete mode 100644
streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/pipeline/StopPipeline.java
copy
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/{PipelineCache.java
=> PipelineCanvasMetadataCache.java} (63%)
create mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineCanvasMetadataResource.java
create mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineElementPreview.java
copy
streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/{CRUDStorage.java
=> IPipelineCanvasMetadataStorage.java} (77%)
delete mode 100644
streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/IVisualizablePipelineStorage.java
copy
streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/{PipelineElementTemplateStorageImpl.java
=> PipelineCanvasMetadataStorageImpl.java} (50%)
delete mode 100644
streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/VisualizablePipelineStorageImpl.java
create mode 100644
ui/src/app/connect/components/data-marketplace/existing-adapters/existing-adapters.component.html
copy ui/src/app/{files/components/file-overview/file-overview.component.scss
=>
connect/components/data-marketplace/existing-adapters/existing-adapters.component.scss}
(88%)
create mode 100644
ui/src/app/connect/components/data-marketplace/existing-adapters/existing-adapters.component.ts
copy
ui/src/app/{pipelines/dialog/delete-pipeline/delete-pipeline-dialog.component.html
=> connect/dialog/delete-adapter-dialog/delete-adapter-dialog.component.html}
(100%)
copy
ui/src/app/{pipelines/dialog/delete-pipeline/delete-pipeline-dialog.component.ts
=> connect/dialog/delete-adapter-dialog/delete-adapter-dialog.component.ts}
(81%)
copy ui/src/app/{pipelines/dialog/delete-pipeline =>
connect/dialog/delete-adapter-dialog}/delete-pipeline-dialog.component.scss
(100%)
copy ui/src/app/dashboard/services/{resize.service.ts => edit-mode.service.ts}
(78%)
copy ui/src/app/dashboard/services/{resize.service.ts =>
reload-pipeline.service.ts} (78%)
copy
ui/src/app/{dashboard/components/widgets/bar-race/bar-race-widget.component.html
=>
editor/components/pipeline-element-preview/pipeline-element-preview.component.html}
(60%)
copy ui/src/app/{add/components/endpoint-item/endpoint-item.component.scss =>
editor/components/pipeline-element-preview/pipeline-element-preview.component.scss}
(75%)
create mode 100644
ui/src/app/editor/components/pipeline-element-preview/pipeline-element-preview.component.ts
copy ui/src/app/{connect/dialog/adapter-export/adapter-export-dialog.html =>
pipelines/dialog/pipeline-notifications/pipeline-notifications.component.html}
(75%)
copy
ui/src/app/pipelines/dialog/{pipeline-status/pipeline-status-dialog.component.scss
=> pipeline-notifications/pipeline-notifications.component.scss} (85%)
copy
ui/src/app/{pipeline-details/components/status/pipeline-status.component.ts =>
pipelines/dialog/pipeline-notifications/pipeline-notifications.component.ts}
(51%)
copy ui/src/app/{platform-services/contants/platform-services.constants.ts =>
pipelines/model/pipeline-model.ts} (94%)
create mode 100644
ui/src/app/platform-services/apis/pipeline-canvas-metadata.service.ts
