This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/pip/streampipes-client-python/pytest-8.4.2
in repository https://gitbox.apache.org/repos/asf/streampipes.git
omit c6ac99cdd5 chore(deps-dev): bump pytest in /streampipes-client-python
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 d866764436 feat: Bump PLC4X version, improve connection cache
management (#3744)
add 23257ffba9 fix(#3893): Fix handle failing plc read (#3899)
add 152862830f fix: Mark old mqtt based adapters as deprecated for future
removal (#3900)
add beae74fbb7 fix: Only admins can see dashboard permissions dialog
(#3901)
add 9c862aaf11 fix: Bump remaining snapshot versions to 0.99 (#3902)
add 349aff2a04 Role Management for Assets in create Tasks (#3897)
add ce6cab09d1 feat: Add more descriptive sidebar (#3891)
add 7a8a54b953 fix: Use relative imports
add 4d36a7259f chore(deps-dev): bump isort from 5.13.2 to 7.0.0 in
/streampipes-client-python (#3864)
add 15dc5d4c25 chore(deps-dev): bump pytest in /streampipes-client-python
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (c6ac99cdd5)
\
N -- N -- N
refs/heads/dependabot/pip/streampipes-client-python/pytest-8.4.2 (15dc5d4c25)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/workflows/extensions-docs.yml | 6 +-
.github/workflows/go-docs.yml | 2 +-
.github/workflows/pypi-deployment.yml | 2 +-
.github/workflows/python-docs.yml | 2 +-
.mvn/develocity.xml | 2 +-
.../streampipes-archetype-extensions-jvm/pom.xml | 2 +-
.../src/main/resources/archetype-resources/pom.xml | 2 +-
.../pom.xml | 2 +-
.../src/main/resources/archetype-resources/pom.xml | 2 +-
.../streampipes-archetype-pe-sinks-flink/pom.xml | 2 +-
.../src/main/resources/archetype-resources/pom.xml | 2 +-
installer/cli/.env | 2 +-
installer/cli/README.md | 2 +-
installer/compose/.env | 2 +-
installer/compose/README.md | 50 +-
...r-compose.full.yml => docker-compose.kafka.yml} | 39 +-
installer/compose/docker-compose.nats.yml | 114 ----
installer/compose/docker-compose.pulsar.yml | 109 ----
installer/compose/docker-compose.yml | 45 +-
installer/k8s/Chart.yaml | 2 +-
installer/k8s/README.md | 4 +-
installer/k8s/values.yaml | 2 +-
pom.xml | 16 +-
streampipes-client-api/pom.xml | 8 +-
streampipes-client-python/poetry.lock | 25 +-
streampipes-client-python/pyproject.toml | 4 +-
streampipes-client/pom.xml | 14 +-
streampipes-commons/pom.xml | 2 +-
.../apache/streampipes/commons/constants/Envs.java | 71 ++-
.../commons/environment/DefaultEnvironment.java | 172 +++++-
.../commons/environment/Environment.java | 95 +++-
.../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 | 47 +-
.../loadbalancer/LoadBalancerMetrics.java | 50 ++
.../prometheus/loadbalancer/LoadBalancerStats.java | 52 ++
.../prometheus/service/ElementServiceMetrics.java | 58 +--
.../prometheus/service/ElementServiceStats.java | 3 -
.../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 | 172 +++---
streampipes-connect-shared/pom.xml | 10 +-
streampipes-data-explorer-api/pom.xml | 8 +-
streampipes-data-explorer-export/pom.xml | 8 +-
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 +-
streampipes-data-export/pom.xml | 12 +-
.../export/dataimport/PerformImportGenerator.java | 12 +-
streampipes-dataformat/pom.xml | 4 +-
streampipes-extensions-api/pom.xml | 33 +-
.../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 +-
.../management/connect/PullAdapterScheduler.java | 5 +-
.../elements/SendToBrokerAdapterSink.java | 8 +-
.../monitoring/ServiceLoadDataReportGenerator.java | 102 ++--
streampipes-extensions/pom.xml | 4 +-
.../streampipes-connect-adapters-iiot/pom.xml | 10 +-
.../iiot/adapters/iolink/IfmAlMqttAdapter.java | 1 +
.../connect/iiot/adapters/oi4/Oi4Adapter.java | 6 +
.../streampipes-connect-adapters/pom.xml | 10 +-
.../connect/adapters/netio/NetioMQTTAdapter.java | 1 +
.../connect/adapters/netio/NetioRestAdapter.java | 1 +
.../connect/adapters/netio/NetioUtils.java | 1 +
.../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 +-
.../connectors/opcua/adapter/OpcUaNodeBrowser.java | 15 +-
.../opcua/migration/OpcUaAdapterMigrationV6.java | 3 +-
.../opcua/model/node/BasicVariableNodeInfo.java | 8 +-
.../model/nodename/NamingStrategyResolver.java | 4 +-
.../opcua/model/nodename/ParsedNodeIdResolver.java | 4 +-
.../opcua/model/nodename/SimpleNameResolver.java | 8 +-
.../opcua/utils/OpcUaNamingStrategy.java | 8 +-
.../connectors/opcua/utils/OpcUaTypes.java | 4 +-
.../streampipes-connectors-plc/pom.xml | 14 +-
.../connectors/plc/PlcConnectorsModuleExport.java | 4 +-
.../connection/ContinuousPlcRequestReader.java | 38 +-
.../generic/connection/PlcEventGenerator.java | 7 +-
.../generic/model/Plc4xConnectionExtractor.java | 11 +-
.../connectors/plc/adapter/s7/Plc4xS7Adapter.java | 2 +-
.../plc/cache/SpCachedPlcConnectionManager.java | 178 +++++++
.../plc/cache/SpConnectionContainer.java | 235 +++++++++
.../plc/cache/SpLeasedPlcConnection.java | 575 +++++++++++++++++++++
.../plc/adapter/ConnectionContainerReproTest.java | 167 ++++++
.../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 +-
.../pom.xml | 6 +-
.../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 | 22 +-
.../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 +-
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 | 9 +
streampipes-model-shared/pom.xml | 2 +-
streampipes-model/pom.xml | 8 +-
.../org/apache/streampipes/model/UserInfo.java | 9 +
.../model/connect/adapter/AdapterDescription.java | 1 +
.../model/datalake/DataLakeMeasure.java | 8 +
.../svcdiscovery/SpServiceRegistration.java | 17 +
.../svcdiscovery/SpServiceTagPrefix.java | 5 +
.../loadbalancer/LoadBalanceResourceUnit.java | 120 +++++
.../loadbalancer/LoadBalanceResourceUnitStats.java | 154 ++++++
.../model/loadbalancer/ServiceLoadDataReport.java | 249 +++++++--
.../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 +-
streampipes-resource-management/pom.xml | 8 +-
.../DataExplorerWidgetResourceManager.java | 2 +-
streampipes-rest-core-base/pom.xml | 10 +-
streampipes-rest-extensions/pom.xml | 8 +-
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/FunctionsResource.java | 2 +-
.../streampipes/rest/impl/PipelineMonitoring.java | 8 +-
.../streampipes/rest/impl/PipelineResource.java | 10 +-
.../impl/admin/ServiceRegistrationResource.java | 8 +-
.../rest/impl/connect/AdapterResource.java | 214 ++++----
.../rest/impl/connect/CompactAdapterResource.java | 2 +-
.../rest/impl/datalake/DataLakeWidgetResource.java | 2 +-
streampipes-sdk-bundle/pom.xml | 18 +-
streampipes-sdk/pom.xml | 10 +-
.../adapter/AdapterConfigurationBuilder.java | 4 +
streampipes-security-jwt/pom.xml | 4 +-
streampipes-serializers-json/pom.xml | 8 +-
streampipes-service-base/pom.xml | 6 +-
streampipes-service-core-minimal/pom.xml | 6 +-
streampipes-service-core/pom.xml | 28 +-
.../service/core/StreamPipesCoreApplication.java | 117 ++---
.../core/migrations/AvailableMigrations.java | 6 +-
.../AddDefaultExportProviderMigration.java} | 34 +-
.../v0980/FixImportedPermissionsMigration.java | 116 +++++
.../service/core/scheduler/DataLakeScheduler.java | 6 +-
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 | 2 +
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/support/utils/UserUtils.ts | 17 +
ui/cypress/support/utils/connect/ConnectBtns.ts | 4 +
.../support/utils/dataExplorer/DataExplorerBtns.ts | 10 +-
ui/cypress/support/utils/pipeline/PipelineBtns.ts | 12 +
.../{pipeline/PipelineBtns.ts => user/UserBtns.ts} | 22 +-
ui/cypress/tests/pipeline/pipelineAsset.spec.ts | 2 +-
.../tests/userManagement/testUserRoleAsset.spec.ts | 139 +++++
ui/deployment/base-navigation.component.mst | 70 ++-
.../Dockerfile => ui/deployment/categories.yml | 17 +-
ui/deployment/home.service.mst | 2 +-
ui/deployment/i18n/de.json | 172 +++++-
ui/deployment/i18n/en.json | 159 +++++-
ui/deployment/modules.yml | 35 +-
ui/deployment/prebuild.js | 15 +-
ui/deployment/theme/_custom-variables.scss | 22 +-
ui/develocity.config.js | 95 +++-
ui/package-lock.json | 4 +-
ui/package.json | 2 +-
.../src/lib/model/gen/streampipes-model-client.ts | 7 +-
.../src/lib/model/gen/streampipes-model.ts | 5 +-
.../src/lib/model/types/data-type.ts | 11 +
...sset-browser-filter-asset-model.component.html} | 14 +-
.../asset-browser-filter-asset-model.component.ts} | 22 +-
.../asset-browser-filter-labels.component.html | 81 +--
.../asset-browser-filter-labels.component.ts | 8 +
.../asset-browser-filter.component.html | 5 +
.../asset-browser-filter.component.ts | 7 +-
.../asset-browser-toolbar.component.html | 64 ++-
.../asset-browser-toolbar.component.scss} | 25 +-
.../asset-browser-toolbar.component.ts | 54 +-
.../asset-browser/asset-browser.model.ts | 11 +
.../asset-browser/asset-browser.service.ts | 156 ++++--
.../basic-inner-panel.component.html | 1 +
.../basic-inner-panel.component.scss | 18 +-
.../basic-inner-panel.component.ts | 3 +
.../basic-nav-tabs/basic-nav-tabs.component.html | 15 +-
.../basic-nav-tabs/basic-nav-tabs.component.scss | 10 +-
.../basic-view/basic-view.component.html | 6 +-
.../basic-view/basic-view.component.scss | 8 +-
.../split-section/split-section.component.html | 2 +-
.../split-section/split-section.component.scss | 2 +-
.../shared-ui/src/lib/shared-ui.module.ts | 3 +
.../streampipes/shared-ui/src/public-api.ts | 1 +
.../asset-overview/asset-overview.component.html | 2 +-
.../datalake-configuration.component.html | 7 +-
.../datalake-configuration.component.ts | 40 +-
.../select-export/select-format.component.ts | 2 +-
.../select-data-retention.component.html | 2 +-
.../data-retention-dialog.component.html | 2 +-
.../data-retention-dialog.component.ts | 14 +-
.../delete-export-provider-dialog.component.ts | 2 +-
.../export-provider-dialog.component.html | 47 +-
.../export-provider-dialog.component.ts | 8 +-
.../security-user-config.component.html | 6 +-
.../adapter-configuration.component.html | 22 +-
.../adapter-configuration.component.ts | 6 +
.../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 +-
.../start-adapter-configuration.component.html | 118 +++--
.../start-adapter-configuration.component.ts | 27 +-
.../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 +-
.../adapter-description.component.html | 8 +-
.../data-marketplace.component.html | 4 +-
.../existing-adapters.component.html | 561 +++++++++-----------
.../existing-adapters.component.ts | 76 +--
.../filter-toolbar/filter-toolbar.component.html | 19 +-
.../filter-toolbar/filter-toolbar.component.ts | 4 -
.../adapter-started-dialog.component.html | 2 +-
.../adapter-started-dialog.component.ts | 16 +-
...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 +-
.../app/core/collapse.service.ts} | 30 +-
ui/src/app/core/components/bars.scss | 34 --
.../breadcrumb/breadcrumb.component.scss | 5 +-
.../components/breadcrumb/breadcrumb.component.ts | 28 +-
.../core/components/iconbar/iconbar.component.html | 151 ++++--
.../core/components/iconbar/iconbar.component.scss | 251 +++++++++
.../core/components/iconbar/iconbar.component.ts | 2 +-
.../streampipes/streampipes.component.html | 24 +-
.../streampipes/streampipes.component.scss | 57 +-
.../streampipes/streampipes.component.ts | 31 +-
.../core/components/toolbar/toolbar.component.html | 47 +-
.../core/components/toolbar/toolbar.component.scss | 17 +-
.../core/components/toolbar/toolbar.component.ts | 5 +-
ui/src/app/core/core.module.ts | 2 +
ui/src/app/core/navigation.backup | 220 ++++++++
.../dashboard-overview-table.component.html | 7 +-
.../dashboard-overview-table.component.ts | 56 +-
.../overview/dashboard-overview.component.html | 60 +--
.../overview/dashboard-overview.component.ts | 17 +-
.../panel/dashboard-panel.component.html | 177 ++++---
.../components/panel/dashboard-panel.component.ts | 12 +-
.../edit-dashboard-dialog.component.html | 69 +--
.../edit-dashboard-dialog.component.ts | 15 +-
.../data-explorer-chart-container.component.html | 27 +-
.../data-explorer-chart-view.component.html | 94 ++--
.../data-explorer-chart-view.component.ts | 47 +-
...data-explorer-chart-view-toolbar.component.html | 22 +-
.../data-explorer-chart-view-toolbar.component.ts | 26 +-
.../data-explorer-overview-table.component.ts | 52 +-
.../overview/data-explorer-overview.component.html | 60 +--
.../overview/data-explorer-overview.component.ts | 32 +-
.../overview/data-explorer-overview.directive.ts | 59 ---
.../save-pipeline-settings.component.html | 38 +-
.../save-pipeline-settings.component.ts | 11 +
.../save-pipeline/save-pipeline.component.html | 9 +-
ui/src/app/editor/editor.component.ts | 10 +-
.../components/auth-box/auth-box.component.html | 4 +-
.../components/auth-box/auth-box.component.scss | 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 +
.../pipeline-details.component.html | 6 +
.../pipeline-details/pipeline-details.component.ts | 35 +-
.../pipeline-overview.component.html | 67 +--
ui/src/app/pipelines/pipelines.component.html | 177 +++----
ui/src/app/pipelines/pipelines.component.ts | 69 +--
.../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 | 8 +-
ui/src/app/profile/profile.module.ts | 4 +
ui/src/scss/sp/_variables.scss | 2 +
ui/src/scss/sp/buttons-mat3.scss | 14 +-
ui/src/scss/sp/layout.scss | 2 -
ui/src/scss/sp/main.scss | 11 -
389 files changed, 11433 insertions(+), 3559 deletions(-)
rename installer/compose/{docker-compose.full.yml => docker-compose.kafka.yml}
(83%)
delete mode 100644 installer/compose/docker-compose.nats.yml
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
copy
streampipes-service-base/src/main/java/org/apache/streampipes/service/base/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
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/streampipes-connectors-plc/src/main/java/org/apache/streampipes/extensions/connectors/plc/cache/SpCachedPlcConnectionManager.java
create mode 100644
streampipes-extensions/streampipes-connectors-plc/src/main/java/org/apache/streampipes/extensions/connectors/plc/cache/SpConnectionContainer.java
create mode 100644
streampipes-extensions/streampipes-connectors-plc/src/main/java/org/apache/streampipes/extensions/connectors/plc/cache/SpLeasedPlcConnection.java
create mode 100644
streampipes-extensions/streampipes-connectors-plc/src/test/java/org/apache/streampipes/extensions/connectors/plc/adapter/ConnectionContainerReproTest.java
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
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-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
copy ui/cypress/support/utils/{pipeline/PipelineBtns.ts => user/UserBtns.ts}
(59%)
create mode 100644 ui/cypress/tests/userManagement/testUserRoleAsset.spec.ts
copy
archetypes/streampipes-archetype-pe-processors-flink/src/main/resources/archetype-resources/Dockerfile
=> ui/deployment/categories.yml (78%)
copy
ui/projects/streampipes/shared-ui/src/lib/components/asset-browser/asset-browser-toolbar/asset-browser-filter/{asset-browser-filter-sites/asset-browser-filter-sites.component.html
=>
asset-browser-filter-asset-model/asset-browser-filter-asset-model.component.html}
(81%)
copy
ui/projects/streampipes/shared-ui/src/lib/components/asset-browser/asset-browser-toolbar/asset-browser-filter/{asset-browser-filter-sites/asset-browser-filter-sites.component.ts
=>
asset-browser-filter-asset-model/asset-browser-filter-asset-model.component.ts}
(70%)
copy
ui/{src/app/data-explorer/components/overview/data-explorer-overview.component.scss
=>
projects/streampipes/shared-ui/src/lib/components/asset-browser/asset-browser-toolbar/asset-browser-toolbar.component.scss}
(82%)
copy
ui/{projects/streampipes/platform-services/src/lib/services/pipeline-element-icon-text.service.ts
=> src/app/core/collapse.service.ts} (61%)
delete mode 100644 ui/src/app/core/components/bars.scss
create mode 100644 ui/src/app/core/navigation.backup
delete mode 100644
ui/src/app/data-explorer/components/overview/data-explorer-overview.directive.ts
