Ganeti.Luxi

Contents

• Utility functions
• Generic protocol functionality

Description

Synopsis

• withTimeout :: Int -> String -> IO a -> IO a
• data RecvResult
  • = RecvConnClosed
  • | RecvError String
  • | RecvOk String
• data LuxiOp
  • = Query ItemType [String] (Filter FilterField)
  • | QueryFields ItemType [String]
  • | QueryNodes [String] [String] Bool
  • | QueryGroups [String] [String] Bool
  • | QueryNetworks [String] [String] Bool
  • | QueryInstances [String] [String] Bool
  • | QueryJobs [JobId] [String]
  • | QueryExports [String] Bool
  • | QueryConfigValues [String]
  • | QueryClusterInfo
  • | QueryTags TagKind String
  • | SubmitJob [MetaOpCode]
  • | SubmitJobToDrainedQueue [MetaOpCode]
  • | SubmitManyJobs [[MetaOpCode]]
  • | WaitForJobChange JobId [String] JSValue JSValue Int
  • | ArchiveJob JobId
  • | AutoArchiveJobs Int Int
  • | CancelJob JobId
  • | ChangeJobPriority JobId Int
  • | SetDrainFlag Bool
  • | SetWatcherPause Double
• data LuxiReq
  • = ReqQuery
  • | ReqQueryFields
  • | ReqQueryNodes
  • | ReqQueryGroups
  • | ReqQueryNetworks
  • | ReqQueryInstances
  • | ReqQueryJobs
  • | ReqQueryExports
  • | ReqQueryConfigValues
  • | ReqQueryClusterInfo
  • | ReqQueryTags
  • | ReqSubmitJob
  • | ReqSubmitJobToDrainedQueue
  • | ReqSubmitManyJobs
  • | ReqWaitForJobChange
  • | ReqArchiveJob
  • | ReqAutoArchiveJobs
  • | ReqCancelJob
  • | ReqChangeJobPriority
  • | ReqSetDrainFlag
  • | ReqSetWatcherPause
• luxiReqFromRaw :: forall m. Monad m => String -> m LuxiReq
• luxiReqToRaw :: LuxiReq -> String
• opToArgs :: LuxiOp -> JSValue
• opToDict :: LuxiOp -> [(String, JSValue)]
• allLuxiCalls :: [String]
• strOfOp :: LuxiOp -> String
• data LuxiCall = LuxiCall LuxiReq JSValue
• eOM :: Word8
• bEOM :: ByteString
• data MsgKeys
  • = Method
  • | Args
  • | Success
  • | Result
• strOfKey :: MsgKeys -> String
• data Client = Client {
  • socket :: Handle
  • rbuf :: IORef ByteString
  }
• getClient :: String -> IO Client
• getServer :: Bool -> FilePath -> IO Socket
• closeServer :: FilePath -> Socket -> IO ()
• acceptClient :: Socket -> IO Client
• closeClient :: Client -> IO ()
• sendMsg :: Client -> String -> IO ()
• recvUpdate :: Handle -> ByteString -> IO (ByteString, ByteString)
• recvMsg :: Client -> IO String
• recvMsgExt :: Client -> IO RecvResult
• buildCall :: LuxiOp -> String
• buildResponse :: Bool -> JSValue -> String
• validateCall :: String -> Result LuxiCall
• decodeCall :: LuxiCall -> Result LuxiOp
• validateResult :: String -> ErrorResult JSValue
• decodeError :: JSValue -> ErrorResult JSValue
• callMethod :: LuxiOp -> Client -> IO (ErrorResult JSValue)
• parseSubmitJobResult :: JSValue -> ErrorResult JobId
• submitManyJobs :: Client -> [[MetaOpCode]] -> IO (ErrorResult [JobId])
• queryJobsStatus :: Client -> [JobId] -> IO (ErrorResult [JobStatus])

Utility functions

Generic protocol functionality