Add CnsSyncVolume API bindings

Signed-off-by: Nikhil Barge <[email protected]>

Author: nikhilbarge

cns/client.go

@@ -307,3 +307,16 @@ func (c *Client) SyncDatastore(ctx context.Context, dsURL string, fullSync bool)
 	}
 	return object.NewTask(c.vim25Client, res.Returnval), nil
 }
+
+// SyncVolume calls the CnsSyncVolume API
+func (c *Client) SyncVolume(ctx context.Context, syncSpecs []cnstypes.CnsSyncVolumeSpec) (*object.Task, error) {
+	req := cnstypes.CnsSyncVolume{
+		This:      CnsVolumeManagerInstance,
+		SyncSpecs: syncSpecs,
+	}
+	res, err := methods.CnsSyncVolume(ctx, c, &req)
+	if err != nil {
+		return nil, err
+	}
+	return object.NewTask(c.vim25Client, res.Returnval), nil
+}

cns/client_test.go

@@ -1641,6 +1641,37 @@ func TestClient(t *testing.T) {
 		t.Fatalf("%+v", syncDatastoreTaskInfo.Error)
 	}
 	t.Logf("syncDatastore on %v with full sync successful\n", dsUrl)
+
+	// Test CnsSyncVolume API
+	/*
+		t.Logf("Calling syncVolume for volumeId: %v ...\n", volumeId)
+		var cnsSyncVolumeSpecs []cnstypes.CnsSyncVolumeSpec
+		dataStore := ds.Reference()
+		cnsSyncVolumeSpec := cnstypes.CnsSyncVolumeSpec{
+			VolumeId: cnstypes.CnsVolumeId{
+				Id: volumeId,
+			},
+			Datastore: &dataStore,
+			SyncMode:  []string{string(cnstypes.CnsSyncVolumeModeSPACE_USAGE)},
+		}
+		cnsSyncVolumeSpecs = append(cnsSyncVolumeSpecs, cnsSyncVolumeSpec)
+		syncVolumeTask, err := cnsClient.SyncVolume(ctx, cnsSyncVolumeSpecs)
+		if err != nil {
+			t.Errorf("Failed to sync volume %v. Error: %+v \n", volumeId, err)
+			t.Fatal(err)
+		}
+		syncVolumeTaskInfo, err := GetTaskInfo(ctx, syncVolumeTask)
+		if err != nil {
+			t.Errorf("Failed to get sync volume taskInfo. Error: %+v \n", err)
+			t.Fatal(err)
+		}
+		if syncVolumeTaskInfo.State != vim25types.TaskInfoStateSuccess {
+			t.Errorf("Failed to sync volume. Error: %+v \n", syncVolumeTaskInfo.Error)
+			t.Fatalf("%+v", syncVolumeTaskInfo.Error)
+		}
+		t.Logf("syncVolume for volumeId: %v successful...\n", volumeId)
+	*/
+
 }
 
 // isvSphereVersion70U3orAbove checks if specified version is 7.0 Update 3 or higher

cns/methods/methods.go

@@ -355,3 +355,23 @@ func CnsSyncDatastore(ctx context.Context, r soap.RoundTripper, req *types.CnsSy
 
 	return resBody.Res, nil
 }
+
+type CnsSyncVolumeBody struct {
+	Req    *types.CnsSyncVolume         `xml:"urn:vsan CnsSyncVolume,omitempty"`
+	Res    *types.CnsSyncVolumeResponse `xml:"urn:vsan CnsSyncVolumeResponse,omitempty"`
+	Fault_ *soap.Fault                  `xml:"http://schemas.xmlsoap.org/soap/envelope/ Fault,omitempty"`
+}
+
+func (b *CnsSyncVolumeBody) Fault() *soap.Fault { return b.Fault_ }
+
+func CnsSyncVolume(ctx context.Context, r soap.RoundTripper, req *types.CnsSyncVolume) (*types.CnsSyncVolumeResponse, error) {
+	var reqBody, resBody CnsSyncVolumeBody
+
+	reqBody.Req = req
+
+	if err := r.RoundTrip(ctx, &reqBody, &resBody); err != nil {
+		return nil, err
+	}
+
+	return resBody.Res, nil
+}

cns/types/enum.go

@@ -85,3 +85,13 @@ const (
 func init() {
 	types.Add("CnsKubernetesEntityType", reflect.TypeOf((*CnsKubernetesEntityType)(nil)).Elem())
 }
+
+type CnsSyncVolumeMode string
+
+const (
+	CnsSyncVolumeModeSPACE_USAGE = CnsSyncVolumeMode("SPACE_USAGE")
+)
+
+func init() {
+	types.Add("vsan:CnsSyncVolumeMode", reflect.TypeOf((*CnsSyncVolumeMode)(nil)).Elem())
+}

cns/types/types.go

@@ -950,3 +950,34 @@ func init() {
 type CnsSyncDatastoreResponse struct {
 	Returnval types.ManagedObjectReference `xml:"returnval" json:"returnval"`
 }
+
+type CnsSyncVolume CnsSyncVolumeRequestType
+
+func init() {
+	types.Add("vsan:CnsSyncVolume", reflect.TypeOf((*CnsSyncVolume)(nil)).Elem())
+}
+
+type CnsSyncVolumeRequestType struct {
+	This      types.ManagedObjectReference `xml:"_this"`
+	SyncSpecs []CnsSyncVolumeSpec          `xml:"syncSpecs,omitempty"`
+}
+
+func init() {
+	types.Add("vsan:CnsSyncVolumeRequestType", reflect.TypeOf((*CnsSyncVolumeRequestType)(nil)).Elem())
+}
+
+type CnsSyncVolumeResponse struct {
+	Returnval types.ManagedObjectReference `xml:"returnval"`
+}
+
+type CnsSyncVolumeSpec struct {
+	types.DynamicData
+
+	VolumeId  CnsVolumeId                   `xml:"volumeId"`
+	Datastore *types.ManagedObjectReference `xml:"datastore,omitempty"`
+	SyncMode  []string                      `xml:"syncMode,omitempty"`
+}
+
+func init() {
+	types.Add("vsan:CnsSyncVolumeSpec", reflect.TypeOf((*CnsSyncVolumeSpec)(nil)).Elem())
+}