Updates features in bos and cce

Author: duanliguo

bce/config.go

@@ -26,7 +26,7 @@ import (
 
 // Constants and default values for the package bce
 const (
-	SDK_VERSION                          = "0.9.195"
+	SDK_VERSION                          = "0.9.196"
 	URI_PREFIX                           = "/" // now support uri without prefix "v1" so just set root path
 	DEFAULT_DOMAIN                       = "baidubce.com"
 	DEFAULT_PROTOCOL                     = "http"

http/constants.go

@@ -65,6 +65,7 @@ const (
 
 	// BOS HTTP Headers
 	BCE_COPY_METADATA_DIRECTIVE         = "x-bce-metadata-directive"
+	BCE_COPY_TAGGING_DIRECTIVE          = "x-bce-tagging-directive"
 	BCE_COPY_SOURCE                     = "x-bce-copy-source"
 	BCE_COPY_SOURCE_IF_MATCH            = "x-bce-copy-source-if-match"
 	BCE_COPY_SOURCE_IF_MODIFIED_SINCE   = "x-bce-copy-source-if-modified-since"

services/bcm/model/model.go

@@ -192,11 +192,28 @@ type EventDataRequest struct {
 }
 
 type CloudEventResponse struct {
-	PageNo     int          `json:"pageNo,omitempty"`
-	PageSize   int          `json:"pageSize,omitempty"`
-	TotalCount int          `json:"totalCount,omitempty"`
-	TotalPage  int          `json:"totalPage,omitempty"`
-	Result     []CloudEvent `json:"result,omitempty"`
+	PageNumber    int              `json:"pageNumber,omitempty"`
+	PageSize      int              `json:"pageSize,omitempty"`
+	PageElements  int              `json:"pageElements,omitempty"`
+	Last          bool             `json:"last,omitempty"`
+	First         bool             `json:"first,omitempty"`
+	TotalPages    bool             `json:"totalPages,omitempty"`
+	TotalElements int              `json:"totalElements,omitempty"`
+	Content       []CloudEventData `json:"content,omitempty"`
+}
+
+type CloudEventData struct {
+	AccountID    string `json:"accountId,omitempty"`
+	ServiceName  string `json:"serviceName,omitempty"`
+	Region       string `json:"region,omitempty"`
+	ResourceType string `json:"resourceType,omitempty"`
+	ResourceID   string `json:"resourceId,omitempty"`
+	EventID      string `json:"eventId,omitempty"`
+	EventType    string `json:"eventType,omitempty"`
+	EventLevel   string `json:"eventLevel,omitempty"`
+	EventAlias   string `json:"eventAlias,omitempty"`
+	Timestamp    string `json:"timestamp,omitempty"`
+	Content      string `json:"content,omitempty"`
 }
 
 type CloudEvent struct {

services/bos/api/model.go

@@ -280,10 +280,13 @@ type CopyObjectArgs struct {
 	IfUnmodifiedSince string
 	TrafficLimit      int64
 	CannedAcl         string
+	TaggingDirective  string
 }
 
 type MultiCopyObjectArgs struct {
 	StorageClass string
+	ObjectTagging string
+	TaggingDirective string
 }
 
 type CallbackResult struct {
@@ -456,6 +459,8 @@ type InitiateMultipartUploadArgs struct {
 	ContentDisposition string
 	Expires            string
 	StorageClass       string
+	ObjectTagging      string
+	TaggingDirective   string
 }
 
 // InitiateMultipartUploadResult defines the result structure to initiate a multipart upload.

services/bos/api/multipart.go

@@ -66,6 +66,14 @@ func InitiateMultipartUpload(cli bce.Client, bucket, object, contentType string,
 					args.StorageClass)
 			}
 		}
+		if len(args.ObjectTagging) != 0 {
+			if ok, encodeTagging := validObjectTagging(args.ObjectTagging); ok {
+				req.SetHeader(http.BCE_OBJECT_TAGGING, encodeTagging)
+			}
+		}
+		if validMetadataDirective(args.TaggingDirective) {
+			req.SetHeader(http.BCE_COPY_TAGGING_DIRECTIVE, args.TaggingDirective)
+		}
 	}
 
 	// Send request and get the result

services/bos/api/object.go

@@ -201,6 +201,9 @@ func CopyObject(cli bce.Client, bucket, object, source string,
 					"invalid metadata directive value: " + args.MetadataDirective)
 			}
 		}
+		if validMetadataDirective(args.TaggingDirective) {
+			req.SetHeader(http.BCE_COPY_TAGGING_DIRECTIVE, args.TaggingDirective)
+		}
 		if validStorageClass(args.StorageClass) {
 			req.SetHeader(http.BCE_STORAGE_CLASS, args.StorageClass)
 		} else {

services/bos/client.go

@@ -2118,6 +2118,8 @@ func (c *Client) ParallelCopy(srcBucketName string, srcObjectName string,
 		ContentDisposition: objectMeta.ContentDisposition,
 		Expires:            objectMeta.Expires,
 		StorageClass:       objectMeta.StorageClass,
+		ObjectTagging: args.ObjectTagging,
+		TaggingDirective: args.TaggingDirective,
 	}
 	if args != nil {
 		if len(args.StorageClass) != 0 {

services/cce/v2/types/instance_group.go

@@ -29,8 +29,11 @@ type InstanceGroupSpec struct {
 
 	CleanPolicy CleanPolicy `json:"cleanPolicy,omitempty" `
 
-	InstanceTemplate InstanceTemplate `json:"instanceTemplate" `
-	Replicas         int              `json:"replicas" `
+	// Deprecated: Use InstanceTemplates instead.
+	InstanceTemplate  InstanceTemplate   `json:"instanceTemplate" `
+	InstanceTemplates []InstanceTemplate `json:"instanceTemplates,omitempty" `
+
+	Replicas int `json:"replicas" `
 
 	ClusterAutoscalerSpec *ClusterAutoscalerSpec `json:"clusterAutoscalerSpec,omitempty" `
 }