Merge pull request #201 from tencentyun/feature_jojoliang_6a39e426

Feature jojoliang 6a39e426

Author: agin719

batch.go

@@ -274,3 +274,18 @@ func (s *BatchService) UpdateJobStatus(ctx context.Context, opt *BatchUpdateStat
 	resp, err := s.client.send(ctx, &sendOpt)
 	return &res, resp, err
 }
+
+func (s *BatchService) DeleteJob(ctx context.Context, id string, headers *BatchRequestHeaders) (*Response, error) {
+	if len(id) == 0 {
+		return nil, fmt.Errorf("Id is invalid")
+	}
+	u := fmt.Sprintf("/jobs/%s", id)
+	sendOpt := sendOptions{
+		baseURL:   s.client.BaseURL.BatchURL,
+		uri:       u,
+		method:    http.MethodDelete,
+		optHeader: headers,
+	}
+	resp, err := s.client.send(ctx, &sendOpt)
+	return resp, err
+}

batch_test.go

@@ -194,7 +194,6 @@ func TestBatchService_DescribeJob(t *testing.T) {
 	if !reflect.DeepEqual(ref, want) {
 		t.Errorf("Batch.DescribeJob returned %+v, want %+v", ref, want)
 	}
-
 }
 
 func TestBatchService_ListJobs(t *testing.T) {
@@ -387,3 +386,21 @@ func TestBatchService_UpdateJobsStatus(t *testing.T) {
 		t.Errorf("Batch.UpdateJobsStatus returned %+v, want %+v", ref, want)
 	}
 }
+
+func TestBatchService_DeleteJob(t *testing.T) {
+	setup()
+	defer teardown()
+
+	mux.HandleFunc("/jobs/53dc6228-c50b-46f7-8ad7-65e7159f1aae", func(w http.ResponseWriter, r *http.Request) {
+		testHeader(t, r, "x-cos-appid", "1250000000")
+		testMethod(t, r, http.MethodDelete)
+	})
+
+	headers := &BatchRequestHeaders{
+		XCosAppid: 1250000000,
+	}
+	_, err := client.Batch.DeleteJob(context.Background(), "53dc6228-c50b-46f7-8ad7-65e7159f1aae", headers)
+	if err != nil {
+		t.Fatalf("Batch.DescribeJob returned error: %v", err)
+	}
+}

example/batch/delete_job.go

@@ -0,0 +1,40 @@
+package main
+
+import (
+	"context"
+	"net/http"
+	"net/url"
+	"os"
+
+	"github.com/tencentyun/cos-go-sdk-v5"
+	"github.com/tencentyun/cos-go-sdk-v5/debug"
+)
+
+func main() {
+	uin := "100010805041"
+	appid := 1259654469
+	jobid := "49e0dd01-27a6-41a6-97b2-dda3cca19223"
+	u, _ := url.Parse("https://" + uin + ".cos-control.ap-guangzhou.myqcloud.com")
+	b := &cos.BaseURL{BatchURL: u}
+	c := cos.NewClient(b, &http.Client{
+		Transport: &cos.AuthorizationTransport{
+			SecretID:  os.Getenv("COS_SECRETID"),
+			SecretKey: os.Getenv("COS_SECRETKEY"),
+			Transport: &debug.DebugRequestTransport{
+				RequestHeader:  true,
+				RequestBody:    true,
+				ResponseHeader: true,
+				ResponseBody:   true,
+			},
+		},
+	})
+
+	headers := &cos.BatchRequestHeaders{
+		XCosAppid: appid,
+	}
+
+	_, err := c.Batch.DeleteJob(context.Background(), jobid, headers)
+	if err != nil {
+		panic(err)
+	}
+}