com.google.cloud.storage.spi.v1

Interface StorageRpc

All Superinterfaces:

ServiceRpc

All Known Implementing Classes:

HttpStorageRpc

public interface StorageRpc
extends 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) 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.
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 entity) Deletes the ACL entry for the specified entity on the specified bucket.
boolean	deleteAcl(String bucket, String object, Long generation, String entity) Deletes the ACL entry for the specified entity on the specified object.
boolean	deleteDefaultAcl(String bucket, String entity) Deletes the default object ACL entry for the specified entity on the specified bucket.
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.BucketAccessControl	getAcl(String bucket, String entity) Returns the ACL entry for the specified entity on the specified bucket 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.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) Returns the IAM policy for the specified bucket.
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) 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.
byte[]	load(com.google.api.services.storage.model.StorageObject storageObject, Map<StorageRpc.Option,?> options) Reads all the bytes from a storage object.
String	open(com.google.api.services.storage.model.StorageObject object, Map<StorageRpc.Option,?> options) Opens a resumable upload channel for a given storage object.
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) 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) Updates the IAM policy for the specified bucket.
com.google.api.services.storage.model.TestIamPermissionsResponse	testIamPermissions(String bucket, List<String> permissions) 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.

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

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

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

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

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

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)

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)

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)

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)

Updates an ACL entry on the specified bucket.

Throws:

StorageException - upon failure

listAcls

List<com.google.api.services.storage.model.BucketAccessControl> listAcls(String bucket)

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

getIamPolicy

com.google.api.services.storage.model.Policy getIamPolicy(String bucket)

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)

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)

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

Throws:

StorageException - upon failure