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 <[email protected]> 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(-)
