X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=policy-agent%2Fsrc%2Fmain%2Fjava%2Forg%2Foransc%2Fpolicyagent%2Frepository%2FRic.java;h=98c497f76909f5f340e8d90ab9785925d25483a1;hb=e6f2305abd791d003d4729c3bd8c8652d89eed70;hp=bfd8ef65e1316ca8e6e6a640fe4aa9a58cd5be77;hpb=63036ab25f7878781e74b2ca0706b28451f59f27;p=nonrtric.git diff --git a/policy-agent/src/main/java/org/oransc/policyagent/repository/Ric.java b/policy-agent/src/main/java/org/oransc/policyagent/repository/Ric.java index bfd8ef65..98c497f7 100644 --- a/policy-agent/src/main/java/org/oransc/policyagent/repository/Ric.java +++ b/policy-agent/src/main/java/org/oransc/policyagent/repository/Ric.java @@ -20,8 +20,12 @@ package org.oransc.policyagent.repository; +import java.util.Collection; +import java.util.HashMap; +import java.util.Map; +import java.util.Vector; + import org.oransc.policyagent.configuration.RicConfig; -import org.oransc.policyagent.repository.Ric.RicState; /** * Represents the dynamic information about a NearRealtime-RIC. @@ -29,6 +33,7 @@ import org.oransc.policyagent.repository.Ric.RicState; public class Ric { private final RicConfig ricConfig; private RicState state = RicState.NOT_INITIATED; + private Map supportedPolicyTypes = new HashMap<>(); /** * Creates the Ric. Initial state is {@link RicState.NOT_INITIATED}. @@ -51,6 +56,19 @@ public class Ric { state = newState; } + public RicConfig getConfig() { + return this.ricConfig; + } + + /** + * Gets the nodes managed by this Ric. + * + * @return a vector containing the nodes managed by this Ric. + */ + public Vector getManagedNodes() { + return ricConfig.managedElementIds(); + } + /** * Determines if the given node is managed by this Ric. * @@ -81,6 +99,65 @@ public class Ric { ricConfig.managedElementIds().remove(nodeName); } + /** + * Gets the policy types supported by this Ric. + * + * @return the policy types supported by this Ric in an unmodifiable list. + */ + public Collection getSupportedPolicyTypes() { + return supportedPolicyTypes.values(); + } + + public Collection getSupportedPolicyTypeNames() { + return supportedPolicyTypes.keySet(); + } + + /** + * Adds a policy type as supported by this Ric. + * + * @param type the policy type to support. + */ + public void addSupportedPolicyType(PolicyType type) { + supportedPolicyTypes.put(type.name(), type); + } + + /** + * Adds policy types as supported by this Ric. + * + * @param types the policy types to support. + */ + public void addSupportedPolicyTypes(Collection types) { + for (PolicyType type : types) { + addSupportedPolicyType(type); + } + } + + /** + * Removes a policy type as supported by this Ric. + * + * @param type the policy type to remove as supported by this Ric. + */ + public void removeSupportedPolicyType(PolicyType type) { + supportedPolicyTypes.remove(type.name()); + } + + /** + * Checks if a type is supported by this Ric. + * + * @param typeName the name of the type to check if it is supported. + * + * @return true if the given type is supported by this Ric, false otherwise. + */ + public boolean isSupportingType(String typeName) { + return supportedPolicyTypes.containsKey(typeName); + } + + @Override + public String toString() { + return Ric.class.getSimpleName() + ": " + "name: " + name() + ", state: " + state + ", baseUrl: " + + ricConfig.baseUrl() + ", managedNodes: " + ricConfig.managedElementIds(); + } + /** * Represents the states possible for a Ric. */ @@ -94,12 +171,8 @@ public class Ric { */ ACTIVE, /** - * Something is wrong with the Ric. - */ - FAULTY, - /** - * The node is unreachable at the moment. + * The Ric cannot be contacted. */ - UNREACHABLE + NOT_REACHABLE } }