This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch improve-startup-behaviour
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 67fe516ed Improve execution order of migrations and service startup
tasks
add 3d654a716 fix(grammatical): correct typos and improve grammar (#2100)
add 388973d7e chore(deps-dev): bump browserify-sign from 4.2.1 to 4.2.2 in
/ui (#2091)
add 89c414fa4 refactor(#2088): Remove module streampipes-logging (#2089)
add 03a416c8a [#1936] Adapter Deletion: Show the Names of All Pipelines
Using the Adapter and Allow One Click Deletion (#2070)
add 5b04827ba introduce quickstart deployment mode (#1955)
add 1a7a17edc chore(deps): bump nats-py in /streampipes-client-python
(#2102)
add a34a4dda3 implement migration for adapter and pipeline element
configurations (#2077)
add 0497444a2 refactor(#2092): Use HttpStatus in stead of plain strings
(#2099)
add 38a3cfb73 Merge branch 'dev' into improve-startup-behaviour
No new revisions were added by this update.
Summary of changes:
README.md | 4 +-
installer/compose/README.md | 20 +++-
...r-compose.yml => docker-compose.quickstart.yml} | 17 +++-
.../compose/quickstart}/Dockerfile | 10 +-
installer/compose/quickstart/upload.sh | 101 +++++++++++++++++++++
...set - Smart Factory Monitoring and Analysis.zip | Bin 0 -> 78596 bytes
pom.xml | 1 -
streampipes-client-python/poetry.lock | 4 +-
.../streampipes/client/api/AbstractClientApi.java | 5 +-
.../client/api/AbstractTypedClientApi.java | 4 +-
.../streampipes/client/http/HttpRequest.java | 5 +-
.../management/management/WorkerRestClient.java | 6 +-
...{AdapterMigrator.java => IAdapterMigrator.java} | 10 +-
...orMigrator.java => IDataProcessorMigrator.java} | 12 +--
...ataSinkMigrator.java => IDataSinkMigrator.java} | 10 +-
.../{ModelMigrator.java => IModelMigrator.java} | 10 +-
.../api/migration/MigrationComparison.java | 10 +-
.../management/model/SpServiceDefinition.java | 11 ++-
.../model/SpServiceDefinitionBuilder.java | 6 +-
.../model/SpServiceDefinitionBuilderTest.java | 4 +-
.../connect/adapters/netio/NetioRestAdapter.java | 5 +-
.../connect/adapters/PullAdapterTest.java | 4 +-
.../generic/protocol/stream/HttpProtocolTest.java | 4 +-
.../streampipes-connectors-influx/pom.xml | 6 ++
.../connectors/influx/sink/InfluxDbSink.java | 9 +-
.../opcua/migration/OpcUaAdapterMigrationV1.java | 4 +-
.../urldereferencing/UrlDereferencing.java | 3 -
.../inverter/BooleanInverterProcessor.java | 3 -
.../counter/StringCounterProcessor.java | 4 -
.../state/StringToStateProcessor.java | 4 -
.../stringoperator/timer/StringTimerProcessor.java | 4 -
.../sinks/databases/jvm/jdbcclient/JdbcClient.java | 30 +++---
.../sinks/databases/jvm/postgresql/PostgreSql.java | 16 ++--
streampipes-integration-tests/pom.xml | 4 +
.../integration/containers/PulsarContainer.java | 3 +-
streampipes-logging/pom.xml | 46 ----------
.../apache/streampipes/logging/LoggerFactory.java | 31 -------
.../org/apache/streampipes/logging/api/Logger.java | 34 -------
.../logging/impl/EventStatisticLogger.java | 41 ---------
.../apache/streampipes/logging/impl/PeLogger.java | 62 -------------
.../org/apache/streampipes/logging/model/Log.java | 69 --------------
.../streampipes/logging/model/LogRequest.java | 50 ----------
streampipes-model/pom.xml | 5 -
.../model/base/InvocableStreamPipesEntity.java | 5 -
.../manager/health/ServiceHealthCheck.java | 4 +-
.../extensions/AbstractExtensionsResource.java | 6 +-
.../AbstractPipelineElementResource.java | 5 +-
.../connect/HttpServerAdapterResource.java | 4 +-
.../connect/RuntimeResolvableResource.java | 4 +-
.../migration/AdapterMigrationResource.java | 4 +-
.../migration/DataProcessorMigrationResource.java | 4 +-
.../migration/DataSinkMigrationResource.java | 4 +-
.../migration/MigrateExtensionsResource.java | 6 +-
.../pe/DataStreamPipelineElementResource.java | 4 +-
.../pe/InvocablePipelineElementResource.java | 5 +-
.../migration/MigrateExtensionsResourceTest.java | 8 +-
streampipes-rest-shared/pom.xml | 9 ++
.../shared/impl/AbstractSharedRestInterface.java | 14 +--
.../apache/streampipes/rest/impl/UserResource.java | 3 +-
.../rest/impl/connect/AdapterResource.java | 30 +++++-
.../service/base/rest/ServiceHealthResource.java | 5 +-
streampipes-service-discovery-consul/pom.xml | 5 -
.../extensions/ExtensionsModelSubmitter.java | 4 +-
.../couchdb/utils/CouchDbViewGenerator.java | 7 +-
.../wrapper/flink/logger/StatisticLogger.java | 2 -
.../wrapper/kafka/converter/JsonToMapFormat.java | 2 -
tools/maven/installer.xml | 1 +
ui/package-lock.json | 51 ++++++-----
.../src/lib/apis/adapter.service.ts | 24 ++++-
.../delete-adapter-dialog.component.html | 42 ++++++---
.../delete-adapter-dialog.component.ts | 29 +++---
71 files changed, 414 insertions(+), 568 deletions(-)
copy installer/compose/{docker-compose.yml => docker-compose.quickstart.yml}
(95%)
copy
{archetypes/streampipes-archetype-pe-processors-flink/src/main/resources/archetype-resources
=> installer/compose/quickstart}/Dockerfile (78%)
create mode 100755 installer/compose/quickstart/upload.sh
create mode 100644 installer/compose/quickstart/zip_folder/Example Asset -
Smart Factory Monitoring and Analysis.zip
rename
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/migration/{AdapterMigrator.java
=> IAdapterMigrator.java} (76%)
rename
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/migration/{DataProcessorMigrator.java
=> IDataProcessorMigrator.java} (75%)
rename
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/migration/{DataSinkMigrator.java
=> IDataSinkMigrator.java} (76%)
rename
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/migration/{ModelMigrator.java
=> IModelMigrator.java} (88%)
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/parser/PrimitiveTypeParser.java
=>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/migration/MigrationComparison.java
(77%)
delete mode 100644 streampipes-logging/pom.xml
delete mode 100644
streampipes-logging/src/main/java/org/apache/streampipes/logging/LoggerFactory.java
delete mode 100644
streampipes-logging/src/main/java/org/apache/streampipes/logging/api/Logger.java
delete mode 100644
streampipes-logging/src/main/java/org/apache/streampipes/logging/impl/EventStatisticLogger.java
delete mode 100644
streampipes-logging/src/main/java/org/apache/streampipes/logging/impl/PeLogger.java
delete mode 100644
streampipes-logging/src/main/java/org/apache/streampipes/logging/model/Log.java
delete mode 100644
streampipes-logging/src/main/java/org/apache/streampipes/logging/model/LogRequest.java
