This is an automated email from the ASF dual-hosted git repository. lordgamez pushed a change to branch MINIFICPP-2596 in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git
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 bde9225b0 MINIFICPP-2600 Change RecordSetReader interface add 9df9c71f8 MINIFICPP-2594 Add XMLReader controller service add 3b1efcced Fix license add 579fd1680 Fix build add 35680ed42 MINIFICPP-2596 Add XMLRecordSetWriter controller service add b7b0564bb Fix license 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 (27903b953) \ N -- N -- N refs/heads/MINIFICPP-2596 (b7b0564bb) 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: .dockerignore | 2 +- .github/workflows/ci.yml | 46 +- .github/workflows/verify-package.yml | 2 +- CMakeLists.txt | 48 +- CONTRIBUTING.md | 3 - LICENSE | 2 +- PROCESSORS.md | 30 +- bootstrap.sh | 7 + bstrp_functions.sh | 11 +- cmake/AzureSdkCpp.cmake | 21 +- cmake/BundledLibcURL.cmake | 1 + cmake/ExpectedLite.cmake | 2 +- cmake/Extensions.cmake | 8 - cmake/Grpc.cmake | 17 +- cmake/MiNiFiOptions.cmake | 1 + cmake/Protobuf.cmake | 37 + controller/MiNiFiController.cpp | 25 +- controller/tests/ControllerTests.cpp | 8 +- core-framework/CMakeLists.txt | 22 + {utils => core-framework}/include/Exception.h | 0 {utils => core-framework}/include/SwapManager.h | 0 .../include/agent/agent_docs.h | 3 +- .../include/agent/agent_version.h | 0 .../include/core/Annotation.h | 0 .../include/core/BufferedContentSession.h | 0 .../include/core/ClassLoader.h | 6 + {utils => core-framework}/include/core/ClassName.h | 0 .../include/core/ConfigurableComponentImpl.h | 4 +- .../include/core/Connectable.h | 0 .../include/core/ContentRepository.h | 0 .../include/core/ContentSession.h | 0 {utils => core-framework}/include/core/Core.h | 0 .../include/core/ObjectFactory.h | 0 .../include/core/OutputAttributeDefinition.h | 0 .../include/core/ProcessContext.h | 74 +- .../include/core/ProcessContextBuilder.h | 0 .../include/core/ProcessorFactoryImpl.h | 46 +- core-framework/include/core/ProcessorImpl.h | 157 +++ .../include/core/ProcessorMetrics.h | 6 +- {utils => core-framework}/include/core/Property.h | 0 .../include/core/PropertyDefinition.h | 0 .../include/core/PropertyDefinitionBuilder.h | 0 .../include/core/Relationship.h | 0 .../include/core/RelationshipDefinition.h | 0 .../include/core/Repository.h | 0 .../include/core/RepositoryMetricsSource.h | 0 {utils => core-framework}/include/core/Resource.h | 14 +- .../include/core/StreamManager.h | 0 .../include/core/ThreadedRepository.h | 0 .../include/core/TypedValues.h | 0 .../include/core/VariableRegistry.h | 0 .../include/core/controller/ControllerService.h | 4 + {utils => core-framework}/include/core/expect.h | 0 .../include/core/extension/Extension.h | 0 .../include/core/logging/Logger.h | 0 .../include/core/logging/LoggerFactory.h | 0 .../include/core/state/MetricsPublisher.h | 0 .../include/core/state/PublishedMetricProvider.h | 0 .../include/core/state/Value.h | 0 .../include/core/state/nodes/ResponseNode.h | 20 +- .../include/http/BaseHTTPClient.h | 6 +- .../include/http/HTTPCallback.h | 0 .../include/http/HTTPClient.h | 15 +- .../include/http/HTTPStream.h | 0 .../include/io/ArchiveStream.h | 0 {utils => core-framework}/include/io/AsioStream.h | 0 {utils => core-framework}/include/io/BaseStream.h | 0 .../include/io/BufferStream.h | 0 {utils => core-framework}/include/io/CRCStream.h | 0 {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 | 0 {utils => core-framework}/include/io/StreamSlice.h | 0 {utils => core-framework}/include/io/ZlibStream.h | 0 {utils => core-framework}/include/io/validation.h | 0 .../include/utils/ArrayUtils.h | 0 .../include/utils/AttributeErrors.h | 0 .../include/utils/AutoPersistor.h | 0 .../include/utils/BackTrace.h | 0 .../include/utils/ByteArrayCallback.h | 0 .../include/utils/CallBackTimer.h | 0 .../include/utils/ClassUtils.h | 0 .../include/utils/CollectionUtils.h | 0 .../include/utils/ConfigurationUtils.h | 0 {utils => core-framework}/include/utils/Cron.h | 0 {utils => core-framework}/include/utils/Deleters.h | 0 {utils => core-framework}/include/utils/Enum.h | 0 .../include/utils/Environment.h | 0 {utils => core-framework}/include/utils/Error.h | 0 {utils => core-framework}/include/utils/Export.h | 0 .../include/utils/FailurePolicy.h | 0 .../include/utils/FifoExecutor.h | 0 .../include/utils/FileMutex.h | 0 .../include/utils/GeneralUtils.h | 0 .../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 | 0 .../include/utils/JsonCallback.h | 0 .../utils/LineByLineInputOutputStreamCallback.h | 0 {utils => core-framework}/include/utils/Literals.h | 0 {utils => core-framework}/include/utils/LogUtils.h | 0 {utils => core-framework}/include/utils/Macro.h | 0 {utils => core-framework}/include/utils/MapUtils.h | 0 .../include/utils/MinifiConcurrentQueue.h | 0 {utils => core-framework}/include/utils/Monitors.h | 0 .../include/utils/OptionalUtils.h | 0 {utils => core-framework}/include/utils/OsUtils.h | 0 .../include/utils/ParsingErrors.h | 0 .../include/utils/ParsingUtils.h | 0 .../include/utils/ProcessCpuUsageTracker.h | 0 .../include/utils/PropertyErrors.h | 0 .../include/utils/PropertyExceptions.h | 0 .../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 | 0 .../include/utils/SystemCpuUsageTracker.h | 0 .../include/utils/ThreadPool.h | 0 {utils => core-framework}/include/utils/TimeUtil.h | 0 .../include/utils/TryMoveCall.h | 0 .../include/utils/UnicodeConversion.h | 0 .../include/utils/ValueCaster.h | 0 .../include/utils/ValueParser.h | 0 .../include/utils/crypto/EncryptionManager.h | 0 .../include/utils/crypto/EncryptionProvider.h | 0 .../include/utils/crypto/EncryptionUtils.h | 0 .../include/utils/crypto/ciphers/Aes256Ecb.h | 0 .../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 | 0 .../include/utils/file/PathUtils.h | 0 {utils => core-framework}/include/utils/gsl.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 | 21 +- {utils => core-framework}/include/utils/net/DNS.h | 0 .../include/utils/net/NetworkInterfaceInfo.h | 0 .../include/utils/net/Socket.h | 0 .../include/utils/requirements/Container.h | 0 .../utils/requirements/EqualityComparable.h | 0 .../utils/requirements/LegacyForwardIterator.h | 0 .../utils/requirements/LegacyInputIterator.h | 0 .../include/utils/requirements/LegacyIterator.h | 0 .../include/utils/requirements/Swappable.h | 0 {utils => core-framework}/include/utils/span.h | 0 .../src/core/BufferedContentSession.cpp | 0 .../src/core/ConfigurableComponentImpl.cpp | 0 {utils => core-framework}/src/core/Connectable.cpp | 2 + .../src/core/ContentRepository.cpp | 0 .../src/core/ContentSession.cpp | 0 {utils => core-framework}/src/core/Core.cpp | 0 .../src/core/ProcessContextBuilder.cpp | 0 .../src/core/ProcessSession.cpp | 0 core-framework/src/core/ProcessorImpl.cpp | 100 ++ .../src/core/ProcessorMetrics.cpp | 4 +- {utils => core-framework}/src/core/Property.cpp | 0 {utils => core-framework}/src/core/Repository.cpp | 0 {utils => core-framework}/src/core/TypedValues.cpp | 0 .../src/core/extension/Extension.cpp | 0 .../src/http/BaseHTTPClient.cpp | 0 {utils => core-framework}/src/http/HTTPClient.cpp | 4 +- {utils => core-framework}/src/http/HTTPStream.cpp | 0 {utils => core-framework}/src/io/BufferStream.cpp | 0 {utils => core-framework}/src/io/CPPLINT.cfg | 0 {utils => core-framework}/src/io/CRCStream.cpp | 0 {utils => core-framework}/src/io/FileStream.cpp | 0 {utils => core-framework}/src/io/InputStream.cpp | 0 {utils => core-framework}/src/io/OutputStream.cpp | 12 +- {utils => core-framework}/src/io/StreamSlice.cpp | 0 {utils => core-framework}/src/io/ZlibStream.cpp | 0 .../src/utils/AutoPersistor.cpp | 0 {utils => core-framework}/src/utils/BackTrace.cpp | 0 .../src/utils/ByteArrayCallback.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 | 0 {utils => core-framework}/src/utils/Error.cpp | 0 .../src/utils/FifoExecutor.cpp | 0 {utils => core-framework}/src/utils/FileMutex.cpp | 0 {utils => core-framework}/src/utils/HTTPUtils.cpp | 0 {utils => core-framework}/src/utils/Id.cpp | 0 .../utils/LineByLineInputOutputStreamCallback.cpp | 0 {utils => core-framework}/src/utils/OsUtils.cpp | 0 .../src/utils/ParsingUtils.cpp | 0 .../src/utils/ProcessCpuUsageTracker.cpp | 0 {utils => core-framework}/src/utils/RegexUtils.cpp | 0 .../src/utils/StoppableThread.cpp | 0 .../src/utils/StringUtils.cpp | 0 .../src/utils/SystemCpuUsageTracker.cpp | 0 {utils => core-framework}/src/utils/ThreadPool.cpp | 0 {utils => core-framework}/src/utils/TimeUtil.cpp | 0 .../src/utils/crypto/EncryptionManager.cpp | 0 .../src/utils/crypto/EncryptionProvider.cpp | 0 .../src/utils/crypto/EncryptionUtils.cpp | 0 .../src/utils/crypto/ciphers/Aes256Ecb.cpp | 0 .../PropertyEncryptionUtils.cpp | 0 .../src/utils/file/FilePattern.cpp | 0 .../src/utils/file/FileUtils.cpp | 0 .../src/utils/file/PathUtils.cpp | 0 .../src/utils/net/AsioSocketUtils.cpp | 6 +- {utils => core-framework}/src/utils/net/DNS.cpp | 0 .../src/utils/net/NetworkInterfaceInfo.cpp | 0 {utils => core-framework}/src/utils/net/Socket.cpp | 0 .../containers/AzureStorageServerContainer.py | 2 +- .../CMakeLists.txt | 16 +- .../include/FlowFileRecord.h | 0 .../include/ResourceClaim.h | 2 +- .../include/controllers/AttributeProviderService.h | 0 .../include/controllers/RecordSetReader.h | 0 .../include/controllers/RecordSetWriter.h | 0 .../include/controllers/SSLContextService.h | 2 +- .../controllers/SSLContextServiceInterface.h | 4 +- .../controllers/keyvalue/KeyValueStateManager.h | 0 .../controllers/keyvalue/KeyValueStateStorage.h | 0 .../include/core/AbstractProcessor.h | 7 +- .../include/core/FlowFile.h | 0 .../include/core/FlowFileStore.h | 0 .../include/core/ProcessSession.h | 0 .../include/core/StateManager.h | 3 +- .../include/core/StateStorage.h | 6 +- .../include/properties/Configure.h | 0 .../include/properties/Properties.h | 0 .../include/serialization/FlowFileSerializer.h | 0 .../include/serialization/FlowFileV3Serializer.h | 0 .../include/serialization/PayloadSerializer.h | 0 .../include/utils/ListingStateManager.h | 0 .../include/utils/OpenTelemetryLogDataModelUtils.h | 0 .../include/utils/ProcessorConfigUtils.h | 52 +- .../include/utils/ResourceQueue.h | 0 .../include/utils/file/FileManager.h | 0 .../include/utils/file/FileReaderCallback.h | 0 .../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 | 0 .../include/utils/net/Ssl.h | 0 .../include/utils/net/TcpServer.h | 0 .../include/utils/net/UdpServer.h | 0 .../controllers/keyvalue/KeyValueStateManager.cpp | 0 .../controllers/keyvalue/KeyValueStateStorage.cpp | 0 .../src/core/ProcessContext.cpp | 0 .../src/serialization/FlowFileV3Serializer.cpp | 0 .../src/serialization/PayloadSerializer.cpp | 0 .../src/utils/CallBackTimer.cpp | 0 .../src/utils/ListingStateManager.cpp | 0 .../src/utils/file/FileReaderCallback.cpp | 0 .../src/utils/file/FileWriterCallback.cpp | 0 .../src/utils/net/Ssl.cpp | 8 +- .../src/utils/net/TcpServer.cpp | 0 .../src/utils/net/UdpServer.cpp | 0 extensions/aws/CMakeLists.txt | 2 - extensions/aws/processors/AwsProcessor.cpp | 5 - extensions/aws/processors/AwsProcessor.h | 9 +- extensions/aws/processors/DeleteS3Object.h | 10 +- extensions/aws/processors/FetchS3Object.h | 10 +- extensions/aws/processors/ListS3.h | 10 +- extensions/aws/processors/PutKinesisStream.h | 10 +- extensions/aws/processors/PutS3Object.h | 10 +- extensions/aws/processors/S3Processor.cpp | 9 +- extensions/aws/processors/S3Processor.h | 7 +- extensions/aws/tests/PutKinesisStreamTests.cpp | 41 +- extensions/aws/tests/PutS3ObjectTests.cpp | 4 +- extensions/aws/tests/S3TestsFixture.h | 8 +- extensions/azure/CMakeLists.txt | 2 - .../processors/AzureBlobStorageProcessorBase.cpp | 12 +- .../processors/AzureBlobStorageProcessorBase.h | 6 +- .../AzureBlobStorageSingleBlobProcessorBase.h | 6 +- .../AzureDataLakeStorageFileProcessorBase.h | 9 +- .../processors/AzureDataLakeStorageProcessorBase.h | 10 +- .../azure/processors/AzureStorageProcessorBase.h | 9 +- .../azure/processors/DeleteAzureBlobStorage.h | 8 +- .../azure/processors/DeleteAzureDataLakeStorage.h | 8 +- .../azure/processors/FetchAzureBlobStorage.h | 8 +- .../azure/processors/FetchAzureDataLakeStorage.h | 8 +- extensions/azure/processors/ListAzureBlobStorage.h | 8 +- .../azure/processors/ListAzureDataLakeStorage.h | 8 +- extensions/azure/processors/PutAzureBlobStorage.h | 8 +- .../azure/processors/PutAzureDataLakeStorage.h | 8 +- .../azure/storage/AzureBlobStorageClient.cpp | 20 +- extensions/azure/storage/AzureBlobStorageClient.h | 2 +- .../azure/tests/AzureBlobStorageTestsFixture.h | 6 +- .../azure/tests/AzureDataLakeStorageTestsFixture.h | 8 +- .../azure/tests/ListAzureBlobStorageTests.cpp | 7 +- .../azure/tests/ListAzureDataLakeStorageTests.cpp | 8 +- extensions/bustache/ApplyTemplate.h | 7 +- extensions/bustache/CMakeLists.txt | 1 - extensions/bustache/tests/ApplyTemplateTests.cpp | 3 +- extensions/civetweb/CMakeLists.txt | 1 - extensions/civetweb/processors/ListenHTTP.cpp | 16 +- extensions/civetweb/processors/ListenHTTP.h | 9 +- extensions/civetweb/tests/C2VerifyServeResults.cpp | 6 +- extensions/civetweb/tests/ListenHTTPTests.cpp | 23 +- extensions/couchbase/CMakeLists.txt | 1 - .../controllerservices/CouchbaseClusterService.cpp | 10 +- .../controllerservices/CouchbaseClusterService.h | 6 +- .../couchbase/tests/GetCouchbaseKeyTests.cpp | 3 +- .../couchbase/tests/PutCouchbaseKeyTests.cpp | 3 +- extensions/elasticsearch/CMakeLists.txt | 1 - extensions/elasticsearch/PostElasticsearch.cpp | 4 +- extensions/elasticsearch/PostElasticsearch.h | 11 +- .../elasticsearch/tests/PostElasticsearchTests.cpp | 3 +- extensions/execute-process/CMakeLists.txt | 1 - extensions/execute-process/ExecuteProcess.cpp | 14 +- extensions/execute-process/ExecuteProcess.h | 12 +- .../execute-process/test/ExecuteProcessTests.cpp | 7 +- extensions/expression-language/CMakeLists.txt | 1 - .../expression-language/ProcessContextExpr.cpp | 8 +- .../expression-language/ProcessContextExpr.h | 18 +- .../tests/ProcessContextExprTests.cpp | 65 +- extensions/gcp/CMakeLists.txt | 1 - extensions/gcp/processors/DeleteGCSObject.h | 4 +- extensions/gcp/processors/FetchGCSObject.h | 4 +- extensions/gcp/processors/GCSProcessor.h | 8 +- extensions/gcp/processors/ListGCSBucket.h | 4 +- extensions/gcp/processors/PutGCSObject.h | 4 +- extensions/gcp/tests/DeleteGCSObjectTests.cpp | 17 +- extensions/gcp/tests/FetchGCSObjectTests.cpp | 15 +- extensions/gcp/tests/ListGCSBucketTests.cpp | 17 +- extensions/gcp/tests/PutGCSObjectTests.cpp | 47 +- extensions/grafana-loki/CMakeLists.txt | 2 - extensions/grafana-loki/PushGrafanaLoki.cpp | 14 +- extensions/grafana-loki/PushGrafanaLoki.h | 17 +- extensions/grafana-loki/PushGrafanaLokiGrpc.h | 4 +- extensions/grafana-loki/PushGrafanaLokiREST.h | 4 +- .../grafana-loki/tests/PushGrafanaLokiGrpcTest.cpp | 12 +- .../grafana-loki/tests/PushGrafanaLokiRESTTest.cpp | 14 +- extensions/kafka/CMakeLists.txt | 1 - extensions/kafka/ConsumeKafka.cpp | 2 +- extensions/kafka/ConsumeKafka.h | 3 +- extensions/kafka/KafkaProcessorBase.cpp | 2 +- extensions/kafka/KafkaProcessorBase.h | 12 +- extensions/kafka/PublishKafka.h | 7 +- extensions/kafka/tests/PublishKafkaTests.cpp | 17 +- extensions/kubernetes/CMakeLists.txt | 1 - .../processors/CollectKubernetesPodMetrics.h | 7 +- extensions/libarchive/BinFiles.cpp | 10 +- extensions/libarchive/BinFiles.h | 4 +- extensions/libarchive/CMakeLists.txt | 1 - extensions/libarchive/CompressContent.h | 7 +- extensions/libarchive/FocusArchiveEntry.cpp | 16 +- extensions/libarchive/FocusArchiveEntry.h | 11 +- extensions/libarchive/ManipulateArchive.cpp | 4 +- extensions/libarchive/ManipulateArchive.h | 7 +- extensions/libarchive/MergeContent.h | 5 +- extensions/libarchive/UnfocusArchiveEntry.h | 7 +- .../libarchive/tests/CompressContentTests.cpp | 2 +- extensions/libarchive/tests/FocusArchiveTests.cpp | 5 +- .../libarchive/tests/ManipulateArchiveTests.cpp | 3 +- extensions/libarchive/tests/MergeFileTests.cpp | 8 +- extensions/llamacpp/CMakeLists.txt | 1 - .../llamacpp/processors/RunLlamaCppInference.h | 9 +- .../llamacpp/tests/RunLlamaCppInferenceTests.cpp | 28 +- extensions/lua/CMakeLists.txt | 1 - .../TestExecuteScriptProcessorWithLuaScript.cpp | 23 +- extensions/mqtt/CMakeLists.txt | 1 - .../mqtt/processors/AbstractMQTTProcessor.cpp | 4 +- extensions/mqtt/processors/AbstractMQTTProcessor.h | 8 +- extensions/mqtt/processors/ConsumeMQTT.cpp | 6 +- extensions/mqtt/processors/ConsumeMQTT.h | 9 +- extensions/mqtt/processors/PublishMQTT.cpp | 10 +- extensions/mqtt/processors/PublishMQTT.h | 11 +- extensions/opc/CMakeLists.txt | 1 - extensions/opc/include/fetchopc.h | 54 +- extensions/opc/include/opcbase.h | 9 +- extensions/opc/include/putopc.h | 10 +- extensions/opc/src/fetchopc.cpp | 112 +- extensions/opc/src/opcbase.cpp | 1 - extensions/opc/src/putopc.cpp | 4 +- extensions/opc/tests/FetchOpcProcessorTests.cpp | 113 +- extensions/opc/tests/OpcUaTestServer.h | 30 +- extensions/opc/tests/PutOpcProcessorTests.cpp | 36 +- extensions/opencv/CMakeLists.txt | 1 - extensions/opencv/CaptureRTSPFrame.h | 7 +- extensions/opencv/MotionDetector.h | 7 +- extensions/pdh/CMakeLists.txt | 1 - extensions/pdh/PerformanceDataMonitor.cpp | 6 +- extensions/pdh/PerformanceDataMonitor.h | 9 +- extensions/procfs/CMakeLists.txt | 1 - extensions/procfs/processors/ProcFsMonitor.h | 7 +- extensions/procfs/tests/ProcFsMonitorTests.cpp | 3 +- extensions/prometheus/CMakeLists.txt | 1 - extensions/prometheus/PrometheusExposerWrapper.h | 4 +- extensions/python/CMakeLists.txt | 1 - extensions/python/ExecutePythonProcessor.cpp | 99 +- extensions/python/ExecutePythonProcessor.h | 19 +- extensions/python/PythonCreator.h | 67 +- extensions/python/PythonObjectFactory.h | 59 +- extensions/python/PythonProcessor.cpp | 6 +- extensions/python/PythonProcessor.h | 4 +- extensions/python/PythonScriptEngine.cpp | 4 +- extensions/python/PythonScriptEngine.h | 10 +- .../TestExecuteScriptProcessorWithPythonScript.cpp | 23 +- extensions/python/types/PyProcessContext.cpp | 10 +- extensions/python/types/PySSLContextService.h | 4 +- extensions/rocksdb-repos/CMakeLists.txt | 3 +- .../rocksdb-repos/database/RocksDatabase.cpp | 17 +- extensions/rocksdb-repos/database/RocksDatabase.h | 2 - .../rocksdb-repos/database/RocksDbInstance.cpp | 5 +- .../rocksdb-repos/database/RocksDbInstance.h | 2 +- extensions/rocksdb-repos/tests/RepoTests.cpp | 2 +- extensions/rocksdb-repos/tests/SwapTests.cpp | 8 +- extensions/script/CMakeLists.txt | 1 - extensions/script/ExecuteScript.cpp | 2 +- extensions/script/ExecuteScript.h | 7 +- extensions/sftp/CMakeLists.txt | 1 - extensions/sftp/processors/FetchSFTP.cpp | 5 - extensions/sftp/processors/FetchSFTP.h | 4 +- extensions/sftp/processors/ListSFTP.cpp | 5 - extensions/sftp/processors/ListSFTP.h | 4 +- extensions/sftp/processors/PutSFTP.cpp | 5 +- extensions/sftp/processors/PutSFTP.h | 6 +- extensions/sftp/processors/SFTPProcessorBase.cpp | 4 +- extensions/sftp/processors/SFTPProcessorBase.h | 8 +- extensions/smb/CMakeLists.txt | 1 - extensions/smb/FetchSmb.h | 7 +- extensions/smb/ListSmb.h | 7 +- extensions/smb/PutSmb.h | 7 +- extensions/smb/SmbConnectionControllerService.cpp | 2 +- extensions/smb/tests/FetchSmbTests.cpp | 5 +- extensions/smb/tests/ListAndFetchSmbTests.cpp | 12 +- extensions/smb/tests/ListSmbTests.cpp | 5 +- extensions/smb/tests/PutSmbTests.cpp | 7 +- extensions/splunk/CMakeLists.txt | 1 - extensions/splunk/PutSplunkHTTP.cpp | 2 +- extensions/splunk/PutSplunkHTTP.h | 7 +- extensions/splunk/QuerySplunkIndexingStatus.h | 4 +- extensions/splunk/SplunkHECProcessor.cpp | 6 +- extensions/splunk/SplunkHECProcessor.h | 17 +- extensions/splunk/tests/PutSplunkHTTPTests.cpp | 60 +- .../tests/QuerySplunkIndexingStatusTests.cpp | 66 +- extensions/sql/CMakeLists.txt | 1 - extensions/sql/processors/ExecuteSQL.cpp | 4 - extensions/sql/processors/ExecuteSQL.h | 2 +- extensions/sql/processors/PutSQL.cpp | 4 - extensions/sql/processors/PutSQL.h | 2 +- extensions/sql/processors/QueryDatabaseTable.cpp | 4 - extensions/sql/processors/QueryDatabaseTable.h | 2 +- extensions/sql/processors/SQLProcessor.h | 7 +- extensions/sql/tests/PutSQLTests.cpp | 3 +- extensions/standard-processors/CMakeLists.txt | 1 - .../controllers/JsonRecordSetWriter.h | 1 + .../controllers/JsonTreeReader.h | 1 + .../standard-processors/controllers/XMLReader.cpp | 2 +- .../standard-processors/controllers/XMLReader.h | 2 +- .../controllers/XMLRecordSetWriter.cpp | 2 +- .../controllers/XMLRecordSetWriter.h | 2 +- .../standard-processors/modbus/FetchModbusTcp.cpp | 12 +- .../standard-processors/modbus/FetchModbusTcp.h | 13 +- .../processors/AppendHostInfo.h | 7 +- .../processors/AttributeRollingWindow.cpp | 2 +- .../processors/AttributesToJSON.h | 7 +- .../processors/DefragmentText.cpp | 8 - .../processors/DefragmentText.h | 8 +- .../standard-processors/processors/ExtractText.h | 7 +- .../standard-processors/processors/FetchFile.h | 7 +- .../processors/GenerateFlowFile.cpp | 6 +- .../processors/GenerateFlowFile.h | 7 +- .../standard-processors/processors/GetFile.cpp | 6 +- .../standard-processors/processors/GetFile.h | 9 +- .../standard-processors/processors/GetTCP.cpp | 2 +- extensions/standard-processors/processors/GetTCP.h | 11 +- .../standard-processors/processors/HashContent.h | 7 +- .../standard-processors/processors/InvokeHTTP.cpp | 6 +- .../standard-processors/processors/InvokeHTTP.h | 15 +- .../processors/JoltTransformJSON.h | 8 +- .../standard-processors/processors/ListFile.h | 7 +- .../processors/ListenSyslog.cpp | 3 +- .../standard-processors/processors/ListenSyslog.h | 8 +- .../standard-processors/processors/ListenTCP.cpp | 4 +- .../standard-processors/processors/ListenTCP.h | 12 +- .../standard-processors/processors/ListenUDP.cpp | 2 +- .../standard-processors/processors/ListenUDP.h | 4 +- .../standard-processors/processors/LogAttribute.h | 8 +- .../processors/NetworkListenerProcessor.h | 10 +- .../standard-processors/processors/PutFile.h | 7 +- .../standard-processors/processors/PutTCP.cpp | 13 +- extensions/standard-processors/processors/PutTCP.h | 18 +- .../standard-processors/processors/PutUDP.cpp | 10 +- extensions/standard-processors/processors/PutUDP.h | 7 +- .../standard-processors/processors/ReplaceText.cpp | 11 +- .../standard-processors/processors/ReplaceText.h | 6 +- .../standard-processors/processors/RetryFlowFile.h | 7 +- .../processors/RouteOnAttribute.cpp | 7 +- .../processors/RouteOnAttribute.h | 7 +- .../standard-processors/processors/RouteText.cpp | 21 +- .../standard-processors/processors/RouteText.h | 6 +- .../processors/SegmentContent.h | 6 +- .../standard-processors/processors/SplitContent.h | 6 +- .../standard-processors/processors/SplitRecord.cpp | 2 +- .../standard-processors/processors/SplitText.h | 7 +- .../standard-processors/processors/TailFile.cpp | 4 +- .../standard-processors/processors/TailFile.h | 7 +- .../processors/UpdateAttribute.cpp | 2 +- .../processors/UpdateAttribute.h | 7 +- .../tests/integration/InvokeHTTPTests.cpp | 24 +- .../tests/integration/VerifyInvokeHTTP.h | 2 +- .../tests/unit/AttributeRollingWindowTests.cpp | 3 +- .../tests/unit/DefragmentTextTests.cpp | 254 ++-- .../tests/unit/ExtractTextTests.cpp | 2 +- .../tests/unit/FetchFileTests.cpp | 6 +- .../tests/unit/FlowJsonTests.cpp | 34 +- .../tests/unit/GenerateFlowFileTests.cpp | 13 +- .../tests/unit/GetFileTests.cpp | 4 +- .../standard-processors/tests/unit/GetTCPTests.cpp | 14 +- .../tests/unit/HashContentTest.cpp | 4 +- .../tests/unit/JoltTransformJSONTests.cpp | 14 +- .../tests/unit/JsonRecordTests.cpp | 2 +- .../tests/unit/ListFileTests.cpp | 4 +- .../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 | 31 +- .../tests/unit/PutFileTests.cpp | 2 +- .../standard-processors/tests/unit/PutTCPTests.cpp | 14 +- .../standard-processors/tests/unit/PutUDPTests.cpp | 3 +- .../tests/unit/RecordSetTests.cpp | 2 +- .../tests/unit/ReplaceTextTests.cpp | 8 +- .../tests/unit/RouteTextTests.cpp | 3 +- .../tests/unit/SegmentContentTests.cpp | 15 +- .../tests/unit/SplitContentTests.cpp | 49 +- .../tests/unit/SplitRecordTests.cpp | 3 +- .../tests/unit/SplitTextTests.cpp | 25 +- .../tests/unit/TailFileTests.cpp | 16 +- .../tests/unit/XMLReaderTests.cpp | 4 +- .../tests/unit/YamlConfigurationTests.cpp | 8 +- .../tests/unit/YamlConnectionParserTest.cpp | 16 +- extensions/systemd/CMakeLists.txt | 1 - extensions/systemd/ConsumeJournald.cpp | 10 +- extensions/systemd/ConsumeJournald.h | 5 +- extensions/systemd/tests/ConsumeJournaldTest.cpp | 5 +- extensions/test-processors/CMakeLists.txt | 1 - extensions/test-processors/KamikazeProcessor.h | 7 +- .../test-processors/LogOnDestructionProcessor.h | 7 +- extensions/windows-event-log/CMakeLists.txt | 1 - .../windows-event-log/ConsumeWindowsEventLog.cpp | 5 +- .../windows-event-log/ConsumeWindowsEventLog.h | 4 +- extensions/windows-event-log/TailEventLog.h | 7 +- .../tests/ConsumeWindowsEventLogTests.cpp | 9 +- extensions/windows-event-log/wel/MetadataWalker.h | 2 +- extensions/windows-event-log/wel/WindowsEventLog.h | 2 +- extensions/windows-event-log/wel/XMLString.h | 2 +- libminifi/CMakeLists.txt | 4 +- libminifi/include/ForwardingNode.h | 11 +- libminifi/include/Funnel.h | 4 +- libminifi/include/Port.h | 25 +- libminifi/include/RemoteProcessorGroupPort.h | 16 +- libminifi/include/c2/ControllerSocketProtocol.h | 6 +- libminifi/include/c2/protocols/RESTSender.h | 4 +- .../controllers/NetworkPrioritizerService.h | 1 - libminifi/include/controllers/SSLContextService.h | 32 +- libminifi/include/core/FlowConfiguration.h | 5 +- libminifi/include/core/ProcessGroup.h | 2 +- libminifi/include/core/Processor.h | 178 +++ libminifi/include/core/logging/alert/AlertSink.h | 4 +- .../reporting/SiteToSiteProvenanceReportingTask.h | 6 +- .../include/core/state/nodes/FlowInformation.h | 2 +- libminifi/include/core/state/nodes/MetricsBase.h | 2 +- libminifi/include/processors/ProcessorUtils.h | 12 +- libminifi/include/sitetosite/SiteToSite.h | 8 +- libminifi/include/sitetosite/SiteToSiteClient.h | 4 +- libminifi/src/Funnel.cpp | 5 +- libminifi/src/RemoteProcessorGroupPort.cpp | 36 +- libminifi/src/agent/agent_docs.cpp | 9 +- libminifi/src/c2/ControllerSocketProtocol.cpp | 27 +- libminifi/src/c2/protocols/RESTSender.cpp | 6 +- libminifi/src/controllers/SSLContextService.cpp | 40 +- libminifi/src/core/ClassLoader.cpp | 103 +- libminifi/src/core/FlowConfiguration.cpp | 19 +- libminifi/src/core/ProcessContext.cpp | 137 ++ libminifi/src/core/ProcessSession.cpp | 1 + {utils => libminifi}/src/core/Processor.cpp | 269 +++- .../src/core/flow/StructuredConfiguration.cpp | 45 +- .../src/core/flow/StructuredConnectionParser.cpp | 4 +- libminifi/src/core/logging/alert/AlertSink.cpp | 4 +- .../SiteToSiteProvenanceReportingTask.cpp | 2 +- .../src/core/state/nodes/AgentInformation.cpp | 13 +- libminifi/test/flow-tests/CustomProcessors.h | 8 +- libminifi/test/flow-tests/CycleTest.cpp | 14 +- libminifi/test/flow-tests/FlowControllerTests.cpp | 40 +- libminifi/test/flow-tests/LoopTest.cpp | 10 +- libminifi/test/flow-tests/MultiLoopTest.cpp | 10 +- libminifi/test/flow-tests/SessionTests.cpp | 5 +- .../integration/C2ControllerEnableFailureTest.cpp | 9 +- libminifi/test/integration/C2MetricsTest.cpp | 1 + libminifi/test/integration/C2NullConfiguration.cpp | 6 +- libminifi/test/integration/C2PauseResumeTest.cpp | 5 +- .../ControllerServiceIntegrationTests.cpp | 16 +- libminifi/test/integration/HTTPSiteToSiteTests.cpp | 2 +- libminifi/test/integration/SiteToSiteRestTest.cpp | 15 +- .../integration/StateTransactionalityTests.cpp | 8 +- .../integration/TimeoutHTTPSiteToSiteTests.cpp | 2 +- libminifi/test/libtest/unit/CMakeLists.txt | 2 +- libminifi/test/libtest/unit/DummyProcessor.h | 15 +- libminifi/test/libtest/unit/MockClasses.h | 19 +- libminifi/test/libtest/unit/ProcessorUtils.h | 46 + .../libtest/unit/ReadFromFlowFileTestProcessor.h | 7 +- .../libtest/unit/SingleProcessorTestController.h | 7 +- libminifi/test/libtest/unit/StatefulProcessor.h | 2 +- libminifi/test/libtest/unit/TestBase.cpp | 2 +- libminifi/test/libtest/unit/TestBase.h | 49 + libminifi/test/libtest/unit/TestUtils.h | 20 +- .../libtest/unit/WriteToFlowFileTestProcessor.h | 7 +- .../test/persistence-tests/PersistenceTests.cpp | 11 +- libminifi/test/unit/AbstractProcessorTest.cpp | 11 +- libminifi/test/unit/BulletinStoreTests.cpp | 3 +- libminifi/test/unit/ComponentManifestTests.cpp | 1 + libminifi/test/unit/ExpectedTest.cpp | 12 +- libminifi/test/unit/MetricsTests.cpp | 8 +- libminifi/test/unit/NetUtilsTest.cpp | 72 +- libminifi/test/unit/ProcessorConfigUtilsTests.cpp | 16 +- libminifi/test/unit/ResponseNodeLoaderTests.cpp | 5 +- libminifi/test/unit/SchedulingAgentTests.cpp | 29 +- minifi-api/include/minifi-cpp/agent/agent_docs.h | 2 + .../minifi-cpp/controllers/RecordSetReader.h | 6 + .../minifi-cpp/controllers/RecordSetWriter.h | 7 + ...ntextService.h => SSLContextServiceInterface.h} | 10 +- minifi-api/include/minifi-cpp/core/ClassLoader.h | 25 +- .../minifi-cpp/core/ConfigurableComponent.h | 3 + ...finition.h => ControllerServiceApiDefinition.h} | 9 +- .../include/minifi-cpp/core/ProcessContext.h | 28 +- .../minifi-cpp/core/ProcessContextBuilder.h | 3 +- minifi-api/include/minifi-cpp/core/Processor.h | 105 -- minifi-api/include/minifi-cpp/core/ProcessorApi.h | 75 ++ ...ocessSessionFactory.h => ProcessorDescriptor.h} | 18 +- .../{VariableRegistry.h => ProcessorFactory.h} | 23 +- .../{ThreadedRepository.h => ProcessorMetadata.h} | 15 +- minifi-api/include/minifi-cpp/core/Record.h | 1 + .../minifi-cpp/core/state/nodes/MetricsBase.h | 4 +- .../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 +++++++++++--------- thirdparty/grpc/fix-constants-on-windows.patch | 35 - thirdparty/grpc/fix-protobuf-find-package.patch | 22 + ...e-custom-commands-for-unused-dependencies.patch | 428 ------ utils/CMakeLists.txt | 22 - utils/include/core/Processor.h | 305 ----- 653 files changed, 4404 insertions(+), 3981 deletions(-) create mode 100644 cmake/Protobuf.cmake create mode 100644 core-framework/CMakeLists.txt rename {utils => core-framework}/include/Exception.h (100%) rename {utils => core-framework}/include/SwapManager.h (100%) rename {utils => core-framework}/include/agent/agent_docs.h (98%) rename {utils => core-framework}/include/agent/agent_version.h (100%) rename {utils => core-framework}/include/core/Annotation.h (100%) rename {utils => core-framework}/include/core/BufferedContentSession.h (100%) rename {utils => core-framework}/include/core/ClassLoader.h (85%) rename {utils => core-framework}/include/core/ClassName.h (100%) rename {utils => core-framework}/include/core/ConfigurableComponentImpl.h (97%) rename {utils => core-framework}/include/core/Connectable.h (100%) rename {utils => core-framework}/include/core/ContentRepository.h (100%) rename {utils => core-framework}/include/core/ContentSession.h (100%) rename {utils => core-framework}/include/core/Core.h (100%) rename {utils => core-framework}/include/core/ObjectFactory.h (100%) rename {utils => core-framework}/include/core/OutputAttributeDefinition.h (100%) rename {utils => core-framework}/include/core/ProcessContext.h (79%) rename {utils => core-framework}/include/core/ProcessContextBuilder.h (100%) 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/Property.h (100%) rename {utils => core-framework}/include/core/PropertyDefinition.h (100%) rename {utils => core-framework}/include/core/PropertyDefinitionBuilder.h (100%) rename {utils => core-framework}/include/core/Relationship.h (100%) rename {utils => core-framework}/include/core/RelationshipDefinition.h (100%) rename {utils => core-framework}/include/core/Repository.h (100%) 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 (100%) rename {utils => core-framework}/include/core/ThreadedRepository.h (100%) rename {utils => core-framework}/include/core/TypedValues.h (100%) 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 (100%) rename {utils => core-framework}/include/core/logging/Logger.h (100%) rename {utils => core-framework}/include/core/logging/LoggerFactory.h (100%) rename {utils => core-framework}/include/core/state/MetricsPublisher.h (100%) 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 (98%) 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/ArchiveStream.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 (100%) rename {utils => core-framework}/include/io/CRCStream.h (100%) 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 (100%) rename {utils => core-framework}/include/io/StreamSlice.h (100%) rename {utils => core-framework}/include/io/ZlibStream.h (100%) 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 (100%) rename {utils => core-framework}/include/utils/BackTrace.h (100%) rename {utils => core-framework}/include/utils/ByteArrayCallback.h (100%) 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 (100%) rename {utils => core-framework}/include/utils/ConfigurationUtils.h (100%) rename {utils => core-framework}/include/utils/Cron.h (100%) 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 (100%) rename {utils => core-framework}/include/utils/Error.h (100%) rename {utils => core-framework}/include/utils/Export.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 (100%) rename {utils => core-framework}/include/utils/GeneralUtils.h (100%) 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 (100%) rename {utils => core-framework}/include/utils/JsonCallback.h (100%) rename {utils => core-framework}/include/utils/LineByLineInputOutputStreamCallback.h (100%) rename {utils => core-framework}/include/utils/Literals.h (100%) 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 (100%) 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 (100%) 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 (100%) rename {utils => core-framework}/include/utils/ProcessCpuUsageTracker.h (100%) rename {utils => core-framework}/include/utils/PropertyErrors.h (100%) rename {utils => core-framework}/include/utils/PropertyExceptions.h (100%) 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 (100%) rename {utils => core-framework}/include/utils/SystemCpuUsageTracker.h (100%) rename {utils => core-framework}/include/utils/ThreadPool.h (100%) rename {utils => core-framework}/include/utils/TimeUtil.h (100%) rename {utils => core-framework}/include/utils/TryMoveCall.h (100%) 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 (100%) rename {utils => core-framework}/include/utils/crypto/EncryptionManager.h (100%) rename {utils => core-framework}/include/utils/crypto/EncryptionProvider.h (100%) rename {utils => core-framework}/include/utils/crypto/EncryptionUtils.h (100%) rename {utils => core-framework}/include/utils/crypto/ciphers/Aes256Ecb.h (100%) 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 (100%) rename {utils => core-framework}/include/utils/file/PathUtils.h (100%) rename {utils => core-framework}/include/utils/gsl.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 (100%) rename {utils => core-framework}/include/utils/net/Socket.h (100%) rename {utils => core-framework}/include/utils/requirements/Container.h (100%) rename {utils => core-framework}/include/utils/requirements/EqualityComparable.h (100%) rename {utils => core-framework}/include/utils/requirements/LegacyForwardIterator.h (100%) rename {utils => core-framework}/include/utils/requirements/LegacyInputIterator.h (100%) rename {utils => core-framework}/include/utils/requirements/LegacyIterator.h (100%) rename {utils => core-framework}/include/utils/requirements/Swappable.h (100%) rename {utils => core-framework}/include/utils/span.h (100%) rename {utils => core-framework}/src/core/BufferedContentSession.cpp (100%) 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 (100%) 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 (100%) rename {utils => core-framework}/src/core/Repository.cpp (100%) rename {utils => core-framework}/src/core/TypedValues.cpp (100%) rename {utils => core-framework}/src/core/extension/Extension.cpp (100%) rename {utils => core-framework}/src/http/BaseHTTPClient.cpp (100%) rename {utils => core-framework}/src/http/HTTPClient.cpp (99%) rename {utils => core-framework}/src/http/HTTPStream.cpp (100%) rename {utils => core-framework}/src/io/BufferStream.cpp (100%) 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 (100%) rename {utils => core-framework}/src/io/InputStream.cpp (100%) rename {utils => core-framework}/src/io/OutputStream.cpp (91%) rename {utils => core-framework}/src/io/StreamSlice.cpp (100%) rename {utils => core-framework}/src/io/ZlibStream.cpp (100%) 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 (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 (100%) rename {utils => core-framework}/src/utils/Error.cpp (100%) rename {utils => core-framework}/src/utils/FifoExecutor.cpp (100%) rename {utils => core-framework}/src/utils/FileMutex.cpp (100%) rename {utils => core-framework}/src/utils/HTTPUtils.cpp (100%) rename {utils => core-framework}/src/utils/Id.cpp (100%) rename {utils => core-framework}/src/utils/LineByLineInputOutputStreamCallback.cpp (100%) rename {utils => core-framework}/src/utils/OsUtils.cpp (100%) 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 (100%) rename {utils => core-framework}/src/utils/StoppableThread.cpp (100%) rename {utils => core-framework}/src/utils/StringUtils.cpp (100%) rename {utils => core-framework}/src/utils/SystemCpuUsageTracker.cpp (100%) rename {utils => core-framework}/src/utils/ThreadPool.cpp (100%) rename {utils => core-framework}/src/utils/TimeUtil.cpp (100%) rename {utils => core-framework}/src/utils/crypto/EncryptionManager.cpp (100%) 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 (100%) 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 (100%) rename {utils => core-framework}/src/utils/file/PathUtils.cpp (100%) rename {utils => core-framework}/src/utils/net/AsioSocketUtils.cpp (97%) rename {utils => core-framework}/src/utils/net/DNS.cpp (100%) rename {utils => core-framework}/src/utils/net/NetworkInterfaceInfo.cpp (100%) rename {utils => core-framework}/src/utils/net/Socket.cpp (100%) rename {extension-utils => extension-framework}/CMakeLists.txt (56%) copy {extension-utils => extension-framework}/include/FlowFileRecord.h (100%) rename {extension-utils => extension-framework}/include/ResourceClaim.h (95%) rename {extension-utils => extension-framework}/include/controllers/AttributeProviderService.h (100%) rename {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/SSLContextService.h (92%) rename extension-utils/include/FlowFileRecord.h => extension-framework/include/controllers/SSLContextServiceInterface.h (92%) rename {extension-utils => extension-framework}/include/controllers/keyvalue/KeyValueStateManager.h (100%) rename {extension-utils => extension-framework}/include/controllers/keyvalue/KeyValueStateStorage.h (100%) rename {extension-utils => extension-framework}/include/core/AbstractProcessor.h (91%) rename {extension-utils => extension-framework}/include/core/FlowFile.h (100%) rename {extension-utils => extension-framework}/include/core/FlowFileStore.h (100%) 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 (100%) rename {extension-utils => extension-framework}/include/properties/Configure.h (100%) rename {extension-utils => extension-framework}/include/properties/Properties.h (100%) rename {extension-utils => extension-framework}/include/serialization/FlowFileSerializer.h (100%) rename {extension-utils => extension-framework}/include/serialization/FlowFileV3Serializer.h (100%) rename {extension-utils => extension-framework}/include/serialization/PayloadSerializer.h (100%) rename {extension-utils => extension-framework}/include/utils/ListingStateManager.h (100%) rename {extension-utils => extension-framework}/include/utils/OpenTelemetryLogDataModelUtils.h (100%) rename {extension-utils => extension-framework}/include/utils/ProcessorConfigUtils.h (69%) rename {extension-utils => extension-framework}/include/utils/ResourceQueue.h (100%) rename {extension-utils => extension-framework}/include/utils/file/FileManager.h (100%) rename {extension-utils => extension-framework}/include/utils/file/FileReaderCallback.h (100%) 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 (100%) rename {extension-utils => extension-framework}/include/utils/net/Ssl.h (100%) rename {extension-utils => extension-framework}/include/utils/net/TcpServer.h (100%) rename {extension-utils => extension-framework}/include/utils/net/UdpServer.h (100%) rename {extension-utils => extension-framework}/src/controllers/keyvalue/KeyValueStateManager.cpp (100%) rename {extension-utils => extension-framework}/src/controllers/keyvalue/KeyValueStateStorage.cpp (100%) rename {extension-utils => extension-framework}/src/core/ProcessContext.cpp (100%) rename {extension-utils => extension-framework}/src/serialization/FlowFileV3Serializer.cpp (100%) rename {extension-utils => extension-framework}/src/serialization/PayloadSerializer.cpp (100%) rename {extension-utils => extension-framework}/src/utils/CallBackTimer.cpp (100%) rename {extension-utils => extension-framework}/src/utils/ListingStateManager.cpp (100%) 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 (91%) rename {extension-utils => extension-framework}/src/utils/net/TcpServer.cpp (100%) rename {extension-utils => extension-framework}/src/utils/net/UdpServer.cpp (100%) create mode 100644 libminifi/include/core/Processor.h create mode 100644 libminifi/src/core/ProcessContext.cpp rename {utils => libminifi}/src/core/Processor.cpp (62%) create mode 100644 libminifi/test/libtest/unit/ProcessorUtils.h rename minifi-api/include/minifi-cpp/controllers/{SSLContextService.h => SSLContextServiceInterface.h} (83%) copy minifi-api/include/minifi-cpp/core/{RelationshipDefinition.h => ControllerServiceApiDefinition.h} (82%) 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%) 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 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 delete mode 100644 utils/CMakeLists.txt delete mode 100644 utils/include/core/Processor.h