mirror of
https://github.com/go-admin-team/go-admin.git
synced 2026-09-22 02:27:57 +00:00
zhangwenjian
5ecb1e6e4c
`gofmt -l` listed 26 files. Seventeen of them were missing the newline at the end of the file; the rest are indentation that used spaces where the file uses tabs, a handful of call sites written `f(a,b)`, and the doc comment spacing gofmt has rewritten since 1.19 (`//X` to `// X`). Nothing here changes behaviour: `go build ./...` and `go vet ./...` are clean and `go test ./common/...` passes, which is the half of the tree these files are concentrated in. Only the files gofmt named are touched, so the diff reads line by line rather than as a reflow of the whole repository. `gofmt -l` is now empty, which is the precondition for gating it in CI -- worth doing, but a separate change.
53 lines
1.4 KiB
Go
53 lines
1.4 KiB
Go
package file_store
|
||
|
||
import (
|
||
"github.com/aliyun/aliyun-oss-go-sdk/oss"
|
||
"log"
|
||
)
|
||
|
||
type ALiYunOSS struct {
|
||
Client interface{}
|
||
BucketName string
|
||
}
|
||
|
||
// Setup 装载
|
||
// endpoint sss
|
||
func (e *ALiYunOSS) Setup(endpoint, accessKeyID, accessKeySecret, BucketName string, options ...ClientOption) error {
|
||
client, err := oss.New(endpoint, accessKeyID, accessKeySecret)
|
||
if err != nil {
|
||
log.Println("Error:", err)
|
||
return err
|
||
}
|
||
e.Client = client
|
||
e.BucketName = BucketName
|
||
|
||
return nil
|
||
}
|
||
|
||
// UpLoad 文件上传
|
||
func (e *ALiYunOSS) UpLoad(yourObjectName string, localFile interface{}) error {
|
||
client, ok := e.Client.(*oss.Client)
|
||
if !ok {
|
||
return notConfigured(AliYunOSS)
|
||
}
|
||
// 获取存储空间。
|
||
bucket, err := client.Bucket(e.BucketName)
|
||
if err != nil {
|
||
log.Println("Error:", err)
|
||
return err
|
||
}
|
||
// 设置分片大小为100 KB，指定分片上传并发数为3，并开启断点续传上传。
|
||
// 其中<yourObjectName>与objectKey是同一概念，表示断点续传上传文件到OSS时需要指定包含文件后缀在内的完整路径，例如abc/efg/123.jpg。
|
||
// "LocalFile"为filePath，100*1024为partSize。
|
||
err = bucket.UploadFile(yourObjectName, localFile.(string), 100*1024, oss.Routines(3), oss.Checkpoint(true, ""))
|
||
if err != nil {
|
||
log.Println("Error:", err)
|
||
return err
|
||
}
|
||
return nil
|
||
}
|
||
|
||
func (e *ALiYunOSS) GetTempToken() (string, error) {
|
||
return "", nil
|
||
}
|