You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by wi...@apache.org on 2021/05/12 07:07:20 UTC
[incubator-streampipes] 02/03: Merge remote-tracking branch
'refs/remotes/origin/edge-extensions' into edge-extensions
This is an automated email from the ASF dual-hosted git repository.
wiener pushed a commit to branch edge-extensions
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git
commit dd25a9c29800ce5646a40e4a5ebf04e624aa2b2c
Merge: bdfecf0 589dec6
Author: Patrick Wiener <wi...@fzi.de>
AuthorDate: Mon May 10 23:28:18 2021 +0200
Merge remote-tracking branch 'refs/remotes/origin/edge-extensions' into edge-extensions
.../backend/StreamPipesBackendApplication.java | 1 -
.../extensions/ExtensionsModelSubmitter.java | 24 +++--
.../standalone/init/StandaloneModelSubmitter.java | 25 +++--
.../model/node/InvocableRegistration.java | 15 +--
.../container/util/NodeControllerUtil.java | 15 +--
.../model/base/InvocableStreamPipesEntity.java | 22 +++++
.../model/message/NotificationType.java | 1 +
.../streampipes/model/pipeline/Pipeline.java | 4 +
.../offloading/OffloadingPolicyManager.java | 100 ++++++++++++++++++++
.../offloading/model/OffloadingStrategy.java | 68 ++++++++++++++
.../model/OffloadingStrategyFactory.java | 60 ++++++++++++
.../{ => model}/policies/Comparator.java | 2 +-
.../{ => model}/policies/OffloadingPolicy.java | 2 +-
.../ThresholdViolationOffloadingPolicy.java} | 22 +++--
.../property/CPULoadResourceProperty.java} | 16 +++-
.../property/FreeDiskSpaceResourceProperty.java} | 14 ++-
.../property/FreeMemoryResourceProperty.java} | 13 ++-
.../property/ResourceProperty.java} | 12 ++-
.../selection/CPULoadSelectionStrategy.java} | 17 +++-
.../model/selection/PrioritySelectionStrategy.java | 69 ++++++++++++++
.../selection/RandomSelectionStrategy.java} | 20 ++--
.../selection/SelectionStrategy.java} | 10 +-
.../management/pe/InvocableElementManager.java | 31 ++++---
.../management/resource/ResourceManager.java | 24 ++---
.../management/resource/utils/FileSystemType.java | 3 +-
.../management/resource/utils/ResourceChecker.java | 82 +++++++++++++++++
.../management/resource/utils/ResourceUtils.java | 2 +
.../monitor/resource/ClusterResourceMonitor.java | 20 ++++
.../migration/MigrationPipelineGenerator.java | 102 +++++++++++++++++----
.../migration/PipelineElementOffloadHandler.java | 5 +-
ui/src/app/core-model/gen/streampipes-model.ts | 12 ++-
.../save-pipeline/save-pipeline.component.ts | 11 +++
32 files changed, 688 insertions(+), 136 deletions(-)