Distrib.Butter.Lang

Documentation

data ProcessID

Constructors

PID

Fields

• machineID :: Text
• processID :: Int

Named

Fields

• hostname :: Text
• processName :: Text

Instances

Eq ProcessID

Methods

(==) :: ProcessID -> ProcessID -> Bool

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

Show ProcessID

Methods

showsPrec :: Int -> ProcessID -> ShowS

show :: ProcessID -> String

showList :: [ProcessID] -> ShowS

Generic ProcessID

Associated Types

type Rep ProcessID :: * -> *

Methods

from :: ProcessID -> Rep ProcessID x

to :: Rep ProcessID x -> ProcessID

ToJSON ProcessID

Methods

toJSON :: ProcessID -> Value

toEncoding :: ProcessID -> Encoding

toJSONList :: [ProcessID] -> Value

toEncodingList :: [ProcessID] -> Encoding

FromJSON ProcessID

Methods

parseJSON :: Value -> Parser ProcessID

parseJSONList :: Value -> Parser [ProcessID]

type Rep ProcessID

type Rep ProcessID = D1 * (MetaData "ProcessID" "Distrib.Butter.Lang" "butter-0.1.0.6-DRJWwjqobcy784zW4BKx1a" False) ((:+:) * (C1 * (MetaCons "PID" PrefixI True) ((:*:) * (S1 * (MetaSel (Just Symbol "machineID") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Text)) (S1 * (MetaSel (Just Symbol "processID") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Int)))) (C1 * (MetaCons "Named" PrefixI True) ((:*:) * (S1 * (MetaSel (Just Symbol "hostname") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Text)) (S1 * (MetaSel (Just Symbol "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)

Methods

fmap :: (a -> b) -> Action m a -> Action m b

(<$) :: a -> Action m b -> Action m a

MonadIO m => MonadIO (Free (Action m))

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