Synnefo » snf-ganeti

  , idx         :: T.Gdx         -- ^ Internal index for book-keeping

  , allocPolicy :: T.AllocPolicy -- ^ The allocation policy for this group

  , iPolicy     :: T.IPolicy     -- ^ The instance policy for this group

  } deriving (Show, Read, Eq)

-- Note: we use the name as the alias, and the UUID as the official

-- * Initialization functions

-- | Create a new group.

  Group { name        = name_init

        , uuid        = id_init

        , allocPolicy = apol_init

        , iPolicy     = ipol_init

        , idx         = -1

        }

  name <- extract "name"

  apol <- extract "alloc_policy"

  ipol <- extract "ipolicy"

-- | Top-level parser.

--

-- | The input data for node group query.

queryGroupsMsg :: L.LuxiOp

queryGroupsMsg =

-- | Wraper over 'callMethod' doing node query.

queryNodes :: L.Client -> IO (Result JSValue)

-- | Parses a given group information.

parseGroup :: [(JSValue, JSValue)] -> Result (String, Group.Group)

  xname <- annotateResult "Parsing new group" (fromJValWithStatus name)

  let convert a = genericConvert "Group" xname a

  xuuid <- convert "uuid" uuid

  xapol <- convert "alloc_policy" apol

  xipol <- convert "ipolicy" ipol

parseGroup v = fail ("Invalid group query result: " ++ show v)

defGroup :: Group.Group

defGroup = flip Group.setIdx 0 $

             Group.create "default" Types.defaultGroupID Types.AllocPreferred

defGroupList :: Group.List

defGroupList = Container.fromList [(Group.idx defGroup, defGroup)]

  uuid <- extract "uuid"

  apol <- extract "alloc_policy"

  ipol <- extract "ipolicy"

-- | Parse cluster data from the info resource.

parseCluster :: JSObject JSValue -> Result ([String], IPolicy)

                           (fromIntegral cpu) False spindles grpIndex

                  ) [1..ncount]

      grp = Group.create (printf "group-%02d" grpIndex)

  return (Group.setIdx grp grpIndex, nodes)

-- | Builds the cluster data from node\/instance files.

-- | Serialize a single group.

serializeGroup :: Group.Group -> String

serializeGroup grp =

           (allocPolicyToRaw (Group.allocPolicy grp))

-- | Generate group file data from a group list.

serializeGroups :: Group.List -> String

loadGroup :: (Monad m) => [String]

          -> m (String, Group.Group) -- ^ The result, a tuple of group

                                     -- UUID and group object

  xapol <- allocPolicyFromRaw apol

loadGroup s = fail $ "Invalid/incomplete group data: '" ++ show s ++ "'"

      "name": gdata.name,

      "alloc_policy": gdata.alloc_policy,

      "ipolicy": _CalculateGroupIPolicy(cluster, gdata),

      })

      for guuid, gdata in cfg.GetAllNodeGroupsInfo().items())

node1.example.com|1024|0|1024|95367|95367|4|N|fake-uuid-01|1

node2.example.com|1024|0|896|95367|94343|4|N|fake-uuid-01|1

        "spindle-ratio": 32.0

      },

      "alloc_policy": "preferred",

      "name": "default"

    }

  },

        "spindle-ratio": 32.0

      },

      "alloc_policy": "preferred",

      "name": "default"

    },

    "uuid-group-2": {

        "spindle-ratio": 32.0

      },

      "alloc_policy": "preferred",

      "name": "empty"

    }

  },

        "spindle-ratio": 32.0

      },

      "alloc_policy": "preferred",

      "name": "default"

    }

  },

        "spindle-ratio": 32.0

      },

      "alloc_policy": "preferred",

      "name": "default"

    }

  },

node-01|16384|0|14336|409600|153600|16|N|fake-uuid-01|1

node-02|16384|0|13312|409600|153600|16|N|fake-uuid-01|1

node-01-001|98304|0|96256|8388608|8355840|16|N|fake-uuid-01|1

node-01-002|98304|0|96256|8388608|8355840|16|N|fake-uuid-01|1

node-01-001|1024|0|1024|95367|95367|4|N|fake-uuid-01|1

node-01-002|1024|0|896|95367|94343|4|N|fake-uuid-01|1

node1|1024|0|1024|95367|95367|4|N|fake-uuid-01|1

node2|1024|0|0|95367|0|4|N|fake-uuid-01|1