本文整理汇总了Java中org.openbaton.catalogue.nfvo.Action类的典型用法代码示例。如果您正苦于以下问题:Java Action类的具体用法?Java Action怎么用?Java Action使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
Action类属于org.openbaton.catalogue.nfvo包,在下文中一共展示了Action类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: setStatus
import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
/**
* Handles the callback by the NFVO when the deploy is finished (or failed)
*
* @param evt OpenbatonEvent, payload of the POST
* @param id occi Identifier of the stack, set in deployAndProvision
* @throws SDKException
*/
@RequestMapping(value = "{id}", method = RequestMethod.POST, consumes = MediaType.APPLICATION_JSON_VALUE)
@ResponseStatus(HttpStatus.OK)
public void setStatus(@RequestBody OpenbatonEvent evt, @PathVariable("id") String id) throws SDKException {
Stack stack = stacks.get(id);
log.debug("Received event for nsr " + stack.getNsrId() + " with occiId " + id);
if (evt.getAction().equals(Action.INSTANTIATE_FINISH)) {
log.debug("Instantiate finished");
stack.setVirtualNFRs(obManager.statusOfNSR(stack.getNsrId()));
stack.setStatus("CREATE_COMPLETE");
} else if (evt.getAction().equals(Action.ERROR)) {
log.debug("Error on instantiate");
stack.setStatus("CREATE_FAILED");
}
log.debug("Deleting listening-events");
nfvoRequestor.getEventAgent().delete(stack.getReceivedEndpointCreation().getId());
nfvoRequestor.getEventAgent().delete(stack.getReceivedEndpointError().getId());
}
开发者ID:MobileCloudNetworking,项目名称:OpenBaton-OCCI,代码行数:27,代码来源:OcciControler.java
示例2: activate
import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
/**
* Activates autoscaling for the passed NSR
*
* @param msg : NSR in payload to add for autoscaling
*/
@RequestMapping(
value = "INSTANTIATE_FINISH",
method = RequestMethod.POST,
consumes = MediaType.APPLICATION_JSON_VALUE,
produces = MediaType.APPLICATION_JSON_VALUE
)
@ResponseStatus(HttpStatus.CREATED)
public void activate(@RequestBody String msg)
throws NotFoundException, VimException, SDKException {
log.trace("msg=" + msg);
JsonParser jsonParser = new JsonParser();
JsonObject json = jsonParser.parse(msg).getAsJsonObject();
Gson mapper = new GsonBuilder().create();
Action action = mapper.fromJson(json.get("action"), Action.class);
log.trace("ACTION=" + action);
NetworkServiceRecord nsr = mapper.fromJson(json.get("payload"), NetworkServiceRecord.class);
log.trace("NSR=" + nsr);
elasticityManagement.activate(nsr.getProjectId(), nsr.getId());
}
开发者ID:openbaton,项目名称:autoscaling-engine,代码行数:25,代码来源:RestElasticityManagementInterface.java
示例3: deactivate
import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
/**
* Deactivates autoscaling for the passed NSR
*
* @param msg : NSR in payload to add for autoscaling
*/
@RequestMapping(
value = "RELEASE_RESOURCES_FINISH",
method = RequestMethod.POST,
consumes = MediaType.APPLICATION_JSON_VALUE,
produces = MediaType.APPLICATION_JSON_VALUE
)
@ResponseStatus(HttpStatus.CREATED)
public void deactivate(@RequestBody String msg) throws NotFoundException {
log.trace("msg=" + msg);
JsonParser jsonParser = new JsonParser();
JsonObject json = jsonParser.parse(msg).getAsJsonObject();
Gson mapper = new GsonBuilder().create();
Action action = mapper.fromJson(json.get("action"), Action.class);
log.trace("ACTION=" + action);
NetworkServiceRecord nsr = mapper.fromJson(json.get("payload"), NetworkServiceRecord.class);
log.trace("NSR=" + nsr);
for (VirtualNetworkFunctionRecord vnfr : nsr.getVnfr()) {
elasticityManagement.deactivate(nsr.getProjectId(), nsr.getId(), vnfr);
}
}
开发者ID:openbaton,项目名称:autoscaling-engine,代码行数:26,代码来源:RestElasticityManagementInterface.java
示例4: stop
import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
/**
* Stops autoscaling for the passed NSR
*
* @param msg : NSR in payload to add for autoscaling
*/
@RequestMapping(
value = "ERROR",
method = RequestMethod.POST,
consumes = MediaType.APPLICATION_JSON_VALUE,
produces = MediaType.APPLICATION_JSON_VALUE
)
@ResponseStatus(HttpStatus.CREATED)
public void stop(@RequestBody String msg) throws NotFoundException {
log.trace("msg=" + msg);
JsonParser jsonParser = new JsonParser();
JsonObject json = jsonParser.parse(msg).getAsJsonObject();
Gson mapper = new GsonBuilder().create();
Action action = mapper.fromJson(json.get("action"), Action.class);
log.trace("ACTION=" + action);
// try {
// NetworkServiceRecord nsr = mapper.fromJson(json.get("payload"), NetworkServiceRecord.class);
// log.debug("NSR=" + nsr);
// elasticityManagement.deactivate(nsr);
// } catch (NullPointerException e) {
// VirtualNetworkFunctionRecord vnfr = mapper.fromJson(json.get("payload"), VirtualNetworkFunctionRecord.class);
// log.debug("vnfr=" + vnfr);
// elasticityManagement.deactivate(vnfr);
// }
}
开发者ID:openbaton,项目名称:autoscaling-engine,代码行数:30,代码来源:RestElasticityManagementInterface.java
示例5: stop
import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
/**
* Stops autoscaling for the passed NSR
*
* @param msg : NSR in payload to add for autoscaling
*/
@RequestMapping(
value = "ERROR",
method = RequestMethod.POST,
consumes = MediaType.APPLICATION_JSON_VALUE,
produces = MediaType.APPLICATION_JSON_VALUE
)
@ResponseStatus(HttpStatus.CREATED)
public void stop(@RequestBody String msg) throws NotFoundException {
log.debug("========================");
log.debug("msg=" + msg);
JsonParser jsonParser = new JsonParser();
JsonObject json = jsonParser.parse(msg).getAsJsonObject();
Gson mapper = new GsonBuilder().create();
Action action = mapper.fromJson(json.get("action"), Action.class);
log.debug("ACTION=" + action);
// try {
// NetworkServiceRecord nsr = mapper.fromJson(json.get("payload"), NetworkServiceRecord.class);
// log.debug("NSR=" + nsr);
// elasticityManagement.deactivate(nsr);
// } catch (NullPointerException e) {
// VirtualNetworkFunctionRecord vnfr = mapper.fromJson(json.get("payload"), VirtualNetworkFunctionRecord.class);
// log.debug("vnfr=" + vnfr);
// elasticityManagement.deactivate(vnfr);
// }
}
开发者ID:openbaton,项目名称:autoscaling-engine,代码行数:31,代码来源:RestDetectionInterface.java
示例6: OrVnfmInstantiateMessage
import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
public OrVnfmInstantiateMessage(
VirtualNetworkFunctionDescriptor vnfd,
VNFDeploymentFlavour vnfdf,
String vnfInstanceName,
Set<VirtualLinkRecord> vlrs,
Map<String, String> extension,
Map<String, Collection<BaseVimInstance>> vimInstances,
Set<Key> keys,
VNFPackage vnfPackage) {
this.vnfd = vnfd;
this.keys = keys;
this.vnfdf = vnfdf;
this.vnfInstanceName = vnfInstanceName;
this.vlrs = vlrs;
this.extension = extension;
this.vimInstances = vimInstances;
this.action = Action.INSTANTIATE;
this.vnfPackage = vnfPackage;
}
开发者ID:openbaton,项目名称:NFVO,代码行数:20,代码来源:OrVnfmInstantiateMessage.java
示例7: sendStart
import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
private void sendStart(VirtualNetworkFunctionRecord virtualNetworkFunctionRecord)
throws NotFoundException, BadFormatException, ExecutionException, InterruptedException {
VnfmSender vnfmSender;
vnfmSender =
this.getVnfmSender(
vnfmRegister.getVnfm(virtualNetworkFunctionRecord.getEndpoint()).getEndpointType());
log.info(
"Calling START to: "
+ virtualNetworkFunctionRecord.getName()
+ " because it has 0 dependencies");
log.trace(
"VNFR ("
+ virtualNetworkFunctionRecord.getId()
+ ") hibernate version is = "
+ virtualNetworkFunctionRecord.getHbVersion());
/*vnfmSender.sendCommand(
new OrVnfmGenericMessage(virtualNetworkFunctionRecord, Action.START),
vnfmRegister.getVnfm(virtualNetworkFunctionRecord.getEndpoint()));*/
vnfStateHandler.executeAction(
vnfmSender.sendCommand(
new OrVnfmStartStopMessage(virtualNetworkFunctionRecord, null, Action.START),
vnfmRegister.getVnfm(virtualNetworkFunctionRecord.getEndpoint())));
}
开发者ID:openbaton,项目名称:NFVO,代码行数:24,代码来源:InstantiateTask.java
示例8: OrVnfmInstantiateMessage
import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
public OrVnfmInstantiateMessage(
VirtualNetworkFunctionDescriptor vnfd,
VNFDeploymentFlavour vnfdf,
String vnfInstanceName,
Set<VirtualLinkRecord> vlrs,
Map<String, String> extension,
Map<String, Collection<VimInstance>> vimInstances,
Set<Key> keys,
VNFPackage vnfPackage) {
this.vnfd = vnfd;
this.keys = keys;
this.vnfdf = vnfdf;
this.vnfInstanceName = vnfInstanceName;
this.vlrs = vlrs;
this.extension = extension;
this.vimInstances = vimInstances;
this.action = Action.INSTANTIATE;
this.vnfPackage = vnfPackage;
}
开发者ID:openbaton,项目名称:openbaton-libs,代码行数:20,代码来源:OrVnfmInstantiateMessage.java
示例9: configureSubTask
import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
@Override
public void configureSubTask(Profile.Section currentSection) {
this.setTimeout(Integer.parseInt(currentSection.get("timeout", "5")));
String action = currentSection.get("action");
if (action == null) {
try {
throw new IntegrationTestException("action for NetworkServiceRecordWait not set");
} catch (IntegrationTestException e) {
e.printStackTrace();
log.error(e.getMessage());
System.exit(42);
}
}
this.setAction(Action.valueOf(action));
}
开发者ID:openbaton,项目名称:integration-tests,代码行数:17,代码来源:NetworkServiceRecordWait.java
示例10: grantLifecycleOperation
import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
private OrVnfmGrantLifecycleOperationMessage grantLifecycleOperation() throws VnfmSdkException {
NFVMessage response;
try {
response =
vnfmHelper.sendAndReceive(
VnfmUtils.getNfvMessage(Action.GRANT_OPERATION, virtualNetworkFunctionRecord));
} catch (Exception e) {
throw new VnfmSdkException("Not able to grant operation", e, virtualNetworkFunctionRecord);
}
if (response != null) {
if (response.getAction().ordinal() == Action.ERROR.ordinal()) {
throw new VnfmSdkException(
"Not able to grant operation because: "
+ ((OrVnfmErrorMessage) response).getMessage(),
((OrVnfmErrorMessage) response).getVnfr());
}
OrVnfmGrantLifecycleOperationMessage orVnfmGrantLifecycleOperationMessage =
(OrVnfmGrantLifecycleOperationMessage) response;
return orVnfmGrantLifecycleOperationMessage;
}
return null;
}
开发者ID:openbaton,项目名称:openbaton-libs,代码行数:24,代码来源:AbstractVnfm.java
示例11: scale
import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
@Override
public VirtualNetworkFunctionRecord scale(
Action scaleInOrOut,
VirtualNetworkFunctionRecord virtualNetworkFunctionRecord,
VNFComponent component,
Object scripts,
VNFRecordDependency dependency)
throws Exception {
log.info(
scaleInOrOut.name()
+ " on VNFR "
+ virtualNetworkFunctionRecord.getName()
+ " with id "
+ virtualNetworkFunctionRecord.getId());
Thread.sleep((int) (Math.random() * 500) + 1000);
return virtualNetworkFunctionRecord;
}
开发者ID:openbaton,项目名称:dummy-vnfm-amqp,代码行数:18,代码来源:DummyAMQPVNFManager.java
示例12: subscribe
import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
private String subscribe(Action action) throws SDKException, FileNotFoundException {
log.debug("Subscribing to all NSR Events with Action " + action);
EventEndpoint eventEndpoint = new EventEndpoint();
eventEndpoint.setName("Subscription:" + action);
eventEndpoint.setEndpoint(
"http://"
+ autoScalingProperties.getServer().getIp()
+ ":"
+ autoScalingProperties.getServer().getPort()
+ "/elasticity-management/"
+ action);
eventEndpoint.setEvent(action);
eventEndpoint.setType(EndpointType.REST);
return nfvoRequestor.getEventAgent().create(eventEndpoint).getId();
}
开发者ID:openbaton,项目名称:autoscaling-engine,代码行数:16,代码来源:Application.java
示例13: OrVnfmStartStopMessage
import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
public OrVnfmStartStopMessage(
VirtualNetworkFunctionRecord virtualNetworkFunctionRecord,
VNFCInstance vnfcInstance,
Action action) {
this.virtualNetworkFunctionRecord = virtualNetworkFunctionRecord;
this.vnfcInstance = vnfcInstance;
this.action = action;
}
开发者ID:openbaton,项目名称:NFVO,代码行数:9,代码来源:OrVnfmStartStopMessage.java
示例14: toString
import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
@Override
public String toString() {
return "OrVnfmErrorMessage{"
+ "action='"
+ Action.ERROR
+ '\''
+ "message='"
+ message
+ '\''
+ ", vnfr="
+ vnfr
+ '}';
}
开发者ID:openbaton,项目名称:NFVO,代码行数:14,代码来源:OrVnfmErrorMessage.java
示例15: VnfmOrStartStopMessage
import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
public VnfmOrStartStopMessage(
VirtualNetworkFunctionRecord virtualNetworkFunctionRecord,
VNFCInstance vnfcInstance,
Action action) {
this.virtualNetworkFunctionRecord = virtualNetworkFunctionRecord;
this.vnfcInstance = vnfcInstance;
this.action = action;
}
开发者ID:openbaton,项目名称:NFVO,代码行数:9,代码来源:VnfmOrStartStopMessage.java
示例16: VnfmOrGrantLifecycleOperationMessage
import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
public VnfmOrGrantLifecycleOperationMessage(
VirtualNetworkFunctionDescriptor virtualNetworkFunctionDescriptor,
Set<VirtualDeploymentUnit> vduSet,
String deploymentFlavourKey) {
this.virtualNetworkFunctionDescriptor = virtualNetworkFunctionDescriptor;
this.vduSet = vduSet;
this.deploymentFlavourKey = deploymentFlavourKey;
this.action = Action.ALLOCATE_RESOURCES;
}
开发者ID:openbaton,项目名称:NFVO,代码行数:10,代码来源:VnfmOrGrantLifecycleOperationMessage.java
示例17: checkRequest
import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
private boolean checkRequest(String message) {
JsonElement jsonElement = mapper.fromJson(message, JsonElement.class);
String actionReceived = jsonElement.getAsJsonObject().get("action").getAsString();
//log.debug("Action received: " + actionReceived);
action = Action.valueOf(actionReceived);
payload = jsonElement.getAsJsonObject().get("payload").toString();
//log.debug("Payload received: "+payload);
if (actionReceived.equals(ee.getEvent().toString())) return true;
else log.error("Received wrong action: " + actionReceived);
return false;
}
开发者ID:openbaton,项目名称:integration-tests,代码行数:13,代码来源:RestWaiter.java
示例18: getAvailableEvents
import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
@RequestMapping(
value = "/actions",
method = RequestMethod.GET,
produces = MediaType.APPLICATION_JSON_VALUE
)
public Action[] getAvailableEvents() {
return Action.values();
}
开发者ID:openbaton,项目名称:NFVO,代码行数:9,代码来源:RestEvent.java
示例19: sendStart
import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
private void sendStart(VirtualNetworkFunctionRecord virtualNetworkFunctionRecord)
throws NotFoundException, BadFormatException, ExecutionException, InterruptedException {
VnfmSender vnfmSender;
vnfmSender =
this.getVnfmSender(
vnfmRegister.getVnfm(virtualNetworkFunctionRecord.getEndpoint()).getEndpointType());
/*vnfmSender.sendCommand(
new OrVnfmGenericMessage(virtualNetworkFunctionRecord, Action.START),
vnfmRegister.getVnfm(virtualNetworkFunctionRecord.getEndpoint()));*/
vnfStateHandler.executeAction(
vnfmSender.sendCommand(
new OrVnfmStartStopMessage(virtualNetworkFunctionRecord, null, Action.START),
vnfmRegister.getVnfm(virtualNetworkFunctionRecord.getEndpoint())));
}
开发者ID:openbaton,项目名称:NFVO,代码行数:15,代码来源:StartTask.java
示例20: sendStart
import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
private void sendStart(VirtualNetworkFunctionRecord virtualNetworkFunctionRecord)
throws NotFoundException, BadFormatException, ExecutionException, InterruptedException {
VnfmSender vnfmSender;
log.info("Calling START to: " + virtualNetworkFunctionRecord.getName() + " after MODIFY");
vnfmSender =
this.getVnfmSender(
vnfmRegister.getVnfm(virtualNetworkFunctionRecord.getEndpoint()).getEndpointType());
/*vnfmSender.sendCommand(
new OrVnfmGenericMessage(virtualNetworkFunctionRecord, Action.START),
vnfmRegister.getVnfm(virtualNetworkFunctionRecord.getEndpoint()));*/
vnfStateHandler.executeAction(
vnfmSender.sendCommand(
new OrVnfmStartStopMessage(virtualNetworkFunctionRecord, null, Action.START),
vnfmRegister.getVnfm(virtualNetworkFunctionRecord.getEndpoint())));
}
开发者ID:openbaton,项目名称:NFVO,代码行数:16,代码来源:ModifyTask.java
注:本文中的org.openbaton.catalogue.nfvo.Action类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论