This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a change to branch test-uns
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 8c65f6f558 feat: Add topic selection based on asset model
add f069bb6976 refactor: Improve StreamPipesFunction monitoring (#4269)
add a708d2f868 fix: fix cypress e2e tests (#4268)
add 75e4d76578 refactor: migrate core-ui components to signals (#4267)
add 80ae050bb7 feat(#4252): Support broker-based core-extension
communication mode (#4242)
add d02f04d242 fix: Use pinned Github actions versions
add 8c94b54051 chore(deps): bump nats-py from 2.11.0 to 2.14.0 in
/streampipes-client-python (#4199)
add 0a504e4f3b fix(#4270): add cancel navigation option to unsaved changes
warning for chartsdashboards (#4272)
add 9bbfee0992 feat: Improve indicator widget (#4211)
add 63e8eec7cb fix: Remove Maven deploy skip from connectors-iiot module
(#4275)
add cb75562f21 chore(deps): bump docker/setup-qemu-action from 3.6.0 to
4.0.0 (#4277)
add 261499b5e3 chore(deps): bump docker/login-action from 3.7.0 to 4.0.0
(#4280)
add 89fe82a202 chore(deps): bump docker/setup-buildx-action from 3.12.0 to
4.0.0 (#4279)
add e0a80ba87c chore(deps): bump docker/build-push-action from 6.19.2 to
7.0.0 (#4278)
add a9b6cd3eae fix(#4281): honor env values in getValueOrResolve (#4282)
add 48c604c5bd fix: Add missing service id to adapter description (#4283)
add 7e68b8dda6 feat: Improve dashboard appearance (#4276)
add 6b2869385d fix: redesign auto aggregation for client limits (#4274)
new 2069b816ac Merge branch 'dev' into test-uns
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/build.yml | 18 +-
.github/workflows/go-client-e2e-test.yml | 2 +-
.github/workflows/mvn-integration-test.yml | 2 +-
installer/cli/.env | 3 +
installer/cli/README.md | 8 +
.../deploy/standalone/backend/docker-compose.yml | 1 +
.../extensions-all-jvm/docker-compose.yml | 1 +
.../{nats => nats-auth}/docker-compose.dev.yml | 0
.../{nats => nats-auth}/docker-compose.yml | 3 +
.../environments/{backend => backend-nats-auth} | 2 +-
.../cli/environments/{basic => basic-nats-auth} | 2 +-
.../cli/environments/{lite => lite-nats-auth} | 2 +-
...ine-element-nats => pipeline-element-nats-auth} | 2 +-
installer/compose/.env | 4 +
installer/compose/README.md | 14 +-
.../docker-compose.minimal.nats-auth.yml} | 26 +-
.../docker-compose.nats-auth.yml} | 16 +-
pom.xml | 8 +-
.../apache/streampipes/client/api/IAdminApi.java | 3 -
streampipes-client-e2e/docker-compose.yml | 2 +
.../go-client-e2e/pipelines/pipelines.json | 96 +---
.../streampipes/model/pipeline/pipeline.go | 2 -
streampipes-client-python/poetry.lock | 7 +-
.../apache/streampipes/client/api/AdminApi.java | 12 -
.../apache/streampipes/commons/constants/Envs.java | 7 +
.../commons/environment/DefaultEnvironment.java | 20 +
.../commons/environment/Environment.java | 8 +
.../environment/variable/EnvironmentVariable.java | 2 +-
.../variable/EnvironmentVariableTest.java | 73 +++
.../management/compact/AdapterGenerationSteps.java | 8 +-
.../management/compact/PersistPipelineHandler.java | 6 +-
.../management/AdapterMasterManagement.java | 40 +-
.../management/AdapterMigrationManager.java | 27 +-
.../management/AdapterUpdateManagement.java | 19 +-
.../management/DescriptionManagement.java | 22 +-
.../management/management/GuessManagement.java | 41 +-
.../management/WorkerAdministrationManagement.java | 8 +-
.../management/management/WorkerRestClient.java | 182 ++++---
.../connect/management/util/WorkerPaths.java | 51 --
.../management/AdapterMasterManagementTest.java | 26 +-
streampipes-connect-shared/pom.xml | 6 -
.../dataexplorer/AutoAggregationHandler.java | 207 +++++---
.../dataexplorer/QueryResultProvider.java | 3 +-
.../dataexplorer/param/model/SelectColumn.java | 4 +
.../dataexplorer/AutoAggregationHandlerTest.java | 170 +++++++
.../streampipes/export/AssetLinkResolver.java | 12 +-
.../apache/streampipes/export/ExportManager.java | 12 +-
.../apache/streampipes/export/ImportManager.java | 12 +-
.../export/dataimport/PerformImportGenerator.java | 10 +-
.../export/dataimport/PreviewImportGenerator.java | 14 +-
.../export/generator/ExportPackageGenerator.java | 10 +-
.../export/resolver/AdapterResolver.java | 12 +-
.../export/resolver/PipelineResolver.java | 9 +-
.../export/utils/EventGroundingProcessor.java | 77 +--
.../management/ExtensionAdapterManagement.java | 4 +-
.../management/connect/AdapterAssetManagement.java | 71 +++
...ider.java => AdapterDescriptionManagement.java} | 41 +-
.../connect/AdapterWorkerRequestManagement.java | 77 +++
.../AdapterWorkerSampleDataRequestManagement.java | 69 +++
.../connect/ConnectWorkerDescriptionProvider.java | 8 +-
.../HttpServerAdapterRequestManagement.java | 17 +-
.../connect/RuntimeResolvableManagement.java | 55 +++
.../elements/SendToBrokerAdapterSink.java | 15 +-
.../management/init/DeclarersSingleton.java | 31 +-
.../migration/AbstractMigrationHandler.java | 67 +--
.../migration/AdapterMigrationHandler.java | 14 +-
.../migration/DataProcessorMigrationHandler.java | 28 +-
.../migration/DataSinkMigrationHandler.java | 20 +-
.../extensions/management}/model/Description.java | 2 +-
.../management/model/SpServiceDefinition.java | 4 -
.../monitoring/HealthCheckManagement.java | 41 +-
.../monitoring/MonitoringManagement.java | 29 +-
.../monitoring/ServiceMonitorManagement.java | 32 +-
.../pe/AbstractPipelineElementManagement.java | 84 ++++
.../pe/DataProcessorPipelineElementManagement.java | 19 +-
.../pe/DataSinkPipelineElementManagement.java | 18 +-
.../DataStreamPipelineElementManagement.java} | 27 +-
.../pe/InvocablePipelineElementManagement.java | 158 ++++++
.../management/init/DeclarersSingletonTest.java | 6 +-
.../streampipes-connect-adapters-iiot/pom.xml | 4 -
.../extensions/all/iiot/AllExtensionsIIoTInit.java | 2 -
.../extensions/all/jvm/AllExtensionsInit.java | 2 -
.../siddhi/trend/TestTrendProcessor.java | 2 -
.../streampipes-sinks-brokers-jvm/pom.xml | 9 +-
.../sinks/brokers/jvm}/jms/ActiveMQPublisher.java | 38 +-
.../sinks/brokers/jvm}/jms/ActiveMQUtils.java | 9 +-
.../sinks/brokers/jvm/jms/JmsPublisherSink.java | 7 +-
.../sinks/internal/jvm/datalake/DataLakeSink.java | 2 +-
.../INotificationDataSinkMigratorTest.java | 6 +-
.../notifications/jvm/msteams/TestMSTeamsSink.java | 10 +-
.../health/monitoring/AdapterHealthCheck.java | 1 -
.../health/monitoring/ExtensionHealthCheck.java | 19 +-
.../ExtensionInstanceAvailabilityCheck.java | 46 +-
.../health/monitoring/PipelineHealthCheck.java | 19 +-
.../health/monitoring/ResourceProvider.java | 8 +-
.../health/monitoring/ServiceHealthCheck.java | 21 +-
.../monitoring/ServiceRegistrationManager.java | 8 +-
.../service/ExtensionServiceExecutions.java | 86 ----
.../service/ExtensionsServiceReportExecutor.java | 39 +-
streampipes-messaging-jms/pom.xml | 54 ---
.../messaging/jms/ActiveMQConnectionProvider.java | 49 --
.../messaging/jms/ActiveMQConsumer.java | 111 -----
.../streampipes/messaging/jms/SpJmsProtocol.java | 37 --
.../messaging/jms/SpJmsProtocolFactory.java | 42 --
.../messaging/kafka/SpKafkaConsumer.java | 2 +-
.../messaging/kafka/SpKafkaProducer.java | 6 +-
.../messaging/nats/AbstractNatsConnector.java | 17 +-
.../streampipes/messaging/SpProtocolManager.java | 4 -
.../streampipes/model/api/EndpointSelectable.java | 4 +
.../model/base/ConsumableStreamPipesEntity.java | 15 -
.../model/base/InvocableStreamPipesEntity.java | 23 +-
.../configuration/DefaultMessagingSettings.java | 71 ---
.../configuration/DefaultSpCoreConfiguration.java | 1 -
.../model/configuration/MessagingSettings.java | 187 --------
.../model/configuration/SpCoreConfiguration.java | 9 -
.../model/configuration/SpProtocol.java | 1 -
.../model/connect/adapter/AdapterDescription.java | 10 +
.../svcdiscovery/SpServiceTagPrefix.java | 9 -
.../ExtensionServiceBrokerErrorEnvelope.java} | 20 +-
.../transport/ExtensionServiceBrokerOperation.java | 32 +-
.../ExtensionServiceBrokerOperations.java | 70 +++
.../ExtensionServiceBrokerRequestEnvelope.java | 72 +++
.../ExtensionServiceBrokerResponseEnvelope.java | 90 ++++
.../transport/ExtensionServiceBrokerTopics.java | 158 ++++++
.../ExtensionServicePipelineDetachRequest.java} | 32 +-
.../transport/ExtensionServiceTransportMode.java | 35 +-
.../model/graph/DataProcessorDescription.java | 2 -
.../model/graph/DataProcessorInvocation.java | 3 -
.../model/graph/DataSinkDescription.java | 2 -
.../model/graph/DataSinkInvocation.java | 3 -
.../model/grounding/JmsTransportProtocol.java | 53 ---
.../model/grounding/KafkaTransportProtocol.java | 7 +
.../model/grounding/MqttTransportProtocol.java | 7 +
.../model/grounding/NatsTransportProtocol.java | 17 +
.../model/grounding/PulsarTransportProtocol.java | 7 +
.../model/grounding/TransportFormat.java | 54 ---
.../model/grounding/TransportProtocol.java | 3 +-
.../org/apache/streampipes/model/util/Cloner.java | 3 -
.../ExtensionServiceBrokerTopicsTest.java | 87 ++++
.../ExtensionServiceTransportModeTest.java | 52 ++
streampipes-nats-extensions/README.md | 123 +++++
.../pom.xml | 30 +-
.../ExtensionBrokerOperationHandler.java | 18 +-
.../extensions/ExtensionBrokerRequestContext.java | 5 +-
.../extensions/ExtensionBrokerRequestReceiver.java | 372 +++++++++++++++
.../operation/ExtensionBrokerConstants.java | 26 +-
.../operation/ExtensionBrokerResponseFactory.java | 110 +++++
.../operation/ExtensionBrokerTopicParser.java | 92 ++++
.../connect/AdapterAssetOperationHandler.java | 96 ++++
.../AdapterStateChangeOperationHandler.java | 92 ++++
.../connect/RuntimeOptionsOperationHandler.java | 115 +++++
.../connect/SampleDataOperationHandler.java | 104 ++++
.../function/FunctionStopOperationHandler.java | 67 +++
.../migration/MigrationOperationHandler.java | 141 ++++++
.../ExtensionInstanceHealthOperationHandler.java | 69 +++
.../monitoring/ServiceHealthOperationHandler.java | 69 +++
.../monitoring/ServiceLoadOperationHandler.java | 55 +++
.../ContainerProvidedOptionsOperationHandler.java | 136 ++++++
.../operation/pe/DescriptionOperationHandler.java | 125 +++++
.../operation/pe/OutputSchemaOperationHandler.java | 150 ++++++
.../pe/PipelineElementAssetsOperationHandler.java | 165 +++++++
.../pe/PipelineElementDetachOperationHandler.java | 120 +++++
.../PipelineElementInvocationOperationHandler.java | 120 +++++
.../operation/ExtensionBrokerTopicParserTest.java | 88 ++++
.../connect/AdapterAssetOperationHandlerTest.java | 129 +++++
...r.java => ExtensionServiceOperationResult.java} | 28 +-
.../api/extensions/ExtensionServiceRequest.java | 53 +++
.../extensions/ExtensionServiceRequestManager.java | 11 +-
.../extensions/ExtensionServiceRequestMethod.java | 9 +-
.../extensions/ExtensionServiceRequestTarget.java | 94 ++++
.../extensions/ExtensionServiceRequestTargets.java | 257 ++++++++++
.../api/extensions/ExtensionServiceRequests.java | 133 ++++++
.../IExtensionsServiceEndpointGenerator.java | 19 +-
.../streampipes/manager/assets/AssetFetcher.java | 34 +-
.../streampipes/manager/assets/AssetManager.java | 6 +-
.../execution/ExtensionServiceExecutions.java | 75 ---
.../HttpExtensionServiceRequestManager.java | 107 +++++
.../execution/PipelineExecutionTaskFactory.java | 11 +-
.../manager/execution/PipelineExecutor.java | 10 +-
.../ExtensionsServiceEndpointGenerator.java | 29 +-
.../http/BasePipelineElementSubmitter.java | 16 +-
.../execution/http/DetachExtensionRequest.java | 65 +++
.../manager/execution/http/DetachHttpRequest.java | 42 --
.../http/DetachPipelineElementSubmitter.java | 6 +-
...ttpRequest.java => InvokeExtensionRequest.java} | 37 +-
.../http/InvokePipelineElementSubmitter.java | 9 +-
...t.java => PipelineElementExtensionRequest.java} | 46 +-
.../execution/task/DiscoverEndpointsTask.java | 12 +-
.../manager/extensions/ExtensionItemInstaller.java | 41 +-
.../extensions/ExtensionsResourceUrlProvider.java | 74 ---
.../manager/function/FunctionManager.java | 34 +-
.../manager/matching/GroundingSelector.java | 46 --
.../matching/PipelineVerificationHandlerV2.java | 8 +-
.../manager/matching/ProtocolSelector.java | 103 +---
.../CustomTransformOutputSchemaGenerator.java | 50 +-
.../matching/output/OutputSchemaFactory.java | 12 +-
.../manager/matching/v2/ElementVerification.java | 52 --
.../manager/matching/v2/GroundingMatch.java | 53 ---
.../manager/matching/v2/ProtocolMatch.java | 44 --
.../manager/matching/v2/StreamMatch.java | 16 +-
.../matching/v2/pipeline/ApplyGroundingStep.java | 58 +--
.../matching/v2/pipeline/ComputeOutputStep.java | 9 +-
.../v2/pipeline/PipelineValidationSteps.java | 6 +-
.../migration/AbstractMigrationManager.java | 61 ++-
.../AdapterDescriptionMigration093Provider.java | 45 --
.../manager/migration/MigrationUtils.java | 11 +-
.../migration/PipelineElementMigrationManager.java | 34 +-
.../pipeline/ExtensionsServiceLogExecutor.java | 74 +--
.../manager/pipeline/PipelineManager.java | 16 +-
.../compact/CompactPipelineManagement.java | 8 +-
.../manager/preview/PipelinePreview.java | 41 +-
.../manager/recommender/ElementRecommender.java | 10 +-
.../remote/ContainerProvidedOptionsHandler.java | 33 +-
.../runtime/DataStreamRuntimeInfoProvider.java | 10 +
.../manager/setup/AutoInstallation.java | 11 +-
.../manager/setup/ExtensionsInstallationTask.java | 9 +-
.../manager/setup/InstallationConfiguration.java | 11 +-
.../setup/PipelineElementInstallationStep.java | 23 +-
.../compact/CompactPipelineTemplateManagement.java | 8 +-
.../streampipes/manager}/util/GroundingUtils.java | 95 ++--
.../manager/verification/TypedElementVerifier.java | 12 +-
.../verification/extractor/TypeExtractor.java | 14 +-
.../manager/matching/v2/TestGroundingMatch.java | 78 ---
.../manager/matching/v2/TestProtocolMatch.java | 55 ---
.../streampipes/manager/matching/v2/TestUtils.java | 34 --
.../manager/verification/TypeExtractorTest.java | 15 +-
streampipes-rest-extensions/pom.xml | 15 -
.../AbstractPipelineElementResource.java | 102 +---
.../streampipes/rest/extensions/WelcomePage.java | 72 ---
.../extensions/connect/AdapterAssetResource.java | 62 ++-
.../connect/AdapterDescriptionResource.java | 48 +-
.../extensions/connect/AdapterWorkerResource.java | 36 +-
.../connect/AdapterWorkerSampleDataResource.java | 10 +-
.../connect/HttpServerAdapterResource.java | 14 +-
.../connect/RuntimeResolvableResource.java | 31 +-
.../rest/extensions/html/HTMLGenerator.java | 82 ----
.../rest/extensions/html/JSONGenerator.java | 61 ---
.../extensions/html/page/WelcomePageGenerator.java | 154 ------
.../migration/AdapterMigrationResource.java | 28 +-
.../migration/DataProcessorMigrationResource.java | 28 +-
.../migration/DataSinkMigrationResource.java | 29 +-
.../extensions/monitoring/HealthCheckResource.java | 40 +-
.../extensions/monitoring/MonitoringResource.java | 18 +-
.../monitoring/ServiceMonitorResource.java | 15 +-
.../pe/DataProcessorPipelineElementResource.java | 52 +-
.../pe/DataSinkPipelineElementResource.java | 50 +-
.../pe/DataStreamPipelineElementResource.java | 20 +-
.../pe/InvocablePipelineElementResource.java | 121 +----
.../migration/MigrateExtensionsResourceTest.java | 13 +-
.../apache/streampipes/rest/ResetManagement.java | 25 +-
.../rest/impl/AbstractMonitoringResource.java | 11 +-
.../rest/impl/AdapterMonitoringResource.java | 10 +-
.../rest/impl/CompactPipelineResource.java | 10 +-
.../rest/impl/ContainerProvidedOptions.java | 9 +-
.../streampipes/rest/impl/PipelineMonitoring.java | 12 +-
.../streampipes/rest/impl/PipelineResource.java | 16 +-
.../streampipes/rest/impl/PipelineTemplate.java | 6 +-
.../streampipes/rest/impl/ResetResource.java | 21 +-
.../rest/impl/admin/DataExportResource.java | 11 +-
.../rest/impl/admin/DataImportResource.java | 15 +-
.../impl/admin/ExtensionsInstallationResource.java | 34 +-
.../admin/ExtensionsServiceEndpointResource.java | 51 +-
.../impl/admin/MessagingConfigurationResource.java | 55 ---
.../rest/impl/admin/MigrationResource.java | 19 +-
.../rest/impl/connect/AdapterResource.java | 18 +-
.../rest/impl/connect/CompactAdapterResource.java | 31 +-
.../rest/impl/connect/DescriptionResource.java | 23 +-
.../rest/impl/connect/GuessResource.java | 6 +-
.../impl/connect/RuntimeResolvableResource.java | 8 +-
.../importer/CsvDataLakeImportService.java | 11 +-
.../importer/CsvImportValidationService.java | 2 +
.../rest/impl/runtime/PipelinePreviewResource.java | 10 +-
.../importer/CsvDataLakeImportServiceTest.java | 52 ++
.../importer/CsvImportValidationServiceTest.java | 28 +-
streampipes-sdk-bundle/pom.xml | 5 -
.../builder/AbstractProcessingElementBuilder.java | 37 --
.../apache/streampipes/sdk/helpers/Protocols.java | 14 -
.../sdk/helpers/SupportedProtocols.java | 62 ---
streampipes-service-core-minimal/pom.xml | 4 -
streampipes-service-core/pom.xml | 5 -
.../streampipes/service/core/PostStartupTask.java | 24 +-
.../service/core/StreamPipesCoreApplication.java | 98 ++--
.../extensions/CoreExtensionTransportMode.java | 26 +-
.../extensions/CoreNatsRequestReplyClient.java | 111 +++++
.../ExtensionServiceRequestConfiguration.java | 88 ++++
.../NatsExtensionServiceRequestManager.java | 124 +++++
...ansportAwareExtensionServiceRequestManager.java | 109 +++++
.../svcdiscovery/api/ISpServiceDiscovery.java | 12 -
.../api/model/SpServiceUrlProvider.java | 12 -
.../svcdiscovery/SpServiceDiscoveryCore.java | 13 -
streampipes-service-extensions/pom.xml | 5 +
.../StreamPipesExtensionsServiceBase.java | 70 ++-
.../test/generator/InvocationGraphGenerator.java | 2 -
.../distributed/runtime/DistributedRuntime.java | 9 -
.../standalone/function/StreamPipesFunction.java | 22 +-
.../standalone/manager/ProtocolManager.java | 17 +-
ui/cypress/fixtures/datalake/missingData.json | 7 -
ui/cypress/support/utils/chart/ChartBtns.ts | 48 ++
ui/cypress/support/utils/chart/ChartUtils.ts | 18 +
.../support/utils/chart/ChartWidgetTableUtils.ts | 10 +
.../support/utils/dataset/DataLakeSeedUtils.ts | 188 +++++---
ui/cypress/support/utils/dataset/DatasetUtils.ts | 17 +
ui/cypress/tests/chart/autoAggregateTable.spec.ts | 100 ++++
.../tests/chart/chart-types/indicator.spec.ts | 20 +-
.../tests/chart/dynamicColumnFilter.smoke.spec.ts | 5 +-
.../chart/filterNumericalStringProperties.spec.ts | 4 +-
.../tests/chart/missingDataInDataLake.spec.ts | 20 +-
ui/cypress/tests/dataset/csvImport.spec.ts | 2 +
.../tests/pipeline/pipelineMultiSelect.spec.ts | 6 +-
.../userManagement/testGroupManagement.spec.ts | 7 -
ui/deployment/i18n/de.json | 1 +
ui/deployment/i18n/en.json | 1 +
ui/deployment/i18n/pl.json | 1 +
.../lib/query/data-view-query-generator.service.ts | 6 +-
.../asset-browser-filter-asset-model.component.ts | 2 -
.../asset-browser-filter-labels.component.ts | 2 -
.../asset-browser-filter-sites.component.ts | 2 -
.../asset-browser-filter-type.component.ts | 2 -
.../confirm-dialog/confirm-dialog.component.html | 53 ++-
.../confirm-dialog/confirm-dialog.component.scss | 4 +
.../confirm-dialog/confirm-dialog.component.ts | 20 +-
.../dialog/confirm-dialog/confirm-dialog.model.ts | 12 +-
.../streampipes/shared-ui/src/public-api.ts | 1 +
.../asset-overview/asset-overview.component.ts | 5 +-
.../chart-container/chart-container.component.ts | 6 +
.../base/base-data-explorer-widget.directive.ts | 2 +
.../charts/base/echarts-widget.component.ts | 40 +-
.../charts/gauge/gauge-renderer.service.ts | 74 ++-
.../indicator-appearance-config.component.html | 45 ++
.../indicator-appearance-config.component.ts | 85 ++++
.../indicator-chart-widget-config.component.html | 31 +-
.../indicator-chart-widget-config.component.ts | 18 +-
.../indicator/indicator-group-card.component.html | 78 +++
.../indicator/indicator-group-card.component.scss | 138 ++++++
.../indicator/indicator-group-card.component.ts | 160 +++++++
.../charts/indicator/indicator-renderer.service.ts | 125 -----
.../indicator/indicator-widget.component.html | 93 ++++
.../indicator/indicator-widget.component.scss} | 62 ++-
.../charts/indicator/indicator-widget.component.ts | 530 +++++++++++++++++++++
.../model/indicator-chart-widget.model.ts | 12 +-
.../components/charts/pie/pie-renderer.service.ts | 60 +++
.../table/config/table-widget-config.component.ts | 3 +-
.../charts/table/table-widget.component.html | 1 +
.../sp-timeseries-renderer.service.ts | 95 +++-
.../models/dataview-dashboard.model.ts | 5 +
.../registry/chart-registry.service.ts | 11 +-
.../chart-overview-table.component.ts | 5 +-
.../chart-view/chart-view.component.html | 1 +
.../components/chart-view/chart-view.component.ts | 71 ++-
.../chart-data-settings.component.html | 13 +-
.../chart-data-preview.component.ts | 4 +
.../configuration-sections.providers.ts | 10 -
.../endpoint-item/endpoint-item.component.html | 29 +-
.../endpoint-item/endpoint-item.component.scss | 122 ++++-
.../endpoint-item/endpoint-item.component.ts | 27 +-
.../extensions-installation.component.html | 5 +-
.../files/file-overview/file-overview.component.ts | 5 +-
.../broker-config/broker-config.component.html | 44 --
.../broker-config/broker-config.component.ts | 60 ---
.../messaging-configuration.component.html | 200 --------
.../messaging-configuration.component.scss | 70 ---
.../messaging-configuration.component.ts | 116 -----
.../abstract-security-principal-config.ts | 6 +-
.../role-configuration.component.ts | 5 +-
.../user-group-configuration.component.ts | 5 +-
.../adapter-configuration-state.service.ts | 7 +-
.../configure-schema/configure-schema.component.ts | 7 +-
.../core-ui/error-hint/error-hint.component.html | 30 +-
.../app/core-ui/error-hint/error-hint.component.ts | 22 +-
.../loading-indicator.component.html | 2 +-
.../loading-indicator.component.ts | 7 +-
.../pipeline-operation-status.component.html | 2 +-
.../pipeline-operation-status.component.ts | 7 +-
.../pipeline-started-status.component.html | 26 +-
.../pipeline-started-status.component.ts | 31 +-
.../status-indicator.component.html | 6 +-
.../status-indicator/status-indicator.component.ts | 13 +-
.../grid-view/dashboard-grid-view.component.html | 4 +
.../grid-view/dashboard-grid-view.component.scss | 3 +-
.../grid-view/dashboard-grid-view.component.ts | 23 +-
.../slide-view/dashboard-slide-view.component.html | 4 +
.../dashboard-overview-table.component.ts | 5 +-
.../overview/dashboard-overview.component.ts | 7 +-
.../components/panel/dashboard-panel.component.ts | 36 +-
.../edit-dashboard-dialog.component.html | 29 ++
.../edit-dashboard-dialog.component.ts | 13 +
.../dataset-feature-card.component.html | 24 +-
.../pipeline-assembly-options.component.ts | 5 +-
.../components/pipeline/pipeline.component.ts | 3 +-
ui/src/app/pipelines/pipelines.component.ts | 2 -
390 files changed, 9715 insertions(+), 5213 deletions(-)
copy installer/cli/deploy/standalone/{nats =>
nats-auth}/docker-compose.dev.yml (100%)
copy installer/cli/deploy/standalone/{nats => nats-auth}/docker-compose.yml
(90%)
copy installer/cli/environments/{backend => backend-nats-auth} (98%)
copy installer/cli/environments/{basic => basic-nats-auth} (98%)
copy installer/cli/environments/{lite => lite-nats-auth} (98%)
copy installer/cli/environments/{pipeline-element-nats =>
pipeline-element-nats-auth} (98%)
copy installer/{cli/deploy/standalone/crate/docker-compose.yml =>
compose/docker-compose.minimal.nats-auth.yml} (74%)
copy installer/{cli/deploy/standalone/pulsar/docker-compose.dev.yml =>
compose/docker-compose.nats-auth.yml} (75%)
create mode 100644
streampipes-commons/src/test/java/org/apache/streampipes/commons/environment/variable/EnvironmentVariableTest.java
delete mode 100644
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/util/WorkerPaths.java
create mode 100644
streampipes-data-explorer/src/test/java/org/apache/streampipes/dataexplorer/AutoAggregationHandlerTest.java
copy
streampipes-connect-transformer-api/src/main/java/org/apache/streampipes/connect/transformer/api/Context.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/ExtensionAdapterManagement.java
(89%)
create mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/AdapterAssetManagement.java
copy
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/{ConnectWorkerDescriptionProvider.java
=> AdapterDescriptionManagement.java} (56%)
create mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/AdapterWorkerRequestManagement.java
create mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/AdapterWorkerSampleDataRequestManagement.java
copy
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/constants/InputStreamIndex.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/HttpServerAdapterRequestManagement.java
(71%)
create mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/RuntimeResolvableManagement.java
rename
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/migration/MigrateExtensionsResource.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/migration/AbstractMigrationHandler.java
(59%)
copy
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/migration/IAdapterMigrator.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/migration/AdapterMigrationHandler.java
(63%)
copy
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe/param/IDataProcessorParameters.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/migration/DataProcessorMigrationHandler.java
(61%)
copy
streampipes-sdk/src/main/java/org/apache/streampipes/sdk/extractor/DataSinkParameterExtractor.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/migration/DataSinkMigrationHandler.java
(63%)
rename
{streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/html
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/model/Description.java
(98%)
copy
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/monitoring/HealthCheckResource.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/monitoring/HealthCheckManagement.java
(63%)
copy
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/monitoring/MonitoringResource.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/monitoring/MonitoringManagement.java
(56%)
copy
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/containers/SpKafkaTestContainer.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/monitoring/ServiceMonitorManagement.java
(59%)
create mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/pe/AbstractPipelineElementManagement.java
copy
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/pe/DataProcessorPipelineElementResource.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/pe/DataProcessorPipelineElementManagement.java
(81%)
copy
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/pe/DataSinkPipelineElementResource.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/pe/DataSinkPipelineElementManagement.java
(79%)
copy
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/{connect/RuntimeResovable.java
=> pe/DataStreamPipelineElementManagement.java} (55%)
create mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/pe/InvocablePipelineElementManagement.java
rename
{streampipes-messaging-jms/src/main/java/org/apache/streampipes/messaging =>
streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm}/jms/ActiveMQPublisher.java
(75%)
rename
{streampipes-messaging-jms/src/main/java/org/apache/streampipes/messaging =>
streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm}/jms/ActiveMQUtils.java
(77%)
delete mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/service/ExtensionServiceExecutions.java
delete mode 100644 streampipes-messaging-jms/pom.xml
delete mode 100644
streampipes-messaging-jms/src/main/java/org/apache/streampipes/messaging/jms/ActiveMQConnectionProvider.java
delete mode 100644
streampipes-messaging-jms/src/main/java/org/apache/streampipes/messaging/jms/ActiveMQConsumer.java
delete mode 100644
streampipes-messaging-jms/src/main/java/org/apache/streampipes/messaging/jms/SpJmsProtocol.java
delete mode 100644
streampipes-messaging-jms/src/main/java/org/apache/streampipes/messaging/jms/SpJmsProtocolFactory.java
delete mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/configuration/DefaultMessagingSettings.java
delete mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/configuration/MessagingSettings.java
copy
streampipes-model/src/main/java/org/apache/streampipes/model/{datalake/importer/CsvImportValidationMessage.java
=> extensions/transport/ExtensionServiceBrokerErrorEnvelope.java} (70%)
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/data/PipelineGraphHelpers.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/extensions/transport/ExtensionServiceBrokerOperation.java
(55%)
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/extensions/transport/ExtensionServiceBrokerOperations.java
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/extensions/transport/ExtensionServiceBrokerRequestEnvelope.java
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/extensions/transport/ExtensionServiceBrokerResponseEnvelope.java
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/extensions/transport/ExtensionServiceBrokerTopics.java
copy
streampipes-model/src/main/java/org/apache/streampipes/model/{pipeline/PipelineElementRecommendation.java
=> extensions/transport/ExtensionServicePipelineDetachRequest.java} (63%)
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/data/PipelineGraphHelpers.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/extensions/transport/ExtensionServiceTransportMode.java
(57%)
delete mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/grounding/JmsTransportProtocol.java
delete mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/grounding/TransportFormat.java
create mode 100644
streampipes-model/src/test/java/org/apache/streampipes/model/extensions/transport/ExtensionServiceBrokerTopicsTest.java
create mode 100644
streampipes-model/src/test/java/org/apache/streampipes/model/extensions/transport/ExtensionServiceTransportModeTest.java
create mode 100644 streampipes-nats-extensions/README.md
copy {streampipes-extensions-api => streampipes-nats-extensions}/pom.xml (78%)
copy
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/CRUDApi.java
=>
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/ExtensionBrokerOperationHandler.java
(61%)
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/variable/EnvResolver.java
=>
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/ExtensionBrokerRequestContext.java
(85%)
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/ExtensionBrokerRequestReceiver.java
copy
streampipes-messaging-nats/src/main/java/org/apache/streampipes/messaging/nats/SpNatsProtocol.java
=>
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/ExtensionBrokerConstants.java
(59%)
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/ExtensionBrokerResponseFactory.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/ExtensionBrokerTopicParser.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/connect/AdapterAssetOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/connect/AdapterStateChangeOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/connect/RuntimeOptionsOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/connect/SampleDataOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/function/FunctionStopOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/migration/MigrationOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/monitoring/ExtensionInstanceHealthOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/monitoring/ServiceHealthOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/monitoring/ServiceLoadOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/pe/ContainerProvidedOptionsOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/pe/DescriptionOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/pe/OutputSchemaOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/pe/PipelineElementAssetsOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/pe/PipelineElementDetachOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/pe/PipelineElementInvocationOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/test/java/org/apache/streampipes/nats/extensions/operation/ExtensionBrokerTopicParserTest.java
create mode 100644
streampipes-nats-extensions/src/test/java/org/apache/streampipes/nats/extensions/operation/connect/AdapterAssetOperationHandlerTest.java
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/{IExtensionsResourceUrlProvider.java
=> ExtensionServiceOperationResult.java} (57%)
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/ExtensionServiceRequest.java
copy
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/Migration.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/ExtensionServiceRequestManager.java
(80%)
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/variable/EnvResolver.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/ExtensionServiceRequestMethod.java
(86%)
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/ExtensionServiceRequestTarget.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/ExtensionServiceRequestTargets.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/ExtensionServiceRequests.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/ExtensionServiceExecutions.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/HttpExtensionServiceRequestManager.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/DetachExtensionRequest.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/DetachHttpRequest.java
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/{InvokeHttpRequest.java
=> InvokeExtensionRequest.java} (52%)
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/{PipelineElementHttpRequest.java
=> PipelineElementExtensionRequest.java} (58%)
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/extensions/ExtensionsResourceUrlProvider.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/GroundingSelector.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/ElementVerification.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/GroundingMatch.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/ProtocolMatch.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/migration/AdapterDescriptionMigration093Provider.java
rename
{streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance =>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager}/pipeline/ExtensionsServiceLogExecutor.java
(68%)
rename
{streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager}/util/GroundingUtils.java
(59%)
delete mode 100644
streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/matching/v2/TestGroundingMatch.java
delete mode 100644
streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/matching/v2/TestProtocolMatch.java
delete mode 100644
streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/matching/v2/TestUtils.java
delete mode 100644
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/WelcomePage.java
delete mode 100644
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/html/HTMLGenerator.java
delete mode 100644
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/html/JSONGenerator.java
delete mode 100644
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/html/page/WelcomePageGenerator.java
delete mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/admin/MessagingConfigurationResource.java
delete mode 100644
streampipes-sdk/src/main/java/org/apache/streampipes/sdk/helpers/SupportedProtocols.java
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/Environments.java
=>
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/extensions/CoreExtensionTransportMode.java
(65%)
create mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/extensions/CoreNatsRequestReplyClient.java
create mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/extensions/ExtensionServiceRequestConfiguration.java
create mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/extensions/NatsExtensionServiceRequestManager.java
create mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/extensions/TransportAwareExtensionServiceRequestManager.java
delete mode 100644 ui/cypress/fixtures/datalake/missingData.json
create mode 100644 ui/cypress/tests/chart/autoAggregateTable.spec.ts
copy
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/live/EventProcessor.java
=>
ui/projects/streampipes/shared-ui/src/lib/dialog/confirm-dialog/confirm-dialog.model.ts
(78%)
create mode 100644
ui/src/app/chart-shared/components/charts/indicator/appearance-config/indicator-appearance-config.component.html
create mode 100644
ui/src/app/chart-shared/components/charts/indicator/appearance-config/indicator-appearance-config.component.ts
create mode 100644
ui/src/app/chart-shared/components/charts/indicator/indicator-group-card.component.html
create mode 100644
ui/src/app/chart-shared/components/charts/indicator/indicator-group-card.component.scss
create mode 100644
ui/src/app/chart-shared/components/charts/indicator/indicator-group-card.component.ts
delete mode 100644
ui/src/app/chart-shared/components/charts/indicator/indicator-renderer.service.ts
create mode 100644
ui/src/app/chart-shared/components/charts/indicator/indicator-widget.component.html
copy
ui/{projects/streampipes/shared-ui/src/lib/components/feature-card-host/feature-card-host.component.scss
=>
src/app/chart-shared/components/charts/indicator/indicator-widget.component.scss}
(53%)
create mode 100644
ui/src/app/chart-shared/components/charts/indicator/indicator-widget.component.ts
delete mode 100644
ui/src/app/configuration/messaging-configuration/broker-config/broker-config.component.html
delete mode 100644
ui/src/app/configuration/messaging-configuration/broker-config/broker-config.component.ts
delete mode 100644
ui/src/app/configuration/messaging-configuration/messaging-configuration.component.html
delete mode 100644
ui/src/app/configuration/messaging-configuration/messaging-configuration.component.scss
delete mode 100644
ui/src/app/configuration/messaging-configuration/messaging-configuration.component.ts
