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 5ab0c8e79f Refactor request receiver, support pipeline elements
add fbe916f57a Migrate more requests
add 43b9ea4fe9 Cleanup code
add 9ef2c53ebd Centrally provide broker topics
add 31bf35dd24 Add tests, improve package structure
No new revisions were added by this update.
Summary of changes:
...e.java => ExtensionServiceBrokerOperation.java} | 31 ++---
.../ExtensionServiceBrokerOperations.java | 102 ++++++++++++++
.../ExtensionServiceBrokerResponseEnvelope.java | 18 +++
.../transport/ExtensionServiceBrokerTopics.java | 107 ++++++++++++++-
.../ExtensionServicePipelineDetachRequest.java | 3 -
.../transport/ExtensionServiceTransportMode.java | 2 +-
.../ExtensionServiceBrokerTopicsTest.java | 87 ++++++++++++
.../ExtensionServiceTransportModeTest.java | 52 +++++++
streampipes-nats-extensions/README.md | 104 ++++++++++++++
.../extensions/ExtensionBrokerRequestReceiver.java | 130 +++++++++++++++---
.../operation/ExtensionBrokerConstants.java | 26 ++--
.../operation/ExtensionBrokerResponseFactory.java | 54 +++++++-
.../operation/ExtensionBrokerTopicParser.java | 44 ++++--
.../connect/AdapterAssetOperationHandler.java | 96 +++++++++++++
.../AdapterStateChangeOperationHandler.java | 15 ++-
.../connect/RuntimeOptionsOperationHandler.java | 115 ++++++++++++++++
.../connect/SampleDataOperationHandler.java | 104 ++++++++++++++
.../FunctionStopOperationHandler.java} | 32 +++--
.../migration/MigrationOperationHandler.java | 141 +++++++++++++++++++
.../ExtensionInstanceHealthOperationHandler.java} | 34 +++--
.../ServiceHealthOperationHandler.java} | 34 +++--
.../ServiceLoadOperationHandler.java | 6 +-
.../ContainerProvidedOptionsOperationHandler.java | 136 +++++++++++++++++++
.../operation/pe/DescriptionOperationHandler.java | 125 +++++++++++++++++
.../operation/pe/OutputSchemaOperationHandler.java | 150 +++++++++++++++++++++
.../pe/PipelineElementAssetsOperationHandler.java | 115 ++++++++++++++++
.../PipelineElementDetachOperationHandler.java | 27 ++--
.../PipelineElementInvocationOperationHandler.java | 34 ++---
.../operation/ExtensionBrokerTopicParserTest.java | 88 ++++++++++++
.../connect/AdapterAssetOperationHandlerTest.java | 129 ++++++++++++++++++
.../extensions/ExtensionServiceRequestTargets.java | 48 ++++---
.../NatsExtensionServiceRequestManager.java | 77 ++++++++++-
...ansportAwareExtensionServiceRequestManager.java | 56 ++++++++
33 files changed, 2162 insertions(+), 160 deletions(-)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/extensions/transport/{ExtensionServiceTransportMode.java
=> ExtensionServiceBrokerOperation.java} (55%)
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/extensions/transport/ExtensionServiceBrokerOperations.java
create mode 100644
streampipes-model/src/test/java/org/apache/streampipes/model/extensions/transport/ExtensionServiceBrokerTopicsTest.java
create mode 100644
streampipes-model/src/test/java/org/apache/streampipes/model/extensions/transport/ExtensionServiceTransportModeTest.java
create mode 100644 streampipes-nats-extensions/README.md
copy
streampipes-messaging-nats/src/main/java/org/apache/streampipes/messaging/nats/SpNatsProtocol.java
=>
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/ExtensionBrokerConstants.java
(59%)
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/connect/AdapterAssetOperationHandler.java
rename
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/{
=> operation/connect}/AdapterStateChangeOperationHandler.java (85%)
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/connect/RuntimeOptionsOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/connect/SampleDataOperationHandler.java
copy
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/{ServiceLoadOperationHandler.java
=> function/FunctionStopOperationHandler.java} (54%)
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/migration/MigrationOperationHandler.java
copy
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/{ServiceLoadOperationHandler.java
=> monitoring/ExtensionInstanceHealthOperationHandler.java} (50%)
copy
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/{ServiceLoadOperationHandler.java
=> monitoring/ServiceHealthOperationHandler.java} (52%)
rename
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/{
=> monitoring}/ServiceLoadOperationHandler.java (86%)
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/pe/ContainerProvidedOptionsOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/pe/DescriptionOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/pe/OutputSchemaOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/pe/PipelineElementAssetsOperationHandler.java
rename
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/{
=> pe}/PipelineElementDetachOperationHandler.java (79%)
rename
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/{
=> pe}/PipelineElementInvocationOperationHandler.java (77%)
create mode 100644
streampipes-nats-extensions/src/test/java/org/apache/streampipes/nats/extensions/operation/ExtensionBrokerTopicParserTest.java
create mode 100644
streampipes-nats-extensions/src/test/java/org/apache/streampipes/nats/extensions/operation/connect/AdapterAssetOperationHandlerTest.java
