object FileService
- Alphabetic
- By Inheritance
- FileService
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clearRange(objectPath: String, requestBuilder: ClearFileRange): Source[Optional[ObjectMetadata], NotUsed]
Clears specified range from the file.
Clears specified range from the file.
- objectPath
path of the object, should start with "/" and separated by
/, e.g./share/my-directory/blob- requestBuilder
builder to build clearRange 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
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- def createDirectory(directoryPath: String, requestBuilder: CreateDirectory): Source[Optional[ObjectMetadata], NotUsed]
Create directory.
Create directory.
- directoryPath
path of the directory to be created, e.g.,
myshare/myparentdirectorypath/mydirectory- requestBuilder
builder to build createDirectory 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
- def createFile(objectPath: String, requestBuilder: CreateFile): Source[Optional[ObjectMetadata], NotUsed]
Creates a file.
Creates a file.
- objectPath
path of the object, should start with "/" and separated by
/, e.g./share/my-directory/blob- requestBuilder
builder to build createFile 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
- def deleteDirectory(directoryPath: String, requestBuilder: DeleteDirectory): Source[Optional[ObjectMetadata], NotUsed]
Delete directory.
Delete directory.
- directoryPath
path of the directory to be deleted, e.g.,
myshare/myparentdirectorypath/mydirectory- requestBuilder
builder to build deleteDirectory 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
- def deleteFile(objectPath: String, requestBuilder: DeleteFile): Source[Optional[ObjectMetadata], NotUsed]
Deletes file.
Deletes file.
- objectPath
path of the object, should start with "/" and separated by
/, e.g./share/my-directory/blob- requestBuilder
builder to build getFile proroperties 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
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def getFile(objectPath: String, requestBuilder: GetFile): Source[ByteString, CompletionStage[ObjectMetadata]]
Gets file representing
objectPathwith specified range (if applicable).Gets file representing
objectPathwith specified range (if applicable).- objectPath
path of the object, should start with "/" and separated by
/, e.g./share/my-directory/blob- requestBuilder
builder to build getBlob request
- returns
A akka.stream.javadsl.Source containing the objects data as a akka.util.ByteString along with a materialized value containing the akka.stream.alpakka.azure.storage.ObjectMetadata
- def getProperties(objectPath: String, requestBuilder: GetProperties): Source[Optional[ObjectMetadata], NotUsed]
Gets file properties.
Gets file properties.
- objectPath
path of the object, should start with "/" and separated by
/, e.g./share/my-directory/blob- requestBuilder
builder to build getFile proroperties 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
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def listFiles(objectPath: String, requestBuilder: ListFiles): Source[FileShareEntry, NotUsed]
Lists files and directories in an Azure File Share directory.
Lists files and directories in an Azure File Share directory.
- objectPath
share and directory path, e.g.
my-shareormy-share/my-directory- requestBuilder
builder to configure the list request (prefix, maxResults)
- returns
A Source of akka.stream.alpakka.azure.storage.FileShareEntry elements (either akka.stream.alpakka.azure.storage.ShareFileItem or akka.stream.alpakka.azure.storage.ShareDirectoryItem), automatically paginated
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- def updateRange(objectPath: String, requestBuilder: UpdateFileRange, payload: Source[ByteString, _]): Source[Optional[ObjectMetadata], NotUsed]
Updates file on the specified range.
Updates file on the specified range.
- objectPath
path of the object, should start with "/" and separated by
/, e.g./share/my-directory/blob- requestBuilder
range of bytes to be written
- 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
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()