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 8cd308b NIFI-16048 Added Synchronization Interval property for Flow
Registry Clients (#100)
8cd308b is described below
commit 8cd308b81041c70310e12ba5d5cccb9648096616
Author: Pierre Villard <[email protected]>
AuthorDate: Mon Jul 6 16:57:20 2026 +0200
NIFI-16048 Added Synchronization Interval property for Flow Registry
Clients (#100)
Signed-off-by: David Handermann <[email protected]>
---
.../nifi/registry/flow/AbstractFlowRegistryClient.java | 18 ++++++++++++++++++
1 file changed, 18 insertions(+)
diff --git
a/src/main/java/org/apache/nifi/registry/flow/AbstractFlowRegistryClient.java
b/src/main/java/org/apache/nifi/registry/flow/AbstractFlowRegistryClient.java
index 38aae15..6640000 100644
---
a/src/main/java/org/apache/nifi/registry/flow/AbstractFlowRegistryClient.java
+++
b/src/main/java/org/apache/nifi/registry/flow/AbstractFlowRegistryClient.java
@@ -17,13 +17,31 @@
package org.apache.nifi.registry.flow;
import org.apache.nifi.components.AbstractConfigurableComponent;
+import org.apache.nifi.components.PropertyDescriptor;
import org.apache.nifi.logging.ComponentLog;
+import org.apache.nifi.processor.util.StandardValidators;
import java.util.Optional;
import javax.net.ssl.SSLContext;
public abstract class AbstractFlowRegistryClient extends
AbstractConfigurableComponent implements FlowRegistryClient {
+ /**
+ * Property that controls how often NiFi checks this Flow Registry Client
for updated versions of the flows that
+ * are under version control against it. When this property is left blank,
NiFi falls back to the global
+ * {@code nifi.flowcontroller.registry.sync.interval} property. Concrete
Flow Registry Client implementations should
+ * include this descriptor in the List returned by {@link
#getSupportedPropertyDescriptors()} in order to allow the
+ * synchronization interval to be configured on a per-client basis.
+ */
+ public static final PropertyDescriptor SYNCHRONIZATION_INTERVAL = new
PropertyDescriptor.Builder()
+ .name("Synchronization Interval")
+ .description("""
+ How often NiFi checks this Flow Registry Client for newer
versions of the flows that are under version control against it. \
+ When left blank, the application uses the
nifi.flowcontroller.registry.sync.interval property""")
+ .required(false)
+ .addValidator(StandardValidators.TIME_PERIOD_VALIDATOR)
+ .build();
+
private volatile String identifier;
private volatile Optional<SSLContext> systemSslContext;
private volatile ComponentLog logger;
