import com.google.api.gax.paging.Page; //导入依赖的package包/类
@AfterClass
public static void tearDownClass() {
  // Clear the datastore
  Datastore datastore = DatastoreOptions.getDefaultInstance().getService();
  Batch batch = datastore.newBatch();
  StructuredQuery<Key> query = Query.newKeyQueryBuilder()
      .setKind("Book3").build();
  for (QueryResults<Key> keys = datastore.run(query); keys.hasNext(); ) {
    batch.delete(keys.next());
  }
  batch.submit();

  // Delete any objects in the bucket
  Storage storage = StorageOptions.getDefaultInstance().getService();
  Page<Blob> blobs = storage.list(System.getProperty("bookshelf.bucket"));
  List<BlobId> blobIds = new ArrayList<BlobId>();
  for (Blob b : blobs.iterateAll()) {
    blobIds.add(b.getBlobId());
  }
  storage.delete(blobIds);

  service.stop();
}
 

import com.google.api.gax.paging.Page; //导入依赖的package包/类
@AfterClass
public static void tearDownClass() {
  // Delete any objects in the bucket
  Storage storage = StorageOptions.getDefaultInstance().getService();
  Page<Blob> blobs = storage.list(System.getProperty("bookshelf.bucket"));
  List<BlobId> blobIds = new ArrayList<BlobId>();
  for (Blob b : blobs.iterateAll()) {
    blobIds.add(b.getBlobId());
  }
  storage.delete(blobIds);

  // Clear the datastore if we're not using the local emulator
  if (!LOCAL_TEST) {
    Datastore datastore = DatastoreOptions.getDefaultInstance().getService();
    Batch batch = datastore.newBatch();
    StructuredQuery<Key> query = Query.newKeyQueryBuilder()
        .setKind("Book3").build();
    for (QueryResults<Key> keys = datastore.run(query); keys.hasNext(); ) {
      batch.delete(keys.next());
    }
    batch.submit();
  }

  service.stop();
}
 

import com.google.api.gax.paging.Page; //导入依赖的package包/类
/** Expects an existing Stackdriver log name as an argument. */
public static void main(String... args) throws Exception {
  // [START listlogs]
  // Instantiates a client
  LoggingOptions options = LoggingOptions.getDefaultInstance();

  String logName = args[0];

  try (Logging logging = options.getService()) {

    String logFilter = "logName=projects/" + options.getProjectId() + "/logs/" + logName;

    // List all log entries
    Page<LogEntry> entries = logging.listLogEntries(
        EntryListOption.filter(logFilter));
    do {
      for (LogEntry logEntry : entries.iterateAll()) {
        System.out.println(logEntry);
      }
      entries = entries.getNextPage();
    } while (entries != null);

  }
  // [END listlogs]
}
 

import com.google.api.gax.paging.Page; //导入依赖的package包/类
static GcsBucketVirtualFile setupVirtualFileWithBucketMocks(
    GcsBucketVirtualFile gcsBucketVirtualFile) {
  Bucket bucket = mock(Bucket.class);
  Page<Blob> page = mock(Page.class);
  Iterable<Blob> blobIterable = mock(Iterable.class);
  Iterator<Blob> blobIterator = mock(Iterator.class);

  when(gcsBucketVirtualFile.getBucket()).thenReturn(bucket);
  when(bucket.list()).thenReturn(page);
  when(bucket.list(any(BlobListOption.class), any(BlobListOption.class))).thenReturn(page);
  when(page.iterateAll()).thenReturn(blobIterable);
  when(blobIterable.iterator()).thenReturn(blobIterator);

  return gcsBucketVirtualFile;
}
 

import com.google.api.gax.paging.Page; //导入依赖的package包/类
/**
 * Gives the raw JS Scripts sepcified
 * @return list of raw JS Script data as strings
 */
public List<String> getScripts() {
  if (Strings.isNullOrEmpty(gcsJSPath())) {
    return new ArrayList<>();
  }

  String bucketName = gcsJSPath().replace("gs://", "").split("/")[0];
  String prefixPath = gcsJSPath().replace("gs://" + bucketName + "/", "");

  Bucket bucket = getStorageService().get(bucketName);
  if (bucket == null || !bucket.exists()) {
    throw new IllegalArgumentException(
        "Bucket does not exist, or do not have adequate permissions");
  }

  ArrayList<String> filePaths = new ArrayList<>();
  if (prefixPath.endsWith(".js")) {
    filePaths.add(prefixPath);
  } else {
    Page<Blob> blobs = bucket.list(BlobListOption.prefix(prefixPath));
    blobs.iterateAll().forEach((Blob blob) -> {
      if (blob.getName().endsWith(".js")) {
        filePaths.add(blob.getName());
      }
    });
  }

  List<String> scripts = new ArrayList<>();
  for (String filePath : filePaths) {
    Blob b = bucket.get(filePath);
    if (b == null || !b.exists()) {
      throw new IllegalArgumentException(
          "File does not exist, or do not have adequate permissions");
    }
    scripts.add(new String(b.getContent()));
  }

  return scripts;
}
 

import com.google.api.gax.paging.Page; //导入依赖的package包/类
private static Blob blobExistsInner(URI uri) {
  final String bucketName = uri.getAuthority();
  final String prefix = uri.getPath().startsWith("/") ? uri.getPath().substring(1) : uri.getPath();

  final Page<Blob> list = STORAGE.list(bucketName, prefix(prefix));
  for (final Blob blob : list.iterateAll()) {
    if (blob.getName().equals(prefix)) {
      return blob;
    }
  }

  throw new NotReady();
}
 

import com.google.api.gax.paging.Page; //导入依赖的package包/类
private void poolForFiles(long minTimeStamp) {
  Page<Blob> blobs = storage.list(
      gcsOriginConfig.bucketTemplate,
      Storage.BlobListOption.prefix(GcsUtil.normalizePrefix(gcsOriginConfig.commonPrefix))
  );
  blobs.iterateAll().forEach(blob ->  {
    if (isBlobEligible(blob, minTimeStamp)) {
      minMaxPriorityQueue.add(blob);
    }
  });
}
 

import com.google.api.gax.paging.Page; //导入依赖的package包/类
public Page<Blob> listBucket(String bucketName, String directory) {
  Bucket bucket = Objects.requireNonNull(storage.get(bucketName, Storage.BucketGetOption.fields()),
          "Please provide bucket name.");
  Page<Blob> blobs = bucket.list(Storage.BlobListOption.prefix(directory));
  return blobs;
}
 

import com.google.api.gax.paging.Page; //导入依赖的package包/类
private void setBlobs(Blob... blobs) {
  List<Blob> blobList = Lists.newArrayList(blobs);
  Page<Blob> blobPage = bucketVirtualFile.getBucket().list();
  when(blobPage.iterateAll()).thenReturn(blobList);
}