🥮 mooncakes.io

    s3

    Download zip
    Author
    Version
    0.1.0
    License
    Apache-2.0
    Last updated
    4 months ago
    Downloads
    31

    Dependencies

    #hackwaly/s3

    Async S3 client for MoonBit, built on moonbitlang/async/http.

    This package supports the native backend.

    ///|
    async fn example {
      let client = @s3.Client(
        @s3.Config("us-east-1", @s3.Credentials("AKIA...", "secret...")),
      )
      let object = client.get_object("my-bucket", "path/to/object.txt")
      let body = object.body.read_all().text()
      object.body.close()
      println(body)
    }

    For MinIO or other S3-compatible services, use a custom endpoint and path-style addressing:

    ///|
    let client = @s3.Client(
      @s3.Config(
        "us-east-1",
        @s3.Credentials("minioadmin", "minioadmin"),
        endpoint="http://127.0.0.1:9000",
        endpoint_style=@s3.Path,
      ),
    )

    Implemented operations:

    • get_object
    • put_object
    • head_object
    • delete_object
    • list_objects_v2

    ReadCloser

    source
    pub(open) trait ReadCloser : 
    Reader     {
      fn close(Self) -> Unit
    }

    S3Error

    source
    pub suberror S3Error {
      InvalidConfig(String)
      InvalidInput(String)
      InvalidResponse(String)
      ServiceError(
    Response    , String)
    } derive(
    Debug    )

    Client

    source
    pub struct Client {
      // private fields
    }
    fn Client::Client(config : Config) -> Client raise

    Client::delete_object

    source
    async fn Client::delete_object(self : Client, bucket : String, key : String, options? : RequestOptions) -> 
    Response

    Client::get_object

    source
    async fn Client::get_object(self : Client, bucket : String, key : String, options? : RequestOptions) -> ObjectResult

    Client::head_object

    source
    async fn Client::head_object(self : Client, bucket : String, key : String, options? : RequestOptions) -> 
    Response

    Client::list_objects_v2

    source
    async fn Client::list_objects_v2(self : Client, bucket : String, prefix? : String, delimiter? : String, continuation_token? : String, max_keys? : Int, options? : RequestOptions) -> ListObjectsV2Result

    Client::put_object

    source
    async fn Client::put_object(self : Client, bucket : String, key : String, body : &
    Data    , options? : RequestOptions) -> 
    Response

    Config

    source
    pub struct Config {
      // private fields
    } derive(Eq, 
    Debug    )
    fn Config::Config(region : String, credentials : Credentials, endpoint? : String, endpoint_style? : EndpointStyle) -> Config

    Credentials

    source
    pub struct Credentials {
      // private fields
    } derive(Eq)
    fn Credentials::Credentials(access_key_id : String, secret_access_key : String, session_token? : String) -> Credentials

    EndpointStyle

    source
    pub(all) enum EndpointStyle {
      VirtualHost
      Path
    } derive(Eq, 
    Debug    )

    ListObjectsV2Result

    source
    pub struct ListObjectsV2Result {
      is_truncated : Bool
      next_continuation_token : String?
      contents : Array[ListedObject]
      common_prefixes : Array[String]
    } derive(Eq, 
    Debug    )

    ListedObject

    source
    pub struct ListedObject {
      key : String
      size : Int64
      etag : String?
    } derive(Eq, 
    Debug    )

    ObjectResult

    source
    pub struct ObjectResult {
      response : 
    Response
      body : &ReadCloser
    }

    RequestOptions

    source
    pub struct RequestOptions {
      // private fields
    } derive(
    Debug    )
    fn RequestOptions::RequestOptions(headers? : Map[String, String], query? : Map[String, String], timestamp? : String, payload_hash? : String) -> RequestOptions

    Source Files

    Powered by MoonBit

    Site sourceReport issuePackagesBuild queueSkillsStatistics

    © 2026 mooncakes.io