diff options
6 files changed, 1370 insertions, 1462 deletions
diff --git a/dcae-controller-core/dcae-controller-platform-server/src/main/java/org/openecomp/dcae/controller/platform/servers/controller/inventory/DcaeDcaeInventoryTest.java b/dcae-controller-core/dcae-controller-platform-server/src/main/java/org/openecomp/dcae/controller/platform/servers/controller/inventory/DcaeDcaeInventoryTest.java index 0ad21dd..5be2c61 100644 --- a/dcae-controller-core/dcae-controller-platform-server/src/main/java/org/openecomp/dcae/controller/platform/servers/controller/inventory/DcaeDcaeInventoryTest.java +++ b/dcae-controller-core/dcae-controller-platform-server/src/main/java/org/openecomp/dcae/controller/platform/servers/controller/inventory/DcaeDcaeInventoryTest.java @@ -5,19 +5,17 @@ import org.openecomp.ncomp.sirius.manager.ISiriusServer; import org.openecomp.ncomp.sirius.manager.ManagementServer; public class DcaeDcaeInventoryTest implements ISiriusServer { + private ManagementServer server = new ManagementServer(); - public static void main(String[] args) { - DcaeDcaeInventoryTest server = new DcaeDcaeInventoryTest(); - DcaeInventoryFactory f = new DcaeInventoryFactory(server); - DcaeInventory inv = f.createDcaeInventory(); - inv.poll(); - } - - private ManagementServer server = new ManagementServer(); - - @Override - public ManagementServer getServer() { - return server; - } + public static void main(String[] args) { + DcaeDcaeInventoryTest server = new DcaeDcaeInventoryTest(); + DcaeInventoryFactory f = new DcaeInventoryFactory(server); + DcaeInventory inv = f.createDcaeInventory(); + inv.poll(); + } + @Override + public ManagementServer getServer() { + return server; + } } diff --git a/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/DcaeControllerCluster.java b/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/DcaeControllerCluster.java index 893d909..d7b96a2 100644 --- a/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/DcaeControllerCluster.java +++ b/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/DcaeControllerCluster.java @@ -18,132 +18,108 @@ * limitations under the License. * ============LICENSE_END============================================ */ - + // Autogenerated // Do not edit. No need to extend this class. package org.openecomp.dcae.controller.platform.servers.controller; - - - - -import java.io.InputStream; - -import org.openecomp.ncomp.sirius.manager.IRequestHandler; -import org.openecomp.ncomp.sirius.manager.ISwaggerHandler; +import org.apache.log4j.Logger; +import org.openecomp.dcae.controller.platform.controller.impl.ControllerClusterImpl; +import org.openecomp.dcae.controller.platform.servers.controller.logging.ControllerClusterMessageEnum; +import org.openecomp.dcae.controller.platform.servers.controller.logging.ControllerClusterOperationEnum; +import org.openecomp.logger.EcompException; +import org.openecomp.logger.StatusCodeEnum; +import org.openecomp.ncomp.component.ApiRequestStatus; import org.openecomp.ncomp.sirius.manager.ISiriusPlugin; -import org.openecomp.ncomp.sirius.manager.ISiriusServer; import org.openecomp.ncomp.sirius.manager.ISiriusProvider; +import org.openecomp.ncomp.sirius.manager.ISiriusServer; import org.openecomp.ncomp.sirius.manager.ManagementServer; -import org.openecomp.ncomp.sirius.manager.SwaggerUtils; -import org.openecomp.ncomp.sirius.function.FunctionUtils; -import org.openecomp.ncomp.component.ApiRequestStatus; - -import org.apache.log4j.Logger; - import org.openecomp.ncomp.sirius.manager.logging.NcompLogger; -import org.openecomp.logger.StatusCodeEnum; -import org.openecomp.logger.EcompException; - -import org.eclipse.emf.common.util.EList; -import org.eclipse.emf.ecore.EObject; -import org.json.JSONObject; import java.util.Date; -import org.openecomp.dcae.controller.platform.servers.controller.logging.ControllerClusterOperationEnum; -import org.openecomp.dcae.controller.platform.servers.controller.logging.ControllerClusterMessageEnum; - - - - -import org.openecomp.dcae.controller.platform.controller.impl.ControllerClusterImpl; - - - public class DcaeControllerCluster extends ControllerClusterImpl implements ISiriusProvider, ISiriusPlugin { - public static final Logger logger = Logger.getLogger(DcaeControllerCluster.class); - static final NcompLogger ecomplogger = NcompLogger.getNcompLogger(); - public DcaeControllerClusterProvider controller; - ISiriusServer server; - - public DcaeControllerCluster(ISiriusServer server) { - this.server = server; - this.controller = new DcaeControllerClusterProvider(server,this); - } - - public void pushData(java.lang.String serverName, java.lang.String dataName) { - - long duration_ = 0; - if (server != null) - server.getServer().recordApi(null, this, "pushData", ApiRequestStatus.START, duration_,serverName,dataName); - Date now_ = new Date(); - ecomplogger.recordAuditEventStartIfNeeded(ControllerClusterOperationEnum.ControllerCluster_pushData,server,this); - ecomplogger.recordMetricEventStart(ControllerClusterOperationEnum.ControllerCluster_pushData,"self:" + ManagementServer.object2ref(this)); - try { - controller.pushData(serverName,dataName); - } - catch (Exception e) { - duration_ = new Date().getTime()-now_.getTime(); - if (server != null) - server.getServer().recordApi(null, this, "pushData", ApiRequestStatus.ERROR, duration_,serverName,dataName); - System.err.println("ERROR: " + e); - ecomplogger.warn(ControllerClusterMessageEnum.REQUEST_FAILED_pushData, e.toString()); - EcompException e1 = EcompException.create(ControllerClusterMessageEnum.REQUEST_FAILED_pushData,e,e.getMessage()); - ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, ControllerClusterMessageEnum.REQUEST_FAILED_pushData, e.getMessage()); - throw e1; - } - ecomplogger.recordMetricEventEnd(); - duration_ = new Date().getTime()-now_.getTime(); - if (server != null) - server.getServer().recordApi(null, this, "pushData", ApiRequestStatus.OKAY, duration_,serverName,dataName); - - } - - public void receiveData(java.lang.String serverName, java.lang.String dataName, java.util.Date time, java.lang.String content) { - - long duration_ = 0; - if (server != null) - server.getServer().recordApi(null, this, "receiveData", ApiRequestStatus.START, duration_,serverName,dataName,time,content); - Date now_ = new Date(); - ecomplogger.recordAuditEventStartIfNeeded(ControllerClusterOperationEnum.ControllerCluster_receiveData,server,this); - ecomplogger.recordMetricEventStart(ControllerClusterOperationEnum.ControllerCluster_receiveData,"self:" + ManagementServer.object2ref(this)); - try { - controller.receiveData(serverName,dataName,time,content); - } - catch (Exception e) { - duration_ = new Date().getTime()-now_.getTime(); - if (server != null) - server.getServer().recordApi(null, this, "receiveData", ApiRequestStatus.ERROR, duration_,serverName,dataName,time,content); - System.err.println("ERROR: " + e); - ecomplogger.warn(ControllerClusterMessageEnum.REQUEST_FAILED_receiveData, e.toString()); - EcompException e1 = EcompException.create(ControllerClusterMessageEnum.REQUEST_FAILED_receiveData,e,e.getMessage()); - ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, ControllerClusterMessageEnum.REQUEST_FAILED_receiveData, e.getMessage()); - throw e1; - } - ecomplogger.recordMetricEventEnd(); - duration_ = new Date().getTime()-now_.getTime(); - if (server != null) - server.getServer().recordApi(null, this, "receiveData", ApiRequestStatus.OKAY, duration_,serverName,dataName,time,content); - - } - - - - - - - - - @Override - public void start() { - controller.start(); - } - - public static void ecoreSetup() { - DcaeControllerClusterProvider.ecoreSetup(); - } - public DcaeControllerClusterProvider getSiriusProvider() { - return controller; - } + public static final Logger logger = Logger.getLogger(DcaeControllerCluster.class); + static final NcompLogger ecomplogger = NcompLogger.getNcompLogger(); + public DcaeControllerClusterProvider controller; + ISiriusServer server; + + public DcaeControllerCluster(ISiriusServer server) { + this.server = server; + this.controller = new DcaeControllerClusterProvider(server, this); + } + + public void pushData(java.lang.String serverName, java.lang.String dataName) { + + long duration_ = 0; + if (server != null) { + server.getServer().recordApi(null, this, "pushData", ApiRequestStatus.START, duration_, serverName, dataName); + } + Date now_ = new Date(); + ecomplogger.recordAuditEventStartIfNeeded(ControllerClusterOperationEnum.ControllerCluster_pushData, server, this); + ecomplogger.recordMetricEventStart(ControllerClusterOperationEnum.ControllerCluster_pushData, "self:" + ManagementServer.object2ref(this)); + try { + controller.pushData(serverName, dataName); + } catch (Exception e) { + duration_ = new Date().getTime() - now_.getTime(); + if (server != null) { + server.getServer().recordApi(null, this, "pushData", ApiRequestStatus.ERROR, duration_, serverName, dataName); + } + System.err.println("ERROR: " + e); + ecomplogger.warn(ControllerClusterMessageEnum.REQUEST_FAILED_pushData, e.toString()); + EcompException e1 = EcompException.create(ControllerClusterMessageEnum.REQUEST_FAILED_pushData, e, e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, ControllerClusterMessageEnum.REQUEST_FAILED_pushData, e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + duration_ = new Date().getTime() - now_.getTime(); + if (server != null) { + server.getServer().recordApi(null, this, "pushData", ApiRequestStatus.OKAY, duration_, serverName, dataName); + } + + } + + public void receiveData(java.lang.String serverName, java.lang.String dataName, java.util.Date time, java.lang.String content) { + + long duration_ = 0; + if (server != null) { + server.getServer().recordApi(null, this, "receiveData", ApiRequestStatus.START, duration_, serverName, dataName, time, content); + } + Date now_ = new Date(); + ecomplogger.recordAuditEventStartIfNeeded(ControllerClusterOperationEnum.ControllerCluster_receiveData, server, this); + ecomplogger.recordMetricEventStart(ControllerClusterOperationEnum.ControllerCluster_receiveData, "self:" + ManagementServer.object2ref(this)); + try { + controller.receiveData(serverName, dataName, time, content); + } catch (Exception e) { + duration_ = new Date().getTime() - now_.getTime(); + if (server != null) { + server.getServer().recordApi(null, this, "receiveData", ApiRequestStatus.ERROR, duration_, serverName, dataName, time, content); + } + System.err.println("ERROR: " + e); + ecomplogger.warn(ControllerClusterMessageEnum.REQUEST_FAILED_receiveData, e.toString()); + EcompException e1 = EcompException.create(ControllerClusterMessageEnum.REQUEST_FAILED_receiveData, e, e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, ControllerClusterMessageEnum.REQUEST_FAILED_receiveData, e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + duration_ = new Date().getTime() - now_.getTime(); + if (server != null) { + server.getServer().recordApi(null, this, "receiveData", ApiRequestStatus.OKAY, duration_, serverName, dataName, time, content); + } + + } + + @Override + public void start() { + controller.start(); + } + + public static void ecoreSetup() { + DcaeControllerClusterProvider.ecoreSetup(); + } + + @Override + public DcaeControllerClusterProvider getSiriusProvider() { + return controller; + } } diff --git a/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/DcaeControllerVirtualMachineService.java b/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/DcaeControllerVirtualMachineService.java index a44f9bd..d088a34 100644 --- a/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/DcaeControllerVirtualMachineService.java +++ b/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/DcaeControllerVirtualMachineService.java @@ -18,412 +18,410 @@ * limitations under the License. * ============LICENSE_END============================================ */ - + // Autogenerated // Do not edit. No need to extend this class. package org.openecomp.dcae.controller.platform.servers.controller; - - - - -import java.io.InputStream; - -import org.openecomp.ncomp.sirius.manager.IRequestHandler; -import org.openecomp.ncomp.sirius.manager.ISwaggerHandler; +import org.apache.log4j.Logger; +import org.eclipse.emf.ecore.EObject; +import org.openecomp.dcae.controller.platform.controller.impl.ControllerVirtualMachineServiceImpl; +import org.openecomp.dcae.controller.platform.servers.controller.logging.ControllerVirtualMachineServiceMessageEnum; +import org.openecomp.dcae.controller.platform.servers.controller.logging.ControllerVirtualMachineServiceOperationEnum; +import org.openecomp.logger.EcompException; +import org.openecomp.logger.StatusCodeEnum; +import org.openecomp.ncomp.component.ApiRequestStatus; import org.openecomp.ncomp.sirius.manager.ISiriusPlugin; -import org.openecomp.ncomp.sirius.manager.ISiriusServer; import org.openecomp.ncomp.sirius.manager.ISiriusProvider; +import org.openecomp.ncomp.sirius.manager.ISiriusServer; import org.openecomp.ncomp.sirius.manager.ManagementServer; -import org.openecomp.ncomp.sirius.manager.SwaggerUtils; -import org.openecomp.ncomp.sirius.function.FunctionUtils; -import org.openecomp.ncomp.component.ApiRequestStatus; - -import org.apache.log4j.Logger; - import org.openecomp.ncomp.sirius.manager.logging.NcompLogger; -import org.openecomp.logger.StatusCodeEnum; -import org.openecomp.logger.EcompException; - -import org.eclipse.emf.common.util.EList; -import org.eclipse.emf.ecore.EObject; -import org.json.JSONObject; import java.util.Date; -import org.openecomp.dcae.controller.platform.servers.controller.logging.ControllerVirtualMachineServiceOperationEnum; -import org.openecomp.dcae.controller.platform.servers.controller.logging.ControllerVirtualMachineServiceMessageEnum; - - - - -import org.openecomp.dcae.controller.platform.controller.impl.ControllerVirtualMachineServiceImpl; - - - public class DcaeControllerVirtualMachineService extends ControllerVirtualMachineServiceImpl implements ISiriusProvider, ISiriusPlugin { - public static final Logger logger = Logger.getLogger(DcaeControllerVirtualMachineService.class); - static final NcompLogger ecomplogger = NcompLogger.getNcompLogger(); - public DcaeControllerVirtualMachineServiceProvider controller; - ISiriusServer server; - - public DcaeControllerVirtualMachineService(ISiriusServer server) { - this.server = server; - this.controller = new DcaeControllerVirtualMachineServiceProvider(server,this); - } - - public void deploy(java.lang.String instanceName, java.lang.String containerPath) { - - long duration_ = 0; - if (server != null) - server.getServer().recordApi(null, this, "deploy", ApiRequestStatus.START, duration_,instanceName,containerPath); - Date now_ = new Date(); - ecomplogger.recordAuditEventStartIfNeeded(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_deploy,server,this); - ecomplogger.recordMetricEventStart(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_deploy,"self:" + ManagementServer.object2ref(this)); - try { - controller.deploy(instanceName,containerPath); - } - catch (Exception e) { - duration_ = new Date().getTime()-now_.getTime(); - if (server != null) - server.getServer().recordApi(null, this, "deploy", ApiRequestStatus.ERROR, duration_,instanceName,containerPath); - System.err.println("ERROR: " + e); - ecomplogger.warn(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_deploy, e.toString()); - EcompException e1 = EcompException.create(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_deploy,e,e.getMessage()); - ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_deploy, e.getMessage()); - throw e1; - } - ecomplogger.recordMetricEventEnd(); - duration_ = new Date().getTime()-now_.getTime(); - if (server != null) - server.getServer().recordApi(null, this, "deploy", ApiRequestStatus.OKAY, duration_,instanceName,containerPath); - - } - - public void undeploy(java.lang.String instanceName) { - - long duration_ = 0; - if (server != null) - server.getServer().recordApi(null, this, "undeploy", ApiRequestStatus.START, duration_,instanceName); - Date now_ = new Date(); - ecomplogger.recordAuditEventStartIfNeeded(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_undeploy,server,this); - ecomplogger.recordMetricEventStart(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_undeploy,"self:" + ManagementServer.object2ref(this)); - try { - controller.undeploy(instanceName); - } - catch (Exception e) { - duration_ = new Date().getTime()-now_.getTime(); - if (server != null) - server.getServer().recordApi(null, this, "undeploy", ApiRequestStatus.ERROR, duration_,instanceName); - System.err.println("ERROR: " + e); - ecomplogger.warn(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_undeploy, e.toString()); - EcompException e1 = EcompException.create(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_undeploy,e,e.getMessage()); - ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_undeploy, e.getMessage()); - throw e1; - } - ecomplogger.recordMetricEventEnd(); - duration_ = new Date().getTime()-now_.getTime(); - if (server != null) - server.getServer().recordApi(null, this, "undeploy", ApiRequestStatus.OKAY, duration_,instanceName); - - } - - public org.openecomp.dcae.controller.core.service.HealthTestResponse test(java.lang.String instanceName) { - org.openecomp.dcae.controller.core.service.HealthTestResponse res = null; - long duration_ = 0; - if (server != null) - server.getServer().recordApi(null, this, "test", ApiRequestStatus.START, duration_,instanceName); - Date now_ = new Date(); - ecomplogger.recordAuditEventStartIfNeeded(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_test,server,this); - ecomplogger.recordMetricEventStart(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_test,"self:" + ManagementServer.object2ref(this)); - try { - res = controller.test(instanceName); - } - catch (Exception e) { - duration_ = new Date().getTime()-now_.getTime(); - if (server != null) - server.getServer().recordApi(null, this, "test", ApiRequestStatus.ERROR, duration_,instanceName); - System.err.println("ERROR: " + e); - ecomplogger.warn(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_test, e.toString()); - EcompException e1 = EcompException.create(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_test,e,e.getMessage()); - ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_test, e.getMessage()); - throw e1; - } - ecomplogger.recordMetricEventEnd(); - duration_ = new Date().getTime()-now_.getTime(); - if (server != null) - server.getServer().recordApi(null, this, "test", ApiRequestStatus.OKAY, duration_,instanceName); - return res; - } - - public void suspend(java.lang.String instanceName) { - - long duration_ = 0; - if (server != null) - server.getServer().recordApi(null, this, "suspend", ApiRequestStatus.START, duration_,instanceName); - Date now_ = new Date(); - ecomplogger.recordAuditEventStartIfNeeded(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_suspend,server,this); - ecomplogger.recordMetricEventStart(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_suspend,"self:" + ManagementServer.object2ref(this)); - try { - controller.suspend(instanceName); - } - catch (Exception e) { - duration_ = new Date().getTime()-now_.getTime(); - if (server != null) - server.getServer().recordApi(null, this, "suspend", ApiRequestStatus.ERROR, duration_,instanceName); - System.err.println("ERROR: " + e); - ecomplogger.warn(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_suspend, e.toString()); - EcompException e1 = EcompException.create(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_suspend,e,e.getMessage()); - ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_suspend, e.getMessage()); - throw e1; - } - ecomplogger.recordMetricEventEnd(); - duration_ = new Date().getTime()-now_.getTime(); - if (server != null) - server.getServer().recordApi(null, this, "suspend", ApiRequestStatus.OKAY, duration_,instanceName); - - } - - public void resume(java.lang.String instanceName) { - - long duration_ = 0; - if (server != null) - server.getServer().recordApi(null, this, "resume", ApiRequestStatus.START, duration_,instanceName); - Date now_ = new Date(); - ecomplogger.recordAuditEventStartIfNeeded(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_resume,server,this); - ecomplogger.recordMetricEventStart(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_resume,"self:" + ManagementServer.object2ref(this)); - try { - controller.resume(instanceName); - } - catch (Exception e) { - duration_ = new Date().getTime()-now_.getTime(); - if (server != null) - server.getServer().recordApi(null, this, "resume", ApiRequestStatus.ERROR, duration_,instanceName); - System.err.println("ERROR: " + e); - ecomplogger.warn(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_resume, e.toString()); - EcompException e1 = EcompException.create(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_resume,e,e.getMessage()); - ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_resume, e.getMessage()); - throw e1; - } - ecomplogger.recordMetricEventEnd(); - duration_ = new Date().getTime()-now_.getTime(); - if (server != null) - server.getServer().recordApi(null, this, "resume", ApiRequestStatus.OKAY, duration_,instanceName); - - } - - public void pushManagerConfiguration(java.lang.String instanceName) { - - long duration_ = 0; - if (server != null) - server.getServer().recordApi(null, this, "pushManagerConfiguration", ApiRequestStatus.START, duration_,instanceName); - Date now_ = new Date(); - ecomplogger.recordAuditEventStartIfNeeded(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_pushManagerConfiguration,server,this); - ecomplogger.recordMetricEventStart(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_pushManagerConfiguration,"self:" + ManagementServer.object2ref(this)); - try { - controller.pushManagerConfiguration(instanceName); - } - catch (Exception e) { - duration_ = new Date().getTime()-now_.getTime(); - if (server != null) - server.getServer().recordApi(null, this, "pushManagerConfiguration", ApiRequestStatus.ERROR, duration_,instanceName); - System.err.println("ERROR: " + e); - ecomplogger.warn(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_pushManagerConfiguration, e.toString()); - EcompException e1 = EcompException.create(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_pushManagerConfiguration,e,e.getMessage()); - ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_pushManagerConfiguration, e.getMessage()); - throw e1; - } - ecomplogger.recordMetricEventEnd(); - duration_ = new Date().getTime()-now_.getTime(); - if (server != null) - server.getServer().recordApi(null, this, "pushManagerConfiguration", ApiRequestStatus.OKAY, duration_,instanceName); - - } - - public void pollManagerConfiguration(java.lang.String instanceName) { - - long duration_ = 0; - if (server != null) - server.getServer().recordApi(null, this, "pollManagerConfiguration", ApiRequestStatus.START, duration_,instanceName); - Date now_ = new Date(); - ecomplogger.recordAuditEventStartIfNeeded(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_pollManagerConfiguration,server,this); - ecomplogger.recordMetricEventStart(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_pollManagerConfiguration,"self:" + ManagementServer.object2ref(this)); - try { - controller.pollManagerConfiguration(instanceName); - } - catch (Exception e) { - duration_ = new Date().getTime()-now_.getTime(); - if (server != null) - server.getServer().recordApi(null, this, "pollManagerConfiguration", ApiRequestStatus.ERROR, duration_,instanceName); - System.err.println("ERROR: " + e); - ecomplogger.warn(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_pollManagerConfiguration, e.toString()); - EcompException e1 = EcompException.create(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_pollManagerConfiguration,e,e.getMessage()); - ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_pollManagerConfiguration, e.getMessage()); - throw e1; - } - ecomplogger.recordMetricEventEnd(); - duration_ = new Date().getTime()-now_.getTime(); - if (server != null) - server.getServer().recordApi(null, this, "pollManagerConfiguration", ApiRequestStatus.OKAY, duration_,instanceName); - - } - - public org.eclipse.emf.ecore.EObject managerConfiguration(java.lang.String instanceName) { - org.eclipse.emf.ecore.EObject res = null; - long duration_ = 0; - if (server != null) - server.getServer().recordApi(null, this, "managerConfiguration", ApiRequestStatus.START, duration_,instanceName); - Date now_ = new Date(); - ecomplogger.recordAuditEventStartIfNeeded(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_managerConfiguration,server,this); - ecomplogger.recordMetricEventStart(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_managerConfiguration,"self:" + ManagementServer.object2ref(this)); - try { - res = controller.managerConfiguration(instanceName); - } - catch (Exception e) { - duration_ = new Date().getTime()-now_.getTime(); - if (server != null) - server.getServer().recordApi(null, this, "managerConfiguration", ApiRequestStatus.ERROR, duration_,instanceName); - System.err.println("ERROR: " + e); - ecomplogger.warn(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_managerConfiguration, e.toString()); - EcompException e1 = EcompException.create(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_managerConfiguration,e,e.getMessage()); - ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_managerConfiguration, e.getMessage()); - throw e1; - } - ecomplogger.recordMetricEventEnd(); - duration_ = new Date().getTime()-now_.getTime(); - if (server != null) - server.getServer().recordApi(null, this, "managerConfiguration", ApiRequestStatus.OKAY, duration_,instanceName); - return res; - } - - public org.json.JSONObject managerOperation(java.lang.String instanceName, java.lang.String operation, org.json.JSONObject parameters) { - org.json.JSONObject res = null; - long duration_ = 0; - if (server != null) - server.getServer().recordApi(null, this, "managerOperation", ApiRequestStatus.START, duration_,instanceName,operation,parameters); - Date now_ = new Date(); - ecomplogger.recordAuditEventStartIfNeeded(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_managerOperation,server,this); - ecomplogger.recordMetricEventStart(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_managerOperation,"self:" + ManagementServer.object2ref(this)); - try { - res = controller.managerOperation(instanceName,operation,parameters); - } - catch (Exception e) { - duration_ = new Date().getTime()-now_.getTime(); - if (server != null) - server.getServer().recordApi(null, this, "managerOperation", ApiRequestStatus.ERROR, duration_,instanceName,operation,parameters); - System.err.println("ERROR: " + e); - ecomplogger.warn(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_managerOperation, e.toString()); - EcompException e1 = EcompException.create(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_managerOperation,e,e.getMessage()); - ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_managerOperation, e.getMessage()); - throw e1; - } - ecomplogger.recordMetricEventEnd(); - duration_ = new Date().getTime()-now_.getTime(); - if (server != null) - server.getServer().recordApi(null, this, "managerOperation", ApiRequestStatus.OKAY, duration_,instanceName,operation,parameters); - return res; - } - - public void updateConfigurationFromPolicy(java.lang.String instanceName) { - - long duration_ = 0; - if (server != null) - server.getServer().recordApi(null, this, "updateConfigurationFromPolicy", ApiRequestStatus.START, duration_,instanceName); - Date now_ = new Date(); - ecomplogger.recordAuditEventStartIfNeeded(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_updateConfigurationFromPolicy,server,this); - ecomplogger.recordMetricEventStart(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_updateConfigurationFromPolicy,"self:" + ManagementServer.object2ref(this)); - try { - controller.updateConfigurationFromPolicy(instanceName); - } - catch (Exception e) { - duration_ = new Date().getTime()-now_.getTime(); - if (server != null) - server.getServer().recordApi(null, this, "updateConfigurationFromPolicy", ApiRequestStatus.ERROR, duration_,instanceName); - System.err.println("ERROR: " + e); - ecomplogger.warn(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_updateConfigurationFromPolicy, e.toString()); - EcompException e1 = EcompException.create(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_updateConfigurationFromPolicy,e,e.getMessage()); - ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_updateConfigurationFromPolicy, e.getMessage()); - throw e1; - } - ecomplogger.recordMetricEventEnd(); - duration_ = new Date().getTime()-now_.getTime(); - if (server != null) - server.getServer().recordApi(null, this, "updateConfigurationFromPolicy", ApiRequestStatus.OKAY, duration_,instanceName); - - } - - public void runHealthTests() { - - long duration_ = 0; - if (server != null) - server.getServer().recordApi(null, this, "runHealthTests", ApiRequestStatus.START, duration_); - Date now_ = new Date(); - ecomplogger.recordAuditEventStartIfNeeded(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_runHealthTests,server,this); - ecomplogger.recordMetricEventStart(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_runHealthTests,"self:" + ManagementServer.object2ref(this)); - try { - controller.runHealthTests(); - } - catch (Exception e) { - duration_ = new Date().getTime()-now_.getTime(); - if (server != null) - server.getServer().recordApi(null, this, "runHealthTests", ApiRequestStatus.ERROR, duration_); - System.err.println("ERROR: " + e); - ecomplogger.warn(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_runHealthTests, e.toString()); - EcompException e1 = EcompException.create(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_runHealthTests,e,e.getMessage()); - ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_runHealthTests, e.getMessage()); - throw e1; - } - ecomplogger.recordMetricEventEnd(); - duration_ = new Date().getTime()-now_.getTime(); - if (server != null) - server.getServer().recordApi(null, this, "runHealthTests", ApiRequestStatus.OKAY, duration_); - - } - - public void updateDeploymentStatus() { - - long duration_ = 0; - if (server != null) - server.getServer().recordApi(null, this, "updateDeploymentStatus", ApiRequestStatus.START, duration_); - Date now_ = new Date(); - ecomplogger.recordAuditEventStartIfNeeded(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_updateDeploymentStatus,server,this); - ecomplogger.recordMetricEventStart(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_updateDeploymentStatus,"self:" + ManagementServer.object2ref(this)); - try { - controller.updateDeploymentStatus(); - } - catch (Exception e) { - duration_ = new Date().getTime()-now_.getTime(); - if (server != null) - server.getServer().recordApi(null, this, "updateDeploymentStatus", ApiRequestStatus.ERROR, duration_); - System.err.println("ERROR: " + e); - ecomplogger.warn(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_updateDeploymentStatus, e.toString()); - EcompException e1 = EcompException.create(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_updateDeploymentStatus,e,e.getMessage()); - ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_updateDeploymentStatus, e.getMessage()); - throw e1; - } - ecomplogger.recordMetricEventEnd(); - duration_ = new Date().getTime()-now_.getTime(); - if (server != null) - server.getServer().recordApi(null, this, "updateDeploymentStatus", ApiRequestStatus.OKAY, duration_); - - } - - - - - - - - - @Override - public void start() { - controller.start(); - } - - public static void ecoreSetup() { - DcaeControllerVirtualMachineServiceProvider.ecoreSetup(); - } - public DcaeControllerVirtualMachineServiceProvider getSiriusProvider() { - return controller; - } + public static final Logger logger = Logger.getLogger(DcaeControllerVirtualMachineService.class); + static final NcompLogger ecomplogger = NcompLogger.getNcompLogger(); + public DcaeControllerVirtualMachineServiceProvider controller; + ISiriusServer server; + + public DcaeControllerVirtualMachineService(ISiriusServer server) { + this.server = server; + this.controller = new DcaeControllerVirtualMachineServiceProvider(server, this); + } + + public void deploy(java.lang.String instanceName, java.lang.String containerPath) { + + long duration_ = 0; + if (server != null) { + server.getServer().recordApi(null, this, "deploy", ApiRequestStatus.START, duration_, instanceName, containerPath); + } + Date now_ = new Date(); + ecomplogger.recordAuditEventStartIfNeeded(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_deploy, server, this); + ecomplogger.recordMetricEventStart(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_deploy, "self:" + ManagementServer.object2ref(this)); + try { + controller.deploy(instanceName, containerPath); + } catch (Exception e) { + duration_ = new Date().getTime() - now_.getTime(); + if (server != null) { + server.getServer().recordApi(null, this, "deploy", ApiRequestStatus.ERROR, duration_, instanceName, containerPath); + } + System.err.println("ERROR: " + e); + ecomplogger.warn(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_deploy, e.toString()); + EcompException e1 = EcompException.create(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_deploy, e, e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_deploy, e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + duration_ = new Date().getTime() - now_.getTime(); + if (server != null) { + server.getServer().recordApi(null, this, "deploy", ApiRequestStatus.OKAY, duration_, instanceName, containerPath); + } + + } + + public void undeploy(java.lang.String instanceName) { + + long duration_ = 0; + if (server != null) { + server.getServer().recordApi(null, this, "undeploy", ApiRequestStatus.START, duration_, instanceName); + } + Date now_ = new Date(); + ecomplogger.recordAuditEventStartIfNeeded(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_undeploy, server, this); + ecomplogger.recordMetricEventStart(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_undeploy, "self:" + ManagementServer.object2ref(this)); + try { + controller.undeploy(instanceName); + } catch (Exception e) { + duration_ = new Date().getTime() - now_.getTime(); + if (server != null) { + server.getServer().recordApi(null, this, "undeploy", ApiRequestStatus.ERROR, duration_, instanceName); + } + System.err.println("ERROR: " + e); + ecomplogger.warn(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_undeploy, e.toString()); + EcompException e1 = EcompException.create(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_undeploy, e, e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_undeploy, e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + duration_ = new Date().getTime() - now_.getTime(); + if (server != null) { + server.getServer().recordApi(null, this, "undeploy", ApiRequestStatus.OKAY, duration_, instanceName); + } + + } + + public org.openecomp.dcae.controller.core.service.HealthTestResponse test(java.lang.String instanceName) { + org.openecomp.dcae.controller.core.service.HealthTestResponse res = null; + long duration_ = 0; + if (server != null) { + server.getServer().recordApi(null, this, "test", ApiRequestStatus.START, duration_, instanceName); + } + Date now_ = new Date(); + ecomplogger.recordAuditEventStartIfNeeded(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_test, server, this); + ecomplogger.recordMetricEventStart(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_test, "self:" + ManagementServer.object2ref(this)); + try { + res = controller.test(instanceName); + } catch (Exception e) { + duration_ = new Date().getTime() - now_.getTime(); + if (server != null) { + server.getServer().recordApi(null, this, "test", ApiRequestStatus.ERROR, duration_, instanceName); + } + System.err.println("ERROR: " + e); + ecomplogger.warn(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_test, e.toString()); + EcompException e1 = EcompException.create(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_test, e, e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_test, e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + duration_ = new Date().getTime() - now_.getTime(); + if (server != null) { + server.getServer().recordApi(null, this, "test", ApiRequestStatus.OKAY, duration_, instanceName); + } + return res; + } + + public void suspend(java.lang.String instanceName) { + + long duration_ = 0; + if (server != null) { + server.getServer().recordApi(null, this, "suspend", ApiRequestStatus.START, duration_, instanceName); + } + Date now_ = new Date(); + ecomplogger.recordAuditEventStartIfNeeded(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_suspend, server, this); + ecomplogger.recordMetricEventStart(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_suspend, "self:" + ManagementServer.object2ref(this)); + try { + controller.suspend(instanceName); + } catch (Exception e) { + duration_ = new Date().getTime() - now_.getTime(); + if (server != null) { + server.getServer().recordApi(null, this, "suspend", ApiRequestStatus.ERROR, duration_, instanceName); + } + System.err.println("ERROR: " + e); + ecomplogger.warn(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_suspend, e.toString()); + EcompException e1 = EcompException.create(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_suspend, e, e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_suspend, e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + duration_ = new Date().getTime() - now_.getTime(); + if (server != null) { + server.getServer().recordApi(null, this, "suspend", ApiRequestStatus.OKAY, duration_, instanceName); + } + + } + + public void resume(java.lang.String instanceName) { + + long duration_ = 0; + if (server != null) { + server.getServer().recordApi(null, this, "resume", ApiRequestStatus.START, duration_, instanceName); + } + Date now_ = new Date(); + ecomplogger.recordAuditEventStartIfNeeded(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_resume, server, this); + ecomplogger.recordMetricEventStart(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_resume, "self:" + ManagementServer.object2ref(this)); + try { + controller.resume(instanceName); + } catch (Exception e) { + duration_ = new Date().getTime() - now_.getTime(); + if (server != null) { + server.getServer().recordApi(null, this, "resume", ApiRequestStatus.ERROR, duration_, instanceName); + } + System.err.println("ERROR: " + e); + ecomplogger.warn(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_resume, e.toString()); + EcompException e1 = EcompException.create(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_resume, e, e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_resume, e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + duration_ = new Date().getTime() - now_.getTime(); + if (server != null) { + server.getServer().recordApi(null, this, "resume", ApiRequestStatus.OKAY, duration_, instanceName); + } + + } + + public void pushManagerConfiguration(java.lang.String instanceName) { + + long duration_ = 0; + if (server != null) { + server.getServer().recordApi(null, this, "pushManagerConfiguration", ApiRequestStatus.START, duration_, instanceName); + } + Date now_ = new Date(); + ecomplogger.recordAuditEventStartIfNeeded(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_pushManagerConfiguration, server, this); + ecomplogger.recordMetricEventStart(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_pushManagerConfiguration, "self:" + ManagementServer.object2ref(this)); + try { + controller.pushManagerConfiguration(instanceName); + } catch (Exception e) { + duration_ = new Date().getTime() - now_.getTime(); + if (server != null) { + server.getServer().recordApi(null, this, "pushManagerConfiguration", ApiRequestStatus.ERROR, duration_, instanceName); + } + System.err.println("ERROR: " + e); + ecomplogger.warn(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_pushManagerConfiguration, e.toString()); + EcompException e1 = EcompException.create(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_pushManagerConfiguration, e, e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_pushManagerConfiguration, e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + duration_ = new Date().getTime() - now_.getTime(); + if (server != null) { + server.getServer().recordApi(null, this, "pushManagerConfiguration", ApiRequestStatus.OKAY, duration_, instanceName); + } + + } + + public void pollManagerConfiguration(java.lang.String instanceName) { + + long duration_ = 0; + if (server != null) { + server.getServer().recordApi(null, this, "pollManagerConfiguration", ApiRequestStatus.START, duration_, instanceName); + } + Date now_ = new Date(); + ecomplogger.recordAuditEventStartIfNeeded(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_pollManagerConfiguration, server, this); + ecomplogger.recordMetricEventStart(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_pollManagerConfiguration, "self:" + ManagementServer.object2ref(this)); + try { + controller.pollManagerConfiguration(instanceName); + } catch (Exception e) { + duration_ = new Date().getTime() - now_.getTime(); + if (server != null) { + server.getServer().recordApi(null, this, "pollManagerConfiguration", ApiRequestStatus.ERROR, duration_, instanceName); + } + System.err.println("ERROR: " + e); + ecomplogger.warn(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_pollManagerConfiguration, e.toString()); + EcompException e1 = EcompException.create(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_pollManagerConfiguration, e, e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_pollManagerConfiguration, e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + duration_ = new Date().getTime() - now_.getTime(); + if (server != null) { + server.getServer().recordApi(null, this, "pollManagerConfiguration", ApiRequestStatus.OKAY, duration_, instanceName); + } + + } + + public org.eclipse.emf.ecore.EObject managerConfiguration(java.lang.String instanceName) { + org.eclipse.emf.ecore.EObject res = null; + long duration_ = 0; + if (server != null) { + server.getServer().recordApi(null, this, "managerConfiguration", ApiRequestStatus.START, duration_, instanceName); + } + Date now_ = new Date(); + ecomplogger.recordAuditEventStartIfNeeded(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_managerConfiguration, server, this); + ecomplogger.recordMetricEventStart(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_managerConfiguration, "self:" + ManagementServer.object2ref(this)); + try { + res = controller.managerConfiguration(instanceName); + } catch (Exception e) { + duration_ = new Date().getTime() - now_.getTime(); + if (server != null) { + server.getServer().recordApi(null, this, "managerConfiguration", ApiRequestStatus.ERROR, duration_, instanceName); + } + System.err.println("ERROR: " + e); + ecomplogger.warn(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_managerConfiguration, e.toString()); + EcompException e1 = EcompException.create(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_managerConfiguration, e, e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_managerConfiguration, e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + duration_ = new Date().getTime() - now_.getTime(); + if (server != null) { + server.getServer().recordApi(null, this, "managerConfiguration", ApiRequestStatus.OKAY, duration_, instanceName); + } + return res; + } + + public org.json.JSONObject managerOperation(java.lang.String instanceName, java.lang.String operation, org.json.JSONObject parameters) { + org.json.JSONObject res = null; + long duration_ = 0; + if (server != null) { + server.getServer().recordApi(null, this, "managerOperation", ApiRequestStatus.START, duration_, instanceName, operation, parameters); + } + Date now_ = new Date(); + ecomplogger.recordAuditEventStartIfNeeded(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_managerOperation, server, this); + ecomplogger.recordMetricEventStart(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_managerOperation, "self:" + ManagementServer.object2ref(this)); + try { + res = controller.managerOperation(instanceName, operation, parameters); + } catch (Exception e) { + duration_ = new Date().getTime() - now_.getTime(); + if (server != null) { + server.getServer().recordApi(null, this, "managerOperation", ApiRequestStatus.ERROR, duration_, instanceName, operation, parameters); + } + System.err.println("ERROR: " + e); + ecomplogger.warn(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_managerOperation, e.toString()); + EcompException e1 = EcompException.create(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_managerOperation, e, e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_managerOperation, e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + duration_ = new Date().getTime() - now_.getTime(); + if (server != null) { + server.getServer().recordApi(null, this, "managerOperation", ApiRequestStatus.OKAY, duration_, instanceName, operation, parameters); + } + return res; + } + + public void updateConfigurationFromPolicy(java.lang.String instanceName) { + + long duration_ = 0; + if (server != null) { + server.getServer().recordApi(null, this, "updateConfigurationFromPolicy", ApiRequestStatus.START, duration_, instanceName); + } + Date now_ = new Date(); + ecomplogger.recordAuditEventStartIfNeeded(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_updateConfigurationFromPolicy, server, this); + ecomplogger.recordMetricEventStart(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_updateConfigurationFromPolicy, "self:" + ManagementServer.object2ref(this)); + try { + controller.updateConfigurationFromPolicy(instanceName); + } catch (Exception e) { + duration_ = new Date().getTime() - now_.getTime(); + if (server != null) { + server.getServer().recordApi(null, this, "updateConfigurationFromPolicy", ApiRequestStatus.ERROR, duration_, instanceName); + } + System.err.println("ERROR: " + e); + ecomplogger.warn(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_updateConfigurationFromPolicy, e.toString()); + EcompException e1 = EcompException.create(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_updateConfigurationFromPolicy, e, e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_updateConfigurationFromPolicy, e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + duration_ = new Date().getTime() - now_.getTime(); + if (server != null) { + server.getServer().recordApi(null, this, "updateConfigurationFromPolicy", ApiRequestStatus.OKAY, duration_, instanceName); + } + + } + + public void runHealthTests() { + + long duration_ = 0; + if (server != null) { + server.getServer().recordApi(null, this, "runHealthTests", ApiRequestStatus.START, duration_); + } + Date now_ = new Date(); + ecomplogger.recordAuditEventStartIfNeeded(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_runHealthTests, server, this); + ecomplogger.recordMetricEventStart(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_runHealthTests, "self:" + ManagementServer.object2ref(this)); + try { + controller.runHealthTests(); + } catch (Exception e) { + duration_ = new Date().getTime() - now_.getTime(); + if (server != null) { + server.getServer().recordApi(null, this, "runHealthTests", ApiRequestStatus.ERROR, duration_); + } + System.err.println("ERROR: " + e); + ecomplogger.warn(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_runHealthTests, e.toString()); + EcompException e1 = EcompException.create(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_runHealthTests, e, e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_runHealthTests, e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + duration_ = new Date().getTime() - now_.getTime(); + if (server != null) { + server.getServer().recordApi(null, this, "runHealthTests", ApiRequestStatus.OKAY, duration_); + } + + } + + public void updateDeploymentStatus() { + + long duration_ = 0; + if (server != null) { + server.getServer().recordApi(null, this, "updateDeploymentStatus", ApiRequestStatus.START, duration_); + } + Date now_ = new Date(); + ecomplogger.recordAuditEventStartIfNeeded(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_updateDeploymentStatus, server, this); + ecomplogger.recordMetricEventStart(ControllerVirtualMachineServiceOperationEnum.ControllerVirtualMachineService_updateDeploymentStatus, "self:" + ManagementServer.object2ref(this)); + try { + controller.updateDeploymentStatus(); + } catch (Exception e) { + duration_ = new Date().getTime() - now_.getTime(); + if (server != null) { + server.getServer().recordApi(null, this, "updateDeploymentStatus", ApiRequestStatus.ERROR, duration_); + } + System.err.println("ERROR: " + e); + ecomplogger.warn(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_updateDeploymentStatus, e.toString()); + EcompException e1 = EcompException.create(ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_updateDeploymentStatus, e, e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, ControllerVirtualMachineServiceMessageEnum.REQUEST_FAILED_updateDeploymentStatus, e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + duration_ = new Date().getTime() - now_.getTime(); + if (server != null) { + server.getServer().recordApi(null, this, "updateDeploymentStatus", ApiRequestStatus.OKAY, duration_); + } + + } + + + @Override + public void start() { + controller.start(); + } + + public static void ecoreSetup() { + DcaeControllerVirtualMachineServiceProvider.ecoreSetup(); + } + + @Override + public DcaeControllerVirtualMachineServiceProvider getSiriusProvider() { + return controller; + } } diff --git a/dcae-controller-service-cdap/dcae-controller-service-cdap-cluster/dcae-controller-service-cdap-cluster-manager/src/main/java/org/openecomp/dcae/controller/service/cdap/cluster/servers/manager/DcaeCdapClusterManagerProvider.java b/dcae-controller-service-cdap/dcae-controller-service-cdap-cluster/dcae-controller-service-cdap-cluster-manager/src/main/java/org/openecomp/dcae/controller/service/cdap/cluster/servers/manager/DcaeCdapClusterManagerProvider.java index 525412d..42d6955 100644 --- a/dcae-controller-service-cdap/dcae-controller-service-cdap-cluster/dcae-controller-service-cdap-cluster-manager/src/main/java/org/openecomp/dcae/controller/service/cdap/cluster/servers/manager/DcaeCdapClusterManagerProvider.java +++ b/dcae-controller-service-cdap/dcae-controller-service-cdap-cluster/dcae-controller-service-cdap-cluster-manager/src/main/java/org/openecomp/dcae/controller/service/cdap/cluster/servers/manager/DcaeCdapClusterManagerProvider.java @@ -52,7 +52,7 @@ public class DcaeCdapClusterManagerProvider extends DcaeVirtualMachineManagerPro @Override public HealthTestResponse test() { String s = run(o.getHealthCheckScript(), o.getTestTimeout()); - String a[] = s.trim().split(":"); + String[] a = s.trim().split(":"); int index = s.trim().indexOf(":"); String msg = index < 0 ? null : s.substring(index); HealthTestResponse res = ServiceFactory.eINSTANCE.createHealthTestResponse(); diff --git a/dcae-controller-service-cdap/dcae-controller-service-cdap-cluster/dcae-controller-service-cdap-cluster-manager/src/main/sirius-gen/org/openecomp/dcae/controller/service/cdap/cluster/servers/manager/DcaeCdapClusterManagerConsole.java b/dcae-controller-service-cdap/dcae-controller-service-cdap-cluster/dcae-controller-service-cdap-cluster-manager/src/main/sirius-gen/org/openecomp/dcae/controller/service/cdap/cluster/servers/manager/DcaeCdapClusterManagerConsole.java index 9a34e25..e2c72f6 100644 --- a/dcae-controller-service-cdap/dcae-controller-service-cdap-cluster/dcae-controller-service-cdap-cluster-manager/src/main/sirius-gen/org/openecomp/dcae/controller/service/cdap/cluster/servers/manager/DcaeCdapClusterManagerConsole.java +++ b/dcae-controller-service-cdap/dcae-controller-service-cdap-cluster/dcae-controller-service-cdap-cluster-manager/src/main/sirius-gen/org/openecomp/dcae/controller/service/cdap/cluster/servers/manager/DcaeCdapClusterManagerConsole.java @@ -18,7 +18,7 @@ * limitations under the License. * ============LICENSE_END============================================ */ - + // Autogenerated // Do not edit but extend this class as needed package org.openecomp.dcae.controller.service.cdap.cluster.servers.manager; @@ -26,663 +26,602 @@ package org.openecomp.dcae.controller.service.cdap.cluster.servers.manager; import org.apache.log4j.Logger; import org.eclipse.emf.common.util.EList; - -import org.openecomp.ncomp.sirius.manager.console.Console; +import org.openecomp.dcae.controller.service.cdap.cluster.servers.manager.gui.DcaeGuiClientApiConsole; import org.openecomp.ncomp.sirius.manager.AbstractClient; import org.openecomp.ncomp.sirius.manager.ManagementServerError; - - - -import org.openecomp.dcae.controller.service.cdap.cluster.servers.manager.gui.DcaeGuiClientApiConsole; +import org.openecomp.ncomp.sirius.manager.console.Console; public class DcaeCdapClusterManagerConsole extends Console { - public static final Logger logger = Logger.getLogger(DcaeCdapClusterManagerConsole.class); + public static final Logger logger = Logger.getLogger(DcaeCdapClusterManagerConsole.class); protected DcaeCdapClusterManagerClient controller; - - - DcaeGuiClientApiConsole gui; + + + DcaeGuiClientApiConsole gui; public DcaeCdapClusterManagerConsole(String filename, String name) { - super(filename, name); - controller = new DcaeCdapClusterManagerClient(filename,name); - client = controller.client; - - gui = new DcaeGuiClientApiConsole(filename,name); - } - - public DcaeCdapClusterManagerConsole(AbstractClient c) { + super(filename, name); + controller = new DcaeCdapClusterManagerClient(filename, name); + client = controller.client; + + gui = new DcaeGuiClientApiConsole(filename, name); + } + + public DcaeCdapClusterManagerConsole(AbstractClient c) { controller = new DcaeCdapClusterManagerClient(c); client = controller.client; } - public org.openecomp.dcae.controller.core.service.HealthTestResponse test() { - org.openecomp.dcae.controller.core.service.HealthTestResponse res = null; - try { - res = controller.test(); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public void suspend() { - - try { - controller.suspend(); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - - } - - public void resume() { - - try { - controller.resume(); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - - } - - public java.lang.String publicKey() { - java.lang.String res = null; - try { - res = controller.publicKey(); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public void configurationChanged() { - - try { - controller.configurationChanged(); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - - } - - public void updateStreams(EList<org.openecomp.dcae.controller.core.stream.DcaeStream> inputStreams, EList<org.openecomp.dcae.controller.core.stream.DcaeStream> outputStreams) { - - try { - controller.updateStreams(inputStreams,outputStreams); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - - } - - public void logs(EList<org.openecomp.ncomp.core.logs.LogMessage> logs) { - - try { - controller.logs(null,logs); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - - } - - public void metrics(EList<org.openecomp.ncomp.core.metrics.Metric> metrics) { - - try { - controller.metrics(null,metrics); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - - } - - public void properties(EList<org.openecomp.ncomp.sirius.manager.properties.AbstractProperty> l) { - - try { - controller.properties(null,l); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - - } - - public void uploadInfo(EList<org.openecomp.ncomp.sirius.manager.server.ManagementInfo> info) { - - try { - controller.uploadInfo(null,info); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - - } - - public EList<org.openecomp.ncomp.core.metrics.DoubleMetric> getValues(java.lang.String path, java.lang.Long start, java.lang.Long end, org.openecomp.ncomp.core.metrics.MetricValueOption option, boolean relativeInterval) { - EList<org.openecomp.ncomp.core.metrics.DoubleMetric> res = null; - try { - res = controller.getValues(null,path,start,end,option,relativeInterval); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public EList<org.openecomp.ncomp.core.metrics.DoubleMetric> getValuesAll(java.lang.String path, EList<java.lang.String> metrics, java.lang.Long start, java.lang.Long end, org.openecomp.ncomp.core.metrics.MetricValueOption option, boolean relativeInterval) { - EList<org.openecomp.ncomp.core.metrics.DoubleMetric> res = null; - try { - res = controller.getValuesAll(null,path,metrics,start,end,option,relativeInterval); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public EList<org.openecomp.ncomp.core.logs.LogMessage> getMessages(java.lang.String path, java.lang.Long start, java.lang.Long end) { - EList<org.openecomp.ncomp.core.logs.LogMessage> res = null; - try { - res = controller.getMessages(null,path,start,end); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public org.openecomp.ncomp.sirius.manager.server.LoggerInfo getRequestLogger(java.lang.String userName, java.lang.String action, java.lang.String resourcePath, org.json.JSONObject context) { - org.openecomp.ncomp.sirius.manager.server.LoggerInfo res = null; - try { - res = controller.getRequestLogger(userName,action,resourcePath,context); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public EList<org.openecomp.ncomp.core.function.ValuePair> evaluate(java.lang.String path, org.openecomp.ncomp.core.function.Function function) { - EList<org.openecomp.ncomp.core.function.ValuePair> res = null; - try { - res = controller.evaluate(path,function); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public void update(java.lang.String path, org.openecomp.ncomp.core.function.Function function) { - - try { - controller.update(path,function); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - - } - - public java.lang.String createNamespace(java.lang.String namespace) { - java.lang.String res = null; - try { - res = controller.createNamespace(namespace); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String deleteNamespace(java.lang.String namespace) { - java.lang.String res = null; - try { - res = controller.deleteNamespace(namespace); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String deployApp(java.lang.String namespace, java.lang.String jarfile) { - java.lang.String res = null; - try { - res = controller.deployApp(namespace,jarfile); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String loadArtifact(java.lang.String namespace, java.lang.String artifactName, java.lang.String jarfile, java.lang.String version) { - java.lang.String res = null; - try { - res = controller.loadArtifact(namespace,artifactName,jarfile,version); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String loadArtifactWithConfig(java.lang.String namespace, java.lang.String artifactName, java.lang.String jarfile, java.lang.String version, java.lang.String config) { - java.lang.String res = null; - try { - res = controller.loadArtifactWithConfig(namespace,artifactName,jarfile,version,config); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String deleteArtifact(java.lang.String namespace, java.lang.String artifactName, java.lang.String artifactVersion) { - java.lang.String res = null; - try { - res = controller.deleteArtifact(namespace,artifactName,artifactVersion); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String startFlow(java.lang.String namespace, java.lang.String appName, java.lang.String flowId, java.lang.String extraArgs) { - java.lang.String res = null; - try { - res = controller.startFlow(namespace,appName,flowId,extraArgs); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String startWorker(java.lang.String namespace, java.lang.String appName, java.lang.String workerId, java.lang.String extraArgs) { - java.lang.String res = null; - try { - res = controller.startWorker(namespace,appName,workerId,extraArgs); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String startService(java.lang.String namespace, java.lang.String appName, java.lang.String serviceId, java.lang.String extraArgs) { - java.lang.String res = null; - try { - res = controller.startService(namespace,appName,serviceId,extraArgs); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String startApp(java.lang.String namespace, java.lang.String appName) { - java.lang.String res = null; - try { - res = controller.startApp(namespace,appName); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String stopApp(java.lang.String namespace, java.lang.String appName, java.lang.String programTypes) { - java.lang.String res = null; - try { - res = controller.stopApp(namespace,appName,programTypes); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String deleteApp(java.lang.String namespace, java.lang.String appName) { - java.lang.String res = null; - try { - res = controller.deleteApp(namespace,appName); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String loadPreferencesApp(java.lang.String namespace, java.lang.String prefsFile, java.lang.String appId) { - java.lang.String res = null; - try { - res = controller.loadPreferencesApp(namespace,prefsFile,appId); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String loadPreferencesFlow(java.lang.String namespace, java.lang.String prefsFile, java.lang.String appId, java.lang.String flowId) { - java.lang.String res = null; - try { - res = controller.loadPreferencesFlow(namespace,prefsFile,appId,flowId); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String loadPreferencesNameSpace(java.lang.String namespace, java.lang.String prefsFile) { - java.lang.String res = null; - try { - res = controller.loadPreferencesNameSpace(namespace,prefsFile); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String setPreferencesApp(java.lang.String namespace, java.lang.String prefsString, java.lang.String appId) { - java.lang.String res = null; - try { - res = controller.setPreferencesApp(namespace,prefsString,appId); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String setPreferencesFlow(java.lang.String namespace, java.lang.String prefsString, java.lang.String appId, java.lang.String flowId) { - java.lang.String res = null; - try { - res = controller.setPreferencesFlow(namespace,prefsString,appId,flowId); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String setPreferencesWorker(java.lang.String namespace, java.lang.String prefsString, java.lang.String appId, java.lang.String workerId) { - java.lang.String res = null; - try { - res = controller.setPreferencesWorker(namespace,prefsString,appId,workerId); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String setPreferencesService(java.lang.String namespace, java.lang.String prefsString, java.lang.String appId, java.lang.String serviceId) { - java.lang.String res = null; - try { - res = controller.setPreferencesService(namespace,prefsString,appId,serviceId); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String setPreferencesNameSpace(java.lang.String namespace, java.lang.String prefsString) { - java.lang.String res = null; - try { - res = controller.setPreferencesNameSpace(namespace,prefsString); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String setFlowRunTimeArgs(java.lang.String namespace, java.lang.String appId, java.lang.String flowId, java.lang.String args) { - java.lang.String res = null; - try { - res = controller.setFlowRunTimeArgs(namespace,appId,flowId,args); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String setFlowletInstances(java.lang.String namespace, java.lang.String appId, java.lang.String flowId, java.lang.String flowletId, int nInstances) { - java.lang.String res = null; - try { - res = controller.setFlowletInstances(namespace,appId,flowId,flowletId,nInstances); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String stopFlow(java.lang.String namespace, java.lang.String appId, java.lang.String flowId) { - java.lang.String res = null; - try { - res = controller.stopFlow(namespace,appId,flowId); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String stopWorker(java.lang.String namespace, java.lang.String appId, java.lang.String workerId) { - java.lang.String res = null; - try { - res = controller.stopWorker(namespace,appId,workerId); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String stopService(java.lang.String namespace, java.lang.String appId, java.lang.String serviceId) { - java.lang.String res = null; - try { - res = controller.stopService(namespace,appId,serviceId); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String truncateDataSet(java.lang.String namespace, java.lang.String datasetName) { - java.lang.String res = null; - try { - res = controller.truncateDataSet(namespace,datasetName); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String deleteDataset(java.lang.String namespace, java.lang.String datasetName) { - java.lang.String res = null; - try { - res = controller.deleteDataset(namespace,datasetName); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String createStream(java.lang.String namespace, java.lang.String newStreamId) { - java.lang.String res = null; - try { - res = controller.createStream(namespace,newStreamId); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String deleteStream(java.lang.String namespace, java.lang.String streamId) { - java.lang.String res = null; - try { - res = controller.deleteStream(namespace,streamId); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public EList<java.lang.String> getStreamEvents(java.lang.String namespace, java.lang.String streamId, java.lang.String startTime, java.lang.String endTime, int limit) { - EList<java.lang.String> res = null; - try { - res = controller.getStreamEvents(namespace,streamId,startTime,endTime,limit); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public EList<java.lang.String> getStreamStats(java.lang.String namespace, java.lang.String streamId, java.lang.String startTime, java.lang.String endTime, int limit) { - EList<java.lang.String> res = null; - try { - res = controller.getStreamStats(namespace,streamId,startTime,endTime,limit); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String sendEventToStream(java.lang.String namespace, java.lang.String streamId, java.lang.String event) { - java.lang.String res = null; - try { - res = controller.sendEventToStream(namespace,streamId,event); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String trucateStream(java.lang.String namespace, java.lang.String streamId) { - java.lang.String res = null; - try { - res = controller.trucateStream(namespace,streamId); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String setStreamProperties(java.lang.String namespace, java.lang.String streamId, java.lang.String propsFile) { - java.lang.String res = null; - try { - res = controller.setStreamProperties(namespace,streamId,propsFile); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String restartApp(java.lang.String namespace, java.lang.String appId, java.lang.String progTypes) { - java.lang.String res = null; - try { - res = controller.restartApp(namespace,appId,progTypes); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String createApp(java.lang.String namespace, java.lang.String appId, java.lang.String artifactName, java.lang.String artifactVersion, java.lang.String scope) { - java.lang.String res = null; - try { - res = controller.createApp(namespace,appId,artifactName,artifactVersion,scope); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String createAppWithConfig(java.lang.String namespace, java.lang.String appId, java.lang.String artifactName, java.lang.String artifactVersion, java.lang.String scope, java.lang.String appConfig) { - java.lang.String res = null; - try { - res = controller.createAppWithConfig(namespace,appId,artifactName,artifactVersion,scope,appConfig); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String setDatasetProperties(java.lang.String namespace, java.lang.String datasetName, java.lang.String datasetProperties) { - java.lang.String res = null; - try { - res = controller.setDatasetProperties(namespace,datasetName,datasetProperties); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String setStreamTTL(java.lang.String namespace, java.lang.String streamName, int ttlSeconds) { - java.lang.String res = null; - try { - res = controller.setStreamTTL(namespace,streamName,ttlSeconds); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String suspendSchedule(java.lang.String namespace, java.lang.String appId, java.lang.String scheduleId) { - java.lang.String res = null; - try { - res = controller.suspendSchedule(namespace,appId,scheduleId); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } - - public java.lang.String resumeSchedule(java.lang.String namespace, java.lang.String appId, java.lang.String scheduleId) { - java.lang.String res = null; - try { - res = controller.resumeSchedule(namespace,appId,scheduleId); - } - catch (ManagementServerError e) { - System.err.println("ERROR: " + e.getJson().toString(2)); - } - return res; - } + public org.openecomp.dcae.controller.core.service.HealthTestResponse test() { + org.openecomp.dcae.controller.core.service.HealthTestResponse res = null; + try { + res = controller.test(); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public void suspend() { + + try { + controller.suspend(); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + + } + + public void resume() { + + try { + controller.resume(); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + + } + + public java.lang.String publicKey() { + java.lang.String res = null; + try { + res = controller.publicKey(); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public void configurationChanged() { + + try { + controller.configurationChanged(); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + + } + + public void updateStreams(EList<org.openecomp.dcae.controller.core.stream.DcaeStream> inputStreams, EList<org.openecomp.dcae.controller.core.stream.DcaeStream> outputStreams) { + + try { + controller.updateStreams(inputStreams, outputStreams); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + + } + + public void logs(EList<org.openecomp.ncomp.core.logs.LogMessage> logs) { + + try { + controller.logs(null, logs); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + + } + + public void metrics(EList<org.openecomp.ncomp.core.metrics.Metric> metrics) { + + try { + controller.metrics(null, metrics); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + + } + + public void properties(EList<org.openecomp.ncomp.sirius.manager.properties.AbstractProperty> l) { + + try { + controller.properties(null, l); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + + } + + public void uploadInfo(EList<org.openecomp.ncomp.sirius.manager.server.ManagementInfo> info) { + + try { + controller.uploadInfo(null, info); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + + } + + public EList<org.openecomp.ncomp.core.metrics.DoubleMetric> getValues(java.lang.String path, java.lang.Long start, java.lang.Long end, org.openecomp.ncomp.core.metrics.MetricValueOption option, boolean relativeInterval) { + EList<org.openecomp.ncomp.core.metrics.DoubleMetric> res = null; + try { + res = controller.getValues(null, path, start, end, option, relativeInterval); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public EList<org.openecomp.ncomp.core.metrics.DoubleMetric> getValuesAll(java.lang.String path, EList<java.lang.String> metrics, java.lang.Long start, java.lang.Long end, org.openecomp.ncomp.core.metrics.MetricValueOption option, boolean relativeInterval) { + EList<org.openecomp.ncomp.core.metrics.DoubleMetric> res = null; + try { + res = controller.getValuesAll(null, path, metrics, start, end, option, relativeInterval); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public EList<org.openecomp.ncomp.core.logs.LogMessage> getMessages(java.lang.String path, java.lang.Long start, java.lang.Long end) { + EList<org.openecomp.ncomp.core.logs.LogMessage> res = null; + try { + res = controller.getMessages(null, path, start, end); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public org.openecomp.ncomp.sirius.manager.server.LoggerInfo getRequestLogger(java.lang.String userName, java.lang.String action, java.lang.String resourcePath, org.json.JSONObject context) { + org.openecomp.ncomp.sirius.manager.server.LoggerInfo res = null; + try { + res = controller.getRequestLogger(userName, action, resourcePath, context); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public EList<org.openecomp.ncomp.core.function.ValuePair> evaluate(java.lang.String path, org.openecomp.ncomp.core.function.Function function) { + EList<org.openecomp.ncomp.core.function.ValuePair> res = null; + try { + res = controller.evaluate(path, function); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public void update(java.lang.String path, org.openecomp.ncomp.core.function.Function function) { + + try { + controller.update(path, function); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + + } + + public java.lang.String createNamespace(java.lang.String namespace) { + java.lang.String res = null; + try { + res = controller.createNamespace(namespace); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String deleteNamespace(java.lang.String namespace) { + java.lang.String res = null; + try { + res = controller.deleteNamespace(namespace); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String deployApp(java.lang.String namespace, java.lang.String jarfile) { + java.lang.String res = null; + try { + res = controller.deployApp(namespace, jarfile); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String loadArtifact(java.lang.String namespace, java.lang.String artifactName, java.lang.String jarfile, java.lang.String version) { + java.lang.String res = null; + try { + res = controller.loadArtifact(namespace, artifactName, jarfile, version); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String loadArtifactWithConfig(java.lang.String namespace, java.lang.String artifactName, java.lang.String jarfile, java.lang.String version, java.lang.String config) { + java.lang.String res = null; + try { + res = controller.loadArtifactWithConfig(namespace, artifactName, jarfile, version, config); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String deleteArtifact(java.lang.String namespace, java.lang.String artifactName, java.lang.String artifactVersion) { + java.lang.String res = null; + try { + res = controller.deleteArtifact(namespace, artifactName, artifactVersion); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String startFlow(java.lang.String namespace, java.lang.String appName, java.lang.String flowId, java.lang.String extraArgs) { + java.lang.String res = null; + try { + res = controller.startFlow(namespace, appName, flowId, extraArgs); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String startWorker(java.lang.String namespace, java.lang.String appName, java.lang.String workerId, java.lang.String extraArgs) { + java.lang.String res = null; + try { + res = controller.startWorker(namespace, appName, workerId, extraArgs); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String startService(java.lang.String namespace, java.lang.String appName, java.lang.String serviceId, java.lang.String extraArgs) { + java.lang.String res = null; + try { + res = controller.startService(namespace, appName, serviceId, extraArgs); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String startApp(java.lang.String namespace, java.lang.String appName) { + java.lang.String res = null; + try { + res = controller.startApp(namespace, appName); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String stopApp(java.lang.String namespace, java.lang.String appName, java.lang.String programTypes) { + java.lang.String res = null; + try { + res = controller.stopApp(namespace, appName, programTypes); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String deleteApp(java.lang.String namespace, java.lang.String appName) { + java.lang.String res = null; + try { + res = controller.deleteApp(namespace, appName); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String loadPreferencesApp(java.lang.String namespace, java.lang.String prefsFile, java.lang.String appId) { + java.lang.String res = null; + try { + res = controller.loadPreferencesApp(namespace, prefsFile, appId); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String loadPreferencesFlow(java.lang.String namespace, java.lang.String prefsFile, java.lang.String appId, java.lang.String flowId) { + java.lang.String res = null; + try { + res = controller.loadPreferencesFlow(namespace, prefsFile, appId, flowId); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String loadPreferencesNameSpace(java.lang.String namespace, java.lang.String prefsFile) { + java.lang.String res = null; + try { + res = controller.loadPreferencesNameSpace(namespace, prefsFile); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String setPreferencesApp(java.lang.String namespace, java.lang.String prefsString, java.lang.String appId) { + java.lang.String res = null; + try { + res = controller.setPreferencesApp(namespace, prefsString, appId); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String setPreferencesFlow(java.lang.String namespace, java.lang.String prefsString, java.lang.String appId, java.lang.String flowId) { + java.lang.String res = null; + try { + res = controller.setPreferencesFlow(namespace, prefsString, appId, flowId); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String setPreferencesWorker(java.lang.String namespace, java.lang.String prefsString, java.lang.String appId, java.lang.String workerId) { + java.lang.String res = null; + try { + res = controller.setPreferencesWorker(namespace, prefsString, appId, workerId); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String setPreferencesService(java.lang.String namespace, java.lang.String prefsString, java.lang.String appId, java.lang.String serviceId) { + java.lang.String res = null; + try { + res = controller.setPreferencesService(namespace, prefsString, appId, serviceId); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String setPreferencesNameSpace(java.lang.String namespace, java.lang.String prefsString) { + java.lang.String res = null; + try { + res = controller.setPreferencesNameSpace(namespace, prefsString); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String setFlowRunTimeArgs(java.lang.String namespace, java.lang.String appId, java.lang.String flowId, java.lang.String args) { + java.lang.String res = null; + try { + res = controller.setFlowRunTimeArgs(namespace, appId, flowId, args); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String setFlowletInstances(java.lang.String namespace, java.lang.String appId, java.lang.String flowId, java.lang.String flowletId, int nInstances) { + java.lang.String res = null; + try { + res = controller.setFlowletInstances(namespace, appId, flowId, flowletId, nInstances); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String stopFlow(java.lang.String namespace, java.lang.String appId, java.lang.String flowId) { + java.lang.String res = null; + try { + res = controller.stopFlow(namespace, appId, flowId); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String stopWorker(java.lang.String namespace, java.lang.String appId, java.lang.String workerId) { + java.lang.String res = null; + try { + res = controller.stopWorker(namespace, appId, workerId); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String stopService(java.lang.String namespace, java.lang.String appId, java.lang.String serviceId) { + java.lang.String res = null; + try { + res = controller.stopService(namespace, appId, serviceId); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String truncateDataSet(java.lang.String namespace, java.lang.String datasetName) { + java.lang.String res = null; + try { + res = controller.truncateDataSet(namespace, datasetName); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String deleteDataset(java.lang.String namespace, java.lang.String datasetName) { + java.lang.String res = null; + try { + res = controller.deleteDataset(namespace, datasetName); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String createStream(java.lang.String namespace, java.lang.String newStreamId) { + java.lang.String res = null; + try { + res = controller.createStream(namespace, newStreamId); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String deleteStream(java.lang.String namespace, java.lang.String streamId) { + java.lang.String res = null; + try { + res = controller.deleteStream(namespace, streamId); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public EList<java.lang.String> getStreamEvents(java.lang.String namespace, java.lang.String streamId, java.lang.String startTime, java.lang.String endTime, int limit) { + EList<java.lang.String> res = null; + try { + res = controller.getStreamEvents(namespace, streamId, startTime, endTime, limit); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public EList<java.lang.String> getStreamStats(java.lang.String namespace, java.lang.String streamId, java.lang.String startTime, java.lang.String endTime, int limit) { + EList<java.lang.String> res = null; + try { + res = controller.getStreamStats(namespace, streamId, startTime, endTime, limit); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String sendEventToStream(java.lang.String namespace, java.lang.String streamId, java.lang.String event) { + java.lang.String res = null; + try { + res = controller.sendEventToStream(namespace, streamId, event); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String trucateStream(java.lang.String namespace, java.lang.String streamId) { + java.lang.String res = null; + try { + res = controller.trucateStream(namespace, streamId); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String setStreamProperties(java.lang.String namespace, java.lang.String streamId, java.lang.String propsFile) { + java.lang.String res = null; + try { + res = controller.setStreamProperties(namespace, streamId, propsFile); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String restartApp(java.lang.String namespace, java.lang.String appId, java.lang.String progTypes) { + java.lang.String res = null; + try { + res = controller.restartApp(namespace, appId, progTypes); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String createApp(java.lang.String namespace, java.lang.String appId, java.lang.String artifactName, java.lang.String artifactVersion, java.lang.String scope) { + java.lang.String res = null; + try { + res = controller.createApp(namespace, appId, artifactName, artifactVersion, scope); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String createAppWithConfig(java.lang.String namespace, java.lang.String appId, java.lang.String artifactName, java.lang.String artifactVersion, java.lang.String scope, java.lang.String appConfig) { + java.lang.String res = null; + try { + res = controller.createAppWithConfig(namespace, appId, artifactName, artifactVersion, scope, appConfig); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String setDatasetProperties(java.lang.String namespace, java.lang.String datasetName, java.lang.String datasetProperties) { + java.lang.String res = null; + try { + res = controller.setDatasetProperties(namespace, datasetName, datasetProperties); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String setStreamTTL(java.lang.String namespace, java.lang.String streamName, int ttlSeconds) { + java.lang.String res = null; + try { + res = controller.setStreamTTL(namespace, streamName, ttlSeconds); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String suspendSchedule(java.lang.String namespace, java.lang.String appId, java.lang.String scheduleId) { + java.lang.String res = null; + try { + res = controller.suspendSchedule(namespace, appId, scheduleId); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } + + public java.lang.String resumeSchedule(java.lang.String namespace, java.lang.String appId, java.lang.String scheduleId) { + java.lang.String res = null; + try { + res = controller.resumeSchedule(namespace, appId, scheduleId); + } catch (ManagementServerError e) { + logger.error("ERROR: " + e.getJson().toString(2), e); + } + return res; + } } diff --git a/dcae-controller-service-docker/dcae-controller-service-docker-adaptor/src/main/java/org/openecomp/dcae/controller/service/servers/docker/DcaeDockerServiceProvider.java b/dcae-controller-service-docker/dcae-controller-service-docker-adaptor/src/main/java/org/openecomp/dcae/controller/service/servers/docker/DcaeDockerServiceProvider.java index 883ec7b..6d27af3 100644 --- a/dcae-controller-service-docker/dcae-controller-service-docker-adaptor/src/main/java/org/openecomp/dcae/controller/service/servers/docker/DcaeDockerServiceProvider.java +++ b/dcae-controller-service-docker/dcae-controller-service-docker-adaptor/src/main/java/org/openecomp/dcae/controller/service/servers/docker/DcaeDockerServiceProvider.java @@ -18,10 +18,8 @@ * limitations under the License. * ============LICENSE_END============================================ */ - -package org.openecomp.dcae.controller.service.servers.docker; -import java.util.Date; +package org.openecomp.dcae.controller.service.servers.docker; import org.apache.log4j.Logger; import org.eclipse.emf.common.util.BasicEList; @@ -29,8 +27,6 @@ import org.eclipse.emf.common.util.EList; import org.eclipse.emf.ecore.EObject; import org.eclipse.emf.ecore.util.EcoreUtil; import org.json.JSONObject; - -import org.openecomp.dcae.controller.core.service.DcaeServiceContainer; import org.openecomp.dcae.controller.core.service.HealthTestResponse; import org.openecomp.dcae.controller.core.service.HealthTestStatus; import org.openecomp.dcae.controller.core.service.ServiceFactory; @@ -38,15 +34,10 @@ import org.openecomp.dcae.controller.core.stream.DcaeStream; import org.openecomp.dcae.controller.core.stream.DmaapStream; import org.openecomp.dcae.controller.service.docker.DockerService; import org.openecomp.dcae.controller.service.docker.DockerServiceInstance; -import org.openecomp.dcae.controller.service.docker.host.servers.manager.DcaeDockerHostManager; import org.openecomp.dcae.controller.service.docker.host.servers.manager.DcaeDockerHostManagerConsole; -import org.openecomp.dcae.controller.service.docker.host.servers.service.DcaeDockerHostService; import org.openecomp.dcae.controller.service.docker.host.servers.service.DcaeDockerHostServiceProvider; import org.openecomp.dcae.controller.service.docker.host.service.DockerHostServiceInstance; -import org.openecomp.dcae.controller.service.servers.dockermanager.DcaeDockerManagerConsole; -import org.openecomp.dcae.controller.service.servers.vmmanager.DcaeVirtualMachineManagerConsole; import org.openecomp.dcae.controller.service.vm.VirtualMachineService; -import org.openecomp.dcae.controller.service.vm.VirtualMachineServiceInstance; import org.openecomp.ncomp.core.DeploymentStatus; import org.openecomp.ncomp.docker.ContainerOptions; import org.openecomp.ncomp.docker.ContainerPortBindings; @@ -62,289 +53,295 @@ import org.openecomp.ncomp.sirius.manager.ManagementServer; import org.openecomp.ncomp.sirius.manager.ManagementServerUtils; import org.openecomp.ncomp.sirius.manager.Subject; import org.openecomp.ncomp.sirius.manager.metrics.MetricStore; -import org.openecomp.ncomp.utils.CryptoUtils; + +import java.util.Date; public class DcaeDockerServiceProvider extends BasicAdaptorProvider { - private static final Logger logger = Logger.getLogger(DcaeDockerServiceProvider.class); - DockerService o; - - public DcaeDockerServiceProvider(ISiriusServer controller, DockerService o) { - super(controller, o); - this.o = o; - } - - public void deploy(String instanceName, String containerPath) { - DockerServiceInstance i = findInstance(instanceName); - if (!(containerPath == null || containerPath.equals(""))) { - Subject s = controller.getServer().find(containerPath); - if (s == null || s.o == null) { - throw new RuntimeException("Unable to find container object: " + containerPath); - } - if (!(s.o instanceof DockerHostServiceInstance)) - throw new RuntimeException("Unable to deploy to this non docker host container: " + containerPath); - i.setHostService((DockerHostServiceInstance) s.o); - } - if (i.getHostService() == null) { - throw new RuntimeException("Null Container: unable to deploy: " + o.getName() + " " + i.getName()); - } - i.setDockerName(dockerName(i)); - ContainerOptions opts = DockerFactory.eINSTANCE.createContainerOptions(); - opts.setName(i.getDockerName()); - opts.getVolumes().addAll(i.getVolumes()); - opts.getLinks().addAll(i.getLinks()); - opts.getEnv().addAll(i.getEnvs()); - for (ContainerPortBindings p : i.getPortBindings()) { - opts.getPortBindings().add(EcoreUtil.copy(p)); - } - console(instanceName).setupConfiguration(o.getName(), instanceName); - consoleHost(i).dockerRunWithOptions("/resources/dockerHost", image(i), opts); - long toolate = System.currentTimeMillis() + 15 * 60 * 1000; - // wait 15 minutes for container manager - while (i.getManagerPortNumber() > 0 && System.currentTimeMillis() < toolate) { - try { - o.pushManagerConfiguration(instanceName); - break; - } catch (Exception e) { - try { - Thread.sleep(5000); - } catch (InterruptedException e1) { - throw new RuntimeException("Deployment timeout: Deployment interrupted"); - } - } - if (System.currentTimeMillis() >= toolate) - throw new RuntimeException("Unable to configure Docker"); - } - } - - private String image(DockerServiceInstance i) { - if (i.getImage().contains("/")) - return i.getImage(); - String dns = i.getHostService().getServers().get(0).getNetworks().get(0).getDnsName(); - return dns + ":7113/" + i.getImage(); - } - - public void undeploy(String instanceName) { - DockerServiceInstance i = findInstance(instanceName); - DockerDockerHostConsole c = consoleHost(i); + private static final Logger logger = Logger.getLogger(DcaeDockerServiceProvider.class); + DockerService o; + + public DcaeDockerServiceProvider(ISiriusServer controller, DockerService o) { + super(controller, o); + this.o = o; + } + + public void deploy(String instanceName, String containerPath) { + DockerServiceInstance i = findInstance(instanceName); + if (!(containerPath == null || containerPath.equals(""))) { + Subject s = controller.getServer().find(containerPath); + if (s == null || s.o == null) { + throw new RuntimeException("Unable to find container object: " + containerPath); + } + if (!(s.o instanceof DockerHostServiceInstance)) { + throw new RuntimeException("Unable to deploy to this non docker host container: " + containerPath); + } + i.setHostService((DockerHostServiceInstance) s.o); + } + if (i.getHostService() == null) { + throw new RuntimeException("Null Container: unable to deploy: " + o.getName() + " " + i.getName()); + } + i.setDockerName(dockerName(i)); + ContainerOptions opts = DockerFactory.eINSTANCE.createContainerOptions(); + opts.setName(i.getDockerName()); + opts.getVolumes().addAll(i.getVolumes()); + opts.getLinks().addAll(i.getLinks()); + opts.getEnv().addAll(i.getEnvs()); + for (ContainerPortBindings p : i.getPortBindings()) { + opts.getPortBindings().add(EcoreUtil.copy(p)); + } + console(instanceName).setupConfiguration(o.getName(), instanceName); + consoleHost(i).dockerRunWithOptions("/resources/dockerHost", image(i), opts); + long toolate = System.currentTimeMillis() + 15 * 60 * 1000; + // wait 15 minutes for container manager + while (i.getManagerPortNumber() > 0 && System.currentTimeMillis() < toolate) { + try { + o.pushManagerConfiguration(instanceName); + break; + } catch (Exception e) { + try { + Thread.sleep(5000); + } catch (InterruptedException e1) { + throw new RuntimeException("Deployment timeout: Deployment interrupted"); + } + } + if (System.currentTimeMillis() >= toolate) { + throw new RuntimeException("Unable to configure Docker"); + } + } + } + + private String image(DockerServiceInstance i) { + if (i.getImage().contains("/")) { + return i.getImage(); + } + String dns = i.getHostService().getServers().get(0).getNetworks().get(0).getDnsName(); + return dns + ":7113/" + i.getImage(); + } + + public void undeploy(String instanceName) { + DockerServiceInstance i = findInstance(instanceName); + DockerDockerHostConsole c = consoleHost(i); // c.stopContainer("/resources/dockerHost", i.getDockerName(), 10); // c.killContainer("/resources/dockerHost", i.getDockerName(), "KILL"); - c.removeContainer("/resources/dockerHost", i.getDockerName(), true, true); - } - - private DcaeDockerHostManagerConsole console(String instanceName) { - DockerServiceInstance i = findInstance(instanceName); - return new DcaeDockerHostManagerConsole(getClient(i)); - } - - public AbstractClient getClient(DockerServiceInstance i) { - DockerHostServiceInstance instance = i.getHostService(); - VirtualMachineService service = instance.getService(); - DcaeDockerHostServiceProvider provider = (DcaeDockerHostServiceProvider) ((ISiriusProvider) service).getSiriusProvider(); - return provider.getClient(instance); - } - - private DockerDockerHostConsole consoleHost(DockerServiceInstance i) { - DockerHostServiceInstance instance = i.getHostService(); - VirtualMachineService service = instance.getService(); - DcaeDockerHostServiceProvider provider = (DcaeDockerHostServiceProvider) ((ISiriusProvider) service).getSiriusProvider(); - AbstractClient c = provider.getClient(instance); - return new DockerDockerHostConsole(c); - } - - private String dockerName(DockerServiceInstance i) { - return "dcae_" + o.getName() + "_" + i.getName(); - // return "dcae"+ new Date().getTime(); - } - - protected DockerServiceInstance findInstance(String instanceName) { - for (DockerServiceInstance ii : o.getInstances()) { - if (ii.getName().equals(instanceName)) { - ii.setDockerName(dockerName(ii)); - return ii; - } - } - throw new RuntimeException("Unable to find instance: " + instanceName); - - } - - public HealthTestResponse test(String instanceName) { - DockerServiceInstance i = findInstance(instanceName); - DockerContainer c = findContainer(i); - HealthTestResponse h = ServiceFactory.eINSTANCE.createHealthTestResponse(); - if (c == null) { - h.setStatus(HealthTestStatus.YELLOW); - h.setMessageCode("Container not Deployed"); - return h; - } - System.out.println("DOCKER: test" + i.getDockerName() + " " + c.getStatus()); - if (c.getStatus().startsWith("Exited")) { - h.setStatus(HealthTestStatus.RED); - h.setMessageCode("Container not running"); - return h; - } - if (c.getStatus().startsWith("Created")) { - h.setStatus(HealthTestStatus.RED); - h.setMessageCode("Container never started"); - return h; - } - if (c.getStatus().startsWith("Restarting")) { - h.setStatus(HealthTestStatus.RED); - h.setMessageCode("Container restarting"); - return h; - } - if (i.getManagerPortNumber() > 0) { - System.out.println("DOCKER: test" + i.getDockerName() + "HERE"); - return console(instanceName).testContainer(i.getDockerName()); - } - h.setStatus(HealthTestStatus.GREEN); - return h; - } - - public void suspend(String instanceName) { - DockerServiceInstance i = findInstance(instanceName); - console(instanceName).suspendContainer(i.getDockerName()); - } - - public void resume(String instanceName) { - DockerServiceInstance i = findInstance(instanceName); - console(instanceName).resumeContainer(i.getDockerName()); - } - - public void pushManagerConfiguration(String instanceName) { - DockerServiceInstance i = findInstance(instanceName); - DcaeDockerHostManagerConsole console = console(instanceName); - EObject config = o.managerConfiguration(instanceName); - System.out.println("DDDDD " + ManagementServer.ecore2json(config, 1000, null, true).toString(2)); - EList<DcaeStream> l1 = new BasicEList<DcaeStream>(); - l1.addAll(EcoreUtil.copyAll(i.getInputStreams())); - EList<DcaeStream> l2 = new BasicEList<DcaeStream>(); - l2.addAll(EcoreUtil.copyAll(i.getOutputStreams())); - console.updateContainerConfiguration(i.getDockerName(), config, decrypt(l1), decrypt(l2)); - } - - private EList<DcaeStream> decrypt(EList<DcaeStream> l) { - for (DcaeStream s : l) { - if (s instanceof DmaapStream) { - DmaapStream s1 = (DmaapStream) s; - String pw = s1.getDmaapPassword(); - if (pw != null && pw.startsWith("rsa:")) { - try { - s1.setDmaapPassword(JavaHttpClient.decryptPassword(pw)); - } catch (Exception e) { - System.err.println("ZZZZZ: bad pw: " + ManagementServer.object2ref(s)); - s1.setDmaapPassword("decryption error"); - } - } - else - System.err.println("ZZZZZ: unencrypted pw: " + ManagementServer.object2ref(s)); - continue; - } - System.err.println("ZZZZZ: unknown type: " + s.getClass().getName()); - } - return l; - } - - public void pollManagerConfiguration(String instanceName) { - - // TODO IMPLEMENT - throw new UnsupportedOperationException(); - } - - public org.eclipse.emf.ecore.EObject managerConfiguration(String instanceName) { - // TODO IMPLEMENT - throw new UnsupportedOperationException(); - } - - public JSONObject managerOperation(String instanceName, String operation, JSONObject parameters) { - // TODO IMPLEMENT - throw new UnsupportedOperationException(); - } - - public void updateConfigurationFromPolicy(String instanceName) { - - // TODO IMPLEMENT - throw new UnsupportedOperationException(); - } - - public void runHealthTests() { -// System.out.println("DOCKER: runHealthTests" + o.getName()); - for (DockerServiceInstance i : o.getInstances()) { - HealthTestResponse s = null; - try { - if (i.getStatus() == DeploymentStatus.DEPLOYED) { - s = test(i.getName()); - } else { - s = ServiceFactory.eINSTANCE.createHealthTestResponse(); - s.setMessageCode("Not deployed"); - s.setStatus(HealthTestStatus.YELLOW); - } - } catch (Exception e) { - s = ServiceFactory.eINSTANCE.createHealthTestResponse(); - s.setMessageCode("Unable to determine health: " + e); - s.setStatus(HealthTestStatus.RED); - } - i.setHealthTestStatus(s.getStatus()); - i.setHealthTestMessageCode(s.getMessageCode()); - MetricStore store = controller.getServer().metrics.getStore(i); - Date now = new Date(); - String path = "/lastHealthTest"; - store.addLongValue(path, now, now.getTime(), "DateMetricAttribute", false); - } - } - - public void start() { - - Thread t = new Thread("docker service: " + o.getName()) { - @Override - public void run() { - while (true) { - try { - if (! controller.getServer().isSlave) - updateDeploymentStatus(); - Thread.sleep(60000); // sleep 60 seconds - } catch (Exception e) { - ManagementServerUtils.printStackTrace(e); - logger.fatal("vm service: " + o.getName() + " : " + e); - try { - Thread.sleep(30000); - } catch (InterruptedException e1) { - } - } - } - } - - }; - t.start(); - } - - public void updateDeploymentStatus() { - for (DockerServiceInstance instance : o.getInstances()) { - instance.setDockerName(dockerName(instance)); - DockerContainer c = findContainer(instance); - if (c != null) { - if (c.getStatus() != null && c.getStatus().startsWith("Up")) - instance.setStatus(DeploymentStatus.DEPLOYED); - else - instance.setStatus(DeploymentStatus.DEPLOYED_PARTIALLY); - } - else - instance.setStatus(DeploymentStatus.UNDEPLOYED); - } - } - - private DockerContainer findContainer(DockerServiceInstance instance) { - if (instance.getHostService() == null) - return null; - for (DockerContainer c : instance.getHostService().getDockerHost().getContainers()) { - if (instance.getDockerName() != null && instance.getDockerName().equals(c.getName())) { - return c; - } - } - return null; - } - - protected EObject convertToManagerConfiguration(DockerServiceInstance i) { - // TODO Auto-generated method stub - return null; - } + c.removeContainer("/resources/dockerHost", i.getDockerName(), true, true); + } + + private DcaeDockerHostManagerConsole console(String instanceName) { + DockerServiceInstance i = findInstance(instanceName); + return new DcaeDockerHostManagerConsole(getClient(i)); + } + + public AbstractClient getClient(DockerServiceInstance i) { + DockerHostServiceInstance instance = i.getHostService(); + VirtualMachineService service = instance.getService(); + DcaeDockerHostServiceProvider provider = (DcaeDockerHostServiceProvider) ((ISiriusProvider) service).getSiriusProvider(); + return provider.getClient(instance); + } + + private DockerDockerHostConsole consoleHost(DockerServiceInstance i) { + DockerHostServiceInstance instance = i.getHostService(); + VirtualMachineService service = instance.getService(); + DcaeDockerHostServiceProvider provider = (DcaeDockerHostServiceProvider) ((ISiriusProvider) service).getSiriusProvider(); + AbstractClient c = provider.getClient(instance); + return new DockerDockerHostConsole(c); + } + + private String dockerName(DockerServiceInstance i) { + return "dcae_" + o.getName() + "_" + i.getName(); + // return "dcae"+ new Date().getTime(); + } + + protected DockerServiceInstance findInstance(String instanceName) { + for (DockerServiceInstance ii : o.getInstances()) { + if (ii.getName().equals(instanceName)) { + ii.setDockerName(dockerName(ii)); + return ii; + } + } + throw new RuntimeException("Unable to find instance: " + instanceName); + + } + + public HealthTestResponse test(String instanceName) { + DockerServiceInstance i = findInstance(instanceName); + DockerContainer c = findContainer(i); + HealthTestResponse h = ServiceFactory.eINSTANCE.createHealthTestResponse(); + if (c == null) { + h.setStatus(HealthTestStatus.YELLOW); + h.setMessageCode("Container not Deployed"); + return h; + } + System.out.println("DOCKER: test" + i.getDockerName() + " " + c.getStatus()); + if (c.getStatus().startsWith("Exited")) { + h.setStatus(HealthTestStatus.RED); + h.setMessageCode("Container not running"); + return h; + } + if (c.getStatus().startsWith("Created")) { + h.setStatus(HealthTestStatus.RED); + h.setMessageCode("Container never started"); + return h; + } + if (c.getStatus().startsWith("Restarting")) { + h.setStatus(HealthTestStatus.RED); + h.setMessageCode("Container restarting"); + return h; + } + if (i.getManagerPortNumber() > 0) { + System.out.println("DOCKER: test" + i.getDockerName() + "HERE"); + return console(instanceName).testContainer(i.getDockerName()); + } + h.setStatus(HealthTestStatus.GREEN); + return h; + } + + public void suspend(String instanceName) { + DockerServiceInstance i = findInstance(instanceName); + console(instanceName).suspendContainer(i.getDockerName()); + } + + public void resume(String instanceName) { + DockerServiceInstance i = findInstance(instanceName); + console(instanceName).resumeContainer(i.getDockerName()); + } + + public void pushManagerConfiguration(String instanceName) { + DockerServiceInstance i = findInstance(instanceName); + DcaeDockerHostManagerConsole console = console(instanceName); + EObject config = o.managerConfiguration(instanceName); + System.out.println("DDDDD " + ManagementServer.ecore2json(config, 1000, null, true).toString(2)); + EList<DcaeStream> l1 = new BasicEList<DcaeStream>(); + l1.addAll(EcoreUtil.copyAll(i.getInputStreams())); + EList<DcaeStream> l2 = new BasicEList<DcaeStream>(); + l2.addAll(EcoreUtil.copyAll(i.getOutputStreams())); + console.updateContainerConfiguration(i.getDockerName(), config, decrypt(l1), decrypt(l2)); + } + + private EList<DcaeStream> decrypt(EList<DcaeStream> l) { + for (DcaeStream s : l) { + if (s instanceof DmaapStream) { + DmaapStream s1 = (DmaapStream) s; + String pw = s1.getDmaapPassword(); + if (pw != null && pw.startsWith("rsa:")) { + try { + s1.setDmaapPassword(JavaHttpClient.decryptPassword(pw)); + } catch (Exception e) { + System.err.println("ZZZZZ: bad pw: " + ManagementServer.object2ref(s)); + s1.setDmaapPassword("decryption error"); + } + } else { + System.err.println("ZZZZZ: unencrypted pw: " + ManagementServer.object2ref(s)); + } + continue; + } + System.err.println("ZZZZZ: unknown type: " + s.getClass().getName()); + } + return l; + } + + public void pollManagerConfiguration(String instanceName) { + + // TODO IMPLEMENT + throw new UnsupportedOperationException(); + } + + public org.eclipse.emf.ecore.EObject managerConfiguration(String instanceName) { + // TODO IMPLEMENT + throw new UnsupportedOperationException(); + } + + public JSONObject managerOperation(String instanceName, String operation, JSONObject parameters) { + // TODO IMPLEMENT + throw new UnsupportedOperationException(); + } + + public void updateConfigurationFromPolicy(String instanceName) { + + // TODO IMPLEMENT + throw new UnsupportedOperationException(); + } + + public void runHealthTests() { + for (DockerServiceInstance i : o.getInstances()) { + HealthTestResponse s = null; + try { + if (i.getStatus() == DeploymentStatus.DEPLOYED) { + s = test(i.getName()); + } else { + s = ServiceFactory.eINSTANCE.createHealthTestResponse(); + s.setMessageCode("Not deployed"); + s.setStatus(HealthTestStatus.YELLOW); + } + } catch (Exception e) { + s = ServiceFactory.eINSTANCE.createHealthTestResponse(); + s.setMessageCode("Unable to determine health: " + e); + s.setStatus(HealthTestStatus.RED); + } + i.setHealthTestStatus(s.getStatus()); + i.setHealthTestMessageCode(s.getMessageCode()); + MetricStore store = controller.getServer().metrics.getStore(i); + Date now = new Date(); + String path = "/lastHealthTest"; + store.addLongValue(path, now, now.getTime(), "DateMetricAttribute", false); + } + } + + public void start() { + + Thread t = new Thread("docker service: " + o.getName()) { + @Override + public void run() { + while (true) { + try { + if (!controller.getServer().isSlave) { + updateDeploymentStatus(); + } + Thread.sleep(60000); // sleep 60 seconds + } catch (Exception e) { + ManagementServerUtils.printStackTrace(e); + logger.fatal("vm service: " + o.getName() + " : " + e); + try { + Thread.sleep(30000); + } catch (InterruptedException e1) { + } + } + } + } + + }; + t.start(); + } + + public void updateDeploymentStatus() { + for (DockerServiceInstance instance : o.getInstances()) { + instance.setDockerName(dockerName(instance)); + DockerContainer c = findContainer(instance); + if (c != null) { + if (c.getStatus() != null && c.getStatus().startsWith("Up")) { + instance.setStatus(DeploymentStatus.DEPLOYED); + } else { + instance.setStatus(DeploymentStatus.DEPLOYED_PARTIALLY); + } + } else { + instance.setStatus(DeploymentStatus.UNDEPLOYED); + } + } + } + + private DockerContainer findContainer(DockerServiceInstance instance) { + if (instance.getHostService() == null) { + return null; + } + for (DockerContainer c : instance.getHostService().getDockerHost().getContainers()) { + if (instance.getDockerName() != null && instance.getDockerName().equals(c.getName())) { + return c; + } + } + return null; + } + + protected EObject convertToManagerConfiguration(DockerServiceInstance i) { + // TODO Auto-generated method stub + return null; + } } |