common

Documentation

Index

• Constants
• Variables
• func FindScaleIONodeByExecutorID(nodes []*types.ScaleIONode, executorID string) *types.ScaleIONode
• func FindScaleIONodeByHostname(nodes []*types.ScaleIONode, hostname string) *types.ScaleIONode
• func GetGatewayAddress(state *types.ScaleIOFramework) (string, error)
• func GetPrimaryMdmNode(state *types.ScaleIOFramework) (*types.ScaleIONode, error)
• func PersonaIDToString(persona int) string
• func PersonaStringToID(persona string) int
• func SyncRunState(state *types.ScaleIOFramework, runState int, allNodes bool) bool
• type RetrieveState

Constants

const (
	//PollStatusInSeconds the amount of time to wait before updating state
	PollStatusInSeconds = 60

	//WaitForVolumeState the amount of time to wait for volume state changes
	WaitForVolumeState = 1
)

Variables

var (
	//ErrNodeNotFound The node was not found
	ErrNodeNotFound = errors.New("The node was not found")

	//ErrAttributeNotFound The attribute was not found
	ErrAttributeNotFound = errors.New("The attribute was not found")
)

Functions

func FindScaleIONodeByExecutorID

func FindScaleIONodeByExecutorID(nodes []*types.ScaleIONode, executorID string) *types.ScaleIONode

FindScaleIONodeByExecutorID Get ScaleIO node by ExecutorID

func FindScaleIONodeByHostname

func FindScaleIONodeByHostname(nodes []*types.ScaleIONode, hostname string) *types.ScaleIONode

FindScaleIONodeByHostname Find ScaleIO node by Hostname

func GetGatewayAddress

func GetGatewayAddress(state *types.ScaleIOFramework) (string, error)

GetGatewayAddress returns the ScaleIO gateway address

func GetPrimaryMdmNode

func GetPrimaryMdmNode(state *types.ScaleIOFramework) (*types.ScaleIONode, error)

GetPrimaryMdmNode gets the Primary node

func PersonaIDToString

func PersonaIDToString(persona int) string

PersonaIDToString PersonaID -> String

func PersonaStringToID

func PersonaStringToID(persona string) int

PersonaStringToID String -> PersonaID

func SyncRunState

func SyncRunState(state *types.ScaleIOFramework, runState int, allNodes bool) bool

SyncRunState a function to waiting on a specific state

Types

type RetrieveState

type RetrieveState func() (*types.ScaleIOFramework, error)

RetrieveState is a call back to retrieve an update of the state