Safe Haskell	None
Language	Haskell2010

Distrib.Butter.Lang

Documentation

data ProcessID #

Constructors

PID
Fields machineID :: Text processID :: Int
Named
Fields hostname :: Text processName :: Text

Instances

Eq ProcessID #
Instance details Defined in Distrib.Butter.Lang Methods (==) :: ProcessID -> ProcessID -> Bool # (/=) :: ProcessID -> ProcessID -> Bool #
Show ProcessID #
Instance details Defined in Distrib.Butter.Lang Methods showsPrec :: Int -> ProcessID -> ShowS # show :: ProcessID -> String # showList :: [ProcessID] -> ShowS #
Generic ProcessID #
Instance details Defined in Distrib.Butter.Lang Associated Types type Rep ProcessID :: * -> * # Methods from :: ProcessID -> Rep ProcessID x # to :: Rep ProcessID x -> ProcessID #
ToJSON ProcessID #
Instance details Defined in Distrib.Butter.Lang Methods toJSON :: ProcessID -> Value # toEncoding :: ProcessID -> Encoding # toJSONList :: [ProcessID] -> Value # toEncodingList :: [ProcessID] -> Encoding #
FromJSON ProcessID #
Instance details Defined in Distrib.Butter.Lang Methods parseJSON :: Value -> Parser ProcessID # parseJSONList :: Value -> Parser [ProcessID] #
type Rep ProcessID #
Instance details Defined in Distrib.Butter.Lang type Rep ProcessID = D1 (MetaData "ProcessID" "Distrib.Butter.Lang" "butter-0.1.0.6-1YuzefI4Vu77m35PZDfQVX" False) (C1 (MetaCons "PID" PrefixI True) (S1 (MetaSel (Just "machineID") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text) :: S1 (MetaSel (Just "processID") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int)) :+: C1 (MetaCons "Named" PrefixI True) (S1 (MetaSel (Just "hostname") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text) :: S1 (MetaSel (Just "processName") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))

to :: Text -> Text -> ProcessID #

data Action (m :: * -> *) next where #

Constructors

Lift :: m a -> (a -> next) -> Action m next
Connect :: Text -> Text -> Int -> next -> Action m next
Spawn :: Butter m () -> (ProcessID -> next) -> Action m next
Send :: ProcessID -> ByteString -> next -> Action m next
Receive :: (ByteString -> next) -> Action m next
Friends :: ([Text] -> next) -> Action m next
Self :: (ProcessID -> next) -> Action m next
Alive :: ProcessID -> (Bool -> next) -> Action m next
Name :: Text -> next -> Action m next

Instances

Functor (Action m) #
Instance details Defined in Distrib.Butter.Lang Methods fmap :: (a -> b) -> Action m a -> Action m b # (<$) :: a -> Action m b -> Action m a #
MonadIO m => MonadIO (Free (Action m)) #
Instance details Defined in Distrib.Butter.Lang Methods liftIO :: IO a -> Free (Action m) a #

data Internal #

Constructors

Internal
Fields machine :: Text procs :: [Int] names :: Map Text Int fresh :: Int friends :: Map Text Socket mail :: Seq (ProcessID, ProcessID, ByteString)

type Butter m a = Free (Action m) a #

connect :: Text -> Text -> Int -> Butter m () #

spawn :: Butter m () -> Butter m ProcessID #

self :: Butter m ProcessID #

name :: Text -> Butter m () #

send :: ToJSON a => ProcessID -> a -> Butter m () #

receive :: (MonadIO m, FromJSON a) => Butter m a #

lift :: m a -> Butter m a #

alive :: ProcessID -> Butter m Bool #

spreadLocal :: (MonadIO m, ForkableMonad m, ToJSON a, FromJSON a) => Butter m a -> m a #

spread :: (MonadIO m, ForkableMonad m, ToJSON a, FromJSON a) => Text -> Maybe Int -> Butter m a -> m a #