class AmazonS3ClientMaterialized extends AmazonS3Client
Additional functions which materialize stream to Future.
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- AmazonS3ClientMaterialized
- AmazonS3Client
- AmazonS3Wrapper
- MethodWrapper
- AnyRef
- Any
Implicitly
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
Visibility
- Public
- All
Instance Constructors
- new AmazonS3ClientMaterialized(client: AmazonS3, executorService: ExecutorService, flowMaterializer: ActorMaterializer)
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
def
+(other: String): String
- Implicit
- This member is added by an implicit conversion from AmazonS3ClientMaterialized to any2stringadd[AmazonS3ClientMaterialized] performed by method any2stringadd in scala.Predef.
- Definition Classes
- any2stringadd
-
def
->[B](y: B): (AmazonS3ClientMaterialized, B)
- Implicit
- This member is added by an implicit conversion from AmazonS3ClientMaterialized to ArrowAssoc[AmazonS3ClientMaterialized] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
- Annotations
- @inline()
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
abortMultipartUpload(req: AbortMultipartUploadRequest): Future[Unit]
- Definition Classes
- AmazonS3Wrapper
- See also
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
val
client: AmazonS3
- Definition Classes
- AmazonS3Client → AmazonS3Wrapper
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
def
completeMultipartUpload(completeMultipartUploadRequest: CompleteMultipartUploadRequest): Future[CompleteMultipartUploadResult]
- Definition Classes
- AmazonS3Wrapper
- See also
-
def
copyObject(sourceBucketName: String, sourceKey: String, destinationBucketName: String, destinationKey: String): Future[CopyObjectResult]
- Definition Classes
- AmazonS3Wrapper
- See also
-
def
copyObject(copyObjectRequest: CopyObjectRequest): Future[CopyObjectResult]
- Definition Classes
- AmazonS3Wrapper
- See also
-
def
copyPart(copyPartRequest: CopyPartRequest): Future[CopyPartResult]
- Definition Classes
- AmazonS3Wrapper
- See also
-
def
createBucket(bucketName: String, region: String): Future[Bucket]
- Definition Classes
- AmazonS3Wrapper
- See also
-
def
createBucket(bucketName: String, region: Region): Future[Bucket]
- Definition Classes
- AmazonS3Wrapper
- See also
-
def
createBucket(bucketName: String): Future[Bucket]
- Definition Classes
- AmazonS3Wrapper
- See also
-
def
createBucket(createBucketRequest: CreateBucketRequest): Future[Bucket]
- Definition Classes
- AmazonS3Wrapper
- See also
-
def
deleteBucket(bucketName: String): Future[Unit]
- Definition Classes
- AmazonS3Wrapper
- See also
-
def
deleteBucket(deleteBucketRequest: DeleteBucketRequest): Future[Unit]
- Definition Classes
- AmazonS3Wrapper
- See also
-
def
deleteObject(bucketName: String, key: String): Future[Unit]
- Definition Classes
- AmazonS3Wrapper
- See also
-
def
deleteObject(deleteObjectRequest: DeleteObjectRequest): Future[Unit]
- Definition Classes
- AmazonS3Wrapper
- See also
- def deleteObjects(bucket: String, commonPrefix: String): Future[Seq[DeletedObject]]
-
def
deleteObjects(bucketName: String, keys: String*): Future[Seq[DeletedObject]]
- Definition Classes
- AmazonS3Wrapper
- See also
-
def
deleteObjects(deleteObjectsRequest: DeleteObjectsRequest): Future[Seq[DeletedObject]]
- Definition Classes
- AmazonS3Wrapper
- See also
-
def
deleteVersion(bucketName: String, key: String, versionId: String): Future[Unit]
- Definition Classes
- AmazonS3Wrapper
- See also
-
def
deleteVersion(deleteVersionRequest: DeleteVersionRequest): Future[Unit]
- Definition Classes
- AmazonS3Wrapper
- See also
-
def
doesBucketExist(bucketName: String): Future[Boolean]
- Definition Classes
- AmazonS3Wrapper
- See also
-
implicit
val
ec: ExecutionContextExecutorService
- Definition Classes
- AmazonS3Wrapper
-
implicit
lazy val
ecForBlockingOps: ExecutionContextForBlockingOps
- Definition Classes
- AmazonS3Client
-
def
ensuring(cond: (AmazonS3ClientMaterialized) ⇒ Boolean, msg: ⇒ Any): AmazonS3ClientMaterialized
- Implicit
- This member is added by an implicit conversion from AmazonS3ClientMaterialized to Ensuring[AmazonS3ClientMaterialized] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: (AmazonS3ClientMaterialized) ⇒ Boolean): AmazonS3ClientMaterialized
- Implicit
- This member is added by an implicit conversion from AmazonS3ClientMaterialized to Ensuring[AmazonS3ClientMaterialized] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean, msg: ⇒ Any): AmazonS3ClientMaterialized
- Implicit
- This member is added by an implicit conversion from AmazonS3ClientMaterialized to Ensuring[AmazonS3ClientMaterialized] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean): AmazonS3ClientMaterialized
- Implicit
- This member is added by an implicit conversion from AmazonS3ClientMaterialized to Ensuring[AmazonS3ClientMaterialized] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
val
executorService: ExecutorService
- Definition Classes
- AmazonS3Client → AmazonS3Wrapper → MethodWrapper
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
- implicit val flowMaterializer: ActorMaterializer
-
def
formatted(fmtstr: String): String
- Implicit
- This member is added by an implicit conversion from AmazonS3ClientMaterialized to StringFormat[AmazonS3ClientMaterialized] performed by method StringFormat in scala.Predef.
- Definition Classes
- StringFormat
- Annotations
- @inline()
-
def
generatePresignedUrlRequest(generatePresignedUrlRequest: GeneratePresignedUrlRequest): Future[URL]
- Definition Classes
- AmazonS3Wrapper
- See also
-
def
getBucketLocation(bucketName: String): Future[String]
- Definition Classes
- AmazonS3Wrapper
- See also
-
def
getBucketLocation(getBucketLocationRequest: GetBucketLocationRequest): Future[String]
- Definition Classes
- AmazonS3Wrapper
- See also
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
-
def
getFile(bucket: String, key: String): Future[ByteString]
Get a S3 file.
Get a S3 file.
- returns
binary file
-
def
getFileAsStream(bucket: String, key: String, inputStreamTransform: (InputStream) ⇒ InputStream = identity): Source[ByteString, NotUsed]
Stream a S3 file.
Stream a S3 file.
- bucket
the bucket name
- key
the key of file
- inputStreamTransform
optional inputstream transformation (for example GZIP decompression, ...)
- Definition Classes
- AmazonS3Client
-
def
getMultipartFileAsStream(bucket: String, prefix: String, inputStreamTransform: (InputStream) ⇒ InputStream = identity): Source[ByteString, NotUsed]
Stream sequentially a SE multipart file.
Stream sequentially a SE multipart file.
- bucket
S3 bucket
- prefix
S3 prefix. Files of path prefix* will be taken into account.
- inputStreamTransform
optional inputstream transformation (for example GZIP decompression, ...)
- Definition Classes
- AmazonS3Client
-
def
getObject(getObjectRequest: GetObjectRequest, destinationFile: File): Future[ObjectMetadata]
- Definition Classes
- AmazonS3Wrapper
- See also
-
def
getObject(bucketName: String, key: String): Future[S3Object]
- Definition Classes
- AmazonS3Wrapper
- See also
-
def
getObject(getObjectRequest: GetObjectRequest): Future[S3Object]
- Definition Classes
- AmazonS3Wrapper
- See also
-
def
getObjectMetadata(bucketName: String, key: String): Future[ObjectMetadata]
- Definition Classes
- AmazonS3Wrapper
- See also
-
def
getObjectMetadata(getObjectMetadataRequest: GetObjectMetadataRequest): Future[ObjectMetadata]
- Definition Classes
- AmazonS3Wrapper
- See also
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
-
def
initiateMultipartUpload(initiateMultipartUploadRequest: InitiateMultipartUploadRequest): Future[InitiateMultipartUploadResult]
- Definition Classes
- AmazonS3Wrapper
- See also
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
listBuckets(): Future[Seq[Bucket]]
- Definition Classes
- AmazonS3Wrapper
- See also
-
def
listBuckets(listBucketsRequest: ListBucketsRequest): Future[Seq[Bucket]]
- Definition Classes
- AmazonS3Wrapper
- See also
-
def
listFiles(bucket: String, path: Option[String] = None): Future[Seq[S3ObjectSummary]]
List all files with a given prefix of a S3 bucket.
List all files with a given prefix of a S3 bucket.
- bucket
the bucket name
- path
an optional path to search in bucket
- returns
a future of seq of file keys & last modified dates (or a failure)
-
def
listFilesAsStream(bucket: String, maybePrefix: Option[String] = None): Source[S3ObjectSummary, NotUsed]
List all files with a given prefix of a S3 bucket.
List all files with a given prefix of a S3 bucket.
- bucket
S3 bucket
- maybePrefix
S3 prefix. If not present, all the files of the bucket will be returned.
- Definition Classes
- AmazonS3Client
-
def
listNextBatchOfObjects(req: ObjectListing): Future[ObjectListing]
- Definition Classes
- AmazonS3Wrapper
- See also
- def listNextBatchOfObjects(req: ListNextBatchOfObjectsRequest): Future[ObjectListing]
-
def
listObjects(bucketName: String, prefix: String): Future[ObjectListing]
- Definition Classes
- AmazonS3Wrapper
- See also
-
def
listObjects(bucketName: String): Future[ObjectListing]
- Definition Classes
- AmazonS3Wrapper
- See also
-
def
listObjects(listObjectsRequest: ListObjectsRequest): Future[ObjectListing]
- Definition Classes
- AmazonS3Wrapper
- See also
-
def
listVersions(bucketName: String, prefix: String, keyMarker: String, versionIdMarker: String, delimiter: String, maxKeys: Int): Future[VersionListing]
- Definition Classes
- AmazonS3Wrapper
- See also
-
def
listVersions(bucketName: String, prefix: String): Future[VersionListing]
- Definition Classes
- AmazonS3Wrapper
- See also
-
def
listVersions(listVersionsRequest: ListVersionsRequest): Future[VersionListing]
- Definition Classes
- AmazonS3Wrapper
- See also
-
def
materialized(flowMaterializer: ActorMaterializer): AmazonS3ClientMaterialized
Return a client with additional logic to obtain a Stream logic as a Future.
Return a client with additional logic to obtain a Stream logic as a Future.
- Definition Classes
- AmazonS3Client
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
-
def
putObject(bucketName: String, key: String, input: InputStream, metadata: ObjectMetadata): Future[PutObjectResult]
- Definition Classes
- AmazonS3Wrapper
- See also
-
def
putObject(bucketName: String, key: String, file: File): Future[PutObjectResult]
- Definition Classes
- AmazonS3Wrapper
- See also
-
def
putObject(putObjectRequest: PutObjectRequest): Future[PutObjectResult]
- Definition Classes
- AmazonS3Wrapper
- See also
-
def
shutdown(): Unit
Shutdown the client and the executor service.
Shutdown the client and the executor service.
- Definition Classes
- AmazonS3ClientMaterialized → AmazonS3Wrapper
- See also
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
def
uncompressGzippedFileAsStream(bucket: String, key: String): Source[ByteString, NotUsed]
Stream a gzipped S3 file and decompress it on the fly.
Stream a gzipped S3 file and decompress it on the fly.
- bucket
S3 bucket
- key
S3 key
- Definition Classes
- AmazonS3Client
-
def
uploadPart(req: UploadPartRequest): Future[UploadPartResult]
- Definition Classes
- AmazonS3Wrapper
- See also
-
def
uploadStreamAsFile(intiate: InitiateMultipartUploadRequest, chunkUploadConcurrency: Int): Flow[ByteString, CompleteMultipartUploadResult, NotUsed]
- Definition Classes
- AmazonS3Client
-
def
uploadStreamAsFile(bucket: String, key: String, chunkUploadConcurrency: Int = 1): Flow[ByteString, CompleteMultipartUploadResult, NotUsed]
Upload a stream of bytes as a S3 file and returns an element of type CompleteMultipartUploadResult (or nothing if upstream was empty).
Upload a stream of bytes as a S3 file and returns an element of type CompleteMultipartUploadResult (or nothing if upstream was empty).
- bucket
S3 bucket
- key
S3 key
- chunkUploadConcurrency
chunk upload concurrency. Order is guaranteed even with chunkUploadConcurrency > 1.
- Definition Classes
- AmazonS3Client
-
def
uploadStreamAsMultipartFile(bucket: String, getKey: (Long) ⇒ String, nbChunkPerFile: Int): Flow[ByteString, CompleteMultipartUploadResult, NotUsed]
- Definition Classes
- AmazonS3Client
-
def
uploadStreamAsMultipartFile(bucket: String, getKey: (Long) ⇒ String, nbChunkPerFile: Int, chunkUploadConcurrency: Int): Flow[ByteString, CompleteMultipartUploadResult, NotUsed]
Upload a stream as a multipart file with a given number of upstream chunk per file.
Upload a stream as a multipart file with a given number of upstream chunk per file. Part file are uploaded sequentially but chunk inside a part file can be uploaded concurrently (tuned with chunkUploadConcurrency). The Flow returns a CompleteMultipartUploadResult for each part file uploaded.
- bucket
S3 bucket
- getKey
S3 key factory that will generate a new key for each part file based on the index of upstream chunks...
- nbChunkPerFile
the number of upstream chunks (for example lines) to include in each part file
- chunkUploadConcurrency
chunk upload concurrency. Order is guaranteed even with chunkUploadConcurrency > 1.
- Definition Classes
- AmazonS3Client
-
def
uploadStreamAsMultipartFile(bucket: String, prefix: String, nbChunkPerFile: Int, chunkUploadConcurrency: Int = 1): Flow[ByteString, CompleteMultipartUploadResult, NotUsed]
Upload a stream as a multipart file with a given number of upstream chunk per file.
Upload a stream as a multipart file with a given number of upstream chunk per file. Part file are uploaded sequentially but chunk inside a part file can be uploaded concurrently (tuned with chunkUploadConcurrency). The Flow returns a CompleteMultipartUploadResult for each part file uploaded.
- bucket
S3 bucket
- prefix
S3 prefix. The actual part files will be named prefix.part.00000001, prefix.part.00000002, ...
- nbChunkPerFile
the number of upstream chunks (for example lines) to include in each part file
- chunkUploadConcurrency
chunk upload concurrency. Order is guaranteed even with chunkUploadConcurrency > 1.
- Definition Classes
- AmazonS3Client
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
def
wrapMethod[Request, Result](f: (Request) ⇒ Result, request: Request): Future[Result]
- Definition Classes
- MethodWrapper
- Annotations
- @inline()
-
def
→[B](y: B): (AmazonS3ClientMaterialized, B)
- Implicit
- This member is added by an implicit conversion from AmazonS3ClientMaterialized to ArrowAssoc[AmazonS3ClientMaterialized] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc