trait AmazonS3Wrapper extends MethodWrapper
A lightweight wrapper for AmazonS3Client
The AWS Java SDK does not provide an asynchronous S3 client, so this class follows the approach of the asynchronous clients that are provided by the SDK. Namely, to make the synchronous calls within an executor service. The methods in this class all return Scala futures.
- Source
- AmazonS3Wrapper.scala
- See also
java.util.concurrent.ExecutorService
Linear Supertypes
Known Subclasses
Ordering
- Alphabetic
- By Inheritance
Inherited
- AmazonS3Wrapper
- MethodWrapper
- AnyRef
- Any
Implicitly
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
Visibility
- Public
- All
Abstract Value Members
- abstract def client: AmazonS3
-
abstract
def
executorService: ExecutorService
- Definition Classes
- AmazonS3Wrapper → MethodWrapper
Concrete 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 AmazonS3Wrapper to any2stringadd[AmazonS3Wrapper] performed by method any2stringadd in scala.Predef.
- Definition Classes
- any2stringadd
-
def
->[B](y: B): (AmazonS3Wrapper, B)
- Implicit
- This member is added by an implicit conversion from AmazonS3Wrapper to ArrowAssoc[AmazonS3Wrapper] 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]
- See also
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
def
completeMultipartUpload(completeMultipartUploadRequest: CompleteMultipartUploadRequest): Future[CompleteMultipartUploadResult]
- See also
-
def
copyObject(sourceBucketName: String, sourceKey: String, destinationBucketName: String, destinationKey: String): Future[CopyObjectResult]
- See also
-
def
copyObject(copyObjectRequest: CopyObjectRequest): Future[CopyObjectResult]
- See also
-
def
copyPart(copyPartRequest: CopyPartRequest): Future[CopyPartResult]
- See also
-
def
createBucket(bucketName: String, region: String): Future[Bucket]
- See also
-
def
createBucket(bucketName: String, region: Region): Future[Bucket]
- See also
-
def
createBucket(bucketName: String): Future[Bucket]
- See also
-
def
createBucket(createBucketRequest: CreateBucketRequest): Future[Bucket]
- See also
-
def
deleteBucket(bucketName: String): Future[Unit]
- See also
-
def
deleteBucket(deleteBucketRequest: DeleteBucketRequest): Future[Unit]
- See also
-
def
deleteObject(bucketName: String, key: String): Future[Unit]
- See also
-
def
deleteObject(deleteObjectRequest: DeleteObjectRequest): Future[Unit]
- See also
-
def
deleteObjects(bucketName: String, keys: String*): Future[Seq[DeletedObject]]
- See also
-
def
deleteObjects(deleteObjectsRequest: DeleteObjectsRequest): Future[Seq[DeletedObject]]
- See also
-
def
deleteVersion(bucketName: String, key: String, versionId: String): Future[Unit]
- See also
-
def
deleteVersion(deleteVersionRequest: DeleteVersionRequest): Future[Unit]
- See also
-
def
doesBucketExist(bucketName: String): Future[Boolean]
- See also
- implicit val ec: ExecutionContextExecutorService
-
def
ensuring(cond: (AmazonS3Wrapper) ⇒ Boolean, msg: ⇒ Any): AmazonS3Wrapper
- Implicit
- This member is added by an implicit conversion from AmazonS3Wrapper to Ensuring[AmazonS3Wrapper] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: (AmazonS3Wrapper) ⇒ Boolean): AmazonS3Wrapper
- Implicit
- This member is added by an implicit conversion from AmazonS3Wrapper to Ensuring[AmazonS3Wrapper] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean, msg: ⇒ Any): AmazonS3Wrapper
- Implicit
- This member is added by an implicit conversion from AmazonS3Wrapper to Ensuring[AmazonS3Wrapper] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean): AmazonS3Wrapper
- Implicit
- This member is added by an implicit conversion from AmazonS3Wrapper to Ensuring[AmazonS3Wrapper] 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
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
def
formatted(fmtstr: String): String
- Implicit
- This member is added by an implicit conversion from AmazonS3Wrapper to StringFormat[AmazonS3Wrapper] performed by method StringFormat in scala.Predef.
- Definition Classes
- StringFormat
- Annotations
- @inline()
-
def
generatePresignedUrlRequest(generatePresignedUrlRequest: GeneratePresignedUrlRequest): Future[URL]
- See also
-
def
getBucketLocation(bucketName: String): Future[String]
- See also
-
def
getBucketLocation(getBucketLocationRequest: GetBucketLocationRequest): Future[String]
- See also
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
-
def
getObject(getObjectRequest: GetObjectRequest, destinationFile: File): Future[ObjectMetadata]
- See also
-
def
getObject(bucketName: String, key: String): Future[S3Object]
- See also
-
def
getObject(getObjectRequest: GetObjectRequest): Future[S3Object]
- See also
-
def
getObjectMetadata(bucketName: String, key: String): Future[ObjectMetadata]
- See also
-
def
getObjectMetadata(getObjectMetadataRequest: GetObjectMetadataRequest): Future[ObjectMetadata]
- See also
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
-
def
initiateMultipartUpload(initiateMultipartUploadRequest: InitiateMultipartUploadRequest): Future[InitiateMultipartUploadResult]
- See also
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
listBuckets(): Future[Seq[Bucket]]
- See also
-
def
listBuckets(listBucketsRequest: ListBucketsRequest): Future[Seq[Bucket]]
- See also
-
def
listNextBatchOfObjects(req: ObjectListing): Future[ObjectListing]
- See also
- def listNextBatchOfObjects(req: ListNextBatchOfObjectsRequest): Future[ObjectListing]
-
def
listObjects(bucketName: String, prefix: String): Future[ObjectListing]
- See also
-
def
listObjects(bucketName: String): Future[ObjectListing]
- See also
-
def
listObjects(listObjectsRequest: ListObjectsRequest): Future[ObjectListing]
- See also
-
def
listVersions(bucketName: String, prefix: String, keyMarker: String, versionIdMarker: String, delimiter: String, maxKeys: Int): Future[VersionListing]
- See also
-
def
listVersions(bucketName: String, prefix: String): Future[VersionListing]
- See also
-
def
listVersions(listVersionsRequest: ListVersionsRequest): Future[VersionListing]
- See also
-
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]
- See also
-
def
putObject(bucketName: String, key: String, file: File): Future[PutObjectResult]
- See also
-
def
putObject(putObjectRequest: PutObjectRequest): Future[PutObjectResult]
- See also
-
def
shutdown(): Unit
Shutdown the client and the executor service.
Shutdown the client and the executor service.
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
def
uploadPart(req: UploadPartRequest): Future[UploadPartResult]
- See also
-
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): (AmazonS3Wrapper, B)
- Implicit
- This member is added by an implicit conversion from AmazonS3Wrapper to ArrowAssoc[AmazonS3Wrapper] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc