This is an automated email from the ASF dual-hosted git repository.
martinzink pushed a change to branch minifi_rust_impr
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git
omit 39a5281f8 cargo fmt
omit c881e71c9 review changes and clippy fix (for new rust warnings (rustc
upgrade))
omit e5305814d property trait comments
omit f4637dcca K -> P in Property context 2
omit b82dfb753 K -> P in Property context
omit 60d8d5ffe review change + small improvement in build.rs
omit d52fcd261 is_required: K::IS_REQUIRED
omit cd85d2bd5 cargo fmt
omit 56a694ddb fix
omit c44eb1c94 manifest update
omit 72389ffed rebase NUMBER_VALIDATOR
omit 9dda01cab win fix
omit 786b6a2a1 property rework
omit afc5c0744 MINIFICPP-2869 Improve rust api property validation and
property getters
add a7419e286 MINIFICPP-2870 Lint/Check python code with ruff (#2237)
add 8be29c104 MINIFICPP-2885 Allow explictily unsetting properties with
default value (#2241)
add 3f92464be MINIFICPP-2869 Improve rust api property validation and
property getters
add 5bbfdc8ef property rework
add 64866d509 win fix
add 265f4f8a8 rebase NUMBER_VALIDATOR
add 70f91327d manifest update
add 8b847f62d fix
add d33ed267d cargo fmt
add 518b46846 is_required: K::IS_REQUIRED
add f67a0db5b review change + small improvement in build.rs
add fef93690b K -> P in Property context
add 7f6c01d0a K -> P in Property context 2
add fd73ee076 property trait comments
add fce40dbef review changes and clippy fix (for new rust warnings (rustc
upgrade))
add 6525c688d cargo fmt
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 (39a5281f8)
\
N -- N -- N refs/heads/minifi_rust_impr (6525c688d)
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/conan/compatibility.py | 5 +-
.../github_scripts/github_actions_cache_cleanup.py | 52 ++-
.../github_actions_cache_cleanup_tests.py | 52 +--
.../ubuntu_22_04_clang_arm_manifest.json | 45 +++
.github/workflows/ci.yml | 14 +-
CMakeLists.txt | 3 -
CONTRIBUTING.md | 19 +-
.../minifi_behave/containers/container_linux.py | 177 +++++-----
.../minifi_behave/containers/container_protocol.py | 33 +-
.../minifi_behave/containers/container_windows.py | 104 +++---
.../src/minifi_behave/containers/directory.py | 1 +
.../containers/docker_image_builder.py | 45 ++-
.../src/minifi_behave/containers/file.py | 1 +
.../src/minifi_behave/containers/host_file.py | 1 +
.../containers/http_proxy_container.py | 58 +++-
.../minifi_behave/containers/minifi_controller.py | 33 +-
.../containers/minifi_linux_container.py | 109 ++++--
.../minifi_behave/containers/minifi_protocol.py | 15 +-
.../containers/minifi_win_container.py | 20 +-
.../src/minifi_behave/containers/nifi_container.py | 118 ++++---
behave_framework/src/minifi_behave/core/helpers.py | 48 ++-
behave_framework/src/minifi_behave/core/hooks.py | 40 ++-
.../src/minifi_behave/core/minifi_test_context.py | 27 +-
.../src/minifi_behave/core/ssl_utils.py | 17 +-
.../src/minifi_behave/minifi/controller_service.py | 7 +-
.../src/minifi_behave/minifi/flow_definition.py | 19 +-
.../src/minifi_behave/minifi/funnel.py | 5 +-
.../src/minifi_behave/minifi/input_port.py | 8 +-
.../minifi_behave/minifi/minifi_flow_definition.py | 48 ++-
.../minifi_behave/minifi/nifi_flow_definition.py | 163 ++++-----
.../src/minifi_behave/minifi/output_port.py | 8 +-
.../src/minifi_behave/minifi/parameter.py | 9 +-
.../src/minifi_behave/minifi/parameter_context.py | 6 +-
.../src/minifi_behave/minifi/processor.py | 28 +-
.../src/minifi_behave/minifi/remote_port.py | 9 +-
.../minifi_behave/minifi/remote_process_group.py | 14 +-
.../src/minifi_behave/steps/checking_steps.py | 371 ++++++++++++++------
.../src/minifi_behave/steps/configuration_steps.py | 13 +-
.../src/minifi_behave/steps/core_steps.py | 86 +++--
.../src/minifi_behave/steps/flow_building_steps.py | 385 ++++++++++++++++-----
bootstrap/cli.py | 86 +++--
bootstrap/cmake_parser.py | 26 +-
bootstrap/main.py | 77 +++--
bootstrap/minifi_option.py | 75 +++-
bootstrap/package_manager.py | 209 ++++++-----
bootstrap/system_dependency.py | 27 +-
cmake/GenericPython.cmake | 2 +-
conanfile.py | 176 ++++++++--
.../include/core/ConfigurableComponentImpl.h | 1 +
.../src/core/ConfigurableComponentImpl.cpp | 10 +
docker/rockylinux/Dockerfile | 12 +-
.../scripts/python/reverse_flow_file_content.py | 6 +-
.../containers/kinesis_server_container.py | 21 +-
.../features/containers/s3_server_container.py | 75 +++-
extensions/aws/tests/features/environment.py | 6 +-
extensions/aws/tests/features/steps/steps.py | 57 +--
.../features/containers/azure_server_container.py | 108 ++++--
extensions/azure/tests/features/environment.py | 6 +-
extensions/azure/tests/features/steps/steps.py | 31 +-
extensions/civetweb/tests/features/environment.py | 3 +-
extensions/civetweb/tests/features/steps/steps.py | 10 +-
.../containers/couchbase_server_container.py | 145 ++++++--
extensions/couchbase/tests/features/environment.py | 13 +-
extensions/couchbase/tests/features/steps/steps.py | 33 +-
.../features/containers/elastic_base_container.py | 39 ++-
.../features/containers/elasticsearch_container.py | 96 +++--
.../features/containers/opensearch_container.py | 55 ++-
.../elasticsearch/tests/features/environment.py | 6 +-
.../elasticsearch/tests/features/steps/steps.py | 62 ++--
.../containers/fake_gcs_server_container.py | 20 +-
extensions/gcp/tests/features/environment.py | 6 +-
extensions/gcp/tests/features/steps/steps.py | 17 +-
.../features/containers/grafana_loki_container.py | 59 +++-
.../features/containers/reverse_proxy_container.py | 11 +-
.../grafana-loki/tests/features/environment.py | 13 +-
.../resources/check_log_lines_on_grafana.py | 14 +-
.../grafana-loki/tests/features/steps/steps.py | 49 ++-
.../features/containers/kafka_server_container.py | 127 +++++--
extensions/kafka/tests/features/environment.py | 11 +-
extensions/kafka/tests/features/steps/steps.py | 73 ++--
.../kubernetes/tests/features/environment.py | 11 +-
.../tests/features/steps/kubernetes_proxy.py | 120 ++++---
.../steps/minifi_as_pod_in_kubernetes_cluster.py | 4 +-
.../kubernetes/tests/features/steps/steps.py | 62 +++-
extensions/llamacpp/tests/features/environment.py | 18 +-
extensions/llamacpp/tests/features/steps/steps.py | 10 +-
extensions/lua/tests/features/environment.py | 5 +-
extensions/lua/tests/features/steps/steps.py | 10 +-
.../features/containers/mqtt_broker_container.py | 49 ++-
extensions/mqtt/tests/features/environment.py | 11 +-
.../features/resources/publish_mqtt_message.py | 3 +-
extensions/mqtt/tests/features/steps/steps.py | 48 +--
.../features/containers/opc_ua_server_container.py | 14 +-
extensions/opc/tests/features/environment.py | 9 +-
extensions/opc/tests/features/steps/steps.py | 64 ++--
.../features/containers/prometheus_container.py | 114 ++++--
.../prometheus/tests/features/environment.py | 11 +-
.../tests/features/resources/prometheus_checker.py | 220 +++++++++---
.../prometheus/tests/features/steps/steps.py | 74 ++--
extensions/python/CMakeLists.txt | 10 +-
extensions/python/PYTHON.md | 24 +-
.../pythonprocessor-examples/AddPythonAttribute.py | 1 -
.../pythonprocessor-examples/CountingProcessor.py | 3 +-
.../GaussianDistributionWithNumpy.py | 2 +-
.../pythonprocessor-examples/MoveContentToJson.py | 5 +-
.../pythonprocessor-examples/RemoveFlowFile.py | 1 -
.../pythonprocessor-examples/SentimentAnalysis.py | 12 +-
.../google/SentimentAnalyzer.py | 28 +-
.../pythonprocessor-examples/h2o/ConvertDsToCsv.py | 51 ++-
.../h2o/h2o3/mojo/ExecuteH2oMojoScoring.py | 158 +++++----
.../utils/dependency_installer.py | 32 +-
.../pythonprocessors/nifiapi/componentstate.py | 10 +-
.../python/pythonprocessors/nifiapi/decorators.py | 1 +
.../pythonprocessors/nifiapi/documentation.py | 60 +++-
.../pythonprocessors/nifiapi/flowfilesource.py | 8 +-
.../pythonprocessors/nifiapi/flowfiletransform.py | 12 +-
.../pythonprocessors/nifiapi/processorbase.py | 49 ++-
.../python/pythonprocessors/nifiapi/properties.py | 106 ++++--
.../pythonprocessors/nifiapi/recordtransform.py | 62 +++-
.../pythonprocessors/nifiapi/relationship.py | 1 +
extensions/python/tests/features/environment.py | 101 +++---
.../tests/features/resources/CreateFlowFile.py | 30 +-
.../tests/features/resources/CreateNothing.py | 13 +-
.../resources/EvaluateExpressionLanguageChecker.py | 21 +-
.../ExpressionLanguagePropertyWithValidator.py | 25 +-
.../features/resources/LogDynamicProperties.py | 9 +-
.../resources/NifiStyleLogDynamicProperties.py | 27 +-
.../resources/ProcessContextInterfaceChecker.py | 30 +-
.../resources/RelativeImporterProcessor.py | 5 +-
.../tests/features/resources/RotatingForwarder.py | 1 +
.../tests/features/resources/SetRecordField.py | 27 +-
.../resources/SingleThreadedSleepForever.py | 12 +-
.../tests/features/resources/SleepForever.py | 10 +-
.../resources/SpecialPropertyTypeChecker.py | 15 +-
.../tests/features/resources/TestStateManager.py | 22 +-
.../tests/features/resources/multiplierutils.py | 1 +
.../tests/features/resources/subtractutils.py | 1 +
extensions/python/tests/features/steps/steps.py | 121 ++++---
.../tests/test_python_scripts/foo_bar_processor.py | 2 +-
.../non_transferring_processor.py | 4 +-
...passthrough_processor_transfering_to_failure.py | 4 +-
...passthrough_processor_transfering_to_success.py | 4 +-
.../test_python_scripts/stateful_processor.py | 9 +-
.../tests/features/containers/splunk_container.py | 149 +++++---
extensions/splunk/tests/features/environment.py | 6 +-
extensions/splunk/tests/features/steps/steps.py | 28 +-
.../containers/postgress_server_container.py | 27 +-
extensions/sql/tests/features/environment.py | 36 +-
extensions/sql/tests/features/steps/steps.py | 27 +-
.../stable-api-testing/ExtensionInitializer.cpp | 2 +
extensions/stable-api-testing/PropertyTester.h | 97 ++++++
.../tests/PropertyTesterTests.cpp | 221 ++++++++++++
.../features/containers/diag_slave_container.py | 17 +-
.../tests/features/containers/syslog_container.py | 2 +-
.../features/containers/tcp_client_container.py | 9 +-
.../tests/features/environment.py | 15 +-
.../features/steps/minifi_c2_server_container.py | 98 ++++--
.../features/steps/minifi_controller_steps.py | 43 ++-
.../tests/features/steps/steps.py | 82 +++--
.../src/core/flow/StructuredConfiguration.cpp | 21 +-
.../resources/TestC2DescribeCoreComponentState.yml | 4 +
.../minifi-cpp/core/ConfigurableComponent.h | 1 +
minifi-api/include/minifi-cpp/core/Property.h | 1 +
.../minifi_rs_playground/features/environment.py | 20 +-
.../minifi_rs_playground/features/steps/steps.py | 21 +-
ruff.toml | 17 +
run_flake8.sh | 22 --
thirdparty/google-styleguide/cpplint.py | 3 +
thirdparty/rocksdb/all/conanfile.py | 5 +-
169 files changed, 4836 insertions(+), 2214 deletions(-)
create mode 100644 extensions/stable-api-testing/PropertyTester.h
create mode 100644 extensions/stable-api-testing/tests/PropertyTesterTests.cpp
create mode 100644 ruff.toml
delete mode 100755 run_flake8.sh
