This is an automated email from the ASF dual-hosted git repository.
lordgamez pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git.
from de987db MINIFICPP-1691: PutSplunkHTTP and QuerySplunkIndexingStatus
new 4045e78 MINIFICPP-1699 Add kubernetes-client-c library dependency
new 78050f3 MINIFICPP-1722 - Restore 'artifact' field
new 59b204f MINIFICPP-1688: When storing time durations we should use
std::chrono instead of simple integers
The 3 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 | 2 +-
CMakeLists.txt | 7 +
LICENSE | 422 +++++++++++++++++++++
NOTICE | 3 +
cmake/BundledLibreSSL.cmake | 1 +
cmake/KubernetesClientC.cmake | 52 +++
extensions/aws/processors/ListS3.cpp | 7 +-
extensions/aws/processors/S3Processor.cpp | 7 +-
extensions/expression-language/Expression.cpp | 7 +-
extensions/http-curl/processors/InvokeHTTP.cpp | 14 +-
extensions/http-curl/tests/C2PauseResumeTest.cpp | 2 +-
extensions/http-curl/tests/C2UpdateTest.cpp | 4 +-
extensions/jni/jvm/JniFlowFile.cpp | 6 +-
extensions/{pdh => kubernetes}/CMakeLists.txt | 16 +-
extensions/kubernetes/KubernetesClientPOC.cpp | 123 ++++++
extensions/libarchive/BinFiles.cpp | 20 +-
extensions/libarchive/BinFiles.h | 17 +-
extensions/librdkafka/ConsumeKafka.cpp | 11 +-
extensions/librdkafka/PublishKafka.cpp | 60 ++-
.../controllerservice/MQTTControllerService.cpp | 4 +-
.../mqtt/controllerservice/MQTTControllerService.h | 12 +-
.../mqtt/processors/AbstractMQTTProcessor.cpp | 28 +-
extensions/mqtt/processors/AbstractMQTTProcessor.h | 10 +-
.../SourceInitiatedSubscriptionListener.cpp | 41 +-
.../SourceInitiatedSubscriptionListener.h | 10 +-
extensions/rocksdb-repos/FlowFileRepository.cpp | 9 +-
extensions/rocksdb-repos/FlowFileRepository.h | 25 +-
extensions/rocksdb-repos/ProvenanceRepository.h | 21 +-
extensions/sftp/client/SFTPClient.cpp | 9 +-
extensions/sftp/client/SFTPClient.h | 6 +-
extensions/sftp/processors/ListSFTP.cpp | 59 ++-
extensions/sftp/processors/ListSFTP.h | 8 +-
extensions/sftp/processors/SFTPProcessorBase.cpp | 20 +-
extensions/sftp/processors/SFTPProcessorBase.h | 4 +-
extensions/splunk/QuerySplunkIndexingStatus.cpp | 8 +-
.../processors/DefragmentText.cpp | 24 +-
.../processors/DefragmentText.h | 2 +-
.../processors/ExecuteProcess.cpp | 16 +-
.../processors/ExecuteProcess.h | 3 +-
.../standard-processors/processors/GetFile.cpp | 20 +-
.../standard-processors/processors/GetFile.h | 11 +-
.../standard-processors/processors/GetTCP.cpp | 17 +-
extensions/standard-processors/processors/GetTCP.h | 3 +-
.../processors/LogAttribute.cpp | 4 +-
.../tests/unit/GetFileTests.cpp | 7 +-
.../tests/unit/TailFileTests.cpp | 24 +-
.../tests/unit/YamlConfigurationTests.cpp | 18 +-
.../tests/unit/YamlConnectionParserTest.cpp | 8 +-
extensions/usb-camera/GetUSBCamera.cpp | 4 +-
extensions/usb-camera/GetUSBCamera.h | 2 +-
.../CollectorInitiatedSubscription.cpp | 4 +-
.../windows-event-log/ConsumeWindowsEventLog.cpp | 4 +-
libminifi/include/Connection.h | 18 +-
libminifi/include/FlowControlProtocol.h | 4 +-
libminifi/include/RemoteProcessorGroupPort.h | 4 +-
libminifi/include/SchedulingAgent.h | 8 +-
libminifi/include/c2/C2Agent.h | 4 +-
.../AbstractAutoPersistingKeyValueStoreService.h | 2 +-
libminifi/include/core/ConfigurableComponent.h | 8 +-
libminifi/include/core/FlowFile.h | 18 +-
libminifi/include/core/ProcessContext.h | 4 +-
libminifi/include/core/ProcessGroup.h | 18 +-
libminifi/include/core/Processor.h | 65 ++--
libminifi/include/core/ProcessorConfig.h | 6 +-
libminifi/include/core/Property.h | 93 -----
libminifi/include/core/PropertyValidation.h | 5 +-
libminifi/include/core/Repository.h | 18 +-
libminifi/include/core/TypedValues.h | 51 +--
.../core/repository/VolatileFlowFileRepository.h | 10 +-
.../core/repository/VolatileProvenanceRepository.h | 8 +-
.../include/core/repository/VolatileRepository.h | 12 +-
.../include/core/state/nodes/AgentInformation.h | 5 +-
.../include/core/state/nodes/SchedulingNodes.h | 6 +-
libminifi/include/core/yaml/YamlConnectionParser.h | 2 +-
libminifi/include/provenance/Provenance.h | 34 +-
libminifi/include/sitetosite/Peer.h | 66 ++--
libminifi/include/sitetosite/RawSocketProtocol.h | 24 +-
libminifi/include/sitetosite/SiteToSiteClient.h | 2 +-
libminifi/include/utils/StringUtils.h | 13 -
libminifi/include/utils/ThreadPool.h | 4 +-
libminifi/include/utils/TimeUtil.h | 113 +++++-
libminifi/include/utils/ValueParser.h | 59 ---
libminifi/src/Connection.cpp | 40 +-
libminifi/src/CronDrivenSchedulingAgent.cpp | 8 +-
libminifi/src/DiskSpaceWatchdog.cpp | 10 +-
libminifi/src/EventDrivenSchedulingAgent.cpp | 5 +-
libminifi/src/FlowFileRecord.cpp | 21 +-
libminifi/src/RemoteProcessorGroupPort.cpp | 15 +-
libminifi/src/ThreadedSchedulingAgent.cpp | 11 +-
libminifi/src/TimerDrivenSchedulingAgent.cpp | 11 +-
libminifi/src/c2/C2Agent.cpp | 21 +-
.../AbstractAutoPersistingKeyValueStoreService.cpp | 17 +-
libminifi/src/core/FlowFile.cpp | 13 +-
libminifi/src/core/ProcessGroup.cpp | 6 +-
libminifi/src/core/ProcessSession.cpp | 33 +-
libminifi/src/core/Processor.cpp | 33 +-
libminifi/src/core/Repository.cpp | 7 +-
libminifi/src/core/RepositoryFactory.cpp | 8 +-
.../SiteToSiteProvenanceReportingTask.cpp | 6 +-
.../core/repository/VolatileContentRepository.cpp | 4 +-
libminifi/src/core/yaml/YamlConfiguration.cpp | 65 ++--
libminifi/src/core/yaml/YamlConnectionParser.cpp | 16 +-
libminifi/src/provenance/Provenance.cpp | 53 ++-
libminifi/src/sitetosite/RawSocketProtocol.cpp | 8 +-
libminifi/src/sitetosite/SiteToSiteClient.cpp | 19 +-
libminifi/src/utils/ProcessorConfigUtils.cpp | 9 +-
libminifi/test/TestBase.cpp | 8 +-
.../DeleteAzureDataLakeStorageTests.cpp | 2 +-
.../azure-tests/PutAzureDataLakeStorageTests.cpp | 2 +-
libminifi/test/flow-tests/FlowControllerTests.cpp | 4 +-
.../rocksdb-tests/DBProvenanceRepositoryTests.cpp | 12 +-
libminifi/test/rocksdb-tests/ProvenanceTests.cpp | 11 +-
libminifi/test/rocksdb-tests/RepoTests.cpp | 15 +-
libminifi/test/unit/ComponentManifestTests.cpp | 101 +++++
libminifi/test/unit/ConnectionTests.cpp | 10 +-
libminifi/test/unit/CpuUsageTest.cpp | 45 ++-
libminifi/test/unit/FileUtilsTests.cpp | 7 +-
libminifi/test/unit/PropertyTests.cpp | 68 ----
libminifi/test/unit/PropertyValidationTests.cpp | 27 ++
libminifi/test/unit/ProvenanceTestHelper.h | 6 +-
libminifi/test/unit/TimeUtilTests.cpp | 57 +++
libminifi/test/unit/tls/TLSStreamTests.cpp | 2 +-
nanofi/include/sitetosite/CRawSocketProtocol.h | 2 +-
.../kubernetes-client-c/remove-findpackage.patch | 12 +
124 files changed, 1651 insertions(+), 1089 deletions(-)
create mode 100644 cmake/KubernetesClientC.cmake
copy extensions/{pdh => kubernetes}/CMakeLists.txt (76%)
create mode 100644 extensions/kubernetes/KubernetesClientPOC.cpp
create mode 100644 libminifi/test/unit/ComponentManifestTests.cpp
create mode 100644 thirdparty/kubernetes-client-c/remove-findpackage.patch
