com.google.cloud.storage.spi

Class DefaultStorageRpc

java.lang.Object

com.google.cloud.storage.spi.DefaultStorageRpc

All Implemented Interfaces:

StorageRpc

public class DefaultStorageRpc
extends Object
implements StorageRpc

Nested Class Summary

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

StorageRpc.Option, StorageRpc.RewriteRequest, StorageRpc.RewriteResponse, StorageRpc.Tuple<X,Y>

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_PROJECTION

Constructor Summary

Constructors

Constructor and Description
DefaultStorageRpc(StorageOptions options)

Method Summary

Methods

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.
RpcBatch	createBatch() Creates an empty batch.
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.
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.
StorageRpc.Tuple<String,Iterable<com.google.api.services.storage.model.Bucket>>	list(Map<StorageRpc.Option,?> options) Lists the project's buckets.
StorageRpc.Tuple<String,Iterable<com.google.api.services.storage.model.StorageObject>>	list(String bucket, Map<StorageRpc.Option,?> options) Lists the bucket's blobs.
byte[]	load(com.google.api.services.storage.model.StorageObject from, 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.
StorageRpc.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.
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

Constructor Detail

DefaultStorageRpc

public DefaultStorageRpc(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 StorageRpc.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 StorageRpc.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 StorageRpc.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

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