add CreateBucketXml

oss/client.go

@@ -148,6 +148,24 @@ func (client Client) CreateBucket(bucketName string, options ...Option) error {
 	return CheckRespCode(resp.StatusCode, []int{http.StatusOK})
 }
 
+// create bucket xml
+func (client Client) CreateBucketXml(bucketName string, xmlBody string, options ...Option) error {
+    buffer := new(bytes.Buffer)
+	buffer.Write([]byte(xmlBody))
+	contentType := http.DetectContentType(buffer.Bytes())
+	headers := map[string]string{}
+	headers[HTTPHeaderContentType] = contentType
+
+	params := map[string]interface{}{}
+	resp, err := client.do("PUT", bucketName, params, headers, buffer, options...)
+	if err != nil {
+	    return err
+	}
+
+	defer resp.Body.Close()
+	return CheckRespCode(resp.StatusCode, []int{http.StatusOK})
+}
+
 // ListBuckets lists buckets of the current account under the given endpoint, with optional filters.
 //
 // options    specifies the filters such as Prefix, Marker and MaxKeys. Prefix is the bucket name's prefix filter.

oss/client_test.go

@@ -4483,3 +4483,26 @@ func (s *OssClientSuite) TestGetBucketCName(c *C) {
 	err = client.DeleteBucket(bucketName)
 	c.Assert(err, IsNil)
 }
+
+func (s *OssClientSuite) TestCreateBucketXml(c *C) {
+	client, err := New(endpoint, accessID, accessKey)
+	c.Assert(err, IsNil)
+
+	bucketName := bucketNamePrefix + RandLowStr(5)
+	xmlBody := `
+        <?xml version="1.0" encoding="UTF-8"?>
+        <CreateBucketConfiguration>
+            <StorageClass>IA</StorageClass>
+        </CreateBucketConfiguration>
+        `
+	err = client.CreateBucketXml(bucketName,xmlBody)
+	c.Assert(err, IsNil)
+
+	//check
+	bucketInfo,_:= client.GetBucketInfo(bucketName)
+	c.Assert(bucketInfo.BucketInfo.StorageClass, Equals, "IA")
+	err = client.DeleteBucket(bucketName)
+	c.Assert(err, IsNil)
+}
+
+

oss/const.go

@@ -235,7 +235,7 @@ const (
 
 	NullVersion = "null"
 
-	Version = "v2.1.11" // Go SDK version
+	Version = "v2.2.0" // Go SDK version
 )
 
 // FrameType