Starting off the certmaster tree with most of the func code, shortly non-certmaster...

[certmaster.git] / func / overlord / modules / netapp.py

diff --git a/func/overlord/modules/netapp.py b/func/overlord/modules/netapp.py
new file mode 100644 (file)
index 0000000..987901e
--- /dev/null
+++ b/func/overlord/modules/netapp.py
@@ -0,0 +1,82 @@
+##
+## Overlord library to interface with minion-side netapp operations
+##
+## Most of this is just wrappers to create some cleaner, earier to use
+## interfaces.  Also allows users to get function signatures and use
+## nice things like kwargs client side, for those of us who can't live
+## without ipython introspection.
+##
+## Copyright 2008, Red Hat, Inc
+## John Eckersberg <jeckersb@redhat.com>
+##
+## This software may be freely redistributed under the terms of the GNU
+## general public license.
+##
+## You should have received a copy of the GNU General Public License
+## along with this program; if not, write to the Free Software
+## Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
+##
+
+from func.overlord.client import Client
+
+class RemoteError(Exception): pass
+
+def _(res):
+    if type(res) == type([]) and res[0] == 'REMOTE_ERROR':
+        raise RemoteError, res[2]
+    else:
+        return res
+
+class Filer(Client):
+    def __init__(self, filer, admin_host):
+        Client.__init__(self, admin_host)
+        self.filer = filer
+        self.admin_host = admin_host
+
+    def create_volume(self, vol, aggr, size):
+        return _(self.netapp.vol.create(self.filer, vol, aggr, size)[self.admin_host])
+
+    def destroy_volume(self, vol):
+        # offline it first
+        try:
+            self.netapp.vol.offline(self.filer, vol)
+        except:
+            pass
+        return _(self.netapp.vol.destroy(self.filer, vol)[self.admin_host])
+
+    def offline_volume(self, vol):
+        return _(self.netapp.vol.offline(self.filer, vol)[self.admin_host])                 
+
+    def online_volume(self, vol):
+        return _(self.netapp.vol.online(self.filer, vol)[self.admin_host])                 
+
+    def get_volume_size(self, vol):
+        return _(self.netapp.vol.size(self.filer, vol)[self.admin_host])
+
+    def resize_volume(self, vol, delta):
+        return _(self.netapp.vol.size(self.filer, vol, delta)[self.admin_host])
+
+    def create_snapshot(self, vol, snap):
+        return _(self.netapp.snap.create(self.filer, vol, snap)[self.admin_host])
+
+    def delete_snapshot(self, vol, snap):
+        return _(self.netapp.snap.delete(self.filer, vol, snap)[self.admin_host])
+
+    def create_clone_volume(self, vol, parent, snap):
+        return _(self.netapp.vol.clone.create(self.filer, vol, parent, snap)[self.admin_host])
+
+    def split_clone_volume(self, vol):
+        return _(self.netapp.vol.clone.split(self.filer, vol)[self.admin_host])
+
+    def list_volumes(self):
+        vols = _(self.netapp.vol.status(self.filer))
+        return_list = []
+        for vol in vols:
+            return_list.append(vol['name'])
+        return return_list
+
+    def volume_details(self, vol=None):
+        if vol:
+            return _(self.netapp.vol.status(self.filer, vol)[self.admin_host])
+        else:
+            return _(self.netapp.vol.status(self.filer)[self.admin_host])