You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by lo...@apache.org on 2026/04/30 11:24:45 UTC
(nifi-minifi-cpp) branch MINIFICPP-2644_aws_azure updated (e8fc1c87c -> 3e0e9e26f)
This is an automated email from the ASF dual-hosted git repository.
lordgamez pushed a change to branch MINIFICPP-2644_aws_azure
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git
omit e8fc1c87c Fix clang tidy issues
omit ab4bc9785 Remove old files
omit 8890e9fe6 Review update
omit 3328292db Fix after rebase
omit 1affabe2e Review update
omit 10c807bff Review update
omit bdfc7f9c3 Add HTTPS proxy support for AWS processors
omit e968c14af Review update
omit 89e041597 Fix after rebase
omit 8f2684a18 Review update
omit 109efea06 Clang tidy fix
omit af02930fc MINIFICPP-2644 Add proxy controller service support for AWS and Azure processors
add d44664ee5 MINIFICPP-2754 Update deprecated CI actions
add c92b0b884 MINIFICPP-2770 - Handle exceptions at usage side, add test
add 8e66eb334 MINIFICPP-2772 README.md img source has been moved
add 943be2eed MINIFICPP-2762 Replace AWS S3 client with AWS CRT S3 client (#2151)
add a3394382c MINIFICPP-2783 - Remove unused global (#2159)
add 521343b62 MINIFICPP-2771 Use separate state managers in schedule and trigger threads (#2157)
add 4263328d2 MINIFICPP-2788 Change corecomponentstate initialization log level to debug
add d182293a2 MINIFICPP-2752 - Register processors one-by-one
add 3813ee50c MINIFICPP-2785 Upgrade OpenSSL FIPS to 3.1.2 for FIPS 140-3 support
add 4d396eaf7 MINIFICPP-2760 Input/OutputStreamCallback should return std::expected
add f34d739bc MINIFICPP-2768 use gcc-toolset-14 on rocky
add 657ea2c59 MINIFICPP-2708 Controller Service C API
add a0e8376ce MINIFICPP-2718 Windows based docker tests
add b7ff503fd MINIFICPP-2782 - Remove resources from class loader on extension unload
add 307e1be5b MINIFICPP-2756 Rename minifi_test_framework to minifi_behave
add 302c1dad2 MINIFICPP-2644 Add proxy controller service support for AWS and Azure processors
add 263772897 Review update
add 6d46182d5 Fix after rebase
add a8b561a0f Review update
add 4f188f468 Add HTTPS proxy support for AWS processors
add 401a69c9b Review update
add c2b821882 Review update
add 02fc06fe3 Fix after rebase
add 136551394 Review update
add cdc16b63b Remove old files
add 4bf99196a Fix clang tidy issues
add c46f4b0aa Fix after rebase
add 6dadccbe4 Remove HTTPS proxy support
add 681645f1c Review update
add 1f752e0d2 Fix linter
add 3e0e9e26f Fix after rebase
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (e8fc1c87c)
\
N -- N -- N refs/heads/MINIFICPP-2644_aws_azure (3e0e9e26f)
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:
.asf.yaml | 9 +-
.github/workflows/ci.yml | 83 +-
.github/workflows/clear-actions-cache.yml | 2 +-
.github/workflows/compiler-support.yml | 12 +-
.github/workflows/create-release-artifacts.yml | 6 +-
.github/workflows/memcheck_ci.yml | 6 +-
.github/workflows/verify-package.yml | 11 +-
CMakeLists.txt | 10 -
Extensions.md | 49 +-
LICENSE | 28 -
NOTICE | 1 -
PROCESSORS.md | 218 +-
README.md | 12 +-
behave_framework/.gitignore | 2 +-
behave_framework/README.md | 71 +
behave_framework/pyproject.toml | 9 +-
.../containers/__init__.py | 0
.../containers/container_linux.py} | 45 +-
.../minifi_behave/containers/container_protocol.py | 62 +
.../minifi_behave/containers/container_windows.py | 396 +++
.../containers/directory.py | 0
.../containers/docker_image_builder.py | 0
.../containers/file.py | 0
.../containers/host_file.py | 0
.../containers/http_proxy_container.py | 23 +-
.../minifi_behave/containers/minifi_controller.py | 95 +
.../containers/minifi_linux_container.py | 147 ++
.../minifi_behave/containers/minifi_protocol.py | 53 +
.../containers/minifi_win_container.py | 73 +
.../containers/nifi_container.py | 25 +-
.../resources/minifi-controller/config.yml | 0
.../resources/nifi/convert_cert_to_jks.sh | 0
.../core/__init__.py | 0
.../core/helpers.py | 2 +-
.../core/hooks.py | 16 +-
.../core/minifi_test_context.py | 34 +-
.../src/minifi_behave/core/ssl_utils.py | 156 ++
.../minifi/__init__.py | 0
.../minifi/connection.py | 0
.../minifi/controller_service.py | 0
.../minifi/flow_definition.py | 0
.../minifi/funnel.py | 0
.../minifi/input_port.py | 0
.../minifi/minifi_flow_definition.py | 0
.../minifi/nifi_flow_definition.py | 0
.../minifi/output_port.py | 0
.../minifi/parameter.py | 0
.../minifi/parameter_context.py | 2 +-
.../minifi/processor.py | 0
.../minifi/remote_port.py | 0
.../minifi/remote_process_group.py | 0
.../steps/__init__.py | 0
.../steps/checking_steps.py | 6 +-
.../steps/configuration_steps.py | 14 +-
.../steps/core_steps.py | 10 +-
.../steps/flow_building_steps.py | 14 +-
.../containers/minifi_container.py | 233 --
.../src/minifi_test_framework/core/ssl_utils.py | 161 --
cmake/BundledAwsSdkCpp.cmake | 38 +-
cmake/BundledOpenSSL.cmake | 8 +-
cmake/Bustache.cmake | 7 +-
cmake/Coroutines.cmake | 22 -
cmake/Couchbase.cmake | 13 +-
cmake/CppVersion.cmake | 8 +-
cmake/DockerConfig.cmake | 4 +-
cmake/ExpectedLite.cmake | 28 -
cmake/Protobuf.cmake | 4 +-
cmake/fmt.cmake | 4 +-
controller/Controller.cpp | 12 +-
controller/Controller.h | 2 +-
controller/tests/ControllerTests.cpp | 2 +-
core-framework/CMakeLists.txt | 5 +-
core-framework/common/CMakeLists.txt | 5 +-
.../common/include/utils/OptionalUtils.h | 6 +-
core-framework/common/include/utils/ParsingUtils.h | 44 +-
core-framework/common/include/utils/StringUtils.h | 8 +-
.../utils/detail/MonadicOperationWrappers.h | 4 +-
core-framework/common/include/utils/expected.h | 62 +-
core-framework/common/src/utils/ParsingUtils.cpp | 38 +-
core-framework/common/src/utils/StringUtils.cpp | 4 +-
core-framework/include/agent/agent_docs.h | 13 +-
.../include/controllers/ProxyConfiguration.h | 7 +-
.../include/core/ConfigurableComponentImpl.h | 20 +-
.../core/controller/ControllerServiceBase.h | 10 +-
.../core/controller/ControllerServiceFactoryImpl.h | 4 +-
core-framework/include/http/HTTPCallback.h | 10 +-
core-framework/include/io/StreamPipe.h | 14 +-
core-framework/include/utils/ByteArrayCallback.h | 11 +-
core-framework/include/utils/JsonCallback.h | 21 +-
.../utils/LineByLineInputOutputStreamCallback.h | 2 +-
core-framework/include/utils/file/FileUtils.h | 6 +-
core-framework/include/utils/file/PathUtils.h | 12 +-
core-framework/include/utils/net/DNS.h | 6 +-
.../src/core/ConfigurableComponentImpl.cpp | 42 +-
core-framework/src/core/Property.cpp | 18 +-
core-framework/src/utils/Cron.cpp | 12 +-
.../utils/LineByLineInputOutputStreamCallback.cpp | 19 +-
core-framework/src/utils/file/FileUtils.cpp | 4 +-
core-framework/src/utils/net/DNS.cpp | 10 +-
docker/RunBehaveTests.sh | 21 +-
.../{installed.Dockerfile => Dockerfile.installed} | 0
.../installed/{rpm.Dockerfile => Dockerfile.rpm} | 0
docker/installed/Dockerfile.win | 42 +
docker/rockylinux/Dockerfile | 9 +-
extension-framework/CMakeLists.txt | 5 +-
.../include/api/core/ProcessContext.h | 6 +-
.../include/api/core/ProcessorImpl.h | 4 +-
.../cpp-extension-lib/src/core/ProcessContext.cpp | 4 +-
.../cpp-extension-lib/src/core/ProcessSession.cpp | 44 +-
.../controllers/keyvalue/KeyValueStateStorage.h | 4 +-
extension-framework/include/core/StateStorage.h | 6 +-
.../include/serialization/FlowFileSerializer.h | 4 +-
.../include/serialization/FlowFileV3Serializer.h | 2 +-
.../include/serialization/PayloadSerializer.h | 2 +-
.../include/utils/ExtensionInitUtils.h | 4 +-
.../include/utils/ListingStateManager.h | 6 +-
.../include/utils/file/FileReaderCallback.h | 2 +-
.../include/utils/file/FileWriterCallback.h | 2 +-
.../controllers/keyvalue/KeyValueStateStorage.cpp | 2 +-
.../src/serialization/FlowFileV3Serializer.cpp | 20 +-
.../src/serialization/PayloadSerializer.cpp | 2 +-
.../src/utils/file/FileReaderCallback.cpp | 8 +-
.../src/utils/file/FileWriterCallback.cpp | 6 +-
extensions/ExtensionInitializer.cpp | 10 +-
extensions/aws/AWSCredentialsProvider.h | 2 -
extensions/aws/AwsLoader.cpp | 66 +
extensions/aws/CMakeLists.txt | 5 +
.../aws/controllerservices/AWSCredentialsService.h | 2 -
extensions/aws/processors/AwsProcessor.cpp | 75 +-
extensions/aws/processors/AwsProcessor.h | 32 +-
extensions/aws/processors/DeleteS3Object.cpp | 23 +-
extensions/aws/processors/DeleteS3Object.h | 6 +-
extensions/aws/processors/FetchS3Object.cpp | 25 +-
extensions/aws/processors/FetchS3Object.h | 5 +-
extensions/aws/processors/ListS3.cpp | 42 +-
extensions/aws/processors/ListS3.h | 6 +-
extensions/aws/processors/PutKinesisStream.cpp | 34 +-
extensions/aws/processors/PutKinesisStream.h | 8 +-
extensions/aws/processors/PutS3Object.cpp | 61 +-
extensions/aws/processors/PutS3Object.h | 10 +-
extensions/aws/processors/S3Processor.cpp | 6 +-
extensions/aws/processors/S3Processor.h | 10 +-
extensions/aws/s3/MultipartUploadStateStorage.h | 4 +-
extensions/aws/s3/S3ClientRequestSender.cpp | 115 +-
extensions/aws/s3/S3ClientRequestSender.h | 78 +-
extensions/aws/s3/S3RequestSender.h | 114 +-
extensions/aws/s3/S3Wrapper.cpp | 87 +-
extensions/aws/s3/S3Wrapper.h | 169 +-
extensions/aws/tests/CMakeLists.txt | 2 +-
extensions/aws/tests/DeleteS3ObjectTests.cpp | 3 +-
extensions/aws/tests/FetchS3ObjectTests.cpp | 7 +-
extensions/aws/tests/ListS3Tests.cpp | 2 +-
extensions/aws/tests/MockS3RequestSender.h | 178 +-
.../aws/tests/MultipartUploadStateStorageTest.cpp | 6 +-
extensions/aws/tests/PutKinesisStreamTests.cpp | 2 +-
extensions/aws/tests/PutS3ObjectTests.cpp | 35 +-
extensions/aws/tests/S3TestsFixture.h | 94 +-
.../containers/kinesis_server_container.py | 10 +-
.../features/containers/s3_server_container.py | 8 +-
extensions/aws/tests/features/environment.py | 4 +-
extensions/aws/tests/features/s3.feature | 117 +-
extensions/aws/tests/features/steps/steps.py | 16 +-
extensions/aws/utils/AWSInitializer.cpp | 46 -
extensions/aws/utils/AWSInitializer.h | 48 -
.../azure/processors/AzureStorageProcessorBase.cpp | 3 +-
.../azure/processors/AzureStorageProcessorBase.h | 2 +-
.../azure/processors/FetchAzureBlobStorage.cpp | 6 +-
.../azure/processors/FetchAzureDataLakeStorage.cpp | 8 +-
.../azure/processors/ListAzureBlobStorage.cpp | 18 +-
extensions/azure/processors/ListAzureBlobStorage.h | 1 -
.../azure/processors/ListAzureDataLakeStorage.cpp | 18 +-
.../azure/processors/ListAzureDataLakeStorage.h | 1 -
extensions/azure/processors/PutAzureBlobStorage.h | 8 +-
.../azure/processors/PutAzureDataLakeStorage.cpp | 6 +-
.../azure/processors/PutAzureDataLakeStorage.h | 2 +-
extensions/azure/storage/AzureBlobStorage.cpp | 2 +-
.../azure/storage/AzureBlobStorageClient.cpp | 14 +-
extensions/azure/storage/AzureBlobStorageClient.h | 2 +-
extensions/azure/storage/AzureDataLakeStorage.cpp | 2 +-
.../azure/storage/AzureDataLakeStorageClient.cpp | 14 +-
.../azure/storage/AzureDataLakeStorageClient.h | 2 +-
extensions/azure/storage/BlobStorageClient.h | 2 +-
extensions/azure/storage/DataLakeStorageClient.h | 2 +-
.../azure/tests/ListAzureBlobStorageTests.cpp | 15 +-
.../azure/tests/ListAzureDataLakeStorageTests.cpp | 19 +-
.../azure/tests/PutAzureBlobStorageTests.cpp | 17 +-
.../azure/tests/PutAzureDataLakeStorageTests.cpp | 15 +-
.../azure/tests/features/azure_storage.feature | 7 +-
.../features/containers/azure_server_container.py | 10 +-
extensions/azure/tests/features/environment.py | 4 +-
extensions/azure/tests/features/steps/steps.py | 14 +-
extensions/bustache/ApplyTemplate.cpp | 4 +-
extensions/civetweb/processors/ListenHTTP.h | 4 +-
extensions/civetweb/tests/features/environment.py | 4 +-
extensions/civetweb/tests/features/steps/steps.py | 8 +-
extensions/couchbase/CMakeLists.txt | 15 +-
.../controllerservices/CouchbaseClusterService.cpp | 26 +-
.../controllerservices/CouchbaseClusterService.h | 12 +-
.../couchbase/processors/GetCouchbaseKey.cpp | 6 +-
extensions/couchbase/tests/CMakeLists.txt | 4 +
.../couchbase/tests/MockCouchbaseClusterService.h | 8 +-
.../containers/couchbase_server_container.py | 23 +-
extensions/couchbase/tests/features/environment.py | 6 +-
extensions/couchbase/tests/features/steps/steps.py | 16 +-
extensions/elasticsearch/PostElasticsearch.cpp | 24 +-
.../features/containers/elastic_base_container.py | 8 +-
.../features/containers/elasticsearch_container.py | 19 +-
.../features/containers/opensearch_container.py | 15 +-
.../elasticsearch/tests/features/environment.py | 4 +-
.../elasticsearch/tests/features/steps/steps.py | 14 +-
extensions/gcp/processors/FetchGCSObject.cpp | 8 +-
extensions/gcp/processors/PutGCSObject.cpp | 6 +-
.../containers/fake_gcs_server_container.py | 10 +-
extensions/gcp/tests/features/environment.py | 4 +-
extensions/gcp/tests/features/steps/steps.py | 12 +-
extensions/grafana-loki/PushGrafanaLoki.cpp | 17 +-
extensions/grafana-loki/PushGrafanaLoki.h | 6 +-
extensions/grafana-loki/PushGrafanaLokiGrpc.cpp | 6 +-
extensions/grafana-loki/PushGrafanaLokiGrpc.h | 2 +-
extensions/grafana-loki/PushGrafanaLokiREST.cpp | 6 +-
extensions/grafana-loki/PushGrafanaLokiREST.h | 2 +-
.../features/containers/grafana_loki_container.py | 19 +-
.../features/containers/reverse_proxy_container.py | 8 +-
.../grafana-loki/tests/features/environment.py | 6 +-
.../grafana-loki/tests/features/steps/steps.py | 12 +-
extensions/kafka/PublishKafka.cpp | 10 +-
.../features/containers/kafka_server_container.py | 19 +-
extensions/kafka/tests/features/environment.py | 6 +-
extensions/kafka/tests/features/steps/steps.py | 12 +-
extensions/kubernetes/MetricsApi.cpp | 4 +-
extensions/kubernetes/MetricsApi.h | 2 +-
extensions/kubernetes/MetricsFilter.cpp | 8 +-
extensions/kubernetes/MetricsFilter.h | 2 +-
.../kubernetes/tests/features/environment.py | 2 +-
.../steps/minifi_as_pod_in_kubernetes_cluster.py | 4 +-
.../kubernetes/tests/features/steps/steps.py | 16 +-
extensions/libarchive/CompressContent.cpp | 18 +-
extensions/libarchive/CompressContent.h | 12 +-
extensions/libarchive/FocusArchiveEntry.cpp | 15 +-
extensions/libarchive/FocusArchiveEntry.h | 2 +-
extensions/libarchive/MergeContent.cpp | 4 +-
extensions/libarchive/MergeContent.h | 42 +-
extensions/libarchive/UnfocusArchiveEntry.cpp | 4 +-
extensions/libarchive/UnfocusArchiveEntry.h | 2 +-
.../libarchive/tests/CompressContentTests.cpp | 8 +-
extensions/libarchive/tests/MergeFileTests.cpp | 14 +-
.../llamacpp/processors/DefaultLlamaContext.cpp | 8 +-
.../llamacpp/processors/DefaultLlamaContext.h | 2 +-
.../llamacpp/processors/ExtensionInitializer.cpp | 19 +-
extensions/llamacpp/processors/LlamaContext.h | 2 +-
.../llamacpp/tests/RunLlamaCppInferenceTests.cpp | 4 +-
extensions/llamacpp/tests/features/environment.py | 10 +-
extensions/llamacpp/tests/features/steps/steps.py | 8 +-
extensions/lua/LuaProcessSession.cpp | 12 +-
extensions/lua/LuaScriptProcessContext.cpp | 1 -
extensions/lua/LuaScriptProcessContext.h | 5 +-
extensions/lua/tests/features/environment.py | 4 +-
extensions/lua/tests/features/steps/steps.py | 8 +-
extensions/mqtt/processors/ConsumeMQTT.cpp | 10 +-
extensions/mqtt/processors/ConsumeMQTT.h | 2 +-
extensions/mqtt/processors/PublishMQTT.cpp | 6 +-
.../features/containers/mqtt_broker_container.py | 10 +-
extensions/mqtt/tests/features/environment.py | 6 +-
extensions/mqtt/tests/features/steps/steps.py | 14 +-
extensions/opc/include/fetchopc.h | 1 -
extensions/opc/include/putopc.h | 2 +-
extensions/opc/src/fetchopc.cpp | 10 +-
extensions/opc/src/putopc.cpp | 24 +-
.../features/containers/opc_ua_server_container.py | 8 +-
extensions/opc/tests/features/environment.py | 4 +-
extensions/opc/tests/features/steps/steps.py | 12 +-
extensions/opencv/CaptureRTSPFrame.cpp | 4 +-
extensions/opencv/MotionDetector.cpp | 10 +-
extensions/opencv/OpenCVLoader.cpp | 10 +-
.../features/containers/prometheus_container.py | 20 +-
.../prometheus/tests/features/environment.py | 6 +-
.../prometheus/tests/features/steps/steps.py | 12 +-
extensions/python/PythonBindings.cpp | 4 +-
extensions/python/PythonBindings.h | 18 +-
.../python/pythonlibloader/PythonLibLoader.cpp | 12 +-
extensions/python/pythonloader/PyProcLoader.cpp | 12 +-
.../TestExecuteScriptProcessorWithPythonScript.cpp | 30 +
extensions/python/tests/features/environment.py | 6 +-
extensions/python/tests/features/steps/steps.py | 12 +-
extensions/python/types/PyDataConverter.cpp | 4 -
extensions/python/types/PyInputStream.cpp | 4 +-
extensions/python/types/PyLogger.cpp | 20 +-
extensions/python/types/PyOutputStream.cpp | 4 +-
extensions/python/types/PyProcessContext.cpp | 40 +-
extensions/python/types/PyProcessSession.cpp | 52 +-
extensions/python/types/PyProcessor.cpp | 16 +-
extensions/python/types/PyRecordSetReader.cpp | 8 +-
extensions/python/types/PyRecordSetWriter.cpp | 4 +-
extensions/python/types/PyRelationship.cpp | 8 +-
extensions/python/types/PySSLContextService.cpp | 16 +-
extensions/python/types/PyScriptFlowFile.cpp | 28 +-
extensions/python/types/PyStateManager.cpp | 16 +-
extensions/rocksdb-repos/FlowFileLoader.cpp | 2 +-
.../controllers/RocksDbStateStorage.cpp | 2 +-
extensions/rocksdb-repos/tests/RepoTests.cpp | 2 +-
extensions/rocksdb-repos/tests/SwapTests.cpp | 13 +-
extensions/sftp/SFTPLoader.cpp | 10 +-
extensions/sftp/processors/FetchSFTP.cpp | 4 +-
extensions/sftp/processors/ListSFTP.cpp | 37 +-
extensions/sftp/processors/ListSFTP.h | 9 +-
extensions/sftp/processors/PutSFTP.cpp | 2 +-
extensions/sftp/tests/ListSFTPTests.cpp | 16 +-
extensions/smb/ListSmb.cpp | 18 +-
extensions/smb/ListSmb.h | 1 -
extensions/smb/SmbConnectionControllerService.cpp | 8 +-
extensions/smb/SmbConnectionControllerService.h | 4 +-
.../utils/MockSmbConnectionControllerService.h | 6 +-
extensions/smb/tests/utils/TempSmbShare.h | 4 +-
.../tests/features/containers/splunk_container.py | 19 +-
extensions/splunk/tests/features/environment.py | 4 +-
extensions/splunk/tests/features/steps/steps.py | 12 +-
extensions/sql/CMakeLists.txt | 2 +-
extensions/sql/processors/QueryDatabaseTable.cpp | 24 +-
extensions/sql/processors/QueryDatabaseTable.h | 3 +-
.../containers/postgress_server_container.py | 10 +-
extensions/sql/tests/features/environment.py | 8 +-
extensions/sql/tests/features/steps/steps.py | 14 +-
extensions/standard-processors/CMakeLists.txt | 2 -
.../controllers/JsonRecordSetWriter.cpp | 8 +-
.../controllers/JsonTreeReader.cpp | 24 +-
.../controllers/JsonTreeReader.h | 2 +-
.../standard-processors/controllers/XMLReader.cpp | 4 +-
.../standard-processors/controllers/XMLReader.h | 2 +-
.../controllers/XMLRecordSetWriter.cpp | 4 +-
.../standard-processors/modbus/FetchModbusTcp.cpp | 28 +-
.../standard-processors/modbus/FetchModbusTcp.h | 6 +-
.../modbus/ReadModbusFunctions.cpp | 14 +-
.../modbus/ReadModbusFunctions.h | 10 +-
.../processors/ConvertRecord.cpp | 9 +-
.../processors/DefragmentText.cpp | 6 +-
.../processors/EvaluateJsonPath.cpp | 4 +-
.../standard-processors/processors/ExtractText.cpp | 8 +-
.../standard-processors/processors/ExtractText.h | 2 +-
.../standard-processors/processors/HashContent.cpp | 5 +-
.../standard-processors/processors/InvokeHTTP.cpp | 6 +-
.../standard-processors/processors/InvokeHTTP.h | 2 +-
.../standard-processors/processors/ListFile.cpp | 17 +-
.../standard-processors/processors/ListFile.h | 1 -
.../standard-processors/processors/PutUDP.cpp | 8 +-
.../standard-processors/processors/RouteText.cpp | 8 +-
.../standard-processors/processors/SplitJson.cpp | 4 +-
.../standard-processors/processors/SplitRecord.cpp | 11 +-
.../standard-processors/processors/SplitRecord.h | 2 +-
.../standard-processors/processors/SplitText.cpp | 45 +-
.../standard-processors/processors/TailFile.cpp | 45 +-
.../standard-processors/processors/TailFile.h | 10 +-
.../standard-processors/tests/CMakeLists.txt | 2 -
.../features/containers/diag_slave_container.py | 10 +-
.../tests/features/containers/syslog_container.py | 4 +-
.../features/containers/tcp_client_container.py | 8 +-
.../tests/features/core_functionality.feature | 2 +-
.../tests/features/environment.py | 9 +-
.../tests/features/replace_text.feature | 2 +-
.../features/steps/minifi_c2_server_container.py | 26 +-
.../features/steps/minifi_controller_steps.py | 32 +-
.../tests/features/steps/steps.py | 16 +-
.../tests/integration/InvokeHTTPTests.cpp | 4 +-
.../tests/unit/ProcessorTests.cpp | 10 +-
.../tests/unit/TailFileTests.cpp | 10 +-
.../tests/unit/XMLRecordSetWriterTests.cpp | 15 +-
extensions/standard-processors/utils/JoltUtils.cpp | 88 +-
extensions/standard-processors/utils/JoltUtils.h | 14 +-
extensions/systemd/ConsumeJournald.cpp | 11 +-
extensions/systemd/ConsumeJournald.h | 1 -
extensions/systemd/tests/ConsumeJournaldTest.cpp | 8 +-
.../windows-event-log/ConsumeWindowsEventLog.cpp | 52 +-
.../windows-event-log/ConsumeWindowsEventLog.h | 9 +-
.../windows-event-log/tests/BookmarkTests.cpp | 22 +-
extensions/windows-event-log/wel/Bookmark.cpp | 10 +-
extensions/windows-event-log/wel/Bookmark.h | 3 +-
.../windows-event-log/wel/WindowsEventLog.cpp | 8 +-
extensions/windows-event-log/wel/WindowsEventLog.h | 2 +-
libminifi/CMakeLists.txt | 5 +-
libminifi/include/FlowController.h | 4 +-
libminifi/include/SchedulingAgent.h | 4 +-
libminifi/include/c2/C2Utils.h | 2 +-
libminifi/include/c2/FlowStatusBuilder.h | 8 +-
libminifi/include/c2/PayloadSerializer.h | 2 +-
.../controllers/NetworkPrioritizerService.h | 2 +-
.../controllers/ProxyConfigurationService.h | 11 +-
libminifi/include/core/ProcessContextImpl.h | 32 +-
libminifi/include/core/ProcessSession.h | 4 +-
.../include/core/ProcessSessionReadCallback.h | 2 +-
.../include/core/controller/ControllerService.h | 17 +-
libminifi/include/core/extension/Extension.h | 16 +-
.../include/core/extension/ExtensionManager.h | 2 -
libminifi/include/core/flow/Node.h | 2 +-
libminifi/include/core/state/UpdateController.h | 2 +-
.../include/core/state/nodes/ResponseNodeLoader.h | 2 +-
libminifi/include/utils/CControllerService.h | 114 +
libminifi/include/utils/CProcessor.h | 9 +-
libminifi/include/utils/file/AssetManager.h | 4 +-
libminifi/src/FlowController.cpp | 12 +-
libminifi/src/SchedulingAgent.cpp | 12 +-
libminifi/src/ThreadedSchedulingAgent.cpp | 10 +-
libminifi/src/c2/C2Agent.cpp | 20 +-
libminifi/src/c2/C2Utils.cpp | 14 +-
libminifi/src/c2/FlowStatusBuilder.cpp | 26 +-
.../src/controllers/ProxyConfigurationService.cpp | 9 +-
libminifi/src/controllers/SSLContextService.cpp | 2 +-
libminifi/src/core/ProcessContextImpl.cpp | 43 +-
libminifi/src/core/ProcessSession.cpp | 55 +-
libminifi/src/core/ProcessSessionFactory.cpp | 1 +
libminifi/src/core/ProcessSessionReadCallback.cpp | 8 +-
libminifi/src/core/extension/Extension.cpp | 31 +-
libminifi/src/core/extension/ExtensionManager.cpp | 12 -
.../src/core/state/nodes/ResponseNodeLoader.cpp | 4 +-
libminifi/src/minifi-c.cpp | 210 +-
.../src/sitetosite/CompressionOutputStream.cpp | 23 +-
libminifi/src/sitetosite/SiteToSiteClient.cpp | 28 +-
libminifi/src/utils/file/AssetManager.cpp | 6 +-
libminifi/test/flow-tests/SessionTests.cpp | 2 +-
.../extension-verification-test/CApiExtension.cpp | 29 +-
.../extension-verification-test/CMakeLists.txt | 13 +-
.../CppApiExtension.cpp | 10 +-
.../CreateNotCalled.cpp | 2 +-
.../ExtensionLoadingTests.cpp | 54 +
.../ExtensionVerificationTests.cpp | 8 +-
.../extension-verification-test/dummy-cpp-api.def | 4 +-
libminifi/test/libtest/integration/HTTPHandlers.h | 13 +-
.../libtest/unit/ContentRepositoryDependentTests.h | 18 +-
.../test/libtest/unit/ControllerServiceUtils.h | 2 +-
libminifi/test/libtest/unit/ProvenanceTestHelper.h | 2 +
libminifi/test/libtest/unit/StatefulProcessor.cpp | 12 +-
libminifi/test/libtest/unit/StatefulProcessor.h | 1 -
libminifi/test/libtest/unit/TestBase.cpp | 4 +-
libminifi/test/libtest/unit/TestBase.h | 4 +-
.../test/persistence-tests/PersistenceTests.cpp | 6 +-
libminifi/test/unit/ExpectedTest.cpp | 177 +-
libminifi/test/unit/FlowFileSerializationTests.cpp | 4 +-
libminifi/test/unit/MetricsTests.cpp | 12 +-
.../test/unit/NetworkPrioritizerServiceTests.cpp | 2 +-
libminifi/test/unit/OptionalTest.cpp | 8 +-
libminifi/test/unit/ParsingUtilsTests.cpp | 22 +-
libminifi/test/unit/ProcessorConfigUtilsTests.cpp | 4 +-
.../test/unit/ProxyConfigurationServiceTests.cpp | 9 +-
libminifi/test/unit/SchedulingAgentTests.cpp | 2 +-
libminifi/test/unit/SiteToSiteTests.cpp | 2 +-
minifi-api/CMakeLists.txt | 2 +-
.../minifi-cpp/core}/ControllerServiceMetadata.h | 6 +-
.../common/include/minifi-cpp/io/StreamCallback.h | 103 +-
minifi-api/include/minifi-c/minifi-c.h | 60 +-
minifi-api/include/minifi-cpp/agent/agent_docs.h | 4 +-
.../ProxyConfigurationServiceInterface.h | 14 +-
.../minifi-cpp/controllers/RecordSetReader.h | 6 +-
.../minifi-cpp/controllers/RecordSetWriter.h | 4 +-
.../controllers/SSLContextServiceInterface.h | 7 +-
.../minifi-cpp/core/ConfigurableComponent.h | 20 +-
...trollerServiceApi.h => ControllerServiceType.h} | 6 +-
...inition.h => ControllerServiceTypeDefinition.h} | 2 +-
.../include/minifi-cpp/core/ProcessContext.h | 33 +-
.../include/minifi-cpp/core/ProcessSession.h | 2 +-
minifi-api/include/minifi-cpp/core/Property.h | 10 +-
minifi-api/include/minifi-cpp/core/StateStorage.h | 4 +-
.../core/controller/ControllerServiceContext.h | 4 +-
.../core/controller/ControllerServiceDescriptor.h | 1 +
.../core/controller/ControllerServiceFactory.h | 5 +-
minifi-api/minifi-c-api.def | 6 +-
thirdparty/aws-sdk-cpp/bundle-openssl.patch | 24 +-
thirdparty/aws-sdk-cpp/cpp23-cstdint.patch | 11 -
thirdparty/aws-sdk-cpp/dll-export-injection.patch | 248 +-
.../fix-deprecated-literal-operator.patch | 31 -
thirdparty/aws-sdk-cpp/shutdown-fix.patch | 13 -
thirdparty/bustache/remove_installs.patch | 49 +
thirdparty/couchbase/remove-debug-symbols.patch | 12 -
thirdparty/couchbase/remove-thirdparty-1.0.2.patch | 172 --
thirdparty/couchbase/remove-thirdparty.patch | 218 +-
.../couchbase/use_fmt_instead_of_spdlog_fmt.patch | 2641 ++++++++++++++++++++
.../libstdc++/avoid_bogus_Wrestrict_PR105651.patch | 32 -
474 files changed, 7344 insertions(+), 4286 deletions(-)
create mode 100644 behave_framework/README.md
rename behave_framework/src/{minifi_test_framework => minifi_behave}/containers/__init__.py (100%)
rename behave_framework/src/{minifi_test_framework/containers/container.py => minifi_behave/containers/container_linux.py} (92%)
create mode 100644 behave_framework/src/minifi_behave/containers/container_protocol.py
create mode 100644 behave_framework/src/minifi_behave/containers/container_windows.py
rename behave_framework/src/{minifi_test_framework => minifi_behave}/containers/directory.py (100%)
rename behave_framework/src/{minifi_test_framework => minifi_behave}/containers/docker_image_builder.py (100%)
rename behave_framework/src/{minifi_test_framework => minifi_behave}/containers/file.py (100%)
rename behave_framework/src/{minifi_test_framework => minifi_behave}/containers/host_file.py (100%)
rename behave_framework/src/{minifi_test_framework => minifi_behave}/containers/http_proxy_container.py (85%)
create mode 100644 behave_framework/src/minifi_behave/containers/minifi_controller.py
create mode 100644 behave_framework/src/minifi_behave/containers/minifi_linux_container.py
create mode 100644 behave_framework/src/minifi_behave/containers/minifi_protocol.py
create mode 100644 behave_framework/src/minifi_behave/containers/minifi_win_container.py
rename behave_framework/src/{minifi_test_framework => minifi_behave}/containers/nifi_container.py (87%)
rename behave_framework/src/{minifi_test_framework => minifi_behave}/containers/resources/minifi-controller/config.yml (100%)
rename behave_framework/src/{minifi_test_framework => minifi_behave}/containers/resources/nifi/convert_cert_to_jks.sh (100%)
rename behave_framework/src/{minifi_test_framework => minifi_behave}/core/__init__.py (100%)
rename behave_framework/src/{minifi_test_framework => minifi_behave}/core/helpers.py (98%)
rename behave_framework/src/{minifi_test_framework => minifi_behave}/core/hooks.py (89%)
rename behave_framework/src/{minifi_test_framework => minifi_behave}/core/minifi_test_context.py (52%)
create mode 100644 behave_framework/src/minifi_behave/core/ssl_utils.py
rename behave_framework/src/{minifi_test_framework => minifi_behave}/minifi/__init__.py (100%)
rename behave_framework/src/{minifi_test_framework => minifi_behave}/minifi/connection.py (100%)
rename behave_framework/src/{minifi_test_framework => minifi_behave}/minifi/controller_service.py (100%)
rename behave_framework/src/{minifi_test_framework => minifi_behave}/minifi/flow_definition.py (100%)
rename behave_framework/src/{minifi_test_framework => minifi_behave}/minifi/funnel.py (100%)
rename behave_framework/src/{minifi_test_framework => minifi_behave}/minifi/input_port.py (100%)
rename behave_framework/src/{minifi_test_framework => minifi_behave}/minifi/minifi_flow_definition.py (100%)
rename behave_framework/src/{minifi_test_framework => minifi_behave}/minifi/nifi_flow_definition.py (100%)
rename behave_framework/src/{minifi_test_framework => minifi_behave}/minifi/output_port.py (100%)
rename behave_framework/src/{minifi_test_framework => minifi_behave}/minifi/parameter.py (100%)
rename behave_framework/src/{minifi_test_framework => minifi_behave}/minifi/parameter_context.py (95%)
rename behave_framework/src/{minifi_test_framework => minifi_behave}/minifi/processor.py (100%)
rename behave_framework/src/{minifi_test_framework => minifi_behave}/minifi/remote_port.py (100%)
rename behave_framework/src/{minifi_test_framework => minifi_behave}/minifi/remote_process_group.py (100%)
rename behave_framework/src/{minifi_test_framework => minifi_behave}/steps/__init__.py (100%)
rename behave_framework/src/{minifi_test_framework => minifi_behave}/steps/checking_steps.py (98%)
rename behave_framework/src/{minifi_test_framework => minifi_behave}/steps/configuration_steps.py (72%)
rename behave_framework/src/{minifi_test_framework => minifi_behave}/steps/core_steps.py (95%)
rename behave_framework/src/{minifi_test_framework => minifi_behave}/steps/flow_building_steps.py (98%)
delete mode 100644 behave_framework/src/minifi_test_framework/containers/minifi_container.py
delete mode 100644 behave_framework/src/minifi_test_framework/core/ssl_utils.py
delete mode 100644 cmake/Coroutines.cmake
delete mode 100644 cmake/ExpectedLite.cmake
rename docker/installed/{installed.Dockerfile => Dockerfile.installed} (100%)
rename docker/installed/{rpm.Dockerfile => Dockerfile.rpm} (100%)
create mode 100644 docker/installed/Dockerfile.win
create mode 100644 extensions/aws/AwsLoader.cpp
delete mode 100755 extensions/aws/utils/AWSInitializer.cpp
delete mode 100755 extensions/aws/utils/AWSInitializer.h
create mode 100644 libminifi/include/utils/CControllerService.h
create mode 100644 libminifi/test/integration/extension-verification-test/ExtensionLoadingTests.cpp
rename minifi-api/{include/minifi-cpp/core/controller => common/include/minifi-cpp/core}/ControllerServiceMetadata.h (84%)
rename minifi-api/include/minifi-cpp/core/{ControllerServiceApi.h => ControllerServiceType.h} (84%)
rename minifi-api/include/minifi-cpp/core/{ControllerServiceApiDefinition.h => ControllerServiceTypeDefinition.h} (96%)
delete mode 100644 thirdparty/aws-sdk-cpp/cpp23-cstdint.patch
delete mode 100644 thirdparty/aws-sdk-cpp/fix-deprecated-literal-operator.patch
delete mode 100644 thirdparty/aws-sdk-cpp/shutdown-fix.patch
create mode 100644 thirdparty/bustache/remove_installs.patch
delete mode 100644 thirdparty/couchbase/remove-debug-symbols.patch
delete mode 100644 thirdparty/couchbase/remove-thirdparty-1.0.2.patch
create mode 100644 thirdparty/couchbase/use_fmt_instead_of_spdlog_fmt.patch
delete mode 100644 thirdparty/libstdc++/avoid_bogus_Wrestrict_PR105651.patch