private static final long serialVersionUID = 3599706574671671516L;

private final StorageOptions options;

private transient Storage storage;

/** Class for specifying bucket source options when {@code Bucket} methods are used. */

@TransportCompatibility({Transport.HTTP, Transport.GRPC})

public static class BucketSourceOption extends Option<BucketSourceOpt> {

private static final long serialVersionUID = 6765489853972162215L;

private BucketSourceOption(BucketSourceOpt opt) {

super(opt);

}

/**

* Returns an option for bucket's metageneration match. If this option is used the request will

* fail if metageneration does not match.

*/

@TransportCompatibility({Transport.HTTP, Transport.GRPC})

public static BucketSourceOption metagenerationMatch() {

return new BucketSourceOption(UnifiedOpts.metagenerationMatchExtractor());

}

/**

* Returns an option for bucket's metageneration mismatch. If this option is used the request

* will fail if metageneration matches.

*/

@TransportCompatibility({Transport.HTTP, Transport.GRPC})

public static BucketSourceOption metagenerationNotMatch() {

return new BucketSourceOption(UnifiedOpts.metagenerationNotMatchExtractor());

}

/**

* Returns an option for blob's billing user project. This option is only used by the buckets

* with 'requester_pays' flag.

*/

@TransportCompatibility({Transport.HTTP, Transport.GRPC})

public static BucketSourceOption userProject(@NonNull String userProject) {

return new BucketSourceOption(UnifiedOpts.userProject(userProject));

}

/**

* Deduplicate any options which are the same parameter. The value which comes last in {@code

* os} will be the value included in the return.

*/

@BetaApi

public static BucketSourceOption[] dedupe(BucketSourceOption... os) {

return Option.dedupe(BucketSourceOption[]::new, os);

}

/**

* Deduplicate any options which are the same parameter.

*

* <p>The value which comes last in {@code collection} and {@code os} will be the value included

* in the return. All options from {@code os} will override their counterparts in {@code

* collection}.

*/

@BetaApi

public static BucketSourceOption[] dedupe(

Collection<BucketSourceOption> collection, BucketSourceOption... os) {

return Option.dedupe(BucketSourceOption[]::new, collection, os);

}

/**

* Deduplicate any options which are the same parameter.

*

* <p>The value which comes last in {@code collection} and {@code os} will be the value included

* in the return. All options from {@code os} will override their counterparts in {@code

* collection}.

*/

@BetaApi

public static BucketSourceOption[] dedupe(

BucketSourceOption[] array, BucketSourceOption... os) {

return Option.dedupe(BucketSourceOption[]::new, array, os);

}

static Storage.BucketSourceOption[] toSourceOptions(

BucketInfo bucketInfo, BucketSourceOption... options) {

Storage.BucketSourceOption[] convertedOptions =

new Storage.BucketSourceOption[options.length];

for (int i = 0; i < options.length; i++) {

BucketSourceOpt opt = options[i].getOpt();

if (opt instanceof BucketOptExtractor) {

BucketOptExtractor<BucketSourceOpt> ex = (BucketOptExtractor<BucketSourceOpt>) opt;

BucketSourceOpt bucketSourceOpt = ex.extractFromBucketInfo(bucketInfo);

convertedOptions[i] = new Storage.BucketSourceOption(bucketSourceOpt);

} else {

convertedOptions[i] = new Storage.BucketSourceOption(options[i].getOpt());

}

}

return convertedOptions;

}

static Storage.BucketGetOption[] toGetOptions(

BucketInfo bucketInfo, BucketSourceOption... options) {

Storage.BucketGetOption[] convertedOptions = new Storage.BucketGetOption[options.length];

for (int i = 0; i < options.length; i++) {

BucketSourceOpt opt = options[i].getOpt();

if (opt instanceof BucketOptExtractor) {

BucketOptExtractor<BucketSourceOpt> ex = (BucketOptExtractor<BucketSourceOpt>) opt;

BucketSourceOpt bucketSourceOpt = ex.extractFromBucketInfo(bucketInfo);

convertedOptions[i] = new BucketGetOption(bucketSourceOpt);

} else {

convertedOptions[i] = new BucketGetOption(options[i].getOpt());

}

}

return convertedOptions;

}

}

/** Class for specifying blob target options when {@code Bucket} methods are used. */

public static class BlobTargetOption extends Option<ObjectTargetOpt> {

private static final long serialVersionUID = -7203767045761758606L;

private BlobTargetOption(ObjectTargetOpt opt) {

super(opt);

}

/** Returns an option for specifying blob's predefined ACL configuration. */

@TransportCompatibility({Transport.HTTP, Transport.GRPC})

public static BlobTargetOption predefinedAcl(Storage.@NonNull PredefinedAcl acl) {

return new BlobTargetOption(UnifiedOpts.predefinedAcl(acl));

}

/**

* Returns an option that causes an operation to succeed only if the target blob does not exist.

* This option can not be provided together with {@link #generationMatch(long)} or {@link

* #generationNotMatch(long)}.

*/

@TransportCompatibility({Transport.HTTP, Transport.GRPC})

public static BlobTargetOption doesNotExist() {

return new BlobTargetOption(UnifiedOpts.doesNotExist());

}

/**

* Returns an option for blob's data generation match. If this option is used the request will

* fail if generation does not match the provided value. This option can not be provided

* together with {@link #generationNotMatch(long)} or {@link #doesNotExist()}.

*/

@TransportCompatibility({Transport.HTTP, Transport.GRPC})

public static BlobTargetOption generationMatch(long generation) {

return new BlobTargetOption(UnifiedOpts.generationMatch(generation));

}

/**

* Returns an option for blob's data generation mismatch. If this option is used the request

* will fail if blob's generation matches the provided value. This option can not be provided

* together with {@link #generationMatch(long)} or {@link #doesNotExist()}.

*/

@TransportCompatibility({Transport.HTTP, Transport.GRPC})

public static BlobTargetOption generationNotMatch(long generation) {

return new BlobTargetOption(UnifiedOpts.generationNotMatch(generation));

}

/**

* Returns an option for blob's metageneration match. If this option is used the request will

* fail if metageneration does not match the provided value. This option can not be provided

* together with {@link #metagenerationNotMatch(long)}.

*/

@TransportCompatibility({Transport.HTTP, Transport.GRPC})

public static BlobTargetOption metagenerationMatch(long metageneration) {

return new BlobTargetOption(UnifiedOpts.metagenerationMatch(metageneration));

}

/**

* Returns an option for blob's metageneration mismatch. If this option is used the request will

* fail if metageneration matches the provided value. This option can not be provided together

* with {@link #metagenerationMatch(long)}.

*/

@TransportCompatibility({Transport.HTTP, Transport.GRPC})

public static BlobTargetOption metagenerationNotMatch(long metageneration) {

return new BlobTargetOption(UnifiedOpts.metagenerationNotMatch(metageneration));

}

/**

* Returns an option to set a customer-supplied AES256 key for server-side encryption of the

* blob.

*/

@TransportCompatibility({Transport.HTTP, Transport.GRPC})

public static BlobTargetOption encryptionKey(@NonNull Key key) {

return new BlobTargetOption(UnifiedOpts.encryptionKey(key));

}

/**

* Returns an option to set a customer-supplied AES256 key for server-side encryption of the

* blob.

*

* @param key the AES256 encoded in base64

*/

@TransportCompatibility({Transport.HTTP, Transport.GRPC})

public static BlobTargetOption encryptionKey(@NonNull String key) {

return new BlobTargetOption(UnifiedOpts.encryptionKey(key));

}

/**

* Returns an option to set a customer-managed KMS key for server-side encryption of the blob.

*

* @param kmsKeyName the KMS key resource id

*/

@TransportCompatibility({Transport.HTTP, Transport.GRPC})

public static BlobTargetOption kmsKeyName(@NonNull String kmsKeyName) {

return new BlobTargetOption(UnifiedOpts.kmsKeyName(kmsKeyName));

}

/**

* Returns an option for blob's billing user project. This option is only used by the buckets

* with 'requester_pays' flag.

*/

@TransportCompatibility({Transport.HTTP, Transport.GRPC})

public static BlobTargetOption userProject(@NonNull String userProject) {

return new BlobTargetOption(UnifiedOpts.userProject(userProject));

}

/**

* Returns an option for overriding an Unlocked Retention policy. This must be set to true in

* order to change a policy from Unlocked to Locked, to set it to null, or to reduce its

* retainUntilTime attribute.

*/

@TransportCompatibility({Transport.HTTP})

public static BlobTargetOption overrideUnlockedRetention(boolean overrideUnlockedRetention) {

return new BlobTargetOption(UnifiedOpts.overrideUnlockedRetention(overrideUnlockedRetention));

}

/**

* Deduplicate any options which are the same parameter. The value which comes last in {@code

* os} will be the value included in the return.

*/

@BetaApi

public static BlobTargetOption[] dedupe(BlobTargetOption... os) {

return Option.dedupe(BlobTargetOption[]::new, os);

}

/**

* Deduplicate any options which are the same parameter.

*

* <p>The value which comes last in {@code collection} and {@code os} will be the value included

* in the return. All options from {@code os} will override their counterparts in {@code

* collection}.

*/

@BetaApi

public static BlobTargetOption[] dedupe(

Collection<BlobTargetOption> collection, BlobTargetOption... os) {

return Option.dedupe(BlobTargetOption[]::new, collection, os);

}

/**

* Deduplicate any options which are the same parameter.

*

* <p>The value which comes last in {@code collection} and {@code os} will be the value included

* in the return. All options from {@code os} will override their counterparts in {@code

* collection}.

*/

@BetaApi

public static BlobTargetOption[] dedupe(BlobTargetOption[] array, BlobTargetOption... os) {

return Option.dedupe(BlobTargetOption[]::new, array, os);

}

static Storage.BlobTargetOption[] toTargetOptions(

BlobInfo blobInfo, BlobTargetOption... options) {

Storage.BlobTargetOption[] targetOptions = new Storage.BlobTargetOption[options.length];

for (int i = 0; i < options.length; i++) {

ObjectTargetOpt opt = options[i].getOpt();

if (opt instanceof ObjectOptExtractor) {

ObjectOptExtractor<ObjectTargetOpt> ex = (ObjectOptExtractor<ObjectTargetOpt>) opt;

ObjectTargetOpt objectTargetOpt = ex.extractFromBlobInfo(blobInfo);

targetOptions[i] = new Storage.BlobTargetOption(objectTargetOpt);

} else {

targetOptions[i] = new Storage.BlobTargetOption(options[i].getOpt());

}

}

return targetOptions;

}

}

/** Class for specifying blob write options when {@code Bucket} methods are used. */

public static class BlobWriteOption extends Option<ObjectTargetOpt> implements Serializable {

private static final long serialVersionUID = 59762268190041584L;

private BlobWriteOption(ObjectTargetOpt opt) {

super(opt);

}

/** Returns an option for specifying blob's predefined ACL configuration. */

@TransportCompatibility({Transport.HTTP, Transport.GRPC})

public static BlobWriteOption predefinedAcl(Storage.@NonNull PredefinedAcl acl) {

return new BlobWriteOption(UnifiedOpts.predefinedAcl(acl));

}

/**

* Returns an option that causes an operation to succeed only if the target blob does not exist.

* This option can not be provided together with {@link #generationMatch(long)} or {@link

* #generationNotMatch(long)}.

*/

@TransportCompatibility({Transport.HTTP, Transport.GRPC})

public static BlobWriteOption doesNotExist() {

return new BlobWriteOption(UnifiedOpts.doesNotExist());

}

/**

* Returns an option for blob's data generation match. If this option is used the request will

* fail if generation does not match the provided value. This option can not be provided

* together with {@link #generationNotMatch(long)} or {@link #doesNotExist()}.

*/

@TransportCompatibility({Transport.HTTP, Transport.GRPC})

public static BlobWriteOption generationMatch(long generation) {

return new BlobWriteOption(UnifiedOpts.generationMatch(generation));

}

/**

* Returns an option for blob's data generation mismatch. If this option is used the request

* will fail if generation matches the provided value. This option can not be provided together

* with {@link #generationMatch(long)} or {@link #doesNotExist()}.

*/

@TransportCompatibility({Transport.HTTP, Transport.GRPC})

public static BlobWriteOption generationNotMatch(long generation) {

return new BlobWriteOption(UnifiedOpts.generationNotMatch(generation));

}

/**

* Returns an option for blob's metageneration match. If this option is used the request will

* fail if metageneration does not match the provided value. This option can not be provided

* together with {@link #metagenerationNotMatch(long)}.

*/

@TransportCompatibility({Transport.HTTP, Transport.GRPC})

public static BlobWriteOption metagenerationMatch(long metageneration) {

return new BlobWriteOption(UnifiedOpts.metagenerationMatch(metageneration));

}

/**

* Returns an option for blob's metageneration mismatch. If this option is used the request will

* fail if metageneration matches the provided value. This option can not be provided together

* with {@link #metagenerationMatch(long)}.

*/

@TransportCompatibility({Transport.HTTP, Transport.GRPC})

public static BlobWriteOption metagenerationNotMatch(long metageneration) {

return new BlobWriteOption(UnifiedOpts.metagenerationNotMatch(metageneration));

}

/**

* Returns an option for blob's data MD5 hash match. If this option is used the request will

* fail if blobs' data MD5 hash does not match the provided value.

*/

@TransportCompatibility({Transport.HTTP, Transport.GRPC})

public static BlobWriteOption md5Match(@NonNull String md5) {

return new BlobWriteOption(UnifiedOpts.md5Match(md5));

}

/**

* Returns an option for blob's data CRC32C checksum match. If this option is used the request

* will fail if blobs' data CRC32C checksum does not match the provided value.

*/

@TransportCompatibility({Transport.HTTP, Transport.GRPC})

public static BlobWriteOption crc32cMatch(@NonNull String crc32c) {

return new BlobWriteOption(UnifiedOpts.crc32cMatch(crc32c));

}

/**

* Returns an option to set a customer-supplied AES256 key for server-side encryption of the

* blob.

*/

@TransportCompatibility({Transport.HTTP, Transport.GRPC})

public static BlobWriteOption encryptionKey(@NonNull Key key) {

return new BlobWriteOption(UnifiedOpts.encryptionKey(key));

}

/**

* Returns an option to set a customer-supplied AES256 key for server-side encryption of the

* blob.

*

* @param key the AES256 encoded in base64

*/

@TransportCompatibility({Transport.HTTP, Transport.GRPC})

public static BlobWriteOption encryptionKey(@NonNull String key) {

return new BlobWriteOption(UnifiedOpts.encryptionKey(key));

}

/**

* Returns an option for blob's billing user project. This option is only used by the buckets

* with 'requester_pays' flag.

*/

@TransportCompatibility({Transport.HTTP, Transport.GRPC})

public static BlobWriteOption userProject(@NonNull String userProject) {

return new BlobWriteOption(UnifiedOpts.userProject(userProject));

}

/**

* Deduplicate any options which are the same parameter. The value which comes last in {@code

* os} will be the value included in the return.

*/

@BetaApi

public static BlobWriteOption[] dedupe(BlobWriteOption... os) {

return Option.dedupe(BlobWriteOption[]::new, os);

}

/**

* Deduplicate any options which are the same parameter.

*

* <p>The value which comes last in {@code collection} and {@code os} will be the value included

* in the return. All options from {@code os} will override their counterparts in {@code

* collection}.

*/

@BetaApi

public static BlobWriteOption[] dedupe(

Collection<BlobWriteOption> collection, BlobWriteOption... os) {

return Option.dedupe(BlobWriteOption[]::new, collection, os);

}

/**

* Deduplicate any options which are the same parameter.

*

* <p>The value which comes last in {@code collection} and {@code os} will be the value included

* in the return. All options from {@code os} will override their counterparts in {@code

* collection}.

*/

@BetaApi

public static BlobWriteOption[] dedupe(BlobWriteOption[] array, BlobWriteOption... os) {

return Option.dedupe(BlobWriteOption[]::new, array, os);

}

static Storage.BlobWriteOption[] toWriteOptions(BlobInfo blobInfo, BlobWriteOption... options) {

Storage.BlobWriteOption[] convertedOptions = new Storage.BlobWriteOption[options.length];

for (int i = 0; i < options.length; i++) {

ObjectTargetOpt opt = options[i].getOpt();

if (opt instanceof ObjectOptExtractor) {

ObjectOptExtractor<ObjectTargetOpt> ex = (ObjectOptExtractor<ObjectTargetOpt>) opt;

ObjectTargetOpt objectTargetOpt = ex.extractFromBlobInfo(blobInfo);

convertedOptions[i] = new Storage.BlobWriteOption(objectTargetOpt);

} else {

convertedOptions[i] = new Storage.BlobWriteOption(options[i].getOpt());

}

}

return convertedOptions;

}

}

/** Builder for {@code Bucket}. */

public static class Builder extends BucketInfo.Builder {

private final Storage storage;

private final BucketInfo.BuilderImpl infoBuilder;

Builder(Bucket bucket) {

this.storage = bucket.storage;

this.infoBuilder = new BucketInfo.BuilderImpl(bucket);

}

@Override

public Builder setName(String name) {

infoBuilder.setName(name);

return this;

}

@Override

Builder setProject(String project) {

infoBuilder.setProject(project);

return this;

}

@Override

Builder setGeneratedId(String generatedId) {

infoBuilder.setGeneratedId(generatedId);

return this;

}

@Override

Builder setOwner(Entity owner) {

infoBuilder.setOwner(owner);

return this;

}

@Override

Builder setSelfLink(String selfLink) {

infoBuilder.setSelfLink(selfLink);

return this;

}

@Override

public Builder setVersioningEnabled(Boolean enable) {

infoBuilder.setVersioningEnabled(enable);

return this;

}

@Override

public Builder setRequesterPays(Boolean requesterPays) {

infoBuilder.setRequesterPays(requesterPays);

return this;

}

@Override

public Builder setIndexPage(String indexPage) {

infoBuilder.setIndexPage(indexPage);

return this;

}

@Override

public Builder setNotFoundPage(String notFoundPage) {

infoBuilder.setNotFoundPage(notFoundPage);

return this;

}

/**

* @deprecated Use {@link #setLifecycleRules(Iterable)} instead, as in {@code

* setLifecycleRules(Collections.singletonList( new BucketInfo.LifecycleRule(

* LifecycleAction.newDeleteAction(), LifecycleCondition.newBuilder().setAge(5).build())));}

*/

@Override

@Deprecated

public Builder setDeleteRules(Iterable<? extends DeleteRule> rules) {

infoBuilder.setDeleteRules(rules);

return this;

}

@Override

public Builder setLifecycleRules(Iterable<? extends LifecycleRule> rules) {

infoBuilder.setLifecycleRules(rules);

return this;

}

@Override

public Builder deleteLifecycleRules() {

infoBuilder.deleteLifecycleRules();

return this;

}

@Override

public Builder setRpo(Rpo rpo) {

infoBuilder.setRpo(rpo);

return this;

}

@Override

public Builder setStorageClass(StorageClass storageClass) {

infoBuilder.setStorageClass(storageClass);

return this;

}

@Override

public Builder setLocation(String location) {

infoBuilder.setLocation(location);

return this;

}

@Override

Builder setEtag(String etag) {

infoBuilder.setEtag(etag);

return this;

}

/** @deprecated Use {@link #setCreateTimeOffsetDateTime(OffsetDateTime)} */

@Override

@Deprecated

Builder setCreateTime(Long createTime) {

infoBuilder.setCreateTime(createTime);

return this;

}

@Override

BucketInfo.Builder setCreateTimeOffsetDateTime(OffsetDateTime createTime) {

infoBuilder.setCreateTimeOffsetDateTime(createTime);

return this;

}

/** @deprecated Use {@link #setUpdateTimeOffsetDateTime(OffsetDateTime)} */

@Override

@Deprecated

Builder setUpdateTime(Long updateTime) {

infoBuilder.setUpdateTime(updateTime);

return this;

}

@Override

BucketInfo.Builder setUpdateTimeOffsetDateTime(OffsetDateTime updateTime) {

infoBuilder.setUpdateTimeOffsetDateTime(updateTime);

return this;

}

@Override

Builder setMetageneration(Long metageneration) {

infoBuilder.setMetageneration(metageneration);

return this;

}

@Override

public Builder setCors(Iterable<Cors> cors) {

infoBuilder.setCors(cors);

return this;

}

@Override

public Builder setAcl(Iterable<Acl> acl) {

infoBuilder.setAcl(acl);

return this;

}

@Override

public Builder setDefaultAcl(Iterable<Acl> acl) {

infoBuilder.setDefaultAcl(acl);

return this;

}

@Override

public Builder setLabels(@Nullable Map<@NonNull String, @Nullable String> labels) {

infoBuilder.setLabels(labels);

return this;

}

@Override

public Builder setDefaultKmsKeyName(String defaultKmsKeyName) {

infoBuilder.setDefaultKmsKeyName(defaultKmsKeyName);

return this;

}

@Override

public Builder setDefaultEventBasedHold(Boolean defaultEventBasedHold) {

infoBuilder.setDefaultEventBasedHold(defaultEventBasedHold);

return this;

}

/** @deprecated {@link #setRetentionEffectiveTimeOffsetDateTime(OffsetDateTime)} */

@Override

@Deprecated

Builder setRetentionEffectiveTime(Long retentionEffectiveTime) {

infoBuilder.setRetentionEffectiveTime(retentionEffectiveTime);

return this;

}

@Override

BucketInfo.Builder setRetentionEffectiveTimeOffsetDateTime(

OffsetDateTime retentionEffectiveTime) {

infoBuilder.setRetentionEffectiveTimeOffsetDateTime(retentionEffectiveTime);

return this;

}

@Override

Builder setRetentionPolicyIsLocked(Boolean retentionIsLocked) {

infoBuilder.setRetentionPolicyIsLocked(retentionIsLocked);

return this;

}

/** @deprecated Use {@link #setRetentionPeriodDuration(Duration)} */

@Override

@Deprecated

public Builder setRetentionPeriod(Long retentionPeriod) {

infoBuilder.setRetentionPeriod(retentionPeriod);

return this;

}

@Override

public BucketInfo.Builder setRetentionPeriodDuration(Duration retentionPeriod) {

infoBuilder.setRetentionPeriodDuration(retentionPeriod);

return this;

}

@Override

public Builder setIamConfiguration(IamConfiguration iamConfiguration) {

infoBuilder.setIamConfiguration(iamConfiguration);

return this;

}

@Override

public Builder setAutoclass(Autoclass autoclass) {

infoBuilder.setAutoclass(autoclass);

return this;

}

@Override

public Builder setLogging(Logging logging) {

infoBuilder.setLogging(logging);

return this;

}

@Override

Builder setLocationType(String locationType) {

infoBuilder.setLocationType(locationType);

return this;

}

@Override

public Builder setCustomPlacementConfig(CustomPlacementConfig customPlacementConfig) {

infoBuilder.setCustomPlacementConfig(customPlacementConfig);

return this;

}

@Override

Builder setObjectRetention(ObjectRetention objectRetention) {

infoBuilder.setObjectRetention(objectRetention);

return this;

}

@Override

public Builder setHierarchicalNamespace(HierarchicalNamespace hierarchicalNamespace) {

infoBuilder.setHierarchicalNamespace(hierarchicalNamespace);

return this;

}

@Override

public Bucket build() {

return new Bucket(storage, infoBuilder);

}

@Override

Builder clearGeneratedId() {

infoBuilder.clearGeneratedId();

return this;

}

@Override

Builder clearProject() {

infoBuilder.clearProject();

return this;

}

@Override

Builder clearName() {

infoBuilder.clearName();

return this;

}

@Override

Builder clearOwner() {

infoBuilder.clearOwner();

return this;

}

@Override

Builder clearSelfLink() {

infoBuilder.clearSelfLink();

return this;

}

@Override

Builder clearRequesterPays() {

infoBuilder.clearRequesterPays();

return this;

}

@Override

Builder clearVersioningEnabled() {

infoBuilder.clearVersioningEnabled();

return this;

}

@Override

Builder clearIndexPage() {

infoBuilder.clearIndexPage();

return this;

}

@Override

Builder clearNotFoundPage() {

infoBuilder.clearNotFoundPage();

return this;

}

@Override

Builder clearLifecycleRules() {

infoBuilder.clearLifecycleRules();

return this;

}

@Override

Builder clearRpo() {

infoBuilder.clearRpo();

return this;

}

@Override

Builder clearStorageClass() {

infoBuilder.clearStorageClass();

return this;

}

@Override

Builder clearLocation() {

infoBuilder.clearLocation();

return this;

}

@Override

Builder clearEtag() {

infoBuilder.clearEtag();

return this;

}

@Override

Builder clearCreateTime() {

infoBuilder.clearCreateTime();

return this;

}

@Override

Builder clearUpdateTime() {

infoBuilder.clearUpdateTime();

return this;

}

@Override

Builder clearMetageneration() {

infoBuilder.clearMetageneration();

return this;

}

@Override

Builder clearCors() {

infoBuilder.clearCors();

return this;

}

@Override

Builder clearAcl() {

infoBuilder.clearAcl();

return this;

}

@Override

Builder clearDefaultAcl() {

infoBuilder.clearDefaultAcl();

return this;

}

@Override

Builder clearLabels() {

infoBuilder.clearLabels();

return this;

}

@Override

Builder clearDefaultKmsKeyName() {

infoBuilder.clearDefaultKmsKeyName();

return this;

}

@Override

Builder clearDefaultEventBasedHold() {

infoBuilder.clearDefaultEventBasedHold();

return this;

}

@Override

Builder clearRetentionEffectiveTime() {

infoBuilder.clearRetentionEffectiveTime();

return this;

}

@Override

Builder clearRetentionPolicyIsLocked() {

infoBuilder.clearRetentionPolicyIsLocked();

return this;

}

@Override

Builder clearRetentionPeriod() {

infoBuilder.clearRetentionPeriod();

return this;

}

@Override

Builder clearIamConfiguration() {

infoBuilder.clearIamConfiguration();

return this;

}

@Override

Builder clearLocationType() {

infoBuilder.clearLocationType();

return this;

}

@Override

Builder clearLogging() {

infoBuilder.clearLogging();

return this;

}

@Override

Builder clearCustomPlacementConfig() {

infoBuilder.clearCustomPlacementConfig();

return this;

}

}

Bucket(Storage storage, BucketInfo.BuilderImpl infoBuilder) {

super(infoBuilder);

this.storage = checkNotNull(storage);

this.options = storage.getOptions();

}

/**

* Checks if this bucket exists.

*

* <p>Example of checking if the bucket exists.

*

* <pre>{@code

* boolean exists = bucket.exists();

* if (exists) {

* // the bucket exists

* } else {

* // the bucket was not found

* }

* }</pre>

*

* @return true if this bucket exists, false otherwise

* @throws StorageException upon failure

*/

@TransportCompatibility({Transport.HTTP, Transport.GRPC})

public boolean exists(BucketSourceOption... options) {

int length = options.length;

// Don't use static imports of BlobSourceOption, it causes import resolution issues

// with the new UnifiedOpts shim interfaces

Storage.BucketGetOption[] getOptions =

Arrays.copyOf(BucketSourceOption.toGetOptions(this, options), length + 1);

getOptions[length] = Storage.BucketGetOption.fields();

return storage.get(getName(), getOptions) != null;

}

/**

* Fetches current bucket's latest information. Returns {@code null} if the bucket does not exist.

*

* <p>Example of getting the bucket's latest information, if its generation does not match the

* {@link Bucket#getMetageneration()} value, otherwise a {@link StorageException} is thrown.

*

* <pre>{@code

* Bucket latestBucket = bucket.reload(BucketSourceOption.metagenerationMatch());

* if (latestBucket == null) {

* // the bucket was not found

* }

* }</pre>

*

* @param options bucket read options

* @return a {@code Bucket} object with latest information or {@code null} if not found

* @throws StorageException upon failure

*/

@TransportCompatibility({Transport.HTTP, Transport.GRPC})

public Bucket reload(BucketSourceOption... options) {

// Don't use static imports of BlobSourceOption, it causes import resolution issues

// with the new UnifiedOpts shim interfaces

return storage.get(getName(), BucketSourceOption.toGetOptions(this, options));

}