This is an automated email from the ASF dual-hosted git repository.
lordgamez pushed a change to branch MINIFICPP-2376
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git
omit a29feb9c5 MINIFICPP-2376 Add support for parameter context inheritance
add bd1182eb8 MINIFICPP-2467 PutCouchbaseKey processor and controller
add ea16935f9 MINIFICPP-2469 Create GetCouchbaseKey processor
add 3885493eb MINIFICPP-2470 Add SSL and mTLS authentication support to
CouchbaseClusterService
add d6dcc24ed MINIFICPP-2479 Update librdkafka and add lz4, zstd support
add 80e9533f2 MINIFICPP-2495 change default logging settings
add 24cfd6575 MINFICPP-2243 ListenHTTP: process requests in onTrigger
add 1e18ec4a1 MINIFICPP-2496 fix: Remove debug symbols from Couchbase
extension lib
add 25882c125 MINIFICPP-2497 Remove alpine-conf package from docker image
add ef27b60bd MINIFICPP-2500 Log runtime as human readable duration
add 212b1458c MINIFICPP-2505 SchedulingAgent::scheduled_processors_ isnt
thread safe
add 5c5fc8946 MINIFICPP-2504 MergeContent should be single threaded
add b194ce55d MINIFICPP-2506 Fix a gcc warning
add 4054419f3 MINIFICPP-2485 fix: Support Expression Language in
InvokeHTTP "Remote URL" property
add a469556a4 MINIFICPP-2503 Remove C2 metric duplication in heartbeat
add 634016bbe MINIFICPP-2499 Do not log errors when loading Python helper
files
add 07b9641ff MINIFICPP-2501 Add processorStatuses C2 metric node to
FlowInformation
add 43da4fc9f MINIFICPP-2511 Fix python processor tests
add 53d8027d7 MINIFICPP-2515 Upgrade libcurl to 8.11.1 (from 8.4.0)
add 29c7255a6 MINIFICPP-2514 Fix Python libloader
add 78d53ed15 MINIFICPP-2516 Change C2 runStatus value format to be
consistent with NiFi
add a2f8851c0 MINIFICPP-2462 Divide libminifi
add 2db0b56cc MINIFICPP-2376 Add support for parameter context inheritance
add 681f23ec3 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 (a29feb9c5)
\
N -- N -- N refs/heads/MINIFICPP-2376 (681f23ec3)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.clang-format | 10 +-
.github/workflows/ci.yml | 18 +-
.github/workflows/verify-package.yml | 128 +++--
C2.md | 400 ++++++++++++++-
CMakeLists.txt | 5 +-
CONFIGURE.md | 2 +
CONTROLLERS.md | 18 +
LICENSE | 154 +++++-
METRICS.md | 34 +-
NOTICE | 3 +
PROCESSORS.md | 84 +++-
README.md | 5 +-
Windows.md | 2 +-
bootstrap.sh | 4 +-
bstrp_functions.sh | 2 +
cmake/Asio.cmake | 2 +-
cmake/BundledLibRdKafka.cmake | 72 ---
cmake/BundledLibcURL.cmake | 5 +-
cmake/BundledRocksDB.cmake | 3 -
cmake/Bustache.cmake | 7 +
cmake/Couchbase.cmake | 47 ++
cmake/DockerConfig.cmake | 3 +-
cmake/Fetchlibrdkafka.cmake | 50 ++
cmake/LZ4.cmake | 22 +-
cmake/MiNiFiOptions.cmake | 3 +-
cmake/Spdlog.cmake | 4 +-
cmake/VerifyPackageWithDocker.cmake | 14 +-
cmake/Zstd.cmake | 8 +-
cmake/fmt.cmake | 4 +-
cmake/zstd/dummy/Findzstd.cmake | 1 +
conf/minifi-log.properties | 4 +-
controller/MiNiFiController.cpp | 6 +-
controller/tests/ControllerTests.cpp | 19 +-
docker/Dockerfile | 5 +-
docker/requirements.txt | 7 +-
docker/test/integration/cluster/ContainerStore.py | 13 +
.../test/integration/cluster/DockerTestCluster.py | 12 +-
.../cluster/DockerTestDirectoryBindings.py | 10 +-
docker/test/integration/cluster/ImageStore.py | 6 +-
.../cluster/checkers/CouchbaseChecker.py | 69 +++
.../cluster/checkers/PrometheusChecker.py | 11 +-
.../integration/cluster/containers/Container.py | 4 +
.../cluster/containers/CouchbaseServerContainer.py | 125 +++++
.../features/MiNiFi_integration_test_driver.py | 24 +-
docker/test/integration/features/couchbase.feature | 232 +++++++++
.../integration/features/fetch_modbus_tcp.feature | 1 +
.../features/google_cloud_storage.feature | 1 +
docker/test/integration/features/kafka.feature | 259 +++++-----
docker/test/integration/features/steps/steps.py | 56 ++-
...rollerService.py => CouchbaseClusterService.py} | 18 +-
.../integration/minifi/core/ControllerService.py | 1 +
.../Minifi_flow_json_serializer.py | 13 +-
.../Minifi_flow_yaml_serializer.py | 38 +-
.../{LogAttribute.py => GetCouchbaseKey.py} | 10 +-
.../{LogAttribute.py => PutCouchbaseKey.py} | 10 +-
encrypt-config/CMakeLists.txt | 2 +-
encrypt-config/FlowConfigEncryptor.cpp | 4 +-
encrypt-config/tests/CMakeLists.txt | 2 +-
examples/couchbase_mtls_authentication.json | 74 +++
examples/couchbase_mtls_authentication.yml | 45 ++
extension-utils/CMakeLists.txt | 35 ++
.../include/FlowFileRecord.h | 6 +-
.../include/ResourceClaim.h | 6 +-
.../include/controllers/AttributeProviderService.h | 10 +-
.../include/controllers/RecordSetReader.h | 10 +-
.../include/controllers/RecordSetWriter.h | 11 +-
.../include/controllers/SSLContextService.h | 6 +-
.../controllers/keyvalue/KeyValueStateManager.h | 3 +-
.../controllers/keyvalue/KeyValueStateStorage.h | 9 +-
.../include/core/AbstractProcessor.h | 8 +-
.../include/core/FlowFile.h | 7 +-
.../include/core/FlowFileStore.h | 0
.../include/core/ProcessSession.h | 9 +-
.../include/core/StateManager.h | 26 +-
.../include/core/StateStorage.h | 14 +-
.../include/properties/Configure.h | 6 +-
.../include/properties/Properties.h | 6 +-
.../include/serialization/FlowFileSerializer.h | 2 +-
.../include/serialization/FlowFileV3Serializer.h | 0
.../include/serialization/PayloadSerializer.h | 0
.../include/utils/ListingStateManager.h | 3 -
.../include/utils/OpenTelemetryLogDataModelUtils.h | 2 +-
.../include/utils/ProcessorConfigUtils.h | 0
.../include/utils/ResourceQueue.h | 10 +-
.../include/utils/file/FileManager.h | 0
.../include/utils/file/FileReaderCallback.h | 0
.../include/utils/file/FileWriterCallback.h | 2 +-
.../include/utils/file/ListedFile.h | 1 +
.../include/utils/net/ConnectionHandler.h | 4 +-
.../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 | 2 +-
.../controllers/keyvalue/KeyValueStateManager.cpp | 2 +-
.../controllers/keyvalue/KeyValueStateStorage.cpp | 2 +-
.../src/core/ProcessContext.cpp | 24 +-
.../src/serialization/FlowFileV3Serializer.cpp | 3 +-
.../src/serialization/PayloadSerializer.cpp | 12 +-
.../src/utils/CallBackTimer.cpp | 12 +-
.../src/utils/ListingStateManager.cpp | 4 +-
.../src/utils/ProcessorConfigUtils.cpp | 0
.../src/utils/file/FileReaderCallback.cpp | 2 +-
.../src/utils/file/FileWriterCallback.cpp | 0
.../src/utils/net/Ssl.cpp | 0
.../src/utils/net/TcpServer.cpp | 0
.../src/utils/net/UdpServer.cpp | 0
extensions/ExtensionHeader.txt | 8 -
extensions/aws/AWSCredentialsProvider.cpp | 26 +-
extensions/aws/AWSCredentialsProvider.h | 8 +-
.../aws/controllerservices/AWSCredentialsService.h | 8 +-
extensions/aws/processors/S3Processor.cpp | 4 +-
extensions/aws/processors/S3Processor.h | 5 +-
extensions/aws/s3/MultipartUploadStateStorage.cpp | 1 +
extensions/aws/s3/MultipartUploadStateStorage.h | 2 +-
extensions/aws/s3/S3RequestSender.h | 2 +-
extensions/aws/s3/S3Wrapper.h | 5 +-
extensions/aws/tests/AWSCredentialsServiceTest.cpp | 4 +-
extensions/aws/utils/AWSSdkLogger.cpp | 1 +
extensions/aws/utils/AWSSdkLogger.h | 2 +-
.../AzureStorageCredentialsService.h | 8 +-
.../AzureBlobStorageSingleBlobProcessorBase.h | 2 +-
.../processors/AzureDataLakeStorageProcessorBase.h | 2 +-
.../azure/processors/AzureStorageProcessorBase.h | 6 +-
.../azure/processors/DeleteAzureBlobStorage.h | 2 +-
.../azure/processors/FetchAzureBlobStorage.h | 4 +-
extensions/azure/processors/ListAzureBlobStorage.h | 2 +-
extensions/azure/processors/PutAzureBlobStorage.h | 8 +-
extensions/azure/storage/AzureBlobStorage.h | 3 +-
.../azure/storage/AzureBlobStorageClient.cpp | 4 +-
extensions/azure/storage/AzureBlobStorageClient.h | 2 +-
extensions/azure/storage/AzureDataLakeStorage.h | 3 +-
.../azure/storage/AzureDataLakeStorageClient.h | 4 +-
extensions/azure/utils/AzureSdkLogger.h | 2 +-
extensions/bustache/ApplyTemplate.h | 8 +-
extensions/civetweb/processors/ListenHTTP.cpp | 244 ++++++---
extensions/civetweb/processors/ListenHTTP.h | 83 +++-
extensions/civetweb/tests/ListenHTTPTests.cpp | 104 ++--
.../{elasticsearch => couchbase}/CMakeLists.txt | 14 +-
.../controllerservices/CouchbaseClusterService.cpp | 266 ++++++++++
.../controllerservices/CouchbaseClusterService.h | 177 +++++++
.../couchbase/processors/GetCouchbaseKey.cpp | 111 +++++
extensions/couchbase/processors/GetCouchbaseKey.h | 113 +++++
.../couchbase/processors/PutCouchbaseKey.cpp | 86 ++++
extensions/couchbase/processors/PutCouchbaseKey.h | 161 ++++++
extensions/{aws => couchbase}/tests/CMakeLists.txt | 23 +-
.../couchbase/tests/GetCouchbaseKeyTests.cpp | 171 +++++++
.../couchbase/tests/MockCouchbaseClusterService.h | 114 +++++
.../couchbase/tests/PutCouchbaseKeyTests.cpp | 173 +++++++
.../ElasticsearchCredentialsControllerService.h | 4 +-
extensions/elasticsearch/PostElasticsearch.h | 4 +-
extensions/elasticsearch/tests/MockElastic.h | 2 +-
.../elasticsearch/tests/PostElasticsearchTests.cpp | 1 +
extensions/execute-process/ExecuteProcess.cpp | 10 +-
extensions/execute-process/ExecuteProcess.h | 6 +-
extensions/expression-language/Expression.cpp | 2 +
.../ExpressionContextBuilder.cpp | 4 +-
.../expression-language/ExpressionContextBuilder.h | 4 +-
.../expression-language/ProcessContextExpr.cpp | 16 +-
.../expression-language/ProcessContextExpr.h | 14 +-
.../impl/expression/Expression.h | 2 +-
.../tests/ExpressionLanguageTests.cpp | 348 ++++++-------
.../tests/ProcessContextExprTests.cpp | 12 +-
.../GCPCredentialsControllerService.h | 6 +-
extensions/gcp/processors/DeleteGCSObject.h | 2 +-
extensions/gcp/processors/FetchGCSObject.h | 7 +-
extensions/gcp/processors/GCSProcessor.h | 4 +-
extensions/gcp/processors/ListGCSBucket.h | 2 +-
extensions/gcp/processors/PutGCSObject.h | 9 +-
extensions/grafana-loki/PushGrafanaLoki.cpp | 2 +-
extensions/grafana-loki/PushGrafanaLoki.h | 6 +-
extensions/grafana-loki/PushGrafanaLokiGrpc.h | 9 +-
.../grafana-loki/tests/MockGrafanaLokiREST.h | 2 +-
extensions/{librdkafka => kafka}/CMakeLists.txt | 16 +-
extensions/{librdkafka => kafka}/ConsumeKafka.cpp | 193 ++++----
extensions/kafka/ConsumeKafka.h | 313 ++++++++++++
.../{librdkafka => kafka}/KafkaConnection.cpp | 35 +-
extensions/{librdkafka => kafka}/KafkaConnection.h | 20 +-
.../{librdkafka => kafka}/KafkaProcessorBase.cpp | 28 +-
extensions/kafka/KafkaProcessorBase.h | 110 +++++
.../KafkaTopic.h} | 23 +-
extensions/{librdkafka => kafka}/PublishKafka.cpp | 550 +++++++++++----------
extensions/kafka/PublishKafka.h | 288 +++++++++++
extensions/{librdkafka => kafka}/rdkafka_utils.cpp | 46 +-
extensions/{librdkafka => kafka}/rdkafka_utils.h | 78 ++-
.../{librdkafka => kafka}/tests/CMakeLists.txt | 6 +-
.../tests/PublishKafkaTests.cpp | 34 ++
.../KubernetesControllerService.cpp | 10 +-
.../KubernetesControllerService.h | 6 +-
.../processors/CollectKubernetesPodMetrics.h | 8 +-
extensions/libarchive/ArchiveStreamProvider.cpp | 6 +-
extensions/libarchive/BinFiles.cpp | 2 +-
extensions/libarchive/BinFiles.h | 6 +-
extensions/libarchive/CompressContent.h | 8 +-
extensions/libarchive/FocusArchiveEntry.h | 6 +-
extensions/libarchive/ManipulateArchive.h | 4 +-
extensions/libarchive/MergeContent.cpp | 2 +-
extensions/libarchive/MergeContent.h | 7 +-
extensions/libarchive/ReadArchiveStream.h | 5 +-
extensions/libarchive/UnfocusArchiveEntry.h | 6 +-
extensions/libarchive/WriteArchiveStream.h | 6 +-
.../libarchive/tests/CompressContentTests.cpp | 22 +-
extensions/libarchive/tests/MergeFileTests.cpp | 84 ++--
extensions/librdkafka/ConsumeKafka.h | 273 ----------
extensions/librdkafka/KafkaProcessorBase.h | 107 ----
extensions/librdkafka/KafkaTopic.h | 57 ---
extensions/librdkafka/PublishKafka.h | 253 ----------
extensions/lua/LuaScriptExecutor.cpp | 2 +-
extensions/lua/LuaScriptProcessContext.h | 1 +
extensions/mqtt/processors/AbstractMQTTProcessor.h | 8 +-
extensions/mqtt/processors/ConsumeMQTT.h | 2 +-
extensions/mqtt/processors/PublishMQTT.cpp | 6 +-
extensions/mqtt/processors/PublishMQTT.h | 12 +-
extensions/opc/include/fetchopc.h | 2 +-
extensions/opc/include/opc.h | 2 +-
extensions/opc/include/opcbase.h | 6 +-
extensions/opc/include/putopc.h | 2 +-
extensions/opc/src/fetchopc.cpp | 1 +
extensions/opc/src/opc.cpp | 4 +-
extensions/opc/src/putopc.cpp | 1 +
extensions/opencv/CaptureRTSPFrame.h | 9 +-
extensions/opencv/MotionDetector.h | 8 +-
extensions/pdh/PerformanceDataMonitor.h | 8 +-
extensions/procfs/ProcFs.h | 2 +-
extensions/procfs/processors/ProcFsMonitor.h | 8 +-
extensions/procfs/tests/MemInfoTests.cpp | 2 +-
extensions/prometheus/PrometheusExposerWrapper.h | 2 +-
.../prometheus/PrometheusMetricsPublisher.cpp | 9 +-
extensions/prometheus/PrometheusMetricsPublisher.h | 4 +-
.../prometheus/PublishedMetricGaugeCollection.cpp | 2 +-
.../prometheus/PublishedMetricGaugeCollection.h | 3 +-
.../tests/PrometheusMetricsPublisherTest.cpp | 4 +-
extensions/python/ExecutePythonProcessor.cpp | 6 +-
extensions/python/ExecutePythonProcessor.h | 4 +-
extensions/python/PythonCreator.h | 18 +-
extensions/python/PythonDependencyInstaller.cpp | 1 +
extensions/python/PythonDependencyInstaller.h | 2 +-
extensions/python/PythonScriptEngine.cpp | 2 +-
extensions/python/PythonScriptEngine.h | 6 +-
extensions/python/PythonScriptException.h | 7 +
extensions/python/PythonScriptExecutor.cpp | 2 +-
.../python/pythonlibloader/PythonLibLoader.cpp | 7 +-
extensions/python/tests/PythonManifestTests.cpp | 8 +-
extensions/python/types/BaseTypes.h | 3 +
extensions/python/types/PyRecordSetWriter.cpp | 2 +-
extensions/python/types/Types.h | 3 -
extensions/rocksdb-repos/CMakeLists.txt | 5 +-
.../rocksdb-repos/DatabaseContentRepository.cpp | 4 +-
.../rocksdb-repos/DatabaseContentRepository.h | 6 +-
extensions/rocksdb-repos/FlowFileLoader.cpp | 4 +-
extensions/rocksdb-repos/FlowFileLoader.h | 3 +-
extensions/rocksdb-repos/FlowFileRepository.cpp | 9 +-
extensions/rocksdb-repos/FlowFileRepository.h | 8 +-
extensions/rocksdb-repos/ProvenanceRepository.cpp | 2 +-
extensions/rocksdb-repos/ProvenanceRepository.h | 6 +-
extensions/rocksdb-repos/RocksDbRepository.cpp | 1 +
extensions/rocksdb-repos/RocksDbRepository.h | 4 +-
extensions/rocksdb-repos/RocksDbStream.cpp | 2 +-
extensions/rocksdb-repos/RocksDbStream.h | 4 +-
.../controllers/RocksDbStateStorage.cpp | 2 +-
.../controllers/RocksDbStateStorage.h | 4 +-
extensions/rocksdb-repos/database/ColumnHandle.cpp | 2 +-
extensions/rocksdb-repos/database/DbHandle.cpp | 2 +-
extensions/rocksdb-repos/database/OpenRocksDb.h | 2 +-
.../rocksdb-repos/database/RocksDatabase.cpp | 2 +-
extensions/rocksdb-repos/database/RocksDatabase.h | 2 +-
.../rocksdb-repos/database/RocksDbInstance.cpp | 2 +-
.../rocksdb-repos/database/RocksDbInstance.h | 2 +-
extensions/rocksdb-repos/database/RocksDbUtils.cpp | 4 +-
.../encryption/RocksDbEncryptionProvider.cpp | 2 +-
.../encryption/RocksDbEncryptionProvider.h | 2 +-
.../rocksdb-repos/tests/ContentSessionTests.cpp | 4 +-
.../tests/DBContentRepositoryTests.cpp | 42 +-
.../tests/DBProvenanceRepositoryTests.cpp | 4 +-
extensions/rocksdb-repos/tests/EncryptionTests.cpp | 6 +-
extensions/rocksdb-repos/tests/ProvenanceTests.cpp | 26 +-
extensions/rocksdb-repos/tests/RepoTests.cpp | 82 +--
.../rocksdb-repos/tests/RocksDBUtilsTests.cpp | 2 +-
extensions/rocksdb-repos/tests/SwapTests.cpp | 18 +-
extensions/script/ExecuteScript.h | 6 +-
extensions/script/ScriptExecutor.h | 10 +-
extensions/sftp/client/SFTPClient.cpp | 2 +
extensions/sftp/client/SFTPClient.h | 15 +-
extensions/sftp/processors/FetchSFTP.h | 2 +-
extensions/sftp/processors/PutSFTP.h | 2 +-
extensions/sftp/processors/SFTPProcessorBase.cpp | 4 +-
extensions/sftp/processors/SFTPProcessorBase.h | 2 +-
extensions/sftp/tests/ListSFTPTests.cpp | 10 +-
extensions/sftp/tests/tools/SFTPTestServer.h | 2 +-
extensions/smb/FetchSmb.h | 8 +-
extensions/smb/ListSmb.h | 8 +-
extensions/smb/PutSmb.cpp | 1 +
extensions/smb/PutSmb.h | 8 +-
extensions/smb/SmbConnectionControllerService.h | 11 +-
extensions/smb/tests/FetchSmbTests.cpp | 2 +-
extensions/splunk/SplunkHECProcessor.h | 4 +-
extensions/splunk/tests/MockSplunkHEC.h | 2 +-
extensions/sql/data/SociConnectors.cpp | 2 +-
extensions/sql/data/SociConnectors.h | 2 +-
extensions/sql/processors/FlowFileSource.h | 2 +-
extensions/sql/processors/SQLProcessor.h | 4 +-
extensions/sql/services/DatabaseService.cpp | 4 +-
extensions/sql/services/DatabaseService.h | 18 +-
extensions/sql/services/ODBCConnector.h | 16 +-
extensions/sql/tests/SQLTestPlan.h | 4 +-
.../controllers/JsonRecordSetReader.h | 5 +-
.../controllers/JsonRecordSetWriter.h | 7 +-
.../controllers/PersistentMapStateStorage.cpp | 2 +-
.../controllers/PersistentMapStateStorage.h | 4 +-
.../controllers/VolatileMapStateStorage.cpp | 2 +-
.../controllers/VolatileMapStateStorage.h | 2 +-
.../standard-processors/modbus/FetchModbusTcp.cpp | 1 +
.../standard-processors/modbus/FetchModbusTcp.h | 6 +-
.../modbus/ReadModbusFunctions.h | 2 +-
.../processors/AppendHostInfo.cpp | 2 +-
.../processors/AppendHostInfo.h | 7 +-
.../processors/AttributeRollingWindow.h | 2 +-
.../processors/AttributesToJSON.h | 6 +-
.../processors/DefragmentText.cpp | 2 +-
.../processors/DefragmentText.h | 6 +-
.../standard-processors/processors/ExtractText.h | 5 +-
.../standard-processors/processors/FetchFile.h | 6 +-
.../processors/GenerateFlowFile.h | 5 +-
.../standard-processors/processors/GetFile.cpp | 3 +-
.../standard-processors/processors/GetFile.h | 18 +-
.../standard-processors/processors/GetTCP.cpp | 1 -
extensions/standard-processors/processors/GetTCP.h | 10 +-
.../standard-processors/processors/HashContent.h | 5 +-
.../standard-processors/processors/InvokeHTTP.cpp | 68 ++-
.../standard-processors/processors/InvokeHTTP.h | 84 +++-
.../processors/JoltTransformJSON.h | 4 +-
.../standard-processors/processors/ListFile.h | 6 +-
.../standard-processors/processors/ListenSyslog.h | 3 +-
.../standard-processors/processors/ListenTCP.h | 3 +-
.../standard-processors/processors/ListenUDP.h | 4 +-
.../standard-processors/processors/LogAttribute.h | 7 +-
.../processors/NetworkListenerProcessor.h | 4 +-
.../standard-processors/processors/PutFile.h | 7 +-
.../standard-processors/processors/PutTCP.cpp | 2 +-
extensions/standard-processors/processors/PutTCP.h | 4 +-
.../standard-processors/processors/PutUDP.cpp | 4 +-
extensions/standard-processors/processors/PutUDP.h | 4 +-
.../standard-processors/processors/ReplaceText.cpp | 4 +-
.../standard-processors/processors/ReplaceText.h | 3 +-
.../standard-processors/processors/RetryFlowFile.h | 8 +-
.../processors/RouteOnAttribute.h | 7 +-
.../standard-processors/processors/RouteText.cpp | 4 +-
.../standard-processors/processors/RouteText.h | 2 +-
.../processors/SegmentContent.h | 4 +-
.../standard-processors/processors/SplitContent.h | 4 +-
.../standard-processors/processors/SplitRecord.h | 2 +-
.../standard-processors/processors/SplitText.cpp | 1 +
.../standard-processors/processors/SplitText.h | 5 +-
.../standard-processors/processors/TailFile.cpp | 3 +-
.../standard-processors/processors/TailFile.h | 7 +-
.../processors/UpdateAttribute.h | 7 +-
.../tests/integration/InvokeHTTPTests.cpp | 285 +++--------
.../tests/integration/VerifyInvokeHTTP.h | 4 +-
.../tests/unit/ConfigurationTests.cpp | 8 +-
.../tests/unit/ControllerServiceTests.cpp | 6 +-
.../tests/unit/DefragmentTextTests.cpp | 4 +-
.../tests/unit/FlowJsonTests.cpp | 4 +-
.../standard-processors/tests/unit/GetTCPTests.cpp | 6 +-
.../tests/unit/HttpClientStoreTests.cpp | 219 ++++++++
.../tests/unit/JsonRecordTests.cpp | 2 +-
.../tests/unit/ListenSyslogTests.cpp | 6 +-
.../tests/unit/ListenTcpTests.cpp | 16 +-
.../tests/unit/ProcessorTests.cpp | 77 +--
.../standard-processors/tests/unit/PutTCPTests.cpp | 8 +-
.../tests/unit/ReplaceTextTests.cpp | 2 +-
.../tests/unit/RouteTextTests.cpp | 2 +-
.../tests/unit/TailFileTests.cpp | 6 +-
.../tests/unit/YamlConfigurationTests.cpp | 6 +-
.../tests/unit/YamlConnectionParserTest.cpp | 4 +-
.../tests/unit/YamlProcessGroupParserTests.cpp | 2 +-
extensions/standard-processors/utils/JoltUtils.h | 2 +-
extensions/systemd/CMakeLists.txt | 2 +-
extensions/systemd/ConsumeJournald.cpp | 4 +-
extensions/systemd/ConsumeJournald.h | 4 +-
extensions/test-processors/KamikazeProcessor.h | 4 +-
.../test-processors/LogOnDestructionProcessor.h | 6 +-
extensions/windows-event-log/Bookmark.h | 2 +-
.../windows-event-log/ConsumeWindowsEventLog.cpp | 4 +-
.../windows-event-log/ConsumeWindowsEventLog.h | 2 +-
extensions/windows-event-log/TailEventLog.cpp | 1 +
extensions/windows-event-log/TailEventLog.h | 6 +-
libminifi/CMakeLists.txt | 13 +-
libminifi/include/Connection.h | 71 +--
libminifi/include/FlowFileRecord.h | 17 +-
libminifi/include/ForwardingNode.h | 6 +-
libminifi/include/RemoteProcessorGroupPort.h | 7 +-
libminifi/include/ResourceClaim.h | 55 +--
libminifi/include/SchedulingAgent.h | 4 +-
libminifi/include/agent/build_description.h | 23 +-
libminifi/include/c2/C2Agent.h | 4 +-
libminifi/include/c2/C2MetricsPublisher.h | 4 +-
libminifi/include/c2/C2Payload.h | 2 +-
libminifi/include/c2/C2Protocol.h | 5 +-
libminifi/include/c2/C2Trigger.h | 4 +-
.../include/c2/ControllerSocketMetricsPublisher.h | 6 +-
libminifi/include/c2/ControllerSocketProtocol.h | 3 +-
libminifi/include/c2/HeartbeatReporter.h | 4 +-
libminifi/include/c2/PayloadParser.h | 187 -------
libminifi/include/c2/protocols/RESTProtocol.h | 1 +
libminifi/include/c2/protocols/RESTSender.h | 2 +-
libminifi/include/c2/triggers/FileUpdateTrigger.h | 6 +-
.../controllers/LinuxPowerManagementService.h | 168 -------
.../controllers/NetworkPrioritizerService.h | 16 +-
libminifi/include/controllers/SSLContextService.h | 39 +-
.../include/controllers/ThreadManagementService.h | 45 +-
.../controllers/UpdatePolicyControllerService.h | 16 +-
libminifi/include/core/ClassLoader.h | 206 --------
libminifi/include/core/Deprecated.h | 29 --
libminifi/include/core/FlowConfiguration.h | 2 +-
libminifi/include/core/FlowFile.h | 114 ++---
libminifi/include/core/ForwardingContentSession.h | 4 +-
libminifi/include/core/ParameterContext.h | 6 +-
libminifi/include/core/ProcessGroup.h | 7 +-
libminifi/include/core/ProcessSession.h | 198 +++-----
libminifi/include/core/ProcessSessionFactory.h | 40 +-
libminifi/include/core/ProcessorNode.h | 71 +--
libminifi/include/core/PropertyValue.h | 259 ----------
libminifi/include/core/RepositoryFactory.h | 2 +-
libminifi/include/core/SerializableComponent.h | 12 +-
libminifi/include/core/WeakReference.h | 47 +-
.../core/controller/ControllerServiceLookup.h | 75 +--
.../core/controller/ControllerServiceNode.h | 49 +-
.../core/controller/ControllerServiceProvider.h | 41 +-
.../ForwardingControllerServiceProvider.h | 4 +-
.../controller/StandardControllerServiceNode.h | 16 +-
.../controller/StandardControllerServiceProvider.h | 8 +-
libminifi/include/core/extension/DynamicLibrary.h | 2 +-
.../include/core/extension/ExtensionManager.h | 12 +-
libminifi/include/core/extension/Module.h | 4 +-
libminifi/include/core/logging/LoggerBase.h | 114 +++++
.../include/core/logging/LoggerConfiguration.h | 6 +-
libminifi/include/core/logging/LoggerFactory.h | 6 +-
libminifi/include/core/logging/LoggerProperties.h | 4 +-
.../include/core/repository/FileSystemRepository.h | 8 +-
.../core/repository/VolatileContentRepository.h | 6 +-
.../include/core/repository/VolatileRepository.h | 4 +-
libminifi/include/core/state/FlowIdentifier.h | 37 +-
libminifi/include/core/state/LogMetricsPublisher.h | 8 +-
.../include/core/state/MetricsPublisherFactory.h | 2 +-
.../include/core/state/MetricsPublisherStore.h | 2 +-
.../include/core/state/nodes/AgentInformation.h | 4 +-
.../include/core/state/nodes/AssetInformation.h | 4 +-
.../core/state/nodes/ConfigurationChecksums.h | 4 +-
.../include/core/state/nodes/DeviceInformation.h | 2 -
.../include/core/state/nodes/FlowInformation.h | 44 +-
libminifi/include/core/state/nodes/MetricsBase.h | 152 +-----
libminifi/include/core/state/nodes/QueueMetrics.h | 8 +-
.../include/core/state/nodes/RepositoryMetrics.h | 8 +-
.../include/core/state/nodes/ResponseNodeLoader.h | 23 +-
libminifi/include/io/AtomicEntryStream.h | 4 +-
libminifi/include/properties/Configuration.h | 178 +------
libminifi/include/properties/Configure.h | 19 +-
libminifi/include/properties/Properties.h | 48 +-
libminifi/include/provenance/Provenance.h | 243 +++------
libminifi/include/sitetosite/HTTPProtocol.h | 3 +-
libminifi/include/sitetosite/Peer.h | 2 +-
libminifi/include/sitetosite/RawSocketProtocol.h | 2 -
libminifi/include/sitetosite/SiteToSite.h | 2 +-
libminifi/include/sitetosite/SiteToSiteClient.h | 4 +-
libminifi/include/sitetosite/SiteToSiteFactory.h | 2 +-
libminifi/include/utils/FlowFileQueue.h | 4 +-
libminifi/include/utils/StagingQueue.h | 2 +-
libminifi/src/Configure.cpp | 31 +-
libminifi/src/Connection.cpp | 32 +-
libminifi/src/FlowFileRecord.cpp | 35 +-
libminifi/src/RemoteProcessorGroupPort.cpp | 6 +-
libminifi/src/ResourceClaim.cpp | 15 +-
libminifi/src/SchedulingAgent.cpp | 33 +-
libminifi/src/ThreadedSchedulingAgent.cpp | 4 +-
libminifi/src/agent/agent_docs.cpp | 13 +-
libminifi/src/c2/C2Agent.cpp | 6 +-
libminifi/src/c2/C2MetricsPublisher.cpp | 33 +-
libminifi/src/c2/C2Payload.cpp | 1 +
libminifi/src/c2/ControllerSocketProtocol.cpp | 4 +-
libminifi/src/c2/HeartbeatJsonSerializer.cpp | 12 +-
libminifi/src/c2/protocols/RESTSender.cpp | 8 +-
.../controllers/LinuxPowerManagementService.cpp | 190 -------
.../src/controllers/NetworkPrioritizerService.cpp | 4 +-
libminifi/src/controllers/SSLContextService.cpp | 79 +--
libminifi/src/core/ClassLoader.cpp | 129 ++++-
libminifi/src/core/FlowConfiguration.cpp | 7 +-
libminifi/src/core/FlowFile.cpp | 60 +--
libminifi/src/core/ForwardingContentSession.cpp | 4 +-
libminifi/src/core/ProcessContextBuilder.cpp | 46 +-
libminifi/src/core/ProcessGroup.cpp | 15 +-
libminifi/src/core/ProcessSession.cpp | 163 +++---
libminifi/src/core/ProcessSessionFactory.cpp | 4 +-
libminifi/src/core/ProcessorNode.cpp | 10 +-
libminifi/src/core/RecordField.cpp | 2 +-
libminifi/src/core/RepositoryFactory.cpp | 4 +-
.../src/core/controller/ControllerServiceNode.cpp | 6 +-
.../core/controller/ControllerServiceProvider.cpp | 6 +-
.../controller/StandardControllerServiceNode.cpp | 15 +-
libminifi/src/core/extension/DynamicLibrary.cpp | 2 +-
libminifi/src/core/extension/ExtensionManager.cpp | 18 +-
libminifi/src/core/extension/Module.cpp | 2 +-
.../src/core/flow/StructuredConfiguration.cpp | 2 +-
.../core/logging/{Logger.cpp => LoggerBase.cpp} | 16 +-
.../src/core/repository/FileSystemRepository.cpp | 6 +-
.../src/core/repository/VolatileRepository.cpp | 6 +-
libminifi/src/core/state/LogMetricsPublisher.cpp | 7 +-
.../src/core/state/MetricsPublisherFactory.cpp | 8 +-
libminifi/src/core/state/MetricsPublisherStore.cpp | 2 +-
libminifi/src/core/state/Value.cpp | 22 +-
.../src/core/state/nodes/DeviceInformation.cpp | 2 +
libminifi/src/core/state/nodes/FlowInformation.cpp | 69 ++-
.../src/core/state/nodes/ResponseNodeLoader.cpp | 69 ++-
libminifi/src/http/HTTPClient.cpp | 506 -------------------
libminifi/src/properties/Properties.cpp | 20 +-
libminifi/src/provenance/Provenance.cpp | 40 +-
libminifi/src/sitetosite/HTTPProtocol.cpp | 2 +
libminifi/src/utils/FlowFileQueue.cpp | 2 +-
libminifi/src/utils/TimeUtil.cpp | 40 +-
libminifi/src/utils/tls/ExtendedKeyUsage.cpp | 2 +-
libminifi/test/flow-tests/CustomProcessors.h | 6 +-
libminifi/test/flow-tests/CycleTest.cpp | 6 +-
libminifi/test/flow-tests/FlowControllerTests.cpp | 15 +-
libminifi/test/flow-tests/LoopTest.cpp | 6 +-
libminifi/test/flow-tests/MultiLoopTest.cpp | 6 +-
libminifi/test/flow-tests/SessionTests.cpp | 14 +-
libminifi/test/integration/C2AssetSyncTest.cpp | 2 +-
.../test/integration/C2DescribeManifestTest.cpp | 2 +-
libminifi/test/integration/C2MetricsTest.cpp | 97 +++-
libminifi/test/integration/C2PauseResumeTest.cpp | 2 +-
.../test/integration/C2PropertiesUpdateTests.cpp | 1 -
libminifi/test/integration/C2RequestClassTest.cpp | 2 +-
libminifi/test/integration/C2UpdateAssetTest.cpp | 2 +-
libminifi/test/integration/ConfigTestAccessor.h | 2 +-
.../ControllerServiceIntegrationTests.cpp | 4 +-
.../integration/OnScheduleErrorHandlingTests.cpp | 2 +-
libminifi/test/keyvalue-tests/CMakeLists.txt | 31 +-
.../keyvalue-tests/PersistentStateStorageTest.cpp | 4 +-
.../keyvalue-tests/VolatileMapStateStorageTest.cpp | 4 +-
libminifi/test/libtest/integration/CMakeLists.txt | 2 +-
libminifi/test/libtest/integration/CivetStream.h | 2 +-
.../test/libtest/integration/IntegrationBase.cpp | 4 +-
.../test/libtest/integration/IntegrationBase.h | 1 +
libminifi/test/libtest/unit/CMakeLists.txt | 2 +-
.../libtest/unit/ConfigurationTestController.h | 2 +-
.../libtest/unit/ContentRepositoryDependentTests.h | 4 +-
libminifi/test/libtest/unit/DummyProcessor.h | 8 +-
libminifi/test/libtest/unit/MockClasses.h | 16 +-
libminifi/test/libtest/unit/ProvenanceTestHelper.h | 10 +-
.../libtest/unit/ReadFromFlowFileTestProcessor.h | 4 +-
libminifi/test/libtest/unit/RecordSetTesters.h | 5 +-
.../libtest/unit/SingleProcessorTestController.cpp | 2 +-
.../libtest/unit/SingleProcessorTestController.h | 4 +-
libminifi/test/libtest/unit/SiteToSiteHelper.h | 2 +-
libminifi/test/libtest/unit/StatefulProcessor.h | 4 +-
libminifi/test/libtest/unit/TestBase.cpp | 27 +-
libminifi/test/libtest/unit/TestBase.h | 4 +-
.../test/libtest/unit/TestControllerWithFlow.cpp | 2 +-
libminifi/test/libtest/unit/TestRecord.h | 2 +-
.../libtest/unit/WriteToFlowFileTestProcessor.h | 4 +-
.../test/persistence-tests/PersistenceTests.cpp | 35 +-
libminifi/test/resources/RocksDbStateStorage.yml | 40 +-
libminifi/test/unit/ComponentManifestTests.cpp | 8 +-
libminifi/test/unit/ConnectionTests.cpp | 26 +-
.../unit/ControllerSocketMetricsPublisherTest.cpp | 6 +-
libminifi/test/unit/CronTests.cpp | 6 +-
libminifi/test/unit/DecryptorTests.cpp | 4 +-
libminifi/test/unit/DiskSpaceWatchdogTests.cpp | 6 +-
libminifi/test/unit/DynamicPropertyTests.cpp | 4 +-
libminifi/test/unit/FileSystemRepositoryTests.cpp | 22 +-
libminifi/test/unit/FileTriggerTests.cpp | 8 +-
libminifi/test/unit/FlatMapTests.cpp | 2 +-
libminifi/test/unit/FlowFileQueueSwapTests.cpp | 8 +-
libminifi/test/unit/FlowFileQueueTests.cpp | 32 +-
libminifi/test/unit/FlowFileSerializationTests.cpp | 2 +-
libminifi/test/unit/IdTests.cpp | 28 +-
.../LineByLineInputOutputStreamCallbackTests.cpp | 2 +-
libminifi/test/unit/LogMetricsPublisherTests.cpp | 20 +-
libminifi/test/unit/LoggerTests.cpp | 2 +-
libminifi/test/unit/MetricsPublisherStoreTests.cpp | 12 +-
libminifi/test/unit/MetricsTests.cpp | 82 ++-
libminifi/test/unit/NetUtilsTest.cpp | 42 +-
libminifi/test/unit/NetworkInterfaceInfoTests.cpp | 2 +-
.../test/unit/NetworkPrioritizerServiceTests.cpp | 2 +-
.../test/unit/OpenTelemetryLogDataModelTests.cpp | 2 +
libminifi/test/unit/PayloadParserTests.cpp | 116 -----
libminifi/test/unit/ProcessContextTest.cpp | 2 +-
libminifi/test/unit/ProcessSessionTests.cpp | 7 +-
libminifi/test/unit/ProcessorConfigUtilsTests.cpp | 9 +-
libminifi/test/unit/PropertyValidationTests.cpp | 3 +-
libminifi/test/unit/ResourceQueueTests.cpp | 4 +-
libminifi/test/unit/ResponseNodeLoaderTests.cpp | 6 +-
libminifi/test/unit/ResponseNodeValueTests.cpp | 6 +-
libminifi/test/unit/SchedulingAgentTests.cpp | 22 +-
libminifi/test/unit/TimeUtilTests.cpp | 14 +
libminifi/test/unit/UpdatePolicyTests.cpp | 10 +-
minifi-api/CMakeLists.txt | 3 +
minifi-api/include/minifi-cpp/Connection.h | 75 +++
.../include/minifi-cpp}/Exception.h | 2 +-
.../include/minifi-cpp}/FlowFileRecord.h | 44 +-
minifi-api/include/minifi-cpp/ResourceClaim.h | 61 +++
.../include/minifi-cpp}/SwapManager.h | 2 +-
minifi-api/include/minifi-cpp/agent/agent_docs.h | 71 +++
.../include/minifi-cpp}/agent/agent_version.h | 17 +-
.../include/minifi-cpp}/agent/build_description.h | 21 -
.../controllers/AttributeProviderService.h | 10 +-
.../minifi-cpp}/controllers/RecordSetReader.h | 10 +-
.../minifi-cpp}/controllers/RecordSetWriter.h | 12 +-
.../minifi-cpp/controllers/SSLContextService.h | 49 +-
.../controllers/ThreadManagementService.h | 49 +-
.../controllers/keyvalue/KeyValueStateStorage.h | 13 +-
.../minifi-cpp}/core/AgentIdentificationProvider.h | 0
.../include/minifi-cpp}/core/Annotation.h | 0
.../minifi-cpp}/core/CachedValueValidator.h | 4 +
minifi-api/include/minifi-cpp/core/ClassLoader.h | 103 ++++
.../minifi-cpp/core/ConfigurableComponent.h | 89 ++++
minifi-api/include/minifi-cpp/core/Connectable.h | 71 +++
.../include/minifi-cpp/core/ContentRepository.h | 46 +-
.../include/minifi-cpp}/core/ContentSession.h | 19 +-
.../include/minifi-cpp/core/Core.h | 38 +-
.../include/minifi-cpp}/core/DynamicProperty.h | 0
minifi-api/include/minifi-cpp/core/FlowFile.h | 102 ++++
.../include/minifi-cpp/core/ObjectFactory.h | 30 +-
.../minifi-cpp}/core/OutputAttributeDefinition.h | 0
.../include/minifi-cpp}/core/ParameterContext.h | 10 -
.../include/minifi-cpp/core/ProcessContext.h | 84 ++++
.../minifi-cpp/core/ProcessContextBuilder.h | 47 ++
.../include/minifi-cpp/core/ProcessSession.h | 125 +++++
.../minifi-cpp/core/ProcessSessionFactory.h | 15 +-
minifi-api/include/minifi-cpp/core/Processor.h | 94 ++++
.../include/minifi-cpp}/core/ProcessorConfig.h | 22 +-
.../include/minifi-cpp/core/ProcessorMetrics.h | 57 +++
.../include/minifi-cpp/core/ProcessorNode.h | 33 +-
.../include/minifi-cpp}/core/Property.h | 76 +--
.../include/minifi-cpp}/core/PropertyDefinition.h | 17 +-
minifi-api/include/minifi-cpp/core/PropertyType.h | 54 ++
minifi-api/include/minifi-cpp/core/PropertyValue.h | 139 ++++++
.../include/minifi-cpp}/core/Record.h | 0
.../include/minifi-cpp}/core/RecordField.h | 0
.../include/minifi-cpp}/core/Relationship.h | 8 -
.../minifi-cpp}/core/RelationshipDefinition.h | 0
minifi-api/include/minifi-cpp/core/Repository.h | 66 +++
.../minifi-cpp}/core/RepositoryMetricsSource.h | 20 +-
.../include/minifi-cpp}/core/Scheduling.h | 16 +-
.../minifi-cpp}/core/SerializableComponent.h | 6 +-
.../include/minifi-cpp}/core/StateManager.h | 16 +-
.../include/minifi-cpp}/core/StateStorage.h | 4 +-
.../include/minifi-cpp}/core/StreamManager.h | 11 +-
.../include/minifi-cpp/core/ThreadedRepository.h | 13 +-
.../include/minifi-cpp}/core/TraceableResource.h | 5 +-
.../include/minifi-cpp}/core/ValidationResult.h | 0
.../include/minifi-cpp/core/VariableRegistry.h | 16 +-
.../include/minifi-cpp/core/WeakReference.h | 39 +-
.../minifi-cpp/core/controller/ControllerService.h | 54 ++
.../core/controller/ControllerServiceLookup.h | 23 +-
.../core/controller/ControllerServiceNode.h | 33 +-
.../core/controller/ControllerServiceProvider.h | 54 ++
.../include/minifi-cpp/core/extension/Extension.h | 36 +-
.../minifi-cpp/core/extension/ExtensionManager.h | 16 +-
.../include/minifi-cpp}/core/logging/Logger.h | 107 +---
.../minifi-cpp/core/logging/LoggerFactory.h | 16 +-
.../core/repository/FileSystemRepository.h | 14 +-
.../include/minifi-cpp/core/state/FlowIdentifier.h | 25 +-
.../minifi-cpp}/core/state/MetricsPublisher.h | 18 +-
.../core/state/PublishedMetricProvider.h | 4 +-
minifi-api/include/minifi-cpp/core/state/Value.h | 136 +++++
.../minifi-cpp/core/state/nodes/MetricsBase.h | 72 +++
.../core/state/nodes/ResponseNodeLoader.h | 35 +-
.../include/minifi-cpp}/io/ArchiveStream.h | 6 +-
.../include/minifi-cpp}/io/BaseStream.h | 2 +-
.../include/minifi-cpp}/io/InputStream.h | 14 +-
.../include/minifi-cpp}/io/OutputStream.h | 0
.../include/minifi-cpp}/io/Stream.h | 27 +-
.../include/minifi-cpp}/io/StreamCallback.h | 8 +-
.../include/minifi-cpp}/properties/Configuration.h | 12 +-
.../include/minifi-cpp/properties/Configure.h | 49 ++
.../include/minifi-cpp/properties/Properties.h | 69 +++
.../include/minifi-cpp/provenance/Provenance.h | 218 ++++++++
.../include/minifi-cpp}/utils/Export.h | 0
.../include/minifi-cpp}/utils/FlatMap.h | 0
minifi-api/include/minifi-cpp/utils/Id.h | 75 +++
.../include/minifi-cpp}/utils/Literals.h | 0
.../include/minifi-cpp}/utils/PropertyErrors.h | 5 +-
.../include/minifi-cpp}/utils/SmallString.h | 15 -
minifi-api/include/minifi-cpp/utils/TimeUtil.h | 55 +++
.../include/minifi-cpp}/utils/gsl.h | 0
minifi_main/AgentDocs.cpp | 1 +
minifi_main/CMakeLists.txt | 2 +-
minifi_main/MiNiFiMain.cpp | 10 +-
thirdparty/bustache/add-append.patch | 18 +
thirdparty/couchbase/remove-debug-symbols.patch | 12 +
thirdparty/couchbase/remove-thirdparty.patch | 172 +++++++
.../0001-remove-findLZ4-and-findZSTD.patch | 92 ++++
thirdparty/librdkafka/high-cpu.patch | 185 -------
utils/CMakeLists.txt | 22 +
.../io/CRCStream.cpp => utils/include/Exception.h | 6 +-
.../CRCStream.cpp => utils/include/SwapManager.h | 6 +-
{libminifi => utils}/include/agent/agent_docs.h | 82 +--
.../include/agent/agent_version.h | 6 +-
.../include/core/Annotation.h | 7 +-
.../include/core/BufferedContentSession.h | 3 +-
.../include/core/ClassLoader.h | 38 +-
.../core/Core.h => utils/include/core/ClassName.h | 120 +----
.../include/core/ConfigurableComponent.h | 153 +++---
{libminifi => utils}/include/core/Connectable.h | 69 +--
.../include/core/ContentRepository.h | 30 +-
{libminifi => utils}/include/core/ContentSession.h | 21 +-
utils/include/core/Core.h | 123 +++++
{libminifi => utils}/include/core/ObjectFactory.h | 59 +--
.../include/core/OutputAttributeDefinition.h | 7 +-
{libminifi => utils}/include/core/ProcessContext.h | 174 +++----
.../include/core/ProcessContextBuilder.h | 32 +-
{libminifi => utils}/include/core/Processor.h | 126 ++---
.../include/core/ProcessorMetrics.h | 58 ++-
.../include/core/Property.h | 12 +-
.../include/core/PropertyDefinition.h | 7 +-
.../include/core/PropertyDefinitionBuilder.h | 17 +-
{libminifi => utils}/include/core/PropertyType.h | 62 +--
utils/include/core/PropertyValue.h | 160 ++++++
.../include/core/Relationship.h | 14 +-
.../include/core/RelationshipDefinition.h | 7 +-
{libminifi => utils}/include/core/Repository.h | 49 +-
.../include/core/RepositoryMetricsSource.h | 26 +-
{libminifi => utils}/include/core/Resource.h | 3 +
.../include/core/StreamManager.h | 29 +-
.../include/core/ThreadedRepository.h | 13 +-
{libminifi => utils}/include/core/TypedValues.h | 7 +-
.../include/core/VariableRegistry.h | 29 +-
.../include/core/controller/ControllerService.h | 61 +--
{libminifi => utils}/include/core/expect.h | 0
.../include/core/extension/Extension.h | 24 +-
.../include/core/logging/Logger.h | 7 +-
.../include/core/logging/LoggerFactory.h | 9 +-
.../include/core/state/MetricsPublisher.h | 11 +-
.../include/core/state/PublishedMetricProvider.h | 13 +-
{libminifi => utils}/include/core/state/Value.h | 185 ++-----
utils/include/core/state/nodes/ResponseNode.h | 88 ++++
{libminifi => utils}/include/http/BaseHTTPClient.h | 3 +-
{libminifi => utils}/include/http/HTTPCallback.h | 2 +-
{libminifi => utils}/include/http/HTTPClient.h | 13 +-
{libminifi => utils}/include/http/HTTPStream.h | 2 +-
.../include/io/ArchiveStream.h | 5 +-
{libminifi => utils}/include/io/AsioStream.h | 2 +-
{libminifi => utils}/include/io/BaseStream.h | 8 +-
{libminifi => utils}/include/io/BufferStream.h | 2 +-
{libminifi => utils}/include/io/CRCStream.h | 8 +-
{libminifi => utils}/include/io/FileStream.h | 2 +-
.../include/io/InputStream.h | 18 +-
.../Error.h => utils/include/io/OutputStream.h | 9 +-
{libminifi => utils}/include/io/Stream.h | 24 +-
{libminifi => utils}/include/io/StreamPipe.h | 2 +-
{libminifi => utils}/include/io/StreamSlice.h | 4 +-
{libminifi => utils}/include/io/ZlibStream.h | 21 +-
{libminifi => utils}/include/io/validation.h | 0
{libminifi => utils}/include/utils/ArrayUtils.h | 29 +-
.../include/utils}/AutoPersistor.h | 0
{libminifi => utils}/include/utils/BackTrace.h | 0
.../include/utils/ByteArrayCallback.h | 3 +-
{libminifi => utils}/include/utils/CallBackTimer.h | 0
{libminifi => utils}/include/utils/ClassUtils.h | 0
.../include/utils/CollectionUtils.h | 0
{libminifi => utils}/include/utils/Cron.h | 0
{libminifi => utils}/include/utils/Deleters.h | 1 -
{libminifi => utils}/include/utils/Enum.h | 0
{libminifi => utils}/include/utils/Environment.h | 0
{libminifi => utils}/include/utils/Error.h | 0
{libminifi => utils}/include/utils/Export.h | 0
{libminifi => utils}/include/utils/FailurePolicy.h | 0
{libminifi => utils}/include/utils/FifoExecutor.h | 0
{libminifi => utils}/include/utils/FileMutex.h | 0
{libminifi => utils}/include/utils/GeneralUtils.h | 18 +-
{libminifi => utils}/include/utils/HTTPUtils.h | 0
{libminifi => utils}/include/utils/Hash.h | 0
{libminifi => utils}/include/utils/Id.h | 50 +-
.../include/utils/IntervalSwitch.h | 0
{libminifi => utils}/include/utils/JsonCallback.h | 0
.../utils/LineByLineInputOutputStreamCallback.h | 2 +-
.../include/utils/Literals.h | 6 +-
{libminifi => utils}/include/utils/LogUtils.h | 0
{libminifi => utils}/include/utils/Macro.h | 0
{libminifi => utils}/include/utils/MapUtils.h | 0
.../include/utils/MinifiConcurrentQueue.h | 18 +-
{libminifi => utils}/include/utils/Monitors.h | 0
{libminifi => utils}/include/utils/OptionalUtils.h | 0
{libminifi => utils}/include/utils/OsUtils.h | 0
.../include/utils/ProcessCpuUsageTracker.h | 0
.../include/utils/PropertyErrors.h | 6 +-
{libminifi => utils}/include/utils/RegexUtils.h | 0
{libminifi => utils}/include/utils/Searcher.h | 0
.../include/utils/SmallString.h | 33 +-
.../include/utils/StoppableThread.h | 0
{libminifi => utils}/include/utils/StringUtils.h | 0
.../include/utils/SystemCpuUsageTracker.h | 0
{libminifi => utils}/include/utils/ThreadPool.h | 11 +-
{libminifi => utils}/include/utils/TimeUtil.h | 38 +-
{libminifi => utils}/include/utils/TryMoveCall.h | 0
.../include/utils/UnicodeConversion.h | 0
{libminifi => utils}/include/utils/ValueCaster.h | 0
{libminifi => utils}/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
{libminifi => utils}/include/utils/expected.h | 0
.../include/utils/file/FilePattern.h | 0
.../include/utils/file/FileUtils.h | 1 -
.../include/utils/file/PathUtils.h | 0
.../io/CRCStream.cpp => utils/include/utils/gsl.h | 6 +-
{libminifi => utils}/include/utils/meta/detected.h | 0
.../include/utils/meta/type_list.h | 0
{libminifi => utils}/include/utils/net/AsioCoro.h | 0
.../include/utils/net/AsioSocketUtils.h | 5 +-
{libminifi => utils}/include/utils/net/DNS.h | 0
.../include/utils/net}/NetworkInterfaceInfo.h | 0
{libminifi => utils}/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
{libminifi => utils}/include/utils/span.h | 0
.../src/core/BufferedContentSession.cpp | 7 +-
.../src/core/CachedValueValidator.cpp | 2 +-
.../src/core/ConfigurableComponent.cpp | 45 +-
{libminifi => utils}/src/core/Connectable.cpp | 38 +-
.../src/core/ContentRepository.cpp | 24 +-
{libminifi => utils}/src/core/ContentSession.cpp | 2 +-
{libminifi => utils}/src/core/Core.cpp | 16 +-
utils/src/core/ProcessContextBuilder.cpp | 67 +++
.../Hash.h => utils/src/core/ProcessSession.cpp | 14 +-
{libminifi => utils}/src/core/Processor.cpp | 71 +--
{libminifi => utils}/src/core/ProcessorMetrics.cpp | 63 ++-
{libminifi => utils}/src/core/Property.cpp | 65 ++-
{libminifi => utils}/src/core/PropertyType.cpp | 4 +-
{libminifi => utils}/src/core/Repository.cpp | 4 +-
{libminifi => utils}/src/core/TypedValues.cpp | 2 +-
.../src/core/extension/Extension.cpp | 10 +-
{libminifi => utils}/src/http/BaseHTTPClient.cpp | 0
{libminifi => utils}/src/http/HTTPClient.cpp | 13 +-
{libminifi => utils}/src/http/HTTPStream.cpp | 0
{libminifi => utils}/src/io/BufferStream.cpp | 0
{libminifi => utils}/src/io/CPPLINT.cfg | 1 -
{libminifi => utils}/src/io/CRCStream.cpp | 0
{libminifi => utils}/src/io/FileStream.cpp | 2 +-
{libminifi => utils}/src/io/InputStream.cpp | 8 +
{libminifi => utils}/src/io/OutputStream.cpp | 0
{libminifi => utils}/src/io/StreamSlice.cpp | 0
{libminifi => utils}/src/io/ZlibStream.cpp | 2 +-
.../keyvalue => utils/src/utils}/AutoPersistor.cpp | 2 +-
{libminifi => utils}/src/utils/BackTrace.cpp | 0
.../src/utils/ByteArrayCallback.cpp | 0
{libminifi => utils}/src/utils/ClassUtils.cpp | 0
{libminifi => utils}/src/utils/Cron.cpp | 0
{libminifi => utils}/src/utils/Environment.cpp | 0
{libminifi => utils}/src/utils/Error.cpp | 0
{libminifi => utils}/src/utils/FifoExecutor.cpp | 0
{libminifi => utils}/src/utils/FileMutex.cpp | 0
{libminifi => utils}/src/utils/HTTPUtils.cpp | 0
{libminifi => utils}/src/utils/Id.cpp | 0
.../utils/LineByLineInputOutputStreamCallback.cpp | 22 +-
{libminifi => utils}/src/utils/OsUtils.cpp | 0
.../src/utils/ProcessCpuUsageTracker.cpp | 0
{libminifi => utils}/src/utils/RegexUtils.cpp | 0
{libminifi => utils}/src/utils/StoppableThread.cpp | 0
{libminifi => utils}/src/utils/StringUtils.cpp | 0
.../src/utils/SystemCpuUsageTracker.cpp | 0
{libminifi => utils}/src/utils/ThreadPool.cpp | 3 +-
{libminifi => utils}/src/utils/TimeUtil.cpp | 62 ++-
.../src/utils/crypto/EncryptionManager.cpp | 20 +-
.../src/utils/crypto/EncryptionProvider.cpp | 0
.../src/utils/crypto/EncryptionUtils.cpp | 0
.../src/utils/crypto/ciphers/Aes256Ecb.cpp | 2 +-
.../PropertyEncryptionUtils.cpp | 0
.../src/utils/file/FilePattern.cpp | 2 +-
{libminifi => utils}/src/utils/file/FileUtils.cpp | 0
{libminifi => utils}/src/utils/file/PathUtils.cpp | 0
.../src/utils/net/AsioSocketUtils.cpp | 2 +-
{libminifi => utils}/src/utils/net/DNS.cpp | 0
.../src/utils/net}/NetworkInterfaceInfo.cpp | 4 +-
{libminifi => utils}/src/utils/net/Socket.cpp | 0
win_build_vs.bat | 6 +-
886 files changed, 12324 insertions(+), 9034 deletions(-)
delete mode 100644 cmake/BundledLibRdKafka.cmake
create mode 100644 cmake/Couchbase.cmake
create mode 100644 cmake/Fetchlibrdkafka.cmake
create mode 100644 docker/test/integration/cluster/checkers/CouchbaseChecker.py
create mode 100644
docker/test/integration/cluster/containers/CouchbaseServerContainer.py
create mode 100644 docker/test/integration/features/couchbase.feature
copy
docker/test/integration/minifi/controllers/{KubernetesControllerService.py =>
CouchbaseClusterService.py} (56%)
copy docker/test/integration/minifi/processors/{LogAttribute.py =>
GetCouchbaseKey.py} (84%)
copy docker/test/integration/minifi/processors/{LogAttribute.py =>
PutCouchbaseKey.py} (84%)
create mode 100644 examples/couchbase_mtls_authentication.json
create mode 100644 examples/couchbase_mtls_authentication.yml
create mode 100644 extension-utils/CMakeLists.txt
copy libminifi/src/io/CRCStream.cpp =>
extension-utils/include/FlowFileRecord.h (92%)
copy libminifi/src/io/CRCStream.cpp => extension-utils/include/ResourceClaim.h
(92%)
copy {libminifi =>
extension-utils}/include/controllers/AttributeProviderService.h (80%)
copy libminifi/include/controllers/RecordSetWriter.h =>
extension-utils/include/controllers/RecordSetReader.h (75%)
copy {libminifi => extension-utils}/include/controllers/RecordSetWriter.h (75%)
copy libminifi/src/io/CRCStream.cpp =>
extension-utils/include/controllers/SSLContextService.h (92%)
rename {libminifi =>
extension-utils}/include/controllers/keyvalue/KeyValueStateManager.h (94%)
rename {libminifi =>
extension-utils}/include/controllers/keyvalue/KeyValueStateStorage.h (89%)
rename {libminifi => extension-utils}/include/core/AbstractProcessor.h (93%)
copy libminifi/src/io/CRCStream.cpp => extension-utils/include/core/FlowFile.h
(92%)
rename {libminifi => extension-utils}/include/core/FlowFileStore.h (100%)
copy libminifi/include/utils/Error.h =>
extension-utils/include/core/ProcessSession.h (78%)
copy {libminifi => extension-utils}/include/core/StateManager.h (72%)
copy {libminifi => extension-utils}/include/core/StateStorage.h (81%)
copy libminifi/src/io/CRCStream.cpp =>
extension-utils/include/properties/Configure.h (92%)
copy libminifi/src/io/CRCStream.cpp =>
extension-utils/include/properties/Properties.h (92%)
rename {libminifi =>
extension-utils}/include/serialization/FlowFileSerializer.h (97%)
rename {libminifi =>
extension-utils}/include/serialization/FlowFileV3Serializer.h (100%)
rename {libminifi =>
extension-utils}/include/serialization/PayloadSerializer.h (100%)
rename {libminifi => extension-utils}/include/utils/ListingStateManager.h (95%)
rename {libminifi =>
extension-utils}/include/utils/OpenTelemetryLogDataModelUtils.h (98%)
rename {libminifi => extension-utils}/include/utils/ProcessorConfigUtils.h
(100%)
rename {libminifi => extension-utils}/include/utils/ResourceQueue.h (94%)
rename {libminifi => extension-utils}/include/utils/file/FileManager.h (100%)
rename {libminifi => extension-utils}/include/utils/file/FileReaderCallback.h
(100%)
rename {libminifi => extension-utils}/include/utils/file/FileWriterCallback.h
(96%)
rename {libminifi => extension-utils}/include/utils/file/ListedFile.h (99%)
rename {libminifi => extension-utils}/include/utils/net/ConnectionHandler.h
(98%)
rename {libminifi =>
extension-utils}/include/utils/net/ConnectionHandlerBase.h (100%)
rename {libminifi => extension-utils}/include/utils/net/IpProtocol.h (100%)
rename {libminifi => extension-utils}/include/utils/net/Message.h (100%)
rename {libminifi => extension-utils}/include/utils/net/Server.h (100%)
rename {libminifi => extension-utils}/include/utils/net/Ssl.h (100%)
rename {libminifi => extension-utils}/include/utils/net/TcpServer.h (100%)
rename {libminifi => extension-utils}/include/utils/net/UdpServer.h (96%)
rename {libminifi =>
extension-utils}/src/controllers/keyvalue/KeyValueStateManager.cpp (99%)
rename {libminifi =>
extension-utils}/src/controllers/keyvalue/KeyValueStateStorage.cpp (98%)
copy libminifi/src/core/TypedValues.cpp =>
extension-utils/src/core/ProcessContext.cpp (65%)
rename {libminifi =>
extension-utils}/src/serialization/FlowFileV3Serializer.cpp (98%)
rename {libminifi => extension-utils}/src/serialization/PayloadSerializer.cpp
(83%)
copy {libminifi => extension-utils}/src/utils/CallBackTimer.cpp (91%)
rename {libminifi => extension-utils}/src/utils/ListingStateManager.cpp (95%)
rename {libminifi => extension-utils}/src/utils/ProcessorConfigUtils.cpp (100%)
rename {libminifi => extension-utils}/src/utils/file/FileReaderCallback.cpp
(98%)
rename {libminifi => extension-utils}/src/utils/file/FileWriterCallback.cpp
(100%)
rename {libminifi => extension-utils}/src/utils/net/Ssl.cpp (100%)
rename {libminifi => extension-utils}/src/utils/net/TcpServer.cpp (100%)
rename {libminifi => extension-utils}/src/utils/net/UdpServer.cpp (100%)
copy extensions/{elasticsearch => couchbase}/CMakeLists.txt (56%)
create mode 100644
extensions/couchbase/controllerservices/CouchbaseClusterService.cpp
create mode 100644
extensions/couchbase/controllerservices/CouchbaseClusterService.h
create mode 100644 extensions/couchbase/processors/GetCouchbaseKey.cpp
create mode 100644 extensions/couchbase/processors/GetCouchbaseKey.h
create mode 100644 extensions/couchbase/processors/PutCouchbaseKey.cpp
create mode 100644 extensions/couchbase/processors/PutCouchbaseKey.h
copy extensions/{aws => couchbase}/tests/CMakeLists.txt (71%)
create mode 100644 extensions/couchbase/tests/GetCouchbaseKeyTests.cpp
create mode 100644 extensions/couchbase/tests/MockCouchbaseClusterService.h
create mode 100644 extensions/couchbase/tests/PutCouchbaseKeyTests.cpp
rename extensions/{librdkafka => kafka}/CMakeLists.txt (76%)
rename extensions/{librdkafka => kafka}/ConsumeKafka.cpp (68%)
create mode 100644 extensions/kafka/ConsumeKafka.h
rename extensions/{librdkafka => kafka}/KafkaConnection.cpp (78%)
rename extensions/{librdkafka => kafka}/KafkaConnection.h (84%)
rename extensions/{librdkafka => kafka}/KafkaProcessorBase.cpp (85%)
create mode 100644 extensions/kafka/KafkaProcessorBase.h
copy extensions/{test-processors/LogOnDestructionProcessor.cpp =>
kafka/KafkaTopic.h} (62%)
rename extensions/{librdkafka => kafka}/PublishKafka.cpp (58%)
create mode 100644 extensions/kafka/PublishKafka.h
rename extensions/{librdkafka => kafka}/rdkafka_utils.cpp (73%)
rename extensions/{librdkafka => kafka}/rdkafka_utils.h (67%)
rename extensions/{librdkafka => kafka}/tests/CMakeLists.txt (92%)
rename extensions/{librdkafka => kafka}/tests/PublishKafkaTests.cpp (52%)
delete mode 100644 extensions/librdkafka/ConsumeKafka.h
delete mode 100644 extensions/librdkafka/KafkaProcessorBase.h
delete mode 100644 extensions/librdkafka/KafkaTopic.h
delete mode 100644 extensions/librdkafka/PublishKafka.h
create mode 100644
extensions/standard-processors/tests/unit/HttpClientStoreTests.cpp
delete mode 100644 libminifi/include/c2/PayloadParser.h
delete mode 100644 libminifi/include/controllers/LinuxPowerManagementService.h
delete mode 100644 libminifi/include/core/ClassLoader.h
delete mode 100644 libminifi/include/core/Deprecated.h
delete mode 100644 libminifi/include/core/PropertyValue.h
create mode 100644 libminifi/include/core/logging/LoggerBase.h
delete mode 100644 libminifi/src/controllers/LinuxPowerManagementService.cpp
rename libminifi/src/core/logging/{Logger.cpp => LoggerBase.cpp} (78%)
delete mode 100644 libminifi/test/unit/PayloadParserTests.cpp
create mode 100644 minifi-api/CMakeLists.txt
create mode 100644 minifi-api/include/minifi-cpp/Connection.h
rename {libminifi/include => minifi-api/include/minifi-cpp}/Exception.h (98%)
copy {libminifi/include => minifi-api/include/minifi-cpp}/FlowFileRecord.h
(62%)
create mode 100644 minifi-api/include/minifi-cpp/ResourceClaim.h
rename {libminifi/include => minifi-api/include/minifi-cpp}/SwapManager.h (97%)
create mode 100644 minifi-api/include/minifi-cpp/agent/agent_docs.h
rename {libminifi/include =>
minifi-api/include/minifi-cpp}/agent/agent_version.h (83%)
copy {libminifi/include =>
minifi-api/include/minifi-cpp}/agent/build_description.h (70%)
rename {libminifi/include =>
minifi-api/include/minifi-cpp}/controllers/AttributeProviderService.h (76%)
rename {libminifi/include =>
minifi-api/include/minifi-cpp}/controllers/RecordSetReader.h (86%)
rename {libminifi/include =>
minifi-api/include/minifi-cpp}/controllers/RecordSetWriter.h (80%)
copy libminifi/include/controllers/keyvalue/AutoPersistor.h =>
minifi-api/include/minifi-cpp/controllers/SSLContextService.h (50%)
copy {libminifi/include =>
minifi-api/include/minifi-cpp}/controllers/ThreadManagementService.h (62%)
copy libminifi/include/core/RelationshipDefinition.h =>
minifi-api/include/minifi-cpp/controllers/keyvalue/KeyValueStateStorage.h (75%)
rename {libminifi/include =>
minifi-api/include/minifi-cpp}/core/AgentIdentificationProvider.h (100%)
rename {libminifi/include => minifi-api/include/minifi-cpp}/core/Annotation.h
(100%)
rename {libminifi/include =>
minifi-api/include/minifi-cpp}/core/CachedValueValidator.h (93%)
create mode 100644 minifi-api/include/minifi-cpp/core/ClassLoader.h
create mode 100644 minifi-api/include/minifi-cpp/core/ConfigurableComponent.h
create mode 100644 minifi-api/include/minifi-cpp/core/Connectable.h
copy libminifi/include/core/ForwardingContentSession.h =>
minifi-api/include/minifi-cpp/core/ContentRepository.h (53%)
copy {libminifi/include =>
minifi-api/include/minifi-cpp}/core/ContentSession.h (70%)
copy libminifi/include/core/ConfigurationFactory.h =>
minifi-api/include/minifi-cpp/core/Core.h (51%)
rename {libminifi/include =>
minifi-api/include/minifi-cpp}/core/DynamicProperty.h (100%)
create mode 100644 minifi-api/include/minifi-cpp/core/FlowFile.h
copy libminifi/include/core/StateStorage.h =>
minifi-api/include/minifi-cpp/core/ObjectFactory.h (63%)
rename {libminifi/include =>
minifi-api/include/minifi-cpp}/core/OutputAttributeDefinition.h (100%)
copy {libminifi/include =>
minifi-api/include/minifi-cpp}/core/ParameterContext.h (84%)
create mode 100644 minifi-api/include/minifi-cpp/core/ProcessContext.h
create mode 100644 minifi-api/include/minifi-cpp/core/ProcessContextBuilder.h
create mode 100644 minifi-api/include/minifi-cpp/core/ProcessSession.h
copy libminifi/include/core/RelationshipDefinition.h =>
minifi-api/include/minifi-cpp/core/ProcessSessionFactory.h (76%)
create mode 100644 minifi-api/include/minifi-cpp/core/Processor.h
copy {libminifi/include =>
minifi-api/include/minifi-cpp}/core/ProcessorConfig.h (80%)
create mode 100644 minifi-api/include/minifi-cpp/core/ProcessorMetrics.h
copy libminifi/include/core/ConfigurationFactory.h =>
minifi-api/include/minifi-cpp/core/ProcessorNode.h (59%)
rename {libminifi/include => minifi-api/include/minifi-cpp}/core/Property.h
(74%)
rename {libminifi/include =>
minifi-api/include/minifi-cpp}/core/PropertyDefinition.h (88%)
create mode 100644 minifi-api/include/minifi-cpp/core/PropertyType.h
create mode 100644 minifi-api/include/minifi-cpp/core/PropertyValue.h
rename {libminifi/include => minifi-api/include/minifi-cpp}/core/Record.h
(100%)
rename {libminifi/include => minifi-api/include/minifi-cpp}/core/RecordField.h
(100%)
rename {libminifi/include =>
minifi-api/include/minifi-cpp}/core/Relationship.h (88%)
copy {libminifi/include =>
minifi-api/include/minifi-cpp}/core/RelationshipDefinition.h (100%)
create mode 100644 minifi-api/include/minifi-cpp/core/Repository.h
rename {libminifi/include =>
minifi-api/include/minifi-cpp}/core/RepositoryMetricsSource.h (82%)
rename {libminifi/include => minifi-api/include/minifi-cpp}/core/Scheduling.h
(78%)
copy {libminifi/include =>
minifi-api/include/minifi-cpp}/core/SerializableComponent.h (89%)
rename {libminifi/include =>
minifi-api/include/minifi-cpp}/core/StateManager.h (87%)
copy {libminifi/include => minifi-api/include/minifi-cpp}/core/StateStorage.h
(91%)
rename {libminifi/include =>
minifi-api/include/minifi-cpp}/core/StreamManager.h (93%)
copy libminifi/include/core/RelationshipDefinition.h =>
minifi-api/include/minifi-cpp/core/ThreadedRepository.h (81%)
rename {libminifi/include =>
minifi-api/include/minifi-cpp}/core/TraceableResource.h (90%)
copy {libminifi/include =>
minifi-api/include/minifi-cpp}/core/ValidationResult.h (100%)
copy libminifi/include/core/ValidationResult.h =>
minifi-api/include/minifi-cpp/core/VariableRegistry.h (72%)
rename libminifi/include/core/StateStorage.h =>
minifi-api/include/minifi-cpp/core/WeakReference.h (54%)
create mode 100644
minifi-api/include/minifi-cpp/core/controller/ControllerService.h
copy {libminifi/include =>
minifi-api/include/minifi-cpp}/core/controller/ControllerServiceLookup.h (84%)
copy libminifi/src/core/controller/ControllerServiceNode.cpp =>
minifi-api/include/minifi-cpp/core/controller/ControllerServiceNode.h (54%)
create mode 100644
minifi-api/include/minifi-cpp/core/controller/ControllerServiceProvider.h
copy libminifi/include/core/extension/ExtensionManager.h =>
minifi-api/include/minifi-cpp/core/extension/Extension.h (58%)
copy minifi_main/AgentDocs.h =>
minifi-api/include/minifi-cpp/core/extension/ExtensionManager.h (72%)
rename {libminifi/include =>
minifi-api/include/minifi-cpp}/core/logging/Logger.h (51%)
copy libminifi/src/core/logging/LoggerFactory.cpp =>
minifi-api/include/minifi-cpp/core/logging/LoggerFactory.h (76%)
copy extensions/azure/utils/AzureEnums.h =>
minifi-api/include/minifi-cpp/core/repository/FileSystemRepository.h (77%)
copy libminifi/include/core/state/PublishedMetricProvider.h =>
minifi-api/include/minifi-cpp/core/state/FlowIdentifier.h (72%)
copy {libminifi/include =>
minifi-api/include/minifi-cpp}/core/state/MetricsPublisher.h (72%)
copy {libminifi/include =>
minifi-api/include/minifi-cpp}/core/state/PublishedMetricProvider.h (93%)
create mode 100644 minifi-api/include/minifi-cpp/core/state/Value.h
create mode 100644 minifi-api/include/minifi-cpp/core/state/nodes/MetricsBase.h
copy libminifi/include/core/state/nodes/SchedulingNodes.h =>
minifi-api/include/minifi-cpp/core/state/nodes/ResponseNodeLoader.h (53%)
rename {libminifi/include => minifi-api/include/minifi-cpp}/io/ArchiveStream.h
(90%)
copy {libminifi/include => minifi-api/include/minifi-cpp}/io/BaseStream.h (94%)
rename {libminifi/include => minifi-api/include/minifi-cpp}/io/InputStream.h
(91%)
rename {libminifi/include => minifi-api/include/minifi-cpp}/io/OutputStream.h
(100%)
copy {libminifi/include => minifi-api/include/minifi-cpp}/io/Stream.h (80%)
rename {libminifi/include =>
minifi-api/include/minifi-cpp}/io/StreamCallback.h (81%)
copy {libminifi/include =>
minifi-api/include/minifi-cpp}/properties/Configuration.h (98%)
create mode 100644 minifi-api/include/minifi-cpp/properties/Configure.h
create mode 100644 minifi-api/include/minifi-cpp/properties/Properties.h
create mode 100644 minifi-api/include/minifi-cpp/provenance/Provenance.h
copy {libminifi/include => minifi-api/include/minifi-cpp}/utils/Export.h (100%)
rename {libminifi/include => minifi-api/include/minifi-cpp}/utils/FlatMap.h
(100%)
create mode 100644 minifi-api/include/minifi-cpp/utils/Id.h
rename {libminifi/include => minifi-api/include/minifi-cpp}/utils/Literals.h
(100%)
rename {libminifi/include =>
minifi-api/include/minifi-cpp}/utils/PropertyErrors.h (94%)
rename {libminifi/include =>
minifi-api/include/minifi-cpp}/utils/SmallString.h (84%)
create mode 100644 minifi-api/include/minifi-cpp/utils/TimeUtil.h
rename {libminifi/include => minifi-api/include/minifi-cpp}/utils/gsl.h (100%)
create mode 100644 thirdparty/bustache/add-append.patch
create mode 100644 thirdparty/couchbase/remove-debug-symbols.patch
create mode 100644 thirdparty/couchbase/remove-thirdparty.patch
create mode 100644 thirdparty/librdkafka/0001-remove-findLZ4-and-findZSTD.patch
delete mode 100644 thirdparty/librdkafka/high-cpu.patch
create mode 100644 utils/CMakeLists.txt
copy libminifi/src/io/CRCStream.cpp => utils/include/Exception.h (92%)
copy libminifi/src/io/CRCStream.cpp => utils/include/SwapManager.h (92%)
rename {libminifi => utils}/include/agent/agent_docs.h (56%)
copy libminifi/src/io/CRCStream.cpp => utils/include/agent/agent_version.h
(92%)
copy libminifi/src/io/CRCStream.cpp => utils/include/core/Annotation.h (92%)
rename {libminifi => utils}/include/core/BufferedContentSession.h (96%)
copy libminifi/include/core/ConfigurationFactory.h =>
utils/include/core/ClassLoader.h (50%)
rename libminifi/include/core/Core.h => utils/include/core/ClassName.h (50%)
rename {libminifi => utils}/include/core/ConfigurableComponent.h (57%)
rename {libminifi => utils}/include/core/Connectable.h (70%)
rename {libminifi => utils}/include/core/ContentRepository.h (70%)
rename {libminifi => utils}/include/core/ContentSession.h (67%)
create mode 100644 utils/include/core/Core.h
rename {libminifi => utils}/include/core/ObjectFactory.h (66%)
copy libminifi/src/io/CRCStream.cpp =>
utils/include/core/OutputAttributeDefinition.h (92%)
rename {libminifi => utils}/include/core/ProcessContext.h (70%)
rename {libminifi => utils}/include/core/ProcessContextBuilder.h (72%)
rename {libminifi => utils}/include/core/Processor.h (61%)
rename {libminifi => utils}/include/core/ProcessorMetrics.h (52%)
rename libminifi/include/core/RelationshipDefinition.h =>
utils/include/core/Property.h (81%)
copy libminifi/src/io/CRCStream.cpp => utils/include/core/PropertyDefinition.h
(92%)
rename {libminifi => utils}/include/core/PropertyDefinitionBuilder.h (91%)
rename {libminifi => utils}/include/core/PropertyType.h (86%)
create mode 100644 utils/include/core/PropertyValue.h
copy extensions/systemd/libwrapper/DlopenWrapper.h =>
utils/include/core/Relationship.h (74%)
copy libminifi/src/io/CRCStream.cpp =>
utils/include/core/RelationshipDefinition.h (92%)
rename {libminifi => utils}/include/core/Repository.h (67%)
rename libminifi/include/core/ValidationResult.h =>
utils/include/core/RepositoryMetricsSource.h (67%)
rename {libminifi => utils}/include/core/Resource.h (94%)
copy libminifi/include/core/ConfigurationFactory.h =>
utils/include/core/StreamManager.h (65%)
rename {libminifi => utils}/include/core/ThreadedRepository.h (90%)
rename {libminifi => utils}/include/core/TypedValues.h (97%)
rename {libminifi => utils}/include/core/VariableRegistry.h (82%)
rename {libminifi => utils}/include/core/controller/ControllerService.h (66%)
rename {libminifi => utils}/include/core/expect.h (100%)
rename {libminifi => utils}/include/core/extension/Extension.h (75%)
copy libminifi/src/io/CRCStream.cpp => utils/include/core/logging/Logger.h
(92%)
copy {libminifi => utils}/include/core/logging/LoggerFactory.h (86%)
rename {libminifi => utils}/include/core/state/MetricsPublisher.h (75%)
rename {libminifi => utils}/include/core/state/PublishedMetricProvider.h (79%)
rename {libminifi => utils}/include/core/state/Value.h (70%)
create mode 100644 utils/include/core/state/nodes/ResponseNode.h
rename {libminifi => utils}/include/http/BaseHTTPClient.h (99%)
rename {libminifi => utils}/include/http/HTTPCallback.h (99%)
rename {libminifi => utils}/include/http/HTTPClient.h (96%)
rename {libminifi => utils}/include/http/HTTPStream.h (98%)
copy libminifi/src/io/CRCStream.cpp => utils/include/io/ArchiveStream.h (92%)
rename {libminifi => utils}/include/io/AsioStream.h (98%)
rename {libminifi => utils}/include/io/BaseStream.h (88%)
rename {libminifi => utils}/include/io/BufferStream.h (98%)
rename {libminifi => utils}/include/io/CRCStream.h (95%)
rename {libminifi => utils}/include/io/FileStream.h (98%)
copy extensions/lua/LuaScriptException.h => utils/include/io/InputStream.h
(71%)
copy libminifi/include/utils/Error.h => utils/include/io/OutputStream.h (82%)
rename {libminifi => utils}/include/io/Stream.h (65%)
rename {libminifi => utils}/include/io/StreamPipe.h (98%)
rename {libminifi => utils}/include/io/StreamSlice.h (95%)
rename {libminifi => utils}/include/io/ZlibStream.h (88%)
rename {libminifi => utils}/include/io/validation.h (100%)
rename {libminifi => utils}/include/utils/ArrayUtils.h (73%)
rename {libminifi/include/controllers/keyvalue =>
utils/include/utils}/AutoPersistor.h (100%)
rename {libminifi => utils}/include/utils/BackTrace.h (100%)
rename {libminifi => utils}/include/utils/ByteArrayCallback.h (98%)
rename {libminifi => utils}/include/utils/CallBackTimer.h (100%)
rename {libminifi => utils}/include/utils/ClassUtils.h (100%)
rename {libminifi => utils}/include/utils/CollectionUtils.h (100%)
rename {libminifi => utils}/include/utils/Cron.h (100%)
rename {libminifi => utils}/include/utils/Deleters.h (98%)
rename {libminifi => utils}/include/utils/Enum.h (100%)
rename {libminifi => utils}/include/utils/Environment.h (100%)
rename {libminifi => utils}/include/utils/Error.h (100%)
rename {libminifi => utils}/include/utils/Export.h (100%)
rename {libminifi => utils}/include/utils/FailurePolicy.h (100%)
rename {libminifi => utils}/include/utils/FifoExecutor.h (100%)
rename {libminifi => utils}/include/utils/FileMutex.h (100%)
rename {libminifi => utils}/include/utils/GeneralUtils.h (89%)
rename {libminifi => utils}/include/utils/HTTPUtils.h (100%)
copy {libminifi => utils}/include/utils/Hash.h (100%)
rename {libminifi => utils}/include/utils/Id.h (71%)
rename {libminifi => utils}/include/utils/IntervalSwitch.h (100%)
rename {libminifi => utils}/include/utils/JsonCallback.h (100%)
rename {libminifi =>
utils}/include/utils/LineByLineInputOutputStreamCallback.h (92%)
copy libminifi/src/io/CRCStream.cpp => utils/include/utils/Literals.h (92%)
rename {libminifi => utils}/include/utils/LogUtils.h (100%)
rename {libminifi => utils}/include/utils/Macro.h (100%)
rename {libminifi => utils}/include/utils/MapUtils.h (100%)
rename {libminifi => utils}/include/utils/MinifiConcurrentQueue.h (95%)
rename {libminifi => utils}/include/utils/Monitors.h (100%)
rename {libminifi => utils}/include/utils/OptionalUtils.h (100%)
rename {libminifi => utils}/include/utils/OsUtils.h (100%)
rename {libminifi => utils}/include/utils/ProcessCpuUsageTracker.h (100%)
copy libminifi/src/io/CRCStream.cpp => utils/include/utils/PropertyErrors.h
(92%)
rename {libminifi => utils}/include/utils/RegexUtils.h (100%)
rename {libminifi => utils}/include/utils/Searcher.h (100%)
copy libminifi/include/core/state/nodes/SchedulingNodes.h =>
utils/include/utils/SmallString.h (59%)
rename {libminifi => utils}/include/utils/StoppableThread.h (100%)
rename {libminifi => utils}/include/utils/StringUtils.h (100%)
rename {libminifi => utils}/include/utils/SystemCpuUsageTracker.h (100%)
rename {libminifi => utils}/include/utils/ThreadPool.h (95%)
rename {libminifi => utils}/include/utils/TimeUtil.h (88%)
rename {libminifi => utils}/include/utils/TryMoveCall.h (100%)
rename {libminifi => utils}/include/utils/UnicodeConversion.h (100%)
rename {libminifi => utils}/include/utils/ValueCaster.h (100%)
rename {libminifi => utils}/include/utils/ValueParser.h (100%)
rename {libminifi => utils}/include/utils/crypto/EncryptionManager.h (100%)
rename {libminifi => utils}/include/utils/crypto/EncryptionProvider.h (100%)
rename {libminifi => utils}/include/utils/crypto/EncryptionUtils.h (100%)
rename {libminifi => utils}/include/utils/crypto/ciphers/Aes256Ecb.h (100%)
rename {libminifi => utils}/include/utils/crypto/ciphers/XSalsa20.h (100%)
rename {libminifi =>
utils}/include/utils/crypto/property_encryption/PropertyEncryptionUtils.h (100%)
rename {libminifi => utils}/include/utils/detail/MonadicOperationWrappers.h
(100%)
rename {libminifi => utils}/include/utils/expected.h (100%)
rename {libminifi => utils}/include/utils/file/FilePattern.h (100%)
rename {libminifi => utils}/include/utils/file/FileUtils.h (99%)
rename {libminifi => utils}/include/utils/file/PathUtils.h (100%)
copy libminifi/src/io/CRCStream.cpp => utils/include/utils/gsl.h (92%)
rename {libminifi => utils}/include/utils/meta/detected.h (100%)
rename {libminifi => utils}/include/utils/meta/type_list.h (100%)
rename {libminifi => utils}/include/utils/net/AsioCoro.h (100%)
rename {libminifi => utils}/include/utils/net/AsioSocketUtils.h (97%)
rename {libminifi => utils}/include/utils/net/DNS.h (100%)
rename {libminifi/include/utils =>
utils/include/utils/net}/NetworkInterfaceInfo.h (100%)
rename {libminifi => utils}/include/utils/net/Socket.h (100%)
rename {libminifi => utils}/include/utils/requirements/Container.h (100%)
rename {libminifi => utils}/include/utils/requirements/EqualityComparable.h
(100%)
rename {libminifi => utils}/include/utils/requirements/LegacyForwardIterator.h
(100%)
rename {libminifi => utils}/include/utils/requirements/LegacyInputIterator.h
(100%)
rename {libminifi => utils}/include/utils/requirements/LegacyIterator.h (100%)
rename {libminifi => utils}/include/utils/requirements/Swappable.h (100%)
rename {libminifi => utils}/include/utils/span.h (100%)
rename {libminifi => utils}/src/core/BufferedContentSession.cpp (94%)
rename {libminifi => utils}/src/core/CachedValueValidator.cpp (97%)
rename {libminifi => utils}/src/core/ConfigurableComponent.cpp (84%)
rename {libminifi => utils}/src/core/Connectable.cpp (77%)
rename {libminifi => utils}/src/core/ContentRepository.cpp (77%)
rename {libminifi => utils}/src/core/ContentSession.cpp (89%)
rename {libminifi => utils}/src/core/Core.cpp (71%)
create mode 100644 utils/src/core/ProcessContextBuilder.cpp
rename libminifi/include/utils/Hash.h => utils/src/core/ProcessSession.cpp
(70%)
rename {libminifi => utils}/src/core/Processor.cpp (84%)
rename {libminifi => utils}/src/core/ProcessorMetrics.cpp (65%)
rename {libminifi => utils}/src/core/Property.cpp (66%)
rename {libminifi => utils}/src/core/PropertyType.cpp (95%)
rename {libminifi => utils}/src/core/Repository.cpp (87%)
rename {libminifi => utils}/src/core/TypedValues.cpp (96%)
rename {libminifi => utils}/src/core/extension/Extension.cpp (80%)
rename {libminifi => utils}/src/http/BaseHTTPClient.cpp (100%)
copy {libminifi => utils}/src/http/HTTPClient.cpp (98%)
rename {libminifi => utils}/src/http/HTTPStream.cpp (100%)
rename {libminifi => utils}/src/io/BufferStream.cpp (100%)
copy {libminifi => utils}/src/io/CPPLINT.cfg (63%)
rename {libminifi => utils}/src/io/CRCStream.cpp (100%)
rename {libminifi => utils}/src/io/FileStream.cpp (99%)
rename {libminifi => utils}/src/io/InputStream.cpp (94%)
rename {libminifi => utils}/src/io/OutputStream.cpp (100%)
rename {libminifi => utils}/src/io/StreamSlice.cpp (100%)
rename {libminifi => utils}/src/io/ZlibStream.cpp (99%)
rename {libminifi/src/controllers/keyvalue =>
utils/src/utils}/AutoPersistor.cpp (98%)
rename {libminifi => utils}/src/utils/BackTrace.cpp (100%)
rename {libminifi => utils}/src/utils/ByteArrayCallback.cpp (100%)
rename {libminifi => utils}/src/utils/ClassUtils.cpp (100%)
rename {libminifi => utils}/src/utils/Cron.cpp (100%)
rename {libminifi => utils}/src/utils/Environment.cpp (100%)
rename {libminifi => utils}/src/utils/Error.cpp (100%)
rename {libminifi => utils}/src/utils/FifoExecutor.cpp (100%)
rename {libminifi => utils}/src/utils/FileMutex.cpp (100%)
rename {libminifi => utils}/src/utils/HTTPUtils.cpp (100%)
rename {libminifi => utils}/src/utils/Id.cpp (100%)
rename {libminifi => utils}/src/utils/LineByLineInputOutputStreamCallback.cpp
(80%)
rename {libminifi => utils}/src/utils/OsUtils.cpp (100%)
rename {libminifi => utils}/src/utils/ProcessCpuUsageTracker.cpp (100%)
rename {libminifi => utils}/src/utils/RegexUtils.cpp (100%)
rename {libminifi => utils}/src/utils/StoppableThread.cpp (100%)
rename {libminifi => utils}/src/utils/StringUtils.cpp (100%)
rename {libminifi => utils}/src/utils/SystemCpuUsageTracker.cpp (100%)
rename {libminifi => utils}/src/utils/ThreadPool.cpp (98%)
copy {libminifi => utils}/src/utils/TimeUtil.cpp (53%)
rename {libminifi => utils}/src/utils/crypto/EncryptionManager.cpp (72%)
rename {libminifi => utils}/src/utils/crypto/EncryptionProvider.cpp (100%)
rename {libminifi => utils}/src/utils/crypto/EncryptionUtils.cpp (100%)
rename {libminifi => utils}/src/utils/crypto/ciphers/Aes256Ecb.cpp (99%)
rename {libminifi =>
utils}/src/utils/crypto/property_encryption/PropertyEncryptionUtils.cpp (100%)
rename {libminifi => utils}/src/utils/file/FilePattern.cpp (99%)
rename {libminifi => utils}/src/utils/file/FileUtils.cpp (100%)
rename {libminifi => utils}/src/utils/file/PathUtils.cpp (100%)
rename {libminifi => utils}/src/utils/net/AsioSocketUtils.cpp (98%)
rename {libminifi => utils}/src/utils/net/DNS.cpp (100%)
rename {libminifi/src/utils => utils/src/utils/net}/NetworkInterfaceInfo.cpp
(98%)
rename {libminifi => utils}/src/utils/net/Socket.cpp (100%)
