mirrors/ceph-csi
1
0
Fork 0
mirror of https://github.com/ceph/ceph-csi.git synced 2024-11-22 14:20:19 +00:00
Code Issues Packages Projects Releases Wiki Activity

util: implement GetPoolName() with go-ceph

Browse Source 
Remove an other call to the "rados" executable and re-use the existing
connection to the Ceph cluster.

Signed-off-by: Niels de Vos <ndevos@redhat.com>
This commit is contained in:
Niels de Vos 2020-03-13 10:24:01 +01:00 committed by mergify[bot]
parent be8c3c4b72
commit ec61f0746b
1 changed files with 8 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
internal/util/cephcmds.go
View File

@ -106,22 +106,21 @@ func GetPoolID(monitors string, cr *Credentials, poolName string) (int64, error)
return id, nil return id, nil
} }
// GetPoolName lists all pools in a ceph cluster, and matches the pool whose pool ID is equal to // GetPoolName fetches the pool whose pool ID is equal to the requested poolID
// the requested poolID parameter // parameter
func GetPoolName(ctx context.Context, monitors string, cr *Credentials, poolID int64) (string, error) { func GetPoolName(ctx context.Context, monitors string, cr *Credentials, poolID int64) (string, error) {
pools, err := getPools(ctx, monitors, cr) conn, err := connPool.Get(monitors, cr.ID, cr.KeyFile)
if err != nil { if err != nil {
return "", err return "", err
} }
defer connPool.Put(conn)
for _, p := range pools { name, err := conn.GetPoolByID(poolID)
if poolID == p.Number { if err != nil {
return p.Name, nil
}
}
return "", ErrPoolNotFound{string(poolID), fmt.Errorf("pool ID (%d) not found in Ceph cluster", poolID)} return "", ErrPoolNotFound{string(poolID), fmt.Errorf("pool ID (%d) not found in Ceph cluster", poolID)}
} }
return name, nil
}
// GetPoolIDs searches a list of pools in a cluster and returns the IDs of the pools that matches // GetPoolIDs searches a list of pools in a cluster and returns the IDs of the pools that matches
// the passed in pools // the passed in pools