This is an automated email from the ASF dual-hosted git repository.
fgerlits pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git
from 56c8bffb9 MINIFICPP-2694 Clarify the documentation of drain.timeout
and graceful.shutdown.period
new 40ff0a929 MINIFICPP-2666 Move Kafka tests to modular docker tests
new 9b84de3b8 MINIFICPP-2668 Move standard processor tests to modular
docker tests
new ca4fa86a2 MINIFICPP-2674 Move Couchbase tests to modular docker tests
new d74d89e30 MINIFICPP-2675 Move Elasticsearch tests to modular docker
tests
new 859c22db8 MINIFICPP-2689 Move Splunk tests to modular docker tests
new d71442ae1 MINIFICPP-2677 Move GCP tests to modular docker tests
new 38179ed19 MINIFICPP-2698 Update NOTICE year to 2026
The 7 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
NOTICE | 4 +-
behave_framework/pyproject.toml | 5 +-
.../minifi_test_framework/containers/container.py | 186 +++++++++++++--
.../minifi_test_framework/containers/directory.py | 6 +-
.../src/minifi_test_framework/containers/file.py | 5 +-
.../containers/minifi_container.py | 29 ++-
.../src/minifi_test_framework/core/helpers.py | 32 ++-
.../src/minifi_test_framework/core/hooks.py | 2 +
.../core/minifi_test_context.py | 12 +-
.../src/minifi_test_framework/core/ssl_utils.py | 0
.../minifi/flow_definition.py | 3 +
.../src/minifi_test_framework/minifi/processor.py | 8 +-
.../minifi_test_framework/steps/checking_steps.py | 90 +++++--
.../src/minifi_test_framework/steps/core_steps.py | 31 ++-
.../steps/flow_building_steps.py | 68 +++++-
docker/RunBehaveTests.sh | 7 +-
docker/requirements.txt | 1 -
docker/test/integration/cluster/ContainerStore.py | 72 ------
.../test/integration/cluster/DockerTestCluster.py | 65 ------
docker/test/integration/cluster/ImageStore.py | 10 -
.../cluster/checkers/CouchbaseChecker.py | 69 ------
.../cluster/checkers/ElasticSearchChecker.py | 50 ----
.../integration/cluster/checkers/GcsChecker.py | 30 ---
.../integration/cluster/checkers/KafkaHelper.py | 58 -----
.../integration/cluster/checkers/SplunkChecker.py | 80 -------
.../cluster/containers/CouchbaseServerContainer.py | 125 ----------
.../integration/cluster/containers/DiagSlave.py | 36 ---
.../cluster/containers/ElasticsearchContainer.py | 101 --------
.../cluster/containers/FakeGcsServerContainer.py | 40 ----
.../cluster/containers/KafkaBrokerContainer.py | 163 -------------
.../cluster/containers/OpensearchContainer.py | 80 -------
.../cluster/containers/SplunkContainer.py | 44 ----
.../cluster/containers/TcpClientContainer.py | 39 ----
.../features/MiNiFi_integration_test_driver.py | 62 -----
.../features/google_cloud_storage.feature | 64 -----
.../test/integration/features/steps/kafka_steps.py | 188 ---------------
docker/test/integration/features/steps/steps.py | 216 -----------------
.../minifi/controllers/CouchbaseClusterService.py | 30 ---
.../controllers/ElasticsearchCredentialsService.py | 27 ---
.../controllers/GCPCredentialsControllerService.py | 31 ---
.../integration/minifi/processors/ConsumeKafka.py | 37 ---
.../minifi/processors/DefragmentText.py | 26 ---
.../minifi/processors/DeleteGCSObject.py | 28 ---
.../minifi/processors/EvaluateJsonPath.py | 22 --
.../minifi/processors/FetchGCSObject.py | 28 ---
.../minifi/processors/FetchModbusTcp.py | 26 ---
.../minifi/processors/GetCouchbaseKey.py | 24 --
.../integration/minifi/processors/ListGCSBucket.py | 28 ---
.../integration/minifi/processors/ListenTCP.py | 27 ---
.../minifi/processors/PostElasticsearch.py | 31 ---
.../integration/minifi/processors/PublishKafka.py | 35 ---
.../minifi/processors/PutCouchbaseKey.py | 24 --
.../integration/minifi/processors/PutGCSObject.py | 28 ---
.../integration/minifi/processors/PutSplunkHTTP.py | 31 ---
.../minifi/processors/QuerySplunkIndexingStatus.py | 31 ---
.../integration/minifi/processors/SplitJson.py | 26 ---
.../integration/resources/diagslave/Dockerfile | 5 -
.../fake-gcs-server-data/test-bucket/test-file | 1 -
.../integration/resources/splunk-hec/Dockerfile | 2 -
.../resources/splunk-hec/conf/default.yml | 6 -
extensions/aws/tests/features/s3.feature | 22 +-
.../azure/tests/features/azure_storage.feature | 4 +-
.../couchbase/tests}/features/couchbase.feature | 98 +++++---
.../tests/features/environment.py | 15 +-
.../features/steps/couchbase_server_container.py | 165 +++++++++++++
extensions/couchbase/tests/features/steps/steps.py | 67 ++++++
.../tests}/features/elasticsearch.feature | 42 ++--
.../tests/features/environment.py | 4 -
.../tests}/features/opensearch.feature | 45 ++--
.../tests/features/resources}/elasticsearch.yml | 0
.../tests/features/resources}/opensearch.yml | 0
.../tests/features/steps/elastic_base_container.py | 47 ++++
.../features/steps/elasticsearch_container.py | 97 ++++++++
.../tests/features/steps/opensearch_container.py | 62 +++++
.../elasticsearch/tests/features/steps/steps.py | 80 +++++++
.../{opc => gcp}/tests/features/environment.py | 4 -
.../tests/features/google_cloud_storage.feature | 91 ++++++++
.../features/steps/fake_gcs_server_container.py} | 29 ++-
.../{opc => gcp}/tests/features/steps/steps.py | 32 ++-
.../kafka/tests}/features/consumekafka.feature | 228 +++++++++---------
.../{aws => kafka}/tests/features/environment.py | 15 +-
.../kafka/tests/features/publishkafka.feature | 259 +++++++++++----------
.../tests/features/steps/kafka_server_container.py | 126 ++++++++++
extensions/kafka/tests/features/steps/steps.py | 214 +++++++++++++++++
extensions/splunk/PutSplunkHTTP.cpp | 46 +++-
.../{aws => splunk}/tests/features/environment.py | 9 +-
.../splunk/tests}/features/splunk.feature | 52 +++--
.../tests/features/steps/splunk_container.py | 116 +++++++++
extensions/splunk/tests/features/steps/steps.py | 46 ++++
.../tests/features/attributes_to_json.feature | 2 +-
.../tests}/features/defragtextflowfiles.feature | 25 +-
.../tests/features/environment.py | 9 +-
.../tests}/features/evaluate_json_path.feature | 17 +-
.../tests}/features/fetch_modbus_tcp.feature | 12 +-
.../tests}/features/file_system_operations.feature | 38 +--
.../tests}/features/hashcontent.feature | 23 +-
.../tests}/features/network_listener.feature | 9 +-
.../tests/features/replace_text.feature | 4 +-
.../tests/features/routetext.feature | 2 +-
.../tests}/features/split_json.feature | 24 +-
.../tests/features/splittext.feature | 4 +-
.../tests/features/steps/diag_slave_container.py | 33 ++-
.../tests/features/steps/steps.py | 18 ++
.../tests/features/steps/tcp_client_container.py} | 21 +-
.../tests/features/syslog_listener.feature | 2 +-
105 files changed, 2204 insertions(+), 2689 deletions(-)
copy docker/test/integration/ssl_utils/SSL_cert_utils.py =>
behave_framework/src/minifi_test_framework/core/ssl_utils.py (100%)
delete mode 100644 docker/test/integration/cluster/checkers/CouchbaseChecker.py
delete mode 100644
docker/test/integration/cluster/checkers/ElasticSearchChecker.py
delete mode 100644 docker/test/integration/cluster/checkers/GcsChecker.py
delete mode 100644 docker/test/integration/cluster/checkers/KafkaHelper.py
delete mode 100644 docker/test/integration/cluster/checkers/SplunkChecker.py
delete mode 100644
docker/test/integration/cluster/containers/CouchbaseServerContainer.py
delete mode 100644 docker/test/integration/cluster/containers/DiagSlave.py
delete mode 100644
docker/test/integration/cluster/containers/ElasticsearchContainer.py
delete mode 100644
docker/test/integration/cluster/containers/FakeGcsServerContainer.py
delete mode 100644
docker/test/integration/cluster/containers/KafkaBrokerContainer.py
delete mode 100644
docker/test/integration/cluster/containers/OpensearchContainer.py
delete mode 100644
docker/test/integration/cluster/containers/SplunkContainer.py
delete mode 100644
docker/test/integration/cluster/containers/TcpClientContainer.py
delete mode 100644
docker/test/integration/features/google_cloud_storage.feature
delete mode 100644 docker/test/integration/features/steps/kafka_steps.py
delete mode 100644
docker/test/integration/minifi/controllers/CouchbaseClusterService.py
delete mode 100644
docker/test/integration/minifi/controllers/ElasticsearchCredentialsService.py
delete mode 100644
docker/test/integration/minifi/controllers/GCPCredentialsControllerService.py
delete mode 100644 docker/test/integration/minifi/processors/ConsumeKafka.py
delete mode 100644 docker/test/integration/minifi/processors/DefragmentText.py
delete mode 100644 docker/test/integration/minifi/processors/DeleteGCSObject.py
delete mode 100644
docker/test/integration/minifi/processors/EvaluateJsonPath.py
delete mode 100644 docker/test/integration/minifi/processors/FetchGCSObject.py
delete mode 100644 docker/test/integration/minifi/processors/FetchModbusTcp.py
delete mode 100644 docker/test/integration/minifi/processors/GetCouchbaseKey.py
delete mode 100644 docker/test/integration/minifi/processors/ListGCSBucket.py
delete mode 100644 docker/test/integration/minifi/processors/ListenTCP.py
delete mode 100644
docker/test/integration/minifi/processors/PostElasticsearch.py
delete mode 100644 docker/test/integration/minifi/processors/PublishKafka.py
delete mode 100644 docker/test/integration/minifi/processors/PutCouchbaseKey.py
delete mode 100644 docker/test/integration/minifi/processors/PutGCSObject.py
delete mode 100644 docker/test/integration/minifi/processors/PutSplunkHTTP.py
delete mode 100644
docker/test/integration/minifi/processors/QuerySplunkIndexingStatus.py
delete mode 100644 docker/test/integration/minifi/processors/SplitJson.py
delete mode 100644 docker/test/integration/resources/diagslave/Dockerfile
delete mode 100644
docker/test/integration/resources/fake-gcs-server-data/test-bucket/test-file
delete mode 100644 docker/test/integration/resources/splunk-hec/Dockerfile
delete mode 100644
docker/test/integration/resources/splunk-hec/conf/default.yml
rename {docker/test/integration =>
extensions/couchbase/tests}/features/couchbase.feature (81%)
copy extensions/{aws => couchbase}/tests/features/environment.py (74%)
create mode 100644
extensions/couchbase/tests/features/steps/couchbase_server_container.py
create mode 100644 extensions/couchbase/tests/features/steps/steps.py
rename {docker/test/integration =>
extensions/elasticsearch/tests}/features/elasticsearch.feature (65%)
copy extensions/{opc => elasticsearch}/tests/features/environment.py (92%)
rename {docker/test/integration =>
extensions/elasticsearch/tests}/features/opensearch.feature (68%)
rename {docker/test/integration/resources/elasticsearch =>
extensions/elasticsearch/tests/features/resources}/elasticsearch.yml (100%)
rename {docker/test/integration/resources/opensearch =>
extensions/elasticsearch/tests/features/resources}/opensearch.yml (100%)
create mode 100644
extensions/elasticsearch/tests/features/steps/elastic_base_container.py
create mode 100644
extensions/elasticsearch/tests/features/steps/elasticsearch_container.py
create mode 100644
extensions/elasticsearch/tests/features/steps/opensearch_container.py
create mode 100644 extensions/elasticsearch/tests/features/steps/steps.py
copy extensions/{opc => gcp}/tests/features/environment.py (92%)
create mode 100644 extensions/gcp/tests/features/google_cloud_storage.feature
copy extensions/{opc/tests/features/steps/opc_ua_server_container.py =>
gcp/tests/features/steps/fake_gcs_server_container.py} (52%)
copy extensions/{opc => gcp}/tests/features/steps/steps.py (56%)
rename {docker/test/integration =>
extensions/kafka/tests}/features/consumekafka.feature (71%)
copy extensions/{aws => kafka}/tests/features/environment.py (75%)
rename docker/test/integration/features/publish_kafka.feature =>
extensions/kafka/tests/features/publishkafka.feature (66%)
create mode 100644
extensions/kafka/tests/features/steps/kafka_server_container.py
create mode 100644 extensions/kafka/tests/features/steps/steps.py
copy extensions/{aws => splunk}/tests/features/environment.py (81%)
rename {docker/test/integration =>
extensions/splunk/tests}/features/splunk.feature (66%)
create mode 100644 extensions/splunk/tests/features/steps/splunk_container.py
create mode 100644 extensions/splunk/tests/features/steps/steps.py
rename {docker/test/integration =>
extensions/standard-processors/tests}/features/defragtextflowfiles.feature (88%)
rename {docker/test/integration =>
extensions/standard-processors/tests}/features/evaluate_json_path.feature (83%)
rename {docker/test/integration =>
extensions/standard-processors/tests}/features/fetch_modbus_tcp.feature (79%)
rename {docker/test/integration =>
extensions/standard-processors/tests}/features/file_system_operations.feature
(67%)
rename {docker/test/integration =>
extensions/standard-processors/tests}/features/hashcontent.feature (83%)
rename {docker/test/integration =>
extensions/standard-processors/tests}/features/network_listener.feature (83%)
rename {docker/test/integration =>
extensions/standard-processors/tests}/features/split_json.feature (70%)
copy
behave_framework/src/minifi_test_framework/containers/http_proxy_container.py
=> extensions/standard-processors/tests/features/steps/diag_slave_container.py
(51%)
copy extensions/{opc/tests/features/steps/opc_ua_server_container.py =>
standard-processors/tests/features/steps/tcp_client_container.py} (66%)
