This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch move-logic-from-rest-extensions
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from ad1488a93f Remove welcome page from extensions service
add 8b200ae429 Extract application logic from rest interfaces
No new revisions were added by this update.
Summary of changes:
.../management/connect/AdapterAssetManagement.java | 71 +++++++++
...ider.java => AdapterDescriptionManagement.java} | 41 +++--
.../connect/AdapterWorkerRequestManagement.java | 77 ++++++++++
.../AdapterWorkerSampleDataRequestManagement.java | 25 ++--
.../HttpServerAdapterRequestManagement.java | 17 +--
.../connect/RuntimeResolvableManagement.java | 55 +++++++
.../migration/AbstractMigrationHandler.java | 67 ++-------
.../migration/AdapterMigrationHandler.java | 14 +-
.../migration/DataProcessorMigrationHandler.java | 28 ++--
.../migration/DataSinkMigrationHandler.java | 20 +--
.../monitoring/HealthCheckManagement.java | 41 +++--
.../monitoring/MonitoringManagement.java | 29 ++--
.../monitoring/ServiceMonitorManagement.java | 32 ++--
.../pe/DataProcessorPipelineElementManagement.java | 22 +--
.../pe/DataSinkPipelineElementManagement.java | 21 +--
.../DataStreamPipelineElementManagement.java} | 28 ++--
.../pe/InvocablePipelineElementManagement.java | 166 +++++++++++++++++++++
.../INotificationDataSinkMigratorTest.java | 6 +-
.../notifications/jvm/msteams/TestMSTeamsSink.java | 10 +-
.../extensions/connect/AdapterAssetResource.java | 50 +++----
.../connect/AdapterDescriptionResource.java | 46 +++---
.../extensions/connect/AdapterWorkerResource.java | 36 +----
.../connect/AdapterWorkerSampleDataResource.java | 10 +-
.../connect/HttpServerAdapterResource.java | 14 +-
.../connect/RuntimeResolvableResource.java | 31 ++--
.../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 | 19 ++-
.../pe/InvocablePipelineElementResource.java | 117 ++-------------
.../migration/MigrateExtensionsResourceTest.java | 13 +-
36 files changed, 735 insertions(+), 631 deletions(-)
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%)
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%)
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
(79%)
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
(77%)
copy
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/{connect/RuntimeResovable.java
=> pe/DataStreamPipelineElementManagement.java} (53%)
create mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/pe/InvocablePipelineElementManagement.java
