final class Live extends Service

Service use to wrap the unsafe amazon s3 client and access safely to s3 storage

Linear Supertypes
Service, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Live
  2. Service
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new Live(unsafeClient: S3AsyncClient)

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( ... ) @native()
  6. def createBucket(bucketName: String): IO[S3Exception, Unit]

    Create a bucket

    Create a bucket

    bucketName

    name of the bucket

    Definition Classes
    Live → Service
  7. def deleteBucket(bucketName: String): IO[S3Exception, Unit]

    Delete bucket, the operation fail if bucket is not present

    Delete bucket, the operation fail if bucket is not present

    bucketName

    name of the bucket

    Definition Classes
    Live → Service
  8. def deleteObject(bucketName: String, key: String): IO[S3Exception, Unit]

    delete an object from a bucket, if not present it will succeed

    delete an object from a bucket, if not present it will succeed

    bucketName

    name of the bucket

    key

    object identifier to remove

    Definition Classes
    Live → Service
  9. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  10. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  11. def execute[T](f: (S3AsyncClient) ⇒ CompletableFuture[T]): ZIO[Any, S3Exception, T]

    * expose safely amazon s3 async client

    * expose safely amazon s3 async client

    T

    value type to return

    f

    call any operations on s3 async client

    Definition Classes
    Live → Service
  12. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  13. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  14. def getNextObjects(listing: S3ObjectListing): IO[S3Exception, S3ObjectListing]

    Fetch the next object listing from a specific object listing.

    Fetch the next object listing from a specific object listing.

    listing

    listing to use as a start

    Definition Classes
    Live → Service
  15. def getObject(bucketName: String, key: String): Stream[S3Exception, Byte]

    Read an object from a bucket, the operation fail if object is not present

    Read an object from a bucket, the operation fail if object is not present

    bucketName

    name of the bucket

    key

    object identifier to read

    Definition Classes
    Live → Service
  16. def getObjectMetadata(bucketName: String, key: String): IO[S3Exception, ObjectMetadata]

    Retrieves metadata from an object without returning the object itself.

    Retrieves metadata from an object without returning the object itself. This operation is useful if you're only interested in an object's metadata.

    bucketName

    name of the bucket

    key

    object identifier to read

    returns

    the ObjectMetadata

    Definition Classes
    Live → Service
  17. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  18. def isBucketExists(bucketName: String): IO[S3Exception, Boolean]

    Check if bucket exists

    Check if bucket exists

    bucketName

    name of the bucket

    Definition Classes
    Live → Service
  19. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  20. def listAllObjects(bucketName: String, options: ListObjectOptions): Stream[S3Exception, S3ObjectSummary]
    Definition Classes
    Service
  21. def listAllObjects(bucketName: String): Stream[S3Exception, S3ObjectSummary]

    List all descendant objects of a bucket Fetch all objects recursively of all nested directory by traversing all of them

    List all descendant objects of a bucket Fetch all objects recursively of all nested directory by traversing all of them

    bucketName

    name of the bucket

    Definition Classes
    Service
  22. val listBuckets: IO[S3Exception, S3BucketListing]

    List all available buckets

    List all available buckets

    Definition Classes
    Live → Service
  23. def listObjects(bucketName: String, options: ListObjectOptions): IO[S3Exception, S3ObjectListing]
    Definition Classes
    Live → Service
  24. def listObjects(bucketName: String): IO[S3Exception, S3ObjectListing]

    list all object for a specific bucket

    list all object for a specific bucket

    bucketName

    name of the bucket

    Definition Classes
    Service
  25. def multipartUpload[R](bucketName: String, key: String, content: ZStream[R, Throwable, Byte], options: MultipartUploadOptions)(parallelism: Int): ZIO[R, S3Exception, Unit]

    *

    *

    Store data object into a specific bucket, minimun size of the data is 5 Mb to use multipartt upload (restriction from amazon API)

    bucketName

    name of the bucket

    key

    unique object identifier

    content

    object data

    options

    the optional configurations of the multipart upload

    parallelism

    the number of parallel requests to upload chunks

    Definition Classes
    Live → Service
  26. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  27. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  28. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  29. def paginate(initialListing: S3ObjectListing): Stream[S3Exception, S3ObjectListing]

    List all objects by traversing all nested directories

    List all objects by traversing all nested directories

    initialListing

    object listing to start with

    Definition Classes
    Service
  30. def putObject[R](bucketName: String, key: String, contentLength: Long, content: ZStream[R, Throwable, Byte], options: UploadOptions): ZIO[R, S3Exception, Unit]

    Store data object into a specific bucket

    Store data object into a specific bucket

    bucketName

    name of the bucket

    key

    unique object identifier

    contentLength

    length of the data in bytes

    content

    object data

    Definition Classes
    Live → Service
  31. def streamLines(bucketName: String, key: String): Stream[S3Exception, String]

    Read an object by lines

    Read an object by lines

    bucketName

    name of the bucket

    Definition Classes
    Service
  32. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  33. def toString(): String
    Definition Classes
    AnyRef → Any
  34. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  35. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  36. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()

Inherited from Service

Inherited from AnyRef

Inherited from Any

Ungrouped