This is an automated email from the ASF dual-hosted git repository.
exceptionfactory pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi-api.git
The following commit(s) were added to refs/heads/main by this push:
new f90a41f NIFI-15055 Add FLOW_REGISTRY_CLIENT to ExtensionType to NiFi
API (#21)
f90a41f is described below
commit f90a41f6192ae626b442f6aa8876adcb9ed0940e
Author: Pierre Villard <[email protected]>
AuthorDate: Mon Oct 6 14:19:17 2025 +0200
NIFI-15055 Add FLOW_REGISTRY_CLIENT to ExtensionType to NiFi API (#21)
Signed-off-by: David Handermann <[email protected]>
---
.../documentation/AbstractDocumentationWriter.java | 11 ++++++++
.../apache/nifi/documentation/ExtensionType.java | 4 ++-
...onFlowRegistryClientInitializationContext.java} | 29 ++++++++++++++++------
3 files changed, 36 insertions(+), 8 deletions(-)
diff --git
a/src/main/java/org/apache/nifi/documentation/AbstractDocumentationWriter.java
b/src/main/java/org/apache/nifi/documentation/AbstractDocumentationWriter.java
index 727b097..5a4b555 100644
---
a/src/main/java/org/apache/nifi/documentation/AbstractDocumentationWriter.java
+++
b/src/main/java/org/apache/nifi/documentation/AbstractDocumentationWriter.java
@@ -47,6 +47,7 @@ import org.apache.nifi.components.PropertyDescriptor;
import org.apache.nifi.controller.ControllerService;
import
org.apache.nifi.documentation.init.DocumentationControllerServiceInitializationContext;
import
org.apache.nifi.documentation.init.DocumentationFlowAnalysisRuleInitializationContext;
+import
org.apache.nifi.documentation.init.DocumentationFlowRegistryClientInitializationContext;
import
org.apache.nifi.documentation.init.DocumentationParameterProviderInitializationContext;
import
org.apache.nifi.documentation.init.DocumentationProcessorInitializationContext;
import
org.apache.nifi.documentation.init.DocumentationReportingInitializationContext;
@@ -56,6 +57,7 @@ import org.apache.nifi.processor.Processor;
import org.apache.nifi.processor.Relationship;
import org.apache.nifi.reporting.InitializationException;
import org.apache.nifi.reporting.ReportingTask;
+import org.apache.nifi.registry.flow.FlowRegistryClient;
import java.io.IOException;
import java.util.ArrayList;
@@ -95,6 +97,8 @@ public abstract class AbstractDocumentationWriter implements
ExtensionDocumentat
initialize((FlowAnalysisRule) component);
} else if (component instanceof ParameterProvider) {
initialize((ParameterProvider) component);
+ } else if (component instanceof FlowRegistryClient) {
+ initialize((FlowRegistryClient) component);
}
} catch (final InitializationException ie) {
throw new RuntimeException("Failed to initialize " + component,
ie);
@@ -121,6 +125,10 @@ public abstract class AbstractDocumentationWriter
implements ExtensionDocumentat
parameterProvider.initialize(new
DocumentationParameterProviderInitializationContext());
}
+ protected void initialize(final FlowRegistryClient flowRegistryClient) {
+ flowRegistryClient.initialize(new
DocumentationFlowRegistryClientInitializationContext());
+ }
+
@Override
public final void write(final ConfigurableComponent component) throws
IOException {
write(component, Collections.emptyList(), Collections.emptyMap());
@@ -296,6 +304,9 @@ public abstract class AbstractDocumentationWriter
implements ExtensionDocumentat
if (component instanceof ParameterProvider) {
return ExtensionType.PARAMETER_PROVIDER;
}
+ if (component instanceof FlowRegistryClient) {
+ return ExtensionType.FLOW_REGISTRY_CLIENT;
+ }
throw new AssertionError("Encountered unknown Configurable Component
Type for " + component);
}
diff --git a/src/main/java/org/apache/nifi/documentation/ExtensionType.java
b/src/main/java/org/apache/nifi/documentation/ExtensionType.java
index 00d7058..7f6fbab 100644
--- a/src/main/java/org/apache/nifi/documentation/ExtensionType.java
+++ b/src/main/java/org/apache/nifi/documentation/ExtensionType.java
@@ -25,5 +25,7 @@ public enum ExtensionType {
FLOW_ANALYSIS_RULE,
- PARAMETER_PROVIDER;
+ PARAMETER_PROVIDER,
+
+ FLOW_REGISTRY_CLIENT;
}
diff --git a/src/main/java/org/apache/nifi/documentation/ExtensionType.java
b/src/main/java/org/apache/nifi/documentation/init/DocumentationFlowRegistryClientInitializationContext.java
similarity index 50%
copy from src/main/java/org/apache/nifi/documentation/ExtensionType.java
copy to
src/main/java/org/apache/nifi/documentation/init/DocumentationFlowRegistryClientInitializationContext.java
index 00d7058..939ee05 100644
--- a/src/main/java/org/apache/nifi/documentation/ExtensionType.java
+++
b/src/main/java/org/apache/nifi/documentation/init/DocumentationFlowRegistryClientInitializationContext.java
@@ -14,16 +14,31 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.nifi.documentation;
+package org.apache.nifi.documentation.init;
-public enum ExtensionType {
- PROCESSOR,
+import org.apache.nifi.logging.ComponentLog;
+import org.apache.nifi.registry.flow.FlowRegistryClientInitializationContext;
- CONTROLLER_SERVICE,
+import javax.net.ssl.SSLContext;
+import java.util.Optional;
+import java.util.UUID;
- REPORTING_TASK,
+public class DocumentationFlowRegistryClientInitializationContext implements
FlowRegistryClientInitializationContext {
+ private final String identifier = UUID.randomUUID().toString();
+ private final ComponentLog componentLog = new NopComponentLog();
- FLOW_ANALYSIS_RULE,
+ @Override
+ public String getIdentifier() {
+ return identifier;
+ }
- PARAMETER_PROVIDER;
+ @Override
+ public ComponentLog getLogger() {
+ return componentLog;
+ }
+
+ @Override
+ public Optional<SSLContext> getSystemSslContext() {
+ return Optional.empty();
+ }
}
