This is an automated email from the ASF dual-hosted git repository.
wiener pushed a change to branch edge-extensions
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git.
from 3ce03cd preview connect adapters from active nodes and quickfix on
pipeline element restart on edge
new 88e204d [WIP] add new node to cluster
new 366492d [WIP] minor refactoring to StreamPipesClusterManager
new a35cc50 [WIP] add skeleton for cluster resource monitoring
The 3 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:
.../Dockerfile => build-docker.sh | 18 +-
streampipes-node-controller/aarch64.Dockerfile | 8 +-
.../orchestrator/docker/utils/DockerUtils.java | 1 +
.../management/pe/InvocableElementManager.java | 3 +
.../controller/container/storage/MapDBImpl.java | 4 +
.../pipeline/AbstractPipelineExecutor.java | 8 +-
...Manager.java => StreamPipesClusterManager.java} | 10 +-
.../cluster}/AbstractClusterManager.java | 38 +----
.../cluster}/AvailableNodesFetcher.java | 2 +-
.../{ => management/cluster}/NodeSyncOptions.java | 2 +-
.../management/healthcheck/ClusterHealthCheck.java | 82 +++++++++
.../resources/ClusterResourceManager.java | 96 +++++++++++
.../org/apache/streampipes/rest/impl/Node.java | 19 +--
.../StreamPipesExternalDataProcessor.java | 3 +-
ui/src/app/configuration/configuration.module.ts | 11 +-
.../node-add-details.component.html | 177 ++++++++++++++++++++
.../node-add-details.component.scss} | 30 +++-
.../node-add-details/node-add-details.component.ts | 183 +++++++++++++++++++++
.../node-configuration.component.html | 110 ++++++++-----
.../node-configuration.component.scss | 22 ++-
.../node-configuration.component.ts | 21 ++-
.../dashboard/registry/widget-config-builder.ts | 4 +-
.../node-tag-selector.component.html | 32 ++--
.../node-tag-selector.component.scss} | 30 ++--
.../node-tag-selector.component.ts | 79 +++++++++
.../save-pipeline/save-pipeline.component.html | 24 ++-
.../save-pipeline/save-pipeline.component.ts | 77 +++++++--
ui/src/app/editor/editor.module.ts | 6 +-
28 files changed, 924 insertions(+), 176 deletions(-)
copy
archetypes/streampipes-archetype-pe-sinks-flink/src/main/resources/archetype-resources/Dockerfile
=> build-docker.sh (67%)
mode change 100644 => 100755
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/node/{NodeClusterManager.java
=> StreamPipesClusterManager.java} (93%)
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/node/{
=> management/cluster}/AbstractClusterManager.java (79%)
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/node/{
=> management/cluster}/AvailableNodesFetcher.java (97%)
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/node/{
=> management/cluster}/NodeSyncOptions.java (93%)
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/node/management/healthcheck/ClusterHealthCheck.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/node/management/resources/ClusterResourceManager.java
create mode 100644
ui/src/app/configuration/node-configuration/node-add-details/node-add-details.component.html
copy
ui/src/app/configuration/node-configuration/{node-configuration-details/node-configuration-details.component.scss
=> node-add-details/node-add-details.component.scss} (83%)
create mode 100644
ui/src/app/configuration/node-configuration/node-add-details/node-add-details.component.ts
copy
archetypes/streampipes-archetype-pe-sinks-flink/src/main/resources/archetype-resources/src/main/resources/__package__.pe.sink.__packageName__/documentation.md
=>
ui/src/app/editor/dialog/save-pipeline/node-tag-selector/node-tag-selector.component.html
(66%)
copy
ui/src/app/editor/dialog/{compatible-elements/compatible-elements.component.scss
=> save-pipeline/node-tag-selector/node-tag-selector.component.scss} (67%)
create mode 100644
ui/src/app/editor/dialog/save-pipeline/node-tag-selector/node-tag-selector.component.ts