Module `S3.Make`

S3 functions All function requires a region, scheme and credentials.

The default region is Us_east_1.

The default scheme is http. If you are connecting from outside AWS, it is strongly recommended that you use https. To use https, make sure to have the relevant opam packages installed: async_ssl for async and lwt_ssl/tls for lwt. Please note that connections are not reused due to a limitation on the AWS endpoint.

If no credentials is provided, the requests will not be signed, The bucket / objects need to be configured accordingly.

IPv6 connection can be set globally using the function: Aws_s3.S3.Make.set_connection_type.

Parameters

module Io : Types.Io

Signature

type error =

| Redirect of Region.endpoint
| Throttled
| Unknown of int * string
| Failed of exn
| Forbidden
| Not_found

type etag = string

type storage_class =

| Standard
| Standard_ia
| Onezone_ia
| Reduced_redundancy
| Glacier

type content = {

storage_class : storage_class;
size : int;
last_modified : float;
(*
Seconds since epoch
*)
key : string;
etag : etag;
(*
Etag as a string. this us usually the MD5, unless the object was constructed by multi-upload
*)

}

type nonrec 'a result = ('a, error) result Io.Deferred.t

type 'a command =
  ?credentials:Credentials.t ->
  ?connect_timeout_ms:int ->
  endpoint:Region.endpoint ->
  'a

module Ls : sig ... end

module Delete_multi : sig ... end

type range = {

first : int option;
last : int option;

}

val put : 
  (?content_type:string ->
    ?content_encoding:string ->
    ?acl:string ->
    ?cache_control:string ->
    ?expect:bool ->
    bucket:string ->
    key:string ->
    data:string ->
    unit ->
    etag result)
    command

Upload data to bucket/key. Returns the etag of the object. The etag is the md5 checksum (RFC 1864)

parameter expect
If true, the body will not be sent until a status has been received from the server. This incurs a delay in transfer, but avoid sending a large body, if the request can be know to fail before the body is sent.

val get : 
  (?range:range ->
    bucket:string ->
    key:string ->
    unit ->
    string result)
    command

Download key from s3 in bucket If range is specified, only a part of the file is retrieved:

If first is None, then start from the beginning of the object.
If last is None, then get to the end of the object.

val head : (bucket:string -> key:string -> unit -> content result) command

Call head on the object to retrieve info on a single object

val delete : (bucket:string -> key:string -> unit -> unit result) command

Delete key from bucket.

val delete_multi : 
  (bucket:string ->
    objects:Delete_multi.objekt list ->
    unit ->
    Delete_multi.result result)
    command

Delete multiple objects from bucket.

The result will indicate which items failed and which are deleted. If an item is not found it will be reported as successfully deleted (the operation is idempotent).

val ls : 
  (?start_after:string ->
    ?continuation_token:string ->
    ?prefix:string ->
    ?max_keys:int ->
    bucket:string ->
    unit ->
    Ls.t)
    command

List contents in bucket Aws will return at most 1000 keys per request. If not all keys are returned, the function will return a continuation.

Keys in s3 are stored in lexicographical order, and also returned as such.

If a continuation_token is given the result will continue from last call.

If start_after is given then keys only keys after start_with are returned. Note that is both start_after and a continuation_token is given then start_after argument is ignored.

If prefix is given, then only keys starting with the given prefix will be returned.

module Stream : sig ... end

Streaming functions. Streaming function seeks to limit the amount of used memory used when operating of large objects by operating on streams.

module Multipart_upload : sig ... end

val retry : 
  endpoint:Region.endpoint ->
  retries:int ->
  f:(endpoint:Region.endpoint -> unit -> 'a result) ->
  unit ->
  'a result

Helper function to handle error codes. The function handle redirects and throttling.

package aws-s3

Module S3.Make

Parameters

Signature

Module `S3.Make`