2 * ============LICENSE_START=======================================================
3 * ONAP : ccsdk features
4 * ================================================================================
5 * Copyright (C) 2020 highstreet technologies GmbH Intellectual Property.
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
12 * http://www.apache.org/licenses/LICENSE-2.0
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=========================================================
22 package org.onap.ccsdk.features.sdnr.wt.dataprovider.setup.elalto;
24 import java.util.HashMap;
26 import org.onap.ccsdk.features.sdnr.wt.dataprovider.setup.data.ComponentName;
27 import org.onap.ccsdk.features.sdnr.wt.dataprovider.setup.data.DatabaseInfo;
28 import org.onap.ccsdk.features.sdnr.wt.dataprovider.setup.data.KeepDataSearchHitConverter;
29 import org.onap.ccsdk.features.sdnr.wt.dataprovider.setup.data.Release;
30 import org.onap.ccsdk.features.sdnr.wt.dataprovider.setup.data.SearchHitConverter;
31 import org.onap.ccsdk.features.sdnr.wt.common.database.HtDatabaseClient;
32 import org.onap.ccsdk.features.sdnr.wt.dataprovider.setup.ReleaseInformation;
34 public class ElAltoReleaseInformation extends ReleaseInformation {
37 private Map<Release, Map<ComponentName, SearchHitConverter>> converters;
39 public ElAltoReleaseInformation() {
40 super(Release.EL_ALTO, createDbInfos());
41 this.converters = generateConverters();
44 private static Map<ComponentName, DatabaseInfo> createDbInfos() {
45 Map<ComponentName, DatabaseInfo> map = new HashMap<>();
46 map.put(ComponentName.EVENTLOG, new DatabaseInfo("sdnevents", "eventlog", ""));
47 map.put(ComponentName.FAULTCURRENT, new DatabaseInfo("sdnevents", "faultcurrent", ""));
48 map.put(ComponentName.FAULTLOG, new DatabaseInfo("sdnevents", "faultlog", ""));
49 map.put(ComponentName.INVENTORY, new DatabaseInfo("sdnevents", "inventoryequipment", ""));
50 map.put(ComponentName.INVENTORYTOPLEVEL, new DatabaseInfo("sdnevents", "inventorytoplevel", ""));
51 map.put(ComponentName.HISTORICAL_PERFORMANCE_15M,
52 new DatabaseInfo("sdnperformance", "historicalperformance15min", ""));
53 map.put(ComponentName.HISTORICAL_PERFORMANCE_24H,
54 new DatabaseInfo("sdnperformance", "historicalperformance24h", ""));
55 map.put(ComponentName.REQUIRED_NETWORKELEMENT, new DatabaseInfo("mwtn", "required-networkelement",
56 "{\"required-networkelement\": {\"date_detection\": false }}"));
57 map.put(ComponentName.MEDIATOR_SERVER, new DatabaseInfo("mwtn", "mediator-server", ""));
58 map.put(ComponentName.MAINTENANCE, new DatabaseInfo("mwtn", "maintenancemode", ""));
63 * @return components used in el alto
67 private static Map<Release, Map<ComponentName, SearchHitConverter>> generateConverters() {
68 Map<Release, Map<ComponentName, SearchHitConverter>> c = new HashMap<>();
69 Map<ComponentName, SearchHitConverter> frankfurtConverters = new HashMap<>();
70 frankfurtConverters.put(ComponentName.EVENTLOG, new FrankfurtEventlogConverter());
71 frankfurtConverters.put(ComponentName.FAULTCURRENT, new FrankfurtFaultcurrentConverter());
72 frankfurtConverters.put(ComponentName.FAULTLOG, new FrankfurtFaultlogConverter());
73 frankfurtConverters.put(ComponentName.INVENTORY, new KeepDataSearchHitConverter(ComponentName.INVENTORY));
74 //obsolete in frankfurt
75 //frankfurtConverters.put(ComponentName.INVENTORYTOPLEVEL, new KeepDataSearchHitConverter(ComponentName.INVENTORYTOPLEVEL));
76 frankfurtConverters.put(ComponentName.HISTORICAL_PERFORMANCE_15M,
77 new KeepDataSearchHitConverter(ComponentName.HISTORICAL_PERFORMANCE_15M));
78 frankfurtConverters.put(ComponentName.HISTORICAL_PERFORMANCE_24H,
79 new KeepDataSearchHitConverter(ComponentName.HISTORICAL_PERFORMANCE_24H));
80 frankfurtConverters.put(ComponentName.MAINTENANCE, new FrankfurtMaintenanceConverter());
81 frankfurtConverters.put(ComponentName.MEDIATOR_SERVER,
82 new KeepDataSearchHitConverter(ComponentName.MEDIATOR_SERVER));
83 frankfurtConverters.put(ComponentName.REQUIRED_NETWORKELEMENT, new FrankfurtRequiredNetworkElementConverter());
84 frankfurtConverters.put(ComponentName.CONNECTIONLOG, new FrankfurtConnectionlogConverter());
85 c.put(Release.FRANKFURT_R1, frankfurtConverters);
90 public SearchHitConverter getConverter(Release dst, ComponentName comp) {
91 SearchHitConverter c = this.converters.containsKey(dst) ? this.converters.get(dst).get(comp) : null;
93 c = super.getConverter(dst, comp);
99 protected boolean runPreInitCommands(HtDatabaseClient dbClient) {
104 protected boolean runPostInitCommands(HtDatabaseClient dbClient) {