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