volume.go

// Copyright 2020 Hewlett Packard Enterprise Development LP
package main

import (
	"fmt"
	"github.com/hpe-storage/nimble-golang-sdk/pkg/client/v1/nimbleos"
	"github.com/hpe-storage/nimble-golang-sdk/pkg/param"
	"github.com/hpe-storage/nimble-golang-sdk/pkg/service"
	"os"
)
func main() {
	host := os.Getenv("SDK_TARGET_HOST")
	user := os.Getenv("SDK_TARGET_USER")
	password := os.Getenv("SDK_TARGET_PASSWORD")

	if host == "" || user == "" || password == "" {
		fmt.Println("ERROR: Missing one of these environment variables: SDK_TARGET_HOST, SDK_TARGET_USER, SDK_TARGET_PASSWORD")
		fmt.Println("Usage:")
		fmt.Println("SDK_TARGET_HOST - Management hostname or IP of array")
		fmt.Println("SDK_TARGET_USER - User (non-tenant) username")
		fmt.Println("SDK_TARGET_PASSWORD - User (non-tenant) password")
		os.Exit(1)
	}

	groupService, err := service.NewNimbleGroupService(
		service.WithHost(host),
		service.WithUser(user),
		service.WithPassword(password))
	if err != nil {
		fmt.Printf("NewGroupService(): Unable to connect to group, err: %v\n", err.Error())
		os.Exit(1)
	}
	defer groupService.LogoutService()
	// get  volume service instance
	volSvc := groupService.GetVolumeService()
	// Initialize volume attributes
	var sizeField int64 = 5120
	descriptionField := "This volume was created as part of a unit test"
	var limitIopsField int64 = 256
	var limitMbpsField int64 = 1

	// set volume attributes
	newVolume := &nimbleos.Volume{
		Name:              param.NewString("TestDemo1"),
		Size:              &sizeField,
		Description:       &descriptionField,
		ThinlyProvisioned: param.NewBool(true),
		Online:            param.NewBool(true),
		LimitIops:         &limitIopsField,
		LimitMbps:         &limitMbpsField,
		MultiInitiator:    param.NewBool(true),
		AgentType:         nimbleos.NsAgentTypeNone,
	}

	// create volume
	volume, err := volSvc.CreateVolume(newVolume)

	if err != nil {
		fmt.Printf("Failed to create volume, err: %v,\n", err)
		return
	}
	fmt.Println(volume)

	// get volume by name
	volume, err = volSvc.GetVolumeByName("TestDemo1")
	if err != nil {
		fmt.Printf("Failed to get volume by name, err: %v,\n", err)
		return
	}
	fmt.Println(volume)

	// get volume with params
	requestParams := new(param.GetParams)
	fieldList := []string{
		nimbleos.VolumeFields.ID,
		nimbleos.VolumeFields.Name,
		nimbleos.VolumeFields.Size,
		nimbleos.VolumeFields.LimitMbps,
	}
	requestParams.WithFields(fieldList)
	volumeList, err := volSvc.GetVolumes(requestParams)

	if err != nil {
		fmt.Printf("Error: get volume with params. Message: %v\n", err)
	}
	fmt.Println(volumeList)

	// delete volume, cleanup
	volSvc.DeleteVolume(*volume.ID)
}