import org.jclouds.domain.LocationBuilder; //导入依赖的package包/类
@Override
public NodeMetadata apply(Instance input) {
   NodeMetadataBuilder builder = new NodeMetadataBuilder();
   builder.id(api.encodeToId(input.getRegionId(), input.getInstanceId()));
   builder.providerId(input.getInstanceId());
   builder.name(input.getInstanceName());
   builder.group(input.getRegionId());
   builder.status(status.get(input.getStatus()));
   builder.imageId(input.getImageId());
   Hardware hardware = new HardwareBuilder()
         .id(input.getInstanceType())
         .build();
   builder.hardware(hardware);
   Location location = new LocationBuilder()
         .scope(LocationScope.REGION)
         .id(input.getRegionId())
         .description(input.getRegionId())
         .build();
   builder.location(location);
   builder.publicAddresses(input.getPublicIpAddress());
   builder.privateAddresses(input.getInnerIpAddress());
   return builder.build();
}
 

import org.jclouds.domain.LocationBuilder; //导入依赖的package包/类
@Override
public LoadBalancerMetadata getLoadBalancer(String id) {
   IAcsClient client = api.getAcsClient(SLBApi.DEFAULT_REGION);
   DescribeLoadBalancerAttributeRequest req = new DescribeLoadBalancerAttributeRequest();
   req.setLoadBalancerId(id);
   LoadBalancerMetadata lbm = null;
   try {
      DescribeLoadBalancerAttributeResponse resp = client.getAcsResponse(req);
      LocationBuilder location = new LocationBuilder()
            .scope(LocationScope.REGION)
            .id(resp.getRegionId())
            .description(resp.getRegionId());
      lbm = new LoadBalancerMetadataImpl(
            loadBalancerTypes.get(resp.getAddressType()),
            resp.getLoadBalancerId(),
            resp.getLoadBalancerName(),
            resp.getLoadBalancerId(),
            location.build(),
            null,
            ImmutableMap.<String, String>builder().build(),
            ImmutableSet.<String> builder().add(resp.getAddress()).build());
   } catch (Exception e) {
      logger.warn(e.getMessage());
   }
   return lbm;
}
 

import org.jclouds.domain.LocationBuilder; //导入依赖的package包/类
@Override
public LoadBalancerMetadata apply(LoadBalancer input) {
   DescribeLoadBalancerAttributeRequest req = new DescribeLoadBalancerAttributeRequest();
   req.setLoadBalancerId(input.getLoadBalancerId());
   DescribeLoadBalancerAttributeResponse resp = null;
   try {
      resp = client.getAcsResponse(req);
   } catch (Exception e) {
      logger.warn(e.getMessage());
   }
   LocationBuilder location = new LocationBuilder()
         .scope(LocationScope.REGION)
         .id(resp.getRegionId())
         .description(resp.getRegionId());
   return new LoadBalancerMetadataImpl(
         loadBalancerTypes.get(resp.getAddressType()),
         input.getLoadBalancerId(),
         input.getLoadBalancerName(),
         input.getLoadBalancerId(),
         location.build(),
         null,
         ImmutableMap.<String, String>builder().build(),
         ImmutableSet.<String> builder().add(resp.getAddress()).build());
}
 

import org.jclouds.domain.LocationBuilder; //导入依赖的package包/类
@BeforeClass
public void beforeClass() {
   LocationBuilder location = new LocationBuilder()
         .scope(LocationScope.REGION)
         .id(testRegion)
         .description(testRegion);
   Set<NodeMetadata> nodes = ImmutableSet.<NodeMetadata> builder()
         .add(new NodeMetadataBuilder()
               .status(Status.RUNNING)
               .id("cn-hangzhou:i-233ehfkdv")
               .build())
         .build();
   lbm = loadBalancerService
         .createLoadBalancerInLocation(
               location.build(),
               testLoadBalancer,
               "http", 80, 80, nodes);
}
 

import org.jclouds.domain.LocationBuilder; //导入依赖的package包/类
@Before
public void setUp(){
    indexShardRepository = mock(BlobStoreIndexShardRepository.class);
    cloudFilesService = mock(CloudFilesService.class);

    RegionScopedBlobStoreContext blobStoreContext = mock(RegionScopedBlobStoreContext.class);

    BlobStore blobStore = mock(BlobStore.class);
    Set<Location> locations = new HashSet<Location>();
    Set<String> isoCodes = new HashSet<String>();
    isoCodes.add("US-IL");
    locations.add(new LocationBuilder().id("ORD").description("ORD").scope(LocationScope.REGION).iso3166Codes(isoCodes).build());
    when(blobStore.listAssignableLocations()).thenReturn((Set) locations);

    when(blobStoreContext.getBlobStore(anyString())).thenReturn(blobStore);

    when(cloudFilesService.context()).thenReturn(blobStoreContext);
}
 

import org.jclouds.domain.LocationBuilder; //导入依赖的package包/类
@Override
public PageSet<? extends StorageMetadata> list() {
   OSS oss = api.getOSSClient(OSSApi.DEFAULT_REGION);
   PageSetImpl<StorageMetadata> pageSet = new PageSetImpl<StorageMetadata>(
         transform(oss.listBuckets(), new Function<Bucket, StorageMetadata>() {
               @Override
               public StorageMetadata apply(Bucket input) {
                  String bucketLocation = input.getLocation();
                  Location location = new LocationBuilder()
                        .id(bucketLocation)
                        .scope(LocationScope.REGION)
                        .description(bucketLocation)
                        .build();
                  StorageMetadata storageMetadata = new StorageMetadataImpl(
                        StorageType.CONTAINER,
                        input.getName(),
                        input.getName(),
                        location,
                        null,
                        null,
                        input.getCreationDate(),
                        input.getCreationDate(),
                        ImmutableMap.<String, String>builder().build(),
                        0L);
                  return storageMetadata;
               }
            }), null);
   return pageSet;
}
 

import org.jclouds.domain.LocationBuilder; //导入依赖的package包/类
@Override
public Location apply(String input) {
   LocationBuilder builder = new LocationBuilder();
   builder.scope(LocationScope.REGION);
   builder.id(input);
   builder.description(input);
   return builder.build();
}
 

import org.jclouds.domain.LocationBuilder; //导入依赖的package包/类
@BeforeClass
public void beforeClass() {
   LocationBuilder location = new LocationBuilder()
         .scope(LocationScope.REGION)
         .id(testRegion)
         .description(testRegion);
   blobStore.createContainerInLocation(
         location.build(), testBucket);
}
 

import org.jclouds.domain.LocationBuilder; //导入依赖的package包/类
@Test
public void createContainerInLocation() {
   LocationBuilder location = new LocationBuilder()
         .scope(LocationScope.REGION)
         .id(testRegion)
         .description(testRegion);
   blobStore.createContainerInLocation(location.build(), "bucket-to-delete", CreateContainerOptions.NONE);
   blobStore.createDirectory("bucket-to-delete", "test-directory");
   blobStore.clearContainer("bucket-to-delete");
   blobStore.deleteContainerIfEmpty("bucket-to-delete");
}
 

import org.jclouds.domain.LocationBuilder; //导入依赖的package包/类
@Override
public Location apply(final Datacenter datacenter) {
    return new LocationBuilder()
            .id(datacenter.id())
            .description(datacenter.displayName())
            .parent(getOnlyElement(justProvider.get()))
            .scope(LocationScope.ZONE)
            .iso3166Codes(ImmutableSet.of(datacenter.country()))
            .metadata(ImmutableMap.<String, Object>of("name", datacenter.displayName()))
            .build();
}
 

import org.jclouds.domain.LocationBuilder; //导入依赖的package包/类
private static Location createRegionLocation( BlobStoreProperties config, Location provider )
{
    return config.location != null ?
        new LocationBuilder()
            .scope( LocationScope.REGION )
            .id( config.location )
            .description( config.location )
            .parent( provider )
            .build() : null;
}
 

import org.jclouds.domain.LocationBuilder; //导入依赖的package包/类
private NodeMetadata getRunningNodeMetaDataAtLocation(LocationScope scope, String id) {
    Location location = new LocationBuilder()
            .scope(scope)
            .id(id)
            .description("desc")
            .build();
    return new NodeMetadataBuilder()
            .location(location)
            .id(newSecureUuidString())
            .status(NodeMetadata.Status.RUNNING)
            .build();
}
 

import org.jclouds.domain.LocationBuilder; //导入依赖的package包/类
@Inject
protected CloudFilesRepository(String repositoryName, RepositorySettings repositorySettings, IndexShardRepository indexShardRepository, CloudFilesService cloudFilesService) {
    super(repositoryName, repositorySettings, indexShardRepository);

    final String container = repositorySettings.settings().get("container", componentSettings.get("container"));
    if(container == null || container.equals("")){
        throw new RepositoryException(repositoryName, "No container defined for cloud files gateway.");
    }

    final String dataCenter = repositorySettings.settings().get("region", componentSettings.get("region", "ORD"));
    final int concurrentStreams = repositorySettings.settings().getAsInt("concurrent_streams", componentSettings.getAsInt("concurrent_streams", 5));
    ExecutorService concurrentStreamPool = EsExecutors.newScaling(1, concurrentStreams, 5, TimeUnit.SECONDS, EsExecutors.daemonThreadFactory(settings, "[cloudfiles_stream]"));
    final Location location = new LocationBuilder()
            .scope(LocationScope.REGION)
            .id(dataCenter)
            .description(String.format("Rackspace's %s datacenter.", dataCenter))
            .build();

    blobStore = new CloudFilesBlobStore(settings, cloudFilesService.context(), container, location, concurrentStreamPool);
    this.chunkSize = repositorySettings.settings().getAsBytesSize("chunk_size", componentSettings.getAsBytesSize("chunk_size", new ByteSizeValue(100, ByteSizeUnit.MB)));
    this.compress = repositorySettings.settings().getAsBoolean("compress", componentSettings.getAsBoolean("compress", false));
    logger.debug("using container [{}], data center [{}], chunk_size [{}], concurrent_streams [{}]", container, dataCenter, chunkSize, concurrentStreams);
    String basePath = repositorySettings.settings().get("base_path", null);
    if (Strings.hasLength(basePath)) {
        BlobPath path = new BlobPath();
        for(String elem : Strings.splitStringToArray(basePath, '/')) {
            path = path.add(elem);
        }
        this.basePath = path;
    } else {
        this.basePath = BlobPath.cleanPath();
    }
}
 

import org.jclouds.domain.LocationBuilder; //导入依赖的package包/类
public synchronized Location location(){
    if(location != null){
        return location;
    }

    final String dataCenter = componentSettings.get("region", "ORD");

    location = new LocationBuilder().scope(LocationScope.REGION).id(dataCenter).description("A Rackspace data center.").build();

    return location;
}
 

import org.jclouds.domain.LocationBuilder; //导入依赖的package包/类
@Before
public void setUp() throws IOException {
    settings = SettingsLoader.getSettingsFromResource("/elasticsearch.yml");

    String account = settings.get("rackspace.account");
    String key = settings.get("rackspace.key");
    blobStoreContext = ContextBuilder.newBuilder("rackspace-cloudfiles-us").credentials(account, key)
            .buildView(RegionScopedBlobStoreContext.class);
    location = new LocationBuilder().scope(LocationScope.REGION).id("ORD").description("ORD").build();
}
 

import org.jclouds.domain.LocationBuilder; //导入依赖的package包/类
@Override
public AssignableLocation apply(AvailabilityZone availabilityZone) {
  //todo: do we need to check the zone state?
  return new AssignableLocationImpl(new LocationBuilder().scope(LocationScope.ZONE)
      .id(RegionAndId.fromRegionAndId(region.getId(), availabilityZone.getName())
          .slashEncode()).parent(region).description(availabilityZone.getName())
      .build(), true);
}
 

import org.jclouds.domain.LocationBuilder; //导入依赖的package包/类
private void createContainer() throws IOException {
   // Ensure that the container exists
   Location location = new LocationBuilder().scope(LocationScope.REGION).id(REGION).description("region").build();
   if (!blobStore.containerExists(CONTAINER)) {
         blobStore.createContainerInLocation(location, CONTAINER);
      System.out.format("Created container in %s%n", REGION);
   }
}
 

import org.jclouds.domain.LocationBuilder; //导入依赖的package包/类
@Test
public void testJCloudsMetadataTest() throws IOException {
   String blobName = "myBlob";
   String containerName = (csBucket + "MetadataTest").toLowerCase();
   BlobStore blobStore = ((CloudStore) cl).getBlobStore();
      
   if (!blobStore.containerExists(containerName)) {
      Location location = new LocationBuilder().scope(LocationScope.REGION).description("test").id(csLocation).build();
      blobStore.createContainerInLocation(location, containerName);
      TestingUtil.sleepThread(10000);
   }

   String payload = "Hello world";
   Blob blob = blobStore.blobBuilder(blobName)
         .payload(payload)
         .contentLength(payload.length())
         .contentType(MediaType.OCTET_STREAM)
         .userMetadata(Collections.singletonMap("hello", "world"))
         .build();
   blobStore.putBlob(containerName, blob);

   blob = blobStore.getBlob(containerName, blobName);
   assertEquals(blob.getMetadata().getUserMetadata().get("hello"), "world");

   PageSet<? extends StorageMetadata> ps = blobStore.list(containerName, ListContainerOptions.Builder.withDetails());
   for (StorageMetadata sm : ps) {
      assertEquals(sm.getUserMetadata().get("hello"), "world");
   }
   
   blobStore.deleteContainer(containerName);
}
 

import org.jclouds.domain.LocationBuilder; //导入依赖的package包/类
@Override
public BlobMetadata blobMetadata(String container, String name) {
   OSS oss = api.getOSSClient(OSSApi.DEFAULT_REGION);
   String region = oss.getBucketLocation(container);
   oss = api.getOSSClient(region);
   OSSObject object = oss.getObject(container, name);
   Calendar time = Calendar.getInstance();
   time.set(Calendar.HOUR, time.get(Calendar.HOUR) + 1);
   Date expires = time.getTime();
   URL url = oss.generatePresignedUrl(container, name, expires);
   URI uri = null;
   try {
      uri = url.toURI();
   } catch (URISyntaxException e) {
      logger.warn(e, e.getMessage());
   }
   Location location = new LocationBuilder()
         .id(region)
         .scope(LocationScope.REGION)
         .description(region)
         .build();
   ContentMetadata cm = ContentMetadataBuilder.create()
         .expires(expires)
         .contentDisposition(object.getObjectMetadata().getContentDisposition())
         .contentEncoding(object.getObjectMetadata().getContentEncoding())
         .contentLength(object.getObjectMetadata().getContentLength())
         .contentType(object.getObjectMetadata().getContentType())
         .build();
   return new BlobMetadataImpl(
         object.getKey(),
         object.getKey(),
         location,
         uri,
         object.getObjectMetadata().getETag(),
         object.getObjectMetadata().getLastModified(),
         object.getObjectMetadata().getLastModified(),
         object.getObjectMetadata().getUserMetadata(),
         uri,
         object.getBucketName(),
         cm);
}
 

import org.jclouds.domain.LocationBuilder; //导入依赖的package包/类
@Override
public void start() {
   key2StringMapper = Util.getInstance(configuration.key2StringMapper(), initializationContext.getCache()
         .getAdvancedCache().getClassLoader());
   key2StringMapper.setMarshaller(initializationContext.getMarshaller());

   ContextBuilder contextBuilder = ContextBuilder.newBuilder(configuration.provider()).credentials(configuration.identity(), configuration.credential());
   if(configuration.overrides() != null)
      contextBuilder.overrides(configuration.overrides());
   if(configuration.endpoint() != null && !configuration.endpoint().isEmpty())
      contextBuilder.endpoint(configuration.endpoint());

   blobStoreContext = contextBuilder.buildView(BlobStoreContext.class);

   blobStore = blobStoreContext.getBlobStore();
   String cacheName = configuration.normalizeCacheNames() ? 
         initializationContext.getCache().getName().replaceAll("[^a-zA-Z0-9-]", "-") 
         : initializationContext.getCache().getName();
   containerName = String.format("%s-%s", configuration.container(), cacheName);

   if (!blobStore.containerExists(containerName)) {
      Location location = null;
      if (configuration.location() != null ) {
         location = new LocationBuilder()
            .scope(LocationScope.REGION)
            .id(configuration.location())
            .description(String.format("Infinispan cache store for %s", containerName))
            .build();
      }
      blobStore.createContainerInLocation(location, containerName);

      //make sure container is created
      if(!blobStore.containerExists(containerName)) {
         try {
            log.waitingForContainer();
            TimeUnit.SECONDS.sleep(10);
         } catch (InterruptedException e) {
            throw new PersistenceException(String.format("Aborted when creating blob container %s", containerName));
         }
         if(!blobStore.containerExists(containerName)) {
            throw new PersistenceException(String.format("Unable to create blob container %s", containerName));
         }
      }
   }
}