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

util: add method to get rados connection

Browse Source 
New go-ceph admin package api's expects to
pass the rados connection as argument.
added new method called GetRBDAdmin
to get admin connection to administrate
rbd volumes.

Signed-off-by: Madhu Rajanna <madhupr007@gmail.com>
This commit is contained in:
Madhu Rajanna 2021-06-28 12:16:25 +05:30 committed by mergify[bot]
parent 8732bec369
commit b1710f4c53
1 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
internal/util/connection.go
View File

@ -23,6 +23,7 @@ import (
ca "github.com/ceph/go-ceph/cephfs/admin" ca "github.com/ceph/go-ceph/cephfs/admin"
"github.com/ceph/go-ceph/rados" "github.com/ceph/go-ceph/rados"
ra "github.com/ceph/go-ceph/rbd/admin"
) )
type ClusterConnection struct { type ClusterConnection struct {
@ -111,6 +112,15 @@ func (cc *ClusterConnection) GetFSAdmin() (*ca.FSAdmin, error) {
return ca.NewFromConn(cc.conn), nil return ca.NewFromConn(cc.conn), nil
} }
// GetRBDAdmin get RBDAdmin to administrate rbd volumes.
func (cc *ClusterConnection) GetRBDAdmin() (*ra.RBDAdmin, error) {
if cc.conn == nil {
return nil, errors.New("cluster is not connected yet")
}
return ra.NewFromConn(cc.conn), nil
}
// DisableDiscardOnZeroedWriteSame enables the // DisableDiscardOnZeroedWriteSame enables the
// `rbd_discard_on_zeroed_write_same` option in the cluster connection, so that // `rbd_discard_on_zeroed_write_same` option in the cluster connection, so that
// writing zero blocks of data are actual writes on the OSDs (doing // writing zero blocks of data are actual writes on the OSDs (doing