cloudstack/StoragePoolService.go (1,828 lines of code) (raw):

// // Licensed to the Apache Software Foundation (ASF) under one // or more contributor license agreements. See the NOTICE file // distributed with this work for additional information // regarding copyright ownership. The ASF licenses this file // to you under the Apache License, Version 2.0 (the // "License"); you may not use this file except in compliance // with the License. You may obtain a copy of the License at // // http://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, // software distributed under the License is distributed on an // "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. // package cloudstack import ( "encoding/json" "fmt" "net/url" "strconv" "strings" ) type StoragePoolServiceIface interface { CancelStorageMaintenance(p *CancelStorageMaintenanceParams) (*CancelStorageMaintenanceResponse, error) NewCancelStorageMaintenanceParams(id string) *CancelStorageMaintenanceParams ChangeStoragePoolScope(p *ChangeStoragePoolScopeParams) (*ChangeStoragePoolScopeResponse, error) NewChangeStoragePoolScopeParams(id string, scope string) *ChangeStoragePoolScopeParams EnableStorageMaintenance(p *EnableStorageMaintenanceParams) (*EnableStorageMaintenanceResponse, error) NewEnableStorageMaintenanceParams(id string) *EnableStorageMaintenanceParams ListAffectedVmsForStorageScopeChange(p *ListAffectedVmsForStorageScopeChangeParams) (*ListAffectedVmsForStorageScopeChangeResponse, error) NewListAffectedVmsForStorageScopeChangeParams(clusterid string, storageid string) *ListAffectedVmsForStorageScopeChangeParams GetAffectedVmsForStorageScopeChangeID(keyword string, clusterid string, storageid string, opts ...OptionFunc) (string, int, error) ListStorageProviders(p *ListStorageProvidersParams) (*ListStorageProvidersResponse, error) NewListStorageProvidersParams(storagePoolType string) *ListStorageProvidersParams ListObjectStoragePools(p *ListObjectStoragePoolsParams) (*ListObjectStoragePoolsResponse, error) NewListObjectStoragePoolsParams() *ListObjectStoragePoolsParams GetObjectStoragePoolID(name string, opts ...OptionFunc) (string, int, error) GetObjectStoragePoolByName(name string, opts ...OptionFunc) (*ObjectStoragePool, int, error) GetObjectStoragePoolByID(id string, opts ...OptionFunc) (*ObjectStoragePool, int, error) ListStoragePoolObjects(p *ListStoragePoolObjectsParams) (*ListStoragePoolObjectsResponse, error) NewListStoragePoolObjectsParams(id string) *ListStoragePoolObjectsParams GetStoragePoolObjectByID(id string, opts ...OptionFunc) (*StoragePoolObject, int, error) UpdateObjectStoragePool(p *UpdateObjectStoragePoolParams) (*UpdateObjectStoragePoolResponse, error) NewUpdateObjectStoragePoolParams(id string) *UpdateObjectStoragePoolParams AddObjectStoragePool(p *AddObjectStoragePoolParams) (*AddObjectStoragePoolResponse, error) NewAddObjectStoragePoolParams(name string, provider string, url string) *AddObjectStoragePoolParams DeleteObjectStoragePool(p *DeleteObjectStoragePoolParams) (*DeleteObjectStoragePoolResponse, error) NewDeleteObjectStoragePoolParams(id string) *DeleteObjectStoragePoolParams ListStoragePoolsMetrics(p *ListStoragePoolsMetricsParams) (*ListStoragePoolsMetricsResponse, error) NewListStoragePoolsMetricsParams() *ListStoragePoolsMetricsParams GetStoragePoolsMetricID(name string, opts ...OptionFunc) (string, int, error) GetStoragePoolsMetricByName(name string, opts ...OptionFunc) (*StoragePoolsMetric, int, error) GetStoragePoolsMetricByID(id string, opts ...OptionFunc) (*StoragePoolsMetric, int, error) } type CancelStorageMaintenanceParams struct { p map[string]interface{} } func (p *CancelStorageMaintenanceParams) toURLValues() url.Values { u := url.Values{} if p.p == nil { return u } if v, found := p.p["id"]; found { u.Set("id", v.(string)) } return u } func (p *CancelStorageMaintenanceParams) SetId(v string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["id"] = v } func (p *CancelStorageMaintenanceParams) ResetId() { if p.p != nil && p.p["id"] != nil { delete(p.p, "id") } } func (p *CancelStorageMaintenanceParams) GetId() (string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["id"].(string) return value, ok } // You should always use this function to get a new CancelStorageMaintenanceParams instance, // as then you are sure you have configured all required params func (s *StoragePoolService) NewCancelStorageMaintenanceParams(id string) *CancelStorageMaintenanceParams { p := &CancelStorageMaintenanceParams{} p.p = make(map[string]interface{}) p.p["id"] = id return p } // Cancels maintenance for primary storage func (s *StoragePoolService) CancelStorageMaintenance(p *CancelStorageMaintenanceParams) (*CancelStorageMaintenanceResponse, error) { resp, err := s.cs.newRequest("cancelStorageMaintenance", p.toURLValues()) if err != nil { return nil, err } var r CancelStorageMaintenanceResponse if err := json.Unmarshal(resp, &r); err != nil { return nil, err } // If we have a async client, we need to wait for the async result if s.cs.async { b, err := s.cs.GetAsyncJobResult(r.JobID, s.cs.timeout) if err != nil { if err == AsyncTimeoutErr { return &r, err } return nil, err } b, err = getRawValue(b) if err != nil { return nil, err } if err := json.Unmarshal(b, &r); err != nil { return nil, err } } return &r, nil } type CancelStorageMaintenanceResponse struct { Allocatediops int64 `json:"allocatediops"` Capacityiops int64 `json:"capacityiops"` Clusterid string `json:"clusterid"` Clustername string `json:"clustername"` Created string `json:"created"` Disksizeallocated int64 `json:"disksizeallocated"` Disksizetotal int64 `json:"disksizetotal"` Disksizeused int64 `json:"disksizeused"` Hasannotations bool `json:"hasannotations"` Hypervisor string `json:"hypervisor"` Id string `json:"id"` Ipaddress string `json:"ipaddress"` Istagarule bool `json:"istagarule"` JobID string `json:"jobid"` Jobstatus int `json:"jobstatus"` Managed bool `json:"managed"` Name string `json:"name"` Nfsmountopts string `json:"nfsmountopts"` Overprovisionfactor string `json:"overprovisionfactor"` Path string `json:"path"` Podid string `json:"podid"` Podname string `json:"podname"` Provider string `json:"provider"` Scope string `json:"scope"` State string `json:"state"` Storagecapabilities map[string]string `json:"storagecapabilities"` Storagecustomstats map[string]string `json:"storagecustomstats"` Suitableformigration bool `json:"suitableformigration"` Tags string `json:"tags"` Type string `json:"type"` Zoneid string `json:"zoneid"` Zonename string `json:"zonename"` } type ChangeStoragePoolScopeParams struct { p map[string]interface{} } func (p *ChangeStoragePoolScopeParams) toURLValues() url.Values { u := url.Values{} if p.p == nil { return u } if v, found := p.p["clusterid"]; found { u.Set("clusterid", v.(string)) } if v, found := p.p["id"]; found { u.Set("id", v.(string)) } if v, found := p.p["scope"]; found { u.Set("scope", v.(string)) } return u } func (p *ChangeStoragePoolScopeParams) SetClusterid(v string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["clusterid"] = v } func (p *ChangeStoragePoolScopeParams) ResetClusterid() { if p.p != nil && p.p["clusterid"] != nil { delete(p.p, "clusterid") } } func (p *ChangeStoragePoolScopeParams) GetClusterid() (string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["clusterid"].(string) return value, ok } func (p *ChangeStoragePoolScopeParams) SetId(v string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["id"] = v } func (p *ChangeStoragePoolScopeParams) ResetId() { if p.p != nil && p.p["id"] != nil { delete(p.p, "id") } } func (p *ChangeStoragePoolScopeParams) GetId() (string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["id"].(string) return value, ok } func (p *ChangeStoragePoolScopeParams) SetScope(v string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["scope"] = v } func (p *ChangeStoragePoolScopeParams) ResetScope() { if p.p != nil && p.p["scope"] != nil { delete(p.p, "scope") } } func (p *ChangeStoragePoolScopeParams) GetScope() (string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["scope"].(string) return value, ok } // You should always use this function to get a new ChangeStoragePoolScopeParams instance, // as then you are sure you have configured all required params func (s *StoragePoolService) NewChangeStoragePoolScopeParams(id string, scope string) *ChangeStoragePoolScopeParams { p := &ChangeStoragePoolScopeParams{} p.p = make(map[string]interface{}) p.p["id"] = id p.p["scope"] = scope return p } // Changes the scope of a storage pool when the pool is in Disabled state.This feature is officially tested and supported for Hypervisors: KVM and VMware, Protocols: NFS and Ceph, and Storage Provider: DefaultPrimary. There might be extra steps involved to make this work for other hypervisors and storage options. func (s *StoragePoolService) ChangeStoragePoolScope(p *ChangeStoragePoolScopeParams) (*ChangeStoragePoolScopeResponse, error) { resp, err := s.cs.newRequest("changeStoragePoolScope", p.toURLValues()) if err != nil { return nil, err } var r ChangeStoragePoolScopeResponse if err := json.Unmarshal(resp, &r); err != nil { return nil, err } // If we have a async client, we need to wait for the async result if s.cs.async { b, err := s.cs.GetAsyncJobResult(r.JobID, s.cs.timeout) if err != nil { if err == AsyncTimeoutErr { return &r, err } return nil, err } if err := json.Unmarshal(b, &r); err != nil { return nil, err } } return &r, nil } type ChangeStoragePoolScopeResponse struct { Displaytext string `json:"displaytext"` JobID string `json:"jobid"` Jobstatus int `json:"jobstatus"` Success bool `json:"success"` } type EnableStorageMaintenanceParams struct { p map[string]interface{} } func (p *EnableStorageMaintenanceParams) toURLValues() url.Values { u := url.Values{} if p.p == nil { return u } if v, found := p.p["id"]; found { u.Set("id", v.(string)) } return u } func (p *EnableStorageMaintenanceParams) SetId(v string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["id"] = v } func (p *EnableStorageMaintenanceParams) ResetId() { if p.p != nil && p.p["id"] != nil { delete(p.p, "id") } } func (p *EnableStorageMaintenanceParams) GetId() (string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["id"].(string) return value, ok } // You should always use this function to get a new EnableStorageMaintenanceParams instance, // as then you are sure you have configured all required params func (s *StoragePoolService) NewEnableStorageMaintenanceParams(id string) *EnableStorageMaintenanceParams { p := &EnableStorageMaintenanceParams{} p.p = make(map[string]interface{}) p.p["id"] = id return p } // Puts storage pool into maintenance state func (s *StoragePoolService) EnableStorageMaintenance(p *EnableStorageMaintenanceParams) (*EnableStorageMaintenanceResponse, error) { resp, err := s.cs.newRequest("enableStorageMaintenance", p.toURLValues()) if err != nil { return nil, err } var r EnableStorageMaintenanceResponse if err := json.Unmarshal(resp, &r); err != nil { return nil, err } // If we have a async client, we need to wait for the async result if s.cs.async { b, err := s.cs.GetAsyncJobResult(r.JobID, s.cs.timeout) if err != nil { if err == AsyncTimeoutErr { return &r, err } return nil, err } b, err = getRawValue(b) if err != nil { return nil, err } if err := json.Unmarshal(b, &r); err != nil { return nil, err } } return &r, nil } type EnableStorageMaintenanceResponse struct { Allocatediops int64 `json:"allocatediops"` Capacityiops int64 `json:"capacityiops"` Clusterid string `json:"clusterid"` Clustername string `json:"clustername"` Created string `json:"created"` Disksizeallocated int64 `json:"disksizeallocated"` Disksizetotal int64 `json:"disksizetotal"` Disksizeused int64 `json:"disksizeused"` Hasannotations bool `json:"hasannotations"` Hypervisor string `json:"hypervisor"` Id string `json:"id"` Ipaddress string `json:"ipaddress"` Istagarule bool `json:"istagarule"` JobID string `json:"jobid"` Jobstatus int `json:"jobstatus"` Managed bool `json:"managed"` Name string `json:"name"` Nfsmountopts string `json:"nfsmountopts"` Overprovisionfactor string `json:"overprovisionfactor"` Path string `json:"path"` Podid string `json:"podid"` Podname string `json:"podname"` Provider string `json:"provider"` Scope string `json:"scope"` State string `json:"state"` Storagecapabilities map[string]string `json:"storagecapabilities"` Storagecustomstats map[string]string `json:"storagecustomstats"` Suitableformigration bool `json:"suitableformigration"` Tags string `json:"tags"` Type string `json:"type"` Zoneid string `json:"zoneid"` Zonename string `json:"zonename"` } type ListAffectedVmsForStorageScopeChangeParams struct { p map[string]interface{} } func (p *ListAffectedVmsForStorageScopeChangeParams) toURLValues() url.Values { u := url.Values{} if p.p == nil { return u } if v, found := p.p["clusterid"]; found { u.Set("clusterid", v.(string)) } if v, found := p.p["keyword"]; found { u.Set("keyword", v.(string)) } if v, found := p.p["page"]; found { vv := strconv.Itoa(v.(int)) u.Set("page", vv) } if v, found := p.p["pagesize"]; found { vv := strconv.Itoa(v.(int)) u.Set("pagesize", vv) } if v, found := p.p["storageid"]; found { u.Set("storageid", v.(string)) } return u } func (p *ListAffectedVmsForStorageScopeChangeParams) SetClusterid(v string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["clusterid"] = v } func (p *ListAffectedVmsForStorageScopeChangeParams) ResetClusterid() { if p.p != nil && p.p["clusterid"] != nil { delete(p.p, "clusterid") } } func (p *ListAffectedVmsForStorageScopeChangeParams) GetClusterid() (string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["clusterid"].(string) return value, ok } func (p *ListAffectedVmsForStorageScopeChangeParams) SetKeyword(v string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["keyword"] = v } func (p *ListAffectedVmsForStorageScopeChangeParams) ResetKeyword() { if p.p != nil && p.p["keyword"] != nil { delete(p.p, "keyword") } } func (p *ListAffectedVmsForStorageScopeChangeParams) GetKeyword() (string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["keyword"].(string) return value, ok } func (p *ListAffectedVmsForStorageScopeChangeParams) SetPage(v int) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["page"] = v } func (p *ListAffectedVmsForStorageScopeChangeParams) ResetPage() { if p.p != nil && p.p["page"] != nil { delete(p.p, "page") } } func (p *ListAffectedVmsForStorageScopeChangeParams) GetPage() (int, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["page"].(int) return value, ok } func (p *ListAffectedVmsForStorageScopeChangeParams) SetPagesize(v int) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["pagesize"] = v } func (p *ListAffectedVmsForStorageScopeChangeParams) ResetPagesize() { if p.p != nil && p.p["pagesize"] != nil { delete(p.p, "pagesize") } } func (p *ListAffectedVmsForStorageScopeChangeParams) GetPagesize() (int, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["pagesize"].(int) return value, ok } func (p *ListAffectedVmsForStorageScopeChangeParams) SetStorageid(v string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["storageid"] = v } func (p *ListAffectedVmsForStorageScopeChangeParams) ResetStorageid() { if p.p != nil && p.p["storageid"] != nil { delete(p.p, "storageid") } } func (p *ListAffectedVmsForStorageScopeChangeParams) GetStorageid() (string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["storageid"].(string) return value, ok } // You should always use this function to get a new ListAffectedVmsForStorageScopeChangeParams instance, // as then you are sure you have configured all required params func (s *StoragePoolService) NewListAffectedVmsForStorageScopeChangeParams(clusterid string, storageid string) *ListAffectedVmsForStorageScopeChangeParams { p := &ListAffectedVmsForStorageScopeChangeParams{} p.p = make(map[string]interface{}) p.p["clusterid"] = clusterid p.p["storageid"] = storageid return p } // This is a courtesy helper function, which in some cases may not work as expected! func (s *StoragePoolService) GetAffectedVmsForStorageScopeChangeID(keyword string, clusterid string, storageid string, opts ...OptionFunc) (string, int, error) { p := &ListAffectedVmsForStorageScopeChangeParams{} p.p = make(map[string]interface{}) p.p["keyword"] = keyword p.p["clusterid"] = clusterid p.p["storageid"] = storageid for _, fn := range append(s.cs.options, opts...) { if err := fn(s.cs, p); err != nil { return "", -1, err } } l, err := s.ListAffectedVmsForStorageScopeChange(p) if err != nil { return "", -1, err } if l.Count == 0 { return "", l.Count, fmt.Errorf("No match found for %s: %+v", keyword, l) } if l.Count == 1 { return l.AffectedVmsForStorageScopeChange[0].Id, l.Count, nil } if l.Count > 1 { for _, v := range l.AffectedVmsForStorageScopeChange { if v.Name == keyword { return v.Id, l.Count, nil } } } return "", l.Count, fmt.Errorf("Could not find an exact match for %s: %+v", keyword, l) } // List user and system VMs that need to be stopped and destroyed respectively for changing the scope of the storage pool from Zone to Cluster. func (s *StoragePoolService) ListAffectedVmsForStorageScopeChange(p *ListAffectedVmsForStorageScopeChangeParams) (*ListAffectedVmsForStorageScopeChangeResponse, error) { resp, err := s.cs.newRequest("listAffectedVmsForStorageScopeChange", p.toURLValues()) if err != nil { return nil, err } var r ListAffectedVmsForStorageScopeChangeResponse if err := json.Unmarshal(resp, &r); err != nil { return nil, err } return &r, nil } type ListAffectedVmsForStorageScopeChangeResponse struct { Count int `json:"count"` AffectedVmsForStorageScopeChange []*AffectedVmsForStorageScopeChange `json:"affectedvmsforstoragescopechange"` } type AffectedVmsForStorageScopeChange struct { Clusterid string `json:"clusterid"` Clustername string `json:"clustername"` Hostid string `json:"hostid"` Hostname string `json:"hostname"` Id string `json:"id"` JobID string `json:"jobid"` Jobstatus int `json:"jobstatus"` Name string `json:"name"` Type string `json:"type"` } type ListStorageProvidersParams struct { p map[string]interface{} } func (p *ListStorageProvidersParams) toURLValues() url.Values { u := url.Values{} if p.p == nil { return u } if v, found := p.p["keyword"]; found { u.Set("keyword", v.(string)) } if v, found := p.p["page"]; found { vv := strconv.Itoa(v.(int)) u.Set("page", vv) } if v, found := p.p["pagesize"]; found { vv := strconv.Itoa(v.(int)) u.Set("pagesize", vv) } if v, found := p.p["type"]; found { u.Set("type", v.(string)) } return u } func (p *ListStorageProvidersParams) SetKeyword(v string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["keyword"] = v } func (p *ListStorageProvidersParams) ResetKeyword() { if p.p != nil && p.p["keyword"] != nil { delete(p.p, "keyword") } } func (p *ListStorageProvidersParams) GetKeyword() (string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["keyword"].(string) return value, ok } func (p *ListStorageProvidersParams) SetPage(v int) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["page"] = v } func (p *ListStorageProvidersParams) ResetPage() { if p.p != nil && p.p["page"] != nil { delete(p.p, "page") } } func (p *ListStorageProvidersParams) GetPage() (int, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["page"].(int) return value, ok } func (p *ListStorageProvidersParams) SetPagesize(v int) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["pagesize"] = v } func (p *ListStorageProvidersParams) ResetPagesize() { if p.p != nil && p.p["pagesize"] != nil { delete(p.p, "pagesize") } } func (p *ListStorageProvidersParams) GetPagesize() (int, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["pagesize"].(int) return value, ok } func (p *ListStorageProvidersParams) SetType(v string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["type"] = v } func (p *ListStorageProvidersParams) ResetType() { if p.p != nil && p.p["type"] != nil { delete(p.p, "type") } } func (p *ListStorageProvidersParams) GetType() (string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["type"].(string) return value, ok } // You should always use this function to get a new ListStorageProvidersParams instance, // as then you are sure you have configured all required params func (s *StoragePoolService) NewListStorageProvidersParams(storagePoolType string) *ListStorageProvidersParams { p := &ListStorageProvidersParams{} p.p = make(map[string]interface{}) p.p["type"] = storagePoolType return p } // Lists storage providers. func (s *StoragePoolService) ListStorageProviders(p *ListStorageProvidersParams) (*ListStorageProvidersResponse, error) { resp, err := s.cs.newRequest("listStorageProviders", p.toURLValues()) if err != nil { return nil, err } var r ListStorageProvidersResponse if err := json.Unmarshal(resp, &r); err != nil { return nil, err } return &r, nil } type ListStorageProvidersResponse struct { Count int `json:"count"` StorageProviders []*StorageProvider `json:"storageprovider"` } type StorageProvider struct { JobID string `json:"jobid"` Jobstatus int `json:"jobstatus"` Name string `json:"name"` Type string `json:"type"` } type ListObjectStoragePoolsParams struct { p map[string]interface{} } func (p *ListObjectStoragePoolsParams) toURLValues() url.Values { u := url.Values{} if p.p == nil { return u } if v, found := p.p["id"]; found { u.Set("id", v.(string)) } if v, found := p.p["keyword"]; found { u.Set("keyword", v.(string)) } if v, found := p.p["name"]; found { u.Set("name", v.(string)) } if v, found := p.p["page"]; found { vv := strconv.Itoa(v.(int)) u.Set("page", vv) } if v, found := p.p["pagesize"]; found { vv := strconv.Itoa(v.(int)) u.Set("pagesize", vv) } if v, found := p.p["provider"]; found { u.Set("provider", v.(string)) } return u } func (p *ListObjectStoragePoolsParams) SetId(v string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["id"] = v } func (p *ListObjectStoragePoolsParams) ResetId() { if p.p != nil && p.p["id"] != nil { delete(p.p, "id") } } func (p *ListObjectStoragePoolsParams) GetId() (string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["id"].(string) return value, ok } func (p *ListObjectStoragePoolsParams) SetKeyword(v string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["keyword"] = v } func (p *ListObjectStoragePoolsParams) ResetKeyword() { if p.p != nil && p.p["keyword"] != nil { delete(p.p, "keyword") } } func (p *ListObjectStoragePoolsParams) GetKeyword() (string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["keyword"].(string) return value, ok } func (p *ListObjectStoragePoolsParams) SetName(v string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["name"] = v } func (p *ListObjectStoragePoolsParams) ResetName() { if p.p != nil && p.p["name"] != nil { delete(p.p, "name") } } func (p *ListObjectStoragePoolsParams) GetName() (string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["name"].(string) return value, ok } func (p *ListObjectStoragePoolsParams) SetPage(v int) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["page"] = v } func (p *ListObjectStoragePoolsParams) ResetPage() { if p.p != nil && p.p["page"] != nil { delete(p.p, "page") } } func (p *ListObjectStoragePoolsParams) GetPage() (int, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["page"].(int) return value, ok } func (p *ListObjectStoragePoolsParams) SetPagesize(v int) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["pagesize"] = v } func (p *ListObjectStoragePoolsParams) ResetPagesize() { if p.p != nil && p.p["pagesize"] != nil { delete(p.p, "pagesize") } } func (p *ListObjectStoragePoolsParams) GetPagesize() (int, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["pagesize"].(int) return value, ok } func (p *ListObjectStoragePoolsParams) SetProvider(v string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["provider"] = v } func (p *ListObjectStoragePoolsParams) ResetProvider() { if p.p != nil && p.p["provider"] != nil { delete(p.p, "provider") } } func (p *ListObjectStoragePoolsParams) GetProvider() (string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["provider"].(string) return value, ok } // You should always use this function to get a new ListObjectStoragePoolsParams instance, // as then you are sure you have configured all required params func (s *StoragePoolService) NewListObjectStoragePoolsParams() *ListObjectStoragePoolsParams { p := &ListObjectStoragePoolsParams{} p.p = make(map[string]interface{}) return p } // This is a courtesy helper function, which in some cases may not work as expected! func (s *StoragePoolService) GetObjectStoragePoolID(name string, opts ...OptionFunc) (string, int, error) { p := &ListObjectStoragePoolsParams{} p.p = make(map[string]interface{}) p.p["name"] = name for _, fn := range append(s.cs.options, opts...) { if err := fn(s.cs, p); err != nil { return "", -1, err } } l, err := s.ListObjectStoragePools(p) if err != nil { return "", -1, err } if l.Count == 0 { return "", l.Count, fmt.Errorf("No match found for %s: %+v", name, l) } if l.Count == 1 { return l.ObjectStoragePools[0].Id, l.Count, nil } if l.Count > 1 { for _, v := range l.ObjectStoragePools { if v.Name == name { return v.Id, l.Count, nil } } } return "", l.Count, fmt.Errorf("Could not find an exact match for %s: %+v", name, l) } // This is a courtesy helper function, which in some cases may not work as expected! func (s *StoragePoolService) GetObjectStoragePoolByName(name string, opts ...OptionFunc) (*ObjectStoragePool, int, error) { id, count, err := s.GetObjectStoragePoolID(name, opts...) if err != nil { return nil, count, err } r, count, err := s.GetObjectStoragePoolByID(id, opts...) if err != nil { return nil, count, err } return r, count, nil } // This is a courtesy helper function, which in some cases may not work as expected! func (s *StoragePoolService) GetObjectStoragePoolByID(id string, opts ...OptionFunc) (*ObjectStoragePool, int, error) { p := &ListObjectStoragePoolsParams{} p.p = make(map[string]interface{}) p.p["id"] = id for _, fn := range append(s.cs.options, opts...) { if err := fn(s.cs, p); err != nil { return nil, -1, err } } l, err := s.ListObjectStoragePools(p) if err != nil { if strings.Contains(err.Error(), fmt.Sprintf( "Invalid parameter id value=%s due to incorrect long value format, "+ "or entity does not exist", id)) { return nil, 0, fmt.Errorf("No match found for %s: %+v", id, l) } return nil, -1, err } if l.Count == 0 { return nil, l.Count, fmt.Errorf("No match found for %s: %+v", id, l) } if l.Count == 1 { return l.ObjectStoragePools[0], l.Count, nil } return nil, l.Count, fmt.Errorf("There is more then one result for ObjectStoragePool UUID: %s!", id) } // Lists object storage pools. func (s *StoragePoolService) ListObjectStoragePools(p *ListObjectStoragePoolsParams) (*ListObjectStoragePoolsResponse, error) { resp, err := s.cs.newRequest("listObjectStoragePools", p.toURLValues()) if err != nil { return nil, err } var r ListObjectStoragePoolsResponse if err := json.Unmarshal(resp, &r); err != nil { return nil, err } return &r, nil } type ListObjectStoragePoolsResponse struct { Count int `json:"count"` ObjectStoragePools []*ObjectStoragePool `json:"objectstore"` } type ObjectStoragePool struct { Hasannotations bool `json:"hasannotations"` Id string `json:"id"` JobID string `json:"jobid"` Jobstatus int `json:"jobstatus"` Name string `json:"name"` Providername string `json:"providername"` Storagetotal int64 `json:"storagetotal"` Storageused int64 `json:"storageused"` Url string `json:"url"` } type ListStoragePoolObjectsParams struct { p map[string]interface{} } func (p *ListStoragePoolObjectsParams) toURLValues() url.Values { u := url.Values{} if p.p == nil { return u } if v, found := p.p["id"]; found { u.Set("id", v.(string)) } if v, found := p.p["keyword"]; found { u.Set("keyword", v.(string)) } if v, found := p.p["page"]; found { vv := strconv.Itoa(v.(int)) u.Set("page", vv) } if v, found := p.p["pagesize"]; found { vv := strconv.Itoa(v.(int)) u.Set("pagesize", vv) } if v, found := p.p["path"]; found { u.Set("path", v.(string)) } return u } func (p *ListStoragePoolObjectsParams) SetId(v string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["id"] = v } func (p *ListStoragePoolObjectsParams) ResetId() { if p.p != nil && p.p["id"] != nil { delete(p.p, "id") } } func (p *ListStoragePoolObjectsParams) GetId() (string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["id"].(string) return value, ok } func (p *ListStoragePoolObjectsParams) SetKeyword(v string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["keyword"] = v } func (p *ListStoragePoolObjectsParams) ResetKeyword() { if p.p != nil && p.p["keyword"] != nil { delete(p.p, "keyword") } } func (p *ListStoragePoolObjectsParams) GetKeyword() (string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["keyword"].(string) return value, ok } func (p *ListStoragePoolObjectsParams) SetPage(v int) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["page"] = v } func (p *ListStoragePoolObjectsParams) ResetPage() { if p.p != nil && p.p["page"] != nil { delete(p.p, "page") } } func (p *ListStoragePoolObjectsParams) GetPage() (int, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["page"].(int) return value, ok } func (p *ListStoragePoolObjectsParams) SetPagesize(v int) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["pagesize"] = v } func (p *ListStoragePoolObjectsParams) ResetPagesize() { if p.p != nil && p.p["pagesize"] != nil { delete(p.p, "pagesize") } } func (p *ListStoragePoolObjectsParams) GetPagesize() (int, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["pagesize"].(int) return value, ok } func (p *ListStoragePoolObjectsParams) SetPath(v string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["path"] = v } func (p *ListStoragePoolObjectsParams) ResetPath() { if p.p != nil && p.p["path"] != nil { delete(p.p, "path") } } func (p *ListStoragePoolObjectsParams) GetPath() (string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["path"].(string) return value, ok } // You should always use this function to get a new ListStoragePoolObjectsParams instance, // as then you are sure you have configured all required params func (s *StoragePoolService) NewListStoragePoolObjectsParams(id string) *ListStoragePoolObjectsParams { p := &ListStoragePoolObjectsParams{} p.p = make(map[string]interface{}) p.p["id"] = id return p } // This is a courtesy helper function, which in some cases may not work as expected! func (s *StoragePoolService) GetStoragePoolObjectByID(id string, opts ...OptionFunc) (*StoragePoolObject, int, error) { p := &ListStoragePoolObjectsParams{} p.p = make(map[string]interface{}) p.p["id"] = id for _, fn := range append(s.cs.options, opts...) { if err := fn(s.cs, p); err != nil { return nil, -1, err } } l, err := s.ListStoragePoolObjects(p) if err != nil { if strings.Contains(err.Error(), fmt.Sprintf( "Invalid parameter id value=%s due to incorrect long value format, "+ "or entity does not exist", id)) { return nil, 0, fmt.Errorf("No match found for %s: %+v", id, l) } return nil, -1, err } if l.Count == 0 { return nil, l.Count, fmt.Errorf("No match found for %s: %+v", id, l) } if l.Count == 1 { return l.StoragePoolObjects[0], l.Count, nil } return nil, l.Count, fmt.Errorf("There is more then one result for StoragePoolObject UUID: %s!", id) } // Lists objects at specified path on a storage pool. func (s *StoragePoolService) ListStoragePoolObjects(p *ListStoragePoolObjectsParams) (*ListStoragePoolObjectsResponse, error) { resp, err := s.cs.newRequest("listStoragePoolObjects", p.toURLValues()) if err != nil { return nil, err } var r ListStoragePoolObjectsResponse if err := json.Unmarshal(resp, &r); err != nil { return nil, err } return &r, nil } type ListStoragePoolObjectsResponse struct { Count int `json:"count"` StoragePoolObjects []*StoragePoolObject `json:"datastoreobject"` } type StoragePoolObject struct { Format string `json:"format"` Isdirectory bool `json:"isdirectory"` JobID string `json:"jobid"` Jobstatus int `json:"jobstatus"` Lastupdated string `json:"lastupdated"` Name string `json:"name"` Size int64 `json:"size"` Snapshotid string `json:"snapshotid"` Snapshotname string `json:"snapshotname"` Templateid string `json:"templateid"` Templatename string `json:"templatename"` Volumeid string `json:"volumeid"` Volumename string `json:"volumename"` } type UpdateObjectStoragePoolParams struct { p map[string]interface{} } func (p *UpdateObjectStoragePoolParams) toURLValues() url.Values { u := url.Values{} if p.p == nil { return u } if v, found := p.p["id"]; found { u.Set("id", v.(string)) } if v, found := p.p["name"]; found { u.Set("name", v.(string)) } if v, found := p.p["url"]; found { u.Set("url", v.(string)) } return u } func (p *UpdateObjectStoragePoolParams) SetId(v string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["id"] = v } func (p *UpdateObjectStoragePoolParams) ResetId() { if p.p != nil && p.p["id"] != nil { delete(p.p, "id") } } func (p *UpdateObjectStoragePoolParams) GetId() (string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["id"].(string) return value, ok } func (p *UpdateObjectStoragePoolParams) SetName(v string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["name"] = v } func (p *UpdateObjectStoragePoolParams) ResetName() { if p.p != nil && p.p["name"] != nil { delete(p.p, "name") } } func (p *UpdateObjectStoragePoolParams) GetName() (string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["name"].(string) return value, ok } func (p *UpdateObjectStoragePoolParams) SetUrl(v string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["url"] = v } func (p *UpdateObjectStoragePoolParams) ResetUrl() { if p.p != nil && p.p["url"] != nil { delete(p.p, "url") } } func (p *UpdateObjectStoragePoolParams) GetUrl() (string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["url"].(string) return value, ok } // You should always use this function to get a new UpdateObjectStoragePoolParams instance, // as then you are sure you have configured all required params func (s *StoragePoolService) NewUpdateObjectStoragePoolParams(id string) *UpdateObjectStoragePoolParams { p := &UpdateObjectStoragePoolParams{} p.p = make(map[string]interface{}) p.p["id"] = id return p } // Updates object storage pool func (s *StoragePoolService) UpdateObjectStoragePool(p *UpdateObjectStoragePoolParams) (*UpdateObjectStoragePoolResponse, error) { resp, err := s.cs.newRequest("updateObjectStoragePool", p.toURLValues()) if err != nil { return nil, err } var nested struct { Response UpdateObjectStoragePoolResponse `json:"objectstore"` } if err := json.Unmarshal(resp, &nested); err != nil { return nil, err } r := nested.Response return &r, nil } type UpdateObjectStoragePoolResponse struct { Hasannotations bool `json:"hasannotations"` Id string `json:"id"` JobID string `json:"jobid"` Jobstatus int `json:"jobstatus"` Name string `json:"name"` Providername string `json:"providername"` Storagetotal int64 `json:"storagetotal"` Storageused int64 `json:"storageused"` Url string `json:"url"` } type AddObjectStoragePoolParams struct { p map[string]interface{} } func (p *AddObjectStoragePoolParams) toURLValues() url.Values { u := url.Values{} if p.p == nil { return u } if v, found := p.p["details"]; found { m := v.(map[string]string) for i, k := range getSortedKeysFromMap(m) { u.Set(fmt.Sprintf("details[%d].key", i), k) u.Set(fmt.Sprintf("details[%d].value", i), m[k]) } } if v, found := p.p["name"]; found { u.Set("name", v.(string)) } if v, found := p.p["provider"]; found { u.Set("provider", v.(string)) } if v, found := p.p["tags"]; found { u.Set("tags", v.(string)) } if v, found := p.p["url"]; found { u.Set("url", v.(string)) } return u } func (p *AddObjectStoragePoolParams) SetDetails(v map[string]string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["details"] = v } func (p *AddObjectStoragePoolParams) ResetDetails() { if p.p != nil && p.p["details"] != nil { delete(p.p, "details") } } func (p *AddObjectStoragePoolParams) GetDetails() (map[string]string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["details"].(map[string]string) return value, ok } func (p *AddObjectStoragePoolParams) SetName(v string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["name"] = v } func (p *AddObjectStoragePoolParams) ResetName() { if p.p != nil && p.p["name"] != nil { delete(p.p, "name") } } func (p *AddObjectStoragePoolParams) GetName() (string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["name"].(string) return value, ok } func (p *AddObjectStoragePoolParams) SetProvider(v string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["provider"] = v } func (p *AddObjectStoragePoolParams) ResetProvider() { if p.p != nil && p.p["provider"] != nil { delete(p.p, "provider") } } func (p *AddObjectStoragePoolParams) GetProvider() (string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["provider"].(string) return value, ok } func (p *AddObjectStoragePoolParams) SetTags(v string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["tags"] = v } func (p *AddObjectStoragePoolParams) ResetTags() { if p.p != nil && p.p["tags"] != nil { delete(p.p, "tags") } } func (p *AddObjectStoragePoolParams) GetTags() (string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["tags"].(string) return value, ok } func (p *AddObjectStoragePoolParams) SetUrl(v string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["url"] = v } func (p *AddObjectStoragePoolParams) ResetUrl() { if p.p != nil && p.p["url"] != nil { delete(p.p, "url") } } func (p *AddObjectStoragePoolParams) GetUrl() (string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["url"].(string) return value, ok } // You should always use this function to get a new AddObjectStoragePoolParams instance, // as then you are sure you have configured all required params func (s *StoragePoolService) NewAddObjectStoragePoolParams(name string, provider string, url string) *AddObjectStoragePoolParams { p := &AddObjectStoragePoolParams{} p.p = make(map[string]interface{}) p.p["name"] = name p.p["provider"] = provider p.p["url"] = url return p } // Adds a object storage pool func (s *StoragePoolService) AddObjectStoragePool(p *AddObjectStoragePoolParams) (*AddObjectStoragePoolResponse, error) { resp, err := s.cs.newRequest("addObjectStoragePool", p.toURLValues()) if err != nil { return nil, err } var nested struct { Response AddObjectStoragePoolResponse `json:"objectstore"` } if err := json.Unmarshal(resp, &nested); err != nil { return nil, err } r := nested.Response return &r, nil } type AddObjectStoragePoolResponse struct { Hasannotations bool `json:"hasannotations"` Id string `json:"id"` JobID string `json:"jobid"` Jobstatus int `json:"jobstatus"` Name string `json:"name"` Providername string `json:"providername"` Storagetotal int64 `json:"storagetotal"` Storageused int64 `json:"storageused"` Url string `json:"url"` } type DeleteObjectStoragePoolParams struct { p map[string]interface{} } func (p *DeleteObjectStoragePoolParams) toURLValues() url.Values { u := url.Values{} if p.p == nil { return u } if v, found := p.p["id"]; found { u.Set("id", v.(string)) } return u } func (p *DeleteObjectStoragePoolParams) SetId(v string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["id"] = v } func (p *DeleteObjectStoragePoolParams) ResetId() { if p.p != nil && p.p["id"] != nil { delete(p.p, "id") } } func (p *DeleteObjectStoragePoolParams) GetId() (string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["id"].(string) return value, ok } // You should always use this function to get a new DeleteObjectStoragePoolParams instance, // as then you are sure you have configured all required params func (s *StoragePoolService) NewDeleteObjectStoragePoolParams(id string) *DeleteObjectStoragePoolParams { p := &DeleteObjectStoragePoolParams{} p.p = make(map[string]interface{}) p.p["id"] = id return p } // Deletes an Object Storage Pool func (s *StoragePoolService) DeleteObjectStoragePool(p *DeleteObjectStoragePoolParams) (*DeleteObjectStoragePoolResponse, error) { resp, err := s.cs.newRequest("deleteObjectStoragePool", p.toURLValues()) if err != nil { return nil, err } var r DeleteObjectStoragePoolResponse if err := json.Unmarshal(resp, &r); err != nil { return nil, err } return &r, nil } type DeleteObjectStoragePoolResponse struct { Displaytext string `json:"displaytext"` JobID string `json:"jobid"` Jobstatus int `json:"jobstatus"` Success bool `json:"success"` } func (r *DeleteObjectStoragePoolResponse) UnmarshalJSON(b []byte) error { var m map[string]interface{} err := json.Unmarshal(b, &m) if err != nil { return err } if success, ok := m["success"].(string); ok { m["success"] = success == "true" b, err = json.Marshal(m) if err != nil { return err } } if ostypeid, ok := m["ostypeid"].(float64); ok { m["ostypeid"] = strconv.Itoa(int(ostypeid)) b, err = json.Marshal(m) if err != nil { return err } } type alias DeleteObjectStoragePoolResponse return json.Unmarshal(b, (*alias)(r)) } type ListStoragePoolsMetricsParams struct { p map[string]interface{} } func (p *ListStoragePoolsMetricsParams) toURLValues() url.Values { u := url.Values{} if p.p == nil { return u } if v, found := p.p["clusterid"]; found { u.Set("clusterid", v.(string)) } if v, found := p.p["hostid"]; found { u.Set("hostid", v.(string)) } if v, found := p.p["id"]; found { u.Set("id", v.(string)) } if v, found := p.p["ipaddress"]; found { u.Set("ipaddress", v.(string)) } if v, found := p.p["keyword"]; found { u.Set("keyword", v.(string)) } if v, found := p.p["name"]; found { u.Set("name", v.(string)) } if v, found := p.p["page"]; found { vv := strconv.Itoa(v.(int)) u.Set("page", vv) } if v, found := p.p["pagesize"]; found { vv := strconv.Itoa(v.(int)) u.Set("pagesize", vv) } if v, found := p.p["path"]; found { u.Set("path", v.(string)) } if v, found := p.p["podid"]; found { u.Set("podid", v.(string)) } if v, found := p.p["scope"]; found { u.Set("scope", v.(string)) } if v, found := p.p["status"]; found { u.Set("status", v.(string)) } if v, found := p.p["storagecustomstats"]; found { vv := strconv.FormatBool(v.(bool)) u.Set("storagecustomstats", vv) } if v, found := p.p["zoneid"]; found { u.Set("zoneid", v.(string)) } return u } func (p *ListStoragePoolsMetricsParams) SetClusterid(v string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["clusterid"] = v } func (p *ListStoragePoolsMetricsParams) ResetClusterid() { if p.p != nil && p.p["clusterid"] != nil { delete(p.p, "clusterid") } } func (p *ListStoragePoolsMetricsParams) GetClusterid() (string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["clusterid"].(string) return value, ok } func (p *ListStoragePoolsMetricsParams) SetHostid(v string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["hostid"] = v } func (p *ListStoragePoolsMetricsParams) ResetHostid() { if p.p != nil && p.p["hostid"] != nil { delete(p.p, "hostid") } } func (p *ListStoragePoolsMetricsParams) GetHostid() (string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["hostid"].(string) return value, ok } func (p *ListStoragePoolsMetricsParams) SetId(v string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["id"] = v } func (p *ListStoragePoolsMetricsParams) ResetId() { if p.p != nil && p.p["id"] != nil { delete(p.p, "id") } } func (p *ListStoragePoolsMetricsParams) GetId() (string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["id"].(string) return value, ok } func (p *ListStoragePoolsMetricsParams) SetIpaddress(v string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["ipaddress"] = v } func (p *ListStoragePoolsMetricsParams) ResetIpaddress() { if p.p != nil && p.p["ipaddress"] != nil { delete(p.p, "ipaddress") } } func (p *ListStoragePoolsMetricsParams) GetIpaddress() (string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["ipaddress"].(string) return value, ok } func (p *ListStoragePoolsMetricsParams) SetKeyword(v string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["keyword"] = v } func (p *ListStoragePoolsMetricsParams) ResetKeyword() { if p.p != nil && p.p["keyword"] != nil { delete(p.p, "keyword") } } func (p *ListStoragePoolsMetricsParams) GetKeyword() (string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["keyword"].(string) return value, ok } func (p *ListStoragePoolsMetricsParams) SetName(v string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["name"] = v } func (p *ListStoragePoolsMetricsParams) ResetName() { if p.p != nil && p.p["name"] != nil { delete(p.p, "name") } } func (p *ListStoragePoolsMetricsParams) GetName() (string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["name"].(string) return value, ok } func (p *ListStoragePoolsMetricsParams) SetPage(v int) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["page"] = v } func (p *ListStoragePoolsMetricsParams) ResetPage() { if p.p != nil && p.p["page"] != nil { delete(p.p, "page") } } func (p *ListStoragePoolsMetricsParams) GetPage() (int, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["page"].(int) return value, ok } func (p *ListStoragePoolsMetricsParams) SetPagesize(v int) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["pagesize"] = v } func (p *ListStoragePoolsMetricsParams) ResetPagesize() { if p.p != nil && p.p["pagesize"] != nil { delete(p.p, "pagesize") } } func (p *ListStoragePoolsMetricsParams) GetPagesize() (int, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["pagesize"].(int) return value, ok } func (p *ListStoragePoolsMetricsParams) SetPath(v string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["path"] = v } func (p *ListStoragePoolsMetricsParams) ResetPath() { if p.p != nil && p.p["path"] != nil { delete(p.p, "path") } } func (p *ListStoragePoolsMetricsParams) GetPath() (string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["path"].(string) return value, ok } func (p *ListStoragePoolsMetricsParams) SetPodid(v string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["podid"] = v } func (p *ListStoragePoolsMetricsParams) ResetPodid() { if p.p != nil && p.p["podid"] != nil { delete(p.p, "podid") } } func (p *ListStoragePoolsMetricsParams) GetPodid() (string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["podid"].(string) return value, ok } func (p *ListStoragePoolsMetricsParams) SetScope(v string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["scope"] = v } func (p *ListStoragePoolsMetricsParams) ResetScope() { if p.p != nil && p.p["scope"] != nil { delete(p.p, "scope") } } func (p *ListStoragePoolsMetricsParams) GetScope() (string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["scope"].(string) return value, ok } func (p *ListStoragePoolsMetricsParams) SetStatus(v string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["status"] = v } func (p *ListStoragePoolsMetricsParams) ResetStatus() { if p.p != nil && p.p["status"] != nil { delete(p.p, "status") } } func (p *ListStoragePoolsMetricsParams) GetStatus() (string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["status"].(string) return value, ok } func (p *ListStoragePoolsMetricsParams) SetStoragecustomstats(v bool) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["storagecustomstats"] = v } func (p *ListStoragePoolsMetricsParams) ResetStoragecustomstats() { if p.p != nil && p.p["storagecustomstats"] != nil { delete(p.p, "storagecustomstats") } } func (p *ListStoragePoolsMetricsParams) GetStoragecustomstats() (bool, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["storagecustomstats"].(bool) return value, ok } func (p *ListStoragePoolsMetricsParams) SetZoneid(v string) { if p.p == nil { p.p = make(map[string]interface{}) } p.p["zoneid"] = v } func (p *ListStoragePoolsMetricsParams) ResetZoneid() { if p.p != nil && p.p["zoneid"] != nil { delete(p.p, "zoneid") } } func (p *ListStoragePoolsMetricsParams) GetZoneid() (string, bool) { if p.p == nil { p.p = make(map[string]interface{}) } value, ok := p.p["zoneid"].(string) return value, ok } // You should always use this function to get a new ListStoragePoolsMetricsParams instance, // as then you are sure you have configured all required params func (s *StoragePoolService) NewListStoragePoolsMetricsParams() *ListStoragePoolsMetricsParams { p := &ListStoragePoolsMetricsParams{} p.p = make(map[string]interface{}) return p } // This is a courtesy helper function, which in some cases may not work as expected! func (s *StoragePoolService) GetStoragePoolsMetricID(name string, opts ...OptionFunc) (string, int, error) { p := &ListStoragePoolsMetricsParams{} p.p = make(map[string]interface{}) p.p["name"] = name for _, fn := range append(s.cs.options, opts...) { if err := fn(s.cs, p); err != nil { return "", -1, err } } l, err := s.ListStoragePoolsMetrics(p) if err != nil { return "", -1, err } if l.Count == 0 { return "", l.Count, fmt.Errorf("No match found for %s: %+v", name, l) } if l.Count == 1 { return l.StoragePoolsMetrics[0].Id, l.Count, nil } if l.Count > 1 { for _, v := range l.StoragePoolsMetrics { if v.Name == name { return v.Id, l.Count, nil } } } return "", l.Count, fmt.Errorf("Could not find an exact match for %s: %+v", name, l) } // This is a courtesy helper function, which in some cases may not work as expected! func (s *StoragePoolService) GetStoragePoolsMetricByName(name string, opts ...OptionFunc) (*StoragePoolsMetric, int, error) { id, count, err := s.GetStoragePoolsMetricID(name, opts...) if err != nil { return nil, count, err } r, count, err := s.GetStoragePoolsMetricByID(id, opts...) if err != nil { return nil, count, err } return r, count, nil } // This is a courtesy helper function, which in some cases may not work as expected! func (s *StoragePoolService) GetStoragePoolsMetricByID(id string, opts ...OptionFunc) (*StoragePoolsMetric, int, error) { p := &ListStoragePoolsMetricsParams{} p.p = make(map[string]interface{}) p.p["id"] = id for _, fn := range append(s.cs.options, opts...) { if err := fn(s.cs, p); err != nil { return nil, -1, err } } l, err := s.ListStoragePoolsMetrics(p) if err != nil { if strings.Contains(err.Error(), fmt.Sprintf( "Invalid parameter id value=%s due to incorrect long value format, "+ "or entity does not exist", id)) { return nil, 0, fmt.Errorf("No match found for %s: %+v", id, l) } return nil, -1, err } if l.Count == 0 { return nil, l.Count, fmt.Errorf("No match found for %s: %+v", id, l) } if l.Count == 1 { return l.StoragePoolsMetrics[0], l.Count, nil } return nil, l.Count, fmt.Errorf("There is more then one result for StoragePoolsMetric UUID: %s!", id) } // Lists storage pool metrics func (s *StoragePoolService) ListStoragePoolsMetrics(p *ListStoragePoolsMetricsParams) (*ListStoragePoolsMetricsResponse, error) { resp, err := s.cs.newRequest("listStoragePoolsMetrics", p.toURLValues()) if err != nil { return nil, err } var r ListStoragePoolsMetricsResponse if err := json.Unmarshal(resp, &r); err != nil { return nil, err } return &r, nil } type ListStoragePoolsMetricsResponse struct { Count int `json:"count"` StoragePoolsMetrics []*StoragePoolsMetric `json:"storagepool"` } type StoragePoolsMetric struct { Allocatediops int64 `json:"allocatediops"` Capacityiops int64 `json:"capacityiops"` Clusterid string `json:"clusterid"` Clustername string `json:"clustername"` Created string `json:"created"` Disksizeallocated int64 `json:"disksizeallocated"` Disksizeallocatedgb string `json:"disksizeallocatedgb"` Disksizetotal int64 `json:"disksizetotal"` Disksizetotalgb string `json:"disksizetotalgb"` Disksizeunallocatedgb string `json:"disksizeunallocatedgb"` Disksizeused int64 `json:"disksizeused"` Disksizeusedgb string `json:"disksizeusedgb"` Hasannotations bool `json:"hasannotations"` Hypervisor string `json:"hypervisor"` Id string `json:"id"` Ipaddress string `json:"ipaddress"` Istagarule bool `json:"istagarule"` JobID string `json:"jobid"` Jobstatus int `json:"jobstatus"` Managed bool `json:"managed"` Name string `json:"name"` Nfsmountopts string `json:"nfsmountopts"` Overprovisionfactor string `json:"overprovisionfactor"` Path string `json:"path"` Podid string `json:"podid"` Podname string `json:"podname"` Provider string `json:"provider"` Scope string `json:"scope"` State string `json:"state"` Storageallocateddisablethreshold bool `json:"storageallocateddisablethreshold"` Storageallocatedthreshold bool `json:"storageallocatedthreshold"` Storagecapabilities map[string]string `json:"storagecapabilities"` Storagecustomstats map[string]string `json:"storagecustomstats"` Storageusagedisablethreshold bool `json:"storageusagedisablethreshold"` Storageusagethreshold bool `json:"storageusagethreshold"` Suitableformigration bool `json:"suitableformigration"` Tags string `json:"tags"` Type string `json:"type"` Zoneid string `json:"zoneid"` Zonename string `json:"zonename"` }