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 38179ed19 MINIFICPP-2698 Update NOTICE year to 2026
new 90ddaae14 MINIFICPP-2678 Move Grafana Loki tests to modular docker
tests
new 34a79a9e3 MINIFICPP-2680 Move Amazon Kinesis tests to modular docker
tests
new a55d53657 MINIFICPP-2682 Move Lua tests to modular docker tests
new b6d0eb137 MINIFICPP-2701 ListenUDP udp.sender.port property
new 7e8ec5367 MINIFICPP-2704 Fix API version compatibility issue in Azure
tests
The 5 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:
PROCESSORS.md | 9 +-
.../containers/docker_image_builder.py | 9 +-
.../src/minifi_test_framework/minifi/processor.py | 6 +
.../minifi_test_framework/steps/checking_steps.py | 7 +
.../steps/flow_building_steps.py | 6 +
.../include/utils/MinifiConcurrentQueue.h | 15 +-
docker/RunBehaveTests.sh | 4 +-
docker/test/integration/cluster/ContainerStore.py | 45 ------
.../test/integration/cluster/DockerTestCluster.py | 34 ----
.../cluster/DockerTestDirectoryBindings.py | 1 -
docker/test/integration/cluster/ImageStore.py | 10 --
.../integration/cluster/checkers/AwsChecker.py | 66 --------
.../cluster/checkers/GrafanaLokiChecker.py | 54 -------
.../cluster/containers/GrafanaLokiContainer.py | 176 ---------------------
.../cluster/containers/KinesisServerContainer.py | 41 -----
.../cluster/containers/ReverseProxyContainer.py | 43 -----
.../cluster/containers/S3ServerContainer.py | 40 -----
.../features/MiNiFi_integration_test_driver.py | 25 ---
docker/test/integration/features/steps/steps.py | 83 ----------
.../minifi/processors/DeleteS3Object.py | 42 -----
.../integration/minifi/processors/FetchS3Object.py | 41 -----
.../test/integration/minifi/processors/ListS3.py | 41 -----
.../minifi/processors/PushGrafanaLokiGrpc.py | 24 ---
.../minifi/processors/PushGrafanaLokiREST.py | 24 ---
.../minifi/processors/PutKinesisStream.py | 42 -----
.../integration/minifi/processors/PutS3Object.py | 43 -----
.../integration/resources/reverse-proxy/Dockerfile | 17 --
.../resources/reverse-proxy/nginx-basic-auth.conf | 12 --
.../integration/resources/reverse-proxy/run.sh | 5 -
extension-framework/include/utils/net/Message.h | 15 +-
extension-framework/include/utils/net/Server.h | 8 +-
extension-framework/include/utils/net/TcpServer.h | 6 +-
extension-framework/include/utils/net/UdpServer.h | 2 -
extension-framework/src/utils/net/TcpServer.cpp | 29 ++--
extension-framework/src/utils/net/UdpServer.cpp | 9 +-
.../aws/tests}/features/kinesis.feature | 22 ++-
.../features}/resources/kinesis-mock/Dockerfile | 0
.../resources/kinesis-mock/consumer/consumer.js | 0
.../resources/kinesis-mock/consumer/package.json | 0
.../features}/resources/kinesis-mock/server.json | 0
.../features/steps/kinesis_server_container.py} | 36 +++--
.../tests/features/steps/s3_server_container.py | 4 -
extensions/aws/tests/features/steps/steps.py | 15 +-
.../tests/features/steps/azure_server_container.py | 8 +-
.../tests/features/environment.py | 25 ++-
.../tests}/features/grafana_loki.feature | 44 ++++--
.../resources/check_log_lines_on_grafana.py | 79 +++++++++
.../features/resources/reverse-proxy/Dockerfile | 8 +
.../resources/reverse-proxy/nginx.conf.template | 10 ++
.../tests/features/resources/reverse-proxy/run.sh | 8 +
.../tests/features/steps/grafana_loki_container.py | 151 ++++++++++++++++++
.../features/steps/reverse_proxy_container.py} | 19 ++-
.../grafana-loki/tests/features/steps/steps.py | 63 ++++++++
.../{opc => lua}/tests/features/environment.py | 0
.../lua/tests}/features/lua_script.feature | 7 +-
.../tests/features/resources}/sleep_forever.lua | 0
.../tests/features/steps/steps.py | 0
.../standard-processors/processors/GetTCP.cpp | 20 ++-
extensions/standard-processors/processors/GetTCP.h | 7 +-
.../processors/ListenSyslog.cpp | 4 +-
.../standard-processors/processors/ListenTCP.cpp | 4 +-
.../standard-processors/processors/ListenUDP.cpp | 5 +-
.../standard-processors/processors/ListenUDP.h | 5 +-
.../processors/NetworkListenerProcessor.cpp | 9 +-
.../processors/NetworkListenerProcessor.h | 8 +-
.../tests/unit/ListenSyslogTests.cpp | 26 +--
.../tests/unit/ListenUDPTests.cpp | 24 +--
.../standard-processors/tests/unit/PutTCPTests.cpp | 10 +-
.../standard-processors/tests/unit/PutUDPTests.cpp | 7 +-
libminifi/test/libtest/unit/TestUtils.cpp | 16 +-
libminifi/test/libtest/unit/TestUtils.h | 7 +-
71 files changed, 606 insertions(+), 1079 deletions(-)
delete mode 100644 docker/test/integration/cluster/checkers/AwsChecker.py
delete mode 100644
docker/test/integration/cluster/checkers/GrafanaLokiChecker.py
delete mode 100644
docker/test/integration/cluster/containers/GrafanaLokiContainer.py
delete mode 100644
docker/test/integration/cluster/containers/KinesisServerContainer.py
delete mode 100644
docker/test/integration/cluster/containers/ReverseProxyContainer.py
delete mode 100644
docker/test/integration/cluster/containers/S3ServerContainer.py
delete mode 100644 docker/test/integration/minifi/processors/DeleteS3Object.py
delete mode 100644 docker/test/integration/minifi/processors/FetchS3Object.py
delete mode 100644 docker/test/integration/minifi/processors/ListS3.py
delete mode 100644
docker/test/integration/minifi/processors/PushGrafanaLokiGrpc.py
delete mode 100644
docker/test/integration/minifi/processors/PushGrafanaLokiREST.py
delete mode 100644
docker/test/integration/minifi/processors/PutKinesisStream.py
delete mode 100644 docker/test/integration/minifi/processors/PutS3Object.py
delete mode 100644 docker/test/integration/resources/reverse-proxy/Dockerfile
delete mode 100644
docker/test/integration/resources/reverse-proxy/nginx-basic-auth.conf
delete mode 100644 docker/test/integration/resources/reverse-proxy/run.sh
rename {docker/test/integration =>
extensions/aws/tests}/features/kinesis.feature (59%)
rename {docker/test/integration =>
extensions/aws/tests/features}/resources/kinesis-mock/Dockerfile (100%)
rename {docker/test/integration =>
extensions/aws/tests/features}/resources/kinesis-mock/consumer/consumer.js
(100%)
rename {docker/test/integration =>
extensions/aws/tests/features}/resources/kinesis-mock/consumer/package.json
(100%)
rename {docker/test/integration =>
extensions/aws/tests/features}/resources/kinesis-mock/server.json (100%)
copy extensions/{gcp/tests/features/steps/fake_gcs_server_container.py =>
aws/tests/features/steps/kinesis_server_container.py} (58%)
copy extensions/{couchbase => grafana-loki}/tests/features/environment.py (58%)
rename {docker/test/integration =>
extensions/grafana-loki/tests}/features/grafana_loki.feature (82%)
create mode 100644
extensions/grafana-loki/tests/features/resources/check_log_lines_on_grafana.py
create mode 100644
extensions/grafana-loki/tests/features/resources/reverse-proxy/Dockerfile
create mode 100644
extensions/grafana-loki/tests/features/resources/reverse-proxy/nginx.conf.template
create mode 100644
extensions/grafana-loki/tests/features/resources/reverse-proxy/run.sh
create mode 100644
extensions/grafana-loki/tests/features/steps/grafana_loki_container.py
copy extensions/{opc/tests/features/steps/opc_ua_server_container.py =>
grafana-loki/tests/features/steps/reverse_proxy_container.py} (69%)
create mode 100644 extensions/grafana-loki/tests/features/steps/steps.py
copy extensions/{opc => lua}/tests/features/environment.py (100%)
rename {docker/test/integration =>
extensions/lua/tests}/features/lua_script.feature (85%)
rename {docker/test/integration/resources/lua =>
extensions/lua/tests/features/resources}/sleep_forever.lua (100%)
copy extensions/{llamacpp => lua}/tests/features/steps/steps.py (100%)
