gaussdb-opengauss.go 1.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354
  1. // Copyright 2019 Yunion
  2. //
  3. // Licensed under the Apache License, Version 2.0 (the "License");
  4. // you may not use this file except in compliance with the License.
  5. // You may obtain a copy of the License at
  6. //
  7. // http://www.apache.org/licenses/LICENSE-2.0
  8. //
  9. // Unless required by applicable law or agreed to in writing, software
  10. // distributed under the License is distributed on an "AS IS" BASIS,
  11. // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  12. // See the License for the specific language governing permissions and
  13. // limitations under the License.
  14. package huawei
  15. import (
  16. "fmt"
  17. "net/url"
  18. )
  19. type SGaussDB struct {
  20. Id string
  21. Name string
  22. Nodes []struct {
  23. Id string
  24. }
  25. }
  26. func (self *SRegion) GetGaussDBs() ([]SGaussDB, error) {
  27. query := url.Values{}
  28. ret := []SGaussDB{}
  29. for {
  30. resp, err := self.list(SERVICE_GAUSSDB_OPENGAUSS, "instances", query)
  31. if err != nil {
  32. return nil, err
  33. }
  34. part := struct {
  35. Instances []SGaussDB
  36. TotalCount int
  37. }{}
  38. err = resp.Unmarshal(&part)
  39. if err != nil {
  40. return nil, err
  41. }
  42. ret = append(ret, part.Instances...)
  43. if len(ret) >= part.TotalCount || len(part.Instances) == 0 {
  44. break
  45. }
  46. query.Set("offset", fmt.Sprintf("%d", len(ret)))
  47. }
  48. return ret, nil
  49. }