This is an automated email from the ASF dual-hosted git repository.
SvenO3 pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 9e31c30cc5 chore(deps): Bump docker actions version
add 07d9eff639 fix: Clean up adapter and pipeline lifecycle (#4719)
No new revisions were added by this update.
Summary of changes:
.../api/monitoring/SpMonitoringManager.java | 18 +--
.../connect/AdapterWorkerManagement.java | 53 +++++---
.../connect/adapter/model/EventCollector.java | 11 +-
.../adapter/model/pipeline/AdapterPipeline.java | 14 ++-
.../elements/SendToBrokerAdapterSink.java | 7 +-
...sSingleton.java => RunningAdapterInstance.java} | 7 +-
.../management/init/RunningAdapterInstances.java | 25 ++--
.../management/init/RunningInstances.java | 4 +-
.../pe/DataProcessorPipelineElementManagement.java | 4 +-
.../pe/DataSinkPipelineElementManagement.java | 4 +-
.../pe/InvocablePipelineElementManagement.java | 4 +-
.../connect/AdapterWorkerManagementTest.java | 41 +++++++
.../messaging/kafka/SpKafkaProducer.java | 28 ++---
.../http/InvokePipelineElementSubmitter.java | 2 +-
.../http/PipelineElementExtensionRequest.java | 5 +-
.../http/PipelineElementRollbackTest.java | 136 +++++++++++++++++++++
.../standalone/manager/ProtocolManager.java | 32 +++--
.../runtime/StandaloneEventProcessorRuntime.java | 57 ++++++++-
.../runtime/StandaloneEventSinkRuntime.java | 45 ++++++-
.../runtime/StandalonePipelineElementRuntime.java | 77 +++++++++++-
20 files changed, 479 insertions(+), 95 deletions(-)
copy
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/init/{IDeclarersSingleton.java
=> RunningAdapterInstance.java} (80%)
create mode 100644
streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/execution/http/PipelineElementRollbackTest.java
