This is an automated email from the ASF dual-hosted git repository.
martinzink pushed a change to branch gcp_to_c_api
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git
omit 95d8bdf42 fix typo
omit 91fb2d3a6 move llamacpp to use registerProcessors
omit 508cfaefd registerProcessors and registerControllerServices
omit f1bbb0182 MINIFICPP-2765 Move GCP Extension to stable C API
omit ac458cfca MINIFICPP-2764 Controller Service CPP API
omit f7eea48c0 MINIFICPP-2708 Controller Service C API
omit be71b24b6 MINIFICPP-2752 - Update readme
omit 6a14f159f MINIFICPP-2752 - Register processors one-by-one
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 4f183c148 MINIFICPP-2644 Add proxy controller service support for AWS
and Azure processors (#2045)
add adac07667 Bump cryptography from 46.0.5 to 46.0.7 in /behave_framework
(#2165)
add 8cd8464d6 MINIFICPP-2644 Add proxy controller service support for GCP
processors (#2112)
add d9910d094 MINIFICPP-2796 Remove workIsAvailable from C API (#2164)
add bab842032 MINIFICPP-2797 Extend C Api with sslcontext, penalize,
dynamic properties, flowfile id and size #2166
add f2d1f88a2 MINIFICPP-2764 Controller Service CPP API #2152
add 5b9fc3396 MINIFICPP-2798 Mock library for C extensions
add 9debeb4ce MINIFICPP-2765 Move GCP Extension to stable C API
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 (95d8bdf42)
\
N -- N -- N refs/heads/gcp_to_c_api (9debeb4ce)
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 -
CONTROLLERS.md | 20 +
Extensions.md | 38 +-
LICENSE | 28 -
NOTICE | 1 -
PROCESSORS.md | 226 +-
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} | 49 +-
.../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 | 35 +-
.../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 | 34 +-
.../containers/minifi_container.py | 231 --
.../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 +-
.../include/core/PropertyDefinitionBuilder.h | 22 +-
.../{ => common}/include/utils/AttributeErrors.h | 0
.../common/include/utils/OptionalUtils.h | 6 +-
core-framework/common/include/utils/ParsingUtils.h | 44 +-
.../{ => common}/include/utils/RegexUtils.h | 0
core-framework/common/include/utils/StringUtils.h | 8 +-
.../utils/detail/MonadicOperationWrappers.h | 4 +-
core-framework/common/include/utils/expected.h | 62 +-
.../common}/src/utils/AttributeErrors.cpp | 0
core-framework/common/src/utils/ParsingUtils.cpp | 38 +-
.../{ => common}/src/utils/RegexUtils.cpp | 0
core-framework/common/src/utils/StringUtils.cpp | 4 +-
.../include/controllers/ProxyConfiguration.h | 14 +-
.../include/core/ConfigurableComponentImpl.h | 20 +-
.../core/controller/ControllerServiceBase.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 +-
.../cpp-extension-lib/CMakeLists.txt | 2 +-
.../include/api/core/ControllerServiceContext.h | 6 +-
.../include/api/core/ControllerServiceImpl.h | 6 +-
.../include/api/core/ProcessContext.h | 48 +-
.../include/api/core/ProcessSession.h | 55 +-
.../include/api/core/ProcessorImpl.h | 2 -
.../cpp-extension-lib/include/api/core/Resource.h | 57 +-
.../include/api/core/logging/Logger.h | 5 +-
.../include/api/utils/ProcessorConfigUtils.h | 34 +-
.../cpp-extension-lib/include/api/utils/Proxy.h | 25 +-
.../include/api/utils}/Ssl.h | 13 +-
.../include/api/utils/minifi-c-utils.h | 22 +-
.../libtest/CProcessorTestUtils.h | 8 +-
.../cpp-extension-lib/mocklib}/CMakeLists.txt | 8 +-
.../Logger.h => mocklib/include/MockLogger.h} | 28 +-
.../mocklib/include/MockProcessContext.h | 46 +
.../mocklib/include/MockProcessSession.h | 82 +
.../mocklib/include/MockStreams.h | 97 +
.../cpp-extension-lib/mocklib/include/MockUtils.h | 25 +-
.../mocklib/src/MockProcessContext.cpp | 50 +
.../mocklib/src/MockProcessSession.cpp | 110 +
.../mocklib/src/mock-minifi-c.cpp | 135 +
.../src/core/ControllerServiceContext.cpp | 8 +-
.../src/core/ControllerServiceImpl.cpp | 4 +-
.../cpp-extension-lib/src/core/ProcessContext.cpp | 103 +-
.../cpp-extension-lib/src/core/ProcessSession.cpp | 96 +-
.../cpp-extension-lib/src/core/ProcessorImpl.cpp | 4 -
.../cpp-extension-lib/src/core/logging/Logger.cpp | 8 +-
.../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 | 4 +-
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 | 83 +-
extensions/aws/processors/AwsProcessor.h | 49 +-
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 | 161 +-
extensions/aws/tests/CMakeLists.txt | 2 +-
extensions/aws/tests/DeleteS3ObjectTests.cpp | 10 +-
extensions/aws/tests/FetchS3ObjectTests.cpp | 14 +-
extensions/aws/tests/ListS3Tests.cpp | 20 +-
extensions/aws/tests/MockS3RequestSender.h | 178 +-
.../aws/tests/MultipartUploadStateStorageTest.cpp | 4 +-
extensions/aws/tests/PutKinesisStreamTests.cpp | 2 +-
extensions/aws/tests/PutS3ObjectTests.cpp | 53 +-
extensions/aws/tests/S3TestsFixture.h | 78 +-
.../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 | 164 +-
extensions/aws/tests/features/steps/steps.py | 16 +-
extensions/aws/utils/AWSInitializer.cpp | 46 -
extensions/aws/utils/AWSInitializer.h | 48 -
.../processors/AzureBlobStorageProcessorBase.cpp | 5 +-
.../AzureDataLakeStorageProcessorBase.cpp | 4 +-
.../processors/AzureDataLakeStorageProcessorBase.h | 2 +-
.../azure/processors/AzureStorageProcessorBase.cpp | 14 +
.../azure/processors/AzureStorageProcessorBase.h | 13 +-
.../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 | 31 +-
extensions/azure/storage/AzureBlobStorageClient.h | 3 +-
extensions/azure/storage/AzureDataLakeStorage.cpp | 2 +-
.../azure/storage/AzureDataLakeStorageClient.cpp | 17 +-
.../azure/storage/AzureDataLakeStorageClient.h | 4 +-
extensions/azure/storage/BlobStorageClient.h | 3 +
extensions/azure/storage/DataLakeStorageClient.h | 3 +
.../azure/tests/ListAzureBlobStorageTests.cpp | 24 +
.../azure/tests/ListAzureDataLakeStorageTests.cpp | 20 +
.../azure/tests/PutAzureBlobStorageTests.cpp | 23 +
.../azure/tests/PutAzureDataLakeStorageTests.cpp | 21 +
.../azure/tests/features/azure_storage.feature | 85 +
.../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/ExtensionInitializer.cpp | 12 +-
extensions/gcp/processors/FetchGCSObject.cpp | 10 +-
extensions/gcp/processors/GCSProcessor.cpp | 35 +-
extensions/gcp/processors/GCSProcessor.h | 8 +-
extensions/gcp/processors/PutGCSObject.cpp | 8 +-
.../containers/fake_gcs_server_container.py | 10 +-
extensions/gcp/tests/features/environment.py | 4 +-
.../tests/features/google_cloud_storage.feature | 139 +-
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 +-
extensions/llamacpp/ExtensionInitializer.cpp | 8 +-
.../llamacpp/processors/DefaultLlamaContext.cpp | 8 +-
.../llamacpp/processors/DefaultLlamaContext.h | 2 +-
extensions/llamacpp/processors/LlamaContext.h | 2 +-
.../llamacpp/processors/RunLlamaCppInference.cpp | 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 | 4 +-
.../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 | 4 +-
extensions/python/pythonloader/PyProcLoader.cpp | 4 +-
.../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 | 4 +-
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/ProxyConfigurationService.h | 100 +
libminifi/include/core/ProcessContextImpl.h | 32 +-
libminifi/include/core/ProcessSession.h | 4 +-
.../include/core/ProcessSessionReadCallback.h | 2 +-
.../include/core/controller/ControllerService.h | 8 +-
libminifi/include/core/extension/Extension.h | 9 +-
.../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 | 6 +-
libminifi/include/utils/CProcessor.h | 5 +-
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 | 51 +
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 | 6 +
libminifi/src/core/extension/ExtensionManager.cpp | 12 -
.../src/core/state/nodes/ResponseNodeLoader.cpp | 4 +-
libminifi/src/minifi-c.cpp | 170 +-
.../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 | 27 +-
.../extension-verification-test/CMakeLists.txt | 13 +-
.../CppApiExtension.cpp | 4 +-
.../CreateNotCalled.cpp | 2 +-
.../ExtensionLoadingTests.cpp | 54 +
.../ExtensionVerificationTests.cpp | 8 +-
.../extension-verification-test/dummy-cpp-api.def | 4 +-
.../libtest/unit/ContentRepositoryDependentTests.h | 18 +-
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 +-
libminifi/test/unit/OptionalTest.cpp | 8 +-
libminifi/test/unit/ParsingUtilsTests.cpp | 22 +-
libminifi/test/unit/ProcessorConfigUtilsTests.cpp | 4 +-
.../test/unit/ProxyConfigurationServiceTests.cpp | 66 +
libminifi/test/unit/SchedulingAgentTests.cpp | 2 +-
libminifi/test/unit/SiteToSiteTests.cpp | 2 +-
minifi-api/CMakeLists.txt | 2 +-
.../common/include/minifi-cpp/io/StreamCallback.h | 103 +-
minifi-api/include/minifi-c/minifi-c.h | 72 +-
...iter.h => ProxyConfigurationServiceInterface.h} | 32 +-
.../minifi-cpp/controllers/RecordSetReader.h | 2 +-
.../minifi-cpp/core/ConfigurableComponent.h | 20 +-
.../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 +-
minifi-api/minifi-c-api.def | 13 +-
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 -
497 files changed, 8830 insertions(+), 4259 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} (91%)
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 (61%)
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 (92%)
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 core-framework/{ => common}/include/utils/AttributeErrors.h (100%)
rename core-framework/{ => common}/include/utils/RegexUtils.h (100%)
rename {libminifi => core-framework/common}/src/utils/AttributeErrors.cpp
(100%)
rename core-framework/{ => common}/src/utils/RegexUtils.cpp (100%)
copy minifi-api/include/minifi-cpp/controllers/keyvalue/KeyValueStateStorage.h
=> core-framework/include/controllers/ProxyConfiguration.h (75%)
rename docker/installed/{installed.Dockerfile => Dockerfile.installed} (100%)
rename docker/installed/{rpm.Dockerfile => Dockerfile.rpm} (100%)
create mode 100644 docker/installed/Dockerfile.win
rename extensions/aws/utils/ProxyOptions.h =>
extension-framework/cpp-extension-lib/include/api/utils/Proxy.h (66%)
copy extension-framework/{include/utils/net =>
cpp-extension-lib/include/api/utils}/Ssl.h (74%)
copy {libminifi/test/libtest =>
extension-framework/cpp-extension-lib/mocklib}/CMakeLists.txt (74%)
copy extension-framework/cpp-extension-lib/{include/api/core/logging/Logger.h
=> mocklib/include/MockLogger.h} (57%)
create mode 100644
extension-framework/cpp-extension-lib/mocklib/include/MockProcessContext.h
create mode 100644
extension-framework/cpp-extension-lib/mocklib/include/MockProcessSession.h
create mode 100644
extension-framework/cpp-extension-lib/mocklib/include/MockStreams.h
copy minifi-api/include/minifi-cpp/core/ProcessorFactory.h =>
extension-framework/cpp-extension-lib/mocklib/include/MockUtils.h (62%)
create mode 100644
extension-framework/cpp-extension-lib/mocklib/src/MockProcessContext.cpp
create mode 100644
extension-framework/cpp-extension-lib/mocklib/src/MockProcessSession.cpp
create mode 100644
extension-framework/cpp-extension-lib/mocklib/src/mock-minifi-c.cpp
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/controllers/ProxyConfigurationService.h
create mode 100644 libminifi/src/controllers/ProxyConfigurationService.cpp
create mode 100644
libminifi/test/integration/extension-verification-test/ExtensionLoadingTests.cpp
create mode 100644 libminifi/test/unit/ProxyConfigurationServiceTests.cpp
copy minifi-api/include/minifi-cpp/controllers/{RecordSetWriter.h =>
ProxyConfigurationServiceInterface.h} (63%)
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
