This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a change to branch bump-plc4x-version-0140
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 7b6b1e22c6 Merge branch 'dev' into bump-plc4x-version-0140
add 404646d651 fix(#3772): Add wait to ensure update of event count in
measurement (#3773)
add 88949b8ee0 Feat/retention export (#3770)
add 1c6a10de56 fix: Fix nightly builds after upgrading to material 3
(#3777)
add 397ac5a170 Python 3.12 and 3.13 support (#3779)
add 2b25de5a45 feat: Improve layout of adapter overview, minor style fixes
(#3781)
add 89346893dd chore(deps): bump actions/stale from 9 to 10 (#3758)
add 66d826868b chore(deps): bump actions/labeler from 5 to 6 (#3761)
add 55c182c2e0 deps(#3778): update supported Python versions (#3783)
add cb0446e278 ci: Publish build scans to develocity.apache.org (#3782)
add d51ff5c063 fix: Minor layout issue in Exception dialog
add 17a5b6ee7f refactor: Replace constructor injection with inject()
(#3789)
add 3723c324ec fix: Change opc ua e2e tests (#3784)
add 6b8cec97e0 chore(deps): bump actions/setup-node from 4 to 5 (#3776)
add 9ef787412f fix: Update waiting time parameter to fix flaky editAdapter
test (#3790)
add 7c9df74779 chore(deps): bump
org.springframework.security:spring-security-core (#3786)
add a3e687335c feat:Add the function of collecting load balancing metrics
(#3764)
add ac7fae8a27 Speeding up compact adapter creation by replacing findAll
with getting the specific adapter (#3791)
add 9e373b0212 Update asf.yml
add d3a02cbfd8 fix(#3807): Update kafka version to 4.1.0 (#3808)
add f471645a0e Merge remote-tracking branch 'refs/remotes/origin/dev' into
dev
add 2a01656a37 fix: Update kafka for go e2e tests (#3813)
add 72f4b7b1e0 Fix(#3545): Fix online ml functions (#3803)
add 396d62a455 chore: Disabled Label Editablity in Create Asset Link
(#3806)
add ee60d4bd8d feat(#3798): Show creation and last login date in user
configuration … (#3802)
add faac0ed225 feat: Minor layout improvements, german translations for
pipeline editor (#3799)
add d7c6273d2a feat(#3810): Support cloning of dashboards (#3811)
add f757456e0f chore(deps): bump typing-extensions from 4.13.2 to 4.15.0
in /streampipes-client-python (#3753)
add 0d24ef4786 Add related assets to adapter during adapter generation
process (#3804)
add 39228cc6bf feat: Modify data table actions (#3816)
add 67c4da64f8 fix: Improve styling of adapter asset browser (#3818)
add 828b1b1cb4 feat: Add environment variable for extensions file storage
(#3819)
add 38881c87ed feat(#3822): Support OPC-UA certificate authentication
(#3823)
add 94b660f2f9 feat: Add German translation to "Configuration" (#3820)
add 5f235e2ff0 Edit Assets links for adapter while editing (#3817)
add 567f7caaa3 fix: Fix test createAdapterWithoutStarting (#3827)
add 39e891de80 Fix(#3828): Fix translation for extension
installation/uninstallation (#3830)
add 0477476a8a feat: Improve handling of label colors (#3831)
add b25e5b16fe fix: Avoid flickering of data explorer tables in live
refresh mode (#3832)
add 8e51d30779 Data Retention Export to s3 based object storage (#3824)
add de17d06866 fix(#3833): Add handling for duplicate keys (#3834)
add fe1ef7b4d6 Tests for PR #3829 and #3817 (#3835)
add 38c981fb6c Fix: changed import for export provider service in shared
ui (#3839)
add cb5d5739e5 fix(#3837): Remove delete preview rest endpoint (#3838)
add e0371882b3 refactor: Update some German labels in connect view (#3840)
add 8697becca0 chore(deps): bump actions/setup-node from 5 to 6 (#3836)
add 385527f7b3 chore(deps): bump tmp and @inquirer/editor in /ui (#3774)
add 7c05398db6 deps: Update gRPC version to 1.76.0 in pom.xml (#3843)
add 57d91c0eb5 deps: Remove spring-webmvc dependency (#3842)
add dc6263a014 chore(deps-dev): bump tornado from 6.4.2 to 6.5.1 in
/streampipes-client-python (#3628)
add 1c6db14ca1 deps: update parquet version to 1.16.0 in pom.xml (#3844)
add ad26b70f7e chore(deps-dev): bump numpydoc from 1.7.0 to 1.9.0 in
/streampipes-client-python (#3815)
add 2e5d0c1a88 Add Assets during charts generation /edition (#3841)
add f322df19fa refactor: Change running scope for asset tests
add fe638fc9d8 deps: update commons-beanutils version to 1.11.0 (#3845)
add 6c851eb831 chore(deps): bump confluent-kafka from 2.10.0 to 2.12.0 in
/streampipes-client-python (#3826)
add a7a89e53c8 deps: update ngx-markdown version to 20.1.0
add 7cd5639c92 deps: Downgrade ngx-markdown (#3852)
add b95927c574 chore(deps-dev): bump black from 24.8.0 to 25.9.0 in
/streampipes-client-python (#3849)
add ede660ecd0 chore(deps): bump org.apache.kafka:kafka-clients from 3.7.1
to 3.9.1 (#3659)
add 3ba769b5c9 chore(deps): bump nats-py from 2.10.0 to 2.11.0 in
/streampipes-client-python (#3848)
add 9f3b9b9154 chore(deps): bump org.java-websocket:Java-WebSocket from
1.5.6 to 1.6.0 (#3847)
add 79cb92a1c0 Add / Edit Assets during Dashboard Creation Edit (#3846)
add 3ff81e2388 fix(#3850): Remove osv scanner action (#3851)
add c2cdd1058c chore(deps): bump spring-security.version from 6.4.2 to
6.5.5 (#3788)
add db174852a7 chore(deps-dev): bump @typescript-eslint/eslint-plugin from
8.32.1 to 8.46.1 in /ui (#3856)
add 97ffb4a572 chore(deps-dev): bump blacken-docs from 1.19.1 to 1.20.0 in
/streampipes-client-python (#3857)
add 045abd5781 chore(deps-dev): bump pre-commit from 3.5.0 to 4.3.0 in
/streampipes-client-python (#3858)
add 55e44c6bff Moved Add Assets for Charts from PopUp during Save to
Button in Edit Mode (#3853)
add 8ca6a08004 fix: Minor various layout issues in the UI (#3867)
add f532080c7f feat: Add translations to the Connect view (#3868)
add 03ee016dc9 Small fixes for the export provider settings and the
retention mechanism (#3870)
add da9c179b7f fix: Modify index of OPC-UA migration v6
add 7e10c042b1 fix: Minor layout improvements in retention dialog (#3872)
add cff6242080 3861 Undefined Roots do not show an error message (#3871)
add 3aa1a453a6 fix(#3632): Allow more general OPC-UA variable nodes (#3877)
add 22b0c888df feat: Add option to manually change language (#3878)
add 1133a5a8ed Migration for missing Export Provider Type "FOLDER" (#3875)
add 8f4df6cc8a chore(deps): bump actions/upload-artifact from 4 to 5
(#3881)
add 5aec1ac0fa refactor: Add additional logging in adapter health check
(#3882)
add 45b68b1233 fix: Button margin and close button in data explorer (#3883)
add f624cdb364 Bug Fix: Pipeline not found always showing in pipeline root
(#3879)
add 6d13945c00 3860 translation in connect (#3873)
add 30272f2819 3862 deleting resource delete asset link (#3874)
add d60417f3dc feat: Enhance Develocity Build Scans (#3869)
add 8893b6852d Small fix for the failing test in PipelineAsset. (#3884)
add dce7d250ab fix(3887): permission objects lost after exporting and re
importing assets with sanitized resource ids (#3888)
add e776239bcc refactor: Use nats as default and clean up of readme (#3886)
add 93d9179782 [maven-release-plugin] prepare branch @{releaseLabel}
add 2a122df84f [maven-release-plugin] prepare for next development
iteration
add ecaa286dbf feat: Add loadbalancer (#3795)
add 7ce00b2233 feat:Add SpRateLimiter and SpMemoryManager (#3796)
add e940e092b0 fix: Access rights for adapter and pipeline endpoints
(#3890)
add 2661dd08f1 fix: Avoid sending events twice in adapter sink (#3892)
add 85c51cde18 fix(#3893): Fix translation bug in data lake configuration
(#3894)
add d4489cd2f4 Merge branch 'dev' into bump-plc4x-version-0140
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 12 +-
.github/workflows/build.yml | 12 +-
.github/workflows/cypress-test.yml | 16 +-
.github/workflows/extensions-docs.yml | 8 +-
.github/workflows/go-client-e2e-test.yml | 2 +
.github/workflows/go-docs.yml | 4 +-
.github/workflows/osv-scanner.yml | 54 --
.github/workflows/pr-labeler.yml | 2 +-
.github/workflows/pr-validation.yml | 37 +-
.github/workflows/pypi-deployment.yml | 4 +-
.github/workflows/python-docs.yml | 4 +-
.github/workflows/stale-bot.yml | 2 +-
.gitignore | 3 +
.mvn/develocity.xml | 47 ++
.mvn/extensions.xml | 34 ++
VULNERABILITY.md | 11 -
.../streampipes-archetype-extensions-jvm/pom.xml | 2 +-
.../pom.xml | 2 +-
.../streampipes-archetype-pe-sinks-flink/pom.xml | 2 +-
.../src/main/resources/archetype-resources/pom.xml | 2 +-
docker-compose.yml | 34 +-
.../deploy/standalone/kafka/docker-compose.dev.yml | 28 +-
.../cli/deploy/standalone/kafka/docker-compose.yml | 31 +-
.../cli/deploy/standalone/opcua/docker-compose.yml | 2 +-
installer/compose/README.md | 48 +-
installer/compose/docker-compose.full.yml | 152 -----
...r-compose.nats.yml => docker-compose.kafka.yml} | 47 +-
installer/compose/docker-compose.pulsar.yml | 109 ----
installer/compose/docker-compose.yml | 41 +-
pom.xml | 30 +-
streampipes-client-api/pom.xml | 8 +-
streampipes-client-e2e/docker-compose.yml | 38 +-
...ine-learning-on-a-streampipes-data-stream.ipynb | 49 +-
streampipes-client-python/poetry.lock | 408 +++++--------
streampipes-client-python/pyproject.toml | 12 +-
.../streampipes/function_zoo/river_function.py | 9 +-
.../functions/utils/data_stream_generator.py | 10 +-
streampipes-client/pom.xml | 14 +-
streampipes-commons/pom.xml | 2 +-
.../apache/streampipes/commons/constants/Envs.java | 69 ++-
.../commons/environment/DefaultEnvironment.java | 186 +++++-
.../commons/environment/Environment.java | 100 +++-
.../commons/environment/Environments.java | 1 -
.../variable/BooleanEnvironmentVariable.java | 1 -
...ariable.java => DoubleEnvironmentVariable.java} | 17 +-
...Variable.java => FloatEnvironmentVariable.java} | 17 +-
.../variable/IntEnvironmentVariable.java | 1 -
...tVariable.java => LongEnvironmentVariable.java} | 10 +-
.../variable/StringEnvironmentVariable.java | 1 -
.../commons/exceptions/SpHttpErrorStatusCode.java | 2 +-
.../prometheus/StreamPipesCollectorRegistry.java | 61 +-
.../loadbalancer/LoadBalancerMetrics.java | 50 ++
.../prometheus/loadbalancer/LoadBalancerStats.java | 52 ++
.../prometheus/service/ElementServiceMetrics.java | 58 ++
.../prometheus/service/ElementServiceStats.java | 131 +++++
.../spmemorymanager/SpMemoryManagerMetrics.java | 30 +-
.../spmemorymanager/SpMemoryManagerStats.java | 66 +++
.../SpRateLimiterMetrics.java} | 37 +-
.../spratelimiter/SpRateLimiterStats.java | 66 +++
streampipes-connect-management/pom.xml | 12 +-
.../management/health/AdapterHealthCheck.java | 184 +++---
.../management/AdapterMasterManagement.java | 183 +++---
streampipes-connect-shared/pom.xml | 10 +-
streampipes-data-explorer-api/pom.xml | 8 +-
.../api/IDataExplorerSchemaManagement.java | 3 +
streampipes-data-explorer-export/pom.xml | 42 +-
.../export/ObjectStorge/ExportProviderFactory.java | 39 +-
.../export/ObjectStorge/IObjectStorage.java | 17 +-
.../export/ObjectStorge/LocalFolder.java | 53 ++
.../dataexplorer/export/ObjectStorge/S3.java | 86 +++
streampipes-data-explorer-influx/pom.xml | 16 +-
streampipes-data-explorer-iotdb/pom.xml | 16 +-
streampipes-data-explorer-management/pom.xml | 10 +-
streampipes-data-explorer/pom.xml | 10 +-
.../dataexplorer/DataExplorerSchemaManagement.java | 58 +-
streampipes-data-export/pom.xml | 12 +-
.../export/dataimport/PerformImportGenerator.java | 12 +-
streampipes-dataformat/pom.xml | 4 +-
streampipes-extensions-api/pom.xml | 31 +-
.../extensions/api/limiter/SpRateLimiter.java | 307 ++++++++++
.../api/memorymanager/SpMemoryManager.java | 331 +++++++++++
.../api/monitoring/SpMonitoringManager.java | 6 +-
.../api/pe/routing/RawDataProcessor.java | 2 +-
streampipes-extensions-management/pom.xml | 22 +-
.../connect/HttpServerAdapterManagement.java | 2 +-
.../elements/SendToBrokerAdapterSink.java | 8 +-
.../monitoring/ServiceLoadDataReportGenerator.java | 360 ++++++++++++
streampipes-extensions/pom.xml | 4 +-
.../streampipes-connect-adapters-iiot/pom.xml | 10 +-
.../connect/iiot/adapters/oi4/Oi4Adapter.java | 6 +
.../connect/iiot/utils/FileProtocolUtils.java | 8 +-
.../streampipes-connect-adapters/pom.xml | 10 +-
.../streampipes-connectors-influx/pom.xml | 8 +-
.../streampipes-connectors-kafka/pom.xml | 14 +-
.../streampipes-connectors-mqtt/pom.xml | 8 +-
.../streampipes-connectors-nats/pom.xml | 10 +-
.../streampipes-connectors-opcua/pom.xml | 10 +-
.../opcua/OpcUaConnectorsModuleExport.java | 6 +-
.../connectors/opcua/adapter/OpcUaAdapter.java | 2 +-
.../connectors/opcua/adapter/OpcUaNodeBrowser.java | 15 +-
.../opcua/config/SharedUserConfiguration.java | 13 +-
.../opcua/config/SpOpcUaConfigExtractor.java | 13 +-
.../opcua/config/identity/X509IdentityConfig.java | 114 ++++
.../security/CompositeCertificateValidator.java | 10 +-
...grationV3.java => OpcUaAdapterMigrationV6.java} | 57 +-
...kMigrationV1.java => OpcUaSinkMigrationV2.java} | 8 +-
.../opcua/model/node/BasicVariableNodeInfo.java | 8 +-
.../model/nodename/NamingStrategyResolver.java | 4 +-
.../opcua/model/nodename/ParsedNodeIdResolver.java | 4 +-
.../opcua/model/nodename/SimpleNameResolver.java | 8 +-
.../connectors/opcua/sink/OpcUaSink.java | 2 +-
.../opcua/utils/OpcUaNamingStrategy.java | 8 +-
.../connectors/opcua/utils/OpcUaTypes.java | 4 +-
.../connectors/opcua/utils/OpcUaUtils.java | 21 +-
.../strings.en | 9 +
.../strings.en | 9 +
.../streampipes-connectors-plc/pom.xml | 8 +-
.../streampipes-connectors-pulsar/pom.xml | 8 +-
.../streampipes-connectors-rocketmq/pom.xml | 8 +-
.../rocketmq/adapter/RocketMQConsumer.java | 10 +-
.../rocketmq/sink/RocketMQPublisherSink.java | 2 +-
.../streampipes-connectors-ros/pom.xml | 10 +-
.../streampipes-connectors-tubemq/pom.xml | 8 +-
.../streampipes-extensions-all-iiot/pom.xml | 50 +-
.../streampipes-extensions-all-jvm/pom.xml | 62 +-
.../streampipes-extensions-iiot-minimal/pom.xml | 40 +-
.../streampipes-pipeline-elements-shared/pom.xml | 4 +-
.../pom.xml | 6 +-
.../streampipes-processors-enricher-jvm/pom.xml | 10 +-
.../streampipes-processors-filters-jvm/pom.xml | 8 +-
.../streampipes-processors-filters-siddhi/pom.xml | 8 +-
.../streampipes-processors-geo-jvm/pom.xml | 6 +-
.../pom.xml | 6 +-
.../streampipes-processors-llm-jvm/pom.xml | 8 +-
.../streampipes-processors-text-mining-jvm/pom.xml | 6 +-
.../pom.xml | 10 +-
.../streampipes-sinks-brokers-jvm/pom.xml | 10 +-
.../streampipes-sinks-databases-jvm/pom.xml | 6 +-
.../streampipes-sinks-internal-jvm/pom.xml | 12 +-
.../sinks/internal/jvm/datalake/DataLakeSink.java | 23 +-
.../streampipes-sinks-notifications-jvm/pom.xml | 8 +-
streampipes-integration-tests/pom.xml | 26 +-
.../integration/adapters/KafkaAdapterTester.java | 8 +-
.../integration/containers/KafkaContainer.java | 55 --
.../integration/containers/KafkaDevContainer.java | 2 +-
...DevContainer.java => SpKafkaTestContainer.java} | 26 +-
.../pom.xml | 48 +-
.../loadbalance/ExtensionServiceSelector.java | 61 ++
.../streampipes/loadbalance/LoadBalancer.java | 26 +-
.../loadbalance/LoadBalancerConfig.java | 75 +++
.../streampipes/loadbalance/LoadManager.java | 240 ++++++++
.../streampipes/loadbalance/PipelineMigrator.java | 18 +-
.../loadbalance/ResourceUnitMigration.java | 330 +++++++++++
.../loadbalance/ServiceLoadCalculator.java | 135 +++++
.../loadbalance/impl/AbstractPipelineMigrator.java | 208 +++++++
.../loadbalance/impl/ExtensibleLoadManager.java | 60 ++
.../loadbalance/impl/MinimumLoadSelector.java | 124 ++++
.../loadbalance/impl/OverloadMigrator.java | 93 +++
.../loadbalance/impl/ThresholdMigrator.java | 138 +++++
.../loadbalance/impl/TransferMigrator.java | 145 +++++
.../loadbalance/impl/WeightedFirstSelector.java | 172 ++++++
.../loadbalance/impl/WeightedRandomSelector.java | 155 +++++
.../pipeline/ExtensionsLogProvider.java | 28 +-
.../pipeline/ExtensionsServiceLogExecutor.java | 60 +-
.../service}/ExtensionServiceExecutions.java | 33 +-
.../service/ExtensionsServiceReportExecutor.java | 89 +++
.../unit}/ExtensionsServiceEndpointUtils.java | 2 +-
.../loadbalance/unit/InvokeHttpRequest.java | 131 +++++
.../unit/PipelineElementPartitioner.java | 458 +++++++++++++++
.../loadbalance/unit/ResourceUnitScanner.java | 370 ++++++++++++
.../loadbalance/unit/ResourceUnitStatsScanner.java | 345 +++++++++++
streampipes-mail/pom.xml | 4 +-
streampipes-maven-plugin/pom.xml | 4 +-
streampipes-measurement-units/pom.xml | 4 +-
streampipes-messaging-jms/pom.xml | 4 +-
.../messaging/jms/ActiveMQConsumer.java | 10 +-
streampipes-messaging-kafka/pom.xml | 6 +-
.../messaging/kafka/SpKafkaConsumer.java | 9 +-
.../kafka/config/ConsumerConfigFactory.java | 1 +
streampipes-messaging-mqtt/pom.xml | 4 +-
streampipes-messaging-nats/pom.xml | 4 +-
streampipes-messaging-pulsar/pom.xml | 4 +-
.../messaging/pulsar/PulsarConsumer.java | 10 +-
streampipes-messaging/pom.xml | 4 +-
.../messaging/InternalEventProcessor.java | 2 +-
streampipes-model-client/pom.xml | 6 +-
.../streampipes/model/client/user/UserAccount.java | 29 +
streampipes-model-shared/pom.xml | 2 +-
streampipes-model/pom.xml | 8 +-
.../org/apache/streampipes/model/UserInfo.java | 9 +
...onfig.java => DefaultExportProviderConfig.java} | 16 +-
.../configuration/DefaultSpCoreConfiguration.java | 1 +
.../configuration/ExportProviderSettings.java | 115 ++++
.../{JwtSigningMode.java => ProviderType.java} | 6 +-
.../model/configuration/SpCoreConfiguration.java | 12 +
.../model/dashboard/DashboardModel.java | 5 +
.../model/datalake/DataLakeMeasure.java | 12 +
...ataLakeQueryOrdering.java => ExportConfig.java} | 10 +-
.../model/datalake/RetentionExportConfig.java | 25 +-
.../model/datalake/RetentionTimeConfig.java | 36 +-
.../svcdiscovery/SpServiceRegistration.java | 17 +
.../svcdiscovery/SpServiceTagPrefix.java | 5 +
.../loadbalancer/LoadBalanceResourceUnit.java | 120 ++++
.../loadbalancer/LoadBalanceResourceUnitStats.java | 154 +++++
.../model/loadbalancer/LoadBalancerConstants.java | 31 +-
.../model/loadbalancer/ServiceLoadDataReport.java | 325 +++++++++++
.../streampipes/model/loadbalancer/Usage.java | 201 +++++++
.../model/monitoring/MessageCounter.java | 9 +
.../model/monitoring/SpMetricsEntry.java | 5 +-
.../streampipes/model/pipeline/Pipeline.java | 20 +
streampipes-pipeline-management/pom.xml | 36 +-
.../ExtensionsServiceEndpointGenerator.java | 100 ++--
.../execution/task/DiscoverEndpointsTask.java | 32 +-
.../manager/health/PipelineHealthCheck.java | 81 ++-
.../manager/health/ServiceHealthCheck.java | 55 +-
.../manager/health/ServiceRegistrationManager.java | 28 +-
.../manager/pipeline/PipelineManager.java | 35 +-
.../manager/preview/PipelinePreview.java | 71 ++-
.../manager/runtime/ClientDisconnectCallback.java | 8 +-
.../runtime/RateLimitedRuntimeInfoProvider.java | 7 +-
streampipes-resource-management/pom.xml | 8 +-
.../DataExplorerWidgetResourceManager.java | 2 +-
.../resource/management/UserResourceManager.java | 6 +-
streampipes-rest-core-base/pom.xml | 10 +-
streampipes-rest-extensions/pom.xml | 13 +-
...ngResource.java => ServiceMonitorResource.java} | 18 +-
streampipes-rest-shared/pom.xml | 6 +-
streampipes-rest/pom.xml | 31 +-
.../rest/impl/AbstractMonitoringResource.java | 2 +-
.../rest/impl/AdapterMonitoringResource.java | 66 ++-
.../rest/impl/AssetManagementResource.java | 14 +-
.../streampipes/rest/impl/Authentication.java | 2 +
.../streampipes/rest/impl/FunctionsResource.java | 2 +-
.../streampipes/rest/impl/PipelineMonitoring.java | 8 +-
.../streampipes/rest/impl/PipelineResource.java | 10 +-
.../admin/ExportProviderConfigurationResource.java | 105 ++++
.../impl/admin/ServiceRegistrationResource.java | 8 +-
.../rest/impl/connect/AdapterResource.java | 214 +++----
.../rest/impl/connect/CompactAdapterResource.java | 2 +-
.../impl/dashboard/DataLakeDashboardResource.java | 7 +-
.../impl/datalake/DataLakeMeasureResource.java | 43 +-
.../rest/impl/datalake/DataLakeResource.java | 15 +
.../PipelinePreviewResource.java} | 23 +-
.../StreamPreviewResource.java} | 9 +-
streampipes-sdk-bundle/pom.xml | 18 +-
streampipes-sdk/pom.xml | 10 +-
streampipes-security-jwt/pom.xml | 4 +-
streampipes-serializers-json/pom.xml | 8 +-
streampipes-service-base/pom.xml | 6 +-
.../service/base}/StreamPipesPrometheusConfig.java | 2 +-
streampipes-service-core-minimal/pom.xml | 6 +-
.../minimal/StreamPipesCoreApplicationMinimal.java | 2 +-
streampipes-service-core/pom.xml | 29 +-
.../service/core/StreamPipesCoreApplication.java | 118 ++--
.../core/migrations/AvailableMigrations.java | 6 +-
.../AddDefaultExportProviderMigration.java} | 34 +-
.../v0980/FixImportedPermissionsMigration.java | 116 ++++
.../service/core/oauth2/UserService.java | 4 +-
.../service/core/scheduler/DataLakeScheduler.java | 170 +++++-
streampipes-service-discovery-api/pom.xml | 4 +-
.../svcdiscovery/api/ISpServiceDiscovery.java | 9 +
streampipes-service-discovery/pom.xml | 8 +-
.../svcdiscovery/SpServiceDiscoveryCore.java | 16 +
streampipes-service-extensions/pom.xml | 6 +-
.../StreamPipesExtensionsServiceBase.java | 9 +-
streampipes-storage-api/pom.xml | 8 +-
.../streampipes/storage/api/CRUDStorage.java | 1 +
.../streampipes/storage/api/IGenericStorage.java | 2 +
.../streampipes/storage/api/IPipelineStorage.java | 1 -
streampipes-storage-couchdb/pom.xml | 10 +-
.../storage/couchdb/impl/DefaultCrudStorage.java | 13 +-
.../storage/couchdb/impl/GenericStorageImpl.java | 39 ++
.../impl/PipelineCanvasMetadataStorageImpl.java | 2 +-
.../storage/couchdb/impl/PipelineStorageImpl.java | 12 +-
streampipes-storage-management/pom.xml | 6 +-
streampipes-test-utils-executors/pom.xml | 6 +-
streampipes-test-utils/pom.xml | 8 +-
streampipes-user-management/pom.xml | 8 +-
.../user/management/util/UserInfoUtil.java | 1 +
streampipes-vocabulary/pom.xml | 2 +-
streampipes-wrapper-distributed/pom.xml | 6 +-
streampipes-wrapper-flink/pom.xml | 8 +-
streampipes-wrapper-kafka-streams/pom.xml | 6 +-
streampipes-wrapper-siddhi/pom.xml | 4 +-
streampipes-wrapper-standalone/pom.xml | 6 +-
.../standalone/function/StreamPipesFunction.java | 9 +-
.../routing/StandaloneSpInputCollector.java | 9 +-
.../routing/StandaloneSpOutputCollector.java | 5 +-
.../runtime/StandaloneEventProcessorRuntime.java | 13 +-
.../runtime/StandaloneEventSinkRuntime.java | 13 +-
streampipes-wrapper/pom.xml | 14 +-
ui/cypress.config.ts | 29 +-
.../support/utils/DataDownloadDialogUtils.ts | 8 +-
ui/cypress/support/utils/GeneralUtils.ts | 17 +
.../support/utils/ProcessingElementTestUtils.ts | 4 +-
ui/cypress/support/utils/asset/AssetBtns.ts | 4 +
ui/cypress/support/utils/asset/AssetUtils.ts | 45 +-
ui/cypress/support/utils/connect/ConnectBtns.ts | 17 +-
.../utils/connect/ConnectEventSchemaUtils.ts | 20 +-
ui/cypress/support/utils/connect/ConnectUtils.ts | 90 ++-
ui/cypress/support/utils/connect/OpcUaUtils.ts | 21 +-
.../DataExplorerBtns.ts} | 27 +-
.../DataExplorerUtils.ts} | 161 +++++-
.../DataExplorerWidgetTableUtils.ts} | 2 +-
ui/cypress/support/utils/pipeline/PipelineUtils.ts | 63 +-
ui/cypress/support/utils/user/PermissionUtils.ts | 12 +-
ui/cypress/tests/connect/adapterWithAssets.spec.ts | 106 ++++
.../compactAdapterWithTransformation.spec.ts | 4 +-
.../tests/connect/compact/uiConfiguration.spec.ts | 3 +-
.../connect/createAdapterWithoutStarting.spec.ts | 5 +-
ui/cypress/tests/connect/editAdapter.smoke.spec.ts | 31 +-
.../editAdapterSettingsAndPipeline.smoke.spec.ts | 9 +-
.../editAdapterTransformationRulesAreKept.spec.ts | 1 +
.../connect/editAdapterValuesAndFields.spec.ts | 6 +-
ui/cypress/tests/connect/fileStream.spec.ts | 4 +-
.../connect/machineDataSimulator.smoke.spec.ts | 2 +-
.../opcua/startAndEditOpcAdapters.smoke.spec.ts | 6 +-
.../connect/rules/addNumericalStaticValue.spec.ts | 6 +-
.../dataDownloadDialogTest.smoke.spec.ts | 6 +-
.../dataExplorer/addAssetToDashboard.smoke.spec.ts | 81 +++
.../dataExplorer/addAssetsToDataView.smoke.spec.ts | 67 +++
.../charts}/heatmap.spec.ts | 9 +-
.../charts}/histogram.spec.ts | 8 +-
.../charts}/indicator.spec.ts | 8 +-
.../widgets => dataExplorer/charts}/map.spec.ts | 10 +-
.../charts}/scatter.smoke.spec.ts | 10 +-
.../widgets => dataExplorer/charts}/table.spec.ts | 10 +-
.../charts}/timeSeriesSave.spec.ts | 16 +-
.../configuration.smoke.spec.ts | 12 +-
.../dataExplorer/deleteViewAndDashboard.spec.ts | 76 +++
.../filterNumericalStringProperties.spec.ts | 36 +-
.../missingDataInDataLake.spec.ts | 12 +-
.../timeOrderDataView.spec.ts | 34 +-
.../timeRangeSelectors.spec.ts | 14 +-
.../widgetDataConfiguration.smoke.spec.ts | 119 ++++
.../tests/datalake/deleteViewAndDashboard.spec.ts | 76 ---
ui/cypress/tests/datalake/deleteWidget.ts | 61 --
.../datalake/widgetDataConfiguration.smoke.spec.ts | 105 ----
.../restartStreamPipes/restartStreamPipes2.ts | 4 +-
ui/cypress/tests/pipeline/pipelineAsset.spec.ts | 97 ++++
.../tests/pipeline/pipelineTest.smoke.spec.ts | 2 +-
.../tests/pipeline/renamePipelineTest.spec.ts | 4 +-
.../pipeline/updatePipelineTest.smoke.spec.ts | 15 +-
.../userManagement/testGroupManagement.spec.ts | 2 +-
.../userManagement/testUserRoleConnect.spec.ts | 4 +-
.../userManagement/testUserRolePipeline.spec.ts | 8 +-
ui/deployment/i18n/de.json | 614 ++++++++++++++++++--
ui/deployment/i18n/en.json | 608 +++++++++++++++++--
ui/develocity.config.js | 118 ++++
ui/package-lock.json | 643 +++++++++++++++------
ui/package.json | 4 +-
.../src/lib/apis/abstract-monitoring.service.ts | 7 +-
.../src/lib/apis/adapter-monitoring.service.ts | 9 -
.../src/lib/apis/adapter.service.ts | 12 +-
.../src/lib/apis/asset-management.service.ts | 8 +-
.../src/lib/apis/chart.service.ts | 8 +-
.../src/lib/apis/commons.service.ts | 2 -
.../src/lib/apis/compact-pipeline.service.ts | 8 +-
.../src/lib/apis/dashboard.service.ts | 8 +-
.../src/lib/apis/datalake-rest.service.ts | 22 +-
...icate.service.ts => export-provider.service.ts} | 38 +-
.../src/lib/apis/extension-installation.service.ts | 18 +-
.../src/lib/apis/files.service.ts | 8 +-
.../src/lib/apis/functions.service.ts | 8 +-
.../src/lib/apis/general-config.service.ts | 8 +-
.../src/lib/apis/generic-storage.service.ts | 8 +-
.../src/lib/apis/labels.service.ts | 4 +-
.../src/lib/apis/location-config.service.ts | 8 +-
.../src/lib/apis/mail-config.service.ts | 8 +-
.../src/lib/apis/measurement-units.service.ts | 8 +-
.../src/lib/apis/permissions.service.ts | 8 +-
.../lib/apis/pipeline-canvas-metadata.service.ts | 8 +-
.../src/lib/apis/pipeline-element-asset.service.ts | 2 -
.../apis/pipeline-element-runtime-info.service.ts | 2 +-
.../lib/apis/pipeline-element-template.service.ts | 8 +-
.../src/lib/apis/pipeline-element.service.ts | 8 +-
.../src/lib/apis/pipeline-monitoring.service.ts | 28 +-
.../src/lib/apis/pipeline-template.service.ts | 4 +-
.../src/lib/apis/pipeline.service.spec.ts | 73 ---
.../src/lib/apis/pipeline.service.ts | 8 +-
.../src/lib/apis/privilege.service.ts | 8 +-
.../platform-services/src/lib/apis/role.service.ts | 8 +-
.../src/lib/apis/semantic-types-rest.service.ts | 8 +-
.../src/lib/apis/service-tags.service.ts | 8 +-
.../src/lib/apis/shared-dashboard.service.ts | 4 +-
.../src/lib/apis/user-admin.service.ts | 8 +-
.../src/lib/apis/user-group.service.ts | 8 +-
.../platform-services/src/lib/apis/user.service.ts | 8 +-
.../src/lib/model/assets/asset.model.ts | 17 +
.../src/lib/model/dashboard/dashboard.model.ts | 1 +
.../src/lib/model/gen/streampipes-model-client.ts | 10 +-
.../src/lib/model/gen/streampipes-model.ts | 80 ++-
.../src/lib/model/types/data-type.ts | 11 +
.../platform-services/src/public-api.ts | 1 +
.../asset-browser-filter.component.html | 2 +-
.../asset-link-configuration.component.html | 72 +++
.../asset-link-configuration.component.scss} | 61 +-
.../asset-link-configuration.component.ts | 206 +++++++
.../basic-header-title/header-title.component.scss | 18 +-
.../basic-inner-panel.component.html | 1 +
.../basic-inner-panel.component.scss | 25 +-
.../basic-inner-panel.component.ts | 3 +
.../basic-nav-tabs/basic-nav-tabs.component.html | 1 +
.../basic-nav-tabs/basic-nav-tabs.component.scss | 6 +
.../basic-view/basic-view.component.html | 1 +
.../basic-view/basic-view.component.scss | 3 +
.../input-schema-panel.component.html | 4 +-
.../exception-details-dialog.component.html | 2 +-
.../components/sp-label/sp-label.component.scss | 1 -
.../lib/components/sp-label/sp-label.component.ts | 6 +-
.../sp-table/sp-table-actions.directive.ts | 7 +-
.../components/sp-table/sp-table.component.html | 47 +-
.../components/sp-table/sp-table.component.scss | 9 +
.../lib/components/sp-table/sp-table.component.ts | 31 +
.../split-section/split-section.component.html | 2 +-
.../panel-dialog/panel-dialog.component.html | 2 +-
.../standard-dialog/standard-dialog.component.html | 2 +-
.../lib/services/asset-configuration.service.ts | 337 +++++++++++
.../src/lib/services/colorization.service.ts | 107 +++-
.../shared-ui/src/lib/shared-ui.module.ts | 6 +
.../streampipes/shared-ui/src/public-api.ts | 3 +
ui/src/app/assets/assets.module.ts | 4 +
.../asset-details-basics.component.html | 24 +-
.../asset-details-links.component.html | 7 +-
.../asset-overview/asset-overview.component.html | 80 +--
.../asset-overview/asset-overview.component.ts | 2 +-
.../create-asset-dialog.component.html | 2 +-
.../edit-asset-link-dialog.component.html | 8 +-
.../edit-asset-link-dialog.component.scss | 9 +-
.../manage-asset-links-dialog.component.html | 6 +-
.../manage-asset-links-dialog.component.ts | 1 +
.../configuration/configuration-tabs.service.ts | 26 +-
ui/src/app/configuration/configuration.module.ts | 9 +-
.../datalake-configuration.component.html | 276 ++++++++-
.../datalake-configuration.component.ts | 121 +++-
.../certificate-details-dialog.component.html | 2 +-
.../select-export/select-format.component.html | 131 ++++-
.../select-export/select-format.component.scss | 19 +
.../select-export/select-format.component.ts | 111 +++-
.../select-data-retention.component.html | 8 +-
.../select-data-retention.component.ts | 3 +-
.../select-retention/select-data.component.ts | 4 +-
.../select-retention-action.component.html | 4 +-
.../select-retention-action.component.ts | 3 +-
.../data-retention-dialog.component.html | 25 +-
.../data-retention-dialog.component.ts | 71 ++-
.../model/data-retention-provider.model.ts} | 6 +-
.../services/data-export.service.ts | 148 -----
.../services/file-name.service.spec.ts | 118 ----
.../services/file-name.service.ts | 59 --
.../delete-datalake-index-dialog.component.html | 24 +-
.../delete-datalake-index-dialog.component.ts | 12 +-
.../delete-export-provider-dialog.component.html} | 36 +-
.../delete-export-provider-dialog.component.ts} | 34 +-
.../export-provider-dialog.component.html | 116 ++++
.../export-provider-dialog.component.ts | 135 +++++
.../extensions-installation.component.html | 29 +-
.../extensions-installation.component.ts | 8 +-
...xtensions-service-details-dialog.component.html | 10 +-
.../file-rename/file-rename-dialog.component.html | 18 +-
.../file-upload/file-upload-dialog.component.html | 15 +-
.../file-upload/file-upload-dialog.component.ts | 6 +-
.../edit-location-area.component.html | 4 +-
.../edit-location/edit-location.component.html | 19 +-
.../manage-site/manage-site-dialog.component.html | 4 +-
.../email-configuration.component.html | 73 ++-
.../email-configuration.component.ts | 12 +-
.../email-template-configuration.component.html | 16 +-
.../email-template-configuration.component.ts | 28 +-
.../export/data-export-import.component.html | 26 +-
.../export/data-export-import.component.ts | 6 +-
.../data-export-dialog.component.html | 31 +-
.../generic-storage-items.component.html | 8 +-
.../data-import-dialog.component.html | 48 +-
.../import-dialog/data-import-dialog.component.ts | 6 +-
.../endpoint-item/endpoint-item.component.html | 29 +-
.../endpoint-item/endpoint-item.component.ts | 19 +-
.../extensions-installation.component.html | 41 +-
.../extensions-installation.component.ts | 4 +-
.../certificate-configuration.component.html | 18 +-
.../certificate-configuration.component.ts | 4 +-
...extensions-service-configuration.component.html | 6 +-
.../service-configs/service-configs.component.html | 2 +-
.../extensions-service-management.component.html | 21 +-
.../registered-extensions-services.component.html | 10 +-
.../registered-extensions-services.component.ts | 4 +-
.../file-overview/file-overview.component.html | 10 +-
.../files/file-overview/file-overview.component.ts | 6 +-
.../app/configuration/files/files.component.html | 9 +-
ui/src/app/configuration/files/files.component.ts | 4 +-
.../general-configuration.component.html | 48 +-
.../link-settings/link-settings.component.html | 24 +-
.../user-acknowledgment.component.html | 10 +-
.../edit-label/edit-label.component.html | 10 +-
.../edit-label/edit-label.component.ts | 21 +-
.../label-configuration.component.html | 17 +-
.../broker-config/broker-config.component.html | 4 +-
.../messaging-configuration.component.html | 28 +-
.../abstract-security-principal-config.ts | 37 +-
.../alternate-id-configuration.component.html | 19 +-
.../authentication-configuration.component.html | 2 +-
.../edit-group-dialog.component.html | 21 +-
.../edit-role-dialog.component.html | 33 +-
.../edit-user-dialog.component.html | 84 ++-
.../edit-user-dialog/edit-user-dialog.component.ts | 4 +-
.../role-configuration.component.html | 22 +-
.../role-configuration.component.ts | 20 +-
.../security-configuration.component.html | 42 +-
.../security-service-config.component.html | 14 +-
.../security-user-config.component.html | 49 +-
.../security-user-config.component.ts | 18 +-
.../user-group-configuration.component.html | 17 +-
.../user-group-configuration.component.ts | 20 +-
.../location-features-configuration.component.html | 21 +-
.../location-features-configuration.component.ts | 14 +-
.../site-area-configuration.component.html | 16 +-
.../site-area-configuration.component.ts | 4 +-
.../adapter-configuration-header.component.html | 33 --
.../adapter-configuration-header.component.scss | 22 -
.../adapter-configuration-header.component.ts | 39 --
.../adapter-configuration.component.html | 24 +-
.../adapter-configuration.component.ts | 12 +-
.../adapter-deployment-settings.component.html | 6 +-
.../adapter-settings.component.html | 10 +-
.../error-message/error-message.component.html | 6 +-
.../event-property-row.component.html | 18 +-
.../event-schema-preview.component.html | 9 +-
.../event-schema/event-schema.component.html | 6 +-
.../schema-editor-header.component.html | 4 +-
.../adapter-options-panel.component.scss | 7 +-
.../start-adapter-configuration.component.html | 75 ++-
.../start-adapter-configuration.component.ts | 32 +-
.../abstract-adapter-details.directive.ts | 22 +-
.../adapter-details-code.component.html | 26 +-
.../adapter-details-data.component.html | 55 +-
.../adapter-details-logs.component.html | 24 +-
.../adapter-details-metrics.component.html | 28 +-
.../configuration-group.component.html | 2 +-
.../adapter-description.component.html | 51 +-
.../adapter-description.component.scss | 28 +-
.../adapter-description.component.ts | 3 +
.../data-marketplace.component.html | 5 +-
.../data-marketplace.component.scss | 2 +-
.../existing-adapters.component.html | 198 ++++---
.../existing-adapters.component.scss | 11 +-
.../existing-adapters.component.ts | 22 +-
.../filter-toolbar/filter-toolbar.component.html | 2 +-
ui/src/app/connect/connect.module.ts | 8 +-
.../adapter-started-dialog.component.html | 4 +-
.../adapter-started-dialog.component.ts | 215 ++++++-
.../adapter-started-success.component.html | 44 ++
.../adapter-started-success.component.ts | 6 +
...adapter-started-update-migration.component.html | 38 +-
.../delete-adapter-dialog.component.html | 52 +-
.../all-adapter-actions-dialog.component.html | 39 +-
.../all-adapter-actions-dialog.component.ts | 14 +-
.../adapter-asset-configuration.service.ts | 337 +++++++++++
.../id-generator/id-generator.service.ts | 4 +
.../template/PipelineInvocationBuilder.ts | 96 ---
ui/src/app/core-ui/core-ui.module.ts | 3 +-
.../static-free-input.component.html | 43 +-
.../static-free-input.component.ts | 4 +
.../static-property.component.html | 7 +-
.../static-property.component.scss | 4 -
...tic-runtime-resolvable-any-input.component.html | 2 +-
.../static-tree-input-button-menu.component.html | 1 +
.../streampipes/streampipes.component.ts | 10 +-
.../grid-view/dashboard-grid-view.component.scss | 2 +-
.../grid-view/dashboard-grid-view.component.ts | 4 +-
.../slide-view/dashboard-slide-view.component.scss | 5 +-
.../dashboard-overview-table.component.html | 175 +++---
.../dashboard-overview-table.component.ts | 26 +
.../overview/dashboard-overview.component.ts | 3 +-
.../panel/dashboard-panel.component.html | 177 +++---
.../panel/dashboard-panel.component.scss | 1 -
.../components/panel/dashboard-panel.component.ts | 12 +-
ui/src/app/dashboard/dashboard.module.ts | 4 +
.../clone-dashboard-dialog.component.html | 158 +++++
.../clone-dashboard-dialog.component.scss} | 2 +-
.../clone-dashboard-dialog.component.ts | 130 +++++
.../edit-dashboard-dialog.component.html | 75 ++-
.../edit-dashboard-dialog.component.ts | 89 ++-
.../data-explorer-chart-container.component.html | 63 +-
.../data-explorer-chart-container.component.scss | 11 +-
.../charts/density/density-renderer.service.ts | 6 +-
.../charts/scatter/scatter-renderer.service.ts | 6 +-
.../charts/status/status-widget.component.ts | 2 +-
.../charts/table/table-widget.component.ts | 5 +-
.../data-explorer-chart-view.component.html | 94 +--
.../data-explorer-chart-view.component.ts | 133 ++++-
...lorer-widget-appearance-settings.component.html | 98 +++-
...lorer-widget-appearance-settings.component.scss | 6 +
...xplorer-widget-appearance-settings.component.ts | 44 +-
...data-explorer-chart-view-toolbar.component.html | 11 +
.../data-explorer-chart-view-toolbar.component.ts | 3 +
.../data-explorer-overview-table.component.html | 162 ++----
ui/src/app/data-explorer/data-explorer.module.ts | 10 +-
.../dialog/asset-dialog.component.html | 69 +++
.../data-explorer/dialog/asset-dialog.component.ts | 71 +++
.../custom-output-strategy.component.html | 8 +-
.../output-strategy/output-strategy.component.html | 2 +-
.../user-defined-output.component.html | 10 +-
.../pipeline-assembly-drawing-area.component.ts | 48 +-
...-assembly-options-pipeline-cache.component.html | 18 +-
...-assembly-options-pipeline-cache.component.scss | 4 +
.../pipeline-assembly-options.component.html | 30 +-
.../pipeline-element-icon-stand.component.html | 10 +-
.../pipeline-element-options.component.html | 10 +-
.../pipeline-element-preview.component.html | 4 +-
.../components/pipeline/pipeline.component.html | 2 +-
.../add-template-dialog.component.html | 4 +-
.../compatible-elements.component.html | 2 +-
.../dialog/customize/customize.component.html | 17 +-
.../matching-error/matching-error.component.html | 18 +-
.../missing-elements-for-tutorial.component.html | 14 +-
.../save-pipeline-settings.component.html | 19 +
.../save-pipeline-settings.component.ts | 46 +-
.../save-pipeline/save-pipeline.component.html | 11 +-
.../save-pipeline/save-pipeline.component.ts | 96 ++-
ui/src/app/editor/editor.component.html | 2 +-
ui/src/app/editor/editor.component.ts | 10 +-
ui/src/app/editor/editor.module.ts | 3 +
ui/src/app/editor/services/editor.service.ts | 6 +-
ui/src/app/home/components/status.component.scss | 7 +-
ui/src/app/home/home.component.html | 4 +-
.../components/auth-box/auth-box.component.html | 4 +-
.../login/components/login/login.component.html | 36 +-
.../components/register/register.component.html | 22 +-
.../restore-password.component.html | 26 +-
.../login/components/terms/terms.component.html | 4 +-
ui/src/app/login/login.module.ts | 2 +
.../app/notifications/notifications.component.html | 6 +-
ui/src/app/notifications/notifications.module.ts | 2 +
.../pipeline-details.component.html | 6 +
.../pipeline-details/pipeline-details.component.ts | 35 +-
.../pipeline-overview.component.html | 208 ++++---
.../pipeline-overview.component.ts | 2 +-
ui/src/app/pipelines/pipelines.module.ts | 2 +
.../profile/components/basic-profile-settings.ts | 12 +-
.../general-profile-settings.component.html | 43 +-
.../general/general-profile-settings.component.ts | 7 +
.../token/token-management-settings.component.html | 47 +-
ui/src/app/profile/profile.component.html | 16 +-
ui/src/app/profile/profile.module.ts | 4 +
ui/src/scss/sp/_variables.scss | 4 +
ui/src/scss/sp/buttons-mat3.scss | 2 +-
ui/src/scss/sp/layout.scss | 8 +
ui/src/scss/sp/main.scss | 6 +
ui/src/scss/sp/sp-theme.scss | 3 +-
649 files changed, 18163 insertions(+), 5682 deletions(-)
delete mode 100644 .github/workflows/osv-scanner.yml
create mode 100644 .mvn/develocity.xml
create mode 100644 .mvn/extensions.xml
delete mode 100644 VULNERABILITY.md
delete mode 100644 installer/compose/docker-compose.full.yml
rename installer/compose/{docker-compose.nats.yml => docker-compose.kafka.yml}
(69%)
delete mode 100644 installer/compose/docker-compose.pulsar.yml
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/variable/{StringEnvironmentVariable.java
=> DoubleEnvironmentVariable.java} (71%)
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/variable/{StringEnvironmentVariable.java
=> FloatEnvironmentVariable.java} (71%)
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/variable/{StringEnvironmentVariable.java
=> LongEnvironmentVariable.java} (79%)
create mode 100644
streampipes-commons/src/main/java/org/apache/streampipes/commons/prometheus/loadbalancer/LoadBalancerMetrics.java
create mode 100644
streampipes-commons/src/main/java/org/apache/streampipes/commons/prometheus/loadbalancer/LoadBalancerStats.java
create mode 100644
streampipes-commons/src/main/java/org/apache/streampipes/commons/prometheus/service/ElementServiceMetrics.java
create mode 100644
streampipes-commons/src/main/java/org/apache/streampipes/commons/prometheus/service/ElementServiceStats.java
copy
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/StreamPipesPrometheusConfig.java
=>
streampipes-commons/src/main/java/org/apache/streampipes/commons/prometheus/spmemorymanager/SpMemoryManagerMetrics.java
(54%)
create mode 100644
streampipes-commons/src/main/java/org/apache/streampipes/commons/prometheus/spmemorymanager/SpMemoryManagerStats.java
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/prometheus/{pipelines/PipelineFlowMetrics.java
=> spratelimiter/SpRateLimiterMetrics.java} (54%)
create mode 100644
streampipes-commons/src/main/java/org/apache/streampipes/commons/prometheus/spratelimiter/SpRateLimiterStats.java
copy
ui/src/app/configuration/security-configuration/alternate-id-configuration/alternate-id-configuration.component.ts
=>
streampipes-data-explorer-export/src/main/java/org/apache/streampipes/dataexplorer/export/ObjectStorge/ExportProviderFactory.java
(50%)
copy
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/Migration.java
=>
streampipes-data-explorer-export/src/main/java/org/apache/streampipes/dataexplorer/export/ObjectStorge/IObjectStorage.java
(76%)
create mode 100644
streampipes-data-explorer-export/src/main/java/org/apache/streampipes/dataexplorer/export/ObjectStorge/LocalFolder.java
create mode 100644
streampipes-data-explorer-export/src/main/java/org/apache/streampipes/dataexplorer/export/ObjectStorge/S3.java
create mode 100644
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/limiter/SpRateLimiter.java
create mode 100644
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/memorymanager/SpMemoryManager.java
create mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/monitoring/ServiceLoadDataReportGenerator.java
create mode 100644
streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/config/identity/X509IdentityConfig.java
copy
streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/migration/{OpcUaAdapterMigrationV3.java
=> OpcUaAdapterMigrationV6.java} (53%)
copy
streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/migration/{OpcUaSinkMigrationV1.java
=> OpcUaSinkMigrationV2.java} (91%)
delete mode 100644
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/containers/KafkaContainer.java
copy
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/containers/{KafkaDevContainer.java
=> SpKafkaTestContainer.java} (72%)
copy {streampipes-sdk-bundle => streampipes-load-balancer}/pom.xml (68%)
create mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/ExtensionServiceSelector.java
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/migration/IMigrationHandler.java
=>
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/LoadBalancer.java
(59%)
create mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/LoadBalancerConfig.java
create mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/LoadManager.java
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/migration/IMigrationHandler.java
=>
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/PipelineMigrator.java
(66%)
create mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/ResourceUnitMigration.java
create mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/ServiceLoadCalculator.java
create mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/impl/AbstractPipelineMigrator.java
create mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/impl/ExtensibleLoadManager.java
create mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/impl/MinimumLoadSelector.java
create mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/impl/OverloadMigrator.java
create mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/impl/ThresholdMigrator.java
create mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/impl/TransferMigrator.java
create mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/impl/WeightedFirstSelector.java
create mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/impl/WeightedRandomSelector.java
rename
{streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring
=>
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance}/pipeline/ExtensionsLogProvider.java
(84%)
rename
{streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring
=>
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance}/pipeline/ExtensionsServiceLogExecutor.java
(68%)
copy
{streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution
=>
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/service}/ExtensionServiceExecutions.java
(59%)
create mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/service/ExtensionsServiceReportExecutor.java
copy
{streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/endpoint
=>
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/unit}/ExtensionsServiceEndpointUtils.java
(97%)
create mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/unit/InvokeHttpRequest.java
create mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/unit/PipelineElementPartitioner.java
create mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/unit/ResourceUnitScanner.java
create mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/unit/ResourceUnitStatsScanner.java
copy
streampipes-model/src/main/java/org/apache/streampipes/model/configuration/{DefaultGeneralConfig.java
=> DefaultExportProviderConfig.java} (75%)
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/configuration/ExportProviderSettings.java
copy
streampipes-model/src/main/java/org/apache/streampipes/model/configuration/{JwtSigningMode.java
=> ProviderType.java} (94%)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/datalake/{DataLakeQueryOrdering.java
=> ExportConfig.java} (85%)
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/loadbalancer/LoadBalanceResourceUnit.java
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/loadbalancer/LoadBalanceResourceUnitStats.java
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/provider/CurrentPipelineElementProvider.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/loadbalancer/LoadBalancerConstants.java
(54%)
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/loadbalancer/ServiceLoadDataReport.java
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/loadbalancer/Usage.java
copy
streampipes-client/src/main/java/org/apache/streampipes/client/paths/ApiPath.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/runtime/ClientDisconnectCallback.java
(85%)
copy
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/monitoring/{MonitoringResource.java
=> ServiceMonitorResource.java} (73%)
create mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/admin/ExportProviderConfigurationResource.java
rename
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/{PipelineElementPreview.java
=> runtime/PipelinePreviewResource.java} (82%)
rename
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/{PipelineElementRuntimeInfo.java
=> runtime/StreamPreviewResource.java} (91%)
rename
{streampipes-service-core/src/main/java/org/apache/streampipes/service/core =>
streampipes-service-base/src/main/java/org/apache/streampipes/service/base}/StreamPipesPrometheusConfig.java
(96%)
copy
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/{v970/AddLinkSettingsMigration.java
=> v0980/AddDefaultExportProviderMigration.java} (62%)
create mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v0980/FixImportedPermissionsMigration.java
rename ui/cypress/support/utils/{datalake/DataLakeBtns.ts =>
dataExplorer/DataExplorerBtns.ts} (57%)
rename ui/cypress/support/utils/{datalake/DataLakeUtils.ts =>
dataExplorer/DataExplorerUtils.ts} (75%)
rename ui/cypress/support/utils/{datalake/DataLakeWidgetTableUtils.ts =>
dataExplorer/DataExplorerWidgetTableUtils.ts} (96%)
create mode 100644 ui/cypress/tests/connect/adapterWithAssets.spec.ts
create mode 100644
ui/cypress/tests/dataExplorer/addAssetToDashboard.smoke.spec.ts
create mode 100644
ui/cypress/tests/dataExplorer/addAssetsToDataView.smoke.spec.ts
rename ui/cypress/tests/{datalake/widgets =>
dataExplorer/charts}/heatmap.spec.ts (77%)
rename ui/cypress/tests/{datalake/widgets =>
dataExplorer/charts}/histogram.spec.ts (83%)
rename ui/cypress/tests/{datalake/widgets =>
dataExplorer/charts}/indicator.spec.ts (83%)
rename ui/cypress/tests/{datalake/widgets => dataExplorer/charts}/map.spec.ts
(85%)
rename ui/cypress/tests/{datalake/widgets =>
dataExplorer/charts}/scatter.smoke.spec.ts (79%)
rename ui/cypress/tests/{datalake/widgets =>
dataExplorer/charts}/table.spec.ts (76%)
rename ui/cypress/tests/{datalake/widgets =>
dataExplorer/charts}/timeSeriesSave.spec.ts (79%)
rename ui/cypress/tests/{datalake => dataExplorer}/configuration.smoke.spec.ts
(87%)
create mode 100644 ui/cypress/tests/dataExplorer/deleteViewAndDashboard.spec.ts
rename ui/cypress/tests/{datalake =>
dataExplorer}/filterNumericalStringProperties.spec.ts (71%)
rename ui/cypress/tests/{datalake =>
dataExplorer}/missingDataInDataLake.spec.ts (75%)
rename ui/cypress/tests/{datalake => dataExplorer}/timeOrderDataView.spec.ts
(71%)
rename ui/cypress/tests/{datalake => dataExplorer}/timeRangeSelectors.spec.ts
(92%)
create mode 100644
ui/cypress/tests/dataExplorer/widgetDataConfiguration.smoke.spec.ts
delete mode 100644 ui/cypress/tests/datalake/deleteViewAndDashboard.spec.ts
delete mode 100644 ui/cypress/tests/datalake/deleteWidget.ts
delete mode 100644
ui/cypress/tests/datalake/widgetDataConfiguration.smoke.spec.ts
create mode 100644 ui/cypress/tests/pipeline/pipelineAsset.spec.ts
create mode 100644 ui/develocity.config.js
copy
ui/projects/streampipes/platform-services/src/lib/apis/{certificate.service.ts
=> export-provider.service.ts} (53%)
delete mode 100644
ui/projects/streampipes/platform-services/src/lib/apis/pipeline.service.spec.ts
create mode 100644
ui/projects/streampipes/shared-ui/src/lib/components/asset-link-configuration/asset-link-configuration.component.html
copy
ui/projects/streampipes/shared-ui/src/lib/components/{asset-browser/asset-browser-hierarchy/asset-browser-hierarchy.component.scss
=> asset-link-configuration/asset-link-configuration.component.scss} (55%)
create mode 100644
ui/projects/streampipes/shared-ui/src/lib/components/asset-link-configuration/asset-link-configuration.component.ts
copy
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/annotation/NotYetImplemented.java
=>
ui/projects/streampipes/shared-ui/src/lib/components/sp-table/sp-table-actions.directive.ts
(83%)
create mode 100644
ui/projects/streampipes/shared-ui/src/lib/services/asset-configuration.service.ts
copy
ui/{projects/streampipes/shared-ui/src/lib/dialog/data-download-dialog/model/download-progress.model.ts
=>
src/app/configuration/dialog/data-retention-dialog/model/data-retention-provider.model.ts}
(90%)
delete mode 100644
ui/src/app/configuration/dialog/data-retention-dialog/services/data-export.service.ts
delete mode 100644
ui/src/app/configuration/dialog/data-retention-dialog/services/file-name.service.spec.ts
delete mode 100644
ui/src/app/configuration/dialog/data-retention-dialog/services/file-name.service.ts
copy
ui/src/app/configuration/dialog/{delete-datalake-index/delete-datalake-index-dialog.component.html
=> delete-export-provider/delete-export-provider-dialog.component.html} (71%)
copy
ui/src/app/configuration/dialog/{certificate-details/certificate-details-dialog.component.ts
=> delete-export-provider/delete-export-provider-dialog.component.ts} (53%)
create mode 100644
ui/src/app/configuration/dialog/export-provider-dialog/export-provider-dialog.component.html
create mode 100644
ui/src/app/configuration/dialog/export-provider-dialog/export-provider-dialog.component.ts
delete mode 100644
ui/src/app/connect/components/adapter-configuration/adapter-configuration-header/adapter-configuration-header.component.html
delete mode 100644
ui/src/app/connect/components/adapter-configuration/adapter-configuration-header/adapter-configuration-header.component.scss
delete mode 100644
ui/src/app/connect/components/adapter-configuration/adapter-configuration-header/adapter-configuration-header.component.ts
create mode 100644
ui/src/app/connect/services/adapter-asset-configuration.service.ts
delete mode 100644
ui/src/app/core-services/template/PipelineInvocationBuilder.ts
create mode 100644
ui/src/app/dashboard/dialogs/clone-dashboard/clone-dashboard-dialog.component.html
copy
ui/src/app/{editor/dialog/save-pipeline/save-pipeline-settings/save-pipeline-settings.component.scss
=> dashboard/dialogs/clone-dashboard/clone-dashboard-dialog.component.scss}
(99%)
create mode 100644
ui/src/app/dashboard/dialogs/clone-dashboard/clone-dashboard-dialog.component.ts
create mode 100644 ui/src/app/data-explorer/dialog/asset-dialog.component.html
create mode 100644 ui/src/app/data-explorer/dialog/asset-dialog.component.ts
