From 36a36bfea56aed15ab1d1b76a67591200ce2c464 Mon Sep 17 00:00:00 2001 From: Muthukumar Date: Sun, 14 Oct 2018 11:12:41 +0530 Subject: [PATCH] diskstorage comments added Signed-off-by: Muthukumar --- utils/k8s/openebscrd.go | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) diff --git a/utils/k8s/openebscrd.go b/utils/k8s/openebscrd.go index 6582b59..bdae6ba 100644 --- a/utils/k8s/openebscrd.go +++ b/utils/k8s/openebscrd.go @@ -77,3 +77,21 @@ func (k8s K8S) DeleteStoragePool(storagePoolName string, opts *meta_v1.DeleteOpt storagePoolClient := k8s.OpenebsClientSet.OpenebsV1alpha1().StoragePools() return storagePoolClient.Delete(storagePoolName, opts) } + +// ListDisks list All disks +func (k8s K8S) ListDisks() (*openebs_v1.DiskList, error) { + diskClient := k8s.OpenebsClientSet.OpenebsV1alpha1() + return diskClient.Disks().List(meta_v1.ListOptions{}) +} + +// GetDisk Gets disk with diskname +func (k8s K8S) GetDisk(diskName string) (*openebs_v1.Disk, error) { + diskClient := k8s.OpenebsClientSet.OpenebsV1alpha1() + return diskClient.Disks().Get(diskName, meta_v1.GetOptions{}) +} + +// DeleteDisk deletes disk with diskname +func (k8s K8S) DeleteDisk(diskName string) error { + diskClient := k8s.OpenebsClientSet.OpenebsV1alpha1() + return diskClient.Disks().Delete(diskName, &meta_v1.DeleteOptions{}) +}