Packages

object BlobService

Scala API for BlobService operations.

Source
BlobService.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. BlobService
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  6. def createContainer(objectPath: String, requestBuilder: CreateContainer): Source[Option[ObjectMetadata], NotUsed]

    Create container.

    Create container.

    objectPath

    name of the container

    requestBuilder

    builder to build createContainer request

    returns

    A Source containing an scala.Option of akka.stream.alpakka.azure.storage.ObjectMetadata, will be scala.None in case the object does not exist

  7. def deleteBlob(objectPath: String, requestBuilder: DeleteBlob): Source[Option[ObjectMetadata], NotUsed]

    Deletes blob.

    Deletes blob.

    objectPath

    path of the object, should start with "/" and separated by /, e.g. /container/blob

    requestBuilder

    builder to build deleteBlob request

    returns

    A Source containing an scala.Option of akka.stream.alpakka.azure.storage.ObjectMetadata, will be scala.None in case the object does not exist

  8. def deleteContainer(objectPath: String, requestBuilder: DeleteContainer): Source[Option[ObjectMetadata], NotUsed]

    Delete container.

    Delete container.

    objectPath

    name of the container

    requestBuilder

    builder to build deleteContainer request

    returns

    A Source containing an scala.Option of akka.stream.alpakka.azure.storage.ObjectMetadata, will be scala.None in case the object does not exist

  9. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  10. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  11. def getBlob(objectPath: String, requestBuilder: GetBlob): Source[ByteString, Future[ObjectMetadata]]

    Gets blob representing objectPath with specified range (if applicable).

    Gets blob representing objectPath with specified range (if applicable).

    objectPath

    path of the object, should start with "/" and separated by /, e.g. /container/blob

    requestBuilder

    builder to build getBlob request

    returns

    A akka.stream.scaladsl.Source containing the objects data as a akka.util.ByteString along with a materialized value containing the akka.stream.alpakka.azure.storage.ObjectMetadata

  12. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  13. def getProperties(objectPath: String, requestBuilder: GetProperties): Source[Option[ObjectMetadata], NotUsed]

    Gets blob properties.

    Gets blob properties.

    objectPath

    path of the object, should start with "/" and separated by /, e.g. /container/blob

    requestBuilder

    versionId of the blob (if applicable)

    returns

    A Source containing an scala.Option of akka.stream.alpakka.azure.storage.ObjectMetadata, will be scala.None in case the object does not exist

  14. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  15. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  16. def listBlobs(objectPath: String, requestBuilder: ListBlobs): Source[BlobItem, NotUsed]

    Lists blobs in a container.

    Lists blobs in a container.

    objectPath

    container name, e.g. my-container

    requestBuilder

    builder to configure the list request (prefix, delimiter, maxResults)

    returns

    A Source of akka.stream.alpakka.azure.storage.BlobItem elements, automatically paginated

  17. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  18. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  19. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  20. def putAppendBlock(objectPath: String, requestBuilder: PutAppendBlock): Source[Option[ObjectMetadata], NotUsed]

    Put (Create) Append Blob.

    Put (Create) Append Blob.

    objectPath

    path of the object, should start with "/" and separated by /, e.g. /container/blob

    returns

    A Source containing an scala.Option of akka.stream.alpakka.azure.storage.ObjectMetadata, will be scala.None in case the object does not exist

  21. def putBlockBlob(objectPath: String, requestBuilder: PutBlockBlob, payload: Source[ByteString, _]): Source[Option[ObjectMetadata], NotUsed]

    Put Block blob.

    Put Block blob.

    objectPath

    path of the object, should start with "/" and separated by /, e.g. /container/blob

    requestBuilder

    builder to build putBlockBlob request

    payload

    actual payload, a Source of ByteString

    returns

    A Source containing an scala.Option of akka.stream.alpakka.azure.storage.ObjectMetadata, will be scala.None in case the object does not exist

  22. def putBlockBlobStreaming(objectPath: String, requestBuilder: PutBlockBlobStreaming): Sink[ByteString, Future[ObjectMetadata]]

    Uploads a block blob using streaming Put Block / Put Block List operations.

    Uploads a block blob using streaming Put Block / Put Block List operations. The incoming bytes are grouped into blocks of the configured size, each uploaded individually, then committed as a single blob. Unlike putBlockBlob, this does not require knowing the content length upfront.

    Note: Azure limits a block blob to 50,000 blocks. With the default block size of 4 MB this allows blobs up to ~195 GB. Adjust the block size via PutBlockBlobStreaming.withBlockSize for larger blobs.

    objectPath

    path of the object, should start with "/" and separated by /, e.g. /container/blob

    requestBuilder

    builder to configure block size, content type, optional lease and SSE

    returns

    A akka.stream.scaladsl.Sink consuming ByteString elements and materializing a scala.concurrent.Future of akka.stream.alpakka.azure.storage.ObjectMetadata from the Put Block List response

  23. def putPageBlock(objectPath: String, requestBuilder: PutPageBlock): Source[Option[ObjectMetadata], NotUsed]

    Put (Create) Page Blob.

    Put (Create) Page Blob.

    objectPath

    path of the object, should start with "/" and separated by /, e.g. /container/blob

    requestBuilder

    builder to build putAppendBlob request

    returns

    A Source containing an scala.Option of akka.stream.alpakka.azure.storage.ObjectMetadata, will be scala.None in case the object does not exist

  24. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  25. def toString(): String
    Definition Classes
    AnyRef → Any
  26. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  27. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  28. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

Inherited from AnyRef

Inherited from Any

Ungrouped