com.google.cloud.storage.spi.v1

Class HttpStorageRpc

java.lang.Object

com.google.cloud.storage.spi.v1.HttpStorageRpc

All Implemented Interfaces:

ServiceRpc, StorageRpc

public class HttpStorageRpc
extends Object
implements StorageRpc

Nested Class Summary

Nested classes/interfaces inherited from interface com.google.cloud.storage.spi.v1.StorageRpc

StorageRpc.Option, StorageRpc.RewriteRequest, StorageRpc.RewriteResponse

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_PROJECTION
static String	NO_ACL_PROJECTION

Constructor Summary

Constructors

Constructor and Description
HttpStorageRpc(StorageOptions options)

Method Summary

Modifier and Type	Method and Description
com.google.api.services.storage.model.StorageObject	compose(Iterable<com.google.api.services.storage.model.StorageObject> sources, com.google.api.services.storage.model.StorageObject target, Map<StorageRpc.Option,?> targetOptions) Sends a compose request.
StorageRpc.RewriteResponse	continueRewrite(StorageRpc.RewriteResponse previousResponse) Continues rewriting on an already open rewrite channel.
com.google.api.services.storage.model.Bucket	create(com.google.api.services.storage.model.Bucket bucket, Map<StorageRpc.Option,?> options) Creates a new bucket.
com.google.api.services.storage.model.StorageObject	create(com.google.api.services.storage.model.StorageObject storageObject, InputStream content, Map<StorageRpc.Option,?> options) Creates a new storage object.
com.google.api.services.storage.model.BucketAccessControl	createAcl(com.google.api.services.storage.model.BucketAccessControl acl, Map<StorageRpc.Option,?> options) Creates a new ACL entry on the specified bucket.
com.google.api.services.storage.model.ObjectAccessControl	createAcl(com.google.api.services.storage.model.ObjectAccessControl acl) Creates a new ACL entry on the specified object.
RpcBatch	createBatch() Creates an empty batch.
com.google.api.services.storage.model.ObjectAccessControl	createDefaultAcl(com.google.api.services.storage.model.ObjectAccessControl acl) Creates a new default object ACL entry on the specified bucket.
com.google.api.services.storage.model.Notification	createNotification(String bucket, com.google.api.services.storage.model.Notification notification) Creates a notification with the specified entity on the specified bucket.
boolean	delete(com.google.api.services.storage.model.Bucket bucket, Map<StorageRpc.Option,?> options) Deletes the requested bucket.
boolean	delete(com.google.api.services.storage.model.StorageObject blob, Map<StorageRpc.Option,?> options) Deletes the requested storage object.
boolean	deleteAcl(String bucket, String object, Long generation, String entity) Deletes the ACL entry for the specified entity on the specified object.
boolean	deleteAcl(String bucket, String entity, Map<StorageRpc.Option,?> options) Deletes the ACL entry for the specified entity on the specified bucket.
boolean	deleteDefaultAcl(String bucket, String entity) Deletes the default object ACL entry for the specified entity on the specified bucket.
boolean	deleteNotification(String bucket, String notification) Deletes the notification with the specified name on the specified object.
com.google.api.services.storage.model.Bucket	get(com.google.api.services.storage.model.Bucket bucket, Map<StorageRpc.Option,?> options) Returns the requested bucket or null if not found.
com.google.api.services.storage.model.StorageObject	get(com.google.api.services.storage.model.StorageObject object, Map<StorageRpc.Option,?> options) Returns the requested storage object or null if not found.
com.google.api.services.storage.model.ObjectAccessControl	getAcl(String bucket, String object, Long generation, String entity) Returns the ACL entry for the specified entity on the specified object or null if not found.
com.google.api.services.storage.model.BucketAccessControl	getAcl(String bucket, String entity, Map<StorageRpc.Option,?> options) Returns the ACL entry for the specified entity on the specified bucket or null if not found.
com.google.api.services.storage.model.ObjectAccessControl	getDefaultAcl(String bucket, String entity) Returns the default object ACL entry for the specified entity on the specified bucket or null if not found.
com.google.api.services.storage.model.Policy	getIamPolicy(String bucket, Map<StorageRpc.Option,?> options) Returns the IAM policy for the specified bucket.
com.google.api.services.storage.model.ServiceAccount	getServiceAccount(String projectId) Returns the service account associated with the given project.
Tuple<String,Iterable<com.google.api.services.storage.model.Bucket>>	list(Map<StorageRpc.Option,?> options) Lists the project's buckets.
Tuple<String,Iterable<com.google.api.services.storage.model.StorageObject>>	list(String bucket, Map<StorageRpc.Option,?> options) Lists the bucket's blobs.
List<com.google.api.services.storage.model.BucketAccessControl>	listAcls(String bucket, Map<StorageRpc.Option,?> options) Lists the ACL entries for the provided bucket.
List<com.google.api.services.storage.model.ObjectAccessControl>	listAcls(String bucket, String object, Long generation) Lists the ACL entries for the provided object.
List<com.google.api.services.storage.model.ObjectAccessControl>	listDefaultAcls(String bucket) Lists the default object ACL entries for the provided bucket.
List<com.google.api.services.storage.model.Notification>	listNotifications(String bucket) List the notifications for the provided bucket.
byte[]	load(com.google.api.services.storage.model.StorageObject from, Map<StorageRpc.Option,?> options) Reads all the bytes from a storage object.
com.google.api.services.storage.model.Bucket	lockRetentionPolicy(com.google.api.services.storage.model.Bucket bucket, Map<StorageRpc.Option,?> options) Lock retention policy for the provided bucket.
String	open(com.google.api.services.storage.model.StorageObject object, Map<StorageRpc.Option,?> options) Opens a resumable upload channel for a given storage object.
String	open(String signedURL) Opens a resumable upload channel for a given signedURL.
StorageRpc.RewriteResponse	openRewrite(StorageRpc.RewriteRequest rewriteRequest) Sends a rewrite request to open a rewrite channel.
com.google.api.services.storage.model.Bucket	patch(com.google.api.services.storage.model.Bucket bucket, Map<StorageRpc.Option,?> options) Updates bucket information.
com.google.api.services.storage.model.StorageObject	patch(com.google.api.services.storage.model.StorageObject storageObject, Map<StorageRpc.Option,?> options) Updates the storage object's information.
com.google.api.services.storage.model.BucketAccessControl	patchAcl(com.google.api.services.storage.model.BucketAccessControl acl, Map<StorageRpc.Option,?> options) Updates an ACL entry on the specified bucket.
com.google.api.services.storage.model.ObjectAccessControl	patchAcl(com.google.api.services.storage.model.ObjectAccessControl acl) Updates an ACL entry on the specified object.
com.google.api.services.storage.model.ObjectAccessControl	patchDefaultAcl(com.google.api.services.storage.model.ObjectAccessControl acl) Updates a default object ACL entry on the specified bucket.
Tuple<String,byte[]>	read(com.google.api.services.storage.model.StorageObject from, Map<StorageRpc.Option,?> options, long position, int bytes) Reads the given amount of bytes from a storage object at the given position.
com.google.api.services.storage.model.Policy	setIamPolicy(String bucket, com.google.api.services.storage.model.Policy policy, Map<StorageRpc.Option,?> options) Updates the IAM policy for the specified bucket.
com.google.api.services.storage.model.TestIamPermissionsResponse	testIamPermissions(String bucket, List<String> permissions, Map<StorageRpc.Option,?> options) Tests whether the caller holds the specified permissions for the specified bucket.
void	write(String uploadId, byte[] toWrite, int toWriteOffset, long destOffset, int length, boolean last) Writes the provided bytes to a storage object at the provided location.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

DEFAULT_PROJECTION

public static final String DEFAULT_PROJECTION

See Also:

Constant Field Values

NO_ACL_PROJECTION

public static final String NO_ACL_PROJECTION

See Also:

Constant Field Values

Constructor Detail

HttpStorageRpc

public HttpStorageRpc(StorageOptions options)

Method Detail

create

public com.google.api.services.storage.model.Bucket create(com.google.api.services.storage.model.Bucket bucket,
                                                           Map<StorageRpc.Option,?> options)

Description copied from interface: StorageRpc

Creates a new bucket.

Specified by:

create in interface StorageRpc

create

public com.google.api.services.storage.model.StorageObject create(com.google.api.services.storage.model.StorageObject storageObject,
                                                                  InputStream content,
                                                                  Map<StorageRpc.Option,?> options)

Description copied from interface: StorageRpc

Creates a new storage object.

Specified by:

create in interface StorageRpc

list

public Tuple<String,Iterable<com.google.api.services.storage.model.Bucket>> list(Map<StorageRpc.Option,?> options)

Description copied from interface: StorageRpc

Lists the project's buckets.

Specified by:

list in interface StorageRpc

list

public Tuple<String,Iterable<com.google.api.services.storage.model.StorageObject>> list(String bucket,
                                                                                        Map<StorageRpc.Option,?> options)

Description copied from interface: StorageRpc

Lists the bucket's blobs.

Specified by:

list in interface StorageRpc

get

public com.google.api.services.storage.model.Bucket get(com.google.api.services.storage.model.Bucket bucket,
                                                        Map<StorageRpc.Option,?> options)

Description copied from interface: StorageRpc

Returns the requested bucket or null if not found.

Specified by:

get in interface StorageRpc

get

public com.google.api.services.storage.model.StorageObject get(com.google.api.services.storage.model.StorageObject object,
                                                               Map<StorageRpc.Option,?> options)

Description copied from interface: StorageRpc

Returns the requested storage object or null if not found.

Specified by:

get in interface StorageRpc

patch

public com.google.api.services.storage.model.Bucket patch(com.google.api.services.storage.model.Bucket bucket,
                                                          Map<StorageRpc.Option,?> options)

Description copied from interface: StorageRpc

Updates bucket information.

Specified by:

patch in interface StorageRpc

patch

public com.google.api.services.storage.model.StorageObject patch(com.google.api.services.storage.model.StorageObject storageObject,
                                                                 Map<StorageRpc.Option,?> options)

Description copied from interface: StorageRpc

Updates the storage object's information. Original metadata are merged with metadata in the provided storageObject.

Specified by:

patch in interface StorageRpc

delete

public boolean delete(com.google.api.services.storage.model.Bucket bucket,
                      Map<StorageRpc.Option,?> options)

Description copied from interface: StorageRpc

Deletes the requested bucket.

Specified by:

delete in interface StorageRpc

Returns:

true if the bucket was deleted, false if it was not found

delete

public boolean delete(com.google.api.services.storage.model.StorageObject blob,
                      Map<StorageRpc.Option,?> options)

Description copied from interface: StorageRpc

Deletes the requested storage object.

Specified by:

delete in interface StorageRpc

Returns:

true if the storage object was deleted, false if it was not found

compose

public com.google.api.services.storage.model.StorageObject compose(Iterable<com.google.api.services.storage.model.StorageObject> sources,
                                                                   com.google.api.services.storage.model.StorageObject target,
                                                                   Map<StorageRpc.Option,?> targetOptions)

Description copied from interface: StorageRpc

Sends a compose request.

Specified by:

compose in interface StorageRpc

load

public byte[] load(com.google.api.services.storage.model.StorageObject from,
                   Map<StorageRpc.Option,?> options)

Description copied from interface: StorageRpc

Reads all the bytes from a storage object.

Specified by:

load in interface StorageRpc

createBatch

public RpcBatch createBatch()

Description copied from interface: StorageRpc

Creates an empty batch.

Specified by:

createBatch in interface StorageRpc

read

public Tuple<String,byte[]> read(com.google.api.services.storage.model.StorageObject from,
                                 Map<StorageRpc.Option,?> options,
                                 long position,
                                 int bytes)

Description copied from interface: StorageRpc

Reads the given amount of bytes from a storage object at the given position.

Specified by:

read in interface StorageRpc

write

public void write(String uploadId,
                  byte[] toWrite,
                  int toWriteOffset,
                  long destOffset,
                  int length,
                  boolean last)

Description copied from interface: StorageRpc

Writes the provided bytes to a storage object at the provided location.

Specified by:

write in interface StorageRpc

open

public String open(com.google.api.services.storage.model.StorageObject object,
                   Map<StorageRpc.Option,?> options)

Description copied from interface: StorageRpc

Opens a resumable upload channel for a given storage object.

Specified by:

open in interface StorageRpc

open

public String open(String signedURL)

Description copied from interface: StorageRpc

Opens a resumable upload channel for a given signedURL.

Specified by:

open in interface StorageRpc

openRewrite

public StorageRpc.RewriteResponse openRewrite(StorageRpc.RewriteRequest rewriteRequest)

Description copied from interface: StorageRpc

Sends a rewrite request to open a rewrite channel.

Specified by:

openRewrite in interface StorageRpc

continueRewrite

public StorageRpc.RewriteResponse continueRewrite(StorageRpc.RewriteResponse previousResponse)

Description copied from interface: StorageRpc

Continues rewriting on an already open rewrite channel.

Specified by:

continueRewrite in interface StorageRpc

getAcl

public com.google.api.services.storage.model.BucketAccessControl getAcl(String bucket,
                                                                        String entity,
                                                                        Map<StorageRpc.Option,?> options)

Description copied from interface: StorageRpc

Returns the ACL entry for the specified entity on the specified bucket or null if not found.

Specified by:

getAcl in interface StorageRpc

deleteAcl

public boolean deleteAcl(String bucket,
                         String entity,
                         Map<StorageRpc.Option,?> options)

Description copied from interface: StorageRpc

Deletes the ACL entry for the specified entity on the specified bucket.

Specified by:

deleteAcl in interface StorageRpc

Returns:

true if the ACL was deleted, false if it was not found

createAcl

public com.google.api.services.storage.model.BucketAccessControl createAcl(com.google.api.services.storage.model.BucketAccessControl acl,
                                                                           Map<StorageRpc.Option,?> options)

Description copied from interface: StorageRpc

Creates a new ACL entry on the specified bucket.

Specified by:

createAcl in interface StorageRpc

patchAcl

public com.google.api.services.storage.model.BucketAccessControl patchAcl(com.google.api.services.storage.model.BucketAccessControl acl,
                                                                          Map<StorageRpc.Option,?> options)

Description copied from interface: StorageRpc

Updates an ACL entry on the specified bucket.

Specified by:

patchAcl in interface StorageRpc

listAcls

public List<com.google.api.services.storage.model.BucketAccessControl> listAcls(String bucket,
                                                                                Map<StorageRpc.Option,?> options)

Description copied from interface: StorageRpc

Lists the ACL entries for the provided bucket.

Specified by:

listAcls in interface StorageRpc

getDefaultAcl

public com.google.api.services.storage.model.ObjectAccessControl getDefaultAcl(String bucket,
                                                                               String entity)

Description copied from interface: StorageRpc

Returns the default object ACL entry for the specified entity on the specified bucket or null if not found.

Specified by:

getDefaultAcl in interface StorageRpc

deleteDefaultAcl

public boolean deleteDefaultAcl(String bucket,
                                String entity)

Description copied from interface: StorageRpc

Deletes the default object ACL entry for the specified entity on the specified bucket.

Specified by:

deleteDefaultAcl in interface StorageRpc

Returns:

true if the ACL was deleted, false if it was not found

createDefaultAcl

public com.google.api.services.storage.model.ObjectAccessControl createDefaultAcl(com.google.api.services.storage.model.ObjectAccessControl acl)

Description copied from interface: StorageRpc

Creates a new default object ACL entry on the specified bucket.

Specified by:

createDefaultAcl in interface StorageRpc

patchDefaultAcl

public com.google.api.services.storage.model.ObjectAccessControl patchDefaultAcl(com.google.api.services.storage.model.ObjectAccessControl acl)

Description copied from interface: StorageRpc

Updates a default object ACL entry on the specified bucket.

Specified by:

patchDefaultAcl in interface StorageRpc

listDefaultAcls

public List<com.google.api.services.storage.model.ObjectAccessControl> listDefaultAcls(String bucket)

Description copied from interface: StorageRpc

Lists the default object ACL entries for the provided bucket.

Specified by:

listDefaultAcls in interface StorageRpc

getAcl

public com.google.api.services.storage.model.ObjectAccessControl getAcl(String bucket,
                                                                        String object,
                                                                        Long generation,
                                                                        String entity)

Description copied from interface: StorageRpc

Returns the ACL entry for the specified entity on the specified object or null if not found.

Specified by:

getAcl in interface StorageRpc

deleteAcl

public boolean deleteAcl(String bucket,
                         String object,
                         Long generation,
                         String entity)

Description copied from interface: StorageRpc

Deletes the ACL entry for the specified entity on the specified object.

Specified by:

deleteAcl in interface StorageRpc

Returns:

true if the ACL was deleted, false if it was not found

createAcl

public com.google.api.services.storage.model.ObjectAccessControl createAcl(com.google.api.services.storage.model.ObjectAccessControl acl)

Description copied from interface: StorageRpc

Creates a new ACL entry on the specified object.

Specified by:

createAcl in interface StorageRpc

patchAcl

public com.google.api.services.storage.model.ObjectAccessControl patchAcl(com.google.api.services.storage.model.ObjectAccessControl acl)

Description copied from interface: StorageRpc

Updates an ACL entry on the specified object.

Specified by:

patchAcl in interface StorageRpc

listAcls

public List<com.google.api.services.storage.model.ObjectAccessControl> listAcls(String bucket,
                                                                                String object,
                                                                                Long generation)

Description copied from interface: StorageRpc

Lists the ACL entries for the provided object.

Specified by:

listAcls in interface StorageRpc

getIamPolicy

public com.google.api.services.storage.model.Policy getIamPolicy(String bucket,
                                                                 Map<StorageRpc.Option,?> options)

Description copied from interface: StorageRpc

Returns the IAM policy for the specified bucket.

Specified by:

getIamPolicy in interface StorageRpc

setIamPolicy

public com.google.api.services.storage.model.Policy setIamPolicy(String bucket,
                                                                 com.google.api.services.storage.model.Policy policy,
                                                                 Map<StorageRpc.Option,?> options)

Description copied from interface: StorageRpc

Updates the IAM policy for the specified bucket.

Specified by:

setIamPolicy in interface StorageRpc

testIamPermissions

public com.google.api.services.storage.model.TestIamPermissionsResponse testIamPermissions(String bucket,
                                                                                           List<String> permissions,
                                                                                           Map<StorageRpc.Option,?> options)

Description copied from interface: StorageRpc

Tests whether the caller holds the specified permissions for the specified bucket.

Specified by:

testIamPermissions in interface StorageRpc

deleteNotification

public boolean deleteNotification(String bucket,
                                  String notification)

Description copied from interface: StorageRpc

Deletes the notification with the specified name on the specified object.

Specified by:

deleteNotification in interface StorageRpc

Returns:

true if the notification was deleted, false if it was not found

listNotifications

public List<com.google.api.services.storage.model.Notification> listNotifications(String bucket)

Description copied from interface: StorageRpc

List the notifications for the provided bucket.

Specified by:

listNotifications in interface StorageRpc

Returns:

a list of Notification objects that exist on the bucket.

createNotification

public com.google.api.services.storage.model.Notification createNotification(String bucket,
                                                                             com.google.api.services.storage.model.Notification notification)

Description copied from interface: StorageRpc

Creates a notification with the specified entity on the specified bucket.

Specified by:

createNotification in interface StorageRpc

Returns:

the notification that was created.

lockRetentionPolicy

public com.google.api.services.storage.model.Bucket lockRetentionPolicy(com.google.api.services.storage.model.Bucket bucket,
                                                                        Map<StorageRpc.Option,?> options)

Description copied from interface: StorageRpc

Lock retention policy for the provided bucket.

Specified by:

lockRetentionPolicy in interface StorageRpc

Returns:

a Bucket object of the locked bucket

getServiceAccount

public com.google.api.services.storage.model.ServiceAccount getServiceAccount(String projectId)

Description copied from interface: StorageRpc

Returns the service account associated with the given project.

Specified by:

getServiceAccount in interface StorageRpc

Returns:

the ID of the project to fetch the service account for.