Synnefo » snf-ganeti

{-# LANGUAGE TemplateHaskell #-}

{-| Implementation of the Ganeti config objects.

Some object fields are not implemented yet, and as such they are

commented out below.

-}

{-

Copyright (C) 2011, 2012, 2013 Google Inc.

This program is free software; you can redistribute it and/or modify

it under the terms of the GNU General Public License as published by

the Free Software Foundation; either version 2 of the License, or

(at your option) any later version.

This program is distributed in the hope that it will be useful, but

WITHOUT ANY WARRANTY; without even the implied warranty of

MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU

General Public License for more details.

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., 51 Franklin Street, Fifth Floor, Boston, MA

02110-1301, USA.

-}

module Ganeti.Objects

  ( HvParams

  , OsParams

  , PartialNicParams(..)

  , FilledNicParams(..)

  , fillNicParams

  , allNicParamFields

  , PartialNic(..)

  , FileDriver(..)

  , DiskLogicalId(..)

  , Disk(..)

  , includesLogicalId

  , DiskTemplate(..)

  , PartialBeParams(..)

  , FilledBeParams(..)

  , fillBeParams

  , allBeParamFields

  , Instance(..)

  , toDictInstance

  , getDiskSizeRequirements

  , PartialNDParams(..)

  , FilledNDParams(..)

  , fillNDParams

  , allNDParamFields

  , Node(..)

  , AllocPolicy(..)

  , FilledISpecParams(..)

  , PartialISpecParams(..)

  , fillISpecParams

  , allISpecParamFields

  , MinMaxISpecs(..)

  , FilledIPolicy(..)

  , PartialIPolicy(..)

  , fillIPolicy

  , DiskParams

  , NodeGroup(..)

  , IpFamily(..)

  , ipFamilyToVersion

  , fillDict

  , ClusterHvParams

  , OsHvParams

  , ClusterBeParams

  , ClusterOsParams

  , ClusterNicParams

  , Cluster(..)

  , ConfigData(..)

  , TimeStampObject(..)

  , UuidObject(..)

  , SerialNoObject(..)

  , TagsObject(..)

  , DictObject(..) -- re-exported from THH

  , TagSet -- re-exported from THH

  , Network(..)

  , Ip4Address(..)

  , Ip4Network(..)

  , readIp4Address

  , nextIp4Address

  , IAllocatorParams

  ) where

import Control.Applicative

import Data.List (foldl')

import Data.Maybe

import qualified Data.Map as Map

import qualified Data.Set as Set

import Data.Word

import System.Time (ClockTime(..))

import Text.JSON (showJSON, readJSON, JSON, JSValue(..), fromJSString)

import qualified Text.JSON as J

import qualified AutoConf

import qualified Ganeti.Constants as C

import qualified Ganeti.ConstantUtils as ConstantUtils

import Ganeti.JSON

import Ganeti.Types

import Ganeti.THH

import Ganeti.Utils (sepSplit, tryRead, parseUnitAssumeBinary)

-- * Generic definitions

-- | Fills one map with keys from the other map, if not already

-- existing. Mirrors objects.py:FillDict.

fillDict :: (Ord k) => Map.Map k v -> Map.Map k v -> [k] -> Map.Map k v

fillDict defaults custom skip_keys =

  let updated = Map.union custom defaults

  in foldl' (flip Map.delete) updated skip_keys

-- | The hypervisor parameter type. This is currently a simple map,

-- without type checking on key/value pairs.

type HvParams = Container JSValue

-- | The OS parameters type. This is, and will remain, a string

-- container, since the keys are dynamically declared by the OSes, and

-- the values are always strings.

type OsParams = Container String

-- | Class of objects that have timestamps.

class TimeStampObject a where

  cTimeOf :: a -> ClockTime

  mTimeOf :: a -> ClockTime

-- | Class of objects that have an UUID.

class UuidObject a where

  uuidOf :: a -> String

-- | Class of object that have a serial number.

class SerialNoObject a where

  serialOf :: a -> Int

-- | Class of objects that have tags.

class TagsObject a where

  tagsOf :: a -> Set.Set String

-- * Network definitions

-- ** Ipv4 types

-- | Custom type for a simple IPv4 address.

data Ip4Address = Ip4Address Word8 Word8 Word8 Word8

                  deriving Eq

instance Show Ip4Address where

  show (Ip4Address a b c d) = show a ++ "." ++ show b ++ "." ++

                              show c ++ "." ++ show d

-- | Parses an IPv4 address from a string.

readIp4Address :: (Applicative m, Monad m) => String -> m Ip4Address

readIp4Address s =

  case sepSplit '.' s of

    [a, b, c, d] -> Ip4Address <$>

                      tryRead "first octect" a <*>

                      tryRead "second octet" b <*>

                      tryRead "third octet"  c <*>

                      tryRead "fourth octet" d

    _ -> fail $ "Can't parse IPv4 address from string " ++ s

-- | JSON instance for 'Ip4Address'.

instance JSON Ip4Address where

  showJSON = showJSON . show

  readJSON (JSString s) = readIp4Address (fromJSString s)

  readJSON v = fail $ "Invalid JSON value " ++ show v ++ " for an IPv4 address"

-- | \"Next\" address implementation for IPv4 addresses.

--

-- Note that this loops! Note also that this is a very dumb

-- implementation.

nextIp4Address :: Ip4Address -> Ip4Address

nextIp4Address (Ip4Address a b c d) =

  let inc xs y = if all (==0) xs then y + 1 else y

      d' = d + 1

      c' = inc [d'] c

      b' = inc [c', d'] b

      a' = inc [b', c', d'] a

  in Ip4Address a' b' c' d'

-- | Custom type for an IPv4 network.

data Ip4Network = Ip4Network Ip4Address Word8

                  deriving Eq

instance Show Ip4Network where

  show (Ip4Network ip netmask) = show ip ++ "/" ++ show netmask

-- | JSON instance for 'Ip4Network'.

instance JSON Ip4Network where

  showJSON = showJSON . show

  readJSON (JSString s) =

    case sepSplit '/' (fromJSString s) of

      [ip, nm] -> do

        ip' <- readIp4Address ip

        nm' <- tryRead "parsing netmask" nm

        if nm' >= 0 && nm' <= 32

          then return $ Ip4Network ip' nm'

          else fail $ "Invalid netmask " ++ show nm' ++ " from string " ++

                      fromJSString s

      _ -> fail $ "Can't parse IPv4 network from string " ++ fromJSString s

  readJSON v = fail $ "Invalid JSON value " ++ show v ++ " for an IPv4 network"

-- ** Ganeti \"network\" config object.

-- FIXME: Not all types might be correct here, since they

-- haven't been exhaustively deduced from the python code yet.

$(buildObject "Network" "network" $

  [ simpleField "name"             [t| NonEmptyString |]

  , optionalField $

    simpleField "mac_prefix"       [t| String |]

  , simpleField "network"          [t| Ip4Network |]

  , optionalField $

    simpleField "network6"         [t| String |]

  , optionalField $

    simpleField "gateway"          [t| Ip4Address |]

  , optionalField $

    simpleField "gateway6"         [t| String |]

  , optionalField $

    simpleField "reservations"     [t| String |]

  , optionalField $

    simpleField "ext_reservations" [t| String |]

  ]

  ++ uuidFields

  ++ timeStampFields

  ++ serialFields

  ++ tagsFields)

instance SerialNoObject Network where

  serialOf = networkSerial

instance TagsObject Network where

  tagsOf = networkTags

instance UuidObject Network where

  uuidOf = networkUuid

instance TimeStampObject Network where

  cTimeOf = networkCtime

  mTimeOf = networkMtime

-- * NIC definitions

$(buildParam "Nic" "nicp"

  [ simpleField "mode" [t| NICMode |]

  , simpleField "link" [t| String  |]

  , simpleField "vlan" [t| String |]

  ])

$(buildObject "PartialNic" "nic" $

  [ simpleField "mac" [t| String |]

  , optionalField $ simpleField "ip" [t| String |]

  , simpleField "nicparams" [t| PartialNicParams |]

  , optionalField $ simpleField "network" [t| String |]

  , optionalField $ simpleField "name" [t| String |]

  ] ++ uuidFields)

instance UuidObject PartialNic where

  uuidOf = nicUuid

-- * Disk definitions

-- | Constant for the dev_type key entry in the disk config.

devType :: String

devType = "dev_type"

-- | The disk configuration type. This includes the disk type itself,

-- for a more complete consistency. Note that since in the Python

-- code-base there's no authoritative place where we document the

-- logical id, this is probably a good reference point.

data DiskLogicalId

  = LIDPlain String String  -- ^ Volume group, logical volume

  | LIDDrbd8 String String Int Int Int String

  -- ^ NodeA, NodeB, Port, MinorA, MinorB, Secret

  | LIDFile FileDriver String -- ^ Driver, path

  | LIDSharedFile FileDriver String -- ^ Driver, path

  | LIDBlockDev BlockDriver String -- ^ Driver, path (must be under /dev)

  | LIDRados String String -- ^ Unused, path

  | LIDExt String String -- ^ ExtProvider, unique name

    deriving (Show, Eq)

-- | Mapping from a logical id to a disk type.

lidDiskType :: DiskLogicalId -> DiskTemplate

lidDiskType (LIDPlain {}) = DTPlain

lidDiskType (LIDDrbd8 {}) = DTDrbd8

lidDiskType (LIDFile  {}) = DTFile

lidDiskType (LIDSharedFile  {}) = DTSharedFile

lidDiskType (LIDBlockDev {}) = DTBlock

lidDiskType (LIDRados {}) = DTRbd

lidDiskType (LIDExt {}) = DTExt

-- | Builds the extra disk_type field for a given logical id.

lidEncodeType :: DiskLogicalId -> [(String, JSValue)]

lidEncodeType v = [(devType, showJSON . lidDiskType $ v)]

-- | Custom encoder for DiskLogicalId (logical id only).

encodeDLId :: DiskLogicalId -> JSValue

encodeDLId (LIDPlain vg lv) = JSArray [showJSON vg, showJSON lv]

encodeDLId (LIDDrbd8 nodeA nodeB port minorA minorB key) =

  JSArray [ showJSON nodeA, showJSON nodeB, showJSON port

          , showJSON minorA, showJSON minorB, showJSON key ]

encodeDLId (LIDRados pool name) = JSArray [showJSON pool, showJSON name]

encodeDLId (LIDFile driver name) = JSArray [showJSON driver, showJSON name]

encodeDLId (LIDSharedFile driver name) =

  JSArray [showJSON driver, showJSON name]

encodeDLId (LIDBlockDev driver name) = JSArray [showJSON driver, showJSON name]

encodeDLId (LIDExt extprovider name) =

  JSArray [showJSON extprovider, showJSON name]

-- | Custom encoder for DiskLogicalId, composing both the logical id

-- and the extra disk_type field.

encodeFullDLId :: DiskLogicalId -> (JSValue, [(String, JSValue)])

encodeFullDLId v = (encodeDLId v, lidEncodeType v)

-- | Custom decoder for DiskLogicalId. This is manual for now, since

-- we don't have yet automation for separate-key style fields.

decodeDLId :: [(String, JSValue)] -> JSValue -> J.Result DiskLogicalId

decodeDLId obj lid = do

  dtype <- fromObj obj devType

  case dtype of

    DTDrbd8 ->

      case lid of

        JSArray [nA, nB, p, mA, mB, k] -> do

          nA' <- readJSON nA

          nB' <- readJSON nB

          p'  <- readJSON p

          mA' <- readJSON mA

          mB' <- readJSON mB

          k'  <- readJSON k

          return $ LIDDrbd8 nA' nB' p' mA' mB' k'

        _ -> fail "Can't read logical_id for DRBD8 type"

    DTPlain ->

      case lid of

        JSArray [vg, lv] -> do

          vg' <- readJSON vg

          lv' <- readJSON lv

          return $ LIDPlain vg' lv'

        _ -> fail "Can't read logical_id for plain type"

    DTFile ->

      case lid of

        JSArray [driver, path] -> do

          driver' <- readJSON driver

          path'   <- readJSON path

          return $ LIDFile driver' path'

        _ -> fail "Can't read logical_id for file type"

    DTSharedFile ->

      case lid of

        JSArray [driver, path] -> do

          driver' <- readJSON driver

          path'   <- readJSON path

          return $ LIDSharedFile driver' path'

        _ -> fail "Can't read logical_id for shared file type"

    DTGluster ->

      case lid of

        JSArray [driver, path] -> do

          driver' <- readJSON driver

          path'   <- readJSON path

          return $ LIDSharedFile driver' path'

        _ -> fail "Can't read logical_id for shared file type"

    DTBlock ->

      case lid of

        JSArray [driver, path] -> do

          driver' <- readJSON driver

          path'   <- readJSON path

          return $ LIDBlockDev driver' path'

        _ -> fail "Can't read logical_id for blockdev type"

    DTRbd ->

      case lid of

        JSArray [driver, path] -> do

          driver' <- readJSON driver

          path'   <- readJSON path

          return $ LIDRados driver' path'

        _ -> fail "Can't read logical_id for rdb type"

    DTExt ->

      case lid of

        JSArray [extprovider, name] -> do

          extprovider' <- readJSON extprovider

          name'   <- readJSON name

          return $ LIDExt extprovider' name'

        _ -> fail "Can't read logical_id for extstorage type"

    DTDiskless ->

      fail "Retrieved 'diskless' disk."

-- | Disk data structure.

--

-- This is declared manually as it's a recursive structure, and our TH

-- code currently can't build it.

data Disk = Disk

  { diskLogicalId  :: DiskLogicalId

  , diskChildren   :: [Disk]

  , diskIvName     :: String

  , diskSize       :: Int

  , diskMode       :: DiskMode

  , diskName       :: Maybe String

  , diskSpindles   :: Maybe Int

  , diskUuid       :: String

  } deriving (Show, Eq)

$(buildObjectSerialisation "Disk" $

  [ customField 'decodeDLId 'encodeFullDLId ["dev_type"] $

      simpleField "logical_id"    [t| DiskLogicalId   |]

  , defaultField  [| [] |] $ simpleField "children" [t| [Disk] |]

  , defaultField [| "" |] $ simpleField "iv_name" [t| String |]

  , simpleField "size" [t| Int |]

  , defaultField [| DiskRdWr |] $ simpleField "mode" [t| DiskMode |]

  , optionalField $ simpleField "name" [t| String |]

  , optionalField $ simpleField "spindles" [t| Int |]

  ]

  ++ uuidFields)

instance UuidObject Disk where

  uuidOf = diskUuid

-- | Determines whether a disk or one of his children has the given logical id

-- (determined by the volume group name and by the logical volume name).

-- This can be true only for DRBD or LVM disks.

includesLogicalId :: String -> String -> Disk -> Bool

includesLogicalId vg_name lv_name disk =

  case diskLogicalId disk of

    LIDPlain vg lv -> vg_name == vg && lv_name == lv

    LIDDrbd8 {} ->

      any (includesLogicalId vg_name lv_name) $ diskChildren disk

    _ -> False

-- * Instance definitions

$(buildParam "Be" "bep"

  [ specialNumericalField 'parseUnitAssumeBinary

      $ simpleField "minmem"      [t| Int  |]

  , specialNumericalField 'parseUnitAssumeBinary

      $ simpleField "maxmem"      [t| Int  |]

  , simpleField "vcpus"           [t| Int  |]

  , simpleField "auto_balance"    [t| Bool |]

  , simpleField "always_failover" [t| Bool |]

  , simpleField "spindle_use"     [t| Int  |]

  ])

$(buildObject "Instance" "inst" $

  [ simpleField "name"           [t| String             |]

  , simpleField "primary_node"   [t| String             |]

  , simpleField "os"             [t| String             |]

  , simpleField "hypervisor"     [t| Hypervisor         |]

  , simpleField "hvparams"       [t| HvParams           |]

  , simpleField "beparams"       [t| PartialBeParams    |]

  , simpleField "osparams"       [t| OsParams           |]

  , simpleField "admin_state"    [t| AdminState         |]

  , simpleField "nics"           [t| [PartialNic]       |]

  , simpleField "disks"          [t| [Disk]             |]

  , simpleField "disk_template"  [t| DiskTemplate       |]

  , simpleField "disks_active"   [t| Bool               |]

  , optionalField $ simpleField "network_port" [t| Int  |]

  ]

  ++ timeStampFields

  ++ uuidFields

  ++ serialFields

  ++ tagsFields)

instance TimeStampObject Instance where

  cTimeOf = instCtime

  mTimeOf = instMtime

instance UuidObject Instance where

  uuidOf = instUuid

instance SerialNoObject Instance where

  serialOf = instSerial

instance TagsObject Instance where

  tagsOf = instTags

-- | Retrieves the real disk size requirements for all the disks of the

-- instance. This includes the metadata etc. and is different from the values

-- visible to the instance.

getDiskSizeRequirements :: Instance -> Int

getDiskSizeRequirements inst =

  sum . map

    (\disk -> case instDiskTemplate inst of

                DTDrbd8    -> diskSize disk + C.drbdMetaSize

                DTDiskless -> 0

                DTBlock    -> 0

                _          -> diskSize disk )

    $ instDisks inst

-- * IPolicy definitions

$(buildParam "ISpec" "ispec"

  [ simpleField ConstantUtils.ispecMemSize     [t| Int |]

  , simpleField ConstantUtils.ispecDiskSize    [t| Int |]

  , simpleField ConstantUtils.ispecDiskCount   [t| Int |]

  , simpleField ConstantUtils.ispecCpuCount    [t| Int |]

  , simpleField ConstantUtils.ispecNicCount    [t| Int |]

  , simpleField ConstantUtils.ispecSpindleUse  [t| Int |]

  ])

$(buildObject "MinMaxISpecs" "mmis"

  [ renameField "MinSpec" $ simpleField "min" [t| FilledISpecParams |]

  , renameField "MaxSpec" $ simpleField "max" [t| FilledISpecParams |]

  ])

-- | Custom partial ipolicy. This is not built via buildParam since it

-- has a special 2-level inheritance mode.

$(buildObject "PartialIPolicy" "ipolicy"

  [ optionalField . renameField "MinMaxISpecsP" $

    simpleField ConstantUtils.ispecsMinmax [t| [MinMaxISpecs] |]

  , optionalField . renameField "StdSpecP" $

    simpleField "std" [t| PartialISpecParams |]

  , optionalField . renameField "SpindleRatioP" $

    simpleField "spindle-ratio" [t| Double |]

  , optionalField . renameField "VcpuRatioP" $

    simpleField "vcpu-ratio" [t| Double |]

  , optionalField . renameField "DiskTemplatesP" $

    simpleField "disk-templates" [t| [DiskTemplate] |]

  ])

-- | Custom filled ipolicy. This is not built via buildParam since it

-- has a special 2-level inheritance mode.

$(buildObject "FilledIPolicy" "ipolicy"

  [ renameField "MinMaxISpecs" $

    simpleField ConstantUtils.ispecsMinmax [t| [MinMaxISpecs] |]

  , renameField "StdSpec" $ simpleField "std" [t| FilledISpecParams |]

  , simpleField "spindle-ratio"  [t| Double |]

  , simpleField "vcpu-ratio"     [t| Double |]

  , simpleField "disk-templates" [t| [DiskTemplate] |]

  ])

-- | Custom filler for the ipolicy types.

fillIPolicy :: FilledIPolicy -> PartialIPolicy -> FilledIPolicy

fillIPolicy (FilledIPolicy { ipolicyMinMaxISpecs  = fminmax

                           , ipolicyStdSpec       = fstd

                           , ipolicySpindleRatio  = fspindleRatio

                           , ipolicyVcpuRatio     = fvcpuRatio

                           , ipolicyDiskTemplates = fdiskTemplates})

            (PartialIPolicy { ipolicyMinMaxISpecsP  = pminmax

                            , ipolicyStdSpecP       = pstd

                            , ipolicySpindleRatioP  = pspindleRatio

                            , ipolicyVcpuRatioP     = pvcpuRatio

                            , ipolicyDiskTemplatesP = pdiskTemplates}) =

  FilledIPolicy { ipolicyMinMaxISpecs  = fromMaybe fminmax pminmax

                , ipolicyStdSpec       = case pstd of

                                         Nothing -> fstd

                                         Just p -> fillISpecParams fstd p

                , ipolicySpindleRatio  = fromMaybe fspindleRatio pspindleRatio

                , ipolicyVcpuRatio     = fromMaybe fvcpuRatio pvcpuRatio

                , ipolicyDiskTemplates = fromMaybe fdiskTemplates

                                         pdiskTemplates

                }

-- * Node definitions

$(buildParam "ND" "ndp"

  [ simpleField "oob_program"   [t| String |]

  , simpleField "spindle_count" [t| Int    |]

  , simpleField "exclusive_storage" [t| Bool |]

  , simpleField "ovs"           [t| Bool |]

  , simpleField "ovs_name"       [t| String |]

  , simpleField "ovs_link"       [t| String |]

  , simpleField "ssh_port"      [t| Int |]

  ])

$(buildObject "Node" "node" $

  [ simpleField "name"             [t| String |]

  , simpleField "primary_ip"       [t| String |]

  , simpleField "secondary_ip"     [t| String |]

  , simpleField "master_candidate" [t| Bool   |]

  , simpleField "offline"          [t| Bool   |]

  , simpleField "drained"          [t| Bool   |]

  , simpleField "group"            [t| String |]

  , simpleField "master_capable"   [t| Bool   |]

  , simpleField "vm_capable"       [t| Bool   |]

  , simpleField "ndparams"         [t| PartialNDParams |]

  , simpleField "powered"          [t| Bool   |]

  ]

  ++ timeStampFields

  ++ uuidFields

  ++ serialFields

  ++ tagsFields)

instance TimeStampObject Node where

  cTimeOf = nodeCtime

  mTimeOf = nodeMtime

instance UuidObject Node where

  uuidOf = nodeUuid

instance SerialNoObject Node where

  serialOf = nodeSerial

instance TagsObject Node where

  tagsOf = nodeTags

-- * NodeGroup definitions

-- | The disk parameters type.

type DiskParams = Container (Container JSValue)

-- | A mapping from network UUIDs to nic params of the networks.

type Networks = Container PartialNicParams

$(buildObject "NodeGroup" "group" $

  [ simpleField "name"         [t| String |]

  , defaultField [| [] |] $ simpleField "members" [t| [String] |]

  , simpleField "ndparams"     [t| PartialNDParams |]

  , simpleField "alloc_policy" [t| AllocPolicy     |]

  , simpleField "ipolicy"      [t| PartialIPolicy  |]

  , simpleField "diskparams"   [t| DiskParams      |]

  , simpleField "networks"     [t| Networks        |]

  ]

  ++ timeStampFields

  ++ uuidFields

  ++ serialFields

  ++ tagsFields)

instance TimeStampObject NodeGroup where

  cTimeOf = groupCtime

  mTimeOf = groupMtime

instance UuidObject NodeGroup where

  uuidOf = groupUuid

instance SerialNoObject NodeGroup where

  serialOf = groupSerial

instance TagsObject NodeGroup where

  tagsOf = groupTags

-- | IP family type

$(declareIADT "IpFamily"

  [ ("IpFamilyV4", 'AutoConf.pyAfInet4)

  , ("IpFamilyV6", 'AutoConf.pyAfInet6)

  ])

$(makeJSONInstance ''IpFamily)

-- | Conversion from IP family to IP version. This is needed because

-- Python uses both, depending on context.

ipFamilyToVersion :: IpFamily -> Int

ipFamilyToVersion IpFamilyV4 = C.ip4Version

ipFamilyToVersion IpFamilyV6 = C.ip6Version

-- | Cluster HvParams (hvtype to hvparams mapping).

type ClusterHvParams = Container HvParams

-- | Cluster Os-HvParams (os to hvparams mapping).

type OsHvParams = Container ClusterHvParams

-- | Cluser BeParams.

type ClusterBeParams = Container FilledBeParams

-- | Cluster OsParams.

type ClusterOsParams = Container OsParams

-- | Cluster NicParams.

type ClusterNicParams = Container FilledNicParams

-- | Cluster UID Pool, list (low, high) UID ranges.

type UidPool = [(Int, Int)]

-- | The iallocator parameters type.

type IAllocatorParams = Container JSValue

-- | The master candidate client certificate digests

type CandidateCertificates = Container String

-- * Cluster definitions

$(buildObject "Cluster" "cluster" $

  [ simpleField "rsahostkeypub"             [t| String           |]

  , optionalField $

    simpleField "dsahostkeypub"             [t| String           |]

  , simpleField "highest_used_port"         [t| Int              |]

  , simpleField "tcpudp_port_pool"          [t| [Int]            |]

  , simpleField "mac_prefix"                [t| String           |]

  , optionalField $

    simpleField "volume_group_name"         [t| String           |]

  , simpleField "reserved_lvs"              [t| [String]         |]

  , optionalField $

    simpleField "drbd_usermode_helper"      [t| String           |]

  , simpleField "master_node"               [t| String           |]

  , simpleField "master_ip"                 [t| String           |]

  , simpleField "master_netdev"             [t| String           |]

  , simpleField "master_netmask"            [t| Int              |]

  , simpleField "use_external_mip_script"   [t| Bool             |]

  , simpleField "cluster_name"              [t| String           |]

  , simpleField "file_storage_dir"          [t| String           |]

  , simpleField "shared_file_storage_dir"   [t| String           |]

  , simpleField "gluster_storage_dir"       [t| String           |]

  , simpleField "enabled_hypervisors"       [t| [Hypervisor]     |]

  , simpleField "hvparams"                  [t| ClusterHvParams  |]

  , simpleField "os_hvp"                    [t| OsHvParams       |]

  , simpleField "beparams"                  [t| ClusterBeParams  |]

  , simpleField "osparams"                  [t| ClusterOsParams  |]

  , simpleField "nicparams"                 [t| ClusterNicParams |]

  , simpleField "ndparams"                  [t| FilledNDParams   |]

  , simpleField "diskparams"                [t| DiskParams       |]

  , simpleField "candidate_pool_size"       [t| Int              |]

  , simpleField "modify_etc_hosts"          [t| Bool             |]

  , simpleField "modify_ssh_setup"          [t| Bool             |]

  , simpleField "maintain_node_health"      [t| Bool             |]

  , simpleField "uid_pool"                  [t| UidPool          |]

  , simpleField "default_iallocator"        [t| String           |]

  , simpleField "default_iallocator_params" [t| IAllocatorParams |]

  , simpleField "hidden_os"                 [t| [String]         |]

  , simpleField "blacklisted_os"            [t| [String]         |]

  , simpleField "primary_ip_family"         [t| IpFamily         |]

  , simpleField "prealloc_wipe_disks"       [t| Bool             |]

  , simpleField "ipolicy"                   [t| FilledIPolicy    |]

  , simpleField "enabled_disk_templates"    [t| [DiskTemplate]   |]

  , simpleField "candidate_certs"           [t| CandidateCertificates |]

 ]

 ++ timeStampFields

 ++ uuidFields

 ++ serialFields

 ++ tagsFields)

instance TimeStampObject Cluster where

  cTimeOf = clusterCtime

  mTimeOf = clusterMtime

instance UuidObject Cluster where

  uuidOf = clusterUuid

instance SerialNoObject Cluster where

  serialOf = clusterSerial

instance TagsObject Cluster where

  tagsOf = clusterTags

-- * ConfigData definitions

$(buildObject "ConfigData" "config" $

--  timeStampFields ++

  [ simpleField "version"    [t| Int                 |]

  , simpleField "cluster"    [t| Cluster             |]

  , simpleField "nodes"      [t| Container Node      |]

  , simpleField "nodegroups" [t| Container NodeGroup |]

  , simpleField "instances"  [t| Container Instance  |]

  , simpleField "networks"   [t| Container Network   |]

  ]

  ++ serialFields)

instance SerialNoObject ConfigData where

  serialOf = configSerial