This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch isolate-extensions-http-request
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 4f9834d764 Remove unused method
add b5d14bc0f6 Refactor all HTTP requests to use request manager
No new revisions were added by this update.
Summary of changes:
.../management/AdapterMasterManagement.java | 26 ++++-
.../management/AdapterMigrationManager.java | 19 ++--
.../management/DescriptionManagement.java | 16 ++-
.../management/management/GuessManagement.java | 22 ++--
.../management/management/WorkerRestClient.java | 121 +++++++++++++--------
.../connect/management/util/WorkerPaths.java | 51 ---------
.../health/monitoring/ExtensionHealthCheck.java | 10 +-
.../ExtensionInstanceAvailabilityCheck.java | 38 +++++--
.../health/monitoring/PipelineHealthCheck.java | 13 +--
.../health/monitoring/ResourceProvider.java | 8 +-
.../health/monitoring/ServiceHealthCheck.java | 14 ++-
.../pipeline/ExtensionsServiceLogExecutor.java | 10 +-
.../streampipes/model/api/EndpointSelectable.java | 4 +
.../model/base/InvocableStreamPipesEntity.java | 9 ++
.../model/connect/adapter/AdapterDescription.java | 9 ++
.../svcdiscovery/SpServiceTagPrefix.java | 9 --
.../ExtensionServiceOperationResult.java | 4 -
...der.java => ExtensionServiceOperationType.java} | 27 +++--
.../extensions/ExtensionServiceRequestManager.java | 37 ++++---
...der.java => ExtensionServiceRequestTarget.java} | 11 +-
.../IExtensionsServiceEndpointGenerator.java | 19 +---
.../param/AdapterAssetDocumentationParameters.java | 37 ++++---
.../param/AdapterAssetIconParameters.java | 28 +++--
.../extensions/param/AdapterAssetParameters.java | 28 +++--
.../param/AdapterRuntimeOptionsParameters.java | 26 +++--
.../param/AdapterSampleDataParameters.java | 25 ++---
.../extensions/param/AdapterStartParameters.java | 24 ++--
.../extensions/param/AdapterStopParameters.java | 25 ++---
.../param/ExtensionDescriptionParameters.java | 34 +++++-
.../ExtensionInstanceHealthCheckParameters.java | 25 ++---
.../param/ExtensionServiceOperationParameters.java | 17 +--
.../extensions/param/FunctionStopParameters.java | 26 ++---
.../api/extensions/param/MigrationParameters.java | 27 +++--
.../param/PipelineElementAssetParameters.java} | 30 ++---
.../param/PipelineElementDetachParameters.java | 54 +++++++++
.../param/PipelineElementInvocationParameters.java | 51 +++++++++
.../RequestContainerProvidedOptionsParameters.java | 51 +++++++++
.../param/RequestOutputSchemaParameters.java} | 30 ++---
.../param/ServiceHealthCheckParameters.java} | 26 +++--
.../streampipes/manager/assets/AssetFetcher.java | 16 ++-
.../HttpExtensionServiceRequestManager.java | 77 +++++++------
.../ExtensionsServiceEndpointGenerator.java | 29 ++---
.../http/BasePipelineElementSubmitter.java | 10 +-
...ttpRequest.java => DetachExtensionRequest.java} | 24 ++--
...ttpRequest.java => InvokeExtensionRequest.java} | 21 +++-
.../http/InvokePipelineElementSubmitter.java | 3 +-
...t.java => PipelineElementExtensionRequest.java} | 22 ++--
.../execution/task/DiscoverEndpointsTask.java | 12 +-
.../manager/extensions/ExtensionItemInstaller.java | 34 ++++--
.../extensions/ExtensionsResourceUrlProvider.java | 74 -------------
.../manager/function/FunctionManager.java | 15 ++-
.../CustomTransformOutputSchemaGenerator.java | 18 ++-
.../migration/AbstractMigrationManager.java | 47 +++++---
.../AdapterDescriptionMigration093Provider.java | 45 --------
.../manager/migration/MigrationUtils.java | 21 +++-
.../migration/PipelineElementMigrationManager.java | 23 ++--
.../manager/preview/PipelinePreview.java | 22 ++--
.../remote/ContainerProvidedOptionsHandler.java | 20 +++-
.../setup/PipelineElementInstallationStep.java | 16 ++-
.../pe/InvocablePipelineElementResource.java | 10 +-
.../impl/admin/ExtensionsInstallationResource.java | 27 +++--
.../admin/ExtensionsServiceEndpointResource.java | 13 +--
.../rest/impl/connect/DescriptionResource.java | 18 +--
.../impl/connect/RuntimeResolvableResource.java | 4 +-
.../streampipes/service/core/PostStartupTask.java | 1 +
.../service/core/StreamPipesCoreApplication.java | 1 +
.../svcdiscovery/api/ISpServiceDiscovery.java | 12 --
.../api/model/SpServiceUrlProvider.java | 12 --
.../svcdiscovery/SpServiceDiscoveryCore.java | 13 ---
69 files changed, 950 insertions(+), 751 deletions(-)
delete mode 100644
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/util/WorkerPaths.java
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/{IExtensionsResourceUrlProvider.java
=> ExtensionServiceOperationType.java} (66%)
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/{IExtensionsResourceUrlProvider.java
=> ExtensionServiceRequestTarget.java} (71%)
copy
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/ExtensionServiceRequestConfiguration.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/param/AdapterAssetDocumentationParameters.java
(54%)
copy
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/IDataLakeMeasureApi.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/param/AdapterAssetIconParameters.java
(55%)
copy
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/IDataLakeMeasureApi.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/param/AdapterAssetParameters.java
(56%)
copy
streampipes-data-explorer-export/src/main/java/org/apache/streampipes/dataexplorer/export/item/CsvItemGenerator.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/param/AdapterRuntimeOptionsParameters.java
(56%)
copy
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/IDataLakeMeasureApi.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/param/AdapterSampleDataParameters.java
(61%)
copy
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/IPipelineElementTemplateApi.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/param/AdapterStartParameters.java
(61%)
copy
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/IDataLakeMeasureApi.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/param/AdapterStopParameters.java
(61%)
copy
streampipes-extensions/streampipes-connectors-camel-azure/src/main/java/org/apache/streampipes/extensions/connectors/camel/azure/filter/AzureKameletTemplateFilter.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/param/ExtensionDescriptionParameters.java
(50%)
copy
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/IDataLakeMeasureApi.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/param/ExtensionInstanceHealthCheckParameters.java
(61%)
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/exceptions/ElementNotFoundException.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/param/ExtensionServiceOperationParameters.java
(71%)
copy
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/IDataLakeMeasureApi.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/param/FunctionStopParameters.java
(61%)
copy
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/IDataLakeMeasureApi.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/param/MigrationParameters.java
(58%)
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/{execution/http/DetachPipelineElementSubmitter.java
=> api/extensions/param/PipelineElementAssetParameters.java} (50%)
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/param/PipelineElementDetachParameters.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/param/PipelineElementInvocationParameters.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/param/RequestContainerProvidedOptionsParameters.java
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/{execution/http/DetachPipelineElementSubmitter.java
=> api/extensions/param/RequestOutputSchemaParameters.java} (50%)
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/{setup/tasks/AddFunctionStateViewTask.java
=> api/extensions/param/ServiceHealthCheckParameters.java} (57%)
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/{DetachHttpRequest.java
=> DetachExtensionRequest.java} (54%)
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/{InvokeHttpRequest.java
=> InvokeExtensionRequest.java} (63%)
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/{PipelineElementHttpRequest.java
=> PipelineElementExtensionRequest.java} (81%)
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
