org.jclouds.azureblob.blobstore

Class AzureAsyncBlobStore

java.lang.Object

org.jclouds.blobstore.internal.BaseAsyncBlobStore

org.jclouds.azureblob.blobstore.AzureAsyncBlobStore

All Implemented Interfaces:

AsyncBlobStore

@Singleton
public class AzureAsyncBlobStore
extends BaseAsyncBlobStore

Author:

Adrian Cole

Field Summary

Fields inherited from class org.jclouds.blobstore.internal.BaseAsyncBlobStore

blobUtils, context, defaultLocation, locations, service

Method Summary

Methods

Modifier and Type	Method and Description
com.google.common.util.concurrent.ListenableFuture<Boolean>	blobExists(String container, String name) This implementation invokes AzureBlobAsyncClient.blobExists(java.lang.String, java.lang.String)
com.google.common.util.concurrent.ListenableFuture<BlobMetadata>	blobMetadata(String container, String key) This implementation invokes AzureBlobAsyncClient.getBlobProperties(java.lang.String, java.lang.String)
com.google.common.util.concurrent.ListenableFuture<Boolean>	containerExists(String container) This implementation invokes AzureBlobAsyncClient.containerExists(java.lang.String)
com.google.common.util.concurrent.ListenableFuture<Boolean>	createContainerInLocation(Location location, String container) This implementation invokes AzureBlobAsyncClient.createContainer(java.lang.String, org.jclouds.azureblob.options.CreateContainerOptions...)
com.google.common.util.concurrent.ListenableFuture<Boolean>	createContainerInLocation(Location location, String container, CreateContainerOptions options)
protected boolean	deleteAndVerifyContainerGone(String container)
com.google.common.util.concurrent.ListenableFuture<Void>	deleteContainer(String container) This implementation invokes AzureBlobAsyncClient.deleteContainer(java.lang.String)
com.google.common.util.concurrent.ListenableFuture<Blob>	getBlob(String container, String key, GetOptions options) This implementation invokes AzureBlobAsyncClient.getBlob(java.lang.String, java.lang.String, org.jclouds.http.options.GetOptions...)
com.google.common.util.concurrent.ListenableFuture<PageSet<? extends StorageMetadata>>	list() This implementation invokes AzureBlobAsyncClient.listContainers(org.jclouds.azure.storage.options.ListOptions...) with the ListOptions.includeMetadata() option.
com.google.common.util.concurrent.ListenableFuture<PageSet<? extends StorageMetadata>>	list(String container, ListContainerOptions options) This implementation invokes AzureBlobAsyncClient#listBucket
com.google.common.util.concurrent.ListenableFuture<String>	putBlob(String container, Blob blob) This implementation invokes AzureBlobAsyncClient.putBlob(java.lang.String, org.jclouds.azureblob.domain.AzureBlob)
com.google.common.util.concurrent.ListenableFuture<String>	putBlob(String container, Blob blob, PutOptions options)
com.google.common.util.concurrent.ListenableFuture<Void>	removeBlob(String container, String key) This implementation invokes AzureBlobAsyncClient#deleteObject

Methods inherited from class org.jclouds.blobstore.internal.BaseAsyncBlobStore

blobBuilder, clearContainer, clearContainer, countBlobs, countBlobs, createDirectory, deleteAndEnsurePathGone, deleteDirectory, directoryExists, getBlob, getContext, list, listAssignableLocations

Methods inherited from class java.lang.Object

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

Method Detail

list

public com.google.common.util.concurrent.ListenableFuture<PageSet<? extends StorageMetadata>> list()

This implementation invokes AzureBlobAsyncClient.listContainers(org.jclouds.azure.storage.options.ListOptions...) with the ListOptions.includeMetadata() option.

See Also:

BlobStore.list()

containerExists

public com.google.common.util.concurrent.ListenableFuture<Boolean> containerExists(String container)

This implementation invokes AzureBlobAsyncClient.containerExists(java.lang.String)

Parameters:

container - container name

See Also:

BlobStore.containerExists(java.lang.String)

createContainerInLocation

public com.google.common.util.concurrent.ListenableFuture<Boolean> createContainerInLocation(Location location,
                                                                                    String container)

This implementation invokes AzureBlobAsyncClient.createContainer(java.lang.String, org.jclouds.azureblob.options.CreateContainerOptions...)

Parameters:

location - ignored

container - container name

See Also:

BlobStore.createContainerInLocation(Location, String)

list

public com.google.common.util.concurrent.ListenableFuture<PageSet<? extends StorageMetadata>> list(String container,
                                                                                          ListContainerOptions options)

This implementation invokes AzureBlobAsyncClient#listBucket

Parameters:

container - container name

See Also:

BlobStore.list(String, ListContainerOptions)

deleteContainer

public com.google.common.util.concurrent.ListenableFuture<Void> deleteContainer(String container)

This implementation invokes AzureBlobAsyncClient.deleteContainer(java.lang.String)

Specified by:

deleteContainer in interface AsyncBlobStore

Overrides:

deleteContainer in class BaseAsyncBlobStore

Parameters:

container - container name

See Also:

BlobStore.deleteContainer(java.lang.String)

getBlob

public com.google.common.util.concurrent.ListenableFuture<Blob> getBlob(String container,
                                                               String key,
                                                               GetOptions options)

This implementation invokes AzureBlobAsyncClient.getBlob(java.lang.String, java.lang.String, org.jclouds.http.options.GetOptions...)

Parameters:

container - container name

key - blob key

See Also:

BlobStore.getBlob(String, String, GetOptions)

putBlob

public com.google.common.util.concurrent.ListenableFuture<String> putBlob(String container,
                                                                 Blob blob)

This implementation invokes AzureBlobAsyncClient.putBlob(java.lang.String, org.jclouds.azureblob.domain.AzureBlob)

Parameters:

container - container name

blob - blob

See Also:

BlobStore.putBlob(String,Blob)

removeBlob

public com.google.common.util.concurrent.ListenableFuture<Void> removeBlob(String container,
                                                                  String key)

This implementation invokes AzureBlobAsyncClient#deleteObject

Parameters:

container - container name

key - blob key

See Also:

BlobStore.removeBlob(java.lang.String, java.lang.String)

blobExists

public com.google.common.util.concurrent.ListenableFuture<Boolean> blobExists(String container,
                                                                     String name)

This implementation invokes AzureBlobAsyncClient.blobExists(java.lang.String, java.lang.String)

Parameters:

container - bucket name

credential - object key

See Also:

BlobStore.blobExists(java.lang.String, java.lang.String)

blobMetadata

public com.google.common.util.concurrent.ListenableFuture<BlobMetadata> blobMetadata(String container,
                                                                            String key)

This implementation invokes AzureBlobAsyncClient.getBlobProperties(java.lang.String, java.lang.String)

Parameters:

container - container name

key - blob key

See Also:

BlobStore.blobMetadata(java.lang.String, java.lang.String)

deleteAndVerifyContainerGone

protected boolean deleteAndVerifyContainerGone(String container)

Specified by:

deleteAndVerifyContainerGone in class BaseAsyncBlobStore

putBlob

public com.google.common.util.concurrent.ListenableFuture<String> putBlob(String container,
                                                                 Blob blob,
                                                                 PutOptions options)

See Also:

BlobStore.putBlob(String,Blob,PutOptions)

createContainerInLocation

public com.google.common.util.concurrent.ListenableFuture<Boolean> createContainerInLocation(Location location,
                                                                                    String container,
                                                                                    CreateContainerOptions options)

See Also:

BlobStore.createContainerInLocation(Location,String,CreateContainerOptions)