This is an automated email from the ASF dual-hosted git repository.
lordgamez pushed a change to branch MINIFICPP-2894
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git
omit fd914bcb5 Review update
omit 39ea35050 Write base64 encoded bytestring to records
omit c5bd5c40c Adjust property names to align with other OPC processsor
properties
omit bcd34a907 MINIFICPP-2894 Add FetchOPCHistory processor
add 4756cb537 MINIFICPP-2852 Implement LMDB based flow file repository
(#2203)
add 7148ad2a5 MINIFICPP-2749 Add EncryptContentPGP and DecryptContentPGP
add df3ced3e6 MINIFICPP-2892 Tensor extensions based on sonos/tract (#2258)
add c12f48161 MINIFICPP-2911 fix rocky (MINIFI_RUST=ON)
add 736f660ad MINIFICPP-2912 Support rust options in win_build_vs.bat
add cfb77d1bb MINIFICPP-2913 Lower socket timeout for CivetWeb in Conan
build
add 8dbbd228a MINIFICPP-2914 Fix stale and unescaped data on the CI status
page
add 9409dbaf1 MINIFICPP-2915 Add rust extensions into msi installer (#2275)
add e0b8c97bb MINIFICPP-2918 Fix conan build of m4 library with GCC 15
(#2277)
add 74f052275 MINIFICPP-2917 Dont schedule ClassifyImage/DetectObject
without valid… (#2276)
add 4a3c96967 MINIFICPP-2920 - PutOPCProcessor creates writable node
(#2279)
add cd3515c35 MINIFICPP-2921 Update OpenSSL3 to version 3.6.5 (#2280)
add ab9942dee MINIFICPP-2916 Move manifest check CI job under docker build
(#2278)
add 439e573d2 MINIFICPP-2922 Fix Ruff check issues (#2281)
add b85daf3b9 MINIFICPP-2924 Fix transient failure of update OPC UA node
test scenario (#2283)
add a0cf4b386 MINIFICPP-2925 Fix reading SSL data in PublishKafka (#2284)
add b639ac118 MINIFICPP-2929 Tensor processors: only add mime.type if
content is ov… (#2285)
add d2b164cd8 MINIFICPP-2930 Only use select tract features (#2286)
add 8cf162979 MINIFICPP-2894 Add FetchOPCHistory processor
add 82995425e Adjust property names to align with other OPC processsor
properties
add b5d6c4a74 Write base64 encoded bytestring to records
add 035ec3dcb 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 (fd914bcb5)
\
N -- N -- N refs/heads/MINIFICPP-2894 (035ec3dcb)
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:
...lang_arm_manifest.json => docker_manifest.json} | 802 +++++++++++++++++++++
.github/workflows/ci.yml | 81 ++-
CMakeLists.txt | 10 +-
CONFIGURE.md | 9 +-
CONTROLLERS.md | 53 +-
PROCESSORS.md | 246 +++++++
README.md | 54 +-
Windows.md | 3 +
behave_framework/pyproject.toml | 3 +-
.../src/minifi_behave/core/ssl_utils.py | 12 +-
bootstrap/cli.py | 8 +-
bootstrap/minifi_option.py | 2 +
cmake/BundledOpenSSL.cmake | 6 +-
cmake/Extensions.cmake | 25 +
cmake/MiNiFiOptions.cmake | 2 +
conanfile.py | 2 +-
docker/Dockerfile | 21 +-
docker/rockylinux/Dockerfile | 8 +-
docs/status/index.html | 25 +-
extensions/kafka/KafkaProcessorBase.cpp | 9 +-
extensions/kafka/PublishKafka.cpp | 2 +-
extensions/kafka/tests/CMakeLists.txt | 1 +
extensions/kafka/tests/PublishKafkaTests.cpp | 40 +
extensions/kafka/tests/features/environment.py | 1 +
extensions/lmdb/LmdbContentRepository.cpp | 175 +----
extensions/lmdb/LmdbContentRepository.h | 32 +-
extensions/lmdb/LmdbFlowFileRepository.cpp | 254 +++++++
extensions/lmdb/LmdbFlowFileRepository.h | 120 +++
extensions/lmdb/LmdbStream.cpp | 56 +-
extensions/lmdb/LmdbStream.h | 11 +-
extensions/lmdb/LmdbWrapper.cpp | 269 +++++++
extensions/lmdb/LmdbWrapper.h | 63 ++
.../lmdb/tests/LmdbContentRepositoryTests.cpp | 32 +-
extensions/lmdb/tests/LmdbContentSessionTests.cpp | 2 +-
.../lmdb/tests/LmdbFlowFileRepositoryTests.cpp | 470 ++++++++++++
extensions/lmdb/tests/LmdbStreamTests.cpp | 111 +--
extensions/opc/src/OPCCommon.cpp | 2 +
extensions/opc/tests/PutOPCProcessorTests.cpp | 31 +
extensions/opc/tests/features/opcua.feature | 37 +-
libminifi/src/Configuration.cpp | 1 +
.../include/minifi-cpp/properties/Configuration.h | 1 +
minifi_rust/CMakeLists.txt | 20 +
minifi_rust/Cargo.toml | 6 +
.../.cargo/config.toml | 0
minifi_rust/extensions/minifi_pgp/.gitignore | 7 +
minifi_rust/extensions/minifi_pgp/Cargo.toml | 14 +
.../minifi_pgp/features/encrypt_decrypt.feature | 67 ++
.../features/environment.py | 7 +-
.../extensions/minifi_pgp/features/steps/steps.py | 80 ++
minifi_rust/extensions/minifi_pgp/minifi_pgp.md | 112 +++
.../src/controller_services/encryption_key.rs | 131 ++++
.../src/controller_services/key_file_property.rs | 118 +++
.../src/controller_services/key_lookup.rs | 141 ++++
.../src/controller_services/key_parsing.rs | 90 +++
.../src/controller_services/key_property.rs | 49 ++
.../src/controller_services/mod.rs} | 13 +-
.../src/controller_services/private_key_service.rs | 249 +++++++
.../src/controller_services/public_key_service.rs | 296 ++++++++
.../properties.rs => minifi_pgp/src/lib.rs} | 33 +-
.../minifi_pgp/src/processors/decrypt_content.rs | 474 ++++++++++++
.../minifi_pgp/src/processors/encrypt_content.rs | 392 ++++++++++
.../minifi_pgp/src/processors/mod.rs} | 5 +-
.../src/test_utils/mod.rs} | 19 +-
minifi_rust/extensions/minifi_pgp/src/utils.rs | 80 ++
.../extensions/minifi_pgp/test_keys/README.txt | 59 ++
.../extensions/minifi_pgp/test_keys/alice.asc | 18 +
.../extensions/minifi_pgp/test_keys/alice.gpg | Bin 0 -> 640 bytes
.../minifi_pgp/test_keys/alice_private.asc | 32 +
.../minifi_pgp/test_keys/alice_private.gpg | Bin 0 -> 1337 bytes
.../minifi_pgp/test_keys/ambiguous_keyring.gpg | Bin 0 -> 3227 bytes
.../minifi_pgp/test_keys/bob_private.asc | 71 ++
.../minifi_pgp/test_keys/bob_private.gpg | Bin 0 -> 3207 bytes
.../extensions/minifi_pgp/test_keys/dave.asc | 14 +
.../minifi_pgp/test_keys/dave_private.asc | 18 +
.../extensions/minifi_pgp/test_keys/erin.asc | 10 +
.../extensions/minifi_pgp/test_keys/garbage.gpg | Bin 0 -> 1024 bytes
.../extensions/minifi_pgp/test_keys/keyring.asc | 58 ++
.../extensions/minifi_pgp/test_keys/keyring.gpg | Bin 0 -> 2545 bytes
.../minifi_pgp/test_keys/mixed_secret_keyring.gpg | Bin 0 -> 1966 bytes
.../minifi_pgp/test_keys/secret_keyring.asc | 99 +++
.../minifi_pgp/test_keys/secret_keyring.gpg | Bin 0 -> 4544 bytes
.../minifi_pgp/test_keys/spoofed_bob.asc | 19 +
.../extensions/minifi_pgp/test_keys/truncated.asc | 10 +
.../minifi_pgp/test_keys/truncated_private.asc | 17 +
.../minifi_pgp/test_messages/foo_for_alice.asc | 12 +
.../minifi_pgp/test_messages/foo_for_alice.gpg | Bin 0 -> 346 bytes
.../test_messages/password_encrypted_foo.asc | 6 +
.../test_messages/password_encrypted_foo.gpg | 1 +
.../minifi_rs_playground/minifi_rs_playground.md | 1 +
.../src/processors/asciify_german.rs | 7 +-
.../src/processors/asciify_german/tests.rs | 7 +-
.../src/processors/get_file.rs | 4 +-
.../src/processors/put_file/unix_permissions.rs | 11 +-
minifi_rust/extensions/minifi_tensor/Cargo.toml | 25 +
.../minifi_tensor/features/basic.feature | 33 +
.../minifi_tensor/features/classification.feature | 147 ++++
.../minifi_tensor/features/detection.feature | 132 ++++
.../minifi_tensor/features/environment.py | 125 ++++
.../minifi_tensor/features/image_to_tensor.feature | 105 +++
.../minifi_tensor/features/steps/steps.py | 13 +-
.../extensions/minifi_tensor/minifi_tensor.md | 317 ++++++++
minifi_rust/extensions/minifi_tensor/src/lib.rs | 53 ++
.../src/low_level_processors/classify_output.rs | 573 +++++++++++++++
.../classify_output/classify_output_def.rs | 161 +++++
.../low_level_processors/filter_bounding_boxes.rs | 584 +++++++++++++++
.../filter_bounding_boxes_def.rs | 152 ++++
.../src/low_level_processors/image_to_tensor.rs | 658 +++++++++++++++++
.../image_to_tensor/image_to_tensor_def.rs | 207 ++++++
.../src/low_level_processors/invoke_tract_model.rs | 120 +++
.../invoke_tract_model/invoke_tract_model_def.rs | 87 +++
.../src/low_level_processors/mod.rs} | 11 +-
.../minifi_tensor/src/processors/classify_image.rs | 84 +++
.../classify_image/classify_image_def.rs | 84 +++
.../minifi_tensor/src/processors/detect_object.rs | 117 +++
.../processors/detect_object/detect_object_def.rs | 103 +++
.../src/processors/draw_bounding_box.rs | 195 +++++
.../minifi_tensor/src/processors/mod.rs} | 6 +-
.../minifi_tensor/src/services/mod.rs} | 4 +-
.../src/services/tract_model_service.rs | 179 +++++
.../tract_model_service/tract_model_service_def.rs | 50 ++
.../minifi_tensor/src/utils/bounding_box.rs | 204 ++++++
.../minifi_tensor/src/utils/dimensions.rs | 160 ++++
.../minifi_tensor/src/utils/mod.rs} | 8 +-
.../minifi_tensor/src/utils/per_channel_f32.rs | 86 +++
.../minifi_tensor/src/utils/score_activation.rs | 91 +++
.../minifi_tensor/src/utils/tensor_helpers.rs | 259 +++++++
minifi_rust/minifi_native/src/api/errors.rs | 10 +
minifi_rust/minifi_native/src/api/processor.rs | 3 +-
.../flow_file_stream_transform.rs | 6 +-
.../api/processor_wrappers/flow_file_transform.rs | 5 +-
minifi_rust/minifi_native/src/api/property.rs | 13 +
minifi_rust/minifi_native/src/lib.rs | 15 +-
minifi_rust/minifi_native/src/test_utils.rs | 16 +
minifi_rust/minifi_rs_behave/Cargo.toml | 1 -
minifi_rust/minifi_rs_behave/Dockerfile.alpine | 4 +-
minifi_rust/minifi_rs_behave/Dockerfile.debian | 4 +-
minifi_rust/minifi_rs_behave/linux_build.sh | 9 +
thirdparty/aws-sdk-cpp/all/conanfile.py | 2 +-
thirdparty/azure-sdk-cpp/all/conanfile.py | 2 +-
thirdparty/google-cloud-cpp/all/conanfile.py | 2 +-
thirdparty/kubernetes-client-c/all/conanfile.py | 2 +-
thirdparty/paho-mqtt/all/conanfile.py | 2 +-
win_build_vs.bat | 7 +
143 files changed, 10688 insertions(+), 517 deletions(-)
rename .github/references/{ubuntu_22_04_clang_arm_manifest.json =>
docker_manifest.json} (93%)
create mode 100644 extensions/lmdb/LmdbFlowFileRepository.cpp
create mode 100644 extensions/lmdb/LmdbFlowFileRepository.h
create mode 100644 extensions/lmdb/LmdbWrapper.cpp
create mode 100644 extensions/lmdb/LmdbWrapper.h
create mode 100644 extensions/lmdb/tests/LmdbFlowFileRepositoryTests.cpp
copy minifi_rust/extensions/{minifi_rs_playground =>
minifi_pgp}/.cargo/config.toml (100%)
create mode 100644 minifi_rust/extensions/minifi_pgp/.gitignore
create mode 100644 minifi_rust/extensions/minifi_pgp/Cargo.toml
create mode 100644
minifi_rust/extensions/minifi_pgp/features/encrypt_decrypt.feature
copy minifi_rust/extensions/{minifi_rs_playground =>
minifi_pgp}/features/environment.py (82%)
create mode 100644 minifi_rust/extensions/minifi_pgp/features/steps/steps.py
create mode 100644 minifi_rust/extensions/minifi_pgp/minifi_pgp.md
create mode 100644
minifi_rust/extensions/minifi_pgp/src/controller_services/encryption_key.rs
create mode 100644
minifi_rust/extensions/minifi_pgp/src/controller_services/key_file_property.rs
create mode 100644
minifi_rust/extensions/minifi_pgp/src/controller_services/key_lookup.rs
create mode 100644
minifi_rust/extensions/minifi_pgp/src/controller_services/key_parsing.rs
create mode 100644
minifi_rust/extensions/minifi_pgp/src/controller_services/key_property.rs
copy
minifi_rust/extensions/{minifi_rs_playground/src/processors/lorem_ipsum_cs_user/relationships.rs
=> minifi_pgp/src/controller_services/mod.rs} (82%)
create mode 100644
minifi_rust/extensions/minifi_pgp/src/controller_services/private_key_service.rs
create mode 100644
minifi_rust/extensions/minifi_pgp/src/controller_services/public_key_service.rs
copy
minifi_rust/extensions/{minifi_rs_playground/src/processors/lorem_ipsum_cs_user/properties.rs
=> minifi_pgp/src/lib.rs} (50%)
create mode 100644
minifi_rust/extensions/minifi_pgp/src/processors/decrypt_content.rs
create mode 100644
minifi_rust/extensions/minifi_pgp/src/processors/encrypt_content.rs
copy minifi_rust/{minifi_native/src/api/processor_wrappers/utils.rs =>
extensions/minifi_pgp/src/processors/mod.rs} (87%)
copy
minifi_rust/extensions/{minifi_rs_playground/src/controller_services/animal_controller_apis.rs
=> minifi_pgp/src/test_utils/mod.rs} (63%)
create mode 100644 minifi_rust/extensions/minifi_pgp/src/utils.rs
create mode 100644 minifi_rust/extensions/minifi_pgp/test_keys/README.txt
create mode 100644 minifi_rust/extensions/minifi_pgp/test_keys/alice.asc
create mode 100644 minifi_rust/extensions/minifi_pgp/test_keys/alice.gpg
create mode 100644
minifi_rust/extensions/minifi_pgp/test_keys/alice_private.asc
create mode 100644
minifi_rust/extensions/minifi_pgp/test_keys/alice_private.gpg
create mode 100644
minifi_rust/extensions/minifi_pgp/test_keys/ambiguous_keyring.gpg
create mode 100644 minifi_rust/extensions/minifi_pgp/test_keys/bob_private.asc
create mode 100644 minifi_rust/extensions/minifi_pgp/test_keys/bob_private.gpg
create mode 100644 minifi_rust/extensions/minifi_pgp/test_keys/dave.asc
create mode 100644 minifi_rust/extensions/minifi_pgp/test_keys/dave_private.asc
create mode 100644 minifi_rust/extensions/minifi_pgp/test_keys/erin.asc
create mode 100644 minifi_rust/extensions/minifi_pgp/test_keys/garbage.gpg
create mode 100644 minifi_rust/extensions/minifi_pgp/test_keys/keyring.asc
create mode 100644 minifi_rust/extensions/minifi_pgp/test_keys/keyring.gpg
create mode 100644
minifi_rust/extensions/minifi_pgp/test_keys/mixed_secret_keyring.gpg
create mode 100644
minifi_rust/extensions/minifi_pgp/test_keys/secret_keyring.asc
create mode 100644
minifi_rust/extensions/minifi_pgp/test_keys/secret_keyring.gpg
create mode 100644 minifi_rust/extensions/minifi_pgp/test_keys/spoofed_bob.asc
create mode 100644 minifi_rust/extensions/minifi_pgp/test_keys/truncated.asc
create mode 100644
minifi_rust/extensions/minifi_pgp/test_keys/truncated_private.asc
create mode 100644
minifi_rust/extensions/minifi_pgp/test_messages/foo_for_alice.asc
create mode 100644
minifi_rust/extensions/minifi_pgp/test_messages/foo_for_alice.gpg
create mode 100644
minifi_rust/extensions/minifi_pgp/test_messages/password_encrypted_foo.asc
create mode 100644
minifi_rust/extensions/minifi_pgp/test_messages/password_encrypted_foo.gpg
create mode 100644 minifi_rust/extensions/minifi_tensor/Cargo.toml
create mode 100644 minifi_rust/extensions/minifi_tensor/features/basic.feature
create mode 100644
minifi_rust/extensions/minifi_tensor/features/classification.feature
create mode 100644
minifi_rust/extensions/minifi_tensor/features/detection.feature
create mode 100644 minifi_rust/extensions/minifi_tensor/features/environment.py
create mode 100644
minifi_rust/extensions/minifi_tensor/features/image_to_tensor.feature
copy thirdparty/Simple-Windows-Posix-Semaphore/CMakeLists.txt =>
minifi_rust/extensions/minifi_tensor/features/steps/steps.py (76%)
create mode 100644 minifi_rust/extensions/minifi_tensor/minifi_tensor.md
create mode 100644 minifi_rust/extensions/minifi_tensor/src/lib.rs
create mode 100644
minifi_rust/extensions/minifi_tensor/src/low_level_processors/classify_output.rs
create mode 100644
minifi_rust/extensions/minifi_tensor/src/low_level_processors/classify_output/classify_output_def.rs
create mode 100644
minifi_rust/extensions/minifi_tensor/src/low_level_processors/filter_bounding_boxes.rs
create mode 100644
minifi_rust/extensions/minifi_tensor/src/low_level_processors/filter_bounding_boxes/filter_bounding_boxes_def.rs
create mode 100644
minifi_rust/extensions/minifi_tensor/src/low_level_processors/image_to_tensor.rs
create mode 100644
minifi_rust/extensions/minifi_tensor/src/low_level_processors/image_to_tensor/image_to_tensor_def.rs
create mode 100644
minifi_rust/extensions/minifi_tensor/src/low_level_processors/invoke_tract_model.rs
create mode 100644
minifi_rust/extensions/minifi_tensor/src/low_level_processors/invoke_tract_model/invoke_tract_model_def.rs
copy
minifi_rust/extensions/{minifi_rs_playground/src/processors/lorem_ipsum_cs_user/relationships.rs
=> minifi_tensor/src/low_level_processors/mod.rs} (81%)
create mode 100644
minifi_rust/extensions/minifi_tensor/src/processors/classify_image.rs
create mode 100644
minifi_rust/extensions/minifi_tensor/src/processors/classify_image/classify_image_def.rs
create mode 100644
minifi_rust/extensions/minifi_tensor/src/processors/detect_object.rs
create mode 100644
minifi_rust/extensions/minifi_tensor/src/processors/detect_object/detect_object_def.rs
create mode 100644
minifi_rust/extensions/minifi_tensor/src/processors/draw_bounding_box.rs
copy minifi_rust/{minifi_native/src/api/processor_wrappers/utils.rs =>
extensions/minifi_tensor/src/processors/mod.rs} (87%)
copy minifi_rust/{minifi_native/src/api/processor_wrappers/utils.rs =>
extensions/minifi_tensor/src/services/mod.rs} (87%)
create mode 100644
minifi_rust/extensions/minifi_tensor/src/services/tract_model_service.rs
create mode 100644
minifi_rust/extensions/minifi_tensor/src/services/tract_model_service/tract_model_service_def.rs
create mode 100644
minifi_rust/extensions/minifi_tensor/src/utils/bounding_box.rs
create mode 100644 minifi_rust/extensions/minifi_tensor/src/utils/dimensions.rs
copy minifi_rust/{minifi_native/src/api/processor_wrappers/utils.rs =>
extensions/minifi_tensor/src/utils/mod.rs} (84%)
create mode 100644
minifi_rust/extensions/minifi_tensor/src/utils/per_channel_f32.rs
create mode 100644
minifi_rust/extensions/minifi_tensor/src/utils/score_activation.rs
create mode 100644
minifi_rust/extensions/minifi_tensor/src/utils/tensor_helpers.rs
create mode 100644 minifi_rust/minifi_native/src/test_utils.rs
