Initial commit

iscsi/iscsi.go

@@ -0,0 +1,170 @@
+package iscsi
+
+import (
+	"fmt"
+	"strings"
+
+	// Vendors
+	"util"
+	"github.com/Sirupsen/logrus"
+)
+
+type iscsiLUNInfo struct {
+	host string
+	fqdn string
+}
+
+type ISCSIPlugin struct {
+	lunInfo []iscsiLUNInfo
+}
+
+func NewISCSIPlugin() ISCSIPlugin {
+	var lun []iscsiLUNInfo
+	iscsiPlugin := ISCSIPlugin{lun}
+	return iscsiPlugin
+}
+
+func (plugin *ISCSIPlugin) CheckIscsiSupport() bool {
+	//Check if "iscsiadm" is installed
+	_, err := util.ExecuteCommand("iscsiadm")
+	if strings.Contains(err, util.CmdNotFound) {
+		return false
+	}
+	return true
+}
+
+// iscsiadm -m discovery -t sendtargets -p <IP | Target>
+func (plugin *ISCSIPlugin) DiscoverLUNs(host string) error {
+
+	if len(host) == 0 {
+		err := fmt.Errorf("IP or Hostname is expected")
+		return err
+	}
+	out, errMsg := util.ExecuteCommand("iscsiadm",
+		"-m",
+		"discovery",
+		"-t",
+		"sendtargets",
+		"-p",
+		host)
+
+	if len(out) > 0 {
+		lineArray := strings.Split(out, "\n")
+		for _, line := range lineArray {
+			if len(line) == 0 {
+				break
+			}
+			token := strings.Split(line, ",")
+			var lun iscsiLUNInfo
+			lun.host = strings.TrimSpace(token[0])
+			// Split again to get only fqdn name.
+			fqdn := strings.Split(token[1], " ")
+			lun.fqdn = strings.TrimSpace(fqdn[1])
+			logrus.Infof("%s: %s", lun.host, lun.fqdn)
+			plugin.lunInfo = append(plugin.lunInfo, lun)
+		}
+	}
+	if len(errMsg) > 0 {
+		err := fmt.Errorf("Unable to Discover: %s", errMsg)
+		return err
+	}
+
+	return nil
+}
+
+// iscsiadm -m node -o show  (Shows discovered list)
+func (plugin *ISCSIPlugin) ListVolumes() error {
+
+	out, errMsg := util.ExecuteCommand("iscsiadm",
+		"-m",
+		"node",
+		"-o",
+		"show")
+
+	logrus.Info(out)
+	if len(errMsg) > 0 {
+		err := fmt.Errorf("Unable to fetch List: %s", errMsg)
+		return err
+	}
+
+	return nil
+}
+
+func (plugin *ISCSIPlugin) ListSessions() error {
+
+	out, errMsg := util.ExecuteCommand("iscsiadm",
+		"-m",
+		"session")
+
+	logrus.Info(out)
+	if len(errMsg) > 0 {
+		err := fmt.Errorf("Unable to fetch List: %s", errMsg)
+		return err
+	}
+
+	return nil
+}
+
+// Login: iscsiadm -m node --login (login on all discovered nodes.)
+// iscsiadm -m node -T <Complete Target Name> -l -p <Group IP>:3260
+func (plugin *ISCSIPlugin) LoginTarget(target string, group string) error {
+	var out, errMsg string
+	if len(target) == 0 {
+		out, errMsg = util.ExecuteCommand("iscsiadm",
+			"-m",
+			"node",
+			"-l")
+	} else {
+		if len(group) == 0 {
+			err := fmt.Errorf("group IP for target is missing!!")
+			return err
+		}
+		out, errMsg = util.ExecuteCommand("iscsiadm",
+			"-m",
+			"node",
+			"-T",
+			target,
+			"-l",
+			"-p",
+			group)
+
+	}
+
+	logrus.Info(out)
+	if len(errMsg) > 0 {
+		err := fmt.Errorf("Unable to Login: %s", errMsg)
+		return err
+	}
+
+	return nil
+}
+
+// iscsiadm -m node -u
+// iscsiadm -m node -u -T <Complete Target Name>-p <Group IP address>:3260
+func (plugin *ISCSIPlugin) LogoutTarget(target string, group string) error {
+	var out, errMsg string
+	if len(target) == 0 {
+		out, errMsg = util.ExecuteCommand("iscsiadm",
+			"-m",
+			"node",
+			"-u")
+	} else {
+		out, errMsg = util.ExecuteCommand("iscsiadm",
+			"-m",
+			"node",
+			"-u",
+			"-T",
+			target,
+			"-p",
+			group)
+	}
+
+	logrus.Info(out)
+	if len(errMsg) > 0 {
+		err := fmt.Errorf("Unable to Logout: %s", errMsg)
+		return err
+	}
+
+	return nil
+}
+