This is an automated email from the ASF dual-hosted git repository.
lordgamez pushed a change to branch MINIFICPP-2603
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git
omit 70d0b7f97 MINIFICPP-2603 Add Record Reader and Record Writer
properties to MQTT processors
omit 27903b953 MINIFICPP-2596 Add XMLRecordSetWriter controller service
omit 61a9e1684 MINIFICPP-2594 Add XMLReader controller service
omit d85829804 MINIFICPP-2600 Change RecordSetReader interface
omit 05314ac3f remove -Wno-error=restrict
omit a2d5ef907 Update cmake/ExpectedLite.cmake
omit 256abadfd Update .github/workflows/compiler-support.yml
omit d2f8749b4 Update libminifi/test/unit/ExpectedTest.cpp
omit 0f79afd89 NetUtilsTest fix
omit e2b5e97fd fix
omit d7f069731 clang-tidy fixes
omit 94324e0c5 do not upgrade Couchbase and fmtlib versions on Windows
omit 83c0277b2 add gcc15 support
omit e22e8555f add clang20 support
omit 976891dad rebase fix
omit 629231e11 update README.md compiler support
omit 404e95021 add explanation for thirdparty/coachbase/c++23_fixes.patch
omit 6bf869e3f MINIFICPP-2567 C++23 Support
add a473f11a9 MINIFICPP-2597 Replace removed thirdparty actions
add ef701211b MINIFICPP-2591 Add new value option to FetchOPCProcessor
lazy mode
add e3474f98e MINIFICPP-2598 Fixing inherited ControllerService manifest
issues
add 210a91e56 Working on api reduction
add 29d78d342 MINIFICPP-2604 Upgrade Azure SDK to the latest release
add 8bb8cc7e2 MINIFICPP-2607 ProcessContextExpr thread safety fix
add c1565bdce MINIFICPP-2597 Replace removed thirdparty actions (part 2)
add f85ebaa75 MINIFICPP-2567 C++23 Support
add 5eda82dc1 MINIFICPP-2563 Add build option for enabling link time
optimization
add 97087b22e MINIFICPP-2601 Separate protobuf library from grpc
add 0ed0524e7 MINIFICPP-2608 Refresh outdated linter cmake target
add 6e8114aa9 MINIFICPP-2576 Improve CWEL performance
add f1758fab5 MINIFICPP-2599 parseOptionalControllerService should throw
add 28dc05893 MINIFICPP-2606 Improve logging for python virtualenv
initialization
add 50b943940 MINIFICPP-2610 Fixing false positive warnings with
ControllerServices
add da0708613 MINIFICPP-2612 Remove unnecessary clang tidy checks
add 95ca031d6 MINIFICPP-2362 Improve handling of script extensions in
Windows MSI
add 30ddcb946 MINIFICPP-2561 Properties with Allowed Values or Complex
validators cannot support Expression Language
add d8dc39183 MINIFICPP-2615 Workaround for flaky ExpressionLanguageTest
on macOS
add 79277cb13 MINIFICPP-2616 Fix kafka image in docker tests
add d2b692785 MINIFICPP-2617 Update version number to 0.99.2
add e92801c8a MINIFICPP-2618 Fix build failure of zlib on MacOS runner
add 35f98753d MINIFICPP-2619 Fix deadlock of ThreadPool shutdown
add fd0eacbd3 MINIFICPP-2584 Linux Filesystem Hierarchy Standard support,
RPM package
add f65f14543 MINIFICPP-2589 Refactor ConsumeWindowsEventLog
add 434646feb MINIFICPP-2622 Replace Bitnami Kafka image with Apache in
tests
add 1121e3e34 MINIFICPP-2623 - Use same compiler
add 54000432a MINIFICPP-2620 DatabaseContentRepository should be the
default
add 68c27b98c MINIFICPP-2600 Change RecordSetReader interface
add 91d3c0568 MINIFICPP-2625 minifi.service should be in /usr/lib (rpm
package)
add 1b32c49e2 MINIFICPP-2448 Add minifi.sh flowStatus command
add 9ce51ca94 MINIFICPP-2626 Update RPM package description
add f28961cfb MINIFICPP-2594 Add XMLReader controller service
add ef7dbcb97 MINIFICPP-2595 Create ConvertRecord processor
add 8f83e3d66 MINIFICPP-2596 Add XMLRecordSetWriter controller service
add d9205afdb MINIFICPP-2628 CMake4 compatibility
add e25a247a4 MINIFICPP-2458 Create EvaluateJsonPath processor
add 107598b95 MINIFICPP-2577 Create SplitJson processor
add 5406747f7 MINIFICPP-2305 Fix various C2 integration test issues
add 857ed5bf2 MINIFICPP-2627 Fix ${MINIFI_HOME} in config files
add be873d380 MINIFICPP-2631 Fix various Windows build issues
add 59d6705c1 MINIFICPP-2632 Make RPM creation in rockylinux docker build
optional
add d3aa81c97 MINIFICPP-2633 Improve logging for python initialization
when no dependencies are installed
add 9b76620f1 MINIFICPP-2634 Turn on building stable extensions by default
add 6f545de4e MINIFICPP-2636 update ExecutePythonProcessor description
add 22c519f52 MINIFICPP-2635 Handle dynamic properties correctly in python
processors
add 2884584f0 MINIFICPP-2637 Upgrade libxml2 to v2.15.0
add 92fb88dca MINIFICPP-2638 Fix package source and gitignore lists
add 4f296765b MINIFICPP-2558 Revamp site to site communication
add 1fd592fd0 MINIFICPP-2605 Generate MQTT client id in MQTT processors if
not set in property
add 26409cfd5 MINIFICPP-2614 Add more authentication options to Azure
processors
add 198c89078 MINIFICPP-2642 std::invocable should be used with std::invoke
add 4d7c19eaa MINIFICPP-2645 Enable NiFi python processors using both EL
and validators
add f17f36a0d MINIFICPP-2646 Reenable Lua docker tests
add 02873cc04 MINIFICPP-2647 Fix Dependency installer for older pythons
add 97011df5a MINIFICPP-2565 Add compression support for site to site
communication
add a0ab21f03 MINIFICPP-2640 Remove explicit use of ExecutePythonProcessor
add 5b750041f MINIFICPP-2651 Add documenation on asset reference syntax
add 8cb945b10 MINIFICPP-2232 Remove option to load SSL context from flow
config
add cd4729197 MINIFICPP-2629 Clean up minifi-api includes
add e8c9a7c42 MINIFICPP-2643 Fix clang tidy issues
add 612e9f5c3 MINIFICPP-2652 Remove deprecated bootstrap.sh
add 1976d80e4 MINIFICPP-2655 Upgrade elasticsearch container image to
v9.1.5
add 8feba9caf MINIFICPP-2603 Add Record Reader and Record Writer
properties to MQTT processors
add 034d4d19b Review update
add 06aedaf4d Add RercordConverter struct
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 (70d0b7f97)
\
N -- N -- N refs/heads/MINIFICPP-2603 (06aedaf4d)
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:
.clang-tidy | 6 +-
.dockerignore | 2 +-
.github/workflows/ci.yml | 46 +-
.github/workflows/verify-package.yml | 23 +-
.gitignore | 8 +-
C2.md | 3 -
CMakeLists.txt | 233 ++--
CONFIGURE.md | 118 +-
CONTRIBUTING.md | 3 -
CONTROLLERS.md | 36 +-
LICENSE | 59 +-
NOTICE | 3 +-
OPS.md | 109 +-
PROCESSORS.md | 260 ++--
README.md | 93 +-
SITE_TO_SITE.md | 137 ++
ThirdParties.md | 7 -
aptitude.sh | 89 --
arch.sh | 77 --
bin/CMakeLists.txt | 71 +
bin/flowstatus-minifi.bat | 46 +
bin/{minifi.service => minifi.service.in} | 5 +-
bin/minifi.sh | 24 +-
bootstrap.sh | 517 --------
bootstrap/minifi_option.py | 2 +-
bstrp_functions.sh | 471 -------
centos.sh | 99 --
cmake/AzureSdkCpp.cmake | 32 +-
cmake/BundledLibXml2.cmake | 102 --
cmake/BundledLibcURL.cmake | 1 +
cmake/BundledOpenCV.cmake | 12 +-
cmake/BundledOpenSSL.cmake | 31 +-
cmake/BundledZLIB.cmake | 12 +-
cmake/Catch2.cmake | 4 +-
cmake/DockerConfig.cmake | 16 +-
cmake/ExpectedLite.cmake | 2 +-
cmake/Extensions.cmake | 22 +-
cmake/GetLibXml2.cmake | 3 +-
cmake/Grpc.cmake | 17 +-
cmake/{Sol2.cmake => Jsoncons.cmake} | 11 +-
cmake/LibXml2.cmake | 55 +
cmake/MiNiFiOptions.cmake | 11 +-
cmake/Protobuf.cmake | 37 +
cmake/VerifyPackageWithDocker.cmake | 4 +
cmake/Zstd.cmake | 9 +-
cmake/zlib/dummy/FindZLIB.cmake | 4 -
conanfile.py | 4 +-
conf/CMakeLists.txt | 91 ++
conf/{config.yml => config.yml.in} | 0
...ifi-log.properties => minifi-log.properties.in} | 3 +-
...ifi-uid.properties => minifi-uid.properties.in} | 0
conf/{minifi.properties => minifi.properties.in} | 18 +-
controller/CMakeLists.txt | 27 +-
controller/Controller.cpp | 48 +-
controller/Controller.h | 1 +
controller/MiNiFiController.cpp | 100 +-
controller/tests/CMakeLists.txt | 20 +-
controller/tests/ControllerTests.cpp | 95 +-
core-framework/CMakeLists.txt | 22 +
core-framework/include/Defaults.h | 32 +
.../include/agent/agent_docs.h | 3 +-
.../include/core/BufferedContentSession.h | 2 +-
.../include/core/ClassLoader.h | 9 +-
{utils => core-framework}/include/core/ClassName.h | 0
.../include/core/ConfigurableComponentImpl.h | 6 +-
.../include/core/Connectable.h | 2 +-
.../include/core/ContentRepository.h | 2 +-
.../include/core/ContentSession.h | 5 +-
{utils => core-framework}/include/core/Core.h | 0
.../include/core/ObjectFactory.h | 32 +-
.../include/core/ProcessContext.h | 86 +-
.../include/core/ProcessContextBuilder.h | 3 +-
.../include/core/ProcessorFactoryImpl.h | 46 +-
core-framework/include/core/ProcessorImpl.h | 156 +++
.../include/core/ProcessorMetrics.h | 6 +-
.../include/core/PropertyDefinitionBuilder.h | 13 +-
.../include/core/Relationship.h | 0
.../include/core/Repository.h | 8 +-
.../include/core/RepositoryMetricsSource.h | 0
{utils => core-framework}/include/core/Resource.h | 15 +-
.../include/core/StreamManager.h | 4 +-
.../include/core/ThreadedRepository.h | 0
.../include/core/TypedValues.h | 6 +-
.../include/core/VariableRegistry.h | 0
.../include/core/controller/ControllerService.h | 4 +
{utils => core-framework}/include/core/expect.h | 0
.../include/core/extension/Extension.h | 14 +-
.../include/core/logging/LoggerFactory.h | 0
.../include/core/state/MetricsPublisher.h | 2 +-
.../include/core/state/PublishedMetricProvider.h | 0
.../include/core/state/Value.h | 0
.../include/core/state/nodes/ResponseNode.h | 20 +-
.../include/http/BaseHTTPClient.h | 39 +-
.../include/http/HTTPCallback.h | 0
.../include/http/HTTPClient.h | 17 +-
.../include/http/HTTPStream.h | 0
{utils => core-framework}/include/io/AsioStream.h | 0
{utils => core-framework}/include/io/BaseStream.h | 0
.../include/io/BufferStream.h | 14 +-
{utils => core-framework}/include/io/CRCStream.h | 8 +-
{utils => core-framework}/include/io/FileStream.h | 0
{utils => core-framework}/include/io/InputStream.h | 0
.../include/io/OutputStream.h | 0
{utils => core-framework}/include/io/Stream.h | 0
{utils => core-framework}/include/io/StreamPipe.h | 4 +-
{utils => core-framework}/include/io/StreamSlice.h | 0
{utils => core-framework}/include/io/ZlibStream.h | 2 +-
{utils => core-framework}/include/io/validation.h | 0
.../include/utils/ArrayUtils.h | 0
.../include/utils/AttributeErrors.h | 0
.../include/utils/AutoPersistor.h | 2 +-
.../include/utils/BackTrace.h | 0
.../include/utils/ByteArrayCallback.h | 4 +-
.../include/utils/CallBackTimer.h | 0
.../include/utils/ClassUtils.h | 0
.../include/utils/CollectionUtils.h | 12 +-
.../include/utils/ConfigurationUtils.h | 0
{utils => core-framework}/include/utils/Cron.h | 2 +-
{utils => core-framework}/include/utils/Deleters.h | 0
{utils => core-framework}/include/utils/Enum.h | 0
.../include/utils/Environment.h | 2 +-
{utils => core-framework}/include/utils/Error.h | 0
.../include/utils/FailurePolicy.h | 0
.../include/utils/FifoExecutor.h | 0
.../include/utils/FileMutex.h | 2 +-
.../include/utils/GeneralUtils.h | 2 +-
.../include/utils/HTTPUtils.h | 0
{utils => core-framework}/include/utils/Hash.h | 0
{utils => core-framework}/include/utils/Id.h | 0
.../include/utils/IntervalSwitch.h | 14 +-
.../include/utils/JsonCallback.h | 12 +-
.../utils/LineByLineInputOutputStreamCallback.h | 6 +-
core-framework/include/utils/Locations.h | 51 +
{utils => core-framework}/include/utils/LogUtils.h | 0
{utils => core-framework}/include/utils/Macro.h | 0
{utils => core-framework}/include/utils/MapUtils.h | 14 +-
.../include/utils/MinifiConcurrentQueue.h | 0
{utils => core-framework}/include/utils/Monitors.h | 0
.../include/utils/OptionalUtils.h | 2 +-
{utils => core-framework}/include/utils/OsUtils.h | 0
.../include/utils/ParsingErrors.h | 0
.../include/utils/ParsingUtils.h | 4 +-
.../include/utils/ProcessCpuUsageTracker.h | 0
.../include/utils/PropertyErrors.h | 3 +-
.../include/utils/RegexUtils.h | 0
{utils => core-framework}/include/utils/Searcher.h | 0
.../include/utils/SmallString.h | 0
.../include/utils/StoppableThread.h | 0
.../include/utils/StringUtils.h | 8 +-
.../include/utils/SystemCpuUsageTracker.h | 0
.../include/utils/ThreadPool.h | 3 +-
{utils => core-framework}/include/utils/TimeUtil.h | 0
.../include/utils/TryMoveCall.h | 12 +-
.../include/utils/UnicodeConversion.h | 0
.../include/utils/ValueCaster.h | 0
.../include/utils/ValueParser.h | 2 +-
.../include/utils/crypto/EncryptionManager.h | 2 +-
.../include/utils/crypto/EncryptionProvider.h | 2 +-
.../include/utils/crypto/EncryptionUtils.h | 0
.../include/utils/crypto/ciphers/Aes256Ecb.h | 18 +-
.../include/utils/crypto/ciphers/XSalsa20.h | 0
.../property_encryption/PropertyEncryptionUtils.h | 0
.../utils/detail/MonadicOperationWrappers.h | 0
{utils => core-framework}/include/utils/expected.h | 0
.../include/utils/file/FilePattern.h | 0
.../include/utils/file/FileUtils.h | 2 +-
.../include/utils/file/PathUtils.h | 0
.../include/utils/meta/detected.h | 0
.../include/utils/meta/type_list.h | 0
.../include/utils/net/AsioCoro.h | 0
.../include/utils/net/AsioSocketUtils.h | 23 +-
{utils => core-framework}/include/utils/net/DNS.h | 0
.../include/utils/net/NetworkInterfaceInfo.h | 2 +-
.../include/utils/net/Socket.h | 0
.../include/utils/requirements/Container.h | 12 +-
.../utils/requirements/EqualityComparable.h | 12 +-
.../utils/requirements/LegacyForwardIterator.h | 12 +-
.../utils/requirements/LegacyInputIterator.h | 12 +-
.../include/utils/requirements/LegacyIterator.h | 12 +-
.../include/utils/requirements/Swappable.h | 12 +-
{utils => core-framework}/include/utils/span.h | 0
.../src/core/BufferedContentSession.cpp | 6 +-
.../src/core/ConfigurableComponentImpl.cpp | 0
{utils => core-framework}/src/core/Connectable.cpp | 2 +
.../src/core/ContentRepository.cpp | 0
.../src/core/ContentSession.cpp | 1 -
{utils => core-framework}/src/core/Core.cpp | 0
.../src/core/ProcessContextBuilder.cpp | 0
.../src/core/ProcessSession.cpp | 0
core-framework/src/core/ProcessorImpl.cpp | 99 ++
.../src/core/ProcessorMetrics.cpp | 6 +-
{utils => core-framework}/src/core/Property.cpp | 4 +-
{utils => core-framework}/src/core/Repository.cpp | 0
{utils => core-framework}/src/core/TypedValues.cpp | 2 +-
.../src/core/extension/Extension.cpp | 0
.../src/http/BaseHTTPClient.cpp | 7 +-
{utils => core-framework}/src/http/HTTPClient.cpp | 18 +-
{utils => core-framework}/src/http/HTTPStream.cpp | 2 +-
{utils => core-framework}/src/io/BufferStream.cpp | 2 +-
{utils => core-framework}/src/io/CPPLINT.cfg | 0
{utils => core-framework}/src/io/CRCStream.cpp | 0
{utils => core-framework}/src/io/FileStream.cpp | 10 +-
{utils => core-framework}/src/io/InputStream.cpp | 2 +-
{utils => core-framework}/src/io/OutputStream.cpp | 14 +-
{utils => core-framework}/src/io/StreamSlice.cpp | 0
{utils => core-framework}/src/io/ZlibStream.cpp | 6 +-
.../src/utils/AutoPersistor.cpp | 0
{utils => core-framework}/src/utils/BackTrace.cpp | 0
.../src/utils/ByteArrayCallback.cpp | 8 +-
.../src/utils/CallBackTimer.cpp | 0
{utils => core-framework}/src/utils/ClassUtils.cpp | 0
.../src/utils/ConfigurationUtils.cpp | 0
{utils => core-framework}/src/utils/Cron.cpp | 0
.../src/utils/Environment.cpp | 2 +-
{utils => core-framework}/src/utils/Error.cpp | 2 +-
.../src/utils/FifoExecutor.cpp | 2 +-
{utils => core-framework}/src/utils/FileMutex.cpp | 2 +-
{utils => core-framework}/src/utils/HTTPUtils.cpp | 0
{utils => core-framework}/src/utils/Id.cpp | 6 +-
.../utils/LineByLineInputOutputStreamCallback.cpp | 2 +-
{utils => core-framework}/src/utils/OsUtils.cpp | 10 +-
.../src/utils/ParsingUtils.cpp | 0
.../src/utils/ProcessCpuUsageTracker.cpp | 0
{utils => core-framework}/src/utils/RegexUtils.cpp | 2 +-
.../src/utils/StoppableThread.cpp | 2 +-
.../src/utils/StringUtils.cpp | 0
.../src/utils/SystemCpuUsageTracker.cpp | 5 +-
{utils => core-framework}/src/utils/ThreadPool.cpp | 6 +-
{utils => core-framework}/src/utils/TimeUtil.cpp | 0
.../src/utils/crypto/EncryptionManager.cpp | 6 +-
.../src/utils/crypto/EncryptionProvider.cpp | 0
.../src/utils/crypto/EncryptionUtils.cpp | 0
.../src/utils/crypto/ciphers/Aes256Ecb.cpp | 4 +-
.../PropertyEncryptionUtils.cpp | 0
.../src/utils/file/FilePattern.cpp | 0
.../src/utils/file/FileUtils.cpp | 2 +-
.../src/utils/file/PathUtils.cpp | 2 +-
.../src/utils/net/AsioSocketUtils.cpp | 8 +-
{utils => core-framework}/src/utils/net/DNS.cpp | 2 +-
.../src/utils/net/NetworkInterfaceInfo.cpp | 6 +-
{utils => core-framework}/src/utils/net/Socket.cpp | 2 +-
darwin.sh | 109 --
debian.sh | 90 --
deploy.sh | 28 -
docker/DockerBuild.sh | 9 +-
docker/DockerVerify.sh | 2 +-
docker/Dockerfile | 16 +-
docker/compiler-test/gcc.Dockerfile | 2 +-
.../installed.Dockerfile | 8 +-
.../installed.dockerignore | 0
.../rpm.Dockerfile} | 18 +-
docker/rockylinux/Dockerfile | 22 +-
docker/test/integration/cluster/ContainerStore.py | 3 +
.../test/integration/cluster/DockerTestCluster.py | 5 +-
docker/test/integration/cluster/ImageStore.py | 76 +-
.../cluster/MinifiControllerExecutor.py | 23 +-
.../integration/cluster/checkers/KafkaHelper.py | 8 +-
.../containers/AzureStorageServerContainer.py | 2 +-
.../cluster/containers/ElasticsearchContainer.py | 2 +-
.../cluster/containers/KafkaBrokerContainer.py | 68 +-
.../containers/MinifiAsPodInKubernetesCluster.py | 2 +-
.../cluster/containers/MinifiContainer.py | 52 +-
.../cluster/containers/NifiContainer.py | 2 +-
.../features/MiNiFi_integration_test_driver.py | 20 +-
.../features/core_functionality.feature | 15 +
docker/test/integration/features/couchbase.feature | 16 +-
docker/test/integration/features/environment.py | 5 +-
.../features/evaluate_json_path.feature | 50 +
.../test/integration/features/kubernetes.feature | 1 +
.../test/integration/features/lua_script.feature | 2 +-
.../integration/features/minifi_c2_server.feature | 8 -
docker/test/integration/features/python.feature | 91 +-
docker/test/integration/features/s2s.feature | 285 +++-
.../test/integration/features/split_json.feature | 42 +
docker/test/integration/features/steps/steps.py | 98 +-
.../integration/minifi/controllers/XMLReader.py | 2 -
docker/test/integration/minifi/core/Connectable.py | 3 +
docker/test/integration/minifi/core/InputPort.py | 7 +
.../minifi/core/{InputPort.py => OutputPort.py} | 11 +-
.../integration/minifi/core/RemoteProcessGroup.py | 3 +-
.../Minifi_flow_json_serializer.py | 100 +-
.../Minifi_flow_yaml_serializer.py | 109 +-
.../Nifi_flow_json_serializer.py | 26 +-
...{ExecutePythonProcessor.py => ConvertRecord.py} | 10 +-
.../{AttributesToJSON.py => EvaluateJsonPath.py} | 4 +-
... => ExpressionLanguagePropertyWithValidator.py} | 6 +-
.../{ListFile.py => LogDynamicProperties.py} | 12 +-
...Nothing.py => NifiStyleLogDynamicProperties.py} | 6 +-
.../processors/{SplitText.py => SplitJson.py} | 10 +-
.../kubernetes/minifi-conf/minifi.properties | 10 +
.../integration/resources/minifi/minifi.properties | 7 -
.../ExpressionLanguagePropertyWithValidator.py | 53 +
...bute_to_flowfile.py => LogDynamicProperties.py} | 16 +-
.../python/NifiStyleLogDynamicProperties.py | 55 +
encrypt-config/CMakeLists.txt | 22 +-
encrypt-config/ConfigFile.h | 13 +-
encrypt-config/ConfigFileEncryptor.cpp | 12 +-
encrypt-config/ConfigFileEncryptor.h | 12 +-
encrypt-config/EncryptConfig.cpp | 5 +-
encrypt-config/EncryptConfigMain.cpp | 2 +-
encrypt-config/FlowConfigEncryptor.cpp | 13 +-
encrypt-config/Utils.h | 12 +-
encrypt-config/tests/ConfigFileEncryptorTests.cpp | 2 +-
encrypt-config/tests/ConfigFileTests.cpp | 10 +-
encrypt-config/tests/resources/minifi.properties | 1 -
...th-additional-sensitive-props.minifi.properties | 1 -
.../CMakeLists.txt | 16 +-
.../include/controllers/AttributeProviderService.h | 0
.../include/controllers/RecordSetReader.h | 0
.../include/controllers/RecordSetWriter.h | 0
.../controllers/keyvalue/KeyValueStateManager.h | 2 +-
.../controllers/keyvalue/KeyValueStateStorage.h | 0
.../include/core/AbstractProcessor.h | 9 +-
.../include/core/FlowFileStore.h | 2 +-
.../include/core/ProcessSession.h | 0
.../include/core/StateManager.h | 3 +-
.../include/core/StateStorage.h | 6 +-
.../include/serialization/FlowFileSerializer.h | 10 +-
.../include/serialization/FlowFileV3Serializer.h | 10 +-
.../include/serialization/PayloadSerializer.h | 12 +-
.../include/utils/ListingStateManager.h | 4 +-
.../include/utils/OpenTelemetryLogDataModelUtils.h | 0
.../include/utils/ProcessorConfigUtils.h | 78 +-
.../include/utils/ResourceQueue.h | 2 +-
.../include/utils/file/FileManager.h | 0
.../include/utils/file/FileReaderCallback.h | 2 +-
.../include/utils/file/FileWriterCallback.h | 0
.../include/utils/file/ListedFile.h | 0
.../include/utils/net/ConnectionHandler.h | 0
.../include/utils/net/ConnectionHandlerBase.h | 0
.../include/utils/net/IpProtocol.h | 0
.../include/utils/net/Message.h | 0
.../include/utils/net/Server.h | 2 +-
.../include/utils/net/Ssl.h | 6 +-
.../include/utils/net/TcpServer.h | 0
.../include/utils/net/UdpServer.h | 2 +-
.../controllers/keyvalue/KeyValueStateManager.cpp | 0
.../controllers/keyvalue/KeyValueStateStorage.cpp | 4 +-
.../src/serialization/FlowFileV3Serializer.cpp | 6 +-
.../src/serialization/PayloadSerializer.cpp | 0
.../src/utils/ListingStateManager.cpp | 6 +-
.../src/utils/file/FileReaderCallback.cpp | 0
.../src/utils/file/FileWriterCallback.cpp | 0
.../src/utils/net/Ssl.cpp | 8 +-
.../src/utils/net/TcpServer.cpp | 2 +-
.../src/utils/net/UdpServer.cpp | 0
extension-utils/include/FlowFileRecord.h | 21 -
extension-utils/include/ResourceClaim.h | 21 -
.../include/controllers/SSLContextService.h | 19 -
extension-utils/include/core/FlowFile.h | 20 -
extension-utils/include/properties/Configure.h | 19 -
extension-utils/include/properties/Properties.h | 19 -
extension-utils/src/core/ProcessContext.cpp | 22 -
extensions/aws/AWSCredentialsProvider.cpp | 2 +-
extensions/aws/AWSCredentialsProvider.h | 14 +-
extensions/aws/CMakeLists.txt | 2 -
.../aws/controllerservices/AWSCredentialsService.h | 2 +-
extensions/aws/processors/AwsProcessor.cpp | 19 +-
extensions/aws/processors/AwsProcessor.h | 11 +-
extensions/aws/processors/DeleteS3Object.cpp | 2 +-
extensions/aws/processors/DeleteS3Object.h | 12 +-
extensions/aws/processors/FetchS3Object.cpp | 2 +-
extensions/aws/processors/FetchS3Object.h | 12 +-
extensions/aws/processors/ListS3.cpp | 2 +-
extensions/aws/processors/ListS3.h | 12 +-
extensions/aws/processors/PutKinesisStream.cpp | 2 +-
extensions/aws/processors/PutKinesisStream.h | 10 +-
extensions/aws/processors/PutS3Object.cpp | 8 +-
extensions/aws/processors/PutS3Object.h | 20 +-
extensions/aws/processors/S3Processor.cpp | 12 +-
extensions/aws/processors/S3Processor.h | 13 +-
extensions/aws/s3/MultipartUploadStateStorage.cpp | 2 +-
extensions/aws/s3/MultipartUploadStateStorage.h | 6 +-
extensions/aws/s3/S3RequestSender.h | 2 +-
extensions/aws/s3/S3Wrapper.cpp | 2 +-
extensions/aws/s3/S3Wrapper.h | 10 +-
extensions/aws/tests/AWSCredentialsServiceTest.cpp | 2 +-
.../aws/tests/MultipartUploadStateStorageTest.cpp | 2 +-
extensions/aws/tests/PutKinesisStreamTests.cpp | 41 +-
extensions/aws/tests/PutS3ObjectTests.cpp | 4 +-
extensions/aws/tests/S3TestsFixture.h | 8 +-
extensions/aws/utils/AWSInitializer.h | 14 +-
extensions/aws/utils/AWSSdkLogger.cpp | 2 +-
extensions/aws/utils/AWSSdkLogger.h | 2 +-
extensions/azure/CMakeLists.txt | 3 -
.../AzureStorageCredentialsService.cpp | 13 +-
.../AzureStorageCredentialsService.h | 32 +-
.../processors/AzureBlobStorageProcessorBase.cpp | 27 +-
.../processors/AzureBlobStorageProcessorBase.h | 44 +-
.../AzureBlobStorageSingleBlobProcessorBase.cpp | 2 +-
.../AzureBlobStorageSingleBlobProcessorBase.h | 8 +-
.../AzureDataLakeStorageFileProcessorBase.h | 11 +-
.../processors/AzureDataLakeStorageProcessorBase.h | 16 +-
.../azure/processors/AzureStorageProcessorBase.cpp | 2 +-
.../azure/processors/AzureStorageProcessorBase.h | 15 +-
.../azure/processors/DeleteAzureBlobStorage.h | 12 +-
.../processors/DeleteAzureDataLakeStorage.cpp | 2 +-
.../azure/processors/DeleteAzureDataLakeStorage.h | 8 +-
.../azure/processors/FetchAzureBlobStorage.cpp | 5 +-
.../azure/processors/FetchAzureBlobStorage.h | 14 +-
.../azure/processors/FetchAzureDataLakeStorage.cpp | 8 +-
.../azure/processors/FetchAzureDataLakeStorage.h | 13 +-
extensions/azure/processors/ListAzureBlobStorage.h | 12 +-
.../azure/processors/ListAzureDataLakeStorage.h | 8 +-
.../azure/processors/PutAzureBlobStorage.cpp | 2 +-
extensions/azure/processors/PutAzureBlobStorage.h | 14 +-
.../azure/processors/PutAzureDataLakeStorage.cpp | 15 +-
.../azure/processors/PutAzureDataLakeStorage.h | 12 +-
extensions/azure/storage/AzureBlobStorage.h | 6 +-
.../azure/storage/AzureBlobStorageClient.cpp | 29 +-
extensions/azure/storage/AzureBlobStorageClient.h | 4 +-
extensions/azure/storage/AzureDataLakeStorage.cpp | 2 +-
extensions/azure/storage/AzureDataLakeStorage.h | 4 +-
.../azure/storage/AzureDataLakeStorageClient.cpp | 10 +-
.../azure/storage/AzureDataLakeStorageClient.h | 3 +-
.../azure/storage/AzureStorageCredentials.cpp | 51 +-
extensions/azure/storage/AzureStorageCredentials.h | 17 +-
extensions/azure/storage/BlobStorageClient.h | 4 +-
extensions/azure/storage/DataLakeStorageClient.h | 4 +-
.../azure/tests/AzureBlobStorageTestsFixture.h | 6 +-
.../azure/tests/AzureDataLakeStorageTestsFixture.h | 8 +-
.../azure/tests/DeleteAzureBlobStorageTests.cpp | 74 +-
.../tests/DeleteAzureDataLakeStorageTests.cpp | 32 +-
.../azure/tests/FetchAzureBlobStorageTests.cpp | 74 +-
.../azure/tests/FetchAzureDataLakeStorageTests.cpp | 46 +-
.../azure/tests/ListAzureBlobStorageTests.cpp | 71 +-
.../azure/tests/ListAzureDataLakeStorageTests.cpp | 48 +-
.../azure/tests/PutAzureBlobStorageTests.cpp | 74 +-
.../azure/tests/PutAzureDataLakeStorageTests.cpp | 32 +-
extensions/azure/utils/AzureEnums.h | 28 +
extensions/azure/utils/AzureSdkLogger.h | 2 +-
extensions/bustache/ApplyTemplate.cpp | 2 +-
extensions/bustache/ApplyTemplate.h | 7 +-
extensions/bustache/CMakeLists.txt | 1 -
extensions/bustache/tests/ApplyTemplateTests.cpp | 5 +-
extensions/civetweb/CMakeLists.txt | 1 -
extensions/civetweb/processors/ListenHTTP.cpp | 21 +-
extensions/civetweb/processors/ListenHTTP.h | 20 +-
extensions/civetweb/tests/C2VerifyServeResults.cpp | 13 +-
extensions/civetweb/tests/CMakeLists.txt | 19 +-
.../civetweb/tests/HttpPostIntegrationTest.cpp | 16 +-
extensions/civetweb/tests/ListenHTTPTests.cpp | 147 ++-
extensions/couchbase/CMakeLists.txt | 1 -
.../controllerservices/CouchbaseClusterService.cpp | 24 +-
.../controllerservices/CouchbaseClusterService.h | 12 +-
.../couchbase/processors/GetCouchbaseKey.cpp | 5 +-
.../couchbase/processors/PutCouchbaseKey.cpp | 5 +-
.../couchbase/tests/GetCouchbaseKeyTests.cpp | 3 +-
.../couchbase/tests/PutCouchbaseKeyTests.cpp | 3 +-
extensions/elasticsearch/CMakeLists.txt | 1 -
.../ElasticsearchCredentialsControllerService.h | 2 +-
extensions/elasticsearch/PostElasticsearch.cpp | 19 +-
extensions/elasticsearch/PostElasticsearch.h | 17 +-
extensions/elasticsearch/tests/MockElastic.h | 2 +-
.../elasticsearch/tests/PostElasticsearchTests.cpp | 5 +-
extensions/execute-process/CMakeLists.txt | 1 -
extensions/execute-process/ExecuteProcess.cpp | 20 +-
extensions/execute-process/ExecuteProcess.h | 18 +-
.../execute-process/test/ExecuteProcessTests.cpp | 7 +-
extensions/expression-language/CMakeLists.txt | 1 -
extensions/expression-language/Driver.h | 12 +-
extensions/expression-language/Expression.cpp | 5 +-
extensions/expression-language/Parser.yy | 12 +-
.../expression-language/ProcessContextExpr.cpp | 8 +-
.../expression-language/ProcessContextExpr.h | 18 +-
.../impl/expression/Expression.h | 2 +-
.../tests/ExpressionLanguageTests.cpp | 24 +-
.../tests/ProcessContextExprTests.cpp | 71 +-
.../integration/UpdateAttributeIntegrationTest.cpp | 7 +-
extensions/gcp/CMakeLists.txt | 1 -
extensions/gcp/GCPAttributes.h | 2 +-
.../GCPCredentialsControllerService.h | 4 +-
extensions/gcp/processors/DeleteGCSObject.cpp | 4 +-
extensions/gcp/processors/DeleteGCSObject.h | 8 +-
extensions/gcp/processors/FetchGCSObject.cpp | 4 +-
extensions/gcp/processors/FetchGCSObject.h | 8 +-
extensions/gcp/processors/GCSProcessor.cpp | 9 +-
extensions/gcp/processors/GCSProcessor.h | 12 +-
extensions/gcp/processors/ListGCSBucket.cpp | 4 +-
extensions/gcp/processors/ListGCSBucket.h | 10 +-
extensions/gcp/processors/PutGCSObject.cpp | 4 +-
extensions/gcp/processors/PutGCSObject.h | 8 +-
extensions/gcp/tests/DeleteGCSObjectTests.cpp | 17 +-
extensions/gcp/tests/FetchGCSObjectTests.cpp | 15 +-
.../tests/GCPCredentialsControllerServiceTests.cpp | 6 +-
extensions/gcp/tests/ListGCSBucketTests.cpp | 17 +-
extensions/gcp/tests/PutGCSObjectTests.cpp | 47 +-
extensions/grafana-loki/CMakeLists.txt | 2 -
extensions/grafana-loki/PushGrafanaLoki.cpp | 25 +-
extensions/grafana-loki/PushGrafanaLoki.h | 22 +-
extensions/grafana-loki/PushGrafanaLokiGrpc.cpp | 22 +-
extensions/grafana-loki/PushGrafanaLokiGrpc.h | 5 +-
extensions/grafana-loki/PushGrafanaLokiREST.cpp | 3 +-
extensions/grafana-loki/PushGrafanaLokiREST.h | 4 +-
.../grafana-loki/tests/MockGrafanaLokiREST.h | 2 +-
.../grafana-loki/tests/PushGrafanaLokiGrpcTest.cpp | 12 +-
.../grafana-loki/tests/PushGrafanaLokiRESTTest.cpp | 14 +-
extensions/kafka/CMakeLists.txt | 1 -
extensions/kafka/ConsumeKafka.cpp | 6 +-
extensions/kafka/ConsumeKafka.h | 7 +-
extensions/kafka/KafkaConnection.cpp | 2 +-
extensions/kafka/KafkaConnection.h | 4 +-
extensions/kafka/KafkaProcessorBase.cpp | 2 +-
extensions/kafka/KafkaProcessorBase.h | 12 +-
extensions/kafka/PublishKafka.cpp | 10 +-
extensions/kafka/PublishKafka.h | 15 +-
extensions/kafka/rdkafka_utils.cpp | 2 +-
extensions/kafka/tests/PublishKafkaTests.cpp | 17 +-
extensions/kubernetes/ApiClient.h | 2 +-
extensions/kubernetes/CMakeLists.txt | 1 -
.../KubernetesControllerService.cpp | 4 +-
.../KubernetesControllerService.h | 4 +-
.../processors/CollectKubernetesPodMetrics.cpp | 18 +-
.../processors/CollectKubernetesPodMetrics.h | 9 +-
extensions/libarchive/ArchiveMetadata.cpp | 4 +-
extensions/libarchive/BinFiles.cpp | 12 +-
extensions/libarchive/BinFiles.h | 12 +-
extensions/libarchive/CMakeLists.txt | 1 -
extensions/libarchive/CompressContent.cpp | 2 +-
extensions/libarchive/CompressContent.h | 15 +-
extensions/libarchive/FocusArchiveEntry.cpp | 23 +-
extensions/libarchive/FocusArchiveEntry.h | 19 +-
extensions/libarchive/ManipulateArchive.cpp | 10 +-
extensions/libarchive/ManipulateArchive.h | 15 +-
extensions/libarchive/MergeContent.cpp | 2 +-
extensions/libarchive/MergeContent.h | 9 +-
extensions/libarchive/ReadArchiveStream.h | 3 +-
extensions/libarchive/UnfocusArchiveEntry.cpp | 4 +-
extensions/libarchive/UnfocusArchiveEntry.h | 11 +-
extensions/libarchive/WriteArchiveStream.h | 2 +-
.../libarchive/tests/CompressContentTests.cpp | 625 +++++----
extensions/libarchive/tests/FocusArchiveTests.cpp | 5 +-
.../libarchive/tests/ManipulateArchiveTests.cpp | 5 +-
extensions/libarchive/tests/MergeFileTests.cpp | 20 +-
extensions/libarchive/tests/util/ArchiveTests.cpp | 4 +-
extensions/llamacpp/CMakeLists.txt | 1 -
.../llamacpp/processors/DefaultLlamaContext.cpp | 2 +-
.../llamacpp/processors/RunLlamaCppInference.cpp | 4 +-
.../llamacpp/processors/RunLlamaCppInference.h | 9 +-
.../llamacpp/tests/RunLlamaCppInferenceTests.cpp | 32 +-
extensions/lua/CMakeLists.txt | 1 -
extensions/lua/LuaInputStream.h | 2 +-
extensions/lua/LuaLogger.h | 1 -
extensions/lua/LuaOutputStream.h | 2 +-
extensions/lua/LuaScriptFlowFile.cpp | 10 +-
extensions/lua/LuaScriptFlowFile.h | 6 +-
extensions/lua/LuaScriptStateManager.h | 2 +-
.../TestExecuteScriptProcessorWithLuaScript.cpp | 23 +-
extensions/mqtt/CMakeLists.txt | 1 -
.../mqtt/processors/AbstractMQTTProcessor.cpp | 28 +-
extensions/mqtt/processors/AbstractMQTTProcessor.h | 35 +-
extensions/mqtt/processors/ConsumeMQTT.cpp | 51 +-
extensions/mqtt/processors/ConsumeMQTT.h | 29 +-
extensions/mqtt/processors/PublishMQTT.cpp | 28 +-
extensions/mqtt/processors/PublishMQTT.h | 30 +-
extensions/mqtt/tests/ConsumeMQTTTests.cpp | 207 ++-
extensions/mqtt/tests/PublishMQTTTests.cpp | 63 +-
extensions/opc/CMakeLists.txt | 1 -
extensions/opc/include/fetchopc.h | 62 +-
extensions/opc/include/opc.h | 6 +-
extensions/opc/include/opcbase.h | 13 +-
extensions/opc/include/putopc.h | 17 +-
extensions/opc/src/fetchopc.cpp | 114 +-
extensions/opc/src/opc.cpp | 9 +-
extensions/opc/src/opcbase.cpp | 3 +-
extensions/opc/src/putopc.cpp | 6 +-
extensions/opc/tests/FetchOpcProcessorTests.cpp | 113 +-
extensions/opc/tests/OpcUaTestServer.h | 30 +-
extensions/opc/tests/PutOpcProcessorTests.cpp | 58 +-
extensions/opencv/CMakeLists.txt | 1 -
extensions/opencv/CaptureRTSPFrame.cpp | 2 +-
extensions/opencv/CaptureRTSPFrame.h | 11 +-
extensions/opencv/MotionDetector.cpp | 2 +-
extensions/opencv/MotionDetector.h | 11 +-
extensions/pdh/CMakeLists.txt | 1 -
extensions/pdh/MemoryConsumptionCounter.h | 12 +-
extensions/pdh/PDHCounters.cpp | 12 +-
extensions/pdh/PDHCounters.h | 12 +-
extensions/pdh/PerformanceDataCounter.h | 12 +-
extensions/pdh/PerformanceDataMonitor.cpp | 20 +-
extensions/pdh/PerformanceDataMonitor.h | 25 +-
.../pdh/tests/PerformanceDataCounterTests.cpp | 2 +-
extensions/procfs/CMakeLists.txt | 1 -
extensions/procfs/DiskStat.cpp | 2 +-
extensions/procfs/NetDev.cpp | 2 +-
extensions/procfs/ProcFs.h | 2 +-
extensions/procfs/ProcFsSerialization.h | 167 +--
extensions/procfs/ProcessStat.cpp | 4 +-
extensions/procfs/processors/ProcFsMonitor.cpp | 4 +-
extensions/procfs/processors/ProcFsMonitor.h | 13 +-
extensions/procfs/tests/MemInfoTests.cpp | 2 +-
extensions/procfs/tests/ProcFsMonitorTests.cpp | 3 +-
extensions/prometheus/CMakeLists.txt | 1 -
extensions/prometheus/PrometheusExposerWrapper.h | 6 +-
extensions/prometheus/PrometheusMetricsPublisher.h | 2 +-
.../prometheus/PublishedMetricGaugeCollection.cpp | 2 +-
.../prometheus/PublishedMetricGaugeCollection.h | 4 +-
extensions/python/CMakeLists.txt | 23 +-
extensions/python/ExecutePythonProcessor.cpp | 233 +---
extensions/python/ExecutePythonProcessor.h | 79 +-
extensions/python/PYTHON.md | 144 +-
extensions/python/PythonBindings.cpp | 4 +-
extensions/python/PythonCreator.h | 109 +-
extensions/python/PythonDependencyInstaller.cpp | 65 +-
extensions/python/PythonDependencyInstaller.h | 4 +-
extensions/python/PythonObjectFactory.h | 58 +-
extensions/python/PythonProcessor.cpp | 6 +-
extensions/python/PythonProcessor.h | 6 +-
extensions/python/PythonScriptEngine.cpp | 4 +-
extensions/python/PythonScriptEngine.h | 12 +-
.../utils/dependency_installer.py | 22 +-
.../pythonprocessors/nifiapi/processorbase.py | 17 +-
.../python/pythonprocessors/nifiapi/properties.py | 2 +
.../python/tests/ExecutePythonProcessorTests.cpp | 179 +--
extensions/python/tests/PythonManifestTests.cpp | 17 +-
.../TestExecuteScriptProcessorWithPythonScript.cpp | 23 +-
extensions/python/types/PyInputStream.cpp | 2 +-
extensions/python/types/PyInputStream.h | 2 +-
extensions/python/types/PyLogger.cpp | 2 +-
extensions/python/types/PyLogger.h | 2 +-
extensions/python/types/PyOutputStream.h | 2 +-
extensions/python/types/PyProcessContext.cpp | 66 +-
extensions/python/types/PyProcessContext.h | 4 +-
extensions/python/types/PyProcessSession.cpp | 2 +-
extensions/python/types/PyProcessor.cpp | 47 +-
extensions/python/types/PyRecordSetReader.h | 2 +-
extensions/python/types/PyRecordSetWriter.h | 2 +-
extensions/python/types/PySSLContextService.h | 4 +-
extensions/python/types/PyScriptFlowFile.h | 2 +-
extensions/python/types/PyStateManager.h | 2 +-
extensions/python/types/Types.h | 2 +-
extensions/rocksdb-repos/CMakeLists.txt | 3 +-
.../rocksdb-repos/DatabaseContentRepository.cpp | 19 +-
.../rocksdb-repos/DatabaseContentRepository.h | 4 +-
extensions/rocksdb-repos/FlowFileLoader.cpp | 4 +-
extensions/rocksdb-repos/FlowFileLoader.h | 6 +-
extensions/rocksdb-repos/FlowFileRepository.cpp | 13 +-
extensions/rocksdb-repos/FlowFileRepository.h | 2 +-
extensions/rocksdb-repos/ProvenanceRepository.cpp | 1 -
extensions/rocksdb-repos/ProvenanceRepository.h | 2 +-
extensions/rocksdb-repos/RocksDbStream.cpp | 2 +-
extensions/rocksdb-repos/RocksDbStream.h | 12 +-
.../controllers/RocksDbStateStorage.cpp | 13 +-
.../controllers/RocksDbStateStorage.h | 4 +-
extensions/rocksdb-repos/database/OpenRocksDb.h | 4 +-
.../rocksdb-repos/database/RocksDatabase.cpp | 17 +-
extensions/rocksdb-repos/database/RocksDatabase.h | 4 +-
.../rocksdb-repos/database/RocksDbInstance.cpp | 5 +-
.../rocksdb-repos/database/RocksDbInstance.h | 4 +-
extensions/rocksdb-repos/database/RocksDbUtils.cpp | 4 +-
extensions/rocksdb-repos/database/RocksDbUtils.h | 2 +-
extensions/rocksdb-repos/database/WriteBatch.cpp | 12 +-
extensions/rocksdb-repos/database/WriteBatch.h | 13 +-
.../encryption/RocksDbEncryptionProvider.h | 2 +-
.../rocksdb-repos/tests/ContentSessionTests.cpp | 9 +-
.../tests/DBContentRepositoryTests.cpp | 16 +-
extensions/rocksdb-repos/tests/EncryptionTests.cpp | 2 +-
extensions/rocksdb-repos/tests/ProvenanceTests.cpp | 5 +-
extensions/rocksdb-repos/tests/RepoTests.cpp | 29 +-
extensions/rocksdb-repos/tests/SwapTests.cpp | 16 +-
extensions/script/CMakeLists.txt | 1 -
extensions/script/ExecuteScript.cpp | 2 +-
extensions/script/ExecuteScript.h | 11 +-
extensions/script/ScriptExecutor.h | 2 +-
extensions/sftp/CMakeLists.txt | 1 -
extensions/sftp/client/SFTPClient.cpp | 2 +-
extensions/sftp/client/SFTPClient.h | 4 +-
extensions/sftp/processors/FetchSFTP.cpp | 9 +-
extensions/sftp/processors/FetchSFTP.h | 8 +-
extensions/sftp/processors/ListSFTP.cpp | 15 +-
extensions/sftp/processors/ListSFTP.h | 10 +-
extensions/sftp/processors/PutSFTP.cpp | 12 +-
extensions/sftp/processors/PutSFTP.h | 12 +-
extensions/sftp/processors/SFTPProcessorBase.cpp | 21 +-
extensions/sftp/processors/SFTPProcessorBase.h | 12 +-
extensions/sftp/tests/ListSFTPTests.cpp | 10 +-
extensions/sftp/tests/ListThenFetchSFTPTests.cpp | 4 +-
extensions/sftp/tests/PutSFTPTests.cpp | 4 +-
extensions/sftp/tests/tools/SFTPTestServer.cpp | 4 +-
extensions/sftp/tests/tools/SFTPTestServer.h | 2 +-
extensions/smb/CMakeLists.txt | 1 -
extensions/smb/FetchSmb.cpp | 3 +-
extensions/smb/FetchSmb.h | 13 +-
extensions/smb/ListSmb.cpp | 2 +-
extensions/smb/ListSmb.h | 13 +-
extensions/smb/PutSmb.cpp | 4 +-
extensions/smb/PutSmb.h | 7 +-
extensions/smb/SmbConnectionControllerService.cpp | 12 +-
extensions/smb/SmbConnectionControllerService.h | 8 +-
extensions/smb/tests/FetchSmbTests.cpp | 5 +-
extensions/smb/tests/ListAndFetchSmbTests.cpp | 12 +-
extensions/smb/tests/ListSmbTests.cpp | 5 +-
extensions/smb/tests/PutSmbTests.cpp | 7 +-
.../tests/SmbConnectionControllerServiceTests.cpp | 1 -
.../utils/MockSmbConnectionControllerService.h | 1 -
extensions/splunk/CMakeLists.txt | 1 -
extensions/splunk/PutSplunkHTTP.cpp | 6 +-
extensions/splunk/PutSplunkHTTP.h | 13 +-
extensions/splunk/QuerySplunkIndexingStatus.cpp | 7 +-
extensions/splunk/QuerySplunkIndexingStatus.h | 10 +-
extensions/splunk/SplunkHECProcessor.cpp | 12 +-
extensions/splunk/SplunkHECProcessor.h | 18 +-
extensions/splunk/tests/MockSplunkHEC.h | 2 +-
extensions/splunk/tests/PutSplunkHTTPTests.cpp | 60 +-
.../tests/QuerySplunkIndexingStatusTests.cpp | 66 +-
extensions/sql/CMakeLists.txt | 1 -
extensions/sql/data/JSONSQLWriter.cpp | 2 +-
extensions/sql/data/SQLRowSubscriber.h | 12 +-
extensions/sql/data/SQLRowsetProcessor.cpp | 21 +-
extensions/sql/data/SociConnectors.h | 4 +-
extensions/sql/processors/ExecuteSQL.cpp | 8 +-
extensions/sql/processors/ExecuteSQL.h | 8 +-
extensions/sql/processors/FlowFileSource.h | 4 +-
extensions/sql/processors/PutSQL.cpp | 8 +-
extensions/sql/processors/PutSQL.h | 6 +-
extensions/sql/processors/QueryDatabaseTable.cpp | 10 +-
extensions/sql/processors/QueryDatabaseTable.h | 6 +-
extensions/sql/processors/SQLProcessor.cpp | 19 +-
extensions/sql/processors/SQLProcessor.h | 9 +-
extensions/sql/services/DatabaseService.cpp | 2 +-
extensions/sql/services/DatabaseService.h | 2 +-
extensions/sql/tests/FlowFileMatcher.h | 2 +-
extensions/sql/tests/PutSQLTests.cpp | 3 +-
extensions/sql/tests/SQLTestPlan.h | 2 +
extensions/standard-processors/CMakeLists.txt | 4 +-
.../controllers/InMemoryKeyValueStorage.h | 2 +-
.../controllers/JsonRecordSetWriter.h | 3 +-
.../controllers/JsonTreeReader.cpp | 6 +-
.../controllers/JsonTreeReader.h | 1 +
.../controllers/PersistentMapStateStorage.h | 6 +-
.../controllers/VolatileMapStateStorage.h | 6 +-
.../standard-processors/controllers/XMLReader.cpp | 43 +-
.../standard-processors/controllers/XMLReader.h | 21 +-
.../controllers/XMLRecordSetWriter.cpp | 69 +-
.../controllers/XMLRecordSetWriter.h | 12 +-
.../standard-processors/modbus/FetchModbusTcp.cpp | 30 +-
.../standard-processors/modbus/FetchModbusTcp.h | 15 +-
.../processors/AppendHostInfo.cpp | 4 +-
.../processors/AppendHostInfo.h | 13 +-
.../processors/AttributeRollingWindow.cpp | 4 +-
.../processors/AttributeRollingWindow.h | 5 +-
.../processors/AttributesToJSON.cpp | 6 +-
.../processors/AttributesToJSON.h | 15 +-
.../processors/ConvertRecord.cpp | 68 +
.../standard-processors/processors/ConvertRecord.h | 84 ++
.../processors/DefragmentText.cpp | 14 +-
.../processors/DefragmentText.h | 12 +-
.../processors/EvaluateJsonPath.cpp | 174 +++
.../processors/EvaluateJsonPath.h | 194 +++
.../standard-processors/processors/ExtractText.cpp | 6 +-
.../standard-processors/processors/ExtractText.h | 15 +-
.../standard-processors/processors/FetchFile.h | 11 +-
.../processors/GenerateFlowFile.cpp | 8 +-
.../processors/GenerateFlowFile.h | 17 +-
.../standard-processors/processors/GetFile.cpp | 8 +-
.../standard-processors/processors/GetFile.h | 17 +-
.../standard-processors/processors/GetTCP.cpp | 27 +-
extensions/standard-processors/processors/GetTCP.h | 22 +-
.../standard-processors/processors/HashContent.cpp | 4 +-
.../standard-processors/processors/HashContent.h | 13 +-
.../standard-processors/processors/InvokeHTTP.cpp | 35 +-
.../standard-processors/processors/InvokeHTTP.h | 27 +-
.../processors/JoltTransformJSON.h | 12 +-
.../standard-processors/processors/ListFile.cpp | 2 +-
.../standard-processors/processors/ListFile.h | 13 +-
.../processors/ListenSyslog.cpp | 5 +-
.../standard-processors/processors/ListenSyslog.h | 14 +-
.../standard-processors/processors/ListenTCP.cpp | 4 +-
.../standard-processors/processors/ListenTCP.h | 16 +-
.../standard-processors/processors/ListenUDP.cpp | 2 +-
.../standard-processors/processors/ListenUDP.h | 10 +-
.../processors/LogAttribute.cpp | 2 +-
.../standard-processors/processors/LogAttribute.h | 16 +-
.../processors/NetworkListenerProcessor.h | 16 +-
.../standard-processors/processors/PutFile.cpp | 16 +-
.../standard-processors/processors/PutFile.h | 15 +-
.../standard-processors/processors/PutTCP.cpp | 30 +-
extensions/standard-processors/processors/PutTCP.h | 26 +-
.../standard-processors/processors/PutUDP.cpp | 16 +-
extensions/standard-processors/processors/PutUDP.h | 13 +-
.../standard-processors/processors/ReplaceText.cpp | 11 +-
.../standard-processors/processors/ReplaceText.h | 18 +-
.../standard-processors/processors/RetryFlowFile.h | 18 +-
.../processors/RouteOnAttribute.cpp | 7 +-
.../processors/RouteOnAttribute.h | 11 +-
.../standard-processors/processors/RouteText.cpp | 23 +-
.../standard-processors/processors/RouteText.h | 14 +-
.../processors/SegmentContent.cpp | 4 +-
.../processors/SegmentContent.h | 14 +-
.../processors/SplitContent.cpp | 6 +-
.../standard-processors/processors/SplitContent.h | 14 +-
.../standard-processors/processors/SplitJson.cpp | 133 ++
.../standard-processors/processors/SplitJson.h | 123 ++
.../standard-processors/processors/SplitRecord.cpp | 20 +-
.../standard-processors/processors/SplitRecord.h | 18 +-
.../standard-processors/processors/SplitText.cpp | 8 +-
.../standard-processors/processors/SplitText.h | 13 +-
.../standard-processors/processors/TailFile.cpp | 43 +-
.../standard-processors/processors/TailFile.h | 18 +-
.../processors/TextFragmentUtils.h | 2 +-
.../processors/UpdateAttribute.cpp | 4 +-
.../processors/UpdateAttribute.h | 11 +-
.../tests/integration/InvokeHTTPTests.cpp | 28 +-
.../tests/integration/ProcessGroupTest.cpp | 9 +-
.../tests/integration/TailFileIntegrationTest.cpp | 7 +-
.../tests/integration/VerifyInvokeHTTP.h | 23 +-
.../tests/integration/VerifyInvokeHTTPGetTest.cpp | 10 +-
.../tests/integration/VerifyInvokeHTTPPostTest.cpp | 74 +-
.../tests/unit/AttributeRollingWindowTests.cpp | 5 +-
.../tests/unit/ControllerServiceTests.cpp | 4 +-
.../tests/unit/ConvertRecordTests.cpp | 103 ++
.../tests/unit/DefragmentTextTests.cpp | 254 ++--
.../tests/unit/EvaluateJsonPathTests.cpp | 325 +++++
.../tests/unit/ExtractTextTests.cpp | 6 +-
.../tests/unit/FetchFileTests.cpp | 8 +-
.../tests/unit/FlowJsonTests.cpp | 126 +-
.../tests/unit/GenerateFlowFileTests.cpp | 13 +-
.../tests/unit/GetFileTests.cpp | 4 +-
.../standard-processors/tests/unit/GetTCPTests.cpp | 18 +-
.../tests/unit/HashContentTest.cpp | 4 +-
.../tests/unit/HttpClientStoreTests.cpp | 12 +-
.../tests/unit/JoltTransformJSONTests.cpp | 14 +-
.../tests/unit/JsonRecordTests.cpp | 8 +-
.../tests/unit/ListFileTests.cpp | 6 +-
.../tests/unit/ListenSyslogTests.cpp | 30 +-
.../tests/unit/ListenTcpTests.cpp | 46 +-
.../tests/unit/ListenUDPTests.cpp | 12 +-
.../tests/unit/LogAttributeTests.cpp | 8 +-
.../tests/unit/ManifestTests.cpp | 158 ++-
.../tests/unit/ProcessGroupTestUtils.h | 2 +-
.../tests/unit/ProcessorTests.cpp | 45 +-
.../tests/unit/PutFileTests.cpp | 6 +-
.../standard-processors/tests/unit/PutTCPTests.cpp | 14 +-
.../standard-processors/tests/unit/PutUDPTests.cpp | 5 +-
.../tests/unit/RecordSetTests.cpp | 2 +-
.../tests/unit/ReplaceTextTests.cpp | 9 +-
.../tests/unit/RouteTextTests.cpp | 6 +-
.../tests/unit/SegmentContentTests.cpp | 17 +-
.../tests/unit/SplitContentTests.cpp | 51 +-
.../tests/unit/SplitJsonTests.cpp | 150 +++
.../tests/unit/SplitRecordTests.cpp | 3 +-
.../tests/unit/SplitTextTests.cpp | 27 +-
.../tests/unit/TailFileTests.cpp | 32 +-
.../tests/unit/XMLReaderTests.cpp | 10 +-
.../tests/unit/XMLRecordSetWriterTests.cpp | 2 +-
.../tests/unit/YamlConfigurationTests.cpp | 94 +-
.../tests/unit/YamlConnectionParserTest.cpp | 18 +-
extensions/standard-processors/utils/JoltUtils.cpp | 23 +-
extensions/standard-processors/utils/JoltUtils.h | 8 +-
extensions/systemd/CMakeLists.txt | 1 -
extensions/systemd/Common.h | 9 +-
extensions/systemd/ConsumeJournald.cpp | 14 +-
extensions/systemd/ConsumeJournald.h | 13 +-
extensions/systemd/libwrapper/DlopenWrapper.cpp | 4 +-
extensions/systemd/libwrapper/LibWrapper.cpp | 10 +-
extensions/systemd/libwrapper/LibWrapper.h | 12 +-
extensions/systemd/tests/ConsumeJournaldTest.cpp | 9 +-
extensions/test-processors/CMakeLists.txt | 1 -
extensions/test-processors/KamikazeProcessor.cpp | 4 +-
extensions/test-processors/KamikazeProcessor.h | 11 +-
.../test-processors/LogOnDestructionProcessor.h | 7 +-
extensions/windows-event-log/CMakeLists.txt | 1 -
.../windows-event-log/ConsumeWindowsEventLog.cpp | 293 ++---
.../windows-event-log/ConsumeWindowsEventLog.h | 77 +-
extensions/windows-event-log/TailEventLog.cpp | 4 +-
extensions/windows-event-log/TailEventLog.h | 25 +-
.../windows-event-log/tests/BookmarkTests.cpp | 13 +-
extensions/windows-event-log/tests/CMakeLists.txt | 2 +-
extensions/windows-event-log/tests/CWELTestUtils.h | 2 +-
.../tests/ConsumeWindowsEventLogTests.cpp | 33 +-
.../tests/MetadataWalkerTests.cpp | 174 +--
.../tests/StringSplitterTests.cpp | 45 +
.../windows-event-log/tests/WindowsErrorTests.cpp | 33 +-
.../windows-event-log/{ => wel}/Bookmark.cpp | 29 +-
extensions/windows-event-log/{ => wel}/Bookmark.h | 19 +-
extensions/windows-event-log/wel/EventPath.h | 4 +-
extensions/windows-event-log/wel/JSONUtils.cpp | 2 +-
extensions/windows-event-log/wel/JSONUtils.h | 20 +-
.../windows-event-log/wel/MetadataWalker.cpp | 69 +-
extensions/windows-event-log/wel/MetadataWalker.h | 34 +-
extensions/windows-event-log/wel/StringSplitter.h | 57 +
extensions/windows-event-log/wel/UniqueEvtHandle.h | 15 +-
.../wel/{LookupCacher.cpp => WindowsError.h} | 31 +-
.../windows-event-log/wel/WindowsEventLog.cpp | 62 +-
extensions/windows-event-log/wel/WindowsEventLog.h | 115 +-
extensions/windows-event-log/wel/XMLString.h | 17 +-
fedora.sh | 83 --
fips/openssl.cnf | 2 +-
generateVersion.bat | 18 +-
generateVersion.sh | 14 +-
libminifi/CMakeLists.txt | 16 +-
libminifi/include/Connection.h | 7 +-
libminifi/include/CronDrivenSchedulingAgent.h | 6 +-
libminifi/include/Defaults.h | 25 -
libminifi/include/EventDrivenSchedulingAgent.h | 6 +-
libminifi/include/FlowController.h | 18 +-
libminifi/include/FlowFileRecord.h | 6 +-
libminifi/include/ForwardingNode.h | 11 +-
libminifi/include/Funnel.h | 4 +-
libminifi/include/Port.h | 25 +-
...ocessorGroupPort.h => RemoteProcessGroupPort.h} | 214 ++-
libminifi/include/ResourceClaim.h | 2 +-
libminifi/include/RootProcessGroupWrapper.h | 11 +-
libminifi/include/SchedulingAgent.h | 8 +-
libminifi/include/ThreadedSchedulingAgent.h | 4 +-
libminifi/include/TimerDrivenSchedulingAgent.h | 6 +-
libminifi/include/agent/build_description.h | 5 +-
libminifi/include/c2/C2Agent.h | 2 +-
libminifi/include/c2/C2MetricsPublisher.h | 6 +-
libminifi/include/c2/C2Payload.h | 2 +-
libminifi/include/c2/C2Protocol.h | 7 +-
libminifi/include/c2/C2Trigger.h | 5 +-
libminifi/include/c2/C2Utils.h | 2 +-
.../include/c2/ControllerSocketMetricsPublisher.h | 6 +
libminifi/include/c2/ControllerSocketProtocol.h | 16 +-
libminifi/include/c2/ControllerSocketReporter.h | 10 +
libminifi/include/c2/FlowStatusBuilder.h | 63 +
...trollerSocketReporter.h => FlowStatusRequest.h} | 37 +-
libminifi/include/c2/HeartbeatLogger.h | 2 +-
libminifi/include/c2/HeartbeatReporter.h | 7 +-
libminifi/include/c2/PayloadSerializer.h | 23 +-
libminifi/include/c2/protocols/RESTProtocol.h | 7 +-
libminifi/include/c2/protocols/RESTSender.h | 4 +-
.../controllers/NetworkPrioritizerService.h | 6 +-
libminifi/include/controllers/SSLContextService.h | 34 +-
.../include/controllers/ThreadManagementService.h | 5 +-
.../controllers/UpdatePolicyControllerService.h | 4 +-
libminifi/include/core/BulletinStore.h | 1 +
libminifi/include/core/FlowConfiguration.h | 14 +-
libminifi/include/core/FlowFile.h | 8 +-
libminifi/include/core/ForwardingContentSession.h | 5 +-
libminifi/include/core/ParameterContext.h | 2 +-
libminifi/include/core/ParameterTokenParser.h | 2 +-
libminifi/include/core/ProcessGroup.h | 8 +-
libminifi/include/core/ProcessSession.h | 8 +-
.../include/core/ProcessSessionReadCallback.h | 2 +-
libminifi/include/core/Processor.h | 178 +++
libminifi/include/core/RepositoryFactory.h | 4 +-
libminifi/include/core/SerializableComponent.h | 4 +-
.../core/controller/ControllerServiceLookup.h | 21 -
.../core/controller/ControllerServiceNode.h | 6 +-
.../core/controller/ControllerServiceNodeMap.h | 2 +-
.../core/controller/ControllerServiceProvider.h | 4 +-
.../ForwardingControllerServiceProvider.h | 2 +-
libminifi/include/core/extension/Executable.h | 14 +-
.../include/core/extension/ExtensionManager.h | 2 +-
libminifi/include/core/extension/Module.h | 20 +-
libminifi/include/core/extension/Utils.h | 2 +-
libminifi/include/core/flow/FlowSchema.h | 5 +
libminifi/include/core/flow/Node.h | 2 +-
.../include/core/flow/StructuredConfiguration.h | 4 +-
.../include/core/flow/StructuredConnectionParser.h | 4 +-
libminifi/include/core/json/JsonNode.h | 2 +-
libminifi/include/core/logging/LoggerBase.h | 2 +-
.../include/core/logging/LoggerConfiguration.h | 4 +-
libminifi/include/core/logging/LoggerFactory.h | 43 -
libminifi/include/core/logging/LoggerProperties.h | 8 +-
.../include/core/logging/WindowsEventLogSink.h | 16 +-
libminifi/include/core/logging/alert/AlertSink.h | 9 +-
.../core/logging/internal/ActiveCompressor.h | 18 +-
.../core/logging/internal/CompressionManager.h | 22 +-
.../include/core/logging/internal/LogBuffer.h | 16 +-
.../include/core/logging/internal/LogCompressor.h | 18 +-
.../reporting/SiteToSiteProvenanceReportingTask.h | 11 +-
.../include/core/repository/AtomicRepoEntries.h | 2 +-
.../repository/LegacyVolatileContentRepository.h | 3 +-
.../core/repository/VolatileFlowFileRepository.h | 3 +-
.../core/repository/VolatileProvenanceRepository.h | 1 -
.../include/core/repository/VolatileRepository.h | 2 -
libminifi/include/core/state/ConnectionStore.h | 4 +-
libminifi/include/core/state/LogMetricsPublisher.h | 4 +-
.../include/core/state/MetricsPublisherFactory.h | 2 +-
.../include/core/state/MetricsPublisherStore.h | 5 +-
libminifi/include/core/state/UpdateController.h | 19 +-
libminifi/include/core/state/UpdatePolicy.h | 21 +-
.../include/core/state/nodes/AgentInformation.h | 6 +-
.../include/core/state/nodes/AssetInformation.h | 2 +-
.../core/state/nodes/ConfigurationChecksums.h | 2 +-
.../include/core/state/nodes/DeviceInformation.h | 3 +-
.../include/core/state/nodes/FlowInformation.h | 6 +-
libminifi/include/core/state/nodes/MetricsBase.h | 4 +-
libminifi/include/core/state/nodes/QueueMetrics.h | 1 -
.../include/core/state/nodes/RepositoryMetrics.h | 2 +-
.../state/nodes/RepositoryMetricsSourceStore.h | 4 +-
.../include/core/state/nodes/ResponseNodeLoader.h | 6 +-
libminifi/include/core/yaml/YamlConfiguration.h | 2 +-
libminifi/include/core/yaml/YamlNode.h | 2 +-
libminifi/include/io/AtomicEntryStream.h | 21 +-
libminifi/include/io/NetworkPrioritizer.h | 17 +-
libminifi/include/processors/ProcessorUtils.h | 12 +-
libminifi/include/properties/Configuration.h | 2 +-
libminifi/include/properties/Decryptor.h | 10 +-
libminifi/include/properties/Properties.h | 17 +-
libminifi/include/provenance/Provenance.h | 9 +-
.../include/sitetosite/CompressionConsts.h | 15 +-
.../CompressionInputStream.h} | 47 +-
.../CompressionOutputStream.h} | 37 +-
libminifi/include/sitetosite/HTTPProtocol.h | 157 ---
libminifi/include/sitetosite/HTTPTransaction.h | 32 +-
.../include/sitetosite/HttpSiteToSiteClient.h | 95 ++
libminifi/include/sitetosite/Peer.h | 305 +----
libminifi/include/sitetosite/PeersEntity.h | 117 --
libminifi/include/sitetosite/RawSiteToSiteClient.h | 95 ++
libminifi/include/sitetosite/RawSocketProtocol.h | 177 ---
libminifi/include/sitetosite/SiteToSite.h | 379 +++---
libminifi/include/sitetosite/SiteToSiteClient.h | 288 ++--
libminifi/include/sitetosite/SiteToSiteFactory.h | 63 +-
libminifi/include/utils/FlowFileQueue.h | 3 +-
libminifi/include/utils/MinMaxHeap.h | 2 +-
libminifi/include/utils/StagingQueue.h | 12 +-
libminifi/include/utils/file/AssetManager.h | 2 +-
libminifi/include/utils/file/FileSystem.h | 14 +-
libminifi/include/utils/tls/DistinguishedName.h | 14 +-
libminifi/include/utils/tls/ExtendedKeyUsage.h | 2 +-
libminifi/include/utils/tls/TLSUtils.h | 14 +-
libminifi/src/Configuration.cpp | 3 -
libminifi/src/Configure.cpp | 2 +-
libminifi/src/Connection.cpp | 2 +-
libminifi/src/CronDrivenSchedulingAgent.cpp | 4 +-
libminifi/src/DiskSpaceWatchdog.cpp | 4 +-
libminifi/src/EventDrivenSchedulingAgent.cpp | 6 +-
libminifi/src/Exception.cpp | 2 +-
libminifi/src/FlowController.cpp | 13 +-
libminifi/src/FlowFileRecord.cpp | 11 +-
libminifi/src/Funnel.cpp | 5 +-
libminifi/src/RemoteProcessGroupPort.cpp | 370 ++++++
libminifi/src/RemoteProcessorGroupPort.cpp | 356 -----
libminifi/src/ResourceClaim.cpp | 3 +-
libminifi/src/RootProcessGroupWrapper.cpp | 6 +
libminifi/src/SchedulingAgent.cpp | 2 +-
libminifi/src/ThreadedSchedulingAgent.cpp | 7 +-
libminifi/src/agent/JsonSchema.cpp | 10 +-
libminifi/src/agent/agent_docs.cpp | 9 +-
libminifi/src/c2/C2Agent.cpp | 12 +-
libminifi/src/c2/C2MetricsPublisher.cpp | 5 +-
.../src/c2/ControllerSocketMetricsPublisher.cpp | 21 +-
libminifi/src/c2/ControllerSocketProtocol.cpp | 90 +-
libminifi/src/c2/FlowStatusBuilder.cpp | 385 ++++++
libminifi/src/c2/FlowStatusRequest.cpp | 55 +
libminifi/src/c2/HeartbeatJsonSerializer.cpp | 3 +-
libminifi/src/c2/PayloadSerializer.cpp | 12 +-
libminifi/src/c2/protocols/RESTProtocol.cpp | 2 +-
libminifi/src/c2/protocols/RESTSender.cpp | 25 +-
libminifi/src/controllers/SSLContextService.cpp | 40 +-
.../controllers/UpdatePolicyControllerService.cpp | 2 -
libminifi/src/core/BulletinStore.cpp | 8 +
libminifi/src/core/ClassLoader.cpp | 112 +-
libminifi/src/core/FlowConfiguration.cpp | 21 +-
libminifi/src/core/FlowFile.cpp | 2 +-
libminifi/src/core/ForwardingContentSession.cpp | 7 +-
libminifi/src/core/ParameterContext.cpp | 2 +-
libminifi/src/core/ProcessContext.cpp | 135 ++
libminifi/src/core/ProcessGroup.cpp | 2 +-
libminifi/src/core/ProcessSession.cpp | 12 +-
libminifi/src/core/ProcessSessionFactory.cpp | 12 +-
libminifi/src/core/ProcessSessionReadCallback.cpp | 4 +-
{utils => libminifi}/src/core/Processor.cpp | 275 +++-
libminifi/src/core/RepositoryFactory.cpp | 2 -
.../core/controller/ControllerServiceProvider.cpp | 2 +-
libminifi/src/core/extension/DynamicLibrary.cpp | 1 -
libminifi/src/core/extension/ExtensionManager.cpp | 20 +-
libminifi/src/core/extension/Module.cpp | 2 +-
libminifi/src/core/flow/AdaptiveConfiguration.cpp | 6 +-
libminifi/src/core/flow/CheckRequiredField.cpp | 4 +-
libminifi/src/core/flow/FlowSchema.cpp | 10 +
.../src/core/flow/StructuredConfiguration.cpp | 98 +-
.../src/core/flow/StructuredConnectionParser.cpp | 17 +-
libminifi/src/core/logging/LoggerConfiguration.cpp | 22 +-
libminifi/src/core/logging/WindowsEventLogSink.cpp | 18 +-
libminifi/src/core/logging/alert/AlertSink.cpp | 27 +-
.../core/logging/internal/CompressionManager.cpp | 4 +-
.../src/core/logging/internal/LogCompressor.cpp | 17 +-
.../SiteToSiteProvenanceReportingTask.cpp | 18 +-
.../src/core/repository/FileSystemRepository.cpp | 9 +-
.../src/core/repository/VolatileRepository.cpp | 1 -
.../src/core/repository/VolatileRepositoryData.cpp | 4 +-
libminifi/src/core/state/MetricsPublisherStore.cpp | 1 +
libminifi/src/core/state/UpdateController.cpp | 12 +-
libminifi/src/core/state/Value.cpp | 2 +-
.../src/core/state/nodes/AgentInformation.cpp | 15 +-
.../src/core/state/nodes/BuildInformation.cpp | 2 +-
.../src/core/state/nodes/DeviceInformation.cpp | 3 +-
.../src/core/state/nodes/RepositoryMetrics.cpp | 2 +-
.../src/core/state/nodes/ResponseNodeLoader.cpp | 2 +-
libminifi/src/io/AtomicEntryStream.cpp | 33 -
.../EnvironmentVariableParameterProvider.cpp | 2 +-
libminifi/src/properties/Properties.cpp | 8 +-
libminifi/src/provenance/Provenance.cpp | 8 +-
.../src/sitetosite/CompressionInputStream.cpp | 154 +++
.../src/sitetosite/CompressionOutputStream.cpp | 139 ++
libminifi/src/sitetosite/HTTPProtocol.cpp | 304 -----
libminifi/src/sitetosite/HttpSiteToSiteClient.cpp | 391 ++++++
libminifi/src/sitetosite/Peer.cpp | 30 +-
libminifi/src/sitetosite/RawSiteToSiteClient.cpp | 429 ++++++
libminifi/src/sitetosite/RawSocketProtocol.cpp | 623 ---------
libminifi/src/sitetosite/SiteToSite.cpp | 49 -
libminifi/src/sitetosite/SiteToSiteClient.cpp | 1021 ++++++++-------
libminifi/src/sitetosite/SiteToSiteFactory.cpp | 83 ++
libminifi/src/utils/CallBackTimer.cpp | 92 --
libminifi/src/utils/file/AssetManager.cpp | 17 +-
libminifi/src/utils/tls/DistinguishedName.cpp | 2 +-
libminifi/src/utils/tls/TLSUtils.cpp | 2 +-
libminifi/test/flow-tests/CustomProcessors.h | 12 +-
libminifi/test/flow-tests/CycleTest.cpp | 14 +-
libminifi/test/flow-tests/FlowControllerTests.cpp | 44 +-
libminifi/test/flow-tests/LoopTest.cpp | 10 +-
libminifi/test/flow-tests/MultiLoopTest.cpp | 10 +-
libminifi/test/flow-tests/SessionTests.cpp | 6 +-
libminifi/test/integration/AlertTests.cpp | 17 +-
libminifi/test/integration/C2AssetSyncTest.cpp | 15 +-
.../integration/C2ClearCoreComponentStateTest.cpp | 9 +-
libminifi/test/integration/C2CompressTest.cpp | 1 +
libminifi/test/integration/C2ConfigEncryption.cpp | 15 +-
.../integration/C2ControllerEnableFailureTest.cpp | 28 +-
libminifi/test/integration/C2DebugBundleTest.cpp | 12 +-
.../C2DescribeCoreComponentStateTest.cpp | 9 +-
.../test/integration/C2DescribeManifestTest.cpp | 7 +-
.../test/integration/C2DescribeMetricsTest.cpp | 7 +-
libminifi/test/integration/C2EmptyMetricTest.cpp | 7 +-
libminifi/test/integration/C2FailedUpdateTest.cpp | 5 +-
.../test/integration/C2FetchFlowIfMissingTest.cpp | 5 +-
libminifi/test/integration/C2JstackTest.cpp | 5 +-
libminifi/test/integration/C2LogHeartbeatTest.cpp | 1 +
libminifi/test/integration/C2MetricsTest.cpp | 11 +-
.../test/integration/C2MultipleCommandsTest.cpp | 10 +-
libminifi/test/integration/C2NullConfiguration.cpp | 18 +-
libminifi/test/integration/C2PauseResumeTest.cpp | 15 +-
.../test/integration/C2PropertiesUpdateTests.cpp | 20 +-
.../test/integration/C2SameProcessorMetrics.cpp | 7 +-
libminifi/test/integration/C2UpdateAssetTest.cpp | 5 +
libminifi/test/integration/C2UpdateTest.cpp | 6 +-
.../test/integration/C2VerifyHeartbeatAndStop.cpp | 6 +-
.../C2VerifyLightweightHeartbeatAndStop.cpp | 6 +-
.../C2VerifyResourceConsumptionInHeartbeat.cpp | 6 +-
.../ControllerServiceIntegrationTests.cpp | 16 +-
libminifi/test/integration/HTTPClientTests.cpp | 12 +-
libminifi/test/integration/HTTPSiteToSiteTests.cpp | 23 +-
.../integration/OnScheduleErrorHandlingTests.cpp | 18 +-
libminifi/test/integration/SiteToSiteRestTest.cpp | 31 +-
.../integration/StateTransactionalityTests.cpp | 24 +-
.../integration/TimeoutHTTPSiteToSiteTests.cpp | 21 +-
.../keyvalue-tests/PersistentStateStorageTest.cpp | 1 -
libminifi/test/libtest/integration/CivetStream.h | 3 +-
.../integration/ConnectionCountingServer.cpp | 6 +-
.../test/libtest/integration/HTTPHandlers.cpp | 31 +-
libminifi/test/libtest/integration/HTTPHandlers.h | 9 -
.../libtest/integration/HTTPIntegrationBase.cpp | 4 +-
.../test/libtest/integration/HTTPIntegrationBase.h | 18 +-
.../test/libtest/integration/IntegrationBase.cpp | 34 +-
.../test/libtest/integration/IntegrationBase.h | 37 +-
libminifi/test/libtest/unit/CMakeLists.txt | 2 +-
libminifi/test/libtest/unit/Catch.h | 1 +
libminifi/test/libtest/unit/DummyProcessor.h | 18 +-
libminifi/test/libtest/unit/MockClasses.h | 25 +-
libminifi/test/libtest/unit/ProcessorUtils.h | 46 +
libminifi/test/libtest/unit/ProvenanceTestHelper.h | 4 +-
.../libtest/unit/ReadFromFlowFileTestProcessor.cpp | 2 +-
.../libtest/unit/ReadFromFlowFileTestProcessor.h | 13 +-
libminifi/test/libtest/unit/RecordSetTesters.h | 6 +-
.../libtest/unit/SingleProcessorTestController.cpp | 5 +-
.../libtest/unit/SingleProcessorTestController.h | 11 +-
libminifi/test/libtest/unit/SiteToSiteHelper.h | 2 +-
libminifi/test/libtest/unit/StatefulProcessor.cpp | 4 +-
libminifi/test/libtest/unit/StatefulProcessor.h | 4 +-
libminifi/test/libtest/unit/TestBase.cpp | 25 +-
libminifi/test/libtest/unit/TestBase.h | 67 +-
.../test/libtest/unit/TestControllerWithFlow.cpp | 1 -
libminifi/test/libtest/unit/TestUtils.cpp | 18 +-
libminifi/test/libtest/unit/TestUtils.h | 33 +-
.../libtest/unit/WriteToFlowFileTestProcessor.cpp | 2 +-
.../libtest/unit/WriteToFlowFileTestProcessor.h | 17 +-
.../test/persistence-tests/PersistenceTests.cpp | 16 +-
libminifi/test/resources/TestHTTPSiteToSite.yml | 10 +-
.../test/resources/TestTimeoutHTTPSiteToSite.yml | 8 +-
.../test/resources/encrypted.minifi.properties | 1 -
libminifi/test/schema-tests/SchemaTests.cpp | 2 +-
libminifi/test/unit/AbstractProcessorTest.cpp | 11 +-
libminifi/test/unit/ArrayUtilsTests.cpp | 8 +-
libminifi/test/unit/BackTraceTests.cpp | 2 +-
libminifi/test/unit/BulletinStoreTests.cpp | 27 +-
libminifi/test/unit/CRCTests.cpp | 4 +-
libminifi/test/unit/CertificateUtilsTests.cpp | 2 +-
libminifi/test/unit/ComponentManifestTests.cpp | 3 +-
.../unit/ControllerSocketMetricsPublisherTest.cpp | 13 +-
libminifi/test/unit/CronTests.cpp | 2 +
libminifi/test/unit/DecryptorTests.cpp | 3 +-
libminifi/test/unit/EnvironmentUtilsTests.cpp | 7 +-
.../EnvironmentVariableParameterProviderTest.cpp | 12 +-
libminifi/test/unit/ExceptionTests.cpp | 2 +-
libminifi/test/unit/ExpectedTest.cpp | 14 +-
libminifi/test/unit/ExtendedKeyUsageTests.cpp | 20 +-
libminifi/test/unit/ExtensionVerificationTests.cpp | 2 +-
libminifi/test/unit/FileSystemRepositoryTests.cpp | 5 +-
libminifi/test/unit/FileUtilsTests.cpp | 2 +-
libminifi/test/unit/FlowFileQueueSwapTests.cpp | 20 +-
libminifi/test/unit/FlowFileQueueTests.cpp | 1 +
libminifi/test/unit/FlowFileSerializationTests.cpp | 2 +-
libminifi/test/unit/FlowStatusBuilderTests.cpp | 488 +++++++
libminifi/test/unit/GeneralUtilsTest.cpp | 60 +-
libminifi/test/unit/HTTPStreamingCallbackTests.cpp | 2 +-
libminifi/test/unit/IdTests.cpp | 1 +
libminifi/test/unit/LogMetricsPublisherTests.cpp | 4 +-
libminifi/test/unit/LoggerConfigurationTests.cpp | 2 +-
libminifi/test/unit/LoggerTests.cpp | 77 +-
libminifi/test/unit/MapUtilsTests.cpp | 4 +-
libminifi/test/unit/MemoryUsageTest.cpp | 2 +-
libminifi/test/unit/MetricsPublisherStoreTests.cpp | 2 +
libminifi/test/unit/MetricsTests.cpp | 9 +-
libminifi/test/unit/MinifiConcurrentQueueTests.cpp | 2 +-
libminifi/test/unit/NetUtilsTest.cpp | 72 +-
libminifi/test/unit/NetworkInterfaceInfoTests.cpp | 2 +-
.../test/unit/NetworkPrioritizerServiceTests.cpp | 2 +-
libminifi/test/unit/ParameterTokenParserTest.cpp | 16 +-
libminifi/test/unit/ProcessContextTest.cpp | 4 +-
libminifi/test/unit/ProcessSessionTests.cpp | 1 -
libminifi/test/unit/ProcessorConfigUtilsTests.cpp | 118 +-
libminifi/test/unit/PropertyValidationTests.cpp | 18 +-
libminifi/test/unit/RegexUtilsTests.cpp | 1 -
libminifi/test/unit/ResponseNodeLoaderTests.cpp | 6 +-
libminifi/test/unit/SchedulingAgentTests.cpp | 31 +-
libminifi/test/unit/Site2SiteTests.cpp | 150 ---
.../test/unit/SiteToSiteCompressionStreamTests.cpp | 215 +++
libminifi/test/unit/SiteToSiteTests.cpp | 414 ++++++
libminifi/test/unit/StreamTests.cpp | 2 +-
libminifi/test/unit/StringUtilsTests.cpp | 20 +-
libminifi/test/unit/TimeUtilTests.cpp | 6 +-
libminifi/test/unit/UpdatePolicyTests.cpp | 1 -
libminifi/test/unit/ZlibStreamTests.cpp | 2 +-
.../performance/VolatileRepositoryPerfTests.cpp | 2 +-
linux.sh | 60 -
minifi-api/include/minifi-cpp/Connection.h | 7 +-
minifi-api/include/minifi-cpp/FlowFileRecord.h | 2 +-
minifi-api/include/minifi-cpp/ResourceClaim.h | 1 -
minifi-api/include/minifi-cpp/agent/agent_docs.h | 2 +
.../minifi-cpp/controllers/RecordConverter.h | 12 +-
.../minifi-cpp/controllers/RecordSetReader.h | 12 +-
.../minifi-cpp/controllers/RecordSetWriter.h | 7 +
...ntextService.h => SSLContextServiceInterface.h} | 10 +-
.../minifi-cpp/core/AgentIdentificationProvider.h | 12 +-
minifi-api/include/minifi-cpp/core/Annotation.h | 14 +-
minifi-api/include/minifi-cpp/core/ClassLoader.h | 25 +-
.../minifi-cpp/core/ConfigurableComponent.h | 3 +
minifi-api/include/minifi-cpp/core/Connectable.h | 2 +-
.../include/minifi-cpp/core/ContentRepository.h | 2 +-
.../include/minifi-cpp/core/ContentSession.h | 2 +-
.../core/ControllerServiceApiDefinition.h | 10 +-
minifi-api/include/minifi-cpp/core/FlowFile.h | 4 +-
minifi-api/include/minifi-cpp/core/ObjectFactory.h | 4 +-
.../include/minifi-cpp/core/ProcessContext.h | 30 +-
.../minifi-cpp/core/ProcessContextBuilder.h | 5 +-
minifi-api/include/minifi-cpp/core/Processor.h | 105 --
minifi-api/include/minifi-cpp/core/ProcessorApi.h | 74 ++
...ocessSessionFactory.h => ProcessorDescriptor.h} | 18 +-
.../{VariableRegistry.h => ProcessorFactory.h} | 23 +-
.../{ThreadedRepository.h => ProcessorMetadata.h} | 15 +-
minifi-api/include/minifi-cpp/core/Property.h | 2 +-
.../include/minifi-cpp/core/PropertyDefinition.h | 2 +-
minifi-api/include/minifi-cpp/core/Record.h | 4 -
minifi-api/include/minifi-cpp/core/Repository.h | 2 +-
.../minifi-cpp/core/SerializableComponent.h | 6 +-
minifi-api/include/minifi-cpp/core/StreamManager.h | 4 +-
.../include/minifi-cpp/core/TraceableResource.h | 12 +-
.../core/controller/ControllerServiceNode.h | 2 +-
.../core/controller/ControllerServiceProvider.h | 2 +-
.../include/minifi-cpp/core/logging/Logger.h | 2 +-
.../minifi-cpp/core/state/nodes/MetricsBase.h | 4 +-
minifi-api/include/minifi-cpp/io/ArchiveStream.h | 2 +-
minifi-api/include/minifi-cpp/io/OutputStream.h | 14 +-
minifi-api/include/minifi-cpp/io/Stream.h | 2 +-
.../include/minifi-cpp/properties/Configuration.h | 3 -
.../include/minifi-cpp/properties/Configure.h | 5 +-
.../include/minifi-cpp/properties/Properties.h | 2 -
.../include/minifi-cpp/provenance/Provenance.h | 2 +-
.../include/minifi-cpp/utils/PropertyExceptions.h | 2 +-
minifi_main/AgentDocs.cpp | 2 +-
minifi_main/CMakeLists.txt | 16 +-
minifi_main/Fips.cpp | 63 +-
minifi_main/Fips.h | 6 +-
minifi_main/MainHelper.cpp | 75 +-
minifi_main/MainHelper.h | 52 +-
minifi_main/MiNiFiMain.cpp | 96 +-
minifi_main/MiNiFiWindowsService.cpp | 2 +-
minifi_main/TableFormatter.cpp | 2 +-
.../FindLibSSH2.cmake => packaging/CMakeLists.txt | 9 +-
{msi => packaging/msi}/MergeModulesFeature.xml | 0
.../msi}/VSRedistributablesComponent.xml | 0
.../msi}/VSRedistributablesFeature.xml | 0
{msi => packaging/msi}/WixWin.wsi.in | 2 +-
{msi => packaging/msi}/bgr.png | Bin
{msi => packaging/msi}/minifi-logo-ico.ico | Bin
{msi => packaging/msi}/minifi-logo-png-banner.png | Bin
{msi => packaging/msi}/x64.wsi | 0
{msi => packaging/msi}/x86.wsi | 0
packaging/rpm/check_rpm_contents.sh | 43 +
packaging/rpm/expected-rpm-contents.in | 68 +
packaging/rpm/pre_install.sh | 11 +
rheldistro.sh | 91 --
suse.sh | 96 --
.../azure-sdk-cpp/fix-managed-identity.patch | 15 +
thirdparty/azure-sdk-cpp/fix-openssl-helper.patch | 34 +
.../include-cinttypes-for-uint8_t-gcc15-fix.patch | 24 +
thirdparty/azure-sdk-cpp/remove-amqp.patch | 37 -
thirdparty/concurrentqueue/concurrentqueue.h | 1370 +++++++++++---------
.../google-cloud-cpp/remove_installation.patch | 258 ++++
thirdparty/grpc/fix-constants-on-windows.patch | 35 -
thirdparty/grpc/fix-protobuf-find-package.patch | 22 +
...e-custom-commands-for-unused-dependencies.patch | 428 ------
.../0003-remove_FindLZ4_installation.patch | 22 +
thirdparty/libxml2/libxml2-win.patch | 126 --
thirdparty/opencv/windows-install-path.patch | 34 +
utils/CMakeLists.txt | 22 -
utils/include/Exception.h | 21 -
utils/include/SwapManager.h | 21 -
utils/include/agent/agent_version.h | 19 -
utils/include/core/Annotation.h | 20 -
utils/include/core/OutputAttributeDefinition.h | 20 -
utils/include/core/Processor.h | 305 -----
utils/include/core/PropertyDefinition.h | 20 -
utils/include/core/RelationshipDefinition.h | 20 -
utils/include/core/logging/Logger.h | 20 -
utils/include/io/ArchiveStream.h | 20 -
utils/include/utils/Export.h | 35 -
utils/include/utils/Literals.h | 19 -
utils/include/utils/PropertyExceptions.h | 19 -
utils/include/utils/gsl.h | 21 -
1325 files changed, 18183 insertions(+), 15583 deletions(-)
create mode 100644 SITE_TO_SITE.md
delete mode 100644 aptitude.sh
delete mode 100644 arch.sh
create mode 100644 bin/CMakeLists.txt
create mode 100644 bin/flowstatus-minifi.bat
rename bin/{minifi.service => minifi.service.in} (60%)
delete mode 100755 bootstrap.sh
delete mode 100755 bstrp_functions.sh
delete mode 100644 centos.sh
delete mode 100644 cmake/BundledLibXml2.cmake
copy cmake/{Sol2.cmake => Jsoncons.cmake} (73%)
create mode 100644 cmake/LibXml2.cmake
create mode 100644 cmake/Protobuf.cmake
create mode 100644 conf/CMakeLists.txt
rename conf/{config.yml => config.yml.in} (100%)
rename conf/{minifi-log.properties => minifi-log.properties.in} (95%)
rename conf/{minifi-uid.properties => minifi-uid.properties.in} (100%)
rename conf/{minifi.properties => minifi.properties.in} (92%)
create mode 100644 core-framework/CMakeLists.txt
create mode 100644 core-framework/include/Defaults.h
rename {utils => core-framework}/include/agent/agent_docs.h (98%)
rename {utils => core-framework}/include/core/BufferedContentSession.h (98%)
rename {utils => core-framework}/include/core/ClassLoader.h (80%)
rename {utils => core-framework}/include/core/ClassName.h (100%)
rename {utils => core-framework}/include/core/ConfigurableComponentImpl.h (95%)
rename {utils => core-framework}/include/core/Connectable.h (99%)
rename {utils => core-framework}/include/core/ContentRepository.h (98%)
rename {utils => core-framework}/include/core/ContentSession.h (95%)
rename {utils => core-framework}/include/core/Core.h (100%)
rename {utils => core-framework}/include/core/ObjectFactory.h (78%)
rename {utils => core-framework}/include/core/ProcessContext.h (77%)
rename {utils => core-framework}/include/core/ProcessContextBuilder.h (98%)
copy extension-utils/include/core/StateManager.h =>
core-framework/include/core/ProcessorFactoryImpl.h (57%)
create mode 100644 core-framework/include/core/ProcessorImpl.h
rename {utils => core-framework}/include/core/ProcessorMetrics.h (97%)
rename {utils => core-framework}/include/core/PropertyDefinitionBuilder.h (89%)
rename {utils => core-framework}/include/core/Relationship.h (100%)
rename {utils => core-framework}/include/core/Repository.h (96%)
rename {utils => core-framework}/include/core/RepositoryMetricsSource.h (100%)
rename {utils => core-framework}/include/core/Resource.h (83%)
rename {utils => core-framework}/include/core/StreamManager.h (96%)
rename {utils => core-framework}/include/core/ThreadedRepository.h (100%)
rename {utils => core-framework}/include/core/TypedValues.h (97%)
rename {utils => core-framework}/include/core/VariableRegistry.h (100%)
rename {utils => core-framework}/include/core/controller/ControllerService.h
(95%)
rename {utils => core-framework}/include/core/expect.h (100%)
rename {utils => core-framework}/include/core/extension/Extension.h (92%)
rename {utils => core-framework}/include/core/logging/LoggerFactory.h (100%)
rename {utils => core-framework}/include/core/state/MetricsPublisher.h (97%)
rename {utils => core-framework}/include/core/state/PublishedMetricProvider.h
(100%)
rename {utils => core-framework}/include/core/state/Value.h (100%)
rename {utils => core-framework}/include/core/state/nodes/ResponseNode.h (82%)
rename {utils => core-framework}/include/http/BaseHTTPClient.h (87%)
rename {utils => core-framework}/include/http/HTTPCallback.h (100%)
rename {utils => core-framework}/include/http/HTTPClient.h (95%)
rename {utils => core-framework}/include/http/HTTPStream.h (100%)
rename {utils => core-framework}/include/io/AsioStream.h (100%)
rename {utils => core-framework}/include/io/BaseStream.h (100%)
rename {utils => core-framework}/include/io/BufferStream.h (91%)
rename {utils => core-framework}/include/io/CRCStream.h (96%)
rename {utils => core-framework}/include/io/FileStream.h (100%)
rename {utils => core-framework}/include/io/InputStream.h (100%)
rename {utils => core-framework}/include/io/OutputStream.h (100%)
rename {utils => core-framework}/include/io/Stream.h (100%)
rename {utils => core-framework}/include/io/StreamPipe.h (97%)
rename {utils => core-framework}/include/io/StreamSlice.h (100%)
rename {utils => core-framework}/include/io/ZlibStream.h (99%)
rename {utils => core-framework}/include/io/validation.h (100%)
rename {utils => core-framework}/include/utils/ArrayUtils.h (100%)
rename {utils => core-framework}/include/utils/AttributeErrors.h (100%)
rename {utils => core-framework}/include/utils/AutoPersistor.h (98%)
rename {utils => core-framework}/include/utils/BackTrace.h (100%)
rename {utils => core-framework}/include/utils/ByteArrayCallback.h (97%)
rename {utils => core-framework}/include/utils/CallBackTimer.h (100%)
rename {utils => core-framework}/include/utils/ClassUtils.h (100%)
rename {utils => core-framework}/include/utils/CollectionUtils.h (89%)
rename {utils => core-framework}/include/utils/ConfigurationUtils.h (100%)
rename {utils => core-framework}/include/utils/Cron.h (98%)
rename {utils => core-framework}/include/utils/Deleters.h (100%)
rename {utils => core-framework}/include/utils/Enum.h (100%)
rename {utils => core-framework}/include/utils/Environment.h (97%)
rename {utils => core-framework}/include/utils/Error.h (100%)
rename {utils => core-framework}/include/utils/FailurePolicy.h (100%)
rename {utils => core-framework}/include/utils/FifoExecutor.h (100%)
rename {utils => core-framework}/include/utils/FileMutex.h (97%)
rename {utils => core-framework}/include/utils/GeneralUtils.h (99%)
rename {utils => core-framework}/include/utils/HTTPUtils.h (100%)
rename {utils => core-framework}/include/utils/Hash.h (100%)
rename {utils => core-framework}/include/utils/Id.h (100%)
rename {utils => core-framework}/include/utils/IntervalSwitch.h (89%)
rename {utils => core-framework}/include/utils/JsonCallback.h (94%)
rename {utils =>
core-framework}/include/utils/LineByLineInputOutputStreamCallback.h (93%)
create mode 100644 core-framework/include/utils/Locations.h
rename {utils => core-framework}/include/utils/LogUtils.h (100%)
rename {utils => core-framework}/include/utils/Macro.h (100%)
rename {utils => core-framework}/include/utils/MapUtils.h (80%)
rename {utils => core-framework}/include/utils/MinifiConcurrentQueue.h (100%)
rename {utils => core-framework}/include/utils/Monitors.h (100%)
rename {utils => core-framework}/include/utils/OptionalUtils.h (99%)
rename {utils => core-framework}/include/utils/OsUtils.h (100%)
rename {utils => core-framework}/include/utils/ParsingErrors.h (100%)
rename {utils => core-framework}/include/utils/ParsingUtils.h (99%)
rename {utils => core-framework}/include/utils/ProcessCpuUsageTracker.h (100%)
rename {utils => core-framework}/include/utils/PropertyErrors.h (98%)
rename {utils => core-framework}/include/utils/RegexUtils.h (100%)
rename {utils => core-framework}/include/utils/Searcher.h (100%)
rename {utils => core-framework}/include/utils/SmallString.h (100%)
rename {utils => core-framework}/include/utils/StoppableThread.h (100%)
rename {utils => core-framework}/include/utils/StringUtils.h (98%)
rename {utils => core-framework}/include/utils/SystemCpuUsageTracker.h (100%)
rename {utils => core-framework}/include/utils/ThreadPool.h (99%)
rename {utils => core-framework}/include/utils/TimeUtil.h (100%)
rename {utils => core-framework}/include/utils/TryMoveCall.h (93%)
rename {utils => core-framework}/include/utils/UnicodeConversion.h (100%)
rename {utils => core-framework}/include/utils/ValueCaster.h (100%)
rename {utils => core-framework}/include/utils/ValueParser.h (99%)
rename {utils => core-framework}/include/utils/crypto/EncryptionManager.h (98%)
rename {utils => core-framework}/include/utils/crypto/EncryptionProvider.h
(97%)
rename {utils => core-framework}/include/utils/crypto/EncryptionUtils.h (100%)
rename {utils => core-framework}/include/utils/crypto/ciphers/Aes256Ecb.h (86%)
rename {utils => core-framework}/include/utils/crypto/ciphers/XSalsa20.h (100%)
rename {utils =>
core-framework}/include/utils/crypto/property_encryption/PropertyEncryptionUtils.h
(100%)
rename {utils =>
core-framework}/include/utils/detail/MonadicOperationWrappers.h (100%)
rename {utils => core-framework}/include/utils/expected.h (100%)
rename {utils => core-framework}/include/utils/file/FilePattern.h (100%)
rename {utils => core-framework}/include/utils/file/FileUtils.h (99%)
rename {utils => core-framework}/include/utils/file/PathUtils.h (100%)
rename {utils => core-framework}/include/utils/meta/detected.h (100%)
rename {utils => core-framework}/include/utils/meta/type_list.h (100%)
rename {utils => core-framework}/include/utils/net/AsioCoro.h (100%)
rename {utils => core-framework}/include/utils/net/AsioSocketUtils.h (95%)
rename {utils => core-framework}/include/utils/net/DNS.h (100%)
rename {utils => core-framework}/include/utils/net/NetworkInterfaceInfo.h (98%)
rename {utils => core-framework}/include/utils/net/Socket.h (100%)
rename {utils => core-framework}/include/utils/requirements/Container.h (95%)
rename {utils =>
core-framework}/include/utils/requirements/EqualityComparable.h (85%)
rename {utils =>
core-framework}/include/utils/requirements/LegacyForwardIterator.h (89%)
rename {utils =>
core-framework}/include/utils/requirements/LegacyInputIterator.h (88%)
rename {utils => core-framework}/include/utils/requirements/LegacyIterator.h
(91%)
rename {utils => core-framework}/include/utils/requirements/Swappable.h (91%)
rename {utils => core-framework}/include/utils/span.h (100%)
rename {utils => core-framework}/src/core/BufferedContentSession.cpp (97%)
rename {utils => core-framework}/src/core/ConfigurableComponentImpl.cpp (100%)
rename {utils => core-framework}/src/core/Connectable.cpp (98%)
rename {utils => core-framework}/src/core/ContentRepository.cpp (100%)
rename {utils => core-framework}/src/core/ContentSession.cpp (98%)
rename {utils => core-framework}/src/core/Core.cpp (100%)
rename {utils => core-framework}/src/core/ProcessContextBuilder.cpp (100%)
rename {utils => core-framework}/src/core/ProcessSession.cpp (100%)
create mode 100644 core-framework/src/core/ProcessorImpl.cpp
rename {utils => core-framework}/src/core/ProcessorMetrics.cpp (98%)
rename {utils => core-framework}/src/core/Property.cpp (98%)
rename {utils => core-framework}/src/core/Repository.cpp (100%)
rename {utils => core-framework}/src/core/TypedValues.cpp (97%)
rename {utils => core-framework}/src/core/extension/Extension.cpp (100%)
rename {utils => core-framework}/src/http/BaseHTTPClient.cpp (98%)
rename {utils => core-framework}/src/http/HTTPClient.cpp (98%)
rename {utils => core-framework}/src/http/HTTPStream.cpp (98%)
rename {utils => core-framework}/src/io/BufferStream.cpp (98%)
rename {utils => core-framework}/src/io/CPPLINT.cfg (100%)
rename {utils => core-framework}/src/io/CRCStream.cpp (100%)
rename {utils => core-framework}/src/io/FileStream.cpp (98%)
rename {utils => core-framework}/src/io/InputStream.cpp (98%)
rename {utils => core-framework}/src/io/OutputStream.cpp (90%)
rename {utils => core-framework}/src/io/StreamSlice.cpp (100%)
rename {utils => core-framework}/src/io/ZlibStream.cpp (98%)
rename {utils => core-framework}/src/utils/AutoPersistor.cpp (100%)
rename {utils => core-framework}/src/utils/BackTrace.cpp (100%)
rename {utils => core-framework}/src/utils/ByteArrayCallback.cpp (95%)
rename {extension-utils => core-framework}/src/utils/CallBackTimer.cpp (100%)
rename {utils => core-framework}/src/utils/ClassUtils.cpp (100%)
rename {utils => core-framework}/src/utils/ConfigurationUtils.cpp (100%)
rename {utils => core-framework}/src/utils/Cron.cpp (100%)
rename {utils => core-framework}/src/utils/Environment.cpp (99%)
rename {utils => core-framework}/src/utils/Error.cpp (97%)
rename {utils => core-framework}/src/utils/FifoExecutor.cpp (94%)
rename {utils => core-framework}/src/utils/FileMutex.cpp (99%)
rename {utils => core-framework}/src/utils/HTTPUtils.cpp (100%)
rename {utils => core-framework}/src/utils/Id.cpp (98%)
rename {utils =>
core-framework}/src/utils/LineByLineInputOutputStreamCallback.cpp (98%)
rename {utils => core-framework}/src/utils/OsUtils.cpp (97%)
rename {utils => core-framework}/src/utils/ParsingUtils.cpp (100%)
rename {utils => core-framework}/src/utils/ProcessCpuUsageTracker.cpp (100%)
rename {utils => core-framework}/src/utils/RegexUtils.cpp (99%)
rename {utils => core-framework}/src/utils/StoppableThread.cpp (97%)
rename {utils => core-framework}/src/utils/StringUtils.cpp (100%)
rename {utils => core-framework}/src/utils/SystemCpuUsageTracker.cpp (97%)
rename {utils => core-framework}/src/utils/ThreadPool.cpp (99%)
rename {utils => core-framework}/src/utils/TimeUtil.cpp (100%)
rename {utils => core-framework}/src/utils/crypto/EncryptionManager.cpp (88%)
rename {utils => core-framework}/src/utils/crypto/EncryptionProvider.cpp (100%)
rename {utils => core-framework}/src/utils/crypto/EncryptionUtils.cpp (100%)
rename {utils => core-framework}/src/utils/crypto/ciphers/Aes256Ecb.cpp (97%)
rename {utils =>
core-framework}/src/utils/crypto/property_encryption/PropertyEncryptionUtils.cpp
(100%)
rename {utils => core-framework}/src/utils/file/FilePattern.cpp (100%)
rename {utils => core-framework}/src/utils/file/FileUtils.cpp (99%)
rename {utils => core-framework}/src/utils/file/PathUtils.cpp (98%)
rename {utils => core-framework}/src/utils/net/AsioSocketUtils.cpp (95%)
rename {utils => core-framework}/src/utils/net/DNS.cpp (98%)
rename {utils => core-framework}/src/utils/net/NetworkInterfaceInfo.cpp (95%)
rename {utils => core-framework}/src/utils/net/Socket.cpp (98%)
delete mode 100644 darwin.sh
delete mode 100644 debian.sh
delete mode 100755 deploy.sh
copy docker/{python-verify => installed}/installed.Dockerfile (89%)
rename docker/{python-verify => installed}/installed.dockerignore (100%)
rename docker/{python-verify/installed.Dockerfile => installed/rpm.Dockerfile}
(65%)
create mode 100644 docker/test/integration/features/evaluate_json_path.feature
create mode 100644 docker/test/integration/features/split_json.feature
copy docker/test/integration/minifi/core/{InputPort.py => OutputPort.py} (78%)
rename docker/test/integration/minifi/processors/{ExecutePythonProcessor.py =>
ConvertRecord.py} (83%)
copy docker/test/integration/minifi/processors/{AttributesToJSON.py =>
EvaluateJsonPath.py} (87%)
copy docker/test/integration/minifi/processors/{FailureWithContent.py =>
ExpressionLanguagePropertyWithValidator.py} (85%)
copy docker/test/integration/minifi/processors/{ListFile.py =>
LogDynamicProperties.py} (80%)
copy docker/test/integration/minifi/processors/{CreateNothing.py =>
NifiStyleLogDynamicProperties.py} (87%)
copy docker/test/integration/minifi/processors/{SplitText.py => SplitJson.py}
(85%)
create mode 100644
docker/test/integration/resources/kubernetes/minifi-conf/minifi.properties
create mode 100644
docker/test/integration/resources/python/ExpressionLanguagePropertyWithValidator.py
rename docker/test/integration/resources/python/{add_attribute_to_flowfile.py
=> LogDynamicProperties.py} (59%)
create mode 100644
docker/test/integration/resources/python/NifiStyleLogDynamicProperties.py
rename {extension-utils => extension-framework}/CMakeLists.txt (56%)
rename {extension-utils =>
extension-framework}/include/controllers/AttributeProviderService.h (100%)
copy {extension-utils =>
extension-framework}/include/controllers/RecordSetReader.h (100%)
rename {extension-utils =>
extension-framework}/include/controllers/RecordSetWriter.h (100%)
rename {extension-utils =>
extension-framework}/include/controllers/keyvalue/KeyValueStateManager.h (98%)
rename {extension-utils =>
extension-framework}/include/controllers/keyvalue/KeyValueStateStorage.h (100%)
rename {extension-utils =>
extension-framework}/include/core/AbstractProcessor.h (89%)
rename {extension-utils => extension-framework}/include/core/FlowFileStore.h
(97%)
rename {extension-utils => extension-framework}/include/core/ProcessSession.h
(100%)
rename {extension-utils => extension-framework}/include/core/StateManager.h
(99%)
rename {extension-utils => extension-framework}/include/core/StateStorage.h
(97%)
rename {extension-utils =>
extension-framework}/include/serialization/FlowFileSerializer.h (90%)
rename {extension-utils =>
extension-framework}/include/serialization/FlowFileV3Serializer.h (90%)
rename {extension-utils =>
extension-framework}/include/serialization/PayloadSerializer.h (85%)
rename {extension-utils =>
extension-framework}/include/utils/ListingStateManager.h (96%)
rename {extension-utils =>
extension-framework}/include/utils/OpenTelemetryLogDataModelUtils.h (100%)
rename {extension-utils =>
extension-framework}/include/utils/ProcessorConfigUtils.h (61%)
rename {extension-utils => extension-framework}/include/utils/ResourceQueue.h
(99%)
rename {extension-utils =>
extension-framework}/include/utils/file/FileManager.h (100%)
rename {extension-utils =>
extension-framework}/include/utils/file/FileReaderCallback.h (97%)
rename {extension-utils =>
extension-framework}/include/utils/file/FileWriterCallback.h (100%)
rename {extension-utils =>
extension-framework}/include/utils/file/ListedFile.h (100%)
rename {extension-utils =>
extension-framework}/include/utils/net/ConnectionHandler.h (100%)
rename {extension-utils =>
extension-framework}/include/utils/net/ConnectionHandlerBase.h (100%)
rename {extension-utils => extension-framework}/include/utils/net/IpProtocol.h
(100%)
rename {extension-utils => extension-framework}/include/utils/net/Message.h
(100%)
rename {extension-utils => extension-framework}/include/utils/net/Server.h
(98%)
rename {extension-utils => extension-framework}/include/utils/net/Ssl.h (93%)
rename {extension-utils => extension-framework}/include/utils/net/TcpServer.h
(100%)
rename {extension-utils => extension-framework}/include/utils/net/UdpServer.h
(96%)
rename {extension-utils =>
extension-framework}/src/controllers/keyvalue/KeyValueStateManager.cpp (100%)
rename {extension-utils =>
extension-framework}/src/controllers/keyvalue/KeyValueStateStorage.cpp (98%)
rename {extension-utils =>
extension-framework}/src/serialization/FlowFileV3Serializer.cpp (95%)
rename {extension-utils =>
extension-framework}/src/serialization/PayloadSerializer.cpp (100%)
rename {extension-utils =>
extension-framework}/src/utils/ListingStateManager.cpp (96%)
rename {extension-utils =>
extension-framework}/src/utils/file/FileReaderCallback.cpp (100%)
rename {extension-utils =>
extension-framework}/src/utils/file/FileWriterCallback.cpp (100%)
rename {extension-utils => extension-framework}/src/utils/net/Ssl.cpp (90%)
rename {extension-utils => extension-framework}/src/utils/net/TcpServer.cpp
(99%)
rename {extension-utils => extension-framework}/src/utils/net/UdpServer.cpp
(100%)
delete mode 100644 extension-utils/include/FlowFileRecord.h
delete mode 100644 extension-utils/include/ResourceClaim.h
delete mode 100644 extension-utils/include/controllers/SSLContextService.h
delete mode 100644 extension-utils/include/core/FlowFile.h
delete mode 100644 extension-utils/include/properties/Configure.h
delete mode 100644 extension-utils/include/properties/Properties.h
delete mode 100644 extension-utils/src/core/ProcessContext.cpp
create mode 100644 extensions/standard-processors/processors/ConvertRecord.cpp
create mode 100644 extensions/standard-processors/processors/ConvertRecord.h
create mode 100644
extensions/standard-processors/processors/EvaluateJsonPath.cpp
create mode 100644 extensions/standard-processors/processors/EvaluateJsonPath.h
create mode 100644 extensions/standard-processors/processors/SplitJson.cpp
create mode 100644 extensions/standard-processors/processors/SplitJson.h
create mode 100644
extensions/standard-processors/tests/unit/ConvertRecordTests.cpp
create mode 100644
extensions/standard-processors/tests/unit/EvaluateJsonPathTests.cpp
create mode 100644 extensions/standard-processors/tests/unit/SplitJsonTests.cpp
create mode 100644 extensions/windows-event-log/tests/StringSplitterTests.cpp
copy libminifi/test/unit/SpanTests.cpp =>
extensions/windows-event-log/tests/WindowsErrorTests.cpp (51%)
rename extensions/windows-event-log/{ => wel}/Bookmark.cpp (87%)
rename extensions/windows-event-log/{ => wel}/Bookmark.h (82%)
create mode 100644 extensions/windows-event-log/wel/StringSplitter.h
copy extensions/windows-event-log/wel/{LookupCacher.cpp => WindowsError.h}
(63%)
delete mode 100644 fedora.sh
delete mode 100644 libminifi/include/Defaults.h
rename libminifi/include/{RemoteProcessorGroupPort.h =>
RemoteProcessGroupPort.h} (53%)
create mode 100644 libminifi/include/c2/FlowStatusBuilder.h
copy libminifi/include/c2/{ControllerSocketReporter.h => FlowStatusRequest.h}
(56%)
create mode 100644 libminifi/include/core/Processor.h
delete mode 100644 libminifi/include/core/controller/ControllerServiceLookup.h
delete mode 100644 libminifi/include/core/logging/LoggerFactory.h
copy extensions/python/PythonBindings.h =>
libminifi/include/sitetosite/CompressionConsts.h (73%)
copy libminifi/include/{core/ProcessSessionReadCallback.h =>
sitetosite/CompressionInputStream.h} (50%)
copy libminifi/include/{c2/HeartbeatLogger.h =>
sitetosite/CompressionOutputStream.h} (52%)
delete mode 100644 libminifi/include/sitetosite/HTTPProtocol.h
create mode 100644 libminifi/include/sitetosite/HttpSiteToSiteClient.h
delete mode 100644 libminifi/include/sitetosite/PeersEntity.h
create mode 100644 libminifi/include/sitetosite/RawSiteToSiteClient.h
delete mode 100644 libminifi/include/sitetosite/RawSocketProtocol.h
create mode 100644 libminifi/src/RemoteProcessGroupPort.cpp
delete mode 100644 libminifi/src/RemoteProcessorGroupPort.cpp
create mode 100644 libminifi/src/c2/FlowStatusBuilder.cpp
create mode 100644 libminifi/src/c2/FlowStatusRequest.cpp
create mode 100644 libminifi/src/core/ProcessContext.cpp
rename {utils => libminifi}/src/core/Processor.cpp (62%)
delete mode 100644 libminifi/src/io/AtomicEntryStream.cpp
create mode 100644 libminifi/src/sitetosite/CompressionInputStream.cpp
create mode 100644 libminifi/src/sitetosite/CompressionOutputStream.cpp
delete mode 100644 libminifi/src/sitetosite/HTTPProtocol.cpp
create mode 100644 libminifi/src/sitetosite/HttpSiteToSiteClient.cpp
create mode 100644 libminifi/src/sitetosite/RawSiteToSiteClient.cpp
delete mode 100644 libminifi/src/sitetosite/RawSocketProtocol.cpp
delete mode 100644 libminifi/src/sitetosite/SiteToSite.cpp
create mode 100644 libminifi/src/sitetosite/SiteToSiteFactory.cpp
delete mode 100644 libminifi/src/utils/CallBackTimer.cpp
create mode 100644 libminifi/test/libtest/unit/ProcessorUtils.h
create mode 100644 libminifi/test/unit/FlowStatusBuilderTests.cpp
delete mode 100644 libminifi/test/unit/Site2SiteTests.cpp
create mode 100644 libminifi/test/unit/SiteToSiteCompressionStreamTests.cpp
create mode 100644 libminifi/test/unit/SiteToSiteTests.cpp
delete mode 100644 linux.sh
rename extension-utils/include/controllers/RecordSetReader.h =>
minifi-api/include/minifi-cpp/controllers/RecordConverter.h (76%)
rename minifi-api/include/minifi-cpp/controllers/{SSLContextService.h =>
SSLContextServiceInterface.h} (83%)
rename utils/include/core/Property.h =>
minifi-api/include/minifi-cpp/core/ControllerServiceApiDefinition.h (79%)
delete mode 100644 minifi-api/include/minifi-cpp/core/Processor.h
create mode 100644 minifi-api/include/minifi-cpp/core/ProcessorApi.h
copy minifi-api/include/minifi-cpp/core/{ProcessSessionFactory.h =>
ProcessorDescriptor.h} (70%)
copy minifi-api/include/minifi-cpp/core/{VariableRegistry.h =>
ProcessorFactory.h} (74%)
copy minifi-api/include/minifi-cpp/core/{ThreadedRepository.h =>
ProcessorMetadata.h} (81%)
copy cmake/libssh2/dummy/FindLibSSH2.cmake => packaging/CMakeLists.txt (77%)
rename {msi => packaging/msi}/MergeModulesFeature.xml (100%)
rename {msi => packaging/msi}/VSRedistributablesComponent.xml (100%)
rename {msi => packaging/msi}/VSRedistributablesFeature.xml (100%)
rename {msi => packaging/msi}/WixWin.wsi.in (99%)
rename {msi => packaging/msi}/bgr.png (100%)
rename {msi => packaging/msi}/minifi-logo-ico.ico (100%)
rename {msi => packaging/msi}/minifi-logo-png-banner.png (100%)
rename {msi => packaging/msi}/x64.wsi (100%)
rename {msi => packaging/msi}/x86.wsi (100%)
create mode 100755 packaging/rpm/check_rpm_contents.sh
create mode 100644 packaging/rpm/expected-rpm-contents.in
create mode 100644 packaging/rpm/pre_install.sh
delete mode 100644 rheldistro.sh
delete mode 100644 suse.sh
create mode 100644 thirdparty/azure-sdk-cpp/fix-managed-identity.patch
create mode 100644 thirdparty/azure-sdk-cpp/fix-openssl-helper.patch
create mode 100644
thirdparty/azure-sdk-cpp/include-cinttypes-for-uint8_t-gcc15-fix.patch
delete mode 100644 thirdparty/azure-sdk-cpp/remove-amqp.patch
create mode 100644 thirdparty/google-cloud-cpp/remove_installation.patch
delete mode 100644 thirdparty/grpc/fix-constants-on-windows.patch
create mode 100644 thirdparty/grpc/fix-protobuf-find-package.patch
delete mode 100644
thirdparty/grpc/remove-custom-commands-for-unused-dependencies.patch
create mode 100644 thirdparty/librdkafka/0003-remove_FindLZ4_installation.patch
delete mode 100644 thirdparty/libxml2/libxml2-win.patch
create mode 100644 thirdparty/opencv/windows-install-path.patch
delete mode 100644 utils/CMakeLists.txt
delete mode 100644 utils/include/Exception.h
delete mode 100644 utils/include/SwapManager.h
delete mode 100644 utils/include/agent/agent_version.h
delete mode 100644 utils/include/core/Annotation.h
delete mode 100644 utils/include/core/OutputAttributeDefinition.h
delete mode 100644 utils/include/core/Processor.h
delete mode 100644 utils/include/core/PropertyDefinition.h
delete mode 100644 utils/include/core/RelationshipDefinition.h
delete mode 100644 utils/include/core/logging/Logger.h
delete mode 100644 utils/include/io/ArchiveStream.h
delete mode 100644 utils/include/utils/Export.h
delete mode 100644 utils/include/utils/Literals.h
delete mode 100644 utils/include/utils/PropertyExceptions.h
delete mode 100644 utils/include/utils/gsl.h
