Bulk api test

src/main/java/com/autotune/Autotune.java

@@ -24,14 +24,20 @@
 import com.autotune.analyzer.utils.AnalyzerConstants;
 import com.autotune.common.datasource.DataSourceCollection;
 import com.autotune.common.datasource.DataSourceInfo;
+import com.autotune.common.exceptions.datasource.DataSourceAlreadyExist;
+import com.autotune.common.exceptions.datasource.DataSourceNotServiceable;
+import com.autotune.common.exceptions.datasource.UnsupportedDataSourceProvider;
 import com.autotune.database.helper.DBConstants;
 import com.autotune.database.init.KruizeHibernateUtil;
 import com.autotune.experimentManager.core.ExperimentManager;
 import com.autotune.operator.InitializeDeployment;
 import com.autotune.operator.KruizeDeploymentInfo;
 import com.autotune.service.HealthService;
 import com.autotune.service.InitiateListener;
-import com.autotune.utils.*;
+import com.autotune.utils.CloudWatchAppender;
+import com.autotune.utils.KruizeConstants;
+import com.autotune.utils.MetricsConfig;
+import com.autotune.utils.ServerContext;
 import com.autotune.utils.filter.KruizeCORSFilter;
 import io.prometheus.client.exporter.MetricsServlet;
 import io.prometheus.client.hotspot.DefaultExports;
@@ -50,8 +56,12 @@
 
 import javax.servlet.DispatcherType;
 import java.io.File;
+import java.io.IOException;
 import java.nio.file.Path;
 import java.nio.file.Paths;
+import java.security.KeyManagementException;
+import java.security.KeyStoreException;
+import java.security.NoSuchAlgorithmException;
 import java.util.EnumSet;
 import java.util.HashMap;
 import java.util.Scanner;
@@ -112,7 +122,11 @@ public static void main(String[] args) {
                 // load available datasources from db
                 loadDataSourcesFromDB();
                 // setting up DataSources
-                setUpDataSources();
+                try {
+                    setUpDataSources();
+                } catch (Exception e) {
+                    LOGGER.error(e.getMessage());
+                }
                 // checking available DataSources
                 checkAvailableDataSources();
                 // load available metric profiles from db
@@ -124,7 +138,7 @@ public static void main(String[] args) {
             //Regenerate a Hibernate session following the creation of new tables
             KruizeHibernateUtil.buildSessionFactory();
         } catch (Exception | K8sTypeNotSupportedException | MonitoringAgentNotSupportedException |
-                MonitoringAgentNotFoundException e) {
+                 MonitoringAgentNotFoundException e) {
             e.printStackTrace();
             System.exit(1);
         }
@@ -170,7 +184,7 @@ public static void main(String[] args) {
     /**
      * Set up the data sources available at installation time from config file
      */
-    private static void setUpDataSources() {
+    private static void setUpDataSources() throws UnsupportedDataSourceProvider, DataSourceNotServiceable, DataSourceAlreadyExist, IOException, NoSuchAlgorithmException, KeyStoreException, KeyManagementException {
         DataSourceCollection dataSourceCollection = DataSourceCollection.getInstance();
         dataSourceCollection.addDataSourcesFromConfigFile(KruizeConstants.CONFIG_FILE);
     }
@@ -190,7 +204,7 @@ private static void checkAvailableDataSources() {
         DataSourceCollection dataSourceCollection = DataSourceCollection.getInstance();
         LOGGER.info(KruizeConstants.DataSourceConstants.DataSourceInfoMsgs.CHECKING_AVAILABLE_DATASOURCE);
         HashMap<String, DataSourceInfo> dataSources = dataSourceCollection.getDataSourcesCollection();
-        for (String name: dataSources.keySet()) {
+        for (String name : dataSources.keySet()) {
             DataSourceInfo dataSource = dataSources.get(name);
             String dataSourceName = dataSource.getName();
             String url = dataSource.getUrl().toString();