This is an automated email from the ASF dual-hosted git repository.
lordgamez pushed a change to branch MINIFICPP-2624_modular_docker_tests_part1
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git
omit 4853f5edb add apache license and auto format
omit 176f7a6dd review changes
omit d5a369d7b split verify-package.yml
omit 7f72c6ae5 MINIFICPP-2624 Modularized behave tests part 1
add 97011df5a MINIFICPP-2565 Add compression support for site to site
communication
add a0ab21f03 MINIFICPP-2640 Remove explicit use of ExecutePythonProcessor
add 5b750041f MINIFICPP-2651 Add documenation on asset reference syntax
add 8cb945b10 MINIFICPP-2232 Remove option to load SSL context from flow
config
add cd4729197 MINIFICPP-2629 Clean up minifi-api includes
add e8c9a7c42 MINIFICPP-2643 Fix clang tidy issues
add 612e9f5c3 MINIFICPP-2652 Remove deprecated bootstrap.sh
add 1976d80e4 MINIFICPP-2655 Upgrade elasticsearch container image to
v9.1.5
add d4cd850e8 MINIFICPP-2624 Modularized behave tests part 1
add 63c6c1413 split verify-package.yml
add 665c96e31 review changes
add 0671dad9c add apache license and auto format
add d58939bf2 review changes
add fcb25c7f4 move makedirs outside of loop
add 5aeb03998 rename behavex_output_2 to behavex_output_modular
add 60da88eb3 rename consue_kafka.feature to consumekafka.feature
add 4fb0b25a8 remove already rewritten tests from legacy
consumekafka.feature
add 40b5649ba RunBehaveTests.sh with INFO
add 6f9dc2cec add json check for attributes_to_json.feature
add 253583677 shlex
add d1181583e use os.path.join
add f62a2c69d get_number_of_files return -1 instead of False
add 288a426c4 fix sql tests
add b4557124d inject_scenario_id, flake8 fixes
add 621be5a3e fix regex matching
add 1cfb06556 fix s3.feature
add 82b7e6448 remove accidental WIP from syslog_listener.feature
add 270bc944f check dir empty
add 1fe9bd2f0 auto format via PyCharm
add c20dd7cd4 change sleep length in wait_for_condition
add d7469f721 fix sql tests
add 7cb26f05f remove typing
add 6fa1ee3f5 add modular tests documentation to README.md
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 (4853f5edb)
\
N -- N -- N refs/heads/MINIFICPP-2624_modular_docker_tests_part1
(6fa1ee3f5)
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-tidy | 3 +-
.github/workflows/ci.yml | 6 +-
.github/workflows/verify-package.yml | 6 +-
C2.md | 3 -
CONFIGURE.md | 50 +-
OPS.md | 8 +-
PROCESSORS.md | 29 --
README.md | 104 +---
SITE_TO_SITE.md | 8 +-
ThirdParties.md | 7 -
aptitude.sh | 89 ----
arch.sh | 77 ---
behave_framework/pyproject.toml | 9 +-
.../minifi_test_framework/containers/container.py | 149 +++---
.../minifi_test_framework/containers/directory.py | 5 +-
...ontainer_builder.py => docker_image_builder.py} | 23 +-
.../containers/http_proxy_container.py | 7 +-
.../containers/minifi_container.py | 7 +-
.../src/minifi_test_framework/core/helpers.py | 6 +-
.../src/minifi_test_framework/core/hooks.py | 18 +-
.../core/minifi_test_context.py | 4 +-
.../minifi/controller_service.py | 3 +-
.../minifi/flow_definition.py | 11 +-
.../minifi/parameter_context.py | 4 +-
.../src/minifi_test_framework/minifi/processor.py | 5 +-
.../minifi_test_framework/steps/checking_steps.py | 13 +-
.../src/minifi_test_framework/steps/core_steps.py | 6 +-
.../steps/flow_building_steps.py | 8 +
bootstrap.sh | 524 ---------------------
bstrp_functions.sh | 474 -------------------
centos.sh | 99 ----
cmake/Extensions.cmake | 2 +-
conanfile.py | 2 +-
conf/minifi-log.properties.in | 1 -
conf/minifi.properties.in | 2 -
controller/Controller.cpp | 2 +-
controller/MiNiFiController.cpp | 55 +--
controller/tests/ControllerTests.cpp | 76 +--
core-framework/include/Exception.h | 21 -
core-framework/include/SwapManager.h | 21 -
core-framework/include/agent/agent_version.h | 19 -
core-framework/include/core/Annotation.h | 20 -
.../include/core/BufferedContentSession.h | 2 +-
core-framework/include/core/ClassLoader.h | 3 +-
.../include/core/ConfigurableComponentImpl.h | 2 +-
core-framework/include/core/Connectable.h | 2 +-
core-framework/include/core/ContentRepository.h | 2 +-
core-framework/include/core/ContentSession.h | 5 +-
core-framework/include/core/ObjectFactory.h | 32 +-
.../include/core/OutputAttributeDefinition.h | 20 -
core-framework/include/core/ProcessContext.h | 3 +-
.../include/core/ProcessContextBuilder.h | 3 +-
core-framework/include/core/ProcessorImpl.h | 7 +-
core-framework/include/core/Property.h | 25 -
core-framework/include/core/PropertyDefinition.h | 20 -
.../include/core/PropertyDefinitionBuilder.h | 2 +-
.../include/core/RelationshipDefinition.h | 20 -
core-framework/include/core/Repository.h | 8 +-
core-framework/include/core/Resource.h | 1 +
core-framework/include/core/StreamManager.h | 4 +-
core-framework/include/core/TypedValues.h | 6 +-
core-framework/include/core/extension/Extension.h | 14 +-
core-framework/include/core/logging/Logger.h | 20 -
.../include/core/state/MetricsPublisher.h | 2 +-
core-framework/include/http/BaseHTTPClient.h | 33 +-
core-framework/include/http/HTTPClient.h | 2 +-
core-framework/include/io/ArchiveStream.h | 20 -
core-framework/include/io/BufferStream.h | 14 +-
core-framework/include/io/CRCStream.h | 6 +-
core-framework/include/io/StreamPipe.h | 4 +-
core-framework/include/io/ZlibStream.h | 2 +-
core-framework/include/utils/AutoPersistor.h | 2 +-
core-framework/include/utils/ByteArrayCallback.h | 4 +-
core-framework/include/utils/CollectionUtils.h | 12 +-
core-framework/include/utils/Cron.h | 2 +-
core-framework/include/utils/Export.h | 35 --
core-framework/include/utils/FileMutex.h | 2 +-
core-framework/include/utils/GeneralUtils.h | 2 +-
core-framework/include/utils/IntervalSwitch.h | 14 +-
core-framework/include/utils/JsonCallback.h | 12 +-
.../utils/LineByLineInputOutputStreamCallback.h | 6 +-
core-framework/include/utils/Literals.h | 19 -
core-framework/include/utils/MapUtils.h | 14 +-
core-framework/include/utils/OptionalUtils.h | 2 +-
core-framework/include/utils/ParsingUtils.h | 4 +-
core-framework/include/utils/PropertyExceptions.h | 19 -
core-framework/include/utils/StringUtils.h | 8 +-
core-framework/include/utils/ThreadPool.h | 2 +-
core-framework/include/utils/TryMoveCall.h | 12 +-
core-framework/include/utils/ValueParser.h | 2 +-
.../include/utils/crypto/EncryptionManager.h | 2 +-
.../include/utils/crypto/EncryptionProvider.h | 2 +-
.../include/utils/crypto/ciphers/Aes256Ecb.h | 18 +-
core-framework/include/utils/file/FileUtils.h | 2 +-
core-framework/include/utils/gsl.h | 21 -
.../include/utils/net/NetworkInterfaceInfo.h | 2 +-
.../include/utils/requirements/Container.h | 12 +-
.../utils/requirements/EqualityComparable.h | 12 +-
.../utils/requirements/LegacyForwardIterator.h | 12 +-
.../utils/requirements/LegacyInputIterator.h | 12 +-
.../include/utils/requirements/LegacyIterator.h | 12 +-
.../include/utils/requirements/Swappable.h | 12 +-
core-framework/src/core/BufferedContentSession.cpp | 6 +-
core-framework/src/core/ContentSession.cpp | 1 -
core-framework/src/core/ProcessorImpl.cpp | 5 +-
core-framework/src/core/ProcessorMetrics.cpp | 2 +-
core-framework/src/core/Property.cpp | 4 +-
core-framework/src/core/TypedValues.cpp | 2 +-
core-framework/src/http/BaseHTTPClient.cpp | 7 +-
core-framework/src/http/HTTPClient.cpp | 14 +-
core-framework/src/http/HTTPStream.cpp | 2 +-
core-framework/src/io/BufferStream.cpp | 2 +-
core-framework/src/io/FileStream.cpp | 10 +-
core-framework/src/io/InputStream.cpp | 2 +-
core-framework/src/io/OutputStream.cpp | 2 +-
core-framework/src/io/ZlibStream.cpp | 6 +-
core-framework/src/utils/ByteArrayCallback.cpp | 8 +-
.../src/utils/CallBackTimer.cpp | 0
core-framework/src/utils/Environment.cpp | 2 +-
core-framework/src/utils/Error.cpp | 2 +-
core-framework/src/utils/FifoExecutor.cpp | 2 +-
core-framework/src/utils/FileMutex.cpp | 2 +-
core-framework/src/utils/Id.cpp | 6 +-
.../utils/LineByLineInputOutputStreamCallback.cpp | 2 +-
core-framework/src/utils/OsUtils.cpp | 10 +-
core-framework/src/utils/RegexUtils.cpp | 2 +-
core-framework/src/utils/StoppableThread.cpp | 2 +-
core-framework/src/utils/SystemCpuUsageTracker.cpp | 5 +-
.../src/utils/crypto/ciphers/Aes256Ecb.cpp | 4 +-
core-framework/src/utils/file/FileUtils.cpp | 2 +-
core-framework/src/utils/file/PathUtils.cpp | 2 +-
core-framework/src/utils/net/AsioSocketUtils.cpp | 2 +-
core-framework/src/utils/net/DNS.cpp | 2 +-
.../src/utils/net/NetworkInterfaceInfo.cpp | 6 +-
core-framework/src/utils/net/Socket.cpp | 2 +-
darwin.sh | 109 -----
debian.sh | 90 ----
deploy.sh | 28 --
docker/RunBehaveTests.sh | 2 +-
.../cluster/containers/ElasticsearchContainer.py | 2 +-
.../cluster/containers/MinifiContainer.py | 1 -
.../features/MiNiFi_integration_test_driver.py | 6 +-
...{consume_kafka.feature => consumekafka.feature} | 52 --
.../integration/features/minifi_c2_server.feature | 8 -
docker/test/integration/features/python.feature | 10 -
docker/test/integration/features/s2s.feature | 85 ++++
docker/test/integration/features/steps/steps.py | 26 +-
docker/test/integration/minifi/core/InputPort.py | 4 +
docker/test/integration/minifi/core/OutputPort.py | 4 +
.../Minifi_flow_json_serializer.py | 1 +
.../Minifi_flow_yaml_serializer.py | 1 +
.../minifi/processors/ExecutePythonProcessor.py | 25 -
.../resources/python/add_attribute_to_flowfile.py | 29 --
encrypt-config/ConfigFile.h | 13 +-
encrypt-config/ConfigFileEncryptor.cpp | 12 +-
encrypt-config/ConfigFileEncryptor.h | 12 +-
encrypt-config/EncryptConfig.cpp | 1 -
encrypt-config/EncryptConfigMain.cpp | 2 +-
encrypt-config/Utils.h | 12 +-
encrypt-config/tests/ConfigFileEncryptorTests.cpp | 2 +-
encrypt-config/tests/ConfigFileTests.cpp | 10 +-
encrypt-config/tests/resources/minifi.properties | 1 -
...th-additional-sensitive-props.minifi.properties | 1 -
extension-framework/include/FlowFileRecord.h | 21 -
extension-framework/include/ResourceClaim.h | 21 -
.../include/controllers/SSLContextService.h | 19 -
.../controllers/SSLContextServiceInterface.h | 19 -
.../controllers/keyvalue/KeyValueStateManager.h | 2 +-
.../include/core/AbstractProcessor.h | 2 +-
extension-framework/include/core/FlowFile.h | 20 -
extension-framework/include/core/FlowFileStore.h | 2 +-
extension-framework/include/core/StateStorage.h | 2 +-
extension-framework/include/properties/Configure.h | 19 -
.../include/properties/Properties.h | 19 -
.../include/serialization/FlowFileSerializer.h | 10 +-
.../include/serialization/FlowFileV3Serializer.h | 10 +-
.../include/serialization/PayloadSerializer.h | 12 +-
.../include/utils/ListingStateManager.h | 4 +-
.../include/utils/ProcessorConfigUtils.h | 2 +-
extension-framework/include/utils/ResourceQueue.h | 2 +-
.../include/utils/file/FileReaderCallback.h | 2 +-
extension-framework/include/utils/net/Server.h | 2 +-
extension-framework/include/utils/net/Ssl.h | 6 +-
extension-framework/include/utils/net/UdpServer.h | 2 +-
.../controllers/keyvalue/KeyValueStateStorage.cpp | 4 +-
extension-framework/src/core/ProcessContext.cpp | 22 -
.../src/serialization/FlowFileV3Serializer.cpp | 6 +-
.../src/utils/ListingStateManager.cpp | 6 +-
extension-framework/src/utils/net/Ssl.cpp | 2 +-
extension-framework/src/utils/net/TcpServer.cpp | 2 +-
extensions/aws/AWSCredentialsProvider.cpp | 2 +-
extensions/aws/AWSCredentialsProvider.h | 14 +-
.../aws/controllerservices/AWSCredentialsService.h | 2 +-
extensions/aws/processors/AwsProcessor.cpp | 4 +-
extensions/aws/processors/AwsProcessor.h | 2 +-
extensions/aws/processors/DeleteS3Object.cpp | 2 +-
extensions/aws/processors/DeleteS3Object.h | 2 +-
extensions/aws/processors/FetchS3Object.cpp | 2 +-
extensions/aws/processors/FetchS3Object.h | 2 +-
extensions/aws/processors/ListS3.cpp | 2 +-
extensions/aws/processors/ListS3.h | 2 +-
extensions/aws/processors/PutKinesisStream.cpp | 2 +-
extensions/aws/processors/PutS3Object.cpp | 8 +-
extensions/aws/processors/PutS3Object.h | 4 +-
extensions/aws/processors/S3Processor.cpp | 3 +-
extensions/aws/processors/S3Processor.h | 6 +-
extensions/aws/s3/MultipartUploadStateStorage.cpp | 2 +-
extensions/aws/s3/MultipartUploadStateStorage.h | 6 +-
extensions/aws/s3/S3RequestSender.h | 2 +-
extensions/aws/s3/S3Wrapper.cpp | 2 +-
extensions/aws/s3/S3Wrapper.h | 10 +-
extensions/aws/tests/AWSCredentialsServiceTest.cpp | 2 +-
.../aws/tests/MultipartUploadStateStorageTest.cpp | 2 +-
extensions/aws/tests/features/s3.feature | 10 +-
extensions/aws/utils/AWSInitializer.h | 14 +-
extensions/aws/utils/AWSSdkLogger.cpp | 2 +-
extensions/aws/utils/AWSSdkLogger.h | 2 +-
.../AzureStorageCredentialsService.h | 4 +-
.../processors/AzureBlobStorageProcessorBase.cpp | 2 +-
.../processors/AzureBlobStorageProcessorBase.h | 6 +-
.../AzureBlobStorageSingleBlobProcessorBase.cpp | 2 +-
.../AzureBlobStorageSingleBlobProcessorBase.h | 2 +-
.../AzureDataLakeStorageFileProcessorBase.h | 2 +-
.../processors/AzureDataLakeStorageProcessorBase.h | 6 +-
.../azure/processors/AzureStorageProcessorBase.cpp | 2 +-
.../azure/processors/AzureStorageProcessorBase.h | 6 +-
.../azure/processors/DeleteAzureBlobStorage.h | 4 +-
.../processors/DeleteAzureDataLakeStorage.cpp | 2 +-
.../azure/processors/FetchAzureBlobStorage.cpp | 5 +-
.../azure/processors/FetchAzureBlobStorage.h | 4 +-
.../azure/processors/FetchAzureDataLakeStorage.cpp | 8 +-
.../azure/processors/FetchAzureDataLakeStorage.h | 2 +-
extensions/azure/processors/ListAzureBlobStorage.h | 4 +-
.../azure/processors/PutAzureBlobStorage.cpp | 2 +-
extensions/azure/processors/PutAzureBlobStorage.h | 6 +-
.../azure/processors/PutAzureDataLakeStorage.cpp | 2 +-
.../azure/processors/PutAzureDataLakeStorage.h | 4 +-
extensions/azure/storage/AzureBlobStorage.h | 6 +-
.../azure/storage/AzureBlobStorageClient.cpp | 1 +
extensions/azure/storage/AzureBlobStorageClient.h | 2 +-
extensions/azure/storage/AzureDataLakeStorage.cpp | 2 +-
extensions/azure/storage/AzureDataLakeStorage.h | 4 +-
.../azure/storage/AzureDataLakeStorageClient.h | 3 +-
extensions/azure/storage/BlobStorageClient.h | 4 +-
extensions/azure/storage/DataLakeStorageClient.h | 4 +-
extensions/azure/utils/AzureSdkLogger.h | 2 +-
extensions/bustache/ApplyTemplate.cpp | 2 +-
extensions/bustache/tests/ApplyTemplateTests.cpp | 2 +-
extensions/civetweb/processors/ListenHTTP.cpp | 5 +-
extensions/civetweb/processors/ListenHTTP.h | 11 +-
.../civetweb/tests/HttpPostIntegrationTest.cpp | 2 +-
extensions/civetweb/tests/ListenHTTPTests.cpp | 124 ++---
.../controllerservices/CouchbaseClusterService.cpp | 1 +
.../controllerservices/CouchbaseClusterService.h | 6 +-
.../couchbase/processors/GetCouchbaseKey.cpp | 2 +-
.../couchbase/processors/PutCouchbaseKey.cpp | 2 +-
.../ElasticsearchCredentialsControllerService.h | 2 +-
extensions/elasticsearch/PostElasticsearch.cpp | 4 +-
extensions/elasticsearch/PostElasticsearch.h | 6 +-
extensions/elasticsearch/tests/MockElastic.h | 2 +-
.../elasticsearch/tests/PostElasticsearchTests.cpp | 2 +-
extensions/execute-process/ExecuteProcess.cpp | 6 +-
extensions/execute-process/ExecuteProcess.h | 6 +-
extensions/expression-language/Driver.h | 12 +-
extensions/expression-language/Expression.cpp | 5 +-
extensions/expression-language/Parser.yy | 12 +-
.../impl/expression/Expression.h | 2 +-
.../tests/ExpressionLanguageTests.cpp | 4 +-
.../tests/ProcessContextExprTests.cpp | 6 +-
extensions/gcp/GCPAttributes.h | 2 +-
.../GCPCredentialsControllerService.h | 4 +-
extensions/gcp/processors/DeleteGCSObject.cpp | 4 +-
extensions/gcp/processors/DeleteGCSObject.h | 4 +-
extensions/gcp/processors/FetchGCSObject.cpp | 4 +-
extensions/gcp/processors/FetchGCSObject.h | 4 +-
extensions/gcp/processors/GCSProcessor.cpp | 2 +-
extensions/gcp/processors/GCSProcessor.h | 4 +-
extensions/gcp/processors/ListGCSBucket.cpp | 4 +-
extensions/gcp/processors/ListGCSBucket.h | 6 +-
extensions/gcp/processors/PutGCSObject.cpp | 4 +-
extensions/gcp/processors/PutGCSObject.h | 4 +-
.../tests/GCPCredentialsControllerServiceTests.cpp | 6 +-
extensions/grafana-loki/PushGrafanaLoki.cpp | 2 +-
extensions/grafana-loki/PushGrafanaLoki.h | 8 +-
extensions/grafana-loki/PushGrafanaLokiGrpc.h | 1 -
extensions/grafana-loki/PushGrafanaLokiREST.cpp | 2 +-
.../grafana-loki/tests/MockGrafanaLokiREST.h | 2 +-
extensions/kafka/ConsumeKafka.cpp | 4 +-
extensions/kafka/ConsumeKafka.h | 4 +-
extensions/kafka/KafkaConnection.cpp | 2 +-
extensions/kafka/KafkaConnection.h | 4 +-
extensions/kafka/KafkaProcessorBase.cpp | 2 +-
extensions/kafka/KafkaProcessorBase.h | 2 +-
extensions/kafka/PublishKafka.cpp | 10 +-
extensions/kafka/PublishKafka.h | 10 +-
extensions/kafka/rdkafka_utils.cpp | 2 +-
extensions/kafka/tests/features/environment.py | 4 +-
extensions/kubernetes/ApiClient.h | 2 +-
.../KubernetesControllerService.cpp | 4 +-
.../KubernetesControllerService.h | 4 +-
.../processors/CollectKubernetesPodMetrics.cpp | 2 +-
.../processors/CollectKubernetesPodMetrics.h | 2 +-
extensions/libarchive/ArchiveMetadata.cpp | 4 +-
extensions/libarchive/BinFiles.cpp | 2 +-
extensions/libarchive/BinFiles.h | 8 +-
extensions/libarchive/CompressContent.cpp | 2 +-
extensions/libarchive/CompressContent.h | 8 +-
extensions/libarchive/FocusArchiveEntry.cpp | 7 +-
extensions/libarchive/FocusArchiveEntry.h | 8 +-
extensions/libarchive/ManipulateArchive.cpp | 6 +-
extensions/libarchive/ManipulateArchive.h | 8 +-
extensions/libarchive/MergeContent.cpp | 2 +-
extensions/libarchive/MergeContent.h | 4 +-
extensions/libarchive/ReadArchiveStream.h | 3 +-
extensions/libarchive/UnfocusArchiveEntry.cpp | 4 +-
extensions/libarchive/UnfocusArchiveEntry.h | 4 +-
extensions/libarchive/WriteArchiveStream.h | 2 +-
.../libarchive/tests/CompressContentTests.cpp | 6 +-
.../libarchive/tests/ManipulateArchiveTests.cpp | 2 +-
extensions/libarchive/tests/MergeFileTests.cpp | 12 +-
extensions/libarchive/tests/util/ArchiveTests.cpp | 4 +-
.../llamacpp/processors/DefaultLlamaContext.cpp | 2 +-
.../llamacpp/processors/RunLlamaCppInference.cpp | 4 +-
.../llamacpp/tests/RunLlamaCppInferenceTests.cpp | 2 +-
extensions/llamacpp/tests/features/environment.py | 4 +-
extensions/lua/LuaInputStream.h | 2 +-
extensions/lua/LuaLogger.h | 1 -
extensions/lua/LuaOutputStream.h | 2 +-
extensions/lua/LuaScriptFlowFile.cpp | 10 +-
extensions/lua/LuaScriptFlowFile.h | 6 +-
extensions/lua/LuaScriptStateManager.h | 2 +-
.../mqtt/processors/AbstractMQTTProcessor.cpp | 2 +-
extensions/mqtt/processors/AbstractMQTTProcessor.h | 3 +-
extensions/mqtt/processors/ConsumeMQTT.cpp | 2 +-
extensions/mqtt/processors/ConsumeMQTT.h | 8 +-
extensions/mqtt/processors/PublishMQTT.cpp | 2 +-
extensions/mqtt/processors/PublishMQTT.h | 6 +-
extensions/opc/include/fetchopc.h | 10 +-
extensions/opc/include/opc.h | 6 +-
extensions/opc/include/opcbase.h | 4 +-
extensions/opc/include/putopc.h | 6 +-
extensions/opc/src/fetchopc.cpp | 2 +-
extensions/opc/src/opc.cpp | 9 +-
extensions/opc/src/opcbase.cpp | 2 +-
extensions/opc/src/putopc.cpp | 2 +-
extensions/opencv/CaptureRTSPFrame.cpp | 2 +-
extensions/opencv/CaptureRTSPFrame.h | 4 +-
extensions/opencv/MotionDetector.cpp | 2 +-
extensions/opencv/MotionDetector.h | 4 +-
extensions/pdh/MemoryConsumptionCounter.h | 12 +-
extensions/pdh/PDHCounters.cpp | 12 +-
extensions/pdh/PDHCounters.h | 12 +-
extensions/pdh/PerformanceDataCounter.h | 12 +-
extensions/pdh/PerformanceDataMonitor.cpp | 14 +-
extensions/pdh/PerformanceDataMonitor.h | 16 +-
.../pdh/tests/PerformanceDataCounterTests.cpp | 2 +-
extensions/procfs/DiskStat.cpp | 2 +-
extensions/procfs/NetDev.cpp | 2 +-
extensions/procfs/ProcFs.h | 2 +-
extensions/procfs/ProcFsSerialization.h | 2 +-
extensions/procfs/ProcessStat.cpp | 4 +-
extensions/procfs/processors/ProcFsMonitor.cpp | 4 +-
extensions/procfs/processors/ProcFsMonitor.h | 6 +-
extensions/procfs/tests/MemInfoTests.cpp | 2 +-
extensions/prometheus/PrometheusExposerWrapper.h | 4 +-
extensions/prometheus/PrometheusMetricsPublisher.h | 2 +-
.../prometheus/PublishedMetricGaugeCollection.cpp | 2 +-
.../prometheus/PublishedMetricGaugeCollection.h | 4 +-
extensions/python/ExecutePythonProcessor.cpp | 166 +++----
extensions/python/ExecutePythonProcessor.h | 55 +--
extensions/python/PYTHON.md | 130 +++--
extensions/python/PythonBindings.cpp | 4 +-
extensions/python/PythonDependencyInstaller.h | 4 +-
extensions/python/PythonObjectFactory.h | 1 -
extensions/python/PythonProcessor.h | 2 +-
extensions/python/PythonScriptEngine.h | 2 +-
.../python/tests/ExecutePythonProcessorTests.cpp | 179 ++-----
extensions/python/tests/PythonManifestTests.cpp | 4 +-
extensions/python/types/PyInputStream.cpp | 2 +-
extensions/python/types/PyInputStream.h | 2 +-
extensions/python/types/PyLogger.cpp | 2 +-
extensions/python/types/PyLogger.h | 2 +-
extensions/python/types/PyOutputStream.h | 2 +-
extensions/python/types/PyProcessContext.cpp | 4 +-
extensions/python/types/PyProcessContext.h | 2 +-
extensions/python/types/PyProcessSession.cpp | 2 +-
extensions/python/types/PyRecordSetReader.h | 2 +-
extensions/python/types/PyRecordSetWriter.h | 2 +-
extensions/python/types/PySSLContextService.h | 2 +-
extensions/python/types/PyScriptFlowFile.h | 2 +-
extensions/python/types/PyStateManager.h | 2 +-
extensions/python/types/Types.h | 2 +-
.../rocksdb-repos/DatabaseContentRepository.cpp | 4 +-
.../rocksdb-repos/DatabaseContentRepository.h | 4 +-
extensions/rocksdb-repos/FlowFileLoader.cpp | 4 +-
extensions/rocksdb-repos/FlowFileLoader.h | 6 +-
extensions/rocksdb-repos/FlowFileRepository.cpp | 4 +-
extensions/rocksdb-repos/FlowFileRepository.h | 2 +-
extensions/rocksdb-repos/ProvenanceRepository.cpp | 1 -
extensions/rocksdb-repos/ProvenanceRepository.h | 2 +-
extensions/rocksdb-repos/RocksDbStream.cpp | 2 +-
extensions/rocksdb-repos/RocksDbStream.h | 12 +-
.../controllers/RocksDbStateStorage.h | 4 +-
extensions/rocksdb-repos/database/OpenRocksDb.h | 4 +-
extensions/rocksdb-repos/database/RocksDatabase.h | 2 +-
.../rocksdb-repos/database/RocksDbInstance.h | 2 +-
extensions/rocksdb-repos/database/RocksDbUtils.cpp | 4 +-
extensions/rocksdb-repos/database/RocksDbUtils.h | 2 +-
extensions/rocksdb-repos/database/WriteBatch.cpp | 12 +-
extensions/rocksdb-repos/database/WriteBatch.h | 13 +-
.../encryption/RocksDbEncryptionProvider.h | 2 +-
.../rocksdb-repos/tests/ContentSessionTests.cpp | 2 +-
.../tests/DBContentRepositoryTests.cpp | 4 +-
extensions/rocksdb-repos/tests/EncryptionTests.cpp | 1 +
extensions/rocksdb-repos/tests/ProvenanceTests.cpp | 5 +-
extensions/rocksdb-repos/tests/RepoTests.cpp | 8 +-
extensions/rocksdb-repos/tests/SwapTests.cpp | 7 +-
extensions/script/ExecuteScript.h | 4 +-
extensions/script/ScriptExecutor.h | 2 +-
extensions/sftp/client/SFTPClient.cpp | 2 +-
extensions/sftp/client/SFTPClient.h | 4 +-
extensions/sftp/processors/FetchSFTP.cpp | 4 +-
extensions/sftp/processors/FetchSFTP.h | 4 +-
extensions/sftp/processors/ListSFTP.cpp | 10 +-
extensions/sftp/processors/ListSFTP.h | 6 +-
extensions/sftp/processors/PutSFTP.cpp | 7 +-
extensions/sftp/processors/PutSFTP.h | 8 +-
extensions/sftp/processors/SFTPProcessorBase.cpp | 17 +-
extensions/sftp/processors/SFTPProcessorBase.h | 6 +-
extensions/sftp/tests/ListSFTPTests.cpp | 2 +-
extensions/sftp/tests/ListThenFetchSFTPTests.cpp | 4 +-
extensions/sftp/tests/PutSFTPTests.cpp | 4 +-
extensions/sftp/tests/tools/SFTPTestServer.cpp | 4 +-
extensions/sftp/tests/tools/SFTPTestServer.h | 2 +-
extensions/smb/FetchSmb.h | 6 +-
extensions/smb/ListSmb.h | 6 +-
extensions/smb/PutSmb.cpp | 2 +-
extensions/smb/SmbConnectionControllerService.cpp | 1 +
extensions/smb/SmbConnectionControllerService.h | 6 +-
.../tests/SmbConnectionControllerServiceTests.cpp | 1 -
.../utils/MockSmbConnectionControllerService.h | 1 -
extensions/splunk/PutSplunkHTTP.cpp | 2 +-
extensions/splunk/PutSplunkHTTP.h | 6 +-
extensions/splunk/QuerySplunkIndexingStatus.cpp | 2 +-
extensions/splunk/QuerySplunkIndexingStatus.h | 6 +-
extensions/splunk/SplunkHECProcessor.cpp | 4 +-
extensions/splunk/SplunkHECProcessor.h | 4 +-
extensions/splunk/tests/MockSplunkHEC.h | 2 +-
extensions/sql/data/JSONSQLWriter.cpp | 2 +-
extensions/sql/data/SQLRowSubscriber.h | 12 +-
extensions/sql/data/SQLRowsetProcessor.cpp | 21 +-
extensions/sql/data/SociConnectors.h | 4 +-
extensions/sql/processors/ExecuteSQL.cpp | 4 +-
extensions/sql/processors/ExecuteSQL.h | 6 +-
extensions/sql/processors/FlowFileSource.h | 2 +-
extensions/sql/processors/PutSQL.cpp | 4 +-
extensions/sql/processors/PutSQL.h | 4 +-
extensions/sql/processors/QueryDatabaseTable.cpp | 6 +-
extensions/sql/processors/QueryDatabaseTable.h | 4 +-
extensions/sql/processors/SQLProcessor.cpp | 6 +-
extensions/sql/processors/SQLProcessor.h | 2 +-
extensions/sql/services/DatabaseService.cpp | 2 +-
extensions/sql/services/DatabaseService.h | 2 +-
extensions/sql/tests/FlowFileMatcher.h | 2 +-
extensions/sql/tests/SQLTestPlan.h | 2 +
extensions/sql/tests/features/environment.py | 6 +-
extensions/sql/tests/features/sql.feature | 1 +
.../features/steps/postgress_server_container.py | 14 +-
extensions/sql/tests/features/steps/steps.py | 2 +-
.../controllers/InMemoryKeyValueStorage.h | 2 +-
.../controllers/JsonRecordSetWriter.h | 2 +-
.../controllers/PersistentMapStateStorage.h | 6 +-
.../controllers/VolatileMapStateStorage.h | 6 +-
.../standard-processors/controllers/XMLReader.cpp | 2 +-
.../standard-processors/controllers/XMLReader.h | 2 +-
.../controllers/XMLRecordSetWriter.cpp | 2 +-
.../controllers/XMLRecordSetWriter.h | 2 +-
.../standard-processors/modbus/FetchModbusTcp.cpp | 2 +-
.../standard-processors/modbus/FetchModbusTcp.h | 4 +-
.../processors/AppendHostInfo.cpp | 4 +-
.../processors/AppendHostInfo.h | 6 +-
.../processors/AttributeRollingWindow.cpp | 2 +-
.../processors/AttributeRollingWindow.h | 5 +-
.../processors/AttributesToJSON.cpp | 6 +-
.../processors/AttributesToJSON.h | 8 +-
.../standard-processors/processors/ConvertRecord.h | 2 +-
.../processors/DefragmentText.cpp | 6 +-
.../processors/DefragmentText.h | 4 +-
.../processors/EvaluateJsonPath.h | 4 +-
.../standard-processors/processors/ExtractText.cpp | 6 +-
.../standard-processors/processors/ExtractText.h | 8 +-
.../standard-processors/processors/FetchFile.h | 4 +-
.../processors/GenerateFlowFile.cpp | 2 +-
.../processors/GenerateFlowFile.h | 10 +-
.../standard-processors/processors/GetFile.cpp | 2 +-
.../standard-processors/processors/GetFile.h | 8 +-
.../standard-processors/processors/GetTCP.cpp | 4 +-
extensions/standard-processors/processors/GetTCP.h | 10 +-
.../standard-processors/processors/HashContent.cpp | 4 +-
.../standard-processors/processors/HashContent.h | 6 +-
.../standard-processors/processors/InvokeHTTP.cpp | 8 +-
.../standard-processors/processors/InvokeHTTP.h | 12 +-
.../processors/JoltTransformJSON.h | 4 +-
.../standard-processors/processors/ListFile.cpp | 2 +-
.../standard-processors/processors/ListFile.h | 6 +-
.../processors/ListenSyslog.cpp | 4 +-
.../standard-processors/processors/ListenSyslog.h | 8 +-
.../standard-processors/processors/ListenTCP.cpp | 4 +-
.../standard-processors/processors/ListenTCP.h | 8 +-
.../standard-processors/processors/ListenUDP.cpp | 2 +-
.../standard-processors/processors/ListenUDP.h | 6 +-
.../processors/LogAttribute.cpp | 2 +-
.../standard-processors/processors/LogAttribute.h | 8 +-
.../processors/NetworkListenerProcessor.h | 6 +-
.../standard-processors/processors/PutFile.cpp | 16 +-
.../standard-processors/processors/PutFile.h | 8 +-
.../standard-processors/processors/PutTCP.cpp | 6 +-
extensions/standard-processors/processors/PutTCP.h | 10 +-
.../standard-processors/processors/PutUDP.cpp | 6 +-
extensions/standard-processors/processors/PutUDP.h | 6 +-
.../standard-processors/processors/ReplaceText.h | 12 +-
.../standard-processors/processors/RetryFlowFile.h | 10 +-
.../processors/RouteOnAttribute.h | 4 +-
.../standard-processors/processors/RouteText.cpp | 2 +-
.../standard-processors/processors/RouteText.h | 8 +-
.../processors/SegmentContent.cpp | 4 +-
.../processors/SegmentContent.h | 8 +-
.../processors/SplitContent.cpp | 6 +-
.../standard-processors/processors/SplitContent.h | 8 +-
.../standard-processors/processors/SplitJson.h | 4 +-
.../standard-processors/processors/SplitRecord.h | 14 +-
.../standard-processors/processors/SplitText.cpp | 8 +-
.../standard-processors/processors/SplitText.h | 6 +-
.../standard-processors/processors/TailFile.cpp | 2 +-
.../standard-processors/processors/TailFile.h | 8 +-
.../processors/TextFragmentUtils.h | 2 +-
.../processors/UpdateAttribute.cpp | 2 +-
.../processors/UpdateAttribute.h | 4 +-
.../tests/features/attributes_to_json.feature | 2 +-
.../tests/features/syslog_listener.feature | 4 +-
.../tests/integration/InvokeHTTPTests.cpp | 4 +-
.../tests/integration/ProcessGroupTest.cpp | 2 +-
.../tests/integration/VerifyInvokeHTTP.h | 2 +-
.../tests/unit/AttributeRollingWindowTests.cpp | 2 +-
.../tests/unit/ControllerServiceTests.cpp | 4 +-
.../tests/unit/ExtractTextTests.cpp | 4 +-
.../tests/unit/FetchFileTests.cpp | 2 +-
.../standard-processors/tests/unit/GetTCPTests.cpp | 2 +-
.../tests/unit/HttpClientStoreTests.cpp | 12 +-
.../tests/unit/ListFileTests.cpp | 2 +-
.../tests/unit/ProcessorTests.cpp | 8 +-
.../tests/unit/PutFileTests.cpp | 4 +-
.../standard-processors/tests/unit/PutUDPTests.cpp | 2 +-
.../tests/unit/ReplaceTextTests.cpp | 1 +
.../tests/unit/RouteTextTests.cpp | 3 +-
.../tests/unit/SegmentContentTests.cpp | 2 +-
.../tests/unit/SplitContentTests.cpp | 2 +-
.../tests/unit/SplitTextTests.cpp | 2 +-
.../tests/unit/TailFileTests.cpp | 3 +-
.../tests/unit/YamlConnectionParserTest.cpp | 2 +-
extensions/standard-processors/utils/JoltUtils.cpp | 23 +-
extensions/standard-processors/utils/JoltUtils.h | 4 +-
extensions/systemd/Common.h | 9 +-
extensions/systemd/ConsumeJournald.cpp | 4 +-
extensions/systemd/ConsumeJournald.h | 8 +-
extensions/systemd/libwrapper/DlopenWrapper.cpp | 4 +-
extensions/systemd/libwrapper/LibWrapper.cpp | 10 +-
extensions/systemd/libwrapper/LibWrapper.h | 12 +-
extensions/systemd/tests/ConsumeJournaldTest.cpp | 4 +-
extensions/test-processors/KamikazeProcessor.cpp | 4 +-
extensions/test-processors/KamikazeProcessor.h | 4 +-
.../windows-event-log/ConsumeWindowsEventLog.cpp | 4 +-
.../windows-event-log/ConsumeWindowsEventLog.h | 10 +-
extensions/windows-event-log/TailEventLog.cpp | 4 +-
extensions/windows-event-log/TailEventLog.h | 18 +-
.../windows-event-log/tests/BookmarkTests.cpp | 2 +-
extensions/windows-event-log/tests/CWELTestUtils.h | 2 +-
extensions/windows-event-log/wel/Bookmark.h | 4 +-
extensions/windows-event-log/wel/EventPath.h | 2 +-
extensions/windows-event-log/wel/JSONUtils.cpp | 2 +-
extensions/windows-event-log/wel/JSONUtils.h | 20 +-
extensions/windows-event-log/wel/MetadataWalker.h | 2 +-
.../windows-event-log/wel/WindowsEventLog.cpp | 2 +-
extensions/windows-event-log/wel/WindowsEventLog.h | 2 +-
extensions/windows-event-log/wel/XMLString.h | 15 +-
fedora.sh | 83 ----
generateVersion.bat | 16 +-
generateVersion.sh | 12 +-
libminifi/include/Connection.h | 7 +-
libminifi/include/CronDrivenSchedulingAgent.h | 6 +-
libminifi/include/EventDrivenSchedulingAgent.h | 6 +-
libminifi/include/FlowController.h | 15 +-
libminifi/include/FlowFileRecord.h | 6 +-
libminifi/include/RemoteProcessGroupPort.h | 7 +-
libminifi/include/ResourceClaim.h | 2 +-
libminifi/include/RootProcessGroupWrapper.h | 5 +-
libminifi/include/SchedulingAgent.h | 8 +-
libminifi/include/ThreadedSchedulingAgent.h | 4 +-
libminifi/include/TimerDrivenSchedulingAgent.h | 6 +-
libminifi/include/agent/build_description.h | 5 +-
libminifi/include/c2/C2Agent.h | 2 +-
libminifi/include/c2/C2MetricsPublisher.h | 6 +-
libminifi/include/c2/C2Payload.h | 2 +-
libminifi/include/c2/C2Protocol.h | 7 +-
libminifi/include/c2/C2Trigger.h | 5 +-
libminifi/include/c2/C2Utils.h | 2 +-
libminifi/include/c2/ControllerSocketProtocol.h | 8 +-
libminifi/include/c2/HeartbeatLogger.h | 2 +-
libminifi/include/c2/HeartbeatReporter.h | 7 +-
libminifi/include/c2/PayloadSerializer.h | 23 +-
libminifi/include/c2/protocols/RESTProtocol.h | 7 +-
.../controllers/NetworkPrioritizerService.h | 5 +-
libminifi/include/controllers/SSLContextService.h | 4 +-
.../include/controllers/ThreadManagementService.h | 5 +-
.../controllers/UpdatePolicyControllerService.h | 4 +-
libminifi/include/core/FlowConfiguration.h | 7 +-
libminifi/include/core/FlowFile.h | 8 +-
libminifi/include/core/ForwardingContentSession.h | 5 +-
libminifi/include/core/ParameterContext.h | 2 +-
libminifi/include/core/ParameterTokenParser.h | 2 +-
libminifi/include/core/ProcessGroup.h | 6 +-
libminifi/include/core/ProcessSession.h | 8 +-
.../include/core/ProcessSessionReadCallback.h | 2 +-
libminifi/include/core/Processor.h | 4 +-
libminifi/include/core/RepositoryFactory.h | 4 +-
libminifi/include/core/SerializableComponent.h | 4 +-
.../core/controller/ControllerServiceLookup.h | 21 -
.../core/controller/ControllerServiceNode.h | 6 +-
.../core/controller/ControllerServiceNodeMap.h | 2 +-
.../core/controller/ControllerServiceProvider.h | 4 +-
.../ForwardingControllerServiceProvider.h | 2 +-
libminifi/include/core/extension/Executable.h | 14 +-
.../include/core/extension/ExtensionManager.h | 2 +-
libminifi/include/core/extension/Module.h | 20 +-
libminifi/include/core/extension/Utils.h | 2 +-
libminifi/include/core/flow/Node.h | 2 +-
.../include/core/flow/StructuredConfiguration.h | 2 +-
.../include/core/flow/StructuredConnectionParser.h | 2 +-
libminifi/include/core/json/JsonNode.h | 2 +-
libminifi/include/core/logging/LoggerBase.h | 2 +-
.../include/core/logging/LoggerConfiguration.h | 2 +-
libminifi/include/core/logging/LoggerFactory.h | 43 --
.../include/core/logging/WindowsEventLogSink.h | 16 +-
libminifi/include/core/logging/alert/AlertSink.h | 5 +-
.../core/logging/internal/ActiveCompressor.h | 18 +-
.../core/logging/internal/CompressionManager.h | 22 +-
.../include/core/logging/internal/LogBuffer.h | 16 +-
.../include/core/logging/internal/LogCompressor.h | 18 +-
.../reporting/SiteToSiteProvenanceReportingTask.h | 1 -
.../include/core/repository/AtomicRepoEntries.h | 2 +-
.../repository/LegacyVolatileContentRepository.h | 3 +-
.../core/repository/VolatileFlowFileRepository.h | 3 +-
.../core/repository/VolatileProvenanceRepository.h | 1 -
.../include/core/repository/VolatileRepository.h | 2 -
libminifi/include/core/state/ConnectionStore.h | 4 +-
libminifi/include/core/state/LogMetricsPublisher.h | 4 +-
.../include/core/state/MetricsPublisherFactory.h | 2 +-
.../include/core/state/MetricsPublisherStore.h | 5 +-
libminifi/include/core/state/UpdateController.h | 19 +-
libminifi/include/core/state/UpdatePolicy.h | 21 +-
.../include/core/state/nodes/AgentInformation.h | 6 +-
.../include/core/state/nodes/AssetInformation.h | 2 +-
.../core/state/nodes/ConfigurationChecksums.h | 2 +-
.../include/core/state/nodes/DeviceInformation.h | 3 +-
.../include/core/state/nodes/FlowInformation.h | 4 +-
libminifi/include/core/state/nodes/MetricsBase.h | 2 -
libminifi/include/core/state/nodes/QueueMetrics.h | 1 -
.../include/core/state/nodes/RepositoryMetrics.h | 2 +-
.../state/nodes/RepositoryMetricsSourceStore.h | 4 +-
.../include/core/state/nodes/ResponseNodeLoader.h | 6 +-
libminifi/include/core/yaml/YamlConfiguration.h | 2 +-
libminifi/include/core/yaml/YamlNode.h | 2 +-
libminifi/include/io/AtomicEntryStream.h | 21 +-
libminifi/include/io/NetworkPrioritizer.h | 17 +-
libminifi/include/properties/Configuration.h | 2 +-
libminifi/include/properties/Decryptor.h | 10 +-
libminifi/include/properties/Properties.h | 2 +-
libminifi/include/provenance/Provenance.h | 9 +-
.../{SiteToSiteFactory.h => CompressionConsts.h} | 8 +-
...iteToSiteFactory.h => CompressionInputStream.h} | 33 +-
...teToSiteFactory.h => CompressionOutputStream.h} | 28 +-
.../include/sitetosite/HttpSiteToSiteClient.h | 2 +-
libminifi/include/sitetosite/RawSiteToSiteClient.h | 3 +-
libminifi/include/sitetosite/SiteToSiteClient.h | 8 +-
libminifi/include/utils/FlowFileQueue.h | 3 +-
libminifi/include/utils/MinMaxHeap.h | 2 +-
libminifi/include/utils/StagingQueue.h | 12 +-
libminifi/include/utils/file/AssetManager.h | 2 +-
libminifi/include/utils/file/FileSystem.h | 14 +-
libminifi/include/utils/tls/DistinguishedName.h | 14 +-
libminifi/include/utils/tls/ExtendedKeyUsage.h | 2 +-
libminifi/include/utils/tls/TLSUtils.h | 14 +-
libminifi/src/Configuration.cpp | 3 -
libminifi/src/Configure.cpp | 2 +-
libminifi/src/Connection.cpp | 2 +-
libminifi/src/CronDrivenSchedulingAgent.cpp | 4 +-
libminifi/src/DiskSpaceWatchdog.cpp | 4 +-
libminifi/src/EventDrivenSchedulingAgent.cpp | 6 +-
libminifi/src/Exception.cpp | 2 +-
libminifi/src/FlowController.cpp | 9 +-
libminifi/src/FlowFileRecord.cpp | 11 +-
libminifi/src/RemoteProcessGroupPort.cpp | 15 +-
libminifi/src/ResourceClaim.cpp | 3 +-
libminifi/src/SchedulingAgent.cpp | 2 +-
libminifi/src/ThreadedSchedulingAgent.cpp | 7 +-
libminifi/src/agent/JsonSchema.cpp | 4 +-
libminifi/src/c2/C2Agent.cpp | 12 +-
libminifi/src/c2/C2MetricsPublisher.cpp | 5 +-
.../src/c2/ControllerSocketMetricsPublisher.cpp | 2 +-
libminifi/src/c2/ControllerSocketProtocol.cpp | 32 +-
libminifi/src/c2/HeartbeatJsonSerializer.cpp | 3 +-
libminifi/src/c2/PayloadSerializer.cpp | 12 +-
libminifi/src/c2/protocols/RESTProtocol.cpp | 2 +-
libminifi/src/c2/protocols/RESTSender.cpp | 23 +-
.../controllers/UpdatePolicyControllerService.cpp | 2 -
libminifi/src/core/ClassLoader.cpp | 17 +-
libminifi/src/core/FlowConfiguration.cpp | 2 +
libminifi/src/core/FlowFile.cpp | 2 +-
libminifi/src/core/ForwardingContentSession.cpp | 7 +-
libminifi/src/core/ParameterContext.cpp | 2 +-
libminifi/src/core/ProcessGroup.cpp | 2 +-
libminifi/src/core/ProcessSession.cpp | 11 +-
libminifi/src/core/ProcessSessionFactory.cpp | 12 +-
libminifi/src/core/ProcessSessionReadCallback.cpp | 4 +-
libminifi/src/core/Processor.cpp | 6 +-
libminifi/src/core/RepositoryFactory.cpp | 2 -
.../core/controller/ControllerServiceProvider.cpp | 2 +-
libminifi/src/core/extension/DynamicLibrary.cpp | 1 -
libminifi/src/core/extension/ExtensionManager.cpp | 2 +-
libminifi/src/core/extension/Module.cpp | 2 +-
libminifi/src/core/flow/CheckRequiredField.cpp | 4 +-
libminifi/src/core/logging/LoggerConfiguration.cpp | 12 +-
libminifi/src/core/logging/WindowsEventLogSink.cpp | 18 +-
libminifi/src/core/logging/alert/AlertSink.cpp | 27 +-
.../core/logging/internal/CompressionManager.cpp | 4 +-
.../src/core/logging/internal/LogCompressor.cpp | 17 +-
.../SiteToSiteProvenanceReportingTask.cpp | 8 +-
.../src/core/repository/VolatileRepository.cpp | 1 -
.../src/core/repository/VolatileRepositoryData.cpp | 4 +-
libminifi/src/core/state/MetricsPublisherStore.cpp | 1 +
libminifi/src/core/state/UpdateController.cpp | 12 +-
libminifi/src/core/state/Value.cpp | 2 +-
.../src/core/state/nodes/AgentInformation.cpp | 2 +-
.../src/core/state/nodes/BuildInformation.cpp | 2 +-
.../src/core/state/nodes/DeviceInformation.cpp | 3 +-
.../src/core/state/nodes/RepositoryMetrics.cpp | 2 +-
.../src/core/state/nodes/ResponseNodeLoader.cpp | 2 +-
libminifi/src/io/AtomicEntryStream.cpp | 33 --
.../EnvironmentVariableParameterProvider.cpp | 2 +-
libminifi/src/provenance/Provenance.cpp | 8 +-
.../src/sitetosite/CompressionInputStream.cpp | 154 ++++++
.../src/sitetosite/CompressionOutputStream.cpp | 139 ++++++
libminifi/src/sitetosite/HttpSiteToSiteClient.cpp | 19 +-
libminifi/src/sitetosite/RawSiteToSiteClient.cpp | 5 +-
libminifi/src/sitetosite/SiteToSiteClient.cpp | 118 +++--
libminifi/src/utils/CallBackTimer.cpp | 92 ----
libminifi/src/utils/tls/DistinguishedName.cpp | 2 +-
libminifi/src/utils/tls/TLSUtils.cpp | 2 +-
libminifi/test/flow-tests/CustomProcessors.h | 4 +-
libminifi/test/flow-tests/FlowControllerTests.cpp | 4 +-
libminifi/test/flow-tests/SessionTests.cpp | 1 +
libminifi/test/integration/AlertTests.cpp | 9 +-
libminifi/test/integration/C2DebugBundleTest.cpp | 2 +-
libminifi/test/integration/C2NullConfiguration.cpp | 2 +-
.../test/integration/C2PropertiesUpdateTests.cpp | 2 +-
libminifi/test/integration/C2UpdateTest.cpp | 2 +-
libminifi/test/integration/HTTPClientTests.cpp | 12 +-
.../integration/OnScheduleErrorHandlingTests.cpp | 4 +-
libminifi/test/integration/SiteToSiteRestTest.cpp | 2 +-
.../keyvalue-tests/PersistentStateStorageTest.cpp | 1 -
libminifi/test/libtest/integration/CivetStream.h | 3 +-
.../integration/ConnectionCountingServer.cpp | 6 +-
.../test/libtest/integration/HTTPHandlers.cpp | 2 +-
libminifi/test/libtest/integration/HTTPHandlers.h | 9 -
.../libtest/integration/HTTPIntegrationBase.cpp | 4 +-
.../test/libtest/integration/IntegrationBase.cpp | 1 +
libminifi/test/libtest/unit/MockClasses.h | 6 +-
libminifi/test/libtest/unit/ProvenanceTestHelper.h | 4 +-
.../libtest/unit/ReadFromFlowFileTestProcessor.cpp | 2 +-
.../libtest/unit/ReadFromFlowFileTestProcessor.h | 6 +-
libminifi/test/libtest/unit/RecordSetTesters.h | 4 +-
.../libtest/unit/SingleProcessorTestController.cpp | 5 +-
.../libtest/unit/SingleProcessorTestController.h | 4 +-
libminifi/test/libtest/unit/SiteToSiteHelper.h | 2 +-
libminifi/test/libtest/unit/StatefulProcessor.cpp | 4 +-
libminifi/test/libtest/unit/StatefulProcessor.h | 2 +-
libminifi/test/libtest/unit/TestBase.cpp | 10 +-
libminifi/test/libtest/unit/TestBase.h | 18 +-
libminifi/test/libtest/unit/TestUtils.cpp | 18 +-
libminifi/test/libtest/unit/TestUtils.h | 3 +-
.../libtest/unit/WriteToFlowFileTestProcessor.cpp | 2 +-
.../libtest/unit/WriteToFlowFileTestProcessor.h | 10 +-
.../test/persistence-tests/PersistenceTests.cpp | 3 +
.../test/resources/encrypted.minifi.properties | 1 -
libminifi/test/schema-tests/SchemaTests.cpp | 2 +-
libminifi/test/unit/ArrayUtilsTests.cpp | 8 +-
libminifi/test/unit/BackTraceTests.cpp | 2 +-
libminifi/test/unit/CRCTests.cpp | 4 +-
libminifi/test/unit/CertificateUtilsTests.cpp | 2 +-
libminifi/test/unit/ComponentManifestTests.cpp | 2 +-
.../unit/ControllerSocketMetricsPublisherTest.cpp | 2 +-
libminifi/test/unit/CronTests.cpp | 2 +
libminifi/test/unit/EnvironmentUtilsTests.cpp | 7 +-
.../EnvironmentVariableParameterProviderTest.cpp | 12 +-
libminifi/test/unit/ExceptionTests.cpp | 2 +-
libminifi/test/unit/ExpectedTest.cpp | 2 +-
libminifi/test/unit/ExtendedKeyUsageTests.cpp | 20 +-
libminifi/test/unit/ExtensionVerificationTests.cpp | 2 +-
libminifi/test/unit/FileSystemRepositoryTests.cpp | 5 +-
libminifi/test/unit/FileUtilsTests.cpp | 2 +-
libminifi/test/unit/FlowFileQueueSwapTests.cpp | 20 +-
libminifi/test/unit/FlowFileQueueTests.cpp | 1 +
libminifi/test/unit/FlowFileSerializationTests.cpp | 2 +-
libminifi/test/unit/FlowStatusBuilderTests.cpp | 2 +
libminifi/test/unit/GeneralUtilsTest.cpp | 60 +--
libminifi/test/unit/HTTPStreamingCallbackTests.cpp | 2 +-
libminifi/test/unit/IdTests.cpp | 1 +
libminifi/test/unit/MapUtilsTests.cpp | 4 +-
libminifi/test/unit/MemoryUsageTest.cpp | 2 +-
libminifi/test/unit/MetricsPublisherStoreTests.cpp | 2 +
libminifi/test/unit/MetricsTests.cpp | 1 +
libminifi/test/unit/MinifiConcurrentQueueTests.cpp | 2 +-
libminifi/test/unit/NetworkInterfaceInfoTests.cpp | 2 +-
.../test/unit/NetworkPrioritizerServiceTests.cpp | 2 +-
libminifi/test/unit/ParameterTokenParserTest.cpp | 16 +-
libminifi/test/unit/ProcessContextTest.cpp | 4 +-
libminifi/test/unit/ProcessorConfigUtilsTests.cpp | 5 +-
libminifi/test/unit/RegexUtilsTests.cpp | 1 -
libminifi/test/unit/ResponseNodeLoaderTests.cpp | 3 +-
libminifi/test/unit/SchedulingAgentTests.cpp | 2 +
.../test/unit/SiteToSiteCompressionStreamTests.cpp | 215 +++++++++
libminifi/test/unit/SiteToSiteTests.cpp | 182 ++++---
libminifi/test/unit/StreamTests.cpp | 2 +-
libminifi/test/unit/StringUtilsTests.cpp | 20 +-
libminifi/test/unit/TimeUtilTests.cpp | 6 +-
libminifi/test/unit/UpdatePolicyTests.cpp | 1 -
libminifi/test/unit/ZlibStreamTests.cpp | 2 +-
linux.sh | 60 ---
minifi-api/include/minifi-cpp/Connection.h | 7 +-
minifi-api/include/minifi-cpp/FlowFileRecord.h | 2 +-
minifi-api/include/minifi-cpp/ResourceClaim.h | 1 -
.../minifi-cpp/controllers/RecordSetReader.h | 6 +-
.../minifi-cpp/core/AgentIdentificationProvider.h | 12 +-
minifi-api/include/minifi-cpp/core/Annotation.h | 14 +-
minifi-api/include/minifi-cpp/core/ClassLoader.h | 4 +-
minifi-api/include/minifi-cpp/core/Connectable.h | 2 +-
.../include/minifi-cpp/core/ContentRepository.h | 2 +-
.../include/minifi-cpp/core/ContentSession.h | 2 +-
minifi-api/include/minifi-cpp/core/FlowFile.h | 4 +-
minifi-api/include/minifi-cpp/core/ObjectFactory.h | 4 +-
.../minifi-cpp/core/ProcessContextBuilder.h | 2 +-
minifi-api/include/minifi-cpp/core/ProcessorApi.h | 5 +-
minifi-api/include/minifi-cpp/core/Property.h | 2 +-
.../include/minifi-cpp/core/PropertyDefinition.h | 2 +-
minifi-api/include/minifi-cpp/core/Repository.h | 2 +-
.../minifi-cpp/core/SerializableComponent.h | 6 +-
minifi-api/include/minifi-cpp/core/StreamManager.h | 4 +-
.../include/minifi-cpp/core/TraceableResource.h | 12 +-
.../core/controller/ControllerServiceNode.h | 2 +-
.../core/controller/ControllerServiceProvider.h | 2 +-
.../include/minifi-cpp/core/logging/Logger.h | 2 +-
minifi-api/include/minifi-cpp/io/ArchiveStream.h | 2 +-
minifi-api/include/minifi-cpp/io/OutputStream.h | 14 +-
minifi-api/include/minifi-cpp/io/Stream.h | 2 +-
.../include/minifi-cpp/properties/Configuration.h | 3 -
.../include/minifi-cpp/properties/Configure.h | 2 +-
.../include/minifi-cpp/provenance/Provenance.h | 2 +-
.../include/minifi-cpp/utils/PropertyExceptions.h | 2 +-
minifi_main/AgentDocs.cpp | 2 +-
minifi_main/Fips.h | 2 +-
minifi_main/MiNiFiMain.cpp | 2 +-
minifi_main/TableFormatter.cpp | 2 +-
rheldistro.sh | 91 ----
run_flake8.sh | 2 +-
suse.sh | 96 ----
875 files changed, 3086 insertions(+), 5845 deletions(-)
delete mode 100644 aptitude.sh
delete mode 100644 arch.sh
rename
behave_framework/src/minifi_test_framework/containers/{docker_container_builder.py
=> docker_image_builder.py} (81%)
delete mode 100755 bootstrap.sh
delete mode 100755 bstrp_functions.sh
delete mode 100644 centos.sh
delete mode 100644 core-framework/include/Exception.h
delete mode 100644 core-framework/include/SwapManager.h
delete mode 100644 core-framework/include/agent/agent_version.h
delete mode 100644 core-framework/include/core/Annotation.h
delete mode 100644 core-framework/include/core/OutputAttributeDefinition.h
delete mode 100644 core-framework/include/core/Property.h
delete mode 100644 core-framework/include/core/PropertyDefinition.h
delete mode 100644 core-framework/include/core/RelationshipDefinition.h
delete mode 100644 core-framework/include/core/logging/Logger.h
delete mode 100644 core-framework/include/io/ArchiveStream.h
delete mode 100644 core-framework/include/utils/Export.h
delete mode 100644 core-framework/include/utils/Literals.h
delete mode 100644 core-framework/include/utils/PropertyExceptions.h
delete mode 100644 core-framework/include/utils/gsl.h
rename {extension-framework => core-framework}/src/utils/CallBackTimer.cpp
(100%)
delete mode 100644 darwin.sh
delete mode 100644 debian.sh
delete mode 100755 deploy.sh
rename docker/test/integration/features/{consume_kafka.feature =>
consumekafka.feature} (84%)
delete mode 100644
docker/test/integration/minifi/processors/ExecutePythonProcessor.py
delete mode 100644
docker/test/integration/resources/python/add_attribute_to_flowfile.py
delete mode 100644 extension-framework/include/FlowFileRecord.h
delete mode 100644 extension-framework/include/ResourceClaim.h
delete mode 100644 extension-framework/include/controllers/SSLContextService.h
delete mode 100644
extension-framework/include/controllers/SSLContextServiceInterface.h
delete mode 100644 extension-framework/include/core/FlowFile.h
delete mode 100644 extension-framework/include/properties/Configure.h
delete mode 100644 extension-framework/include/properties/Properties.h
delete mode 100644 extension-framework/src/core/ProcessContext.cpp
delete mode 100644 fedora.sh
delete mode 100644 libminifi/include/core/controller/ControllerServiceLookup.h
delete mode 100644 libminifi/include/core/logging/LoggerFactory.h
copy libminifi/include/sitetosite/{SiteToSiteFactory.h => CompressionConsts.h}
(82%)
copy libminifi/include/sitetosite/{SiteToSiteFactory.h =>
CompressionInputStream.h} (51%)
copy libminifi/include/sitetosite/{SiteToSiteFactory.h =>
CompressionOutputStream.h} (53%)
delete mode 100644 libminifi/src/io/AtomicEntryStream.cpp
create mode 100644 libminifi/src/sitetosite/CompressionInputStream.cpp
create mode 100644 libminifi/src/sitetosite/CompressionOutputStream.cpp
delete mode 100644 libminifi/src/utils/CallBackTimer.cpp
create mode 100644 libminifi/test/unit/SiteToSiteCompressionStreamTests.cpp
delete mode 100644 linux.sh
delete mode 100644 rheldistro.sh
delete mode 100644 suse.sh
