AWS Go SDK Guide

export AWS_ENDPOINT_URL_S3="https://adapter.example.test"

import (
    "context"

    "github.com/aws/aws-sdk-go-v2/config"
    "github.com/aws/aws-sdk-go-v2/service/s3"
)

func newS3(ctx context.Context) (*s3.Client, error) {
    cfg, err := config.LoadDefaultConfig(ctx,
        config.WithRegion("us-east-1"),
        config.WithSharedConfigProfile("adapter-test"),
    )
    if err != nil { return nil, err }

    client := s3.NewFromConfig(cfg, func(options *s3.Options) {
        options.UsePathStyle = true
    })
    return client, nil
}

export T9_CLOUD_ADAPTER_ENDPOINT="https://adapter.example.test"

package main

import (
    "context"
    "io"
    "os"
    "strings"
    "time"

    "github.com/aws/aws-sdk-go-v2/aws"
    "github.com/aws/aws-sdk-go-v2/config"
    "github.com/aws/aws-sdk-go-v2/service/s3"
)

func newS3(ctx context.Context) (*s3.Client, error) {
    cfg, err := config.LoadDefaultConfig(ctx,
        config.WithRegion("us-east-1"),
        config.WithSharedConfigProfile("adapter-test"),
    )
    if err != nil {
        return nil, err
    }

    endpoint := os.Getenv("T9_CLOUD_ADAPTER_ENDPOINT")
    return s3.NewFromConfig(cfg, func(options *s3.Options) {
        options.BaseEndpoint = aws.String(endpoint)
        options.UsePathStyle = true
    }), nil
}

ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
defer cancel()

client, err := newS3(ctx)
if err != nil { panic(err) }

bucket := os.Getenv("TEST_BUCKET")
key := "go/" + time.Now().UTC().Format("20060102T150405.000000000Z") + "-hello.txt"
body := "hello through Cloud Adapter\n"

_, err = client.PutObject(ctx, &s3.PutObjectInput{
    Bucket: aws.String(bucket),
    Key: aws.String(key),
    Body: strings.NewReader(body),
    ContentType: aws.String("text/plain"),
})
if err != nil { panic(err) }

_, err = client.HeadObject(ctx, &s3.HeadObjectInput{Bucket: aws.String(bucket), Key: aws.String(key)})
if err != nil { panic(err) }

got, err := client.GetObject(ctx, &s3.GetObjectInput{Bucket: aws.String(bucket), Key: aws.String(key)})
if err != nil { panic(err) }
defer got.Body.Close()

actual, err := io.ReadAll(got.Body)
if err != nil { panic(err) }
if string(actual) != body { panic("downloaded bytes differ") }

_, err = client.DeleteObject(ctx, &s3.DeleteObjectInput{Bucket: aws.String(bucket), Key: aws.String(key)})
if err != nil { panic(err) }