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 feb5a1b MINIFICPP-1678 - Create PutUDP processor, add expected-lite
new a9a0ade MINIFICPP-1630 Create FetchAzureDataLakeStorage processor
new 24b433c MINIFICPP-1718 - Handle case sensitive column names
new faa370d MINIFICPP-1723 Use newer macos and xcode in github actions
new de987db MINIFICPP-1691: PutSplunkHTTP and QuerySplunkIndexingStatus
The 4 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:
.github/workflows/ci.yml | 19 +-
CMakeLists.txt | 6 +
PROCESSORS.md | 133 ++++++++++++
README.md | 3 +-
bootstrap.sh | 2 +
bstrp_functions.sh | 6 +-
cmake/DockerConfig.cmake | 1 +
docker/Dockerfile | 3 +-
docker/requirements.txt | 1 +
.../integration/MiNiFi_integration_test_driver.py | 12 ++
docker/test/integration/features/splunk.feature | 50 +++++
docker/test/integration/features/sql.feature | 34 ++-
.../integration/minifi/core/DockerTestCluster.py | 71 +++++++
docker/test/integration/minifi/core/ImageStore.py | 8 +
.../test/integration/minifi/core/SSL_cert_utils.py | 79 +++++++
.../minifi/core/SingleNodeDockerCluster.py | 3 +
.../{MqttBrokerContainer.py => SplunkContainer.py} | 14 +-
.../integration/minifi/processors/PutSplunkHTTP.py | 14 ++
.../minifi/processors/QuerySplunkIndexingStatus.py | 15 ++
.../integration/resources/splunk-hec/Dockerfile | 2 +
.../resources/splunk-hec/conf/default.yml | 6 +
docker/test/integration/steps/steps.py | 56 ++++-
extensions/aws/processors/FetchS3Object.cpp | 2 +-
extensions/aws/processors/FetchS3Object.h | 11 +-
.../azure/processors/FetchAzureDataLakeStorage.cpp | 126 +++++++++++
.../azure/processors/FetchAzureDataLakeStorage.h | 100 +++++++++
extensions/azure/storage/AzureDataLakeStorage.cpp | 13 +-
extensions/azure/storage/AzureDataLakeStorage.h | 2 +
.../azure/storage/AzureDataLakeStorageClient.cpp | 39 +++-
.../azure/storage/AzureDataLakeStorageClient.h | 29 ++-
extensions/azure/storage/DataLakeStorageClient.h | 9 +
extensions/http-curl/client/HTTPClient.cpp | 5 +-
extensions/http-curl/processors/InvokeHTTP.cpp | 7 -
.../http-curl/tests/unit/HTTPClientTests.cpp | 6 +
extensions/{librdkafka => splunk}/CMakeLists.txt | 14 +-
extensions/splunk/PutSplunkHTTP.cpp | 176 ++++++++++++++++
.../MotionDetector.h => splunk/PutSplunkHTTP.h} | 67 +++---
extensions/splunk/QuerySplunkIndexingStatus.cpp | 202 ++++++++++++++++++
extensions/splunk/QuerySplunkIndexingStatus.h | 61 ++++++
.../data/Utils.h => splunk/SplunkAttributes.h} | 21 +-
extensions/splunk/SplunkHECProcessor.cpp | 81 +++++++
extensions/splunk/SplunkHECProcessor.h | 61 ++++++
.../splunk/tests}/CMakeLists.txt | 31 +--
extensions/splunk/tests/MockSplunkHEC.h | 233 +++++++++++++++++++++
extensions/splunk/tests/PutSplunkHTTPTests.cpp | 168 +++++++++++++++
.../tests/QuerySplunkIndexingStatusTests.cpp | 151 +++++++++++++
extensions/sql/data/JSONSQLWriter.cpp | 1 -
extensions/sql/data/MaxCollector.h | 20 +-
.../data/{Utils.cpp => SQLColumnIdentifier.cpp} | 40 ++--
.../sql/data/SQLColumnIdentifier.h | 57 ++---
extensions/sql/data/SQLRowsetProcessor.cpp | 5 +-
extensions/sql/processors/QueryDatabaseTable.cpp | 60 +++---
extensions/sql/processors/QueryDatabaseTable.h | 7 +-
.../tests/unit/ProcessorTests.cpp | 2 +-
libminifi/test/ReadFromFlowFileTestProcessor.cpp | 28 ++-
libminifi/test/ReadFromFlowFileTestProcessor.h | 16 +-
libminifi/test/TestBase.cpp | 4 +
libminifi/test/TestBase.h | 1 +
.../azure-tests/AzureDataLakeStorageTestsFixture.h | 33 ++-
...ests.cpp => FetchAzureDataLakeStorageTests.cpp} | 83 ++++----
.../test/azure-tests/MockDataLakeStorageClient.h | 37 ++++
.../test/sql-tests/SQLColumnIdentifierTests.cpp | 56 +++++
libminifi/test/sql-tests/mocks/MockConnectors.cpp | 28 ++-
libminifi/test/sql-tests/mocks/MockConnectors.h | 2 +-
win_build_vs.bat | 3 +-
65 files changed, 2338 insertions(+), 298 deletions(-)
create mode 100644 docker/test/integration/features/splunk.feature
copy docker/test/integration/minifi/core/{MqttBrokerContainer.py =>
SplunkContainer.py} (53%)
create mode 100644 docker/test/integration/minifi/processors/PutSplunkHTTP.py
create mode 100644
docker/test/integration/minifi/processors/QuerySplunkIndexingStatus.py
create mode 100644 docker/test/integration/resources/splunk-hec/Dockerfile
create mode 100644
docker/test/integration/resources/splunk-hec/conf/default.yml
create mode 100644 extensions/azure/processors/FetchAzureDataLakeStorage.cpp
create mode 100644 extensions/azure/processors/FetchAzureDataLakeStorage.h
copy extensions/{librdkafka => splunk}/CMakeLists.txt (69%)
create mode 100644 extensions/splunk/PutSplunkHTTP.cpp
copy extensions/{opencv/MotionDetector.h => splunk/PutSplunkHTTP.h} (50%)
create mode 100644 extensions/splunk/QuerySplunkIndexingStatus.cpp
create mode 100644 extensions/splunk/QuerySplunkIndexingStatus.h
rename extensions/{sql/data/Utils.h => splunk/SplunkAttributes.h} (67%)
create mode 100644 extensions/splunk/SplunkHECProcessor.cpp
create mode 100644 extensions/splunk/SplunkHECProcessor.h
copy {libminifi/test/flow-tests => extensions/splunk/tests}/CMakeLists.txt
(56%)
create mode 100644 extensions/splunk/tests/MockSplunkHEC.h
create mode 100644 extensions/splunk/tests/PutSplunkHTTPTests.cpp
create mode 100644 extensions/splunk/tests/QuerySplunkIndexingStatusTests.cpp
rename extensions/sql/data/{Utils.cpp => SQLColumnIdentifier.cpp} (57%)
copy libminifi/test/Path.h => extensions/sql/data/SQLColumnIdentifier.h (51%)
copy libminifi/test/azure-tests/{DeleteAzureDataLakeStorageTests.cpp =>
FetchAzureDataLakeStorageTests.cpp} (62%)
create mode 100644 libminifi/test/sql-tests/SQLColumnIdentifierTests.cpp
