This is an automated email from the ASF dual-hosted git repository.
lordgamez pushed a change to branch MINIFICPP-2849
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git
omit b045aa6b2 Disable LMDB extension by default and mark is as experimental
omit 6d432ab7a Replace ENABLE_LMDB option with MINIFI_LMDB
omit e5e0e9547 Update LMDB and add conan recipe
omit 24e4d93b8 Review update
omit fc19c41c4 Review update
omit 1f91ff276 Fix LMDB build on Windows with WIN32_LEAN_AND_MEAN defined
omit b522d624d Fix lmdb lifetime issues
omit 146d0dd5e MINIFICPP-2849 Implement LMDB based content repository
add 48eedde6d MINIFICPP-2878 PRs from apache should not double run CI
(#2248)
add a7419e286 MINIFICPP-2870 Lint/Check python code with ruff (#2237)
add 8be29c104 MINIFICPP-2885 Allow explictily unsetting properties with
default value (#2241)
add 3207859bc MINIFICPP-2849 Implement LMDB based content repository
add d1d84c2ed Fix lmdb lifetime issues
add 1f15504aa Fix LMDB build on Windows with WIN32_LEAN_AND_MEAN defined
add a3afefa48 Review update
add 9f19fa961 Review update
add 4c21fa660 Update LMDB and add conan recipe
add 842a70b0e Replace ENABLE_LMDB option with MINIFI_LMDB
add 92dfc1460 Disable LMDB extension by default and mark is as experimental
add 6a03da1d5 Review update
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 (b045aa6b2)
\
N -- N -- N refs/heads/MINIFICPP-2849 (6a03da1d5)
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 | 44 ++-
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 | 87 +++--
bootstrap/cmake_parser.py | 26 +-
bootstrap/main.py | 77 +++--
bootstrap/minifi_option.py | 78 ++++-
bootstrap/package_manager.py | 209 ++++++-----
bootstrap/system_dependency.py | 27 +-
cmake/GenericPython.cmake | 2 +-
conanfile.py | 178 ++++++++--
.../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/lmdb/LmdbContentRepository.cpp | 8 +-
extensions/lmdb/LmdbStream.cpp | 11 +-
extensions/lmdb/LmdbStream.h | 2 +-
.../lmdb/tests/LmdbContentRepositoryTests.cpp | 7 +-
extensions/lmdb/tests/LmdbStreamTests.cpp | 16 +
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 +-
174 files changed, 4905 insertions(+), 2225 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
