This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch add-broker-communication-mode
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 6fd1881d63 Use nats transport mode by default
add 659857e1e8 Refactor request management
No new revisions were added by this update.
Summary of changes:
.../management/management/GuessManagement.java | 5 +-
.../management/management/WorkerRestClient.java | 15 +-
.../ExtensionInstanceAvailabilityCheck.java | 5 +-
.../health/monitoring/ServiceHealthCheck.java | 3 +-
.../extensions/ExtensionBrokerRequestReceiver.java | 32 +++-
.../extensions/ExtensionServiceOperationType.java | 40 -----
.../api/extensions/ExtensionServiceRequest.java | 53 ++++++
.../extensions/ExtensionServiceRequestManager.java | 49 +-----
.../extensions/ExtensionServiceRequestMethod.java | 9 +-
.../extensions/ExtensionServiceRequestTarget.java | 10 +-
.../extensions/ExtensionServiceRequestTargets.java | 42 ++---
.../api/extensions/ExtensionServiceRequests.java | 129 ++++++++++++++
.../streampipes/manager/assets/AssetFetcher.java | 3 +-
.../HttpExtensionServiceRequestManager.java | 154 +++--------------
.../execution/http/DetachExtensionRequest.java | 5 +-
.../execution/http/InvokeExtensionRequest.java | 5 +-
.../manager/extensions/ExtensionItemInstaller.java | 3 +-
.../manager/function/FunctionManager.java | 3 +-
.../CustomTransformOutputSchemaGenerator.java | 3 +-
.../migration/AbstractMigrationManager.java | 8 +-
.../pipeline/ExtensionsServiceLogExecutor.java | 3 +-
.../remote/ContainerProvidedOptionsHandler.java | 5 +-
.../service/core/StreamPipesCoreApplication.java | 3 +-
.../NatsExtensionServiceRequestManager.java | 117 ++-----------
...ansportAwareExtensionServiceRequestManager.java | 189 ++-------------------
.../StreamPipesExtensionsServiceBase.java | 9 +-
26 files changed, 341 insertions(+), 561 deletions(-)
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/ExtensionServiceOperationType.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/ExtensionServiceRequest.java
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/variable/EnvResolver.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/ExtensionServiceRequestMethod.java
(86%)
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/ExtensionServiceRequests.java
