datacenter_list_clusters.go

package ovirtclient

import (
	"fmt"
)

func (o *oVirtClient) ListDatacenterClusters(id DatacenterID, retries ...RetryStrategy) (result []Cluster, err error) {
	retries = defaultRetries(retries, defaultReadTimeouts(o))
	result = []Cluster{}
	err = retry(
		fmt.Sprintf("listing datacenters %s clusters", id),
		o.logger,
		retries,
		func() error {
			response, e := o.conn.
				SystemService().
				DataCentersService().
				DataCenterService(string(id)).
				ClustersService().
				List().
				Send()
			if e != nil {
				return e
			}
			sdkObjects, ok := response.Clusters()
			if !ok {
				return nil
			}
			result = make([]Cluster, len(sdkObjects.Slice()))
			for i, sdkObject := range sdkObjects.Slice() {
				result[i], e = convertSDKCluster(sdkObject, o)
				if e != nil {
					return wrap(e, EBug, "failed to convert cluster during listing item #%d", i)
				}
			}
			return nil
		})
	return result, err
}

func (m *mockClient) ListDatacenterClusters(id DatacenterID, _ ...RetryStrategy) ([]Cluster, error) {
	m.lock.Lock()
	defer m.lock.Unlock()

	dc, ok := m.dataCenters[id]
	if !ok {
		return nil, newError(ENotFound, "datacenter with ID %s not found", id)
	}
	clusters := make([]Cluster, len(dc.clusters))
	for i, clusterID := range dc.clusters {
		clusters[i] = m.clusters[clusterID]
	}

	return clusters, nil
}