Util (p.awso-async.0.9.0.doc.awso-async.s3.Awso_s3

Source

val put_object : 
  Awso.Cfg.t ->
  bucket:Awso_s3.Values.BucketName.t ->
  key:string ->
  string ->
  (Awso_s3.Values.ETag.t,
    [ `Missing_etag | `Put_object of Awso_s3.Values.PutObjectOutput.error ])
    Core.Result.t
    Async.Deferred.t

Source

val delete_object : 
  Awso.Cfg.t ->
  bucket:string ->
  key:string ->
  (Awso_s3.Values.DeleteObjectOutput.t,
    Awso_s3.Values.DeleteObjectOutput.error)
    Core.Result.t
    Async.Deferred.t

Source

val put_file : 
  Awso.Cfg.t ->
  bucket:string ->
  key:string ->
  string ->
  (string,
    [> `Put_object of Awso_s3.Values.PutObjectOutput.error | `Missing_etag ])
    Core.result
    Async.Deferred.t

Source

type ('acc, 'error) callback =
  'acc ->
  total:int64 ->
  loaded:int64 ->
  key:string ->
  part:int64 ->
  num_parts:int64 ->
  [ `Complete of Awso_s3.Values.ETag.t
  | `Initial of Awso_s3.Values.MultipartUploadId.t
  | `Partition of Awso_s3.Values.ETag.t ] ->
  ('acc, 'error) Async.Deferred.Result.t

Source

val initialize_multipart : 
  Awso.Cfg.t ->
  bucket:string ->
  key:string ->
  ([> `Upload_id of string ],
    [> `Create_multipart_upload of
         Awso_s3.Values.CreateMultipartUploadOutput.error
    | `Missing_upload_id ])
    Core.result
    Async.Deferred.t

Source

val multipart : 
  Awso.Cfg.t ->
  ?chunk_size:Core.Byte_units.t ->
  ?part:int ->
  ?file_offset:int64 ->
  bucket:string ->
  key:string ->
  init:'acc ->
  cb:('acc, 'error) callback ->
  upload_id:string ->
  string ->
  ('acc * Awso_s3.Values.CompletedPart.t list,
    [> `Callback_error of 'acc * Awso_s3.Values.CompletedPart.t list * 'error
    | `Complete_multipart_upload of
      Awso_s3.Values.CompleteMultipartUploadOutput.error
    | `Upload_part of Awso_s3.Values.UploadPartOutput.error ])
    Core.result
    Async.Deferred.t

parameter chunk_size
The maximum size of a part for a multipart transfer.

Source

val get_object : 
  Awso.Cfg.t ->
  ?range:Awso.Http.Range.t ->
  bucket:string ->
  key:string ->
  unit ->
  (Awso_s3.Values.GetObjectOutput.t, Awso_s3.Values.GetObjectOutput.error)
    Core.result
    Async.Deferred.t

Sourcemodule Source : sig ... end

Source

val map_bucket : 
  Awso.Cfg.t ->
  bucket:string ->
  f:(Awso_s3.Values.Object.t -> 'a Async.Deferred.t) ->
  ('a list, Awso_s3.Values.ListObjectsV2Output.error) Core.result
    Async.Deferred.t

Source

val iter_bucket : 
  Awso.Cfg.t ->
  bucket:string ->
  f:(Awso_s3.Values.Object.t -> unit Async.Deferred.t) ->
  (unit, Awso_s3.Values.ListObjectsV2Output.error) Core.result Async.Deferred.t