cloudi-1.7.0: Haskell CloudI API

Safe HaskellNone
LanguageHaskell2010

Foreign.CloudI

Documentation

data RequestType Source

Constructors

ASYNC 
SYNC 

Instances

type Source = Pid Source

data Response s Source

Constructors

Response (ByteString, s, T s) 
ResponseInfo (ByteString, ByteString, s, T s) 
Forward (ByteString, ByteString, ByteString, s, T s) 
Forward_ (ByteString, ByteString, ByteString, Int, Int, s, T s) 
Null (s, T s) 
NullError (String, s, T s) 

Instances

type Callback s = RequestType -> ByteString -> ByteString -> ByteString -> ByteString -> Int -> Int -> ByteString -> Source -> s -> T s -> IO (Response s) Source

data T s Source

Instances

Show (T s) Source 

transIdNull :: ByteString Source

invalidInputError :: String Source

messageDecodingError :: String Source

terminateError :: String Source

data Exception s Source

Instances

api :: Typeable s => Int -> s -> IO (Result (T s)) Source

threadCount :: IO (Result Int) Source

subscribe :: T s -> ByteString -> Callback s -> IO (Result (T s)) Source

subscribeCount :: Typeable s => T s -> ByteString -> IO (Result (Int, T s)) Source

unsubscribe :: T s -> ByteString -> IO (Result (T s)) Source

sendAsync :: Typeable s => T s -> ByteString -> ByteString -> Maybe Int -> Maybe ByteString -> Maybe Int -> IO (Result (ByteString, T s)) Source

sendSync :: Typeable s => T s -> ByteString -> ByteString -> Maybe Int -> Maybe ByteString -> Maybe Int -> IO (Result (ByteString, ByteString, ByteString, T s)) Source

mcastAsync :: Typeable s => T s -> ByteString -> ByteString -> Maybe Int -> Maybe ByteString -> Maybe Int -> IO (Result (Array Int ByteString, T s)) Source

forward_ :: Typeable s => T s -> RequestType -> ByteString -> ByteString -> ByteString -> Int -> Int -> ByteString -> Source -> IO () Source

forwardAsync :: Typeable s => T s -> ByteString -> ByteString -> ByteString -> Int -> Int -> ByteString -> Source -> IO () Source

forwardSync :: Typeable s => T s -> ByteString -> ByteString -> ByteString -> Int -> Int -> ByteString -> Source -> IO () Source

return_ :: Typeable s => T s -> RequestType -> ByteString -> ByteString -> ByteString -> ByteString -> Int -> ByteString -> Source -> IO () Source

returnAsync :: Typeable s => T s -> ByteString -> ByteString -> ByteString -> ByteString -> Int -> ByteString -> Source -> IO () Source

returnSync :: Typeable s => T s -> ByteString -> ByteString -> ByteString -> ByteString -> Int -> ByteString -> Source -> IO () Source

recvAsync :: Typeable s => T s -> Maybe Int -> Maybe ByteString -> Maybe Bool -> IO (Result (ByteString, ByteString, ByteString, T s)) Source

processIndex :: T s -> Int Source

processCount :: T s -> Int Source

processCountMax :: T s -> Int Source

processCountMin :: T s -> Int Source

prefix :: T s -> ByteString Source

timeoutInitialize :: T s -> Int Source

timeoutAsync :: T s -> Int Source

timeoutSync :: T s -> Int Source

timeoutTerminate :: T s -> Int Source

poll :: Typeable s => T s -> Int -> IO (Result (Bool, T s)) Source

threadCreate :: (Int -> IO ()) -> Int -> IO ThreadId Source

threadsWait :: IO () Source

infoKeyValueParse :: ByteString -> Map ByteString [ByteString] Source