This is an automated email from the ASF dual-hosted git repository.
adamdebreceni pushed a change to branch MINIFICPP-2840
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git
omit 779765341 MINIFICPP-2840 - Linter fix
omit d905a14e7 MINIFICPP-2840 - Linter fix
omit 43e3d2bb4 MINIFICPP-2840 - Review changes
omit 8fb81eaac MINIFICPP-2840 - Rebase fix
omit 9b695c08f MINIFICPP-2840 - More refactor
omit d46dfc3d9 MINIFICPP-2840 - Refactor provenance part 1
add 5ea4c3bca MINIFICPP-2740 Rust bindings based on stable C API (#2186)
add 63d0f5f99 MINIFICPP-2805 Move reinterpret casts into functions in
minifi-c.cpp (#2211)
add 7b54eb7db MINIFICPP-2787 Do not encrypt empty properties and
parameters (#2217)
add d0a117219 MINIFICPP-2840 - Refactor provenance part 1
add c2999b890 MINIFICPP-2840 - More refactor
add ee0cd426b MINIFICPP-2840 - Rebase fix
add 138a7136c MINIFICPP-2840 - Review changes
add a29bf0bc2 MINIFICPP-2840 - Linter fix
add 27333fdbe MINIFICPP-2840 - Linter fix
add 82815c6a6 MINIFICPP-2840 - Review changes
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 (779765341)
\
N -- N -- N refs/heads/MINIFICPP-2840 (82815c6a6)
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:
.../ubuntu_22_04_clang_arm_manifest.json | 669 ++++++++++++++++++++-
.github/workflows/ci.yml | 68 ++-
.github/workflows/create-release-artifacts.yml | 10 +
CMakeLists.txt | 2 +
.../src/minifi_behave/steps/flow_building_steps.py | 7 +
cmake/MiNiFiOptions.cmake | 1 +
.../PropertyEncryptionUtils.cpp | 2 +-
docker/rockylinux/Dockerfile | 3 +-
.../reporting/SiteToSiteProvenanceReportingTask.h | 2 +-
libminifi/include/provenance/Provenance.h | 12 +-
libminifi/include/utils/CControllerService.h | 9 +-
libminifi/include/utils/CProcessor.h | 11 +-
libminifi/include/utils/minifi-api-utils.h | 98 +++
libminifi/src/core/yaml/YamlFlowSerializer.cpp | 8 +-
libminifi/src/minifi-api.cpp | 99 ++-
libminifi/src/provenance/Provenance.cpp | 4 +-
libminifi/test/libtest/unit/Catch.h | 17 +-
libminifi/test/unit/ExpectedTest.cpp | 9 +
libminifi/test/unit/JsonFlowSerializerTests.cpp | 40 ++
.../test/unit/PropertyEncryptionUtilsTests.cpp | 12 +-
libminifi/test/unit/YamlFlowSerializerTests.cpp | 39 +-
minifi_rust/.cargo/config.toml | 19 +
minifi_rust/.dockerignore | 12 +
minifi_rust/.gitignore | 7 +
.../CMakeLists.txt | 33 +-
minifi_rust/Cargo.toml | 9 +
minifi_rust/LICENSE | 202 +++++++
minifi_rust/README.md | 143 +++++
.../minifi_rs_playground/.cargo/config.toml | 5 +
.../extensions/minifi_rs_playground/.gitignore | 7 +
.../extensions/minifi_rs_playground/Cargo.toml | 21 +
.../minifi_rs_playground/features/basic.feature | 99 +++
.../features/controller_apis.feature | 28 +
.../minifi_rs_playground/features/environment.py | 91 +++
.../features/error-handling.feature | 85 +++
.../features/lazy-logging.feature | 26 +-
.../minifi_rs_playground/features/metrics.feature | 38 ++
.../minifi_rs_playground/features/steps/steps.py | 62 ++
.../features/streaming.feature | 49 ++
.../minifi_rs_playground/minifi_rs_playground.md | 335 +++++++++++
.../controller_services/animal_controller_apis.rs | 29 +
.../controller_services/dog_controller_service.rs | 96 +++
.../controller_services/duck_controller_service.rs | 59 ++
.../dummy_controller_service.rs | 40 ++
.../lorem_ipsum_controller_service.rs | 60 ++
.../src/controller_services/mod.rs | 22 +
.../extensions/minifi_rs_playground/src/lib.rs | 60 ++
.../src/processors/asciify_german.rs | 88 +++
.../asciify_german/processor_definition.rs | 32 +
.../src/processors/asciify_german/relationships.rs | 28 +
.../src/processors/asciify_german/tests.rs | 91 +++
.../src/processors/count_actual_logging.rs | 76 +++
.../src/processors/duplicate_text.rs | 71 +++
.../src/processors/generate_flow_file.rs | 198 ++++++
.../generate_flow_file/processor_definition.rs | 38 ++
.../processors/generate_flow_file/properties.rs | 78 +++
.../processors/generate_flow_file/relationships.rs | 23 +
.../src/processors/generate_flow_file/tests.rs | 155 +++++
.../src/processors/get_file.rs | 329 ++++++++++
.../src/processors/get_file/output_attributes.rs | 30 +
.../processors/get_file/processor_definition.rs | 47 ++
.../src/processors/get_file/properties.rs | 138 +++++
.../src/processors/get_file/relationships.rs | 23 +
.../src/processors/get_file/tests.rs | 189 ++++++
.../src/processors/kamikaze_processor.rs | 118 ++++
.../kamikaze_processor/processor_definition.rs | 34 ++
.../processors/kamikaze_processor/properties.rs | 56 ++
.../processors/kamikaze_processor/relationships.rs | 23 +
.../src/processors/kamikaze_processor/tests.rs | 96 +++
.../src/processors/log_attribute.rs | 178 ++++++
.../log_attribute/processor_definition.rs | 41 ++
.../src/processors/log_attribute/properties.rs | 103 ++++
.../src/processors/log_attribute/relationships.rs | 23 +
.../src/processors/log_attribute/tests.rs | 160 +++++
.../src/processors/lorem_ipsum_cs_user.rs | 93 +++
.../lorem_ipsum_cs_user/processor_definition.rs | 34 ++
.../processors/lorem_ipsum_cs_user/properties.rs | 45 ++
.../lorem_ipsum_cs_user/relationships.rs | 23 +
.../src/processors/lorem_ipsum_cs_user/tests.rs | 36 ++
.../minifi_rs_playground/src/processors/mod.rs | 27 +
.../src/processors/put_file.rs | 259 ++++++++
.../processors/put_file/processor_definition.rs | 54 ++
.../src/processors/put_file/properties.rs | 68 +++
.../src/processors/put_file/relationships.rs | 28 +
.../src/processors/put_file/tests.rs | 162 +++++
.../processors/put_file/unix_only_properties.rs | 42 ++
.../src/processors/zoo_processor.rs | 108 ++++
.../generate_docs/Dockerfile.generate_docs | 25 +-
minifi_rust/generate_docs/generate_docs.sh | 29 +
minifi_rust/minifi_native/.gitignore | 2 +
minifi_rust/minifi_native/Cargo.toml | 15 +
minifi_rust/minifi_native/src/api.rs | 43 ++
minifi_rust/minifi_native/src/api/attribute.rs | 28 +
.../src/api/component_definition_traits.rs | 41 ++
.../minifi_native/src/api/controller_service.rs | 79 +++
minifi_rust/minifi_native/src/api/errors.rs | 160 +++++
minifi_rust/minifi_native/src/api/flow_file.rs | 24 +
minifi_rust/minifi_native/src/api/logger.rs | 112 ++++
.../minifi_native/src/api/process_context.rs | 151 +++++
.../minifi_native/src/api/process_session.rs | 69 +++
minifi_rust/minifi_native/src/api/processor.rs | 77 +++
.../minifi_native/src/api/processor_wrappers.rs | 22 +
.../api/processor_wrappers/complex_processor.rs | 100 +++
.../src/api/processor_wrappers/flow_file_source.rs | 145 +++++
.../flow_file_stream_transform.rs | 187 ++++++
.../api/processor_wrappers/flow_file_transform.rs | 202 +++++++
.../src/api/processor_wrappers/utils.rs | 19 +
.../utils/context_session_flowfile_bundle.rs | 102 ++++
.../processor_wrappers/utils/flow_file_content.rs | 44 ++
minifi_rust/minifi_native/src/api/property.rs | 117 ++++
.../minifi_native/src/api/provided_interface.rs | 50 ++
.../src/api/raw_controller_service.rs | 28 +
minifi_rust/minifi_native/src/api/raw_processor.rs | 87 +++
minifi_rust/minifi_native/src/api/relationship.rs | 22 +
minifi_rust/minifi_native/src/c_ffi.rs | 43 ++
.../src/c_ffi/c_ffi_controller_service_context.rs | 97 +++
.../c_ffi/c_ffi_controller_service_definition.rs | 210 +++++++
.../src/c_ffi/c_ffi_controller_service_list.rs | 78 +++
.../minifi_native/src/c_ffi/c_ffi_flow_file.rs | 39 ++
.../minifi_native/src/c_ffi/c_ffi_logger.rs | 77 +++
.../src/c_ffi/c_ffi_output_attribute.rs | 58 ++
.../minifi_native/src/c_ffi/c_ffi_primitives.rs | 92 +++
.../src/c_ffi/c_ffi_process_context.rs | 218 +++++++
.../src/c_ffi/c_ffi_process_session.rs | 578 ++++++++++++++++++
.../src/c_ffi/c_ffi_processor_definition.rs | 290 +++++++++
.../src/c_ffi/c_ffi_processor_list.rs | 76 +++
.../minifi_native/src/c_ffi/c_ffi_property.rs | 170 ++++++
.../minifi_native/src/c_ffi/c_ffi_relationship.rs | 32 +
.../minifi_native/src/c_ffi/c_ffi_streams.rs | 143 +++++
minifi_rust/minifi_native/src/lib.rs | 135 +++++
minifi_rust/minifi_native/src/mock.rs | 29 +
.../src/mock/mock_controller_service_context.rs | 43 ++
.../minifi_native/src/mock/mock_flow_file.rs | 75 +++
minifi_rust/minifi_native/src/mock/mock_logger.rs | 98 +++
.../minifi_native/src/mock/mock_process_context.rs | 174 ++++++
.../minifi_native/src/mock/mock_process_session.rs | 188 ++++++
minifi_rust/minifi_native_macros/Cargo.toml | 11 +
minifi_rust/minifi_native_macros/src/lib.rs | 54 ++
minifi_rust/minifi_native_sys/.gitignore | 2 +
minifi_rust/minifi_native_sys/Cargo.toml | 18 +
minifi_rust/minifi_native_sys/build.rs | 240 ++++++++
minifi_rust/minifi_native_sys/src/lib.rs | 26 +
minifi_rust/minifi_rs_behave/Cargo.toml | 12 +
minifi_rust/minifi_rs_behave/Dockerfile.alpine | 25 +
minifi_rust/minifi_rs_behave/Dockerfile.debian | 25 +
minifi_rust/minifi_rs_behave/build.rs | 23 +
minifi_rust/minifi_rs_behave/linux_build.sh | 94 +++
minifi_rust/minifi_rs_behave/src/main.rs | 172 ++++++
.../__init__.py => minifi_rust/rustfmt.toml | 0
149 files changed, 11683 insertions(+), 146 deletions(-)
create mode 100644 libminifi/include/utils/minifi-api-utils.h
create mode 100644 minifi_rust/.cargo/config.toml
create mode 100644 minifi_rust/.dockerignore
create mode 100644 minifi_rust/.gitignore
copy {extensions/stable-api-testing => minifi_rust}/CMakeLists.txt (52%)
create mode 100644 minifi_rust/Cargo.toml
create mode 100644 minifi_rust/LICENSE
create mode 100644 minifi_rust/README.md
create mode 100644
minifi_rust/extensions/minifi_rs_playground/.cargo/config.toml
create mode 100644 minifi_rust/extensions/minifi_rs_playground/.gitignore
create mode 100644 minifi_rust/extensions/minifi_rs_playground/Cargo.toml
create mode 100644
minifi_rust/extensions/minifi_rs_playground/features/basic.feature
create mode 100644
minifi_rust/extensions/minifi_rs_playground/features/controller_apis.feature
create mode 100644
minifi_rust/extensions/minifi_rs_playground/features/environment.py
create mode 100644
minifi_rust/extensions/minifi_rs_playground/features/error-handling.feature
copy extensions/azure/tests/features/environment.py =>
minifi_rust/extensions/minifi_rs_playground/features/lazy-logging.feature (53%)
create mode 100644
minifi_rust/extensions/minifi_rs_playground/features/metrics.feature
create mode 100644
minifi_rust/extensions/minifi_rs_playground/features/steps/steps.py
create mode 100644
minifi_rust/extensions/minifi_rs_playground/features/streaming.feature
create mode 100644
minifi_rust/extensions/minifi_rs_playground/minifi_rs_playground.md
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/controller_services/animal_controller_apis.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/controller_services/dog_controller_service.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/controller_services/duck_controller_service.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/controller_services/dummy_controller_service.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/controller_services/lorem_ipsum_controller_service.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/controller_services/mod.rs
create mode 100644 minifi_rust/extensions/minifi_rs_playground/src/lib.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/asciify_german.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/asciify_german/processor_definition.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/asciify_german/relationships.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/asciify_german/tests.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/count_actual_logging.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/duplicate_text.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/generate_flow_file.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/generate_flow_file/processor_definition.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/generate_flow_file/properties.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/generate_flow_file/relationships.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/generate_flow_file/tests.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/get_file.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/get_file/output_attributes.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/get_file/processor_definition.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/get_file/properties.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/get_file/relationships.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/get_file/tests.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/kamikaze_processor.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/kamikaze_processor/processor_definition.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/kamikaze_processor/properties.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/kamikaze_processor/relationships.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/kamikaze_processor/tests.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/log_attribute.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/log_attribute/processor_definition.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/log_attribute/properties.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/log_attribute/relationships.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/log_attribute/tests.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/lorem_ipsum_cs_user.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/lorem_ipsum_cs_user/processor_definition.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/lorem_ipsum_cs_user/properties.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/lorem_ipsum_cs_user/relationships.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/lorem_ipsum_cs_user/tests.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/mod.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/put_file.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/put_file/processor_definition.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/put_file/properties.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/put_file/relationships.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/put_file/tests.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/put_file/unix_only_properties.rs
create mode 100644
minifi_rust/extensions/minifi_rs_playground/src/processors/zoo_processor.rs
copy docker/installed/Dockerfile.rpm =>
minifi_rust/generate_docs/Dockerfile.generate_docs (64%)
create mode 100755 minifi_rust/generate_docs/generate_docs.sh
create mode 100644 minifi_rust/minifi_native/.gitignore
create mode 100644 minifi_rust/minifi_native/Cargo.toml
create mode 100644 minifi_rust/minifi_native/src/api.rs
create mode 100644 minifi_rust/minifi_native/src/api/attribute.rs
create mode 100644
minifi_rust/minifi_native/src/api/component_definition_traits.rs
create mode 100644 minifi_rust/minifi_native/src/api/controller_service.rs
create mode 100644 minifi_rust/minifi_native/src/api/errors.rs
create mode 100644 minifi_rust/minifi_native/src/api/flow_file.rs
create mode 100644 minifi_rust/minifi_native/src/api/logger.rs
create mode 100644 minifi_rust/minifi_native/src/api/process_context.rs
create mode 100644 minifi_rust/minifi_native/src/api/process_session.rs
create mode 100644 minifi_rust/minifi_native/src/api/processor.rs
create mode 100644 minifi_rust/minifi_native/src/api/processor_wrappers.rs
create mode 100644
minifi_rust/minifi_native/src/api/processor_wrappers/complex_processor.rs
create mode 100644
minifi_rust/minifi_native/src/api/processor_wrappers/flow_file_source.rs
create mode 100644
minifi_rust/minifi_native/src/api/processor_wrappers/flow_file_stream_transform.rs
create mode 100644
minifi_rust/minifi_native/src/api/processor_wrappers/flow_file_transform.rs
create mode 100644
minifi_rust/minifi_native/src/api/processor_wrappers/utils.rs
create mode 100644
minifi_rust/minifi_native/src/api/processor_wrappers/utils/context_session_flowfile_bundle.rs
create mode 100644
minifi_rust/minifi_native/src/api/processor_wrappers/utils/flow_file_content.rs
create mode 100644 minifi_rust/minifi_native/src/api/property.rs
create mode 100644 minifi_rust/minifi_native/src/api/provided_interface.rs
create mode 100644 minifi_rust/minifi_native/src/api/raw_controller_service.rs
create mode 100644 minifi_rust/minifi_native/src/api/raw_processor.rs
create mode 100644 minifi_rust/minifi_native/src/api/relationship.rs
create mode 100644 minifi_rust/minifi_native/src/c_ffi.rs
create mode 100644
minifi_rust/minifi_native/src/c_ffi/c_ffi_controller_service_context.rs
create mode 100644
minifi_rust/minifi_native/src/c_ffi/c_ffi_controller_service_definition.rs
create mode 100644
minifi_rust/minifi_native/src/c_ffi/c_ffi_controller_service_list.rs
create mode 100644 minifi_rust/minifi_native/src/c_ffi/c_ffi_flow_file.rs
create mode 100644 minifi_rust/minifi_native/src/c_ffi/c_ffi_logger.rs
create mode 100644
minifi_rust/minifi_native/src/c_ffi/c_ffi_output_attribute.rs
create mode 100644 minifi_rust/minifi_native/src/c_ffi/c_ffi_primitives.rs
create mode 100644 minifi_rust/minifi_native/src/c_ffi/c_ffi_process_context.rs
create mode 100644 minifi_rust/minifi_native/src/c_ffi/c_ffi_process_session.rs
create mode 100644
minifi_rust/minifi_native/src/c_ffi/c_ffi_processor_definition.rs
create mode 100644 minifi_rust/minifi_native/src/c_ffi/c_ffi_processor_list.rs
create mode 100644 minifi_rust/minifi_native/src/c_ffi/c_ffi_property.rs
create mode 100644 minifi_rust/minifi_native/src/c_ffi/c_ffi_relationship.rs
create mode 100644 minifi_rust/minifi_native/src/c_ffi/c_ffi_streams.rs
create mode 100644 minifi_rust/minifi_native/src/lib.rs
create mode 100644 minifi_rust/minifi_native/src/mock.rs
create mode 100644
minifi_rust/minifi_native/src/mock/mock_controller_service_context.rs
create mode 100644 minifi_rust/minifi_native/src/mock/mock_flow_file.rs
create mode 100644 minifi_rust/minifi_native/src/mock/mock_logger.rs
create mode 100644 minifi_rust/minifi_native/src/mock/mock_process_context.rs
create mode 100644 minifi_rust/minifi_native/src/mock/mock_process_session.rs
create mode 100644 minifi_rust/minifi_native_macros/Cargo.toml
create mode 100644 minifi_rust/minifi_native_macros/src/lib.rs
create mode 100644 minifi_rust/minifi_native_sys/.gitignore
create mode 100644 minifi_rust/minifi_native_sys/Cargo.toml
create mode 100644 minifi_rust/minifi_native_sys/build.rs
create mode 100644 minifi_rust/minifi_native_sys/src/lib.rs
create mode 100644 minifi_rust/minifi_rs_behave/Cargo.toml
create mode 100644 minifi_rust/minifi_rs_behave/Dockerfile.alpine
create mode 100644 minifi_rust/minifi_rs_behave/Dockerfile.debian
create mode 100644 minifi_rust/minifi_rs_behave/build.rs
create mode 100755 minifi_rust/minifi_rs_behave/linux_build.sh
create mode 100644 minifi_rust/minifi_rs_behave/src/main.rs
copy behave_framework/src/minifi_behave/containers/__init__.py =>
minifi_rust/rustfmt.toml (100%)