Package org.openstack.client.common

Examples of org.openstack.client.common.OpenstackComputeClient.root()

160
161
162
163
164
165
166
167
168
169
170
            waitOperation(terminateOperation);
          }

          try {
            log.info("Deleting security group: " + securityGroup.getId());
            computeClient.root().securityGroups().securityGroup(securityGroup.getId()).delete();
          } catch (OpenstackNotFoundException e) {
            log.info("Ignoring not-found error while deleting security group: " + securityGroup.getId());
          }
        }
      }
View Full Code Here
163
164
165
166
167
168
169
170
171
172
173
  public Server findServerById(OpenstackCloud cloud, String serverId) throws OpsException {
    OpenstackComputeClient computeClient = getComputeClient(cloud);

    try {
      log.info("Getting server info for: " + serverId);
      Server server = computeClient.root().servers().server(serverId).show();
      return server;
    } catch (OpenstackNotFoundException e) {
      return null;
    } catch (OpenstackException e) {
      throw new OpsException("Error getting server", e);
View Full Code Here
252
253
254
255
256
257
258
259
260
261
262
        if (recipe != null) {
          operatingSystem = recipe.getOperatingSystem();
        }

        log.info("Listing images to pick best image");
        Iterable<Image> images = computeClient.root().images().list();
        if (cloudBehaviours.isHpCloud()) {
          // TODO: We need a better solution here!!
          Set<String> imageNames = Sets.newHashSet("Debian Squeeze 6.0.3 Server 64-bit 20120123");
          log.warn("Hard coding image name (presuming HP cloud)");
View Full Code Here
376
377
378
379
380
381
382
383
384
385
386
        List<ImageFormat> formats = Collections.singletonList(ImageFormat.DiskQcow2);
        CloudImage image = imageFactory.getOrCreateImageId(cloud, formats, request.recipeId);

        String imageId = image.getId();
        log.info("Getting image details for image: " + imageId);
        foundImage = computeClient.root().images().image(imageId).show();
        if (foundImage == null) {
          throw new IllegalArgumentException("Could not find image: " + imageId);
        }
      }
View Full Code Here
389
390
391
392
393
394
395
396
397
398
399
        SecurityGroup createTemplate = new SecurityGroup();
        createTemplate.setName(SECURITY_GROUP_PREFIX + serverName);
        createTemplate.setDescription("Security group for instance: " + serverName);
        try {
          log.info("Creating security group: " + createTemplate.getName());
          createdSecurityGroup = computeClient.root().securityGroups().create(createTemplate);
        } catch (OpenstackException e) {
          for (SecurityGroup candidate : computeClient.root().securityGroups().list()) {
            if (Objects.equal(candidate.getName(), createTemplate.getName())) {
              createdSecurityGroup = candidate;
              break;
View Full Code Here
391
392
393
394
395
396
397
398
399
400
401
        createTemplate.setDescription("Security group for instance: " + serverName);
        try {
          log.info("Creating security group: " + createTemplate.getName());
          createdSecurityGroup = computeClient.root().securityGroups().create(createTemplate);
        } catch (OpenstackException e) {
          for (SecurityGroup candidate : computeClient.root().securityGroups().list()) {
            if (Objects.equal(candidate.getName(), createTemplate.getName())) {
              createdSecurityGroup = candidate;
              break;
            }
          }
View Full Code Here
415
416
417
418
419
420
421
422
423
424
425
          newRule.setIpProtocol("tcp");
          newRule.setParentGroupId(createdSecurityGroup.getId());

          try {
            log.info("Creating security group rule for port: " + newRule.getToPort());
            SecurityGroupRule createdRule = computeClient.root().securityGroupRules().create(newRule);
          } catch (OpenstackException e) {
            String message = e.getMessage();
            if (message != null && message.contains("This rule already exists")) {
              log.warn("Ignoring 'rule already exists': " + e.getMessage());
            } else {
View Full Code Here
517
518
519
520
521
522
523
524
525
526
527
          metadata.getItems().add(meta);
        }

        newServerInfo.setMetadata(metadata);
        log.info("Tagging server: " + server.getId());
        computeClient.root().servers().server(server.getId()).update(newServerInfo);
      }

      return server;
    } catch (InterruptedException e) {
      ExceptionUtils.handleInterrupted(e);
View Full Code Here
750
751
752
753
754
755
756
757
758
759
760
    }

    final OpenstackComputeClient compute = getComputeClient(cloud);

    log.info("Creating floating IP");
    FloatingIp floatingIp = compute.root().floatingIps().create();

    // TODO: Don't abandon the IP e.g. if the attach fails
    log.info("Attching floating IP " + floatingIp.getIp() + " to " + server.getId());
    compute.root().servers().server(server.getId()).addFloatingIp(floatingIp.getIp());
View Full Code Here
754
755
756
757
758
759
760
761
762
763
764
    log.info("Creating floating IP");
    FloatingIp floatingIp = compute.root().floatingIps().create();

    // TODO: Don't abandon the IP e.g. if the attach fails
    log.info("Attching floating IP " + floatingIp.getIp() + " to " + server.getId());
    compute.root().servers().server(server.getId()).addFloatingIp(floatingIp.getIp());

    final String serverId = server.getId();

    try {
      server = TimeoutPoll.poll(TimeSpan.FIVE_MINUTES, TimeSpan.TEN_SECONDS, new PollFunction<Server>() {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.