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 c9e993ce7d refactor: Isolate core-ext HTTP requests into single
interface (#4244)
add a88b0b44f2 refactor: Move application logic from rest-extensions to
extensions-management (#4253)
No new revisions were added by this update.
Summary of changes:
pom.xml | 6 -
.../management/ExtensionAdapterManagement.java | 4 +-
.../management/connect/AdapterAssetManagement.java | 71 +++++++++
...ider.java => AdapterDescriptionManagement.java} | 41 +++---
.../connect/AdapterWorkerRequestManagement.java | 77 ++++++++++
.../AdapterWorkerSampleDataRequestManagement.java | 25 ++--
.../connect/ConnectWorkerDescriptionProvider.java | 8 +-
.../HttpServerAdapterRequestManagement.java | 17 +--
.../connect/RuntimeResolvableManagement.java | 55 +++++++
.../management/init/DeclarersSingleton.java | 4 +-
.../migration/AbstractMigrationHandler.java | 67 +++------
.../migration/AdapterMigrationHandler.java | 14 +-
.../migration/DataProcessorMigrationHandler.java | 28 ++--
.../migration/DataSinkMigrationHandler.java | 20 +--
.../extensions/management}/model/Description.java | 2 +-
.../monitoring/HealthCheckManagement.java | 41 +++---
.../monitoring/MonitoringManagement.java | 29 ++--
.../monitoring/ServiceMonitorManagement.java | 32 ++---
.../pe/AbstractPipelineElementManagement.java | 84 +++++++++++
.../pe/DataProcessorPipelineElementManagement.java | 19 +--
.../pe/DataSinkPipelineElementManagement.java | 18 +--
.../DataStreamPipelineElementManagement.java} | 27 ++--
.../pe/InvocablePipelineElementManagement.java | 158 +++++++++++++++++++++
.../management/init/DeclarersSingletonTest.java | 6 +-
.../INotificationDataSinkMigratorTest.java | 6 +-
.../notifications/jvm/msteams/TestMSTeamsSink.java | 10 +-
streampipes-rest-extensions/pom.xml | 15 --
.../AbstractPipelineElementResource.java | 78 ++--------
.../streampipes/rest/extensions/WelcomePage.java | 72 ----------
.../extensions/connect/AdapterAssetResource.java | 62 ++++----
.../connect/AdapterDescriptionResource.java | 48 +++----
.../extensions/connect/AdapterWorkerResource.java | 36 ++---
.../connect/AdapterWorkerSampleDataResource.java | 10 +-
.../connect/HttpServerAdapterResource.java | 14 +-
.../connect/RuntimeResolvableResource.java | 31 ++--
.../rest/extensions/html/HTMLGenerator.java | 82 -----------
.../rest/extensions/html/JSONGenerator.java | 61 --------
.../extensions/html/page/WelcomePageGenerator.java | 154 --------------------
.../migration/AdapterMigrationResource.java | 28 ++--
.../migration/DataProcessorMigrationResource.java | 28 ++--
.../migration/DataSinkMigrationResource.java | 29 ++--
.../extensions/monitoring/HealthCheckResource.java | 40 ++----
.../extensions/monitoring/MonitoringResource.java | 18 ++-
.../monitoring/ServiceMonitorResource.java | 15 +-
.../pe/DataProcessorPipelineElementResource.java | 52 +------
.../pe/DataSinkPipelineElementResource.java | 50 +------
.../pe/DataStreamPipelineElementResource.java | 20 +--
.../pe/InvocablePipelineElementResource.java | 117 ++-------------
.../migration/MigrateExtensionsResourceTest.java | 13 +-
.../StreamPipesExtensionsServiceBase.java | 2 -
50 files changed, 834 insertions(+), 1110 deletions(-)
copy
streampipes-connect-transformer-api/src/main/java/org/apache/streampipes/connect/transformer/api/Context.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/ExtensionAdapterManagement.java
(89%)
create mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/AdapterAssetManagement.java
copy
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/{ConnectWorkerDescriptionProvider.java
=> AdapterDescriptionManagement.java} (56%)
create mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/AdapterWorkerRequestManagement.java
copy
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/connect/IParser.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/AdapterWorkerSampleDataRequestManagement.java
(54%)
copy
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/constants/InputStreamIndex.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/HttpServerAdapterRequestManagement.java
(71%)
create mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/RuntimeResolvableManagement.java
rename
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/migration/MigrateExtensionsResource.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/migration/AbstractMigrationHandler.java
(59%)
copy
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/migration/IAdapterMigrator.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/migration/AdapterMigrationHandler.java
(63%)
copy
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe/param/IDataProcessorParameters.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/migration/DataProcessorMigrationHandler.java
(61%)
copy
streampipes-sdk/src/main/java/org/apache/streampipes/sdk/extractor/DataSinkParameterExtractor.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/migration/DataSinkMigrationHandler.java
(63%)
rename
{streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/html
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/model/Description.java
(98%)
copy
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/monitoring/HealthCheckResource.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/monitoring/HealthCheckManagement.java
(63%)
copy
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/monitoring/MonitoringResource.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/monitoring/MonitoringManagement.java
(56%)
copy
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/containers/SpKafkaTestContainer.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/monitoring/ServiceMonitorManagement.java
(59%)
create mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/pe/AbstractPipelineElementManagement.java
copy
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/pe/DataProcessorPipelineElementResource.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/pe/DataProcessorPipelineElementManagement.java
(81%)
copy
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/pe/DataSinkPipelineElementResource.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/pe/DataSinkPipelineElementManagement.java
(79%)
copy
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/{connect/RuntimeResovable.java
=> pe/DataStreamPipelineElementManagement.java} (55%)
create mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/pe/InvocablePipelineElementManagement.java
delete mode 100644
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/WelcomePage.java
delete mode 100644
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/html/HTMLGenerator.java
delete mode 100644
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/html/JSONGenerator.java
delete mode 100644
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/html/page/WelcomePageGenerator.java
