Class BlobStore

java.lang.Object
ecmwf.ecpds.mover.plugin.http.BlobStore
All Implemented Interfaces:
Closeable, AutoCloseable
public class BlobStore extends Object implements Closeable
The Class BlobStore.

  • Method Details

    • containerExists

      public boolean containerExists(String containerName)
      Container exists.
      Parameters:
      containerName - the container name
      Returns:
      true, if successful

    • getContainerAccess

      public ContainerAccess getContainerAccess(String containerName)
      Gets the container access.
      Parameters:
      containerName - the container name
      Returns:
      the container access

    • list

      public List<StorageMetadata> list() throws S3Exception
      List.
      Returns:
      the list
      Throws:
      S3Exception - the s 3 exception

    • list

      public List<StorageMetadata> list(String containerName, ListContainerOptions options, String prefix, int maxKeys) throws S3Exception
      List.
      Parameters:
      containerName - the container name
      options - the options
      prefix - the prefix
      maxKeys - the max keys
      Returns:
      the list
      Throws:
      S3Exception - the s 3 exception

    • removeBlobs

      public void removeBlobs(String containerName, Collection<String> blobNames) throws S3Exception
      Removes the blobs.
      Parameters:
      containerName - the container name
      blobNames - the blob names
      Throws:
      S3Exception - the s 3 exception

    • blobMetadata

      public BlobMetadata blobMetadata(String containerName, String blobName) throws S3Exception
      Blob metadata.
      Parameters:
      containerName - the container name
      blobName - the blob name
      Returns:
      the blob metadata
      Throws:
      S3Exception - the s 3 exception

    • getBlob

      public Blob getBlob(String containerName, String blobName, GetOptions options) throws S3Exception, IOException
      Gets the blob.
      Parameters:
      containerName - the container name
      blobName - the blob name
      options - the options
      Returns:
      the blob
      Throws:
      S3Exception - the s 3 exception
      IOException - Signals that an I/O exception has occurred.

    • putBlob

      public String putBlob(String containerName, String blobName, InputStream is) throws S3Exception, IOException
      Put blob. Upload data from the given input stream and store it at containerName/blobName. Mirrors the write path used by the REST server (RESTServer.dataFilePost). After the transfer completes a ProxyEvent is recorded so the upload appears in the transfer history, and the ECPDS-assigned ETag is returned.
      Parameters:
      containerName - the container name
      blobName - the blob name
      is - the input stream supplying the object data
      Returns:
      the ETag string assigned by ECPDS for the stored object
      Throws:
      S3Exception - the s 3 exception
      IOException - Signals that an I/O exception has occurred.

    • close

      public void close() throws IOException
      Close.
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
      Throws:
      IOException