This is an automated email from the ASF dual-hosted git repository.
lordgamez pushed a change to branch MINIFICPP-2502
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git
omit a881933c2 Review update
omit b6fa2e04d MINIFICPP-2502 Add processorBulletins C2 metric node to
FlowInformation
omit 986cc7523 Fix clang tidy
omit c364cbf46 MINIFICPP-2512 Only use a single logger per processor
add 1206f3f33 MINIFICPP-2528 disable jom in CI
add 6c3a01c76 MINIFICPP-2533 Fix librdkafka compilation on Windows
add 60c51b73c MINIFICPP-2543 Make S3 operations FIPS compliant
add 6ae85a7dd MINIFICPP-2544 extend and fix FIPS docs
add 7ef4c0656 MINIFICPP-2547 Try to generate fipsmodule.cnf if not found
add e55676e9b MINIFICPP-2546 Allow use of MD5 algorithm in HashContent
processor in FIPS mode
add 049e126b1 MINIFICPP-2548 Dont fail flow-update when FlowController is
not running
add ad9f50e92 MINIFICPP-2549 Verify package CI with FIPS enabled
add 47f3324df MINIFICPP-2550 invokehttp: retry with attributes in headers
includes …
add 0f0d7e6f6 MINIFICPP-2551 Use correct openssl version
add 26aea0d82 MINIFICPP-2553 CMP0065=OLD removed in cmake 4.0, removed
override
add e2436e2d7 MINIFICPP-2519 Property refactor based on minifi-api
add 2fdeaf132 MINIFICPP-2512 Only use a single logger per processor
add fc130f5e2 Fix clang tidy
new 1889eaaf7 MINIFICPP-2502 Add processorBulletins C2 metric node to
FlowInformation
new 37b3f3f34 Review update
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 (a881933c2)
\
N -- N -- N refs/heads/MINIFICPP-2502 (37b3f3f34)
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.
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/ci.yml | 8 -
.github/workflows/verify-package.yml | 166 +++------
CMakeLists.txt | 3 +-
CONFIGURE.md | 15 +-
PROCESSORS.md | 247 +++++++-------
cmake/BundledAwsSdkCpp.cmake | 8 +-
cmake/BundledOpenSSL.cmake | 1 +
cmake/Fetchlibrdkafka.cmake | 7 +-
cmake/JoltTests.cmake | 5 +-
cmake/VerifyPackageWithDocker.cmake | 3 +
cmake/ssl/FindOpenSSL.cmake | 2 +-
docker/DockerVerify.sh | 12 +
docker/python-verify/conda.Dockerfile | 44 ---
docker/python-verify/conda.dockerignore | 1 -
docker/python-verify/venv.Dockerfile | 32 --
docker/python-verify/venv.dockerignore | 1 -
docker/test/integration/cluster/ContainerStore.py | 3 +
.../test/integration/cluster/DockerTestCluster.py | 9 +-
docker/test/integration/cluster/ImageStore.py | 2 +-
.../integration/cluster/checkers/AwsChecker.py | 6 +-
.../cluster/containers/MinifiContainer.py | 15 +-
.../cluster/containers/S3ServerContainer.py | 2 +-
.../features/MiNiFi_integration_test_driver.py | 3 +
.../test/integration/features/hashcontent.feature | 12 +
docker/test/integration/features/https.feature | 3 +-
docker/test/integration/features/kafka.feature | 19 --
.../integration/features/minifi_c2_server.feature | 6 +-
.../test/integration/features/opensearch.feature | 9 +-
.../test/integration/features/prometheus.feature | 3 +-
docker/test/integration/features/s2s.feature | 12 +-
docker/test/integration/features/s3.feature | 18 +
docker/test/integration/features/splunk.feature | 3 +-
docker/test/integration/features/steps/steps.py | 5 +
encrypt-config/FlowConfigEncryptor.cpp | 8 +-
.../include/utils/ListingStateManager.h | 2 +-
.../include/utils/ProcessorConfigUtils.h | 128 +++++--
extension-utils/src/core/ProcessContext.cpp | 14 -
extension-utils/src/utils/ListingStateManager.cpp | 10 +-
extension-utils/src/utils/ProcessorConfigUtils.cpp | 52 ---
extension-utils/src/utils/net/Ssl.cpp | 2 +-
.../controllerservices/AWSCredentialsService.cpp | 19 +-
.../aws/controllerservices/AWSCredentialsService.h | 4 +-
extensions/aws/processors/DeleteS3Object.cpp | 8 +-
extensions/aws/processors/FetchS3Object.cpp | 11 +-
extensions/aws/processors/FetchS3Object.h | 4 +-
extensions/aws/processors/ListS3.cpp | 25 +-
extensions/aws/processors/ListS3.h | 12 +-
extensions/aws/processors/PutS3Object.cpp | 88 ++---
extensions/aws/processors/PutS3Object.h | 28 +-
extensions/aws/processors/S3Processor.cpp | 83 ++---
extensions/aws/processors/S3Processor.h | 28 +-
extensions/aws/s3/MultipartUploadStateStorage.cpp | 24 +-
extensions/aws/s3/S3Wrapper.cpp | 17 +-
extensions/aws/s3/S3Wrapper.h | 34 +-
extensions/aws/tests/DeleteS3ObjectTests.cpp | 10 +-
extensions/aws/tests/FetchS3ObjectTests.cpp | 10 +-
extensions/aws/tests/ListS3Tests.cpp | 10 +-
.../aws/tests/MultipartUploadStateStorageTest.cpp | 4 +-
extensions/aws/tests/PutS3ObjectTests.cpp | 32 +-
.../AzureStorageCredentialsService.cpp | 26 +-
.../AzureStorageCredentialsService.h | 4 +-
.../processors/AzureBlobStorageProcessorBase.cpp | 44 ++-
.../processors/AzureBlobStorageProcessorBase.h | 5 +-
.../AzureBlobStorageSingleBlobProcessorBase.cpp | 2 +-
.../AzureDataLakeStorageFileProcessorBase.cpp | 2 +-
.../AzureDataLakeStorageProcessorBase.cpp | 10 +-
.../azure/processors/AzureStorageProcessorBase.cpp | 4 +-
.../azure/processors/FetchAzureBlobStorage.cpp | 8 +-
.../azure/processors/FetchAzureDataLakeStorage.cpp | 14 +-
.../azure/processors/FetchAzureDataLakeStorage.h | 4 +-
.../azure/processors/ListAzureBlobStorage.cpp | 2 +-
.../azure/processors/ListAzureDataLakeStorage.cpp | 8 +-
.../azure/processors/ListAzureDataLakeStorage.h | 4 +-
.../azure/processors/PutAzureBlobStorage.cpp | 4 +-
extensions/azure/processors/PutAzureBlobStorage.h | 4 +-
extensions/bustache/ApplyTemplate.cpp | 8 +-
extensions/civetweb/processors/ListenHTTP.cpp | 77 +----
extensions/civetweb/processors/ListenHTTP.h | 11 +-
extensions/civetweb/tests/ListenHTTPTests.cpp | 9 +-
.../controllerservices/CouchbaseClusterService.cpp | 12 +-
.../controllerservices/CouchbaseClusterService.h | 2 +-
.../couchbase/processors/GetCouchbaseKey.cpp | 26 +-
extensions/couchbase/processors/GetCouchbaseKey.h | 4 +
.../couchbase/processors/PutCouchbaseKey.cpp | 21 +-
extensions/couchbase/processors/PutCouchbaseKey.h | 4 +
.../couchbase/tests/GetCouchbaseKeyTests.cpp | 47 ++-
.../couchbase/tests/PutCouchbaseKeyTests.cpp | 34 +-
.../ElasticsearchCredentialsControllerService.cpp | 14 +-
.../ElasticsearchCredentialsControllerService.h | 1 +
extensions/elasticsearch/PostElasticsearch.cpp | 10 +-
extensions/elasticsearch/PostElasticsearch.h | 7 +-
extensions/execute-process/ExecuteProcess.cpp | 21 +-
extensions/execute-process/ExecuteProcess.h | 6 +-
.../execute-process/test/ExecuteProcessTests.cpp | 32 +-
extensions/expression-language/Expression.cpp | 2 +-
.../ExpressionContextBuilder.cpp | 2 +-
.../expression-language/ExpressionContextBuilder.h | 2 +-
.../expression-language/ProcessContextExpr.cpp | 94 +++---
.../expression-language/ProcessContextExpr.h | 24 +-
.../impl/expression/Expression.h | 10 +-
.../tests/ProcessContextExprTests.cpp | 33 --
.../GCPCredentialsControllerService.cpp | 17 +-
extensions/gcp/processors/DeleteGCSObject.cpp | 21 +-
extensions/gcp/processors/FetchGCSObject.cpp | 17 +-
extensions/gcp/processors/GCSProcessor.cpp | 13 +-
extensions/gcp/processors/GCSProcessor.h | 4 +-
extensions/gcp/processors/ListGCSBucket.cpp | 10 +-
extensions/gcp/processors/ListGCSBucket.h | 4 +-
extensions/gcp/processors/PutGCSObject.cpp | 4 +-
extensions/gcp/processors/PutGCSObject.h | 4 +-
extensions/gcp/tests/ListGCSBucketTests.cpp | 2 +-
extensions/grafana-loki/PushGrafanaLoki.cpp | 10 +-
extensions/grafana-loki/PushGrafanaLoki.h | 11 +-
extensions/grafana-loki/PushGrafanaLokiGrpc.cpp | 22 +-
extensions/grafana-loki/PushGrafanaLokiGrpc.h | 6 +-
extensions/grafana-loki/PushGrafanaLokiREST.cpp | 18 +-
extensions/grafana-loki/PushGrafanaLokiREST.h | 3 +-
extensions/kafka/ConsumeKafka.cpp | 53 ++-
extensions/kafka/ConsumeKafka.h | 311 ++++++++---------
extensions/kafka/KafkaProcessorBase.cpp | 23 +-
extensions/kafka/PublishKafka.cpp | 214 +++++-------
extensions/kafka/PublishKafka.h | 22 +-
extensions/kafka/tests/PublishKafkaTests.cpp | 29 +-
.../KubernetesControllerService.cpp | 15 +-
extensions/libarchive/BinFiles.cpp | 52 +--
extensions/libarchive/BinFiles.h | 16 +-
extensions/libarchive/CompressContent.cpp | 10 +-
extensions/libarchive/CompressContent.h | 12 +-
extensions/libarchive/FocusArchiveEntry.cpp | 2 +-
extensions/libarchive/ManipulateArchive.cpp | 10 +-
extensions/libarchive/MergeContent.cpp | 31 +-
extensions/libarchive/MergeContent.h | 4 +-
.../libarchive/tests/CompressContentTests.cpp | 99 +++---
extensions/libarchive/tests/MergeFileTests.cpp | 79 +++--
extensions/lua/LuaScriptProcessContext.cpp | 4 +-
.../TestExecuteScriptProcessorWithLuaScript.cpp | 46 +--
.../mqtt/processors/AbstractMQTTProcessor.cpp | 23 +-
extensions/mqtt/processors/AbstractMQTTProcessor.h | 6 +-
extensions/mqtt/processors/ConsumeMQTT.cpp | 74 ++--
extensions/mqtt/processors/ConsumeMQTT.h | 12 +-
extensions/mqtt/processors/PublishMQTT.cpp | 23 +-
extensions/mqtt/processors/PublishMQTT.h | 4 +-
extensions/mqtt/tests/ConsumeMQTTTests.cpp | 110 +++---
extensions/mqtt/tests/PublishMQTTTests.cpp | 26 +-
extensions/opc/include/fetchopc.h | 6 +-
extensions/opc/include/putopc.h | 4 +-
extensions/opc/src/fetchopc.cpp | 29 +-
extensions/opc/src/opcbase.cpp | 26 +-
extensions/opc/src/putopc.cpp | 76 ++---
extensions/opencv/CaptureRTSPFrame.cpp | 26 +-
extensions/opencv/MotionDetector.cpp | 36 +-
extensions/opencv/MotionDetector.h | 15 +-
extensions/opencv/tests/CaptureRTSPFrameTest.cpp | 3 -
extensions/pdh/PerformanceDataMonitor.cpp | 48 +--
.../pdh/tests/PerformanceDataMonitorTests.cpp | 18 -
extensions/procfs/processors/ProcFsMonitor.cpp | 22 +-
extensions/procfs/processors/ProcFsMonitor.h | 3 +-
.../prometheus/PrometheusMetricsPublisher.cpp | 1 +
extensions/python/ExecutePythonProcessor.cpp | 114 +++++--
extensions/python/ExecutePythonProcessor.h | 16 +-
extensions/python/PythonObjectFactory.h | 8 +-
.../TestExecuteScriptProcessorWithPythonScript.cpp | 46 +--
extensions/python/types/PyProcessContext.cpp | 49 ++-
extensions/rocksdb-repos/ProvenanceRepository.cpp | 2 +-
.../controllers/RocksDbStateStorage.cpp | 14 +-
.../controllers/RocksDbStateStorage.h | 10 +-
extensions/rocksdb-repos/tests/RepoTests.cpp | 5 +-
extensions/rocksdb-repos/tests/SwapTests.cpp | 4 +-
extensions/script/ExecuteScript.cpp | 9 +-
extensions/script/tests/ExecuteScriptTests.cpp | 6 +-
extensions/sftp/processors/FetchSFTP.cpp | 24 +-
extensions/sftp/processors/FetchSFTP.h | 8 +-
extensions/sftp/processors/ListSFTP.cpp | 88 ++---
extensions/sftp/processors/ListSFTP.h | 18 +-
extensions/sftp/processors/PutSFTP.cpp | 94 ++----
extensions/sftp/processors/PutSFTP.h | 14 +-
extensions/sftp/processors/SFTPProcessorBase.cpp | 92 ++---
extensions/sftp/processors/SFTPProcessorBase.h | 10 +-
extensions/smb/ListSmb.cpp | 33 +-
extensions/smb/ListSmb.h | 12 +-
extensions/smb/PutSmb.cpp | 2 +-
extensions/smb/SmbConnectionControllerService.cpp | 16 +-
extensions/splunk/PutSplunkHTTP.cpp | 23 +-
extensions/splunk/QuerySplunkIndexingStatus.cpp | 16 +-
extensions/splunk/QuerySplunkIndexingStatus.h | 8 +-
extensions/splunk/SplunkHECProcessor.cpp | 23 +-
extensions/splunk/SplunkHECProcessor.h | 4 +-
extensions/sql/processors/ExecuteSQL.cpp | 15 +-
extensions/sql/processors/FlowFileSource.h | 4 +-
extensions/sql/processors/PutSQL.cpp | 4 +-
extensions/sql/processors/QueryDatabaseTable.cpp | 17 +-
extensions/sql/processors/QueryDatabaseTable.h | 10 +-
extensions/sql/processors/SQLProcessor.cpp | 3 +-
extensions/sql/services/DatabaseService.cpp | 2 +-
extensions/sql/tests/ExecuteSQLTests.cpp | 6 +-
extensions/sql/tests/QueryDatabaseTableTests.cpp | 52 ++-
extensions/sql/tests/SQLTestPlan.h | 4 +
.../controllers/JsonRecordSetReader.cpp | 1 +
.../controllers/JsonRecordSetWriter.cpp | 4 +-
.../controllers/JsonRecordSetWriter.h | 3 +-
.../controllers/PersistentMapStateStorage.cpp | 14 +-
.../controllers/PersistentMapStateStorage.h | 10 +-
.../standard-processors/modbus/FetchModbusTcp.cpp | 50 +--
.../standard-processors/modbus/FetchModbusTcp.h | 9 +-
.../processors/AppendHostInfo.cpp | 22 +-
.../processors/AppendHostInfo.h | 3 +
.../processors/AttributeRollingWindow.cpp | 16 +-
.../processors/AttributeRollingWindow.h | 6 +-
.../processors/AttributesToJSON.cpp | 24 +-
.../processors/AttributesToJSON.h | 8 +-
.../processors/DefragmentText.cpp | 30 +-
.../processors/DefragmentText.h | 5 +-
.../standard-processors/processors/ExtractText.cpp | 58 ++--
.../standard-processors/processors/ExtractText.h | 15 +-
.../standard-processors/processors/FetchFile.cpp | 9 +-
.../processors/GenerateFlowFile.cpp | 20 +-
.../processors/GenerateFlowFile.h | 9 +-
.../standard-processors/processors/GetFile.cpp | 57 +---
.../standard-processors/processors/GetFile.h | 22 +-
.../standard-processors/processors/GetTCP.cpp | 38 +--
extensions/standard-processors/processors/GetTCP.h | 10 +-
.../standard-processors/processors/HashContent.cpp | 7 +-
.../standard-processors/processors/HashContent.h | 11 +-
.../standard-processors/processors/InvokeHTTP.cpp | 88 +++--
.../standard-processors/processors/InvokeHTTP.h | 45 ++-
.../processors/JoltTransformJSON.cpp | 8 +-
.../processors/JoltTransformJSON.h | 1 +
.../standard-processors/processors/ListFile.cpp | 42 +--
.../standard-processors/processors/ListFile.h | 14 +-
.../processors/ListenSyslog.cpp | 14 +-
.../standard-processors/processors/ListenSyslog.h | 10 +-
.../standard-processors/processors/ListenTCP.cpp | 3 +-
.../standard-processors/processors/ListenTCP.h | 10 +-
.../standard-processors/processors/ListenUDP.h | 8 +-
.../processors/LogAttribute.cpp | 14 +-
.../standard-processors/processors/LogAttribute.h | 16 +-
.../processors/NetworkListenerProcessor.cpp | 11 +-
.../processors/NetworkListenerProcessor.h | 4 +-
.../standard-processors/processors/PutFile.cpp | 11 +-
.../standard-processors/processors/PutFile.h | 6 +-
.../standard-processors/processors/PutTCP.cpp | 39 +--
extensions/standard-processors/processors/PutTCP.h | 12 +-
.../standard-processors/processors/PutUDP.cpp | 4 +-
extensions/standard-processors/processors/PutUDP.h | 2 +
.../standard-processors/processors/ReplaceText.cpp | 14 +-
.../processors/RetryFlowFile.cpp | 35 +-
.../standard-processors/processors/RetryFlowFile.h | 13 +-
.../processors/RouteOnAttribute.cpp | 13 +-
.../processors/RouteOnAttribute.h | 5 +-
.../standard-processors/processors/RouteText.cpp | 125 ++++---
.../standard-processors/processors/RouteText.h | 11 +-
.../processors/SegmentContent.cpp | 19 +-
.../processors/SplitContent.cpp | 4 +-
.../standard-processors/processors/SplitContent.h | 6 +-
.../standard-processors/processors/SplitRecord.cpp | 21 +-
.../standard-processors/processors/SplitText.cpp | 13 +-
.../standard-processors/processors/SplitText.h | 10 +-
.../standard-processors/processors/TailFile.cpp | 28 +-
.../standard-processors/processors/TailFile.h | 8 +-
.../processors/UpdateAttribute.cpp | 20 +-
.../processors/UpdateAttribute.h | 4 -
.../tests/integration/InvokeHTTPTests.cpp | 125 +++++--
.../tests/integration/TailFileIntegrationTest.cpp | 4 +-
.../tests/integration/VerifyInvokeHTTP.h | 4 +-
.../tests/unit/AttributeRollingWindowTests.cpp | 4 +-
.../tests/unit/AttributesToJSONTests.cpp | 3 +-
.../tests/unit/ExtractTextTests.cpp | 1 -
.../tests/unit/FetchFileTests.cpp | 54 +--
.../tests/unit/FlowJsonTests.cpp | 198 ++++++-----
.../tests/unit/GenerateFlowFileTests.cpp | 44 +--
.../tests/unit/GetFileTests.cpp | 10 +-
.../standard-processors/tests/unit/GetTCPTests.cpp | 30 +-
.../tests/unit/HashContentTest.cpp | 3 +-
.../tests/unit/JoltTransformJSONTests.cpp | 28 +-
.../tests/unit/JsonRecordTests.cpp | 4 +-
.../tests/unit/ListFileTests.cpp | 8 +-
.../tests/unit/ListenSyslogTests.cpp | 58 ++--
.../tests/unit/ListenTcpTests.cpp | 32 +-
.../tests/unit/ListenUDPTests.cpp | 14 +-
.../tests/unit/LogAttributeTests.cpp | 12 +-
.../tests/unit/ManifestTests.cpp | 2 -
.../tests/unit/ProcessorTests.cpp | 36 +-
.../tests/unit/PutFileTests.cpp | 1 -
.../standard-processors/tests/unit/PutTCPTests.cpp | 12 +-
.../standard-processors/tests/unit/PutUDPTests.cpp | 4 +-
.../tests/unit/RouteTextTests.cpp | 78 ++---
.../tests/unit/SegmentContentTests.cpp | 24 +-
.../tests/unit/SplitContentTests.cpp | 158 ++++-----
.../tests/unit/SplitRecordTests.cpp | 16 +-
.../tests/unit/SplitTextTests.cpp | 54 +--
.../tests/unit/TailFileTests.cpp | 21 +-
.../tests/unit/YamlConfigurationTests.cpp | 112 ++++---
.../tests/unit/YamlConnectionParserTest.cpp | 2 +-
extensions/systemd/ConsumeJournald.cpp | 28 +-
extensions/systemd/ConsumeJournald.h | 10 +-
extensions/systemd/tests/ConsumeJournaldTest.cpp | 31 +-
extensions/test-processors/KamikazeProcessor.cpp | 15 +-
extensions/test-processors/KamikazeProcessor.h | 6 +-
.../windows-event-log/ConsumeWindowsEventLog.cpp | 22 +-
.../windows-event-log/ConsumeWindowsEventLog.h | 21 +-
extensions/windows-event-log/TailEventLog.cpp | 11 +-
.../tests/ConsumeWindowsEventLogTests.cpp | 34 +-
{examples/scripts => fips}/README.md | 15 +-
fips/openssl.cnf | 4 +-
libminifi/include/RemoteProcessorGroupPort.h | 5 +-
libminifi/include/c2/C2Agent.h | 1 -
.../controllers/NetworkPrioritizerService.h | 10 +-
libminifi/include/controllers/SSLContextService.h | 28 +-
.../controllers/UpdatePolicyControllerService.h | 10 +-
libminifi/include/core/ParameterProvider.h | 2 +-
libminifi/include/core/ProcessorNode.h | 284 ----------------
.../core/controller/ControllerServiceNode.h | 2 +-
.../core/controller/ControllerServiceProvider.h | 2 +-
.../include/core/flow/StructuredConfiguration.h | 10 +-
libminifi/include/core/json/JsonFlowSerializer.h | 4 +-
libminifi/include/core/state/nodes/MetricsBase.h | 1 -
libminifi/include/core/yaml/YamlFlowSerializer.h | 2 +-
libminifi/include/processors/ProcessorUtils.h | 2 +-
libminifi/src/Configuration.cpp | 274 +++++++--------
libminifi/src/DiskSpaceWatchdog.cpp | 13 +-
libminifi/src/FlowController.cpp | 3 -
libminifi/src/RemoteProcessorGroupPort.cpp | 25 +-
libminifi/src/RootProcessGroupWrapper.cpp | 9 +-
libminifi/src/ThreadedSchedulingAgent.cpp | 22 +-
libminifi/src/agent/JsonSchema.cpp | 45 +--
libminifi/src/c2/HeartbeatJsonSerializer.cpp | 1 +
libminifi/src/c2/protocols/RESTProtocol.cpp | 1 -
.../src/controllers/NetworkPrioritizerService.cpp | 21 +-
libminifi/src/controllers/SSLContextService.cpp | 26 +-
.../controllers/UpdatePolicyControllerService.cpp | 28 +-
libminifi/src/core/ParameterProvider.cpp | 4 +-
libminifi/src/core/ProcessSession.cpp | 60 ++--
libminifi/src/core/ProcessorNode.cpp | 39 ---
.../controller/StandardControllerServiceNode.cpp | 5 +-
.../src/core/flow/StructuredConfiguration.cpp | 232 ++++++-------
.../src/core/flow/StructuredConnectionParser.cpp | 27 +-
libminifi/src/core/json/JsonFlowSerializer.cpp | 6 +-
.../src/core/repository/VolatileRepositoryData.cpp | 12 +-
.../src/core/state/nodes/AgentInformation.cpp | 8 +-
.../src/core/state/nodes/AssetInformation.cpp | 1 +
.../src/core/state/nodes/BuildInformation.cpp | 1 +
.../core/state/nodes/ConfigurationChecksums.cpp | 1 +
.../src/core/state/nodes/DeviceInformation.cpp | 1 +
libminifi/src/core/state/nodes/FlowInformation.cpp | 1 +
libminifi/src/core/state/nodes/QueueMetrics.cpp | 1 +
libminifi/src/core/state/nodes/SchedulingNodes.cpp | 1 +
.../src/core/state/nodes/SupportedOperations.cpp | 2 +-
libminifi/src/core/yaml/YamlFlowSerializer.cpp | 8 +-
.../EnvironmentVariableParameterProvider.cpp | 8 +-
libminifi/src/properties/Properties.cpp | 46 +--
.../src/utils/ParsingErrors.cpp | 15 +-
.../src/utils/PropertyErrors.cpp | 15 +-
libminifi/test/flow-tests/CustomProcessors.h | 31 +-
libminifi/test/flow-tests/SessionTests.cpp | 4 +-
.../integration/C2ClearCoreComponentStateTest.cpp | 2 +-
.../C2DescribeCoreComponentStateTest.cpp | 2 +-
libminifi/test/integration/C2NullConfiguration.cpp | 3 +-
libminifi/test/integration/C2PauseResumeTest.cpp | 3 +-
.../test/integration/C2VerifyServeResults.cpp | 3 +-
libminifi/test/integration/HTTPSiteToSiteTests.cpp | 2 +-
libminifi/test/integration/SiteToSiteRestTest.cpp | 2 +-
.../integration/TimeoutHTTPSiteToSiteTests.cpp | 2 +-
.../test/libtest/integration/HTTPHandlers.cpp | 4 +-
libminifi/test/libtest/unit/MockClasses.h | 8 +-
libminifi/test/libtest/unit/TestBase.cpp | 15 +-
libminifi/test/libtest/unit/TestBase.h | 2 -
libminifi/test/libtest/unit/TestUtils.h | 10 +-
.../test/persistence-tests/PersistenceTests.cpp | 23 +-
libminifi/test/unit/AbstractProcessorTest.cpp | 4 +-
libminifi/test/unit/ComponentManifestTests.cpp | 2 +-
libminifi/test/unit/DynamicPropertyTests.cpp | 36 +-
.../EnvironmentVariableParameterProviderTest.cpp | 24 +-
libminifi/test/unit/ExpectedTest.cpp | 44 ++-
libminifi/test/unit/JsonFlowSerializerTests.cpp | 8 +-
libminifi/test/unit/NetUtilsTest.cpp | 42 +--
.../test/unit/NetworkPrioritizerServiceTests.cpp | 52 +--
libminifi/test/unit/OptionalTest.cpp | 25 ++
libminifi/test/unit/ParsingUtilsTests.cpp | 85 +++++
libminifi/test/unit/ProcessorConfigUtilsTests.cpp | 13 +-
libminifi/test/unit/PropertyTests.cpp | 129 -------
libminifi/test/unit/PropertyValidationTests.cpp | 306 +++++------------
libminifi/test/unit/ResponseNodeValueTests.cpp | 191 -----------
libminifi/test/unit/SchedulingAgentTests.cpp | 4 +-
libminifi/test/unit/StringUtilsTests.cpp | 6 +-
libminifi/test/unit/TimeUtilTests.cpp | 1 +
libminifi/test/unit/UpdatePolicyTests.cpp | 14 +-
libminifi/test/unit/YamlFlowSerializerTests.cpp | 8 +-
.../include/minifi-cpp/core/CachedValueValidator.h | 82 -----
.../minifi-cpp/core/ConfigurableComponent.h | 72 ++--
.../include/minifi-cpp/core/ProcessContext.h | 49 ++-
.../minifi-cpp/core/ProcessContextBuilder.h | 4 +-
minifi-api/include/minifi-cpp/core/Processor.h | 3 +
minifi-api/include/minifi-cpp/core/Property.h | 162 ++-------
.../include/minifi-cpp/core/PropertyDefinition.h | 53 ++-
minifi-api/include/minifi-cpp/core/PropertyType.h | 54 ---
.../include/minifi-cpp/core/PropertyValidator.h | 137 ++++++++
minifi-api/include/minifi-cpp/core/PropertyValue.h | 139 --------
.../{PropertyErrors.h => PropertyExceptions.h} | 18 +-
minifi_main/AgentDocs.cpp | 7 +-
minifi_main/CMakeLists.txt | 1 -
minifi_main/Fips.cpp | 41 ++-
thirdparty/aws-sdk-cpp/fix-finding-s2n.patch | 26 ++
thirdparty/librdkafka/0002-undef-X509_NAME.patch | 11 +
utils/include/core/ConfigurableComponent.h | 285 ----------------
utils/include/core/ConfigurableComponentImpl.h | 65 ++++
utils/include/core/ProcessContext.h | 266 +++++----------
utils/include/core/ProcessContextBuilder.h | 2 +-
utils/include/core/Processor.h | 10 +-
utils/include/core/Property.h | 5 -
utils/include/core/PropertyDefinitionBuilder.h | 8 +-
utils/include/core/PropertyType.h | 372 ---------------------
utils/include/core/PropertyValue.h | 160 ---------
utils/include/core/TypedValues.h | 2 +-
utils/include/core/controller/ControllerService.h | 2 +-
utils/include/http/HTTPClient.h | 1 +
utils/include/utils/AutoPersistor.h | 2 +-
utils/include/utils/Error.h | 12 +
utils/include/utils/OptionalUtils.h | 36 +-
.../include/utils/ParsingErrors.h | 46 +--
utils/include/utils/ParsingUtils.h | 94 ++++++
utils/include/utils/PropertyErrors.h | 40 ++-
.../include/utils/PropertyExceptions.h | 4 +-
utils/include/utils/StringUtils.h | 33 +-
utils/include/utils/ThreadPool.h | 1 +
utils/include/utils/TimeUtil.h | 2 +-
utils/include/utils/ValueParser.h | 2 +-
.../utils/detail/MonadicOperationWrappers.h | 42 +++
utils/include/utils/expected.h | 35 +-
utils/src/core/CachedValueValidator.cpp | 41 ---
utils/src/core/ConfigurableComponent.cpp | 360 --------------------
utils/src/core/ConfigurableComponentImpl.cpp | 150 +++++++++
utils/src/core/ProcessContextBuilder.cpp | 2 +-
utils/src/core/ProcessorMetrics.cpp | 1 +
utils/src/core/Property.cpp | 122 +++----
utils/src/core/PropertyType.cpp | 84 -----
utils/src/http/HTTPClient.cpp | 6 +
utils/src/utils/AutoPersistor.cpp | 1 -
utils/src/utils/Error.cpp | 8 +
utils/src/utils/ParsingUtils.cpp | 129 +++++++
utils/src/utils/StringUtils.cpp | 4 +-
440 files changed, 5352 insertions(+), 7586 deletions(-)
delete mode 100644 docker/python-verify/conda.Dockerfile
delete mode 100644 docker/python-verify/conda.dockerignore
delete mode 100644 docker/python-verify/venv.Dockerfile
delete mode 100644 docker/python-verify/venv.dockerignore
delete mode 100644 extension-utils/src/utils/ProcessorConfigUtils.cpp
copy {examples/scripts => fips}/README.md (53%)
delete mode 100644 libminifi/include/core/ProcessorNode.h
delete mode 100644 libminifi/src/core/ProcessorNode.cpp
copy extension-utils/include/controllers/RecordSetReader.h =>
libminifi/src/utils/ParsingErrors.cpp (75%)
copy extension-utils/include/controllers/RecordSetReader.h =>
libminifi/src/utils/PropertyErrors.cpp (75%)
create mode 100644 libminifi/test/unit/ParsingUtilsTests.cpp
delete mode 100644 libminifi/test/unit/PropertyTests.cpp
delete mode 100644 libminifi/test/unit/ResponseNodeValueTests.cpp
delete mode 100644 minifi-api/include/minifi-cpp/core/CachedValueValidator.h
delete mode 100644 minifi-api/include/minifi-cpp/core/PropertyType.h
create mode 100644 minifi-api/include/minifi-cpp/core/PropertyValidator.h
delete mode 100644 minifi-api/include/minifi-cpp/core/PropertyValue.h
rename minifi-api/include/minifi-cpp/utils/{PropertyErrors.h =>
PropertyExceptions.h} (88%)
create mode 100644 thirdparty/aws-sdk-cpp/fix-finding-s2n.patch
create mode 100644 thirdparty/librdkafka/0002-undef-X509_NAME.patch
delete mode 100644 utils/include/core/ConfigurableComponent.h
create mode 100644 utils/include/core/ConfigurableComponentImpl.h
delete mode 100644 utils/include/core/PropertyType.h
delete mode 100644 utils/include/core/PropertyValue.h
rename minifi-api/include/minifi-cpp/core/ProcessorNode.h =>
utils/include/utils/ParsingErrors.h (52%)
create mode 100644 utils/include/utils/ParsingUtils.h
copy extension-utils/include/FlowFileRecord.h =>
utils/include/utils/PropertyExceptions.h (94%)
delete mode 100644 utils/src/core/CachedValueValidator.cpp
delete mode 100644 utils/src/core/ConfigurableComponent.cpp
create mode 100644 utils/src/core/ConfigurableComponentImpl.cpp
delete mode 100644 utils/src/core/PropertyType.cpp
create mode 100644 utils/src/utils/ParsingUtils.cpp
