对象存储

// ObjstoreBucket 抽象化包装，以简化使用，读写操作权限
type ObjstoreBucket interface {
    io.Closer
    ObjstoreBucketReader

    // Name 获取默认的 bucket 名称
    Name() string

    // Upload 用于上传对象到默认的 bucket 里
    Upload(ctx context.Context, objectKey string, r io.Reader) (ObjstoreAttributes, error)

    // Delete 用于删除对象在默认的 bucket 里
    Delete(ctx context.Context, objectKey string) error

    // CopyTo 用于拷贝对象在默认 bucket 里
    CopyTo(ctx context.Context, srcObjectKey, dstObjectKey string) (ObjstoreAttributes, error)
}

// ObjstoreBucketReader 抽象化包装，以简化使用，只读操作权限
type ObjstoreBucketReader interface {
    // Get 用于获取默认 bucket 的对象内容
    Get(ctx context.Context, objectKey string) (io.ReadCloser, ObjstoreAttributes, error)

    // Iter 用于遍历默认 bucket 里的对象文件
    Iter(ctx context.Context, dir string, f func(string) error) error

    // GetRange 用于获取默认 bucket 中对象指定位置的内容
    GetRange(ctx context.Context, objectKey string, start, end int64) (io.ReadCloser, ObjstoreAttributes, error)

    // Exists 用于判断默认 bucket 是否存在该对象
    Exists(ctx context.Context, objectKey string) (bool, error)

    // Attributes 用于获取默认 bucket 中对象的额外属性
    Attributes(ctx context.Context, objectKey string) (ObjstoreAttributes, error)

    // IsObjNotFoundErr 错误是否为查询的对象不存在
    IsObjNotFoundErr(err error) bool
}

// ObjstoreAttributes 对象属性信息，如：last_modified、etag 等
type ObjstoreAttributes struct {
    // ETag 对象文件内容的 md5 值
    ETag string `json:"etag"`

    // LastModified 对象文件最近被修改时间
    LastModified time.Time `json:"last_modified"`

    // Size 对象文件大小，单位 bytes
    Size int64 `json:"size"`

    // UserMetadata 用户额外定义该对象的元数据，以 "x-amz-meta-*" 请求头返回
    UserMetadata map[string]string `json:"user_metadata"`

    // UserTags 用户定义对象文件关联的标签
    UserTags map[string]string `json:"user_tags"`

    // VersionID 用于说明本次文件版本号
    VersionID string `json:"version_id"`
}

objstore:
  enable: true
  type: s3
  config:
    bucket: "uptime-syncds-1251023941"
    endpoint: "cos.ap-guangzhou.myqcloud.com"
    access_key: ""
    secret_key: ""

objstore:
  enable: true
  type: s3
  config:
    bucket: ""
    endpoint: ""
    region: ""
    access_key: ""
    insecure: true
    secret_key: ""
    put_user_metadata: {}
    put_user_tags: {}
    http_config:
      idle_conn_timeout: 1m
    signature_version: v4
    list_objects_version: v2
    bucket_lookup_type: auto
    part_size: 67108864
    sse_config:
      type: ""
      kms_key_id: ""
      kms_encryption_context: {}
      encryption_key: ""

$HOME/.aws/credentials

[default]
aws_access_key_id={aws_access_key_id}
aws_secret_access_key={aws_secret_access_key}

# 对象存储配置
objstore:
  enable: true
  type: s3
  config:
    bucket: "uptime-syncds-1251023941"
    endpoint: "cos.ap-guangzhou.myqcloud.com"
    region: "ap-guangzhou"
    access_key: ""
    secret_key: ""
    put_user_metadata:
      x-amz-storage-class: "STANDARD_IA"

# 对象存储配置
objstore:
  enable: true
  type: s3
  config:
    bucket: "uptime-syncds-1251023941"
    endpoint: "cos.ap-guangzhou.myqcloud.com"
    region: "ap-guangzhou"
    access_key: ""
    secret_key: ""
    sse_config:
      type: "SSE-S3"

# 对象存储配置
objstore:
  enable: true
  type: s3
  config:
    bucket: "uptime-syncds-1251023941"
    endpoint: "cos.ap-guangzhou.myqcloud.com"
    region: "ap-guangzhou"
    access_key: ""
    secret_key: ""
    sse_config:
      type: "SSE-C"
      encryption_key: "/opt/config/secret.key"

package main

import (
	"crypto/rand"
	"fmt"
	"log"
	"math/big"
)

func generateSSECKey() (string, error) {
	const charset = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789"
	charsetLen := big.NewInt(int64(len(charset)))

	key := make([]byte, 32)
	for i := range key {
		randomIndex, err := rand.Int(rand.Reader, charsetLen)
		if err != nil {
			return "", err
		}
		key[i] = charset[randomIndex.Int64()]
	}

	return string(key), nil
}

func main() {
	ssecKey, err := generateSSECKey()
	if err != nil {
		log.Fatal(err)
	}
    fmt.Print(ssecKey)
}

go run a.go > /opt/config/secret.key