aboutsummaryrefslogtreecommitdiffstats
path: root/cps-service/src
diff options
context:
space:
mode:
authorDylanB95EST <dylan.byrne@est.tech>2022-04-20 10:35:11 +0100
committerDylanB95EST <dylan.byrne@est.tech>2022-04-29 11:59:29 +0100
commit6369af0f6cb53619daa253d5da0f360f2bf67fc3 (patch)
treed6c5fb0c990a170d5717f09f77034e08c3068635 /cps-service/src
parentd07a5e3cfd74357c626d099dc5d5812ecd8e33ea (diff)
Watchdog-process that changes CM Handles state
Add a fixed delay scheduler to switch cm-handles found in an ADVISED state to a READY state Scheduler currently runs every 30 seconds Will only update a single cm-handle at a time Queries CM-Handle with Advised States Only using CPS Path. Will choose cm handle at random Issue-ID: CPS-875 Change-Id: Ie1b49c89a0350d20e14748a65f9c1d260d8502d2 Signed-off-by: DylanB95EST <dylan.byrne@est.tech>
Diffstat (limited to 'cps-service/src')
-rw-r--r--cps-service/src/main/java/org/onap/cps/spi/CpsDataPersistenceService.java5
1 files changed, 3 insertions, 2 deletions
diff --git a/cps-service/src/main/java/org/onap/cps/spi/CpsDataPersistenceService.java b/cps-service/src/main/java/org/onap/cps/spi/CpsDataPersistenceService.java
index fdcf15bee..06da3ffc8 100644
--- a/cps-service/src/main/java/org/onap/cps/spi/CpsDataPersistenceService.java
+++ b/cps-service/src/main/java/org/onap/cps/spi/CpsDataPersistenceService.java
@@ -23,6 +23,7 @@
package org.onap.cps.spi;
import java.util.Collection;
+import java.util.List;
import java.util.Map;
import org.onap.cps.spi.model.DataNode;
@@ -145,8 +146,8 @@ public interface CpsDataPersistenceService {
* included in the output
* @return the data nodes found i.e. 0 or more data nodes
*/
- Collection<DataNode> queryDataNodes(String dataspaceName, String anchorName,
- String cpsPath, FetchDescendantsOption fetchDescendantsOption);
+ List<DataNode> queryDataNodes(String dataspaceName, String anchorName,
+ String cpsPath, FetchDescendantsOption fetchDescendantsOption);
/**
* Starts a session which allows use of locks and batch interaction with the persistence service.