com.google.cloud.storage.spi.v1

Interface StorageRpc

All Superinterfaces:

com.google.cloud.ServiceRpc

All Known Implementing Classes:

HttpStorageRpc

@InternalApi
public interface StorageRpc
extends com.google.cloud.ServiceRpc

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	StorageRpc.Option
static class	StorageRpc.RewriteRequest
static class	StorageRpc.RewriteResponse

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 object, 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.HmacKey	createHmacKey(String serviceAccountEmail, Map<StorageRpc.Option,?> options) Creates a new HMAC key for the provided service account email.
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 object, 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.
void	deleteHmacKey(com.google.api.services.storage.model.HmacKeyMetadata hmacKeyMetadata, Map<StorageRpc.Option,?> options) Deletes the HMAC key associated with the provided metadata object.
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.HmacKeyMetadata	getHmacKey(String accessId, Map<StorageRpc.Option,?> options) Returns the HMAC key associated with the provided access id.
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.
com.google.cloud.Tuple<String,Iterable<com.google.api.services.storage.model.Bucket>>	list(Map<StorageRpc.Option,?> options) Lists the project's buckets.
com.google.cloud.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.
com.google.cloud.Tuple<String,Iterable<com.google.api.services.storage.model.HmacKeyMetadata>>	listHmacKeys(Map<StorageRpc.Option,?> options) Lists the HMAC keys for the provided service account email.
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 storageObject, 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.
com.google.cloud.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.
long	read(com.google.api.services.storage.model.StorageObject from, Map<StorageRpc.Option,?> options, long position, OutputStream outputStream) Reads all the bytes from a storage object at the given position in to outputstream using direct download.
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.
com.google.api.services.storage.model.HmacKeyMetadata	updateHmacKey(com.google.api.services.storage.model.HmacKeyMetadata hmacKeyMetadata, Map<StorageRpc.Option,?> options) Updates an HMAC key for the provided metadata object and returns the updated object.
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.

Method Detail

create

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

Creates a new bucket.

Throws:

StorageException - upon failure

create

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

Creates a new storage object.

Throws:

StorageException - upon failure

list

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

Lists the project's buckets.

Throws:

StorageException - upon failure

list

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

Lists the bucket's blobs.

Throws:

StorageException - upon failure

get

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.

Throws:

StorageException - upon failure

get

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.

Throws:

StorageException - upon failure

patch

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

Updates bucket information.

Throws:

StorageException - upon failure

patch

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. Original metadata are merged with metadata in the provided storageObject.

Throws:

StorageException - upon failure

delete

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

Deletes the requested bucket.

Returns:

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

Throws:

StorageException - upon failure

delete

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

Deletes the requested storage object.

Returns:

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

Throws:

StorageException - upon failure

createBatch

RpcBatch createBatch()

Creates an empty batch.

compose

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.

Throws:

StorageException - upon failure

load

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

Reads all the bytes from a storage object.

Throws:

StorageException - upon failure

read

com.google.cloud.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.

Throws:

StorageException - upon failure

read

long read(com.google.api.services.storage.model.StorageObject from,
          Map<StorageRpc.Option,?> options,
          long position,
          OutputStream outputStream)

Reads all the bytes from a storage object at the given position in to outputstream using direct download.

Returns:

number of bytes downloaded, returns 0 if position higher than length.

Throws:

StorageException - upon failure

open

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

Opens a resumable upload channel for a given storage object.

Throws:

StorageException - upon failure

open

String open(String signedURL)

Opens a resumable upload channel for a given signedURL.

Throws:

StorageException - upon failure

write

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.

Throws:

StorageException - upon failure

openRewrite

StorageRpc.RewriteResponse openRewrite(StorageRpc.RewriteRequest rewriteRequest)

Sends a rewrite request to open a rewrite channel.

Throws:

StorageException - upon failure

continueRewrite

StorageRpc.RewriteResponse continueRewrite(StorageRpc.RewriteResponse previousResponse)

Continues rewriting on an already open rewrite channel.

Throws:

StorageException - upon failure

getAcl

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.

Throws:

StorageException - upon failure

deleteAcl

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

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

Returns:

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

Throws:

StorageException - upon failure

createAcl

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.

Throws:

StorageException - upon failure

patchAcl

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.

Throws:

StorageException - upon failure

listAcls

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

Lists the ACL entries for the provided bucket.

Throws:

StorageException - upon failure

getDefaultAcl

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.

Throws:

StorageException - upon failure

deleteDefaultAcl

boolean deleteDefaultAcl(String bucket,
                         String entity)

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

Returns:

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

Throws:

StorageException - upon failure

createDefaultAcl

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.

Throws:

StorageException - upon failure

patchDefaultAcl

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.

Throws:

StorageException - upon failure

listDefaultAcls

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

Lists the default object ACL entries for the provided bucket.

Throws:

StorageException - upon failure

getAcl

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.

Throws:

StorageException - upon failure

deleteAcl

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

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

Returns:

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

Throws:

StorageException - upon failure

createAcl

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.

Throws:

StorageException - upon failure

patchAcl

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

Updates an ACL entry on the specified object.

Throws:

StorageException - upon failure

listAcls

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

Lists the ACL entries for the provided object.

Throws:

StorageException - upon failure

createHmacKey

com.google.api.services.storage.model.HmacKey createHmacKey(String serviceAccountEmail,
                                                            Map<StorageRpc.Option,?> options)

Creates a new HMAC key for the provided service account email.

Throws:

StorageException - upon failure

listHmacKeys

com.google.cloud.Tuple<String,Iterable<com.google.api.services.storage.model.HmacKeyMetadata>> listHmacKeys(Map<StorageRpc.Option,?> options)

Lists the HMAC keys for the provided service account email.

Throws:

StorageException - upon failure

updateHmacKey

com.google.api.services.storage.model.HmacKeyMetadata updateHmacKey(com.google.api.services.storage.model.HmacKeyMetadata hmacKeyMetadata,
                                                                    Map<StorageRpc.Option,?> options)

Updates an HMAC key for the provided metadata object and returns the updated object. Only updates the State field.

Throws:

StorageException - upon failure

getHmacKey

com.google.api.services.storage.model.HmacKeyMetadata getHmacKey(String accessId,
                                                                 Map<StorageRpc.Option,?> options)

Returns the HMAC key associated with the provided access id.

Throws:

StorageException - upon failure

deleteHmacKey

void deleteHmacKey(com.google.api.services.storage.model.HmacKeyMetadata hmacKeyMetadata,
                   Map<StorageRpc.Option,?> options)

Deletes the HMAC key associated with the provided metadata object.

Throws:

StorageException - upon failure

getIamPolicy

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

Returns the IAM policy for the specified bucket.

Throws:

StorageException - upon failure

setIamPolicy

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.

Throws:

StorageException - upon failure

testIamPermissions

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.

Throws:

StorageException - upon failure

deleteNotification

boolean deleteNotification(String bucket,
                           String notification)

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

Returns:

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

Throws:

StorageException - upon failure

listNotifications

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

List the notifications for the provided bucket.

Returns:

a list of Notification objects that exist on the bucket.

Throws:

StorageException - upon failure

createNotification

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.

Returns:

the notification that was created.

Throws:

StorageException - upon failure

lockRetentionPolicy

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.

Returns:

a Bucket object of the locked bucket

Throws:

StorageException - upon failure

getServiceAccount

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

Returns the service account associated with the given project.

Returns:

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

Throws:

StorageException - upon failure