-
Notifications
You must be signed in to change notification settings - Fork 58
/
Copy pathbucket_lifecycle.go
129 lines (107 loc) · 2.71 KB
/
bucket_lifecycle.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
package cos
import (
"bytes"
"context"
"errors"
"fmt"
"io/ioutil"
"net/http"
"net/url"
"os"
"strings"
"testing"
"time"
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/suite"
"github.com/tencentyun/cos-go-sdk-v5"
)
type CosTestSuite struct {
suite.Suite
VariableThatShouldStartAtFive int
// CI client
Client *cos.Client
// Copy source client
CClient *cos.Client
// test_object
TestObject string
// special_file_name
SepFileName string
}
var (
UploadID string
PartETag string
)
// 设置存储桶生命周期
func (s *CosTestSuite) putBucketLifecycle() {
client := s.Client
//.cssg-snippet-body-start:[put-bucket-lifecycle]
lc := &cos.BucketPutLifecycleOptions{
Rules: []cos.BucketLifecycleRule{
{
ID: "1234",
Filter: &cos.BucketLifecycleFilter{Prefix: "test"},
Status: "Enabled",
Transition: &cos.BucketLifecycleTransition{
Days: 10,
StorageClass: "Standard",
},
},
{
ID: "123422",
Filter: &cos.BucketLifecycleFilter{Prefix: "gg"},
Status: "Disabled",
Expiration: &cos.BucketLifecycleExpiration{
Days: 10,
},
},
},
}
_, err := client.Bucket.PutLifecycle(context.Background(), lc)
if err != nil {
panic(err)
}
//.cssg-snippet-body-end
}
// 获取存储桶生命周期
func (s *CosTestSuite) getBucketLifecycle() {
client := s.Client
//.cssg-snippet-body-start:[get-bucket-lifecycle]
_, _, err := client.Bucket.GetLifecycle(context.Background())
if err != nil {
panic(err)
}
//.cssg-snippet-body-end
}
// 删除存储桶生命周期
func (s *CosTestSuite) deleteBucketLifecycle() {
client := s.Client
//.cssg-snippet-body-start:[delete-bucket-lifecycle]
_, err := client.Bucket.DeleteLifecycle(context.Background())
if err != nil {
panic(err)
}
//.cssg-snippet-body-end
}
//.cssg-methods-pragma
func TestCOSTestSuite(t *testing.T) {
suite.Run(t, new(CosTestSuite))
}
func (s *CosTestSuite) TestBucketLifecycle() {
// 将 examplebucket-1250000000 和 ap-guangzhou 修改为真实的信息
u, _ := url.Parse("https://examplebucket-1250000000.cos.ap-guangzhou.myqcloud.com")
b := &cos.BaseURL{BucketURL: u}
c := cos.NewClient(b, &http.Client{
Transport: &cos.AuthorizationTransport{
SecretID: os.Getenv("COS_KEY"),
SecretKey: os.Getenv("COS_SECRET"),
},
})
s.Client = c
// 设置存储桶生命周期
s.putBucketLifecycle()
// 获取存储桶生命周期
s.getBucketLifecycle()
// 删除存储桶生命周期
s.deleteBucketLifecycle()
//.cssg-methods-pragma
}