Safe Haskell	None
Language	Haskell2010

Foreign.CloudI

Documentation

data RequestType Source #

Constructors

ASYNC
SYNC

Instances

Eq RequestType Source #
Methods (==) :: RequestType -> RequestType -> Bool # (/=) :: RequestType -> RequestType -> Bool #
Show RequestType Source #
Methods showsPrec :: Int -> RequestType -> ShowS # show :: RequestType -> String # showList :: [RequestType] -> ShowS #

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

Show s => Show (Response s) Source #
Methods showsPrec :: Int -> Response s -> ShowS # show :: Response s -> String # showList :: [Response s] -> ShowS #

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 #
Methods showsPrec :: Int -> T s -> ShowS # show :: T s -> String # showList :: [T s] -> ShowS #

transIdNull :: ByteString Source #

invalidInputError :: String Source #

messageDecodingError :: String Source #

terminateError :: String Source #

data Exception s Source #

Instances

Show (Exception s) Source #
Methods showsPrec :: Int -> Exception s -> ShowS # show :: Exception s -> String # showList :: [Exception s] -> ShowS #
Typeable * s => Exception (Exception s) Source #
Methods toException :: Exception s -> SomeException # fromException :: SomeException -> Maybe (Exception s) # displayException :: Exception s -> String #

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 #