org.jclouds.blobstore.BlobStore.list()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(8.6k)|赞(0)|评价(0)|浏览(179)

本文整理了Java中org.jclouds.blobstore.BlobStore.list()方法的一些代码示例，展示了BlobStore.list()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。BlobStore.list()方法的具体详情如下：
包路径：org.jclouds.blobstore.BlobStore
类名称：BlobStore
方法名：list

BlobStore.list介绍

[英]Lists all root-level resources available to the identity.
[中]列出标识可用的所有根级别资源。

代码示例

代码示例来源：origin: apache/usergrid

blobStore.list(bucketName, new ListContainerOptions().recursive());

代码示例来源：origin: apache/usergrid

final PageSet<? extends StorageMetadata> blobStoreList = blobStore.list();

代码示例来源：origin: gaul/s3proxy

@Override
protected void after() {
  logger.debug("S3 proxy is stopping");
  try {
    s3Proxy.stop();
    BlobStore blobStore = blobStoreContext.getBlobStore();
    for (StorageMetadata metadata : blobStore.list()) {
      blobStore.deleteContainer(metadata.getName());
    }
    blobStoreContext.close();
  } catch (Exception e) {
    throw new RuntimeException("Unable to stop S3 proxy", e);
  }
  FileUtils.deleteQuietly(blobStoreLocation);
  logger.debug("S3 proxy has stopped");
}

代码示例来源：origin: gaul/s3proxy

private void handleContainerList(HttpServletResponse response,
    BlobStore blobStore) throws IOException {
  PageSet<? extends StorageMetadata> buckets = blobStore.list();

代码示例来源：origin: rackerlabs/blueflood

public synchronized void downloadNewFiles(File downloadDir) {
  log.info("Downloading new files since {}", lastMarker);
  
  BlobStoreContext ctx = ContextBuilder.newBuilder(provider)
      .credentials(user, key)
      .overrides(new Properties() {{
        setProperty(LocationConstants.PROPERTY_ZONE, zone);
      }})
      .buildView(BlobStoreContext.class);
  // threadsafe according to https://jclouds.apache.org/documentation/userguide/blobstore-guide/
  BlobStore store = ctx.getBlobStore();
  ListContainerOptions options = new ListContainerOptions().maxResults(batchSize).afterMarker(lastMarker);
  PageSet<? extends StorageMetadata> pages = store.list(container, options);
  //Gets key within the time range specified
  NavigableMap<Long, String> mapWithinRange = getBlobsWithinRange(pages);
  //Download only for keys within that range
  for(Map.Entry<Long, String> blobMeta : mapWithinRange.entrySet()) {
    log.info("Downloading file: " + blobMeta.getValue());
    downloadWorkers.submit(new BlobDownload(downloadDir, store, container, blobMeta.getValue()));
    lastMarker = blobMeta.getValue();
    synchronized (CloudFilesManager.this) {
      // this is where we resume from.
      MarkerUtils.writeLastMarker(blobMeta.getValue());
    }
  }
  log.info("Updated the last marker value as " + lastMarker);
}

代码示例来源：origin: rackerlabs/blueflood

public synchronized boolean hasNewFiles() {
  // see if there are any files since lastMarker.
  BlobStoreContext ctx = ContextBuilder.newBuilder(provider)
      .credentials(user, key)
      .overrides(new Properties() {{
        setProperty(LocationConstants.PROPERTY_ZONE, zone);
      }})
      .buildView(BlobStoreContext.class);
  
  BlobStore store = ctx.getBlobStore();
  ListContainerOptions options = new ListContainerOptions().maxResults(batchSize).afterMarker(lastMarker);
  PageSet<? extends StorageMetadata> pages = store.list(container, options);
  
  log.debug("Saw {} new files since {}", pages.size() == batchSize ? "many" : Integer.toString(pages.size()), lastMarker);
  boolean emptiness = getBlobsWithinRange(pages).isEmpty();
  if(emptiness) {
    log.warn("No file found within range {}", new Range(START_TIME, STOP_TIME));
  } else {
    log.debug("New files found within range {}", new Range(START_TIME, STOP_TIME));
  }
  return !emptiness;
}

代码示例来源：origin: gaul/s3proxy

PageSet<? extends StorageMetadata> set = blobStore.list(containerName,
    options);

代码示例来源：origin: org.apache.brooklyn/brooklyn-launcher-common

@Override
  protected void doCall(BlobStore blobStore, String indent) throws Exception {
    for (String containerName : names) {
      Set<? extends StorageMetadata> contents = blobStore.list(containerName);
      stdout.println(indent+"Container "+containerName+" {");
      for (StorageMetadata content : contents) {
        stdout.println(indent+"\t"+content);
      }
      stdout.println(indent+"}");
    }
  }
}

代码示例来源：origin: com.amysta.jclouds/jclouds-blobstore

@Override
public PageSet<? extends StorageMetadata> list(String container,
   ListContainerOptions options) {
 return delegate().list(container, options);
}

代码示例来源：origin: Nextdoor/bender

@Override
public PageSet<? extends StorageMetadata> list(String container,
   ListContainerOptions options) {
 return delegate().list(container, options);
}

代码示例来源：origin: org.apache.jclouds/jclouds-blobstore

@Override
public PageSet<? extends StorageMetadata> list(String container,
   ListContainerOptions options) {
 return delegate().list(container, options);
}

代码示例来源：origin: org.apache.jclouds.karaf/commands

protected Set<String> listBlobs(BlobStore blobStore, String container) {
 Set<String> blobs = new LinkedHashSet<String>();
 if (blobStore != null && blobStore.containerExists(container)) {
   PageSet<? extends StorageMetadata> storageMetadatas = blobStore.list(container);
   if (storageMetadatas != null && !storageMetadatas.isEmpty()) {
    for (StorageMetadata metadata : storageMetadatas) {
      blobs.add(metadata.getName());
    }
   }
 }
 return blobs;
}

代码示例来源：origin: opendedup/sdfs

public static void main(String[] args) throws Exception {
  BatchJCloudChunkStore st = new BatchJCloudChunkStore();
  st.name = "datishpool0";
  Properties p = new Properties();
  p.setProperty("service-type", "b2");
  st.checkAccess("a6ba900eebf7", "001c60230bbe493db4bbb8d5031a9707628790c7a9", p);
  System.out.println("zzz");
  PageSet<? extends StorageMetadata> zips;
  zips = st.blobStore.list(st.name, ListContainerOptions.Builder.prefix("files/").maxResults(100));
  System.out.println(zips.size());
}

代码示例来源：origin: jclouds/legacy-jclouds

private void assertContainerEmptyDeleting(String container, String name) {
 Iterable<? extends StorageMetadata> listing = Iterables.filter(view.getBlobStore().list(container),
      new Predicate<StorageMetadata>() {
       @Override
       public boolean apply(StorageMetadata input) {
         return input.getType() == StorageType.BLOB;
       }
      });
 assertEquals(Iterables.size(listing), 0, String.format(
      "deleting %s, we still have %s blobs left in container %s, using encoding %s", name, Iterables
          .size(listing), container, LOCAL_ENCODING));
}

代码示例来源：origin: jclouds/legacy-jclouds

@Test
public void testListAllWhenOnePage() throws Exception {
 BlobStore blobStore = createMock(BlobStore.class);
 ListContainerOptions options = ListContainerOptions.NONE;
 StorageMetadata v1 = createMock(StorageMetadata.class);
 PageSet<StorageMetadata> pageSet = new PageSetImpl<StorageMetadata>(ImmutableList.of(v1), null);
 EasyMock.<PageSet<? extends StorageMetadata>> expect(blobStore.list(containerName, options)).andReturn(pageSet)
      .once();
 EasyMock.replay(blobStore);
 Iterable<StorageMetadata> iterable = BlobStores.listAll(blobStore, containerName, options);
 assertEquals(ImmutableList.copyOf(iterable), ImmutableList.of(v1));
}

代码示例来源：origin: jclouds/legacy-jclouds

@Test(groups = { "integration", "live" })
void containerDoesntExist() {
 Set<? extends StorageMetadata> list = view.getBlobStore().list();
 assert !list.contains(new MutableStorageMetadataImpl());
}

代码示例来源：origin: jclouds/legacy-jclouds

@Override
public void run() {
 PageSet<? extends StorageMetadata> list = view.getBlobStore().list();
 assert Iterables.any(list, new Predicate<StorageMetadata>() {
   public boolean apply(StorageMetadata md) {
    return containerName.equals(md.getName()) && location.equals(md.getLocation());
   }
 }) : String.format("container %s/%s not found in list %s", location, containerName, list);
 assertTrue(view.getBlobStore().containerExists(containerName), containerName);
}

代码示例来源：origin: jclouds/legacy-jclouds

@Test(groups = { "integration", "live" })
public void testListContainer() throws InterruptedException, ExecutionException, TimeoutException {
 String containerName = getContainerName();
 try {
   add15UnderRoot(containerName);
   Set<? extends StorageMetadata> container = view.getBlobStore().list(containerName);
   assertEquals(container.size(), 15);
 } finally {
   returnContainer(containerName);
 }
}

代码示例来源：origin: org.apache.brooklyn/brooklyn-locations-jclouds

private Set<Service> getServices(Credentials creds) throws Exception {
  BlobStoreContext tmpContext = BlobStoreContextFactoryImpl.INSTANCE.newBlobStoreContext(location);
  try {
    tmpContext.getBlobStore().list();
    LoadingCache<Credentials, Access> authCache = getAuthCache(tmpContext);
    Access tmpAccess = authCache.get(creds);
    return ImmutableSet.copyOf(tmpAccess);
  } finally {
    tmpContext.close();
  }
}

代码示例来源：origin: jclouds/legacy-jclouds

@Test(groups = { "integration", "live" })
public void testListContainerMaxResults() throws InterruptedException {
 String containerName = getContainerName();
 try {
   addAlphabetUnderRoot(containerName);
   PageSet<? extends StorageMetadata> container = view.getBlobStore().list(containerName, maxResults(5));
   assertEquals(container.size(), 5);
   assert container.getNextMarker() != null;
 } finally {
   returnContainer(containerName);
 }
}

内容来源于网络，如有侵权，请联系作者删除！

BlobStore

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    BlobStore类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com