This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 1b7774b9f1 feat(#3227): Move file management to settings (#3228)
add 362216ebf3 feat(#3224): Add API for programmatic adapter creation
(#3225)
No new revisions were added by this update.
Summary of changes:
pom.xml | 10 +-
.../management/compact/AdapterGenerationSteps.java | 45 +++++
.../management/compact/PersistPipelineHandler.java | 112 +++++++++++
.../management/compact/SchemaMetadataEnricher.java | 69 +++++++
.../compact/generator/AdapterBasicsGenerator.java | 24 +--
.../compact/generator/AdapterConfigGenerator.java | 28 ++-
.../generator/AdapterEnrichmentRuleGenerator.java | 41 ++--
.../compact/generator/AdapterModelGenerator.java | 12 +-
.../compact/generator/AdapterSchemaGenerator.java | 61 ++++++
.../AdapterTransformationRuleGenerator.java | 85 ++++++++
.../management/AdapterMasterManagement.java | 13 +-
.../management/CompactAdapterManagement.java | 70 +++++++
.../generator/AdapterSchemaGeneratorTest.java | 77 ++++++++
.../AdapterTransformationRuleGeneratorTest.java | 94 +++++++++
.../connectors/opcua/utils/OpcUaUtil.java | 2 +
.../expression/MathExpressionProcessorTest.java | 15 +-
.../integration/adapters/KafkaAdapterTester.java | 13 +-
.../integration/adapters/MqttAdapterTester.java | 12 +-
.../integration/adapters/PulsarAdapterTester.java | 17 +-
.../connect/adapter/compact/CompactAdapter.java | 57 ++----
.../adapter/compact/CompactConfiguration.java | 6 +-
.../adapter/compact/CompactEventProperty.java | 11 +-
.../connect/adapter/compact/CompactTransport.java | 6 +-
.../connect/adapter/compact/CreateOptions.java | 7 +-
.../connect/adapter/compact/EnrichmentConfig.java | 7 +-
.../adapter/compact/TransformationConfig.java | 8 +-
.../model/template/PipelineElementTemplate.java | 11 +-
.../manager/template/AbstractTemplateHandler.java | 7 +-
.../template/PipelineElementTemplateVisitor.java | 215 ++++++++++++++-------
.../template/PipelineTemplateManagement.java | 80 ++++++++
.../PipelineElementTemplateVisitorTest.java | 153 ++++++++++++++-
.../ps/PipelineElementTemplateResource.java | 2 +-
streampipes-rest-core-base/pom.xml | 4 +
.../base/impl/converter/YamlConfiguration.java | 56 ++++++
streampipes-rest/pom.xml | 4 +
.../streampipes/rest/impl/PipelineTemplate.java | 54 ++----
.../rest/impl/connect/AdapterResource.java | 69 ++++---
.../rest/impl/connect/CompactAdapterResource.java | 147 ++++++++++++++
.../serializers/json/TestJacksonSerializer.java | 20 +-
.../streampipes/storage/couchdb/utils/Utils.java | 2 +-
.../couchdb/serializer/TestGsonSerializer.java | 30 ++-
.../executors/ProcessingElementTestExecutor.java | 38 ++--
.../template/PipelineElementTemplateHelpers.java | 13 +-
.../src/lib/model/gen/streampipes-model.ts | 28 +--
.../adapter-template-dialog.component.ts | 20 +-
ui/src/app/core-ui/core-ui.module.ts | 2 +
...ne-element-template-config-item.component.html} | 11 +-
...eline-element-template-config-item.component.ts | 59 ++++++
...pipeline-element-template-config.component.html | 17 +-
.../pipeline-element-template-config.component.ts | 44 +----
.../pipeline-element-template-generator.ts | 87 +++++----
.../editor/dialog/customize/customize.component.ts | 18 +-
52 files changed, 1574 insertions(+), 519 deletions(-)
create mode 100644
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/compact/AdapterGenerationSteps.java
create mode 100644
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/compact/PersistPipelineHandler.java
create mode 100644
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/compact/SchemaMetadataEnricher.java
copy
streampipes-resource-management/src/main/java/org/apache/streampipes/resource/management/AdapterDescriptionResourceManager.java
=>
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/compact/generator/AdapterBasicsGenerator.java
(55%)
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/template/AdapterTemplateHandler.java
=>
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/compact/generator/AdapterConfigGenerator.java
(57%)
copy
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing/UtilsTest.java
=>
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/compact/generator/AdapterEnrichmentRuleGenerator.java
(50%)
copy
streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/IAdapterStorage.java
=>
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/compact/generator/AdapterModelGenerator.java
(74%)
create mode 100644
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/compact/generator/AdapterSchemaGenerator.java
create mode 100644
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/compact/generator/AdapterTransformationRuleGenerator.java
create mode 100644
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/management/CompactAdapterManagement.java
create mode 100644
streampipes-connect-management/src/test/java/org/apache/streampipes/connect/management/management/compact/generator/AdapterSchemaGeneratorTest.java
create mode 100644
streampipes-connect-management/src/test/java/org/apache/streampipes/connect/management/management/compact/generator/AdapterTransformationRuleGeneratorTest.java
copy
streampipes-extensions/streampipes-connectors-opcua/src/test/java/org/apache/streampipes/extensions/connectors/opcua/migration/OpcUaAdapterMigrationV2Test.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/compact/CompactAdapter.java
(54%)
copy
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/connect/IEventCollector.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/compact/CompactConfiguration.java
(86%)
copy
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/staticmetadata/StaticMetaDataConfiguration.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/compact/CompactEventProperty.java
(80%)
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/variable/EnvResolver.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/compact/CompactTransport.java
(87%)
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/variable/EnvResolver.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/compact/CreateOptions.java
(84%)
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/variable/EnvResolver.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/compact/EnrichmentConfig.java
(87%)
copy
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/connect/IAdapterPipelineElement.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/compact/TransformationConfig.java
(80%)
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/template/PipelineTemplateManagement.java
create mode 100644
streampipes-rest-core-base/src/main/java/org/apache/streampipes/rest/core/base/impl/converter/YamlConfiguration.java
create mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/connect/CompactAdapterResource.java
copy
ui/{projects/streampipes/shared-ui/src/lib/components/basic-header-title/header-title.component.html
=>
src/app/core-ui/pipeline-element-template-config/pipeline-element-template-config-item/pipeline-element-template-config-item.component.html}
(79%)
create mode 100644
ui/src/app/core-ui/pipeline-element-template-config/pipeline-element-template-config-item/pipeline-element-template-config-item.component.ts
