org.jclouds.azureblob.blobstore
Class AzureAsyncBlobStore

java.lang.Object
  extended by org.jclouds.blobstore.internal.BaseAsyncBlobStore
      extended by 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
 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, newBlob
 
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)


Copyright © 2009-2011 jclouds. All Rights Reserved.