This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch remove-supported-grounding
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 2588f8e17a Improve styling of extensions items
add c9e993ce7d refactor: Isolate core-ext HTTP requests into single
interface (#4244)
No new revisions were added by this update.
Summary of changes:
.../management/compact/AdapterGenerationSteps.java | 8 +-
.../management/compact/PersistPipelineHandler.java | 6 +-
.../management/AdapterMasterManagement.java | 38 +++-
.../management/AdapterMigrationManager.java | 27 +--
.../management/AdapterUpdateManagement.java | 19 +-
.../management/DescriptionManagement.java | 22 +-
.../management/management/GuessManagement.java | 38 ++--
.../management/WorkerAdministrationManagement.java | 8 +-
.../management/management/WorkerRestClient.java | 183 ++++++++--------
.../connect/management/util/WorkerPaths.java | 51 -----
.../management/AdapterMasterManagementTest.java | 26 ++-
.../streampipes/export/AssetLinkResolver.java | 12 +-
.../apache/streampipes/export/ExportManager.java | 12 +-
.../apache/streampipes/export/ImportManager.java | 12 +-
.../export/dataimport/PerformImportGenerator.java | 10 +-
.../export/dataimport/PreviewImportGenerator.java | 14 +-
.../export/generator/ExportPackageGenerator.java | 10 +-
.../export/resolver/AdapterResolver.java | 12 +-
.../export/resolver/PipelineResolver.java | 9 +-
.../health/monitoring/ExtensionHealthCheck.java | 19 +-
.../ExtensionInstanceAvailabilityCheck.java | 43 ++--
.../health/monitoring/PipelineHealthCheck.java | 19 +-
.../health/monitoring/ResourceProvider.java | 8 +-
.../health/monitoring/ServiceHealthCheck.java | 20 +-
.../service/ExtensionServiceExecutions.java | 86 --------
.../service/ExtensionsServiceReportExecutor.java | 39 ++--
.../streampipes/model/api/EndpointSelectable.java | 4 +
.../model/base/InvocableStreamPipesEntity.java | 9 +
.../model/connect/adapter/AdapterDescription.java | 9 +
.../svcdiscovery/SpServiceTagPrefix.java | 9 -
...r.java => ExtensionServiceOperationResult.java} | 28 ++-
...der.java => ExtensionServiceOperationType.java} | 27 ++-
.../extensions/ExtensionServiceRequestManager.java | 73 +++++++
.../extensions/ExtensionServiceRequestTarget.java | 103 +++++++++
.../extensions/ExtensionServiceRequestTargets.java | 231 +++++++++++++++++++++
.../IExtensionsServiceEndpointGenerator.java | 19 +-
.../streampipes/manager/assets/AssetFetcher.java | 33 +--
.../streampipes/manager/assets/AssetManager.java | 6 +-
.../execution/ExtensionServiceExecutions.java | 75 -------
.../HttpExtensionServiceRequestManager.java | 223 ++++++++++++++++++++
.../execution/PipelineExecutionTaskFactory.java | 11 +-
.../manager/execution/PipelineExecutor.java | 10 +-
.../ExtensionsServiceEndpointGenerator.java | 29 +--
.../http/BasePipelineElementSubmitter.java | 16 +-
.../execution/http/DetachExtensionRequest.java | 62 ++++++
.../manager/execution/http/DetachHttpRequest.java | 42 ----
.../http/DetachPipelineElementSubmitter.java | 6 +-
...ttpRequest.java => InvokeExtensionRequest.java} | 34 ++-
.../http/InvokePipelineElementSubmitter.java | 9 +-
...t.java => PipelineElementExtensionRequest.java} | 46 ++--
.../execution/task/DiscoverEndpointsTask.java | 12 +-
.../manager/extensions/ExtensionItemInstaller.java | 40 ++--
.../extensions/ExtensionsResourceUrlProvider.java | 74 -------
.../manager/function/FunctionManager.java | 33 +--
.../matching/PipelineVerificationHandlerV2.java | 8 +-
.../CustomTransformOutputSchemaGenerator.java | 49 +++--
.../matching/output/OutputSchemaFactory.java | 12 +-
.../matching/v2/pipeline/ComputeOutputStep.java | 9 +-
.../v2/pipeline/PipelineValidationSteps.java | 6 +-
.../migration/AbstractMigrationManager.java | 59 +++---
.../AdapterDescriptionMigration093Provider.java | 45 ----
.../manager/migration/MigrationUtils.java | 11 +-
.../migration/PipelineElementMigrationManager.java | 34 +--
.../pipeline/ExtensionsServiceLogExecutor.java | 73 ++++---
.../manager/pipeline/PipelineManager.java | 16 +-
.../compact/CompactPipelineManagement.java | 8 +-
.../manager/preview/PipelinePreview.java | 41 ++--
.../manager/recommender/ElementRecommender.java | 9 +-
.../remote/ContainerProvidedOptionsHandler.java | 30 +--
.../manager/setup/AutoInstallation.java | 11 +-
.../manager/setup/ExtensionsInstallationTask.java | 9 +-
.../manager/setup/InstallationConfiguration.java | 11 +-
.../setup/PipelineElementInstallationStep.java | 23 +-
.../compact/CompactPipelineTemplateManagement.java | 8 +-
.../manager/verification/TypedElementVerifier.java | 12 +-
.../verification/extractor/TypeExtractor.java | 14 +-
.../manager/verification/TypeExtractorTest.java | 15 +-
.../pe/InvocablePipelineElementResource.java | 10 +-
.../apache/streampipes/rest/ResetManagement.java | 25 ++-
.../rest/impl/AbstractMonitoringResource.java | 11 +-
.../rest/impl/AdapterMonitoringResource.java | 10 +-
.../rest/impl/CompactPipelineResource.java | 10 +-
.../rest/impl/ContainerProvidedOptions.java | 9 +-
.../streampipes/rest/impl/PipelineMonitoring.java | 12 +-
.../streampipes/rest/impl/PipelineResource.java | 16 +-
.../streampipes/rest/impl/PipelineTemplate.java | 6 +-
.../streampipes/rest/impl/ResetResource.java | 21 +-
.../rest/impl/admin/DataExportResource.java | 11 +-
.../rest/impl/admin/DataImportResource.java | 15 +-
.../impl/admin/ExtensionsInstallationResource.java | 34 ++-
.../admin/ExtensionsServiceEndpointResource.java | 13 +-
.../rest/impl/admin/MigrationResource.java | 19 +-
.../rest/impl/connect/AdapterResource.java | 18 +-
.../rest/impl/connect/CompactAdapterResource.java | 31 ++-
.../rest/impl/connect/DescriptionResource.java | 23 +-
.../rest/impl/connect/GuessResource.java | 6 +-
.../impl/connect/RuntimeResolvableResource.java | 8 +-
.../rest/impl/runtime/PipelinePreviewResource.java | 10 +-
.../core/ExtensionServiceRequestConfiguration.java | 19 +-
.../streampipes/service/core/PostStartupTask.java | 24 ++-
.../service/core/StreamPipesCoreApplication.java | 59 +++++-
.../svcdiscovery/api/ISpServiceDiscovery.java | 12 --
.../api/model/SpServiceUrlProvider.java | 12 --
.../svcdiscovery/SpServiceDiscoveryCore.java | 13 --
104 files changed, 1900 insertions(+), 1094 deletions(-)
delete mode 100644
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/util/WorkerPaths.java
delete mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/service/ExtensionServiceExecutions.java
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/{IExtensionsResourceUrlProvider.java
=> ExtensionServiceOperationResult.java} (57%)
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/{IExtensionsResourceUrlProvider.java
=> ExtensionServiceOperationType.java} (66%)
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/ExtensionServiceRequestManager.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/ExtensionServiceRequestTarget.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/ExtensionServiceRequestTargets.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/ExtensionServiceExecutions.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/HttpExtensionServiceRequestManager.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/DetachExtensionRequest.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/DetachHttpRequest.java
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/{InvokeHttpRequest.java
=> InvokeExtensionRequest.java} (54%)
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/{PipelineElementHttpRequest.java
=> PipelineElementExtensionRequest.java} (58%)
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/extensions/ExtensionsResourceUrlProvider.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/migration/AdapterDescriptionMigration093Provider.java
rename
{streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance =>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager}/pipeline/ExtensionsServiceLogExecutor.java
(69%)
copy
streampipes-service-base/src/main/java/org/apache/streampipes/service/base/StreamPipesPrometheusConfig.java
=>
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/ExtensionServiceRequestConfiguration.java
(59%)
