src/main/java/org/onap/clamp/clds/model/dcae/DcaeInventoryCache.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP CLAMP
   4  * ================================================================================
   5  * Copyright (C) 2019 AT&T Intellectual Property. All rights
   6  *                             reserved.
   7  * ================================================================================
   8  * Licensed under the Apache License, Version 2.0 (the "License");
   9  * you may not use this file except in compliance with the License.
  10  * You may obtain a copy of the License at
  11  *
  12  * http://www.apache.org/licenses/LICENSE-2.0
  13  *
  14  * Unless required by applicable law or agreed to in writing, software
  15  * distributed under the License is distributed on an "AS IS" BASIS,
  16  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  17  * See the License for the specific language governing permissions and
  18  * limitations under the License.
  19  * ============LICENSE_END============================================
  20  * ===================================================================
  21  *
  22  */
  23
  24 package org.onap.clamp.clds.model.dcae;
  25
  26 import java.util.Map;
  27 import java.util.Set;
  28 import java.util.TreeSet;
  29 import java.util.concurrent.ConcurrentHashMap;
  30
  31 /**
  32  * This class stores the multiple DcaeInventoryResponse coming back from DCAE.
  33  * The structure is a map of list indexed by asdcServiceId. The list is sorted
  34  * by asdcResourceId. Therefore it's possible to retrieve all the loops defined
  35  * in the DCAE inventory and created by DCAE Mod.
  36  */
  37 public class DcaeInventoryCache {
  38
  39     private static Map<String, Set<DcaeInventoryResponse>> blueprintsMap = new ConcurrentHashMap<>();
  40
  41     /**
  42      * Add Dcae inventory response.
  43      *
  44      * @param inventoryResponse the Dcae inventory response
  45      */
  46     public void addDcaeInventoryResponse(DcaeInventoryResponse inventoryResponse) {
  47         Set<DcaeInventoryResponse> responsesSet = blueprintsMap.get(inventoryResponse.getAsdcServiceId());
  48         if (responsesSet == null) {
  49             responsesSet = new TreeSet<>();
  50             blueprintsMap.put(inventoryResponse.getAsdcServiceId(), responsesSet);
  51         }
  52         responsesSet.add(inventoryResponse);
  53     }
  54
  55     public Set<String> getAllLoopIds() {
  56         return this.blueprintsMap.keySet();
  57     }
  58
  59     public Set<DcaeInventoryResponse> getAllBlueprintsPerLoopId(String loopId) {
  60         return blueprintsMap.getOrDefault(loopId, new TreeSet<>());
  61     }
  62 }