This is an automated email from the ASF dual-hosted git repository.
szaszm pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git
from a89a27c9a Bump pyopenssl from 25.0.0 to 26.0.0 in /behave_framework
new 131f6e4dd MINIFICPP-2669 - Reduce controller service api
new 4a857ef4a MINIFICPP-2696 Add option for optimizationForSmallDB in
DatabaseConte…
new a30037b94 MINIFICPP-2751 Remove MinifiStatusToString before C Api is
finalized
new 5ccdfd588 MINIFICPP-2753 - Remove restore from c-api
new 2060d13d8 MINIFICPP-2755 fix macOS CI failure
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:
.github/workflows/ci.yml | 4 +-
CONFIGURE.md | 14 ++
CONTROLLERS.md | 2 +-
conf/minifi.properties.in | 1 +
controller/MiNiFiController.cpp | 4 +-
controller/tests/ControllerTests.cpp | 3 +-
core-framework/include/core/Resource.h | 6 +
.../include/core/controller/ControllerService.h | 121 ------------
.../core/controller/ControllerServiceBase.h | 114 ++++++++++++
.../core/controller/ControllerServiceFactoryImpl.h | 49 +++--
core-framework/include/http/HTTPClient.h | 1 +
core-framework/include/utils/ThreadPool.h | 21 +--
core-framework/src/utils/ThreadPool.cpp | 65 +------
encrypt-config/FlowConfigEncryptor.cpp | 2 +-
.../include/api/core/ProcessorImpl.h | 2 -
.../cpp-extension-lib/include/api/core/Resource.h | 3 -
.../cpp-extension-lib/src/core/ProcessorImpl.cpp | 4 -
.../include/controllers/AttributeProviderService.h | 10 +-
.../include/controllers/RecordSetReader.h | 8 +-
.../include/controllers/RecordSetWriter.h | 8 +-
.../controllers/keyvalue/KeyValueStateStorage.h | 20 +-
.../include/utils/ProcessorConfigUtils.h | 2 +-
.../controllers/keyvalue/KeyValueStateStorage.cpp | 4 -
.../aws/controllerservices/AWSCredentialsService.h | 25 +--
extensions/aws/tests/AWSCredentialsServiceTest.cpp | 6 +-
.../aws/tests/MultipartUploadStateStorageTest.cpp | 7 +-
.../AzureStorageCredentialsService.h | 27 +--
.../azure/processors/AzureStorageProcessorBase.cpp | 2 +-
extensions/civetweb/tests/ListenHTTPTests.cpp | 3 +-
.../controllerservices/CouchbaseClusterService.h | 26 +--
.../couchbase/tests/GetCouchbaseKeyTests.cpp | 2 +-
.../couchbase/tests/PutCouchbaseKeyTests.cpp | 2 +-
.../ElasticsearchCredentialsControllerService.h | 19 +-
.../GCPCredentialsControllerService.h | 20 +-
.../tests/GCPCredentialsControllerServiceTests.cpp | 4 +-
.../KubernetesControllerService.cpp | 12 --
.../KubernetesControllerService.h | 4 +-
.../rocksdb-repos/DatabaseContentRepository.cpp | 40 +++-
extensions/rocksdb-repos/FlowFileLoader.h | 2 +-
.../controllers/RocksDbStateStorage.cpp | 5 -
.../controllers/RocksDbStateStorage.h | 4 +-
extensions/rocksdb-repos/database/OpenRocksDb.cpp | 26 +--
extensions/rocksdb-repos/database/OpenRocksDb.h | 2 +
extensions/rocksdb-repos/database/RocksDbUtils.h | 12 ++
.../tests/DBContentRepositoryTests.cpp | 41 ++++
extensions/smb/SmbConnectionControllerService.h | 11 +-
extensions/smb/tests/FetchSmbTests.cpp | 2 +-
extensions/smb/tests/ListAndFetchSmbTests.cpp | 2 +-
extensions/smb/tests/ListSmbTests.cpp | 2 +-
extensions/smb/tests/PutSmbTests.cpp | 4 +-
.../tests/SmbConnectionControllerServiceTests.cpp | 2 +-
extensions/sql/CMakeLists.txt | 4 +-
extensions/sql/services/DatabaseService.cpp | 4 +-
extensions/sql/services/DatabaseService.h | 35 +---
extensions/sql/services/ODBCConnector.h | 16 +-
extensions/sql/tests/mocks/MockODBCService.h | 16 +-
.../controllers/JsonRecordSetWriter.h | 5 +-
.../controllers/JsonTreeReader.h | 5 +-
.../controllers/PersistentMapStateStorage.cpp | 11 --
.../controllers/PersistentMapStateStorage.h | 4 +-
.../controllers/VolatileMapStateStorage.cpp | 10 -
.../controllers/VolatileMapStateStorage.h | 5 +-
.../standard-processors/controllers/XMLReader.h | 6 +-
.../controllers/XMLRecordSetWriter.h | 6 +-
.../tests/unit/ControllerServiceTests.cpp | 4 +-
.../tests/unit/JsonRecordTests.cpp | 17 +-
.../tests/unit/TailFileTests.cpp | 2 +-
.../tests/unit/XMLReaderTests.cpp | 13 +-
.../tests/unit/XMLRecordSetWriterTests.cpp | 39 ++--
libminifi/include/FlowController.h | 2 +-
libminifi/include/SchedulingAgent.h | 2 +-
libminifi/include/c2/C2Protocol.h | 2 +-
libminifi/include/c2/ControllerSocketProtocol.h | 2 +-
libminifi/include/c2/HeartbeatReporter.h | 2 +-
.../controllers/NetworkPrioritizerService.h | 70 +++----
libminifi/include/controllers/SSLContextService.h | 86 +--------
.../include/controllers/ThreadManagementService.h | 82 --------
.../controllers/UpdatePolicyControllerService.h | 23 +--
libminifi/include/core/FlowConfiguration.h | 2 +-
libminifi/include/core/ProcessContextImpl.h | 13 +-
libminifi/include/core/ProcessGroup.h | 2 +-
.../include/core/controller/ControllerService.h | 158 ++++++++++++++++
.../core/controller/ControllerServiceLookup.h | 22 +--
.../core/controller/ControllerServiceNode.h | 29 ++-
.../core/controller/ControllerServiceNodeMap.h | 2 +-
.../core/controller/ControllerServiceProvider.h | 97 +++-------
.../ForwardingControllerServiceProvider.h | 18 +-
.../controller/StandardControllerServiceNode.h | 9 +-
.../controller/StandardControllerServiceProvider.h | 6 +-
libminifi/include/io/NetworkPrioritizer.h | 29 ---
libminifi/include/utils/CProcessor.h | 4 +-
libminifi/src/Configuration.cpp | 1 +
libminifi/src/FlowController.cpp | 7 +-
libminifi/src/RemoteProcessGroupPort.cpp | 6 +-
libminifi/src/c2/C2Agent.cpp | 6 +-
libminifi/src/c2/ControllerSocketProtocol.cpp | 3 +-
libminifi/src/c2/protocols/RESTSender.cpp | 7 +-
.../src/controllers/NetworkPrioritizerService.cpp | 42 ++---
libminifi/src/controllers/SSLContextService.cpp | 69 ++++++-
.../controllers/UpdatePolicyControllerService.cpp | 11 --
libminifi/src/core/ClassLoader.cpp | 43 +++++
.../src/core/controller/ControllerServiceNode.cpp | 8 +-
.../core/controller/ControllerServiceProvider.cpp | 6 +-
libminifi/src/core/logging/LoggerConfiguration.cpp | 3 +-
.../state/nodes/RepositoryMetricsSourceStore.cpp | 6 +
.../src/core/state/nodes/ResponseNodeLoader.cpp | 8 +-
libminifi/src/minifi-c.cpp | 15 --
libminifi/src/properties/Properties.cpp | 1 +
.../integration/C2ControllerEnableFailureTest.cpp | 20 +-
.../ControllerServiceIntegrationTests.cpp | 2 +-
.../keyvalue-tests/PersistentStateStorageTest.cpp | 3 +-
.../keyvalue-tests/VolatileMapStateStorageTest.cpp | 3 +-
.../test/libtest/integration/HTTPHandlers.cpp | 1 +
libminifi/test/libtest/integration/HTTPHandlers.h | 2 +-
.../{ProcessorUtils.h => ControllerServiceUtils.h} | 22 +--
libminifi/test/libtest/unit/MockClasses.h | 31 +---
libminifi/test/libtest/unit/ProvenanceTestHelper.h | 4 +-
libminifi/test/libtest/unit/TestUtils.cpp | 39 ++++
libminifi/test/libtest/unit/TestUtils.h | 18 +-
libminifi/test/unit/BackTraceTests.cpp | 2 +-
libminifi/test/unit/ComponentManifestTests.cpp | 16 +-
libminifi/test/unit/JsonFlowSerializerTests.cpp | 4 +-
libminifi/test/unit/LogMetricsPublisherTests.cpp | 206 +++++++++------------
libminifi/test/unit/MetricsTests.cpp | 4 +-
libminifi/test/unit/NetUtilsTest.cpp | 16 +-
.../test/unit/NetworkPrioritizerServiceTests.cpp | 45 +++--
libminifi/test/unit/ProcessorConfigUtilsTests.cpp | 31 ++--
libminifi/test/unit/UpdatePolicyTests.cpp | 25 +--
libminifi/test/unit/YamlFlowSerializerTests.cpp | 4 +-
minifi-api/CMakeLists.txt | 1 +
minifi-api/include/minifi-c/minifi-c.h | 3 -
.../controllers/AttributeProviderService.h | 4 +-
.../minifi-cpp/controllers/RecordSetReader.h | 6 +-
.../minifi-cpp/controllers/RecordSetWriter.h | 6 +-
.../controllers/SSLContextServiceInterface.h | 7 +-
.../controllers/ThreadManagementService.h | 75 --------
minifi-api/include/minifi-cpp/core/ClassLoader.h | 3 +
.../core/ControllerServiceApiDefinition.h | 1 +
.../include/minifi-cpp/core/ProcessContext.h | 4 +-
.../minifi-cpp/core/RepositoryMetricsSource.h | 2 +
.../minifi-cpp/core/controller/ControllerService.h | 54 ------
.../core/controller/ControllerServiceApi.h | 48 +++++
.../core/controller/ControllerServiceContext.h | 20 +-
.../core/controller/ControllerServiceDescriptor.h | 15 +-
.../ControllerServiceFactory.h} | 16 +-
.../ControllerServiceHandle.h} | 19 +-
.../core/controller/ControllerServiceMetadata.h} | 6 +-
.../core/controller/ControllerServiceProvider.h | 54 ------
.../include/minifi-cpp/properties/Configuration.h | 1 +
minifi-api/minifi-c-api.def | 1 -
150 files changed, 1186 insertions(+), 1546 deletions(-)
delete mode 100644 core-framework/include/core/controller/ControllerService.h
create mode 100644
core-framework/include/core/controller/ControllerServiceBase.h
rename minifi-api/include/minifi-cpp/core/controller/ControllerServiceNode.h
=> core-framework/include/core/controller/ControllerServiceFactoryImpl.h (55%)
delete mode 100644 libminifi/include/controllers/ThreadManagementService.h
create mode 100644 libminifi/include/core/controller/ControllerService.h
rename {minifi-api/include/minifi-cpp =>
libminifi/include}/core/controller/ControllerServiceLookup.h (73%)
copy libminifi/test/libtest/unit/{ProcessorUtils.h =>
ControllerServiceUtils.h} (62%)
delete mode 100644
minifi-api/include/minifi-cpp/controllers/ThreadManagementService.h
delete mode 100644
minifi-api/include/minifi-cpp/core/controller/ControllerService.h
create mode 100644
minifi-api/include/minifi-cpp/core/controller/ControllerServiceApi.h
copy extension-framework/cpp-extension-lib/include/api/core/PublishedMetrics.h
=> minifi-api/include/minifi-cpp/core/controller/ControllerServiceContext.h
(61%)
copy extension-framework/include/controllers/RecordSetReader.h =>
minifi-api/include/minifi-cpp/core/controller/ControllerServiceDescriptor.h
(69%)
copy minifi-api/include/minifi-cpp/core/{ProcessorFactory.h =>
controller/ControllerServiceFactory.h} (66%)
copy minifi-api/include/minifi-cpp/core/{ProcessSessionFactory.h =>
controller/ControllerServiceHandle.h} (69%)
copy minifi-api/{common/include/minifi-cpp/core/ProcessorMetadata.h =>
include/minifi-cpp/core/controller/ControllerServiceMetadata.h} (87%)
delete mode 100644
minifi-api/include/minifi-cpp/core/controller/ControllerServiceProvider.h
