Foreign.CloudI

Documentation

data RequestType

Constructors

ASYNC

SYNC

Instances

Eq RequestType

Methods

(==) :: RequestType -> RequestType -> Bool

(/=) :: RequestType -> RequestType -> Bool

Show RequestType

Methods

showsPrec :: Int -> RequestType -> ShowS

show :: RequestType -> String

showList :: [RequestType] -> ShowS

type Source = Pid

data Response s

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)

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)

data T s

Instances

Show (T s)

Methods

showsPrec :: Int -> T s -> ShowS

show :: T s -> String

showList :: [T s] -> ShowS

transIdNull :: ByteString

invalidInputError :: String

messageDecodingError :: String

terminateError :: String

data Exception s

Instances

Show (Exception s)

Methods

showsPrec :: Int -> Exception s -> ShowS

show :: Exception s -> String

showList :: [Exception s] -> ShowS

Typeable * s => Exception (Exception s)

Methods

toException :: Exception s -> SomeException

fromException :: SomeException -> Maybe (Exception s)

displayException :: Exception s -> String

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

threadCount :: IO (Result Int)

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

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

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

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

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

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

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

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

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

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

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

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

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

processIndex :: T s -> Int

processCount :: T s -> Int

processCountMax :: T s -> Int

processCountMin :: T s -> Int

prefix :: T s -> ByteString

timeoutInitialize :: T s -> Int

timeoutAsync :: T s -> Int

timeoutSync :: T s -> Int

timeoutTerminate :: T s -> Int

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

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

threadsWait :: IO ()

infoKeyValueParse :: ByteString -> Map ByteString [ByteString]