🥮 mooncakes.io

s3

Download zip
Author
Version
0.1.0
License
Apache-2.0
Last updated
3 months ago
Downloads
19

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