jeremyjh

globalMonitor :: Process ()
globalMonitor = do
    let initState = [] :: [MxEvent]
    void $ mxAgent (MxAgentId "lifecycle-listener-agent") initState [
        mxSink $ \ev -> do
           let act =
                 case ev of

                   (MxProcessDied pid (DiedException msg)) -> liftMX $ say $ debug $ "[Error] " ++ show pid ++  " DiedException: " ++ msg
                   (MxProcessDied pid DiedDisconnect) -> liftMX $ say $ show pid ++ " DiedDisconnect"

jeremyjh

{-# LANGUAGE TemplateHaskell #-}
{-# LANGUAGE MultiParamTypeClasses #-}
{-# LANGUAGE FunctionalDependencies #-}
{-# LANGUAGE FlexibleInstances #-}

module Main where

import Control.Lens

declareFields [d|

jeremyjh

{-# LANGUAGE RankNTypes #-}
{-# LANGUAGE GeneralizedNewtypeDeriving #-}

module Control.Distributed.Process.Lifted
    ( module Control.Distributed.Process
    , module Control.Distributed.Process.Lifted
    )
where

import           Control.Monad.Trans.Control

jeremyjh

-- Functions intended to make it easier to work with distributed-process
-- from the REPL.

module NodeProcess where


import Control.Distributed.Process
import Control.Distributed.Process.Serializable
import Control.Concurrent.MVar
import Control.Concurrent (threadDelay)

jeremyjh

desc "Regenerate tags (CTAGS)"
task :ctags do
  puts " * Regenerating Tags"
  excludes = %w{
      .git
      .git*
      *.yml
      app/views
      app/assets
      coverage