This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a change to branch
4185-add-persistent-state-support-for-streampipe-functions
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 174ca81f39 feat(#4185): Implement function shutdown with state
persistence and introduce new response models
add e73140b658 feat(#4185): Remove unused ts model annotation
add ea3222cd5c feat(#4185): Refactor function state storage initialization
and add StorageApiConfiguration
add 50ffd49394 docs: Add AGENTS guides for various modules in the
repository (#4184)
add 1787bdb9c7 refactor(#4194): checkstyle not consistently enforced in
validate across all modules (#4195)
add ba743c6a7c Merge branch 'dev' into
4185-add-persistent-state-support-for-streampipe-functions
add ee0fa9a620 feat(#4185): remove unused cleanupFunctions method and add
spacing for clarity
add acaf5e0222 feat(#4185): Move function logic to
modulestreampipes-extensions-management
add 2b96c09812 feat(#4185): Implement FunctionManager to handle function
stop and state persistence
add f0ec2ef651 feat(#4185): Add FunctionState management with CouchDB view
integration
add c2d4258f4d feat(#4185): Add migration for FunctionState view
integration
No new revisions were added by this update.
Summary of changes:
pom.xml | 6 --
.../commons/constants/GenericDocTypes.java | 1 +
.../export/objectstorage/IObjectStorage.java | 3 +-
.../export/objectstorage/LocalFolder.java | 1 +
.../dataexplorer/export/objectstorage/S3.java | 4 +-
.../TestExportProviderConnection.java | 4 +-
.../dataexplorer/export/TestJsonItemGenerator.java | 5 +-
.../influx/DataLakeInfluxQueryBuilder.java | 2 +-
.../dataexplorer/influx/SelectQueryParamsTest.java | 2 +-
.../iotdb/DataExplorerIotDbQueryExecutor.java | 11 ++-
.../iotdb/DataExplorerQueryManagementIotDb.java | 1 +
.../dataexplorer/iotdb/IotDbPropertyConverter.java | 12 ++-
.../dataexplorer/iotdb/IotDbSessionProvider.java | 3 +-
.../dataexplorer/iotdb/TimeSeriesStorageIotDb.java | 7 +-
.../DataLakeMeasurementSanitizerIotDbTest.java | 1 +
.../function/FunctionDeregistrationHandler.java | 0
.../function/FunctionRegistrationHandler.java | 0
.../extensions/function/RegistrationHandler.java | 0
.../function/StreamPipesFunctionHandler.java | 13 ---
.../opcua/config/identity/X509IdentityConfig.java | 4 +-
.../plc/adapter/ConnectionContainerReproTest.java | 10 +-
.../connectors/ros/sink/RosBridgeSink.java | 2 +-
.../tubemq/sink/TubeMQPublisherSink.java | 2 +-
.../model/function/FunctionShutdownResult.java | 3 -
.../streampipes/model/function/FunctionState.java | 9 ++
.../model/function/FunctionsShutdownResponse.java | 3 -
.../execution/ExtensionServiceExecutions.java | 9 ++
.../manager/function/FunctionManager.java | 101 +++++++++++++++++++++
.../manager/setup/CouchDbInstallationStep.java | 2 +
...ViewTask.java => AddFunctionStateViewTask.java} | 9 +-
.../function/FunctionShutdownResource.java | 2 +-
.../streampipes/rest/impl/FunctionsResource.java | 8 +-
.../service/core/StreamPipesCoreApplication.java | 92 ++-----------------
.../core/migrations/AvailableMigrations.java | 2 +
...ion.java => AddFunctionStateViewMigration.java} | 10 +-
.../core/storage/StorageApiConfiguration.java | 14 ++-
.../storage/api/core/INoSqlStorage.java | 3 -
.../storage/couchdb/CouchDbStorageManager.java | 7 --
.../impl/function/FunctionStateStorageImpl.java | 10 +-
39 files changed, 203 insertions(+), 175 deletions(-)
rename {streampipes-service-extensions =>
streampipes-extensions-management}/src/main/java/org/apache/streampipes/service/extensions/function/FunctionDeregistrationHandler.java
(100%)
rename {streampipes-service-extensions =>
streampipes-extensions-management}/src/main/java/org/apache/streampipes/service/extensions/function/FunctionRegistrationHandler.java
(100%)
rename {streampipes-service-extensions =>
streampipes-extensions-management}/src/main/java/org/apache/streampipes/service/extensions/function/RegistrationHandler.java
(100%)
rename {streampipes-service-extensions =>
streampipes-extensions-management}/src/main/java/org/apache/streampipes/service/extensions/function/StreamPipesFunctionHandler.java
(92%)
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/function/FunctionManager.java
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/tasks/{AddScriptTemplateViewTask.java
=> AddFunctionStateViewTask.java} (79%)
rename {streampipes-service-extensions =>
streampipes-rest-extensions}/src/main/java/org/apache/streampipes/rest/extensions/function/FunctionShutdownResource.java
(95%)
copy
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v099/{AddScriptTemplateViewMigration.java
=> AddFunctionStateViewMigration.java} (79%)
copy
streampipes-service-base/src/main/java/org/apache/streampipes/service/base/StreamPipesPrometheusConfig.java
=>
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/storage/StorageApiConfiguration.java
(73%)
