Synnefo » snf-ganeti » ganeti-local

    , doNextBalance

    , tryBalance

    , compCV

    , printStats

    , iMoveToJob

    -- * IAllocator functions

-- | The complete state for the balancing solution

data Table = Table Node.List Instance.List Score [Placement]

data CStats = CStats { csFmem :: Int    -- ^ Cluster free mem

                     , csFdsk :: Int    -- ^ Cluster free disk

                     , csScore :: Score -- ^ The cluster score

                     , csNinst :: Int   -- ^ The total number of instances

                     }

-- | Currently used, possibly to allocate, unallocable

type AllocStats = (RSpec, RSpec, RSpec)

    , uuid        :: T.GroupID     -- ^ The UUID of the group

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

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

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

-- name

{-

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

                         , util :: T.DynUtil -- ^ Dynamic resource usage

                         , movable :: Bool   -- ^ Can the instance be moved?

                         , tags :: [String]  -- ^ List of instance tags

instance T.Element Instance where

    nameOf   = name

    | Relocate Idx Int [Ndx]         -- ^ Move an instance to a new

                                     -- secondary node

    | Evacuate [Ndx]                 -- ^ Evacuate nodes

-- | A complete request, as received from Ganeti.

data Request = Request RqType ClusterData

-- | The cluster state.

data ClusterData = ClusterData

    , cdNodes     :: Node.List     -- ^ The node list

    , cdInstances :: Instance.List -- ^ The instance list

    , cdTags      :: [String]      -- ^ The cluster tags

-- | An empty cluster.

emptyCluster :: ClusterData

    , utilLoad :: T.DynUtil -- ^ Sum of instance utilisation

    , pTags    :: TagMap    -- ^ Map of primary instance tags and their count

    , group    :: T.Gdx     -- ^ The node's group (index)

instance T.Element Node where

    nameOf = name

                       -- last-resort, after the preferred groups

    | AllocUnallocable -- ^ This group must not be used for new

                       -- allocations

-- | Convert a string to an alloc policy

apolFromString :: (Monad m) => String -> m AllocPolicy

    { rspecCpu  :: Int  -- ^ Requested VCPUs

    , rspecMem  :: Int  -- ^ Requested memory

    , rspecDsk  :: Int  -- ^ Requested disk

-- | The dynamic resource specs of a machine (i.e. load or load

-- capacity, as opposed to size).

    , memWeight :: Weight -- ^ Standardised memory load

    , dskWeight :: Weight -- ^ Standardised disk I\/O usage

    , netWeight :: Weight -- ^ Standardised network usage

-- | Initial empty utilisation

zeroUtil :: DynUtil

           | ReplaceSecondary Ndx    -- ^ Replace secondary (r:ns)

           | ReplaceAndFailover Ndx  -- ^ Replace secondary, failover (r:np, f)

           | FailoverAndReplace Ndx  -- ^ Failover, replace secondary (f, r:ns)

-- | Formatted solution output for one move (involved nodes and

-- commands

data Result a

    = Bad String

    | Ok a

instance Monad Result where

    (>>=) (Bad x) _ = Bad x

              | FailCPU  -- ^ Failed due to not enough CPU capacity

              | FailN1   -- ^ Failed due to not passing N1 checks

              | FailTags -- ^ Failed due to tag exclusion

-- | List with failure statistics

type FailStats = [(FailMode, Int)]

-- | Either-like data-type customized for our failure modes

data OpResult a = OpFail FailMode -- ^ Failed operation

                | OpGood a        -- ^ Success operation

instance Monad OpResult where

    (OpGood x) >>= fn = fn x

{-

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

              | OP_STATUS_CANCELED

              | OP_STATUS_SUCCESS

              | OP_STATUS_ERROR

instance JSON OpStatus where

    showJSON os = showJSON w

               | JOB_STATUS_CANCELING

               | JOB_STATUS_CANCELED

               | JOB_STATUS_ERROR

instance JSON JobStatus where

    showJSON js = showJSON w

            | CancelJob Int

            | SetDrainFlag Bool

            | SetWatcherPause Double

-- | The serialisation of LuxiOps into strings in messages.

strOfOp :: LuxiOp -> String

{-

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

                  | ReplaceOnSecondary

                  | ReplaceNewSecondary

                  | ReplaceAuto

instance JSON ReplaceDisksMode where

    showJSON m = case m of

              [Int] (Maybe String)

            | OpFailoverInstance String Bool

            | OpMigrateInstance String Bool Bool

opID :: OpCode -> String