This is an automated email from the ASF dual-hosted git repository.
lordgamez pushed a change to branch MINIFICPP-2458
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git
omit 9329dee7a MINIFICPP-2458 Create EvaluateJsonPath processor
add 9dd176da2 MINIFICPP-2449 TailFile: option to output full batch in a
single flow file
add 34d9d1b18 Bump requests from 2.32.0 to 2.32.4 in /github_scripts
add 84ed42d62 MINIFICPP-2573 Remove Apache Rat exclude file
add e3e9b722f MINIFICPP-2574 Change log level for flow config persistance
failure
add 2cbcfc774 MINIFICPP-2578 Add hyphen character to expression language
special character list
add eb899598a MINIFICPP-2580 Upgrade GCP and googletest libraries
add 625679629 MINIFICPP-2579 Upgrade libarchive to v3.8.1
add ee21c293e MINIFICPP-2581 Fix EL evaluation in dynamic properties
add 695c90961 MINIFICPP-2583 Fix warnings of unhandled std::expected
return values
add 47f1c70d0 MINIFICPP-2572 Minor improvements to the python documentation
add c5fb05277 MINIFICPP-2575 Update cpplint to version 2.0.2 and use a
single linter CI job
add 14b32d423 MINIFICPP-2555 Use git diff to get the list of changed files
add aaf268b80 MINIFICPP-2588 Improve flaky docker tests
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 60fd1fbe6 MINIFICPP-2458 Create EvaluateJsonPath processor
add 603363cd8 Review update
add 6acd387d2 Review update
add da13d35b0 Fix after rebase
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 (9329dee7a)
\
N -- N -- N refs/heads/MINIFICPP-2458 (da13d35b0)
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:
.github/workflows/ci.yml | 109 +-
CMakeLists.txt | 4 +-
CPPLINT.cfg | 2 +-
EXPRESSIONS.md | 49 +-
PROCESSORS.md | 75 +-
cmake/AzureSdkCpp.cmake | 55 +
cmake/BundledAzureSdkCpp.cmake | 125 -
cmake/BundledLibArchive.cmake | 31 +-
cmake/BundledLibcURL.cmake | 1 +
cmake/GoogleCloudCpp.cmake | 33 +-
controller/MiNiFiController.cpp | 25 +-
controller/tests/ControllerTests.cpp | 8 +-
core-framework/CMakeLists.txt | 22 +
{utils => core-framework}/include/Exception.h | 2 +-
{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 | 66 +
.../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 | 6 +-
.../include/core/extension/Extension.h | 0
.../include/core/logging/Logger.h | 2 +-
.../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 | 22 +-
.../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 | 17 +-
{utils => core-framework}/include/io/FileStream.h | 0
{utils => core-framework}/include/io/InputStream.h | 2 +-
.../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 | 2 +-
{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 | 6 +-
.../include/utils/ByteArrayCallback.h | 0
.../include/utils/CallBackTimer.h | 19 +-
.../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 | 16 +-
{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 | 17 +-
.../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 | 2 +-
.../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 | 11 +-
.../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 | 4 +-
{utils => core-framework}/src/core/Connectable.cpp | 2 +
.../src/core/ContentRepository.cpp | 0
.../src/core/ContentSession.cpp | 3 +-
{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 | 14 +-
{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 | 6 +-
{utils => core-framework}/src/io/InputStream.cpp | 0
{utils => core-framework}/src/io/OutputStream.cpp | 12 +-
{utils => core-framework}/src/io/StreamSlice.cpp | 2 +
{utils => core-framework}/src/io/ZlibStream.cpp | 4 +-
.../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 | 4 +-
.../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 +-
.../cluster/containers/KafkaBrokerContainer.py | 6 +
.../integration/features/consume_kafka.feature | 3 +-
.../features/core_functionality.feature | 2 +-
docker/test/integration/features/couchbase.feature | 12 +-
.../test/integration/features/grafana_loki.feature | 14 +-
docker/test/integration/features/http.feature | 14 +-
docker/test/integration/features/kinesis.feature | 1 +
docker/test/integration/features/llamacpp.feature | 2 +-
.../test/integration/features/replace_text.feature | 2 +-
docker/test/integration/features/s3.feature | 12 +-
docker/test/integration/features/sql.feature | 10 +-
.../CMakeLists.txt | 16 +-
.../include/FlowFileRecord.h | 0
.../include/ResourceClaim.h | 0
.../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 | 0
.../include/core/StateStorage.h | 0
.../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 | 25 +-
.../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/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 | 5 +-
.../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/tests/ApplyTemplateTests.cpp | 3 +-
extensions/civetweb/processors/ListenHTTP.cpp | 16 +-
extensions/civetweb/processors/ListenHTTP.h | 9 +-
extensions/civetweb/tests/C2VerifyServeResults.cpp | 6 +-
extensions/civetweb/tests/ListenHTTPTests.cpp | 25 +-
.../controllerservices/CouchbaseClusterService.cpp | 10 +-
.../controllerservices/CouchbaseClusterService.h | 6 +-
.../couchbase/tests/GetCouchbaseKeyTests.cpp | 33 +-
.../couchbase/tests/PutCouchbaseKeyTests.cpp | 27 +-
extensions/elasticsearch/PostElasticsearch.cpp | 4 +-
extensions/elasticsearch/PostElasticsearch.h | 11 +-
.../elasticsearch/tests/PostElasticsearchTests.cpp | 3 +-
extensions/execute-process/ExecuteProcess.cpp | 14 +-
extensions/execute-process/ExecuteProcess.h | 12 +-
.../execute-process/test/ExecuteProcessTests.cpp | 7 +-
.../expression-language/ProcessContextExpr.cpp | 22 +-
.../expression-language/ProcessContextExpr.h | 18 +-
.../tests/ExpressionLanguageTests.cpp | 2 +-
.../tests/ProcessContextExprTests.cpp | 72 +-
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/CMakeLists.txt | 3 +-
extensions/gcp/tests/DeleteGCSObjectTests.cpp | 17 +-
extensions/gcp/tests/FetchGCSObjectTests.cpp | 15 +-
.../tests/GCPCredentialsControllerServiceTests.cpp | 19 +-
extensions/gcp/tests/ListGCSBucketTests.cpp | 17 +-
extensions/gcp/tests/PutGCSObjectTests.cpp | 47 +-
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/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 | 33 +-
.../processors/CollectKubernetesPodMetrics.h | 7 +-
extensions/libarchive/BinFiles.cpp | 10 +-
extensions/libarchive/BinFiles.h | 4 +-
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 | 106 +-
extensions/libarchive/tests/FocusArchiveTests.cpp | 5 +-
.../libarchive/tests/ManipulateArchiveTests.cpp | 3 +-
extensions/libarchive/tests/MergeFileTests.cpp | 132 +-
.../llamacpp/processors/RunLlamaCppInference.h | 9 +-
.../llamacpp/tests/RunLlamaCppInferenceTests.cpp | 100 +-
.../TestExecuteScriptProcessorWithLuaScript.cpp | 105 +-
.../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/mqtt/tests/ConsumeMQTTTests.cpp | 106 +-
extensions/mqtt/tests/PublishMQTTTests.cpp | 22 +-
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 | 183 +-
extensions/opc/tests/OpcUaTestServer.h | 30 +-
extensions/opc/tests/PutOpcProcessorTests.cpp | 288 +-
extensions/opencv/CaptureRTSPFrame.h | 7 +-
extensions/opencv/MotionDetector.h | 7 +-
extensions/pdh/PerformanceDataMonitor.cpp | 6 +-
extensions/pdh/PerformanceDataMonitor.h | 9 +-
extensions/procfs/processors/ProcFsMonitor.h | 7 +-
extensions/procfs/tests/ProcFsMonitorTests.cpp | 3 +-
extensions/prometheus/PrometheusExposerWrapper.h | 4 +-
extensions/python/ExecutePythonProcessor.cpp | 99 +-
extensions/python/ExecutePythonProcessor.h | 19 +-
extensions/python/PYTHON.md | 35 +-
extensions/python/PythonCreator.h | 67 +-
extensions/python/PythonObjectFactory.h | 51 +-
extensions/python/PythonProcessor.cpp | 6 +-
extensions/python/PythonProcessor.h | 4 +-
extensions/python/PythonScriptEngine.cpp | 4 +-
extensions/python/PythonScriptEngine.h | 10 +-
.../TestExecuteScriptProcessorWithPythonScript.cpp | 99 +-
extensions/python/types/PyProcessContext.cpp | 10 +-
extensions/python/types/PySSLContextService.h | 4 +-
extensions/rocksdb-repos/CMakeLists.txt | 2 +-
extensions/rocksdb-repos/tests/RepoTests.cpp | 2 +-
extensions/rocksdb-repos/tests/SwapTests.cpp | 8 +-
extensions/script/ExecuteScript.cpp | 2 +-
extensions/script/ExecuteScript.h | 7 +-
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/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 | 14 +-
extensions/smb/tests/ListSmbTests.cpp | 5 +-
extensions/smb/tests/PutSmbTests.cpp | 7 +-
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/data/DatabaseConnectors.h | 4 +-
extensions/sql/data/JSONSQLWriter.cpp | 4 +-
extensions/sql/data/JSONSQLWriter.h | 6 +-
extensions/sql/data/MaxCollector.h | 20 +-
extensions/sql/data/SQLRowSubscriber.h | 4 +-
extensions/sql/data/SQLRowsetProcessor.h | 27 +-
extensions/sql/data/SQLWriter.h | 16 +-
extensions/sql/data/SociConnectors.cpp | 8 +-
extensions/sql/data/SociConnectors.h | 14 +-
extensions/sql/processors/ExecuteSQL.cpp | 6 +-
extensions/sql/processors/ExecuteSQL.h | 2 +-
extensions/sql/processors/FlowFileSource.h | 4 +-
extensions/sql/processors/PutSQL.cpp | 4 -
extensions/sql/processors/PutSQL.h | 2 +-
extensions/sql/processors/QueryDatabaseTable.cpp | 4 -
extensions/sql/processors/QueryDatabaseTable.h | 5 +-
extensions/sql/processors/SQLProcessor.h | 7 +-
extensions/sql/services/DatabaseService.cpp | 6 +-
extensions/sql/tests/ExecuteSQLTests.cpp | 10 +-
extensions/sql/tests/PutSQLTests.cpp | 11 +-
extensions/sql/tests/QueryDatabaseTableTests.cpp | 2 +-
.../controllers/JsonRecordSetWriter.h | 1 +
.../controllers/JsonTreeReader.h | 1 +
.../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 +-
.../processors/EvaluateJsonPath.cpp | 22 +-
.../processors/EvaluateJsonPath.h | 15 +-
.../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 | 12 +-
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 | 21 +-
.../standard-processors/processors/TailFile.h | 37 +-
.../processors/UpdateAttribute.cpp | 2 +-
.../processors/UpdateAttribute.h | 7 +-
.../tests/integration/InvokeHTTPTests.cpp | 108 +-
.../tests/integration/TailFileIntegrationTest.cpp | 4 +-
.../tests/integration/VerifyInvokeHTTP.h | 6 +-
.../tests/unit/AttributeRollingWindowTests.cpp | 3 +-
.../tests/unit/AttributesToJSONTests.cpp | 10 +-
.../tests/unit/DefragmentTextTests.cpp | 254 +-
.../tests/unit/EvaluateJsonPathTests.cpp | 125 +-
.../tests/unit/ExtractTextTests.cpp | 2 +-
.../tests/unit/FetchFileTests.cpp | 60 +-
.../tests/unit/FlowJsonTests.cpp | 34 +-
.../tests/unit/GenerateFlowFileTests.cpp | 13 +-
.../tests/unit/GetFileTests.cpp | 12 +-
.../standard-processors/tests/unit/GetTCPTests.cpp | 14 +-
.../tests/unit/HashContentTest.cpp | 6 +-
.../tests/unit/JoltTransformJSONTests.cpp | 14 +-
.../tests/unit/ListFileTests.cpp | 14 +-
.../tests/unit/ListenSyslogTests.cpp | 30 +-
.../tests/unit/ListenTcpTests.cpp | 46 +-
.../tests/unit/ListenUDPTests.cpp | 12 +-
.../tests/unit/LogAttributeTests.cpp | 8 +-
.../tests/unit/ManifestTests.cpp | 152 +
.../tests/unit/ProcessGroupTestUtils.h | 2 +-
.../tests/unit/ProcessorTests.cpp | 41 +-
.../tests/unit/PutFileTests.cpp | 2 +-
.../standard-processors/tests/unit/PutTCPTests.cpp | 22 +-
.../standard-processors/tests/unit/PutUDPTests.cpp | 7 +-
.../tests/unit/ReplaceTextTests.cpp | 8 +-
.../tests/unit/RouteTextTests.cpp | 121 +-
.../tests/unit/SegmentContentTests.cpp | 35 +-
.../tests/unit/SplitContentTests.cpp | 205 +-
.../tests/unit/SplitRecordTests.cpp | 17 +-
.../tests/unit/SplitTextTests.cpp | 77 +-
.../tests/unit/TailFileTests.cpp | 80 +-
.../tests/unit/YamlConfigurationTests.cpp | 8 +-
.../tests/unit/YamlConnectionParserTest.cpp | 16 +-
extensions/systemd/ConsumeJournald.cpp | 10 +-
extensions/systemd/ConsumeJournald.h | 5 +-
extensions/systemd/tests/ConsumeJournaldTest.cpp | 5 +-
extensions/test-processors/KamikazeProcessor.h | 7 +-
.../test-processors/LogOnDestructionProcessor.h | 7 +-
.../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 +-
github_scripts/requirements.txt | 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 | 9 +-
libminifi/include/c2/protocols/RESTSender.h | 4 +-
.../controllers/NetworkPrioritizerService.h | 1 -
libminifi/include/controllers/SSLContextService.h | 58 +-
libminifi/include/core/FlowConfiguration.h | 5 +-
libminifi/include/core/ProcessGroup.h | 2 +-
libminifi/include/core/ProcessSession.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/EventDrivenSchedulingAgent.cpp | 15 +-
libminifi/src/Funnel.cpp | 5 +-
libminifi/src/RemoteProcessorGroupPort.cpp | 36 +-
libminifi/src/TimerDrivenSchedulingAgent.cpp | 7 +-
libminifi/src/c2/ControllerSocketProtocol.cpp | 39 +-
libminifi/src/c2/protocols/RESTSender.cpp | 6 +-
libminifi/src/controllers/SSLContextService.cpp | 40 +-
libminifi/src/core/ClassLoader.cpp | 103 +-
libminifi/src/core/FlowConfiguration.cpp | 29 +-
libminifi/src/core/ProcessContext.cpp | 137 +
libminifi/src/core/ProcessGroup.cpp | 5 +-
libminifi/src/core/ProcessSession.cpp | 8 +-
{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 +-
libminifi/test/integration/AbsoluteTimeoutTest.cpp | 4 +-
.../integration/C2ClearCoreComponentStateTest.cpp | 2 +-
.../integration/C2ControllerEnableFailureTest.cpp | 9 +-
.../C2DescribeCoreComponentStateTest.cpp | 2 +-
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 | 22 +-
libminifi/test/libtest/unit/TestBase.h | 57 +-
libminifi/test/libtest/unit/TestUtils.h | 20 +-
.../libtest/unit/WriteToFlowFileTestProcessor.h | 7 +-
.../test/persistence-tests/PersistenceTests.cpp | 27 +-
libminifi/test/unit/AbstractProcessorTest.cpp | 11 +-
libminifi/test/unit/BulletinStoreTests.cpp | 3 +-
libminifi/test/unit/ComponentManifestTests.cpp | 1 +
.../EnvironmentVariableParameterProviderTest.cpp | 24 +-
libminifi/test/unit/MetricsTests.cpp | 8 +-
libminifi/test/unit/NetUtilsTest.cpp | 58 +-
.../test/unit/NetworkPrioritizerServiceTests.cpp | 52 +-
libminifi/test/unit/ProcessorConfigUtilsTests.cpp | 20 +-
libminifi/test/unit/ResponseNodeLoaderTests.cpp | 5 +-
libminifi/test/unit/SchedulingAgentTests.cpp | 29 +-
libminifi/test/unit/UpdatePolicyTests.cpp | 14 +-
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 | 7 +-
.../include/minifi-cpp/core/ContentRepository.h | 3 +-
...finition.h => ControllerServiceApiDefinition.h} | 9 +-
.../include/minifi-cpp/core/ProcessContext.h | 32 +-
.../minifi-cpp/core/ProcessContextBuilder.h | 3 +-
.../include/minifi-cpp/core/ProcessSession.h | 2 +-
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/Property.h | 2 +-
.../include/minifi-cpp/core/PropertyDefinition.h | 5 +-
.../include/minifi-cpp/core/PropertyValidator.h | 132 +-
.../include/minifi-cpp/core/state/FlowIdentifier.h | 2 +-
.../minifi-cpp/core/state/nodes/MetricsBase.h | 4 +-
.../include/minifi-cpp/provenance/Provenance.h | 2 +-
.../include/minifi-cpp/utils/PropertyExceptions.h | 4 +-
minifi_main/Fips.cpp | 13 +-
minifi_main/Fips.h | 2 +-
minifi_main/MainHelper.h | 9 +-
minifi_main/MiNiFiMain.cpp | 4 +-
minifi_main/MiNiFiWindowsService.cpp | 6 +-
thirdparty/apache-rat/.rat-excludes | 8 -
.../azure-sdk-cpp/fix-managed-identity.patch | 15 +
thirdparty/azure-sdk-cpp/fix-openssl-helper.patch | 34 +
thirdparty/azure-sdk-cpp/gcc13.patch | 44 -
thirdparty/azure-sdk-cpp/remove-amqp.patch | 15 -
thirdparty/azure-sdk-cpp/wil.patch | 12 +
thirdparty/concurrentqueue/concurrentqueue.h | 1370 +-
.../mock-client-without-decorators.patch | 153 -
.../google-cloud-cpp/mock_client_target.patch | 26 -
.../google-cloud-cpp/remove-find_package.patch | 15 +-
thirdparty/google-styleguide/cpplint.py | 13035 ++++++++++---------
thirdparty/libarchive/libarchive.patch | 66 +-
utils/CMakeLists.txt | 22 -
utils/include/core/ConfigurableComponentImpl.h | 65 -
utils/include/core/Processor.h | 305 -
668 files changed, 12789 insertions(+), 11315 deletions(-)
create mode 100644 cmake/AzureSdkCpp.cmake
delete mode 100644 cmake/BundledAzureSdkCpp.cmake
create mode 100644 core-framework/CMakeLists.txt
rename {utils => core-framework}/include/Exception.h (96%)
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%)
create mode 100644 core-framework/include/core/ConfigurableComponentImpl.h
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 (89%)
rename {utils => core-framework}/include/core/extension/Extension.h (100%)
rename {utils => core-framework}/include/core/logging/Logger.h (94%)
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 (81%)
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 (92%)
rename {utils => core-framework}/include/io/FileStream.h (100%)
rename {utils => core-framework}/include/io/InputStream.h (96%)
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 (98%)
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 (96%)
rename {utils => core-framework}/include/utils/ByteArrayCallback.h (100%)
rename {utils => core-framework}/include/utils/CallBackTimer.h (79%)
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 (85%)
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 (77%)
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 (97%)
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 (99%)
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 (98%)
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 (92%)
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 (99%)
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 (97%)
rename {utils => core-framework}/src/io/ZlibStream.cpp (99%)
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 (98%)
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 (100%)
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
(100%)
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 (92%)
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%)
delete mode 100644 thirdparty/apache-rat/.rat-excludes
create mode 100644 thirdparty/azure-sdk-cpp/fix-managed-identity.patch
create mode 100644 thirdparty/azure-sdk-cpp/fix-openssl-helper.patch
delete mode 100644 thirdparty/azure-sdk-cpp/gcc13.patch
delete mode 100644 thirdparty/azure-sdk-cpp/remove-amqp.patch
create mode 100644 thirdparty/azure-sdk-cpp/wil.patch
delete mode 100644
thirdparty/google-cloud-cpp/mock-client-without-decorators.patch
delete mode 100644 thirdparty/google-cloud-cpp/mock_client_target.patch
delete mode 100644 utils/CMakeLists.txt
delete mode 100644 utils/include/core/ConfigurableComponentImpl.h
delete mode 100644 utils/include/core/Processor.h
