blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2025-04-06 04:15:46 +08:00
Code Issues Packages Projects Releases Wiki Activity

s3 cos test

Browse Source
This commit is contained in:
withchao 2023-07-12 12:34:00 +08:00
parent 535736bad1
commit c32b437821
1 changed files with 4 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
pkg/common/db/s3/cos/cos.go
View File

@ -41,10 +41,9 @@ func NewCos() (s3.Interface, error) {
} }
type Cos struct { type Cos struct {
statObjectURL string copyURL string
copyURL string client *cos.Client
client *cos.Client credential *cos.Credential
credential *cos.Credential
} }
func (c *Cos) Engine() string { func (c *Cos) Engine() string {
@ -170,7 +169,6 @@ func (c *Cos) StatObject(ctx context.Context, name string) (*s3.ObjectInfo, erro
if name != "" && name[0] == '/' { if name != "" && name[0] == '/' {
name = name[1:] name = name[1:]
} }
//info, err := c.client.Object.Head(ctx, c.statObjectURL+name, nil)
info, err := c.client.Object.Head(ctx, name, nil) info, err := c.client.Object.Head(ctx, name, nil)
if err != nil { if err != nil {
return nil, err return nil, err
@ -202,7 +200,7 @@ func (c *Cos) StatObject(ctx context.Context, name string) (*s3.ObjectInfo, erro
} }
func (c *Cos) CopyObject(ctx context.Context, src string, dst string) (*s3.CopyObjectInfo, error) { func (c *Cos) CopyObject(ctx context.Context, src string, dst string) (*s3.CopyObjectInfo, error) {
result, _, err := c.client.Object.Copy(ctx, dst, src, &cos.ObjectCopyOptions{}) result, _, err := c.client.Object.Copy(ctx, dst, c.copyURL+src, &cos.ObjectCopyOptions{})
if err != nil { if err != nil {
return nil, err return nil, err
} }