Synnefo » snf-ganeti » ganeti-local

	htools/Ganeti/Luxi.hs \

	htools/Ganeti/Objects.hs \

	htools/Ganeti/OpCodes.hs \

	htools/Ganeti/Query/Common.hs \

	htools/Ganeti/Query/Filter.hs \

	htools/Ganeti/Query/Language.hs \

from ganeti import constants

from ganeti import luxi

from ganeti import qlang

#: Constant name regex

CONSTANT_RE = re.compile("^[A-Z][A-Z0-9_-]+$")

# have strings instead of easily looked-up names.

IGNORED_DECL_NAMES = ["DEFAULT_ENABLED_HYPERVISOR"]

def NameRules(name):

  """Converts the upper-cased Python name to Haskell camelCase.

  print Convert(constants, "")

  print Convert(luxi, "luxi")

  print Convert(qlang, "qlang")

if __name__ == "__main__":

import Ganeti.Hash

import Ganeti.Logging

import qualified Ganeti.Constants as C

import Ganeti.Query.Server (runQueryD)

-- * Types and constants definitions

  hmac <- getClusterHmac

  -- Inotify setup

  inotify <- initINotify

  -- fork the timeout timer

  -- fork the polling timer

  -- launch the queryd listener

  _ <- forkIO $ runQueryD Nothing (configReader cref)

  -- and finally enter the responder loop

import Ganeti.Confd

import Ganeti.Hash

import qualified Ganeti.Constants as C

import Ganeti.JSON

import Ganeti.HTools.Utils

-- | Returns the HMAC key.

getClusterHmac :: IO HashKey

-- | Parses a signed request.

parseRequest :: HashKey -> String -> Result (String, String, ConfdRequest)

  , parseYesNo

  , parseISpecString

  , shTemplate

  , maybePrintNodes

  , maybePrintInsts

  , maybeShowWarnings

import qualified Ganeti.HTools.Container as Container

import qualified Ganeti.HTools.Node as Node

import Ganeti.HTools.Types

import Ganeti.HTools.Utils

import Ganeti.BasicTypes

import Ganeti.Common as Common

-- * Data types

-- | Command line options structure.

oLuxiSocket :: OptType

oLuxiSocket = Option "L" ["luxi"]

              (OptArg ((\ f opts -> Ok opts { optLuxi = Just f }) .

              "collect data via Luxi, optionally using the given SOCKET path"

oMachineReadable :: OptType

import qualified Ganeti.HTools.Instance as Instance

import qualified Ganeti.HTools.Rapi as Rapi

import qualified Ganeti.HTools.Luxi as Luxi

import Ganeti.HTools.Loader (checkData, mergeData, ClusterData(..))

import Ganeti.HTools.Text (serializeCluster)

                "t_disk" "f_disk" "Score"

  when (null clusters) $ do

         let name = local

         input_data <- Luxi.loadData lsock

         result <- writeData nlen name opts input_data

import System.Info (arch)

import qualified Ganeti.Constants as C

import Ganeti.Daemon

import Ganeti.Objects

import qualified Ganeti.Config as Config

-- only one exposed from this module.

runQueryD :: Maybe FilePath -> ConfigReader -> IO ()

runQueryD fpath creader = do

  cleanupSocket socket_path

  bracket

    (getServer socket_path)

import Text.Printf

import qualified Ganeti.Constants as C

import Ganeti.BasicTypes

data GanetiDaemon = GanetiMasterd

-- | Returns the log file for a daemon.

daemonLogFile :: GanetiDaemon -> FilePath

-- | Returns the pid file name for a daemon.

daemonPidFile :: GanetiDaemon -> FilePath

-- | All groups list. A bit hacking, as we can't enforce it's complete

-- at compile time.

import System.IO.Error (isDoesNotExistError)

import qualified Ganeti.Constants as C

import Ganeti.BasicTypes

import Ganeti.HTools.Utils

keyToFilename :: Maybe FilePath     -- ^ Optional config path override

              -> SSKey              -- ^ ssconf key

              -> FilePath

                            sSFilePrefix ++ sSKeyToRaw key

-- | Runs an IO action while transforming any error into 'Bad'