-- Hoogle documentation, generated by Haddock
-- See Hoogle, http://www.haskell.org/hoogle/


-- | Message passing concurrency as extensible-effect
--   
--   Please see the README on GitHub at
--   <a>https://github.com/sheyll/extensible-effects-concurrent#readme</a>
@package extensible-effects-concurrent
@version 0.23.0


-- | Add-ons to <a>Exception</a> and <a>Exception</a>
module Control.Eff.ExceptionExtra

-- | Catch <a>Exception</a> thrown by an effect.
liftTry :: forall e r a. (HasCallStack, Exception e, Lifted IO r) => Eff r a -> Eff r (Either e a)

-- | Very similar to <a>liftEither</a> but for <a>Maybe</a>s. Unlike
--   <a>liftMaybe</a> this will throw the given value (instead of using
--   <a>Fail</a>).
maybeThrow :: Member (Exc x) e => x -> Maybe a -> Eff e a
instance Control.Monad.Catch.MonadThrow (Control.Eff.Internal.Eff e) => Control.Monad.Catch.MonadThrow (Control.Eff.Internal.Eff (Control.Eff.Reader.Lazy.Reader x : e))
instance Control.Monad.Catch.MonadCatch (Control.Eff.Internal.Eff e) => Control.Monad.Catch.MonadCatch (Control.Eff.Internal.Eff (Control.Eff.Reader.Lazy.Reader x : e))
instance Control.Monad.Catch.MonadMask (Control.Eff.Internal.Eff e) => Control.Monad.Catch.MonadMask (Control.Eff.Internal.Eff (Control.Eff.Reader.Lazy.Reader x : e))
instance Control.Monad.Catch.MonadThrow (Control.Eff.Internal.Eff e) => Control.Monad.Catch.MonadThrow (Control.Eff.Internal.Eff (Control.Eff.Reader.Strict.Reader x : e))
instance Control.Monad.Catch.MonadCatch (Control.Eff.Internal.Eff e) => Control.Monad.Catch.MonadCatch (Control.Eff.Internal.Eff (Control.Eff.Reader.Strict.Reader x : e))
instance Control.Monad.Catch.MonadMask (Control.Eff.Internal.Eff e) => Control.Monad.Catch.MonadMask (Control.Eff.Internal.Eff (Control.Eff.Reader.Strict.Reader x : e))
instance Control.Monad.Catch.MonadThrow m => Control.Monad.Catch.MonadThrow (Control.Eff.Internal.Eff '[Control.Eff.Internal.Lift m])
instance Control.Monad.Catch.MonadCatch m => Control.Monad.Catch.MonadCatch (Control.Eff.Internal.Eff '[Control.Eff.Internal.Lift m])
instance Control.Monad.Catch.MonadMask m => Control.Monad.Catch.MonadMask (Control.Eff.Internal.Eff '[Control.Eff.Internal.Lift m])
instance Control.Monad.Catch.MonadThrow (Control.Eff.Internal.Eff e) => Control.Monad.Catch.MonadThrow (Control.Eff.Internal.Eff (Control.Eff.Exception.Exc x : e))
instance Control.Monad.Catch.MonadCatch (Control.Eff.Internal.Eff e) => Control.Monad.Catch.MonadCatch (Control.Eff.Internal.Eff (Control.Eff.Exception.Exc x : e))
instance Control.Monad.Catch.MonadMask (Control.Eff.Internal.Eff e) => Control.Monad.Catch.MonadMask (Control.Eff.Internal.Eff (Control.Eff.Exception.Exc x : e))


-- | An RFC 5434 inspired log message and convenience functions for logging
--   them.
module Control.Eff.Log.Message

-- | A message data type inspired by the RFC-5424 Syslog Protocol
data LogMessage
MkLogMessage :: !Facility -> !Severity -> Maybe UTCTime -> Maybe Text -> Maybe Text -> Maybe Text -> Maybe Text -> [StructuredDataElement] -> Maybe ThreadId -> Maybe SrcLoc -> Text -> LogMessage
[_lmFacility] :: LogMessage -> !Facility
[_lmSeverity] :: LogMessage -> !Severity
[_lmTimestamp] :: LogMessage -> Maybe UTCTime
[_lmHostname] :: LogMessage -> Maybe Text
[_lmAppName] :: LogMessage -> Maybe Text
[_lmProcessId] :: LogMessage -> Maybe Text
[_lmMessageId] :: LogMessage -> Maybe Text
[_lmStructuredData] :: LogMessage -> [StructuredDataElement]
[_lmThreadId] :: LogMessage -> Maybe ThreadId
[_lmSrcLoc] :: LogMessage -> Maybe SrcLoc
[_lmMessage] :: LogMessage -> Text

-- | A lens for the <a>Facility</a> of a <a>LogMessage</a>
lmFacility :: Functor f => (Facility -> f Facility) -> LogMessage -> f LogMessage

-- | A lens for the <a>Severity</a> of a <a>LogMessage</a>
lmSeverity :: Functor f => (Severity -> f Severity) -> LogMessage -> f LogMessage

-- | A lens for the UTC time of a <a>LogMessage</a> The function
--   <a>setLogMessageTimestamp</a> can be used to set the field.
lmTimestamp :: Functor f => (Maybe UTCTime -> f (Maybe UTCTime)) -> LogMessage -> f LogMessage

-- | A lens for the hostname of a <a>LogMessage</a> The function
--   <a>setLogMessageHostname</a> can be used to set the field.
lmHostname :: Functor f => (Maybe Text -> f (Maybe Text)) -> LogMessage -> f LogMessage

-- | A lens for the RFC 5424 <i>application</i> name of a <a>LogMessage</a>
--   
--   One useful pattern for using this field, is to implement log filters
--   that allow info and debug message from the application itself while
--   only allowing warning and error messages from third party libraries:
--   
--   <pre>
--   debugLogsForAppName myAppName lm =
--     view lmAppName lm == Just myAppName || lmSeverityIsAtLeast warningSeverity lm
--   </pre>
--   
--   This concept is also implemented in <a>discriminateByAppName</a>.
lmAppName :: Functor f => (Maybe Text -> f (Maybe Text)) -> LogMessage -> f LogMessage

-- | A lens for a user defined of <i>process</i> id of a <a>LogMessage</a>
lmProcessId :: Functor f => (Maybe Text -> f (Maybe Text)) -> LogMessage -> f LogMessage

-- | A lens for a user defined <i>message id</i> of a <a>LogMessage</a>
lmMessageId :: Functor f => (Maybe Text -> f (Maybe Text)) -> LogMessage -> f LogMessage

-- | A lens for the <a>StructuredDataElement</a> of a <a>LogMessage</a>
lmStructuredData :: Functor f => ([StructuredDataElement] -> f [StructuredDataElement]) -> LogMessage -> f LogMessage

-- | A lens for the <a>SrcLoc</a> of a <a>LogMessage</a>
lmSrcLoc :: Functor f => (Maybe SrcLoc -> f (Maybe SrcLoc)) -> LogMessage -> f LogMessage

-- | A lens for the <a>ThreadId</a> of a <a>LogMessage</a> The function
--   <a>setLogMessageThreadId</a> can be used to set the field.
lmThreadId :: Functor f => (Maybe ThreadId -> f (Maybe ThreadId)) -> LogMessage -> f LogMessage

-- | A lens for the user defined textual message of a <a>LogMessage</a>
lmMessage :: Functor f => (Text -> f Text) -> LogMessage -> f LogMessage

-- | Put the source location of the given callstack in <a>lmSrcLoc</a>
setCallStack :: CallStack -> LogMessage -> LogMessage

-- | Prefix the <a>lmMessage</a>.
prefixLogMessagesWith :: Text -> LogMessage -> LogMessage

-- | An IO action that sets the current UTC time in <a>lmTimestamp</a>.
setLogMessageTimestamp :: LogMessage -> IO LogMessage

-- | An IO action appends the the <a>ThreadId</a> of the calling process
--   (see <a>myThreadId</a>) to <a>lmMessage</a>.
setLogMessageThreadId :: LogMessage -> IO LogMessage

-- | An IO action that sets the current hosts fully qualified hostname in
--   <a>lmHostname</a>.
setLogMessageHostname :: LogMessage -> IO LogMessage

-- | Construct a <a>LogMessage</a> with <a>errorSeverity</a>
errorMessage :: HasCallStack => Text -> LogMessage

-- | Construct a <a>LogMessage</a> with <a>informationalSeverity</a>
infoMessage :: HasCallStack => Text -> LogMessage

-- | Construct a <a>LogMessage</a> with <a>debugSeverity</a>
debugMessage :: HasCallStack => Text -> LogMessage

-- | Things that can become a <a>LogMessage</a>
class ToLogMessage a

-- | Convert the value to a <a>LogMessage</a>
toLogMessage :: ToLogMessage a => a -> LogMessage

-- | Construct a <a>LogMessage</a> with <a>errorSeverity</a>
errorMessageIO :: (HasCallStack, MonadIO m) => Text -> m LogMessage

-- | Construct a <a>LogMessage</a> with <a>informationalSeverity</a>
infoMessageIO :: (HasCallStack, MonadIO m) => Text -> m LogMessage

-- | Construct a <a>LogMessage</a> with <a>debugSeverity</a>
debugMessageIO :: (HasCallStack, MonadIO m) => Text -> m LogMessage

-- | The filter predicate for message that shall be logged.
--   
--   See <a>Control.Eff.Log#LogPredicate</a>
type LogPredicate = LogMessage -> Bool

-- | All messages.
--   
--   See <a>Control.Eff.Log.Message#PredefinedPredicates</a> for more
--   predicates.
allLogMessages :: LogPredicate

-- | No messages.
--   
--   See <a>Control.Eff.Log.Message#PredefinedPredicates</a> for more
--   predicates.
noLogMessages :: LogPredicate

-- | Match <a>LogMessage</a>s that have exactly the given severity. See
--   <a>lmSeverityIsAtLeast</a>.
--   
--   See <a>Control.Eff.Log.Message#PredefinedPredicates</a> for more
--   predicates.
lmSeverityIs :: Severity -> LogPredicate

-- | Match <a>LogMessage</a>s that have the given severity <b>or worse</b>.
--   See <a>lmSeverityIs</a>.
--   
--   See <a>Control.Eff.Log.Message#PredefinedPredicates</a> for more
--   predicates.
lmSeverityIsAtLeast :: Severity -> LogPredicate

-- | Match <a>LogMessage</a>s whose <a>lmMessage</a> starts with the given
--   string.
--   
--   See <a>Control.Eff.Log.Message#PredefinedPredicates</a> for more
--   predicates.
lmMessageStartsWith :: Text -> LogPredicate

-- | Apply a <a>LogPredicate</a> based on the <a>lmAppName</a> and delegate
--   to one of two <a>LogPredicate</a>s.
--   
--   One useful application for this is to allow info and debug message
--   from one application, e.g. the current application itself, while at
--   the same time allowing only warning and error messages from third
--   party libraries.
--   
--   See <a>Control.Eff.Log.Message#PredefinedPredicates</a> for more
--   predicates.
discriminateByAppName :: Text -> LogPredicate -> LogPredicate -> LogPredicate

-- | RFC-5424 defines how structured data can be included in a log message.
data StructuredDataElement
SdElement :: !Text -> ![SdParameter] -> StructuredDataElement
[_sdElementId] :: StructuredDataElement -> !Text
[_sdElementParameters] :: StructuredDataElement -> ![SdParameter]

-- | Component of an RFC-5424 <a>StructuredDataElement</a>
data SdParameter
MkSdParameter :: !Text -> !Text -> SdParameter

-- | A lens for the key or ID of a group of RFC 5424 key-value pairs.
sdElementId :: Functor f => (Text -> f Text) -> StructuredDataElement -> f StructuredDataElement

-- | A lens for <a>SdParameter</a>s
sdElementParameters :: Functor f => ([SdParameter] -> f [SdParameter]) -> StructuredDataElement -> f StructuredDataElement

-- | An rfc 5424 severity
data Severity

-- | Smart constructor for the RFC-5424 <b>emergency</b> <a>LogMessage</a>
--   <a>Severity</a>. This corresponds to the severity value <b>0</b>. See
--   <a>lmSeverity</a>.
emergencySeverity :: Severity

-- | Smart constructor for the RFC-5424 <b>alert</b> <a>LogMessage</a>
--   <a>Severity</a>. This corresponds to the severity value <b>1</b>. See
--   <a>lmSeverity</a>.
alertSeverity :: Severity

-- | Smart constructor for the RFC-5424 <b>critical</b> <a>LogMessage</a>
--   <a>Severity</a>. This corresponds to the severity value <b>2</b>. See
--   <a>lmSeverity</a>.
criticalSeverity :: Severity

-- | Smart constructor for the RFC-5424 <b>error</b> <a>LogMessage</a>
--   <a>Severity</a>. This corresponds to the severity value <b>3</b>. See
--   <a>lmSeverity</a>.
errorSeverity :: Severity

-- | Smart constructor for the RFC-5424 <b>warning</b> <a>LogMessage</a>
--   <a>Severity</a>. This corresponds to the severity value <b>4</b>. See
--   <a>lmSeverity</a>.
warningSeverity :: Severity

-- | Smart constructor for the RFC-5424 <b>notice</b> <a>LogMessage</a>
--   <a>Severity</a>. This corresponds to the severity value <b>5</b>. See
--   <a>lmSeverity</a>.
noticeSeverity :: Severity

-- | Smart constructor for the RFC-5424 <b>informational</b>
--   <a>LogMessage</a> <a>Severity</a>. This corresponds to the severity
--   value <b>6</b>. See <a>lmSeverity</a>.
informationalSeverity :: Severity

-- | Smart constructor for the RFC-5424 <b>debug</b> <a>LogMessage</a>
--   <a>Severity</a>. This corresponds to the severity value <b>7</b>. See
--   <a>lmSeverity</a>.
debugSeverity :: Severity

-- | An rfc 5424 facility
newtype Facility
Facility :: Int -> Facility
[fromFacility] :: Facility -> Int

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>kernelMessages</tt>. See <a>lmFacility</a>.
kernelMessages :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>userLevelMessages</tt>. See <a>lmFacility</a>.
userLevelMessages :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>mailSystem</tt>. See <a>lmFacility</a>.
mailSystem :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>systemDaemons</tt>. See <a>lmFacility</a>.
systemDaemons :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>securityAuthorizationMessages4</tt>. See <a>lmFacility</a>.
securityAuthorizationMessages4 :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>linePrinterSubsystem</tt>. See <a>lmFacility</a>.
linePrinterSubsystem :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>networkNewsSubsystem</tt>. See <a>lmFacility</a>.
networkNewsSubsystem :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>uucpSubsystem</tt>. See <a>lmFacility</a>.
uucpSubsystem :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>clockDaemon</tt>. See <a>lmFacility</a>.
clockDaemon :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>securityAuthorizationMessages10</tt>. See <a>lmFacility</a>.
securityAuthorizationMessages10 :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>ftpDaemon</tt>. See <a>lmFacility</a>.
ftpDaemon :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>ntpSubsystem</tt>. See <a>lmFacility</a>.
ntpSubsystem :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>logAuditFacility</tt>. See <a>lmFacility</a>.
logAuditFacility :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>logAlertFacility</tt>. See <a>lmFacility</a>.
logAlertFacility :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>clockDaemon2</tt>. See <a>lmFacility</a>.
clockDaemon2 :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>local0</tt>. See <a>lmFacility</a>.
local0 :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>local1</tt>. See <a>lmFacility</a>.
local1 :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>local2</tt>. See <a>lmFacility</a>.
local2 :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>local3</tt>. See <a>lmFacility</a>.
local3 :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>local4</tt>. See <a>lmFacility</a>.
local4 :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>local5</tt>. See <a>lmFacility</a>.
local5 :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>local6</tt>. See <a>lmFacility</a>.
local6 :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>local7</tt>. See <a>lmFacility</a>.
local7 :: Facility
instance Control.Eff.Log.Message.ToLogMessage Control.Eff.Log.Message.LogMessage
instance Control.Eff.Log.Message.ToLogMessage Data.Text.Internal.Text
instance Data.String.IsString Control.Eff.Log.Message.LogMessage
instance GHC.Generics.Generic Control.Eff.Log.Message.LogMessage
instance GHC.Classes.Eq Control.Eff.Log.Message.LogMessage
instance Control.DeepSeq.NFData Control.Eff.Log.Message.Facility
instance GHC.Generics.Generic Control.Eff.Log.Message.Facility
instance GHC.Show.Show Control.Eff.Log.Message.Facility
instance GHC.Classes.Ord Control.Eff.Log.Message.Facility
instance GHC.Classes.Eq Control.Eff.Log.Message.Facility
instance Control.DeepSeq.NFData Control.Eff.Log.Message.Severity
instance GHC.Generics.Generic Control.Eff.Log.Message.Severity
instance GHC.Classes.Ord Control.Eff.Log.Message.Severity
instance GHC.Classes.Eq Control.Eff.Log.Message.Severity
instance GHC.Show.Show Control.Eff.Log.Message.StructuredDataElement
instance GHC.Generics.Generic Control.Eff.Log.Message.StructuredDataElement
instance GHC.Classes.Ord Control.Eff.Log.Message.StructuredDataElement
instance GHC.Classes.Eq Control.Eff.Log.Message.StructuredDataElement
instance GHC.Show.Show Control.Eff.Log.Message.SdParameter
instance GHC.Generics.Generic Control.Eff.Log.Message.SdParameter
instance GHC.Classes.Ord Control.Eff.Log.Message.SdParameter
instance GHC.Classes.Eq Control.Eff.Log.Message.SdParameter
instance Data.Default.Class.Default Control.Eff.Log.Message.LogMessage
instance GHC.Show.Show Control.Eff.Log.Message.LogMessage
instance Control.DeepSeq.NFData Control.Eff.Log.Message.LogMessage
instance Data.Default.Class.Default Control.Eff.Log.Message.Facility
instance GHC.Show.Show Control.Eff.Log.Message.Severity
instance Data.Default.Class.Default Control.Eff.Log.Message.Severity
instance Control.DeepSeq.NFData Control.Eff.Log.Message.StructuredDataElement
instance Control.DeepSeq.NFData Control.Eff.Log.Message.SdParameter


-- | Rendering functions for <a>LogMessage</a>s.
module Control.Eff.Log.MessageRenderer

-- | <a>LogMessage</a> rendering function
type LogMessageRenderer a = LogMessage -> a

-- | Render the <a>LogMessage</a> to contain the severity, message,
--   message-id, pid.
--   
--   Omit hostname, PID and timestamp.
--   
--   Render the header using <tt>renderSyslogSeverity</tt>
--   
--   Useful for logging to <tt><i>dev</i>log</tt>
renderLogMessageSyslog :: LogMessageRenderer Text

-- | Render a <a>LogMessage</a> human readable, for console logging
renderLogMessageConsoleLog :: LogMessageRenderer Text

-- | Render a <a>LogMessage</a> according to the rules in the RFC-3164.
renderRFC3164 :: LogMessageRenderer Text

-- | Render a <a>LogMessage</a> according to the rules in the RFC-3164 but
--   use RFC5424 time stamps.
renderRFC3164WithRFC5424Timestamps :: LogMessageRenderer Text

-- | Render a <a>LogMessage</a> according to the rules in the RFC-3164 but
--   use the custom <a>LogMessageTimeRenderer</a>.
renderRFC3164WithTimestamp :: LogMessageTimeRenderer -> LogMessageRenderer Text

-- | Render a <a>LogMessage</a> according to the rules in the RFC-5424.
--   
--   Equivalent to <tt><a>renderRFC5424Header</a> &lt;&gt; const " "
--   &lt;&gt; <a>renderLogMessageBody</a></tt>.
renderRFC5424 :: LogMessageRenderer Text

-- | Render the header and strucuted data of a <a>LogMessage</a> according
--   to the rules in the RFC-5424, but do not render the <a>lmMessage</a>.
renderRFC5424Header :: LogMessageRenderer Text

-- | Render a <a>LogMessage</a> according to the rules in the RFC-5424,
--   like <a>renderRFC5424</a> but suppress the source location
--   information.
--   
--   Equivalent to <tt><a>renderRFC5424Header</a> &lt;&gt; const " "
--   &lt;&gt; <a>renderLogMessageBodyNoLocation</a></tt>.
renderRFC5424NoLocation :: LogMessageRenderer Text

-- | Render the severity and facility as described in RFC-3164
--   
--   Render e.g. as <tt>&lt;192&gt;</tt>.
--   
--   Useful as header for syslog compatible log output.
renderSyslogSeverityAndFacility :: LogMessageRenderer Text

-- | Render the source location as: <tt>at filepath:linenumber</tt>.
renderLogMessageSrcLoc :: LogMessageRenderer (Maybe Text)

-- | Render a field of a <a>LogMessage</a> using the corresponsing lens.
renderMaybeLogMessageLens :: Text -> Getter LogMessage (Maybe Text) -> LogMessageRenderer Text

-- | Print the thread id, the message and the source file location,
--   seperated by simple white space.
renderLogMessageBodyNoLocation :: LogMessageRenderer Text

-- | Print the thread id, the message and the source file location,
--   seperated by simple white space.
renderLogMessageBody :: LogMessageRenderer Text

-- | Print the <i>body</i> of a <a>LogMessage</a> with fix size fields (60)
--   for the message itself and 30 characters for the location
renderLogMessageBodyFixWidth :: LogMessageRenderer Text

-- | A rendering function for the <a>lmTimestamp</a> field.
data LogMessageTimeRenderer

-- | Make a <a>LogMessageTimeRenderer</a> using <a>formatTime</a> in the
--   <tt>defaultLocale</tt>.
mkLogMessageTimeRenderer :: String -> LogMessageTimeRenderer

-- | Don't render the time stamp
suppressTimestamp :: LogMessageTimeRenderer

-- | Render the time stamp using <tt>"%h %d %H:%M:%S"</tt>
rfc3164Timestamp :: LogMessageTimeRenderer

-- | Render the time stamp to <tt><a>iso8601DateFormat</a> (Just
--   "%H:%M:%S%6QZ")</tt>
rfc5424Timestamp :: LogMessageTimeRenderer

-- | Render the time stamp like <a>rfc5424Timestamp</a> does, but omit the
--   terminal <tt>Z</tt> character.
rfc5424NoZTimestamp :: LogMessageTimeRenderer


-- | The <a>LogWriter</a> type encapsulates an effectful function to write
--   <a>LogMessage</a>s.
--   
--   Used in conjunction with the <a>HandleLogWriter</a> class, it can be
--   used to write messages from within an effectful computation.
module Control.Eff.Log.Writer

-- | A function that takes a log message and returns an effect that
--   <i>logs</i> the message.
newtype LogWriter writerM
MkLogWriter :: (LogMessage -> writerM ()) -> LogWriter writerM
[runLogWriter] :: LogWriter writerM -> LogMessage -> writerM ()

-- | A Reader specialized for <a>LogWriter</a>s
--   
--   The existing <tt>Reader</tt> couldn't be used together with
--   <a>SetMember</a>, so this lazy reader was written, specialized to
--   reading <a>LogWriter</a>.
data LogWriterReader h v

-- | Modify the current <a>LogWriter</a>.
localLogWriterReader :: forall h e a. SetMember LogWriterReader (LogWriterReader h) e => (LogWriter h -> LogWriter h) -> Eff e a -> Eff e a

-- | Get the current <a>LogWriter</a>.
askLogWriter :: SetMember LogWriterReader (LogWriterReader h) e => Eff e (LogWriter h)

-- | Provide the <a>LogWriter</a>
--   
--   Exposed for custom extensions, if in doubt use <tt>withLogging</tt>.
runLogWriterReader :: LogWriter h -> Eff (LogWriterReader h : e) a -> Eff e a

-- | The instances of this class are the monads that define (side-)
--   effect(s) of writting logs.
class HandleLogWriter (writerEff :: Type -> Type) where {
    
    -- | A list of effects that are required for writing the log messages. For
    --   example 'Lift IO' or '[]' for pure log writers.
    type family LogWriterEffects writerEff :: [Type -> Type];
}

-- | Run the side effect of a <a>LogWriter</a> in a compatible <a>Eff</a>.
handleLogWriterEffect :: (HandleLogWriter writerEff, LogWriterEffects writerEff <:: e) => writerEff () -> Eff e ()

-- | Write a message using the <a>LogWriter</a> found in the environment.
--   
--   The semantics of this function are a combination of
--   <a>runLogWriter</a> and <a>handleLogWriterEffect</a>, with the
--   <a>LogWriter</a> read from a <a>LogWriterReader</a>.
liftWriteLogMessage :: (HandleLogWriter writerEff, SetMember LogWriterReader (LogWriterReader writerEff) e, LogWriterEffects writerEff <:: e) => LogMessage -> Eff e ()

-- | This <a>LogWriter</a> will discard all messages.
--   
--   NOTE: This is just an alias for <a>def</a>
noOpLogWriter :: Applicative m => LogWriter m

-- | A phantom type for the <a>HandleLogWriter</a> class for <i>pure</i>
--   <a>LogWriter</a>s
newtype PureLogWriter a
MkPureLogWriter :: Identity a -> PureLogWriter a
[runPureLogWriter] :: PureLogWriter a -> Identity a

-- | A <a>LogWriter</a> that applies a predicate to the <a>LogMessage</a>
--   and delegates to to the given writer of the predicate is satisfied.
filteringLogWriter :: Monad e => LogPredicate -> LogWriter e -> LogWriter e

-- | A <a>LogWriter</a> that applies a function to the <a>LogMessage</a>
--   and delegates the result to to the given writer.
mappingLogWriter :: (LogMessage -> LogMessage) -> LogWriter e -> LogWriter e

-- | Like <a>mappingLogWriter</a> allow the function that changes the
--   <a>LogMessage</a> to have effects.
mappingLogWriterM :: Monad e => (LogMessage -> e LogMessage) -> LogWriter e -> LogWriter e
instance GHC.Base.Monad Control.Eff.Log.Writer.PureLogWriter
instance GHC.Base.Functor Control.Eff.Log.Writer.PureLogWriter
instance GHC.Base.Applicative Control.Eff.Log.Writer.PureLogWriter
instance Control.Eff.Log.Writer.HandleLogWriter Control.Eff.Log.Writer.PureLogWriter
instance Control.Eff.Log.Writer.HandleLogWriter GHC.Types.IO
instance Control.Eff.Internal.Handle (Control.Eff.Log.Writer.LogWriterReader h) e a (Control.Eff.Log.Writer.LogWriter h -> k)
instance (Control.Monad.Base.MonadBase m m, Control.Eff.Internal.LiftedBase m r) => Control.Monad.Trans.Control.MonadBaseControl m (Control.Eff.Internal.Eff (Control.Eff.Log.Writer.LogWriterReader h : r))
instance (Control.Eff.Internal.LiftedBase m e, Control.Monad.Catch.MonadThrow (Control.Eff.Internal.Eff e)) => Control.Monad.Catch.MonadThrow (Control.Eff.Internal.Eff (Control.Eff.Log.Writer.LogWriterReader h : e))
instance (GHC.Base.Applicative m, Control.Eff.Internal.LiftedBase m e, Control.Monad.Catch.MonadCatch (Control.Eff.Internal.Eff e)) => Control.Monad.Catch.MonadCatch (Control.Eff.Internal.Eff (Control.Eff.Log.Writer.LogWriterReader h : e))
instance (GHC.Base.Applicative m, Control.Eff.Internal.LiftedBase m e, Control.Monad.Catch.MonadMask (Control.Eff.Internal.Eff e)) => Control.Monad.Catch.MonadMask (Control.Eff.Internal.Eff (Control.Eff.Log.Writer.LogWriterReader h : e))
instance GHC.Base.Applicative w => Data.Default.Class.Default (Control.Eff.Log.Writer.LogWriter w)


-- | A memory efficient, streaming, logging effect with support for
--   efficiently not logging when no logs are required.
--   
--   Good support for logging to a file or to the network, as well as
--   asynchronous logging in another thread.
module Control.Eff.Log.Handler

-- | Log a message.
--   
--   All logging goes through this function.
--   
--   This function is the only place where the <a>LogPredicate</a> is
--   applied.
--   
--   Also, <a>LogMessage</a>s are evaluated using <a>deepseq</a>,
--   <b>after</b> they pass the <a>LogPredicate</a>.
logMsg :: forall e. (HasCallStack, Member Logs e) => LogMessage -> Eff e ()

-- | Log a <a>Text</a> as <a>LogMessage</a> with a given <a>Severity</a>.
logWithSeverity :: forall e. (HasCallStack, Member Logs e) => Severity -> Text -> Eff e ()

-- | Log a <a>Text</a> as <a>LogMessage</a> with a given <a>Severity</a>.
logWithSeverity' :: forall e. (HasCallStack, Member Logs e) => Severity -> String -> Eff e ()

-- | Log a <a>String</a> as <a>emergencySeverity</a>.
logEmergency :: forall e. (HasCallStack, Member Logs e) => Text -> Eff e ()

-- | Log a <a>String</a> as <a>emergencySeverity</a>.
logEmergency' :: forall e. (HasCallStack, Member Logs e) => String -> Eff e ()

-- | Log a message with <a>alertSeverity</a>.
logAlert :: forall e. (HasCallStack, Member Logs e) => Text -> Eff e ()

-- | Log a message with <a>alertSeverity</a>.
logAlert' :: forall e. (HasCallStack, Member Logs e) => String -> Eff e ()

-- | Log a <a>criticalSeverity</a> message.
logCritical :: forall e. (HasCallStack, Member Logs e) => Text -> Eff e ()

-- | Log a <a>criticalSeverity</a> message.
logCritical' :: forall e. (HasCallStack, Member Logs e) => String -> Eff e ()

-- | Log a <a>errorSeverity</a> message.
logError :: forall e. (HasCallStack, Member Logs e) => Text -> Eff e ()

-- | Log a <a>errorSeverity</a> message.
logError' :: forall e. (HasCallStack, Member Logs e) => String -> Eff e ()

-- | Log a <a>warningSeverity</a> message.
logWarning :: forall e. (HasCallStack, Member Logs e) => Text -> Eff e ()

-- | Log a <a>warningSeverity</a> message.
logWarning' :: forall e. (HasCallStack, Member Logs e) => String -> Eff e ()

-- | Log a <a>noticeSeverity</a> message.
logNotice :: forall e. (HasCallStack, Member Logs e) => Text -> Eff e ()

-- | Log a <a>noticeSeverity</a> message.
logNotice' :: forall e. (HasCallStack, Member Logs e) => String -> Eff e ()

-- | Log a <a>informationalSeverity</a> message.
logInfo :: forall e. (HasCallStack, Member Logs e) => Text -> Eff e ()

-- | Log a <a>informationalSeverity</a> message.
logInfo' :: forall e. (HasCallStack, Member Logs e) => String -> Eff e ()

-- | Log a <a>debugSeverity</a> message.
logDebug :: forall e. (HasCallStack, Member Logs e) => Text -> Eff e ()

-- | Log a <a>debugSeverity</a> message.
logDebug' :: forall e. (HasCallStack, Member Logs e) => String -> Eff e ()

-- | Include <a>LogMessage</a>s that match a <a>LogPredicate</a>.
--   
--   <tt>excludeLogMessages p</tt> allows log message to be logged if <tt>p
--   m</tt>
--   
--   Although it is enough if the previous predicate holds. See
--   <a>excludeLogMessages</a> and <a>modifyLogPredicate</a>.
--   
--   See <a>Control.Eff.Log#LogPredicate</a>
includeLogMessages :: forall e a. Member Logs e => LogPredicate -> Eff e a -> Eff e a

-- | Exclude <a>LogMessage</a>s that match a <a>LogPredicate</a>.
--   
--   <tt>excludeLogMessages p</tt> discards logs if <tt>p m</tt>
--   
--   Also the previous predicate must also hold for a message to be logged.
--   See <a>excludeLogMessages</a> and <a>modifyLogPredicate</a>.
--   
--   See <a>Control.Eff.Log#LogPredicate</a>
excludeLogMessages :: forall e a. Member Logs e => LogPredicate -> Eff e a -> Eff e a

-- | Keep only those messages, for which a predicate holds.
--   
--   E.g. to keep only messages which begin with <tt><a>OMG</a></tt>:
--   
--   <pre>
--   exampleLogPredicate :: IO Int
--   exampleLogPredicate =
--       runLift
--     $ withLogging consoleLogWriter
--     $ do logMsg "test"
--          setLogPredicate (\ msg -&gt; case view lmMessage msg of
--                                     'O':'M':'G':_ -&gt; True
--                                     _             -&gt; False)
--                            (do logMsg "this message will not be logged"
--                                logMsg "OMG logged"
--                                return 42)
--   </pre>
--   
--   In order to also delegate to the previous predicate, use
--   <a>modifyLogPredicate</a>
--   
--   See <a>Control.Eff.Log#LogPredicate</a>
setLogPredicate :: forall r b. (Member Logs r, HasCallStack) => LogPredicate -> Eff r b -> Eff r b

-- | Change the <a>LogPredicate</a>.
--   
--   Other than <a>setLogPredicate</a> this function allows to include the
--   previous predicate, too.
--   
--   For to discard all messages currently no satisfying the predicate and
--   also all messages that are to long:
--   
--   <pre>
--   modifyLogPredicate (previousPredicate msg -&gt; previousPredicate msg &amp;&amp; length (lmMessage msg) &lt; 29 )
--                      (do logMsg "this message will not be logged"
--                          logMsg "this message might be logged")
--   </pre>
--   
--   See <a>Control.Eff.Log#LogPredicate</a>
modifyLogPredicate :: forall e b. (Member Logs e, HasCallStack) => (LogPredicate -> LogPredicate) -> Eff e b -> Eff e b

-- | Get the current <a>Logs</a> filter/transformer function.
--   
--   See <a>Control.Eff.Log#LogPredicate</a>
askLogPredicate :: forall e. Member Logs e => Eff e LogPredicate

-- | Replace the current <a>LogWriter</a>. To add an additional log message
--   consumer use <a>addLogWriter</a>
setLogWriter :: forall h e a. LogsTo h e => LogWriter h -> Eff e a -> Eff e a

-- | Combine the effects of a given <a>LogWriter</a> and the existing one.
--   
--   <pre>
--   import Data.Text    as T
--   import Data.Text.IO as T
--   
--   exampleAddLogWriter :: IO ()
--   exampleAddLogWriter = go &gt;&gt;= T.putStrLn
--    where go = fmap (unlines . map renderLogMessageConsoleLog . snd)
--                 $  runLift
--                 $  runCaptureLogWriter
--                 $  withLogging captureLogWriter
--                 $  addLogWriter (mappingLogWriter (lmMessage %~ ("CAPTURED "++)) captureLogWriter)
--                 $  addLogWriter (filteringLogWriter severeMessages (mappingLogWriter (lmMessage %~ ("TRACED "++)) debugTraceLogWriter))
--                 $  do
--                       logEmergency "test emergencySeverity 1"
--                       logCritical "test criticalSeverity 2"
--                       logAlert "test alertSeverity 3"
--                       logError "test errorSeverity 4"
--                       logWarning "test warningSeverity 5"
--                       logInfo "test informationalSeverity 6"
--                       logDebug "test debugSeverity 7"
--          severeMessages = view (lmSeverity . to (&lt;= errorSeverity))
--   </pre>
addLogWriter :: forall h e a. (HasCallStack, LogsTo h e, Monad h) => LogWriter h -> Eff e a -> Eff e a

-- | Change the current <a>LogWriter</a>.
modifyLogWriter :: forall h e a. LogsTo h e => (LogWriter h -> LogWriter h) -> Eff e a -> Eff e a

-- | Modify the the <a>LogMessage</a>s written in the given sub-expression.
--   
--   Note: This is equivalent to <tt><a>modifyLogWriter</a> .
--   <a>mappingLogWriter</a></tt>
censorLogs :: LogsTo h e => (LogMessage -> LogMessage) -> Eff e a -> Eff e a

-- | Modify the the <a>LogMessage</a>s written in the given sub-expression,
--   as in <a>censorLogs</a> but with a effectful function.
--   
--   Note: This is equivalent to <tt><a>modifyLogWriter</a> .
--   <a>mappingLogWriterM</a></tt>
censorLogsM :: (LogsTo h e, Monad h) => (LogMessage -> h LogMessage) -> Eff e a -> Eff e a

-- | This effect sends <a>LogMessage</a>s and is a reader for a
--   <a>LogPredicate</a>.
--   
--   Logs are sent via <a>logMsg</a>; for more information about log
--   predicates, see <a>Control.Eff.Log#LogPredicate</a>
--   
--   This effect is handled via <a>withLogging</a>.
data Logs v

-- | A constraint alias for effects that requires a <a>LogWriterReader</a>,
--   as well as that the contained <a>LogWriterReader</a> has a
--   <a>HandleLogWriter</a> instance.
--   
--   The requirements of this constraint are provided by:
--   
--   <ul>
--   <li><tt>withIoLogging</tt></li>
--   <li><a>withLogging</a></li>
--   <li><a>withSomeLogging</a></li>
--   </ul>
type LogsTo h e = (Member Logs e, HandleLogWriter h, LogWriterEffects h <:: e, SetMember LogWriterReader (LogWriterReader h) e)

-- | Handle the <a>Logs</a> and <a>LogWriterReader</a> effects.
--   
--   It installs the given <a>LogWriter</a>, which determines the
--   underlying <a>LogWriter</a> type parameter.
--   
--   Example:
--   
--   <pre>
--   exampleWithLogging :: IO ()
--   exampleWithLogging =
--       runLift
--     $ withLogging consoleLogWriter
--     $ logDebug "Oh, hi there"
--   </pre>
withLogging :: forall h e a. (Applicative h, LogsTo h (Logs : (LogWriterReader h : e))) => LogWriter h -> Eff (Logs : (LogWriterReader h : e)) a -> Eff e a

-- | Handles the <a>Logs</a> and <a>LogWriterReader</a> effects.
--   
--   By default it uses the <a>noOpLogWriter</a>, but using
--   <a>setLogWriter</a> the <a>LogWriter</a> can be replaced.
--   
--   This is like <a>withLogging</a> applied to <a>noOpLogWriter</a>
--   
--   Example:
--   
--   <pre>
--   exampleWithSomeLogging :: ()
--   exampleWithSomeLogging =
--       run
--     $ withSomeLogging @PureLogWriter
--     $ logDebug "Oh, hi there"
--   </pre>
withSomeLogging :: forall h e a. (Applicative h, LogsTo h (Logs : (LogWriterReader h : e))) => Eff (Logs : (LogWriterReader h : e)) a -> Eff e a

-- | Raw handling of the <a>Logs</a> effect. Exposed for custom extensions,
--   if in doubt use <a>withLogging</a>.
runLogs :: forall h e b. LogsTo h (Logs : e) => LogPredicate -> Eff (Logs : e) b -> Eff e b

-- | Consume log messages.
--   
--   Exposed for custom extensions, if in doubt use <a>withLogging</a>.
--   
--   Respond to all <a>LogMessage</a>s logged from the given action, up to
--   any <a>MonadBaseControl</a> liftings.
--   
--   Note that all logging is done through <a>logMsg</a> and that means
--   only messages passing the <a>LogPredicate</a> are received.
--   
--   The <a>LogMessage</a>s are <b>consumed</b> once they are passed to the
--   given callback function, previous <a>respondToLogMessage</a>
--   invocations further up in the call stack will not get the messages
--   anymore.
--   
--   Use <a>interceptLogMessages</a> if the messages shall be passed any
--   previous handler.
--   
--   NOTE: The effects of this function are <b>lost</b> when using
--   <a>MonadBaseControl</a>, <a>MonadMask</a>, <a>MonadCatch</a> and
--   <a>MonadThrow</a>.
--   
--   In contrast the functions based on modifying the <a>LogWriter</a>,
--   such as <a>addLogWriter</a> or <a>censorLogs</a>, are save to use in
--   combination with the aforementioned liftings.
respondToLogMessage :: forall r b. Member Logs r => (LogMessage -> Eff r ()) -> Eff r b -> Eff r b

-- | Change the <a>LogMessage</a>s using an effectful function.
--   
--   Exposed for custom extensions, if in doubt use <a>withLogging</a>.
--   
--   This differs from <a>respondToLogMessage</a> in that the intercepted
--   messages will be written either way, albeit in altered form.
--   
--   NOTE: The effects of this function are <b>lost</b> when using
--   <a>MonadBaseControl</a>, <a>MonadMask</a>, <a>MonadCatch</a> and
--   <a>MonadThrow</a>.
--   
--   In contrast the functions based on modifying the <a>LogWriter</a>,
--   such as <a>addLogWriter</a> or <a>censorLogs</a>, are save to use in
--   combination with the aforementioned liftings.
interceptLogMessages :: forall r b. Member Logs r => (LogMessage -> Eff r LogMessage) -> Eff r b -> Eff r b
instance (Control.Monad.Base.MonadBase m m, Control.Eff.Internal.LiftedBase m e, Control.Eff.Log.Handler.LogsTo m (Control.Eff.Log.Handler.Logs : e)) => Control.Monad.Trans.Control.MonadBaseControl m (Control.Eff.Internal.Eff (Control.Eff.Log.Handler.Logs : e))
instance (GHC.Base.Applicative m, Control.Eff.Internal.LiftedBase m e, Control.Monad.Catch.MonadCatch (Control.Eff.Internal.Eff e), Control.Eff.Log.Handler.LogsTo m (Control.Eff.Log.Handler.Logs : e)) => Control.Monad.Catch.MonadCatch (Control.Eff.Internal.Eff (Control.Eff.Log.Handler.Logs : e))
instance (GHC.Base.Applicative m, Control.Eff.Internal.LiftedBase m e, Control.Monad.Catch.MonadMask (Control.Eff.Internal.Eff e), Control.Eff.Log.Handler.LogsTo m (Control.Eff.Log.Handler.Logs : e)) => Control.Monad.Catch.MonadMask (Control.Eff.Internal.Eff (Control.Eff.Log.Handler.Logs : e))
instance Control.Eff.Internal.Handle Control.Eff.Log.Handler.Logs e a (Control.Eff.Log.Message.LogPredicate -> k)
instance (Control.Eff.Internal.LiftedBase m e, Control.Monad.Catch.MonadThrow (Control.Eff.Internal.Eff e)) => Control.Monad.Catch.MonadThrow (Control.Eff.Internal.Eff (Control.Eff.Log.Handler.Logs : e))


-- | The message passing effect.
--   
--   This module describes an abstract message passing effect, and a
--   process effect, mimicking Erlang's process and message semantics.
--   
--   Two <b>scheduler</b> implementations for the <a>Process</a> effect are
--   provided:
--   
--   <ul>
--   <li>A scheduler using <tt>forkIO</tt>, i.e. relying on the multi
--   threaded GHC runtime:
--   <a>Control.Eff.Concurrent.Process.ForkIOScheduler</a></li>
--   <li>And a <i>pure</i>(rer) coroutine based scheduler in:
--   <a>Control.Eff.Concurrent.Process.SingleThreadedScheduler</a></li>
--   </ul>
module Control.Eff.Concurrent.Process

-- | The process effect is the basis for message passing concurrency. This
--   effect describes an interface for concurrent, communicating isolated
--   processes identified uniquely by a process-id.
--   
--   Processes can raise exceptions that can be caught, exit gracefully or
--   with an error, or be killed by other processes, with the option of
--   ignoring the shutdown request.
--   
--   Process Scheduling is implemented in different modules. All scheduler
--   implementations should follow some basic rules:
--   
--   <ul>
--   <li>fair scheduling</li>
--   <li>sending a message does not block</li>
--   <li>receiving a message does block</li>
--   <li>spawning a child blocks only a very moment</li>
--   <li>a newly spawned process shall be scheduled before the parent
--   process after</li>
--   <li>the spawnRaw</li>
--   <li>when the first process exists, all process should be killed
--   immediately</li>
--   </ul>
data Process (r :: [Type -> Type]) b

-- | Remove all messages from the process' message queue
[FlushMessages] :: Process r (ResumeProcess [StrictDynamic])

-- | In cooperative schedulers, this will give processing time to the
--   scheduler. Every other operation implicitly serves the same purpose.
[YieldProcess] :: Process r (ResumeProcess ())

-- | Return the current <a>ProcessId</a>
[SelfPid] :: Process r (ResumeProcess ProcessId)

-- | Start a new process, the new process will execute an effect, the
--   function will return immediately with a <a>ProcessId</a>.
[Spawn] :: Eff (Process r : r) () -> Process r (ResumeProcess ProcessId)

-- | Start a new process, and <a>Link</a> to it .
[SpawnLink] :: Eff (Process r : r) () -> Process r (ResumeProcess ProcessId)

-- | Get the process state (or <a>Nothing</a> if the process is dead)
[GetProcessState] :: ProcessId -> Process r (ResumeProcess (Maybe ProcessState))

-- | Shutdown the process; irregardless of the exit reason, this function
--   never returns,
[Shutdown] :: Interrupt  'NoRecovery -> Process r a

-- | Shutdown another process immediately, the other process has no way of
--   handling this!
[SendShutdown] :: ProcessId -> Interrupt  'NoRecovery -> Process r (ResumeProcess ())

-- | Request that another a process interrupts. The targeted process is
--   interrupted and gets an <a>Interrupted</a>, the target process may
--   decide to ignore the interrupt and continue as if nothing happened.
[SendInterrupt] :: ProcessId -> Interrupt  'Recoverable -> Process r (ResumeProcess ())

-- | Send a message to a process addressed by the <a>ProcessId</a>. Sending
--   a message should <b>always succeed</b> and return <b>immediately</b>,
--   even if the destination process does not exist, or does not accept
--   messages of the given type.
[SendMessage] :: ProcessId -> StrictDynamic -> Process r (ResumeProcess ())

-- | Receive a message that matches a criteria. This should block until an
--   a message was received. The message is returned as a
--   <a>ResumeProcess</a> value. The function should also return if an
--   exception was caught or a shutdown was requested.
[ReceiveSelectedMessage] :: forall r a. MessageSelector a -> Process r (ResumeProcess a)

-- | Generate a unique <a>Int</a> for the current process.
[MakeReference] :: Process r (ResumeProcess Int)

-- | Monitor another process. When the monitored process exits a
--   <a>ProcessDown</a> is sent to the calling process. The return value is
--   a unique identifier for that monitor. There can be multiple monitors
--   on the same process, and a message for each will be sent. If the
--   process is already dead, the <a>ProcessDown</a> message will be sent
--   immediately, without exit reason
[Monitor] :: ProcessId -> Process r (ResumeProcess MonitorReference)

-- | Remove a monitor.
[Demonitor] :: MonitorReference -> Process r (ResumeProcess ())

-- | Connect the calling process to another process, such that if one of
--   the processes crashes (i.e. <a>isCrash</a> returns <a>True</a>), the
--   other is shutdown with the <a>Interrupt</a>
--   <a>LinkedProcessCrashed</a>.
[Link] :: ProcessId -> Process r (ResumeProcess ())

-- | Unlink the calling process from the other process.
[Unlink] :: ProcessId -> Process r (ResumeProcess ())

-- | Data flows between <a>Process</a>es via these messages.
--   
--   This is just a newtype wrapper around <a>Dynamic</a>. The reason this
--   type exists is to force construction through the code in this module,
--   which always evaluates a message to <i>normal form</i> <b>before</b>
--   sending it to another process.
data StrictDynamic

-- | Deeply evaluate the given value and wrap it into a
--   <a>StrictDynamic</a>.
toStrictDynamic :: (Typeable a, NFData a) => a -> StrictDynamic

-- | Convert a <a>StrictDynamic</a> back to a value.
fromStrictDynamic :: Typeable a => StrictDynamic -> Maybe a

-- | Convert a <a>StrictDynamic</a> back to an unwrapped <a>Dynamic</a>.
unwrapStrictDynamic :: StrictDynamic -> Dynamic

-- | Each process is identified by a single process id, that stays constant
--   throughout the life cycle of a process. Also, message sending relies
--   on these values to address messages to processes.
newtype ProcessId
ProcessId :: Int -> ProcessId
[_fromProcessId] :: ProcessId -> Int
fromProcessId :: Iso' ProcessId Int

-- | <i>Cons</i> <a>Process</a> onto a list of effects.
type ConsProcess r = Process r : r

-- | Every <a>Process</a> action returns it's actual result wrapped in this
--   type. It will allow to signal errors as well as pass on normal results
--   such as incoming messages.
data ResumeProcess v

-- | The current operation of the process was interrupted with a
--   <a>Interrupt</a>. If <a>isRecoverable</a> holds for the given reason,
--   the process may choose to continue.
[Interrupted] :: Interrupt  'Recoverable -> ResumeProcess v

-- | The process may resume to do work, using the given result.
[ResumeWith] :: a -> ResumeProcess a

-- | The state that a <a>Process</a> is currently in.
data ProcessState

-- | The process has just been started but not scheduled yet.
ProcessBooting :: ProcessState

-- | The process yielded it's time slice
ProcessIdle :: ProcessState

-- | The process is busy with non-blocking
ProcessBusy :: ProcessState

-- | The process is busy with sending a message
ProcessBusySending :: ProcessState

-- | The process is busy with killing
ProcessBusySendingShutdown :: ProcessState

-- | The process is busy with killing
ProcessBusySendingInterrupt :: ProcessState

-- | The process blocked by a <a>receiveAnyMessage</a>
ProcessBusyReceiving :: ProcessState

-- | The process blocked by a <a>linkProcess</a>
ProcessBusyLinking :: ProcessState

-- | The process blocked by a <a>unlinkProcess</a>
ProcessBusyUnlinking :: ProcessState

-- | The process blocked by a <a>monitor</a>
ProcessBusyMonitoring :: ProcessState

-- | The process blocked by a <a>demonitor</a>
ProcessBusyDemonitoring :: ProcessState

-- | The process was interrupted
ProcessInterrupted :: ProcessState

-- | The process was shutdown or crashed
ProcessShuttingDown :: ProcessState

-- | Use <a>executeAndResumeOrExit</a> to execute <a>YieldProcess</a>.
--   Refer to <a>YieldProcess</a> for more information.
yieldProcess :: forall r q. (SetMember Process (Process q) r, HasCallStack, Member Interrupts r) => Eff r ()

-- | Send a message to a process addressed by the <a>ProcessId</a>. See
--   <a>SendMessage</a>.
--   
--   The message will be reduced to normal form (<a>rnf</a>) by/in the
--   caller process.
sendMessage :: forall r q o. (SetMember Process (Process q) r, HasCallStack, Member Interrupts r, Typeable o, NFData o) => ProcessId -> o -> Eff r ()

-- | Send a <a>Dynamic</a> value to a process addressed by the
--   <a>ProcessId</a>. See <a>SendMessage</a>.
sendAnyMessage :: forall r q. (SetMember Process (Process q) r, HasCallStack, Member Interrupts r) => ProcessId -> StrictDynamic -> Eff r ()

-- | Exit a process addressed by the <a>ProcessId</a>. The process will
--   exit, it might do some cleanup, but is ultimately unrecoverable. See
--   <a>SendShutdown</a>.
sendShutdown :: forall r q. (SetMember Process (Process q) r, HasCallStack, Member Interrupts r) => ProcessId -> Interrupt  'NoRecovery -> Eff r ()

-- | Interrupts a process addressed by the <a>ProcessId</a>. The process
--   might exit, or it may continue. | Like <a>sendInterrupt</a>, but also
--   return <tt>True</tt> iff the process to exit exists.
sendInterrupt :: forall r q. (SetMember Process (Process q) r, HasCallStack, Member Interrupts r) => ProcessId -> Interrupt  'Recoverable -> Eff r ()

-- | Generate a unique <a>Int</a> for the current process.
makeReference :: (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => Eff r Int

-- | Receive and cast the message to some <a>Typeable</a> instance. See
--   <a>ReceiveSelectedMessage</a> for more documentation. This will wait
--   for a message of the return type using <a>receiveSelectedMessage</a>
receiveMessage :: forall a r q. (HasCallStack, Typeable a, NFData a, Show a, SetMember Process (Process q) r, Member Interrupts r) => Eff r a

-- | Block until a message was received, that is not <a>Nothing</a> after
--   applying a callback to it. See <a>ReceiveSelectedMessage</a> for more
--   documentation.
receiveSelectedMessage :: forall r q a. (HasCallStack, Show a, SetMember Process (Process q) r, Member Interrupts r) => MessageSelector a -> Eff r a

-- | Remove and return all messages currently enqueued in the process
--   message queue.
flushMessages :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => Eff r [StrictDynamic]

-- | Block until a message was received. See <a>ReceiveSelectedMessage</a>
--   for more documentation.
receiveAnyMessage :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => Eff r StrictDynamic

-- | Like <a>receiveSelectedLoop</a> but refined to casting to a specific
--   <a>Typeable</a> using <a>selectMessage</a>.
receiveLoop :: forall r q a endOfLoopResult. (SetMember Process (Process q) r, HasCallStack, NFData a, Typeable a) => (Either (Interrupt  'Recoverable) a -> Eff r (Maybe endOfLoopResult)) -> Eff r endOfLoopResult

-- | Enter a loop to receive messages and pass them to a callback, until
--   the function returns <a>Just</a> a result. Only the messages of the
--   given type will be received. If the process is interrupted by an
--   exception of by a <a>SendShutdown</a> from another process, with an
--   exit reason that satisfies <a>isRecoverable</a>, then the callback
--   will be invoked with <tt><a>Left</a> <a>Interrupt</a></tt>, otherwise
--   the process will be exited with the same reason using
--   <a>exitBecause</a>. See also <a>ReceiveSelectedMessage</a> for more
--   documentation.
receiveSelectedLoop :: forall r q a endOfLoopResult. (SetMember Process (Process q) r, HasCallStack) => MessageSelector a -> (Either (Interrupt  'Recoverable) a -> Eff r (Maybe endOfLoopResult)) -> Eff r endOfLoopResult

-- | Like <a>receiveSelectedLoop</a> but <i>not selective</i>. See also
--   <a>selectAnyMessage</a>, <a>receiveSelectedLoop</a>.
receiveAnyLoop :: forall r q endOfLoopResult. (SetMember Process (Process q) r, HasCallStack) => (Either (Interrupt  'Recoverable) StrictDynamic -> Eff r (Maybe endOfLoopResult)) -> Eff r endOfLoopResult

-- | A function that decided if the next message will be received by
--   <a>ReceiveSelectedMessage</a>. It conveniently is an instance of
--   <a>Alternative</a> so the message selector can be combined: &gt; &gt;
--   selectInt :: MessageSelector Int &gt; selectInt = selectMessage &gt;
--   &gt; selectString :: MessageSelector String &gt; selectString =
--   selectMessage &gt; &gt; selectIntOrString :: MessageSelector (Either
--   Int String) &gt; selectIntOrString = &gt; Left <a>$</a>
--   selectTimeout<a>|</a> Right <a>$</a> selectString
data MessageSelector a

-- | Create a message selector for a value that can be obtained by
--   <a>fromStrictDynamic</a>.
selectMessage :: Typeable t => MessageSelector t

-- | Create a message selector from a predicate.
filterMessage :: Typeable a => (a -> Bool) -> MessageSelector a

-- | Select a message of type <tt>a</tt> and apply the given function to
--   it. If the function returns <a>Just</a> The
--   <a>ReceiveSelectedMessage</a> function will return the result (sans
--   <tt>Maybe</tt>).
selectMessageWith :: Typeable a => (a -> Maybe b) -> MessageSelector b

-- | Create a message selector.
selectDynamicMessage :: (StrictDynamic -> Maybe a) -> MessageSelector a

-- | Create a message selector that will match every message. This is
--   <i>lazy</i> because the result is not <a>force</a>ed.
selectAnyMessage :: MessageSelector StrictDynamic

-- | Returns the <a>ProcessId</a> of the current process.
self :: (HasCallStack, SetMember Process (Process q) r) => Eff r ProcessId

-- | Return <a>True</a> if the process is alive.
isProcessAlive :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => ProcessId -> Eff r Bool

-- | Start a new process, the new process will execute an effect, the
--   function will return immediately with a <a>ProcessId</a>. If the new
--   process is interrupted, the process will <a>Shutdown</a> with the
--   <a>Interrupt</a> wrapped in <a>interruptToExit</a>. For specific use
--   cases it might be better to use <a>spawnRaw</a>.
spawn :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => Eff (InterruptableProcess q) () -> Eff r ProcessId

-- | Like <a>spawn</a> but return <tt>()</tt>.
spawn_ :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => Eff (InterruptableProcess q) () -> Eff r ()

-- | Start a new process, and immediately link to it.
spawnLink :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => Eff (InterruptableProcess q) () -> Eff r ProcessId

-- | Start a new process, the new process will execute an effect, the
--   function will return immediately with a <a>ProcessId</a>. The spawned
--   process has only the <i>raw</i> <a>ConsProcess</a> effects. For
--   non-library code <a>spawn</a> might be better suited.
spawnRaw :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => Eff (ConsProcess q) () -> Eff r ProcessId

-- | Like <a>spawnRaw</a> but return <tt>()</tt>.
spawnRaw_ :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => Eff (ConsProcess q) () -> Eff r ()

-- | Exit the process with a <a>Interrupt</a>.
exitBecause :: forall r q a. (HasCallStack, SetMember Process (Process q) r) => Interrupt  'NoRecovery -> Eff r a

-- | Exit the process.
exitNormally :: forall r q a. (HasCallStack, SetMember Process (Process q) r) => Eff r a

-- | Exit the process with an error.
exitWithError :: forall r q a. (HasCallStack, SetMember Process (Process q) r) => String -> Eff r a

-- | Connect the calling process to another process, such that if one of
--   the processes crashes (i.e. <a>isCrash</a> returns <a>True</a>), the
--   other is shutdown with the <a>Interrupt</a>
--   <a>LinkedProcessCrashed</a>.
linkProcess :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => ProcessId -> Eff r ()

-- | Unlink the calling process from the other process.
unlinkProcess :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => ProcessId -> Eff r ()

-- | Monitor another process. When the monitored process exits a
--   <a>ProcessDown</a> is sent to the calling process. The return value is
--   a unique identifier for that monitor. There can be multiple monitors
--   on the same process, and a message for each will be sent. If the
--   process is already dead, the <a>ProcessDown</a> message will be sent
--   immediately, without exit reason
monitor :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => ProcessId -> Eff r MonitorReference

-- | Remove a monitor created with <a>monitor</a>.
demonitor :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => MonitorReference -> Eff r ()

-- | A monitored process exited. This message is sent to a process by the
--   scheduler, when a process that was monitored died.
data ProcessDown
ProcessDown :: !MonitorReference -> !SomeExitReason -> ProcessDown
[downReference] :: ProcessDown -> !MonitorReference
[downReason] :: ProcessDown -> !SomeExitReason

-- | A <a>MessageSelector</a> for the <a>ProcessDown</a> message of a
--   specific process.
selectProcessDown :: MonitorReference -> MessageSelector ProcessDown

-- | Make an <a>Interrupt</a> for a <a>ProcessDown</a> message.
--   
--   For example: <tt>doSomething &gt;&gt;= either (interrupt .
--   becauseProcessIsDown) return</tt>
becauseProcessIsDown :: ProcessDown -> Interrupt  'Recoverable

-- | A value that contains a unique reference of a process monitoring.
data MonitorReference
MonitorReference :: Int -> ProcessId -> MonitorReference
[monitorIndex] :: MonitorReference -> Int
[monitoredProcess] :: MonitorReference -> ProcessId

-- | <a>monitor</a> another process before while performing an action and
--   <a>demonitor</a> afterwards.
withMonitor :: (HasCallStack, Member Interrupts r, SetMember Process (Process q) r, Member Interrupts r) => ProcessId -> (MonitorReference -> Eff r a) -> Eff r a

-- | A <a>MessageSelector</a> for receiving either a monitor of the given
--   process or another message.
receiveWithMonitor :: (HasCallStack, Member Interrupts r, SetMember Process (Process q) r, Member Interrupts r, Typeable a, Show a) => ProcessId -> MessageSelector a -> Eff r (Either ProcessDown a)

-- | Handle all <a>Interrupt</a>s of an <a>InterruptableProcess</a> by
--   wrapping them up in <a>interruptToExit</a> and then do a process
--   <a>Shutdown</a>.
provideInterruptsShutdown :: forall e a. Eff (InterruptableProcess e) a -> Eff (ConsProcess e) a

-- | Handle <a>Interrupt</a>s arising during process operations, e.g. when
--   a linked process crashes while we wait in a
--   <a>receiveSelectedMessage</a> via a call to <a>interrupt</a>.
handleInterrupts :: (HasCallStack, Member Interrupts r) => (Interrupt  'Recoverable -> Eff r a) -> Eff r a -> Eff r a

-- | Like <a>handleInterrupts</a>, but instead of passing the
--   <a>Interrupt</a> to a handler function, <a>Either</a> is returned.
tryUninterrupted :: (HasCallStack, Member Interrupts r) => Eff r a -> Eff r (Either (Interrupt  'Recoverable) a)

-- | Handle <a>Interrupt</a>s arising during process operations, e.g. when
--   a linked process crashes while we wait in a
--   <a>receiveSelectedMessage</a> via a call to <a>interrupt</a>.
exitOnInterrupt :: (HasCallStack, Member Interrupts r, SetMember Process (Process q) r) => Eff r a -> Eff r a

-- | Handle interrupts by logging them with <a>logProcessExit</a> and
--   otherwise ignoring them.
logInterrupts :: forall r. (Member Logs r, HasCallStack, Member Interrupts r) => Eff r () -> Eff r ()

-- | Handle <a>Interrupt</a>s arising during process operations, e.g. when
--   a linked process crashes while we wait in a
--   <a>receiveSelectedMessage</a> via a call to <a>interrupt</a>.
provideInterrupts :: HasCallStack => Eff (Interrupts : r) a -> Eff r (Either (Interrupt  'Recoverable) a)

-- | Wrap all (left) <a>Interrupt</a>s into <a>interruptToExit</a> and
--   return the (right) <a>NoRecovery</a> <a>Interrupt</a>s as is.
mergeEitherInterruptAndExitReason :: Either (Interrupt  'Recoverable) (Interrupt  'NoRecovery) -> Interrupt  'NoRecovery

-- | Throw an <a>Interrupt</a>, can be handled by <a>handleInterrupts</a>
--   or <a>exitOnInterrupt</a> or <a>provideInterrupts</a>.
interrupt :: (HasCallStack, Member Interrupts r) => Interrupt  'Recoverable -> Eff r a

-- | Execute a and action and return the result; if the process is
--   interrupted by an error or exception, or an explicit shutdown from
--   another process, or through a crash of a linked process, i.e. whenever
--   the exit reason satisfies <a>isRecoverable</a>, return the exit
--   reason.
executeAndResume :: forall q r v. (SetMember Process (Process q) r, HasCallStack) => Process q (ResumeProcess v) -> Eff r (Either (Interrupt  'Recoverable) v)

-- | Execute a <a>Process</a> action and resume the process, exit the
--   process when an <a>Interrupts</a> was raised. Use
--   <a>executeAndResume</a> to catch interrupts.
executeAndResumeOrExit :: forall r q v. (SetMember Process (Process q) r, HasCallStack) => Process q (ResumeProcess v) -> Eff r v

-- | Execute a <a>Process</a> action and resume the process, exit the
--   process when an <a>Interrupts</a> was raised. Use
--   <a>executeAndResume</a> to catch interrupts.
executeAndResumeOrThrow :: forall q r v. (SetMember Process (Process q) r, HasCallStack, Member Interrupts r) => Process q (ResumeProcess v) -> Eff r v

-- | A sum-type with reasons for why a process operation, such as receiving
--   messages, is interrupted in the scheduling loop.
--   
--   This includes errors, that can occur when scheduling messages.
data Interrupt (t :: ExitRecovery)

-- | A process has finished a unit of work and might exit or work on
--   something else. This is primarily used for interrupting infinite
--   server loops, allowing for additional cleanup work before exiting
--   (e.g. with <a>ExitNormally</a>)
[NormalExitRequested] :: Interrupt  'Recoverable

-- | A process that should be running was not running.
[OtherProcessNotRunning] :: ProcessId -> Interrupt  'Recoverable

-- | A <a>Recoverable</a> timeout has occurred.
[TimeoutInterrupt] :: String -> Interrupt  'Recoverable

-- | A linked process is down
[LinkedProcessCrashed] :: ProcessId -> Interrupt  'Recoverable

-- | An exit reason that has an error message and is <a>Recoverable</a>.
[ErrorInterrupt] :: String -> Interrupt  'Recoverable

-- | A process function returned or exited without any error.
[ExitNormally] :: Interrupt  'NoRecovery

-- | An error causes the process to exit immediately. For example an
--   unexpected runtime exception was thrown, i.e. an exception derived
--   from <a>SomeException</a> Or a <a>Recoverable</a> Interrupt was not
--   recoverd.
[ExitUnhandledError] :: Text -> Interrupt  'NoRecovery

-- | A process shall exit immediately, without any cleanup was cancelled
--   (e.g. killed, in <a>cancel</a>)
[ExitProcessCancelled] :: Interrupt  'NoRecovery

-- | Return either <a>ExitNormally</a> or <a>interruptToExit</a> from a
--   <a>Recoverable</a> <a>Interrupt</a>;
--   
--   If the <a>Interrupt</a> is <a>NormalExitRequested</a> then return
--   <a>ExitNormally</a>
interruptToExit :: Interrupt  'Recoverable -> Interrupt  'NoRecovery

-- | This kind is used to indicate if a <a>Interrupt</a> can be treated
--   like a short interrupt which can be handled or ignored.
data ExitRecovery
Recoverable :: ExitRecovery
NoRecovery :: ExitRecovery

-- | <a>Interrupt</a>s which are <a>Recoverable</a>.
type RecoverableInterrupt = Interrupt  'Recoverable

-- | <a>Exc</a>eptions containing <a>Interrupt</a>s. See
--   <a>handleInterrupts</a>, <a>exitOnInterrupt</a> or
--   <a>provideInterrupts</a>
type Interrupts = Exc (Interrupt  'Recoverable)

-- | This adds a layer of the <a>Interrupts</a> effect on top of
--   <a>ConsProcess</a>
type InterruptableProcess e = Interrupts : ConsProcess e

-- | This value indicates whether a process exited in way consistent with
--   the planned behaviour or not.
data ExitSeverity
NormalExit :: ExitSeverity
Crash :: ExitSeverity

-- | An existential wrapper around <a>Interrupt</a>
data SomeExitReason
[SomeExitReason] :: Interrupt x -> SomeExitReason

-- | Get the <a>ExitRecovery</a>
toExitRecovery :: Interrupt r -> ExitRecovery

-- | A predicate for recoverable exit reasons. This predicate defines the
--   exit reasons which functions such as <a>executeAndResume</a>
isRecoverable :: Interrupt x -> Bool

-- | Get the <a>ExitSeverity</a> of a <a>Interrupt</a>.
toExitSeverity :: Interrupt e -> ExitSeverity

-- | A predicate for linked process <b>crashes</b>.
isProcessDownInterrupt :: Maybe ProcessId -> Interrupt r -> Bool

-- | A predicate for crashes. A <i>crash</i> happens when a process exits
--   with an <a>Interrupt</a> other than <a>ExitNormally</a>
isCrash :: Interrupt x -> Bool

-- | Print a <a>Interrupt</a> to <a>Just</a> a formatted <a>String</a> when
--   <a>isCrash</a> is <a>True</a>. This can be useful in combination with
--   view patterns, e.g.:
--   
--   <pre>
--   logCrash :: Interrupt -&gt; Eff e ()
--   logCrash (toCrashReason -&gt; Just reason) = logError reason
--   logCrash _ = return ()
--   </pre>
--   
--   Though this can be improved to:
--   
--   <pre>
--   logCrash = traverse_ logError . toCrashReason
--   </pre>
toCrashReason :: Interrupt x -> Maybe Text

-- | Partition a <a>SomeExitReason</a> back into either a <a>NoRecovery</a>
--   or a <a>Recoverable</a> <a>Interrupt</a>
fromSomeExitReason :: SomeExitReason -> Either (Interrupt  'NoRecovery) (Interrupt  'Recoverable)

-- | Log the <a>Interrupt</a>s
logProcessExit :: forall e x. (Member Logs e, HasCallStack) => Interrupt x -> Eff e ()
instance GHC.Show.Show v => GHC.Show.Show (Control.Eff.Concurrent.Process.ResumeProcess v)
instance GHC.Generics.Generic1 Control.Eff.Concurrent.Process.ResumeProcess
instance GHC.Generics.Generic (Control.Eff.Concurrent.Process.ResumeProcess v)
instance GHC.Classes.Ord Control.Eff.Concurrent.Process.ProcessDown
instance GHC.Classes.Eq Control.Eff.Concurrent.Process.ProcessDown
instance GHC.Generics.Generic Control.Eff.Concurrent.Process.ProcessDown
instance GHC.Generics.Generic Control.Eff.Concurrent.Process.MonitorReference
instance GHC.Classes.Ord Control.Eff.Concurrent.Process.MonitorReference
instance GHC.Classes.Eq Control.Eff.Concurrent.Process.MonitorReference
instance GHC.Read.Read Control.Eff.Concurrent.Process.MonitorReference
instance Control.DeepSeq.NFData Control.Eff.Concurrent.Process.ProcessId
instance GHC.Real.Real Control.Eff.Concurrent.Process.ProcessId
instance GHC.Real.Integral Control.Eff.Concurrent.Process.ProcessId
instance GHC.Enum.Enum Control.Eff.Concurrent.Process.ProcessId
instance GHC.Num.Num Control.Eff.Concurrent.Process.ProcessId
instance GHC.Enum.Bounded Control.Eff.Concurrent.Process.ProcessId
instance GHC.Classes.Ord Control.Eff.Concurrent.Process.ProcessId
instance GHC.Classes.Eq Control.Eff.Concurrent.Process.ProcessId
instance GHC.Generics.Generic Control.Eff.Concurrent.Process.ExitSeverity
instance GHC.Classes.Eq Control.Eff.Concurrent.Process.ExitSeverity
instance GHC.Classes.Ord Control.Eff.Concurrent.Process.ExitSeverity
instance GHC.Generics.Generic Control.Eff.Concurrent.Process.ExitRecovery
instance GHC.Classes.Eq Control.Eff.Concurrent.Process.ExitRecovery
instance GHC.Classes.Ord Control.Eff.Concurrent.Process.ExitRecovery
instance GHC.Generics.Generic Control.Eff.Concurrent.Process.ProcessState
instance GHC.Enum.Enum Control.Eff.Concurrent.Process.ProcessState
instance GHC.Classes.Eq Control.Eff.Concurrent.Process.ProcessState
instance GHC.Classes.Ord Control.Eff.Concurrent.Process.ProcessState
instance GHC.Show.Show Control.Eff.Concurrent.Process.ProcessState
instance GHC.Read.Read Control.Eff.Concurrent.Process.ProcessState
instance GHC.Base.Functor Control.Eff.Concurrent.Process.MessageSelector
instance GHC.Base.Semigroup a => GHC.Base.Monoid (Control.Eff.Concurrent.Process.MessageSelector a)
instance GHC.Base.Semigroup a => GHC.Base.Semigroup (Control.Eff.Concurrent.Process.MessageSelector a)
instance GHC.Show.Show (Control.Eff.Concurrent.Process.Process r b)
instance Control.DeepSeq.NFData a => Control.DeepSeq.NFData (Control.Eff.Concurrent.Process.ResumeProcess a)
instance Control.DeepSeq.NFData1 Control.Eff.Concurrent.Process.ResumeProcess
instance Control.DeepSeq.NFData Control.Eff.Concurrent.Process.ProcessDown
instance GHC.Show.Show Control.Eff.Concurrent.Process.ProcessDown
instance GHC.Classes.Ord Control.Eff.Concurrent.Process.SomeExitReason
instance GHC.Classes.Eq Control.Eff.Concurrent.Process.SomeExitReason
instance GHC.Show.Show Control.Eff.Concurrent.Process.SomeExitReason
instance Control.DeepSeq.NFData Control.Eff.Concurrent.Process.SomeExitReason
instance GHC.Show.Show (Control.Eff.Concurrent.Process.Interrupt x)
instance GHC.Exception.Type.Exception (Control.Eff.Concurrent.Process.Interrupt 'Control.Eff.Concurrent.Process.Recoverable)
instance GHC.Exception.Type.Exception (Control.Eff.Concurrent.Process.Interrupt 'Control.Eff.Concurrent.Process.NoRecovery)
instance Control.DeepSeq.NFData (Control.Eff.Concurrent.Process.Interrupt x)
instance GHC.Classes.Ord (Control.Eff.Concurrent.Process.Interrupt x)
instance GHC.Classes.Eq (Control.Eff.Concurrent.Process.Interrupt x)
instance Control.DeepSeq.NFData Control.Eff.Concurrent.Process.MonitorReference
instance GHC.Show.Show Control.Eff.Concurrent.Process.MonitorReference
instance GHC.Read.Read Control.Eff.Concurrent.Process.ProcessId
instance GHC.Show.Show Control.Eff.Concurrent.Process.ProcessId
instance GHC.Show.Show Control.Eff.Concurrent.Process.ExitSeverity
instance Control.DeepSeq.NFData Control.Eff.Concurrent.Process.ExitSeverity
instance Control.DeepSeq.NFData Control.Eff.Concurrent.Process.ExitRecovery
instance GHC.Show.Show Control.Eff.Concurrent.Process.ExitRecovery
instance Control.DeepSeq.NFData Control.Eff.Concurrent.Process.ProcessState
instance Data.Default.Class.Default Control.Eff.Concurrent.Process.ProcessState
instance GHC.Base.Applicative Control.Eff.Concurrent.Process.MessageSelector
instance GHC.Base.Alternative Control.Eff.Concurrent.Process.MessageSelector
instance GHC.Show.Show Control.Eff.Concurrent.Process.StrictDynamic


-- | Functions for timeouts when receiving messages.
--   
--   NOTE: If you use a single threaded scheduler, these functions will not
--   work as expected. (This is an open TODO)
module Control.Eff.Concurrent.Process.Timer

-- | A number of micro seconds.
newtype Timeout
TimeoutMicros :: Int -> Timeout
[fromTimeoutMicros] :: Timeout -> Int

-- | The reference to a timer started by <a>startTimer</a>, required to
--   stop a timer via <a>cancelTimer</a>.
data TimerReference

-- | A value to be sent when timer started with <a>startTimer</a> has
--   elapsed.
data TimerElapsed

-- | Send a message to a given process after waiting. The message is
--   created by applying the function parameter to the
--   <a>TimerReference</a>, such that the message can directly refer to the
--   timer.
sendAfter :: forall r q message. (Lifted IO q, HasCallStack, SetMember Process (Process q) r, Member Interrupts r, Typeable message, NFData message) => ProcessId -> Timeout -> (TimerReference -> message) -> Eff r TimerReference

-- | Start a new timer, after the time has elapsed, <a>TimerElapsed</a> is
--   sent to calling process. The message also contains the
--   <a>TimerReference</a> returned by this function. Use
--   <a>cancelTimer</a> to cancel the timer. Use <a>selectTimerElapsed</a>
--   to receive the message using <a>receiveSelectedMessage</a>. To receive
--   messages with guarded with a timeout see <a>receiveAfter</a>.
startTimer :: forall r q. (Lifted IO q, HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => Timeout -> Eff r TimerReference

-- | Cancel a timer started with <a>startTimer</a>.
cancelTimer :: forall r q. (Lifted IO q, HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => TimerReference -> Eff r ()

-- | A <a>MessageSelector</a> matching <a>TimerElapsed</a> messages created
--   by <a>startTimer</a>.
selectTimerElapsed :: TimerReference -> MessageSelector TimerElapsed

-- | Wait for a message of the given type for the given time. When no
--   message arrives in time, return <a>Nothing</a>. This is based on
--   <a>receiveSelectedAfter</a>.
receiveAfter :: forall a r q. (Lifted IO q, HasCallStack, SetMember Process (Process q) r, Member Interrupts r, Typeable a, NFData a, Show a) => Timeout -> Eff r (Maybe a)

-- | Wait for a message of the given type for the given time. When no
--   message arrives in time, return <a>Left</a> <a>TimerElapsed</a>. This
--   is based on <a>selectTimerElapsed</a> and <a>startTimer</a>.
receiveSelectedAfter :: forall a r q. (Lifted IO q, HasCallStack, SetMember Process (Process q) r, Member Interrupts r, Show a) => MessageSelector a -> Timeout -> Eff r (Either TimerElapsed a)

-- | Like <a>receiveWithMonitor</a> combined with
--   <a>receiveSelectedAfter</a>.
receiveSelectedWithMonitorAfter :: forall a r q. (Lifted IO q, HasCallStack, SetMember Process (Process q) r, Member Interrupts r, Show a) => ProcessId -> MessageSelector a -> Timeout -> Eff r (Either (Either ProcessDown TimerElapsed) a)
instance GHC.Classes.Eq Control.Eff.Concurrent.Process.Timer.TimerElapsed
instance GHC.Classes.Ord Control.Eff.Concurrent.Process.Timer.TimerElapsed
instance Control.DeepSeq.NFData Control.Eff.Concurrent.Process.Timer.TimerElapsed
instance GHC.Enum.Enum Control.Eff.Concurrent.Process.Timer.TimerReference
instance GHC.Real.Real Control.Eff.Concurrent.Process.Timer.TimerReference
instance GHC.Real.Integral Control.Eff.Concurrent.Process.Timer.TimerReference
instance GHC.Num.Num Control.Eff.Concurrent.Process.Timer.TimerReference
instance GHC.Classes.Eq Control.Eff.Concurrent.Process.Timer.TimerReference
instance GHC.Classes.Ord Control.Eff.Concurrent.Process.Timer.TimerReference
instance Control.DeepSeq.NFData Control.Eff.Concurrent.Process.Timer.TimerReference
instance GHC.Enum.Enum Control.Eff.Concurrent.Process.Timer.Timeout
instance GHC.Real.Real Control.Eff.Concurrent.Process.Timer.Timeout
instance GHC.Real.Integral Control.Eff.Concurrent.Process.Timer.Timeout
instance GHC.Num.Num Control.Eff.Concurrent.Process.Timer.Timeout
instance GHC.Classes.Eq Control.Eff.Concurrent.Process.Timer.Timeout
instance GHC.Classes.Ord Control.Eff.Concurrent.Process.Timer.Timeout
instance Control.DeepSeq.NFData Control.Eff.Concurrent.Process.Timer.Timeout
instance GHC.Show.Show Control.Eff.Concurrent.Process.Timer.TimerElapsed
instance GHC.Show.Show Control.Eff.Concurrent.Process.Timer.TimerReference
instance GHC.Show.Show Control.Eff.Concurrent.Process.Timer.Timeout


-- | This module contains a mechanism to specify what kind of messages (aka
--   <i>requests</i>) a <a>Server</a> (<a>Process</a>) can handle, and if
--   the caller blocks and waits for an answer, which the server process
--   provides.
--   
--   The type magic in the <a>Api</a> type family allows to define a
--   related set of <i>requests</i> along with the corresponding responses.
--   
--   Request handling can be either blocking, if a response is required, or
--   non-blocking.
--   
--   A process can <i>serve</i> a specific <a>Api</a> instance by using the
--   functions provided by the <a>Control.Eff.Concurrent.Api.Server</a>
--   module.
--   
--   To enable a process to use such a <i>service</i>, the functions
--   provided by the <a>Control.Eff.Concurrent.Api.Client</a> should be
--   used.
module Control.Eff.Concurrent.Api

-- | This data family defines an API, a communication interface description
--   between at least two processes. The processes act as <b>servers</b> or
--   <b>client(s)</b> regarding a specific instance of this type.
--   
--   The first parameter is usually a user defined phantom type that
--   identifies the <a>Api</a> instance.
--   
--   The second parameter specifies if a specific constructor of an
--   (GADT-like) <tt>Api</tt> instance is <a>Synchronous</a>, i.e. returns
--   a result and blocks the caller or if it is <a>Asynchronous</a>
--   
--   Also, for better logging, the an instance of <a>ToPretty</a> for the
--   <a>Api</a> index type must be given.
--   
--   Example:
--   
--   <pre>
--   data BookShop deriving Typeable
--   
--   data instance Api BookShop r where
--     RentBook  :: BookId   -&gt; Api BookShop ('Synchronous (Either RentalError RentalId))
--     BringBack :: RentalId -&gt; Api BookShop 'Asynchronous
--   
--   type instance ToPretty BookShop = PutStr "book shop"
--   
--   type BookId = Int
--   type RentalId = Int
--   type RentalError = String
--   </pre>
data family Api (api :: Type) (reply :: Synchronicity)

-- | The (promoted) constructors of this type specify (at the type level)
--   the reply behavior of a specific constructor of an <tt>Api</tt>
--   instance.
data Synchronicity

-- | Specify that handling a request is a blocking operation with a
--   specific return type, e.g. <tt>('Synchronous (Either RentalError
--   RentalId))</tt>
Synchronous :: Type -> Synchronicity

-- | Non-blocking, asynchronous, request handling
Asynchronous :: Synchronicity

-- | A set of constraints for types that can evaluated via <a>NFData</a>,
--   compared via <a>Ord</a> and presented dynamically via <a>Typeable</a>,
--   and represented both as values via <a>Show</a>, as well as on the type
--   level via <a>ToPretty</a>.
type Tangible i = (NFData i, Typeable i, Show i, PrettyTypeShow (ToPretty i))

-- | This is a tag-type that wraps around a <a>ProcessId</a> and holds an
--   <a>Api</a> index type.
newtype Server api
Server :: ProcessId -> Server api
[_fromServer] :: Server api -> ProcessId
fromServer :: forall api_aXxm api_aXVF. Iso (Server api_aXxm) (Server api_aXVF) ProcessId ProcessId

-- | Tag a <a>ProcessId</a> with an <a>Api</a> type index to mark it a
--   <a>Server</a> process handling that API
proxyAsServer :: proxy api -> ProcessId -> Server api

-- | Tag a <a>ProcessId</a> with an <a>Api</a> type index to mark it a
--   <a>Server</a> process handling that API
asServer :: forall api. ProcessId -> Server api
instance forall k (api :: k). Control.DeepSeq.NFData (Control.Eff.Concurrent.Api.Server api)
instance forall k (api :: k). GHC.Classes.Ord (Control.Eff.Concurrent.Api.Server api)
instance forall k (api :: k). GHC.Classes.Eq (Control.Eff.Concurrent.Api.Server api)
instance forall k (api :: k). Data.Type.Pretty.PrettyTypeShow (Data.Type.Pretty.ToPretty api) => GHC.Show.Show (Control.Eff.Concurrent.Api.Server api)


-- | Logging via <tt>extensible-effects</tt>
--   
--   Logging consist of <b>two</b> effects:
--   
--   <ul>
--   <li><b>Receiving</b> log messages sent by the code using e.g.
--   <a>logInfo</a>; this also include deep evaluation and dropping
--   messages not satisfying the current <a>LogPredicate</a>.</li>
--   <li><b>Writing</b> log message to disk, network, ... etc; this also
--   includes rendering log messages and setting fields like the hostname,
--   timestamp, etc</li>
--   </ul>
--   
--   <h2>Example</h2>
--   
--   <pre>
--   exampleLogging :: IO ()
--   exampleLogging =
--       runLift
--     $ withLogging consoleLogWriter
--     $ do
--         logDebug "test 1.1"
--         logError "test 1.2"
--         censorLogs (prefixLogMessagesWith "NESTED: ")
--          $ do
--               addLogWriter debugTraceLogWriter
--                $ setLogPredicate (\m -&gt; (view lmMessage m) /= "not logged")
--                $ do
--                     logInfo "not logged"
--                     logMsg "test 2.1"
--               logWarning "test 2.2"
--         logCritical "test 1.3"
--   </pre>
--   
--   <h2>Log Message Data Type</h2>
--   
--   A singular <i>logging event</i> is contained in a
--   <b><a>LogMessage</a>s</b> value.
--   
--   The <a>LogMessage</a> is modelled along RFC-5424.
--   
--   There is the <a>ToLogMessage</a> class for converting to
--   <a>LogMessage</a>. <i>Although the author is not clear on how to
--   pursue the approach.</i>
--   
--   <h2>Receiving and Filtering</h2>
--   
--   <a>LogMessage</a>s are sent using <a>logMsg</a> and friends, see
--   <a>Control.Eff.Log#SendingLogs</a>
--   
--   <h3>Log Message Predicates</h3>
--   
--   There is a single global <a>LogPredicate</a> that can be used to
--   suppress logs before they are passed to any <a>LogWriter</a>.
--   
--   This is done by the <a>logMsg</a> function.
--   
--   Also, <a>LogMessage</a>s are evaluated using <a>deepseq</a>,
--   <b>after</b> they pass the <a>LogPredicate</a>, also inside
--   <a>logMsg</a>.
--   
--   See <a>Control.Eff.Log#LogPredicate</a>
--   
--   <h2>Writing and Rendering</h2>
--   
--   Writing is done through a <a>LogWriter</a>; the current
--   <a>LogWriter</a> value to use is held by the <a>LogWriterReader</a>
--   effect.
--   
--   <h3>Log Message Rendering</h3>
--   
--   Message are rendered by <a>LogMessageRenderer</a>s found in the
--   <a>Control.Eff.Log.MessageRenderer</a>.
--   
--   <h3><a>LogWriter</a>s</h3>
--   
--   <ul>
--   <li>Logging in a <a>withAsync</a> spawned thread is done using
--   <tt>withAsyncLogging</tt>.</li>
--   </ul>
module Control.Eff.Log

-- | Log a message.
--   
--   All logging goes through this function.
--   
--   This function is the only place where the <a>LogPredicate</a> is
--   applied.
--   
--   Also, <a>LogMessage</a>s are evaluated using <a>deepseq</a>,
--   <b>after</b> they pass the <a>LogPredicate</a>.
logMsg :: forall e. (HasCallStack, Member Logs e) => LogMessage -> Eff e ()

-- | Log a <a>Text</a> as <a>LogMessage</a> with a given <a>Severity</a>.
logWithSeverity :: forall e. (HasCallStack, Member Logs e) => Severity -> Text -> Eff e ()

-- | Log a <a>Text</a> as <a>LogMessage</a> with a given <a>Severity</a>.
logWithSeverity' :: forall e. (HasCallStack, Member Logs e) => Severity -> String -> Eff e ()

-- | Log a <a>String</a> as <a>emergencySeverity</a>.
logEmergency :: forall e. (HasCallStack, Member Logs e) => Text -> Eff e ()

-- | Log a <a>String</a> as <a>emergencySeverity</a>.
logEmergency' :: forall e. (HasCallStack, Member Logs e) => String -> Eff e ()

-- | Log a message with <a>alertSeverity</a>.
logAlert :: forall e. (HasCallStack, Member Logs e) => Text -> Eff e ()

-- | Log a message with <a>alertSeverity</a>.
logAlert' :: forall e. (HasCallStack, Member Logs e) => String -> Eff e ()

-- | Log a <a>criticalSeverity</a> message.
logCritical :: forall e. (HasCallStack, Member Logs e) => Text -> Eff e ()

-- | Log a <a>criticalSeverity</a> message.
logCritical' :: forall e. (HasCallStack, Member Logs e) => String -> Eff e ()

-- | Log a <a>errorSeverity</a> message.
logError :: forall e. (HasCallStack, Member Logs e) => Text -> Eff e ()

-- | Log a <a>errorSeverity</a> message.
logError' :: forall e. (HasCallStack, Member Logs e) => String -> Eff e ()

-- | Log a <a>warningSeverity</a> message.
logWarning :: forall e. (HasCallStack, Member Logs e) => Text -> Eff e ()

-- | Log a <a>warningSeverity</a> message.
logWarning' :: forall e. (HasCallStack, Member Logs e) => String -> Eff e ()

-- | Log a <a>noticeSeverity</a> message.
logNotice :: forall e. (HasCallStack, Member Logs e) => Text -> Eff e ()

-- | Log a <a>noticeSeverity</a> message.
logNotice' :: forall e. (HasCallStack, Member Logs e) => String -> Eff e ()

-- | Log a <a>informationalSeverity</a> message.
logInfo :: forall e. (HasCallStack, Member Logs e) => Text -> Eff e ()

-- | Log a <a>informationalSeverity</a> message.
logInfo' :: forall e. (HasCallStack, Member Logs e) => String -> Eff e ()

-- | Log a <a>debugSeverity</a> message.
logDebug :: forall e. (HasCallStack, Member Logs e) => Text -> Eff e ()

-- | Log a <a>debugSeverity</a> message.
logDebug' :: forall e. (HasCallStack, Member Logs e) => String -> Eff e ()

-- | Include <a>LogMessage</a>s that match a <a>LogPredicate</a>.
--   
--   <tt>excludeLogMessages p</tt> allows log message to be logged if <tt>p
--   m</tt>
--   
--   Although it is enough if the previous predicate holds. See
--   <a>excludeLogMessages</a> and <a>modifyLogPredicate</a>.
--   
--   See <a>Control.Eff.Log#LogPredicate</a>
includeLogMessages :: forall e a. Member Logs e => LogPredicate -> Eff e a -> Eff e a

-- | Exclude <a>LogMessage</a>s that match a <a>LogPredicate</a>.
--   
--   <tt>excludeLogMessages p</tt> discards logs if <tt>p m</tt>
--   
--   Also the previous predicate must also hold for a message to be logged.
--   See <a>excludeLogMessages</a> and <a>modifyLogPredicate</a>.
--   
--   See <a>Control.Eff.Log#LogPredicate</a>
excludeLogMessages :: forall e a. Member Logs e => LogPredicate -> Eff e a -> Eff e a

-- | Keep only those messages, for which a predicate holds.
--   
--   E.g. to keep only messages which begin with <tt><a>OMG</a></tt>:
--   
--   <pre>
--   exampleLogPredicate :: IO Int
--   exampleLogPredicate =
--       runLift
--     $ withLogging consoleLogWriter
--     $ do logMsg "test"
--          setLogPredicate (\ msg -&gt; case view lmMessage msg of
--                                     'O':'M':'G':_ -&gt; True
--                                     _             -&gt; False)
--                            (do logMsg "this message will not be logged"
--                                logMsg "OMG logged"
--                                return 42)
--   </pre>
--   
--   In order to also delegate to the previous predicate, use
--   <a>modifyLogPredicate</a>
--   
--   See <a>Control.Eff.Log#LogPredicate</a>
setLogPredicate :: forall r b. (Member Logs r, HasCallStack) => LogPredicate -> Eff r b -> Eff r b

-- | Change the <a>LogPredicate</a>.
--   
--   Other than <a>setLogPredicate</a> this function allows to include the
--   previous predicate, too.
--   
--   For to discard all messages currently no satisfying the predicate and
--   also all messages that are to long:
--   
--   <pre>
--   modifyLogPredicate (previousPredicate msg -&gt; previousPredicate msg &amp;&amp; length (lmMessage msg) &lt; 29 )
--                      (do logMsg "this message will not be logged"
--                          logMsg "this message might be logged")
--   </pre>
--   
--   See <a>Control.Eff.Log#LogPredicate</a>
modifyLogPredicate :: forall e b. (Member Logs e, HasCallStack) => (LogPredicate -> LogPredicate) -> Eff e b -> Eff e b

-- | Get the current <a>Logs</a> filter/transformer function.
--   
--   See <a>Control.Eff.Log#LogPredicate</a>
askLogPredicate :: forall e. Member Logs e => Eff e LogPredicate

-- | Replace the current <a>LogWriter</a>. To add an additional log message
--   consumer use <a>addLogWriter</a>
setLogWriter :: forall h e a. LogsTo h e => LogWriter h -> Eff e a -> Eff e a

-- | Combine the effects of a given <a>LogWriter</a> and the existing one.
--   
--   <pre>
--   import Data.Text    as T
--   import Data.Text.IO as T
--   
--   exampleAddLogWriter :: IO ()
--   exampleAddLogWriter = go &gt;&gt;= T.putStrLn
--    where go = fmap (unlines . map renderLogMessageConsoleLog . snd)
--                 $  runLift
--                 $  runCaptureLogWriter
--                 $  withLogging captureLogWriter
--                 $  addLogWriter (mappingLogWriter (lmMessage %~ ("CAPTURED "++)) captureLogWriter)
--                 $  addLogWriter (filteringLogWriter severeMessages (mappingLogWriter (lmMessage %~ ("TRACED "++)) debugTraceLogWriter))
--                 $  do
--                       logEmergency "test emergencySeverity 1"
--                       logCritical "test criticalSeverity 2"
--                       logAlert "test alertSeverity 3"
--                       logError "test errorSeverity 4"
--                       logWarning "test warningSeverity 5"
--                       logInfo "test informationalSeverity 6"
--                       logDebug "test debugSeverity 7"
--          severeMessages = view (lmSeverity . to (&lt;= errorSeverity))
--   </pre>
addLogWriter :: forall h e a. (HasCallStack, LogsTo h e, Monad h) => LogWriter h -> Eff e a -> Eff e a

-- | Change the current <a>LogWriter</a>.
modifyLogWriter :: forall h e a. LogsTo h e => (LogWriter h -> LogWriter h) -> Eff e a -> Eff e a

-- | Modify the the <a>LogMessage</a>s written in the given sub-expression.
--   
--   Note: This is equivalent to <tt><a>modifyLogWriter</a> .
--   <a>mappingLogWriter</a></tt>
censorLogs :: LogsTo h e => (LogMessage -> LogMessage) -> Eff e a -> Eff e a

-- | Modify the the <a>LogMessage</a>s written in the given sub-expression,
--   as in <a>censorLogs</a> but with a effectful function.
--   
--   Note: This is equivalent to <tt><a>modifyLogWriter</a> .
--   <a>mappingLogWriterM</a></tt>
censorLogsM :: (LogsTo h e, Monad h) => (LogMessage -> h LogMessage) -> Eff e a -> Eff e a

-- | This effect sends <a>LogMessage</a>s and is a reader for a
--   <a>LogPredicate</a>.
--   
--   Logs are sent via <a>logMsg</a>; for more information about log
--   predicates, see <a>Control.Eff.Log#LogPredicate</a>
--   
--   This effect is handled via <a>withLogging</a>.
data Logs v

-- | A constraint alias for effects that requires a <a>LogWriterReader</a>,
--   as well as that the contained <a>LogWriterReader</a> has a
--   <a>HandleLogWriter</a> instance.
--   
--   The requirements of this constraint are provided by:
--   
--   <ul>
--   <li><tt>withIoLogging</tt></li>
--   <li><a>withLogging</a></li>
--   <li><a>withSomeLogging</a></li>
--   </ul>
type LogsTo h e = (Member Logs e, HandleLogWriter h, LogWriterEffects h <:: e, SetMember LogWriterReader (LogWriterReader h) e)

-- | Handle the <a>Logs</a> and <a>LogWriterReader</a> effects.
--   
--   It installs the given <a>LogWriter</a>, which determines the
--   underlying <a>LogWriter</a> type parameter.
--   
--   Example:
--   
--   <pre>
--   exampleWithLogging :: IO ()
--   exampleWithLogging =
--       runLift
--     $ withLogging consoleLogWriter
--     $ logDebug "Oh, hi there"
--   </pre>
withLogging :: forall h e a. (Applicative h, LogsTo h (Logs : (LogWriterReader h : e))) => LogWriter h -> Eff (Logs : (LogWriterReader h : e)) a -> Eff e a

-- | Handles the <a>Logs</a> and <a>LogWriterReader</a> effects.
--   
--   By default it uses the <a>noOpLogWriter</a>, but using
--   <a>setLogWriter</a> the <a>LogWriter</a> can be replaced.
--   
--   This is like <a>withLogging</a> applied to <a>noOpLogWriter</a>
--   
--   Example:
--   
--   <pre>
--   exampleWithSomeLogging :: ()
--   exampleWithSomeLogging =
--       run
--     $ withSomeLogging @PureLogWriter
--     $ logDebug "Oh, hi there"
--   </pre>
withSomeLogging :: forall h e a. (Applicative h, LogsTo h (Logs : (LogWriterReader h : e))) => Eff (Logs : (LogWriterReader h : e)) a -> Eff e a

-- | Raw handling of the <a>Logs</a> effect. Exposed for custom extensions,
--   if in doubt use <a>withLogging</a>.
runLogs :: forall h e b. LogsTo h (Logs : e) => LogPredicate -> Eff (Logs : e) b -> Eff e b

-- | Consume log messages.
--   
--   Exposed for custom extensions, if in doubt use <a>withLogging</a>.
--   
--   Respond to all <a>LogMessage</a>s logged from the given action, up to
--   any <a>MonadBaseControl</a> liftings.
--   
--   Note that all logging is done through <a>logMsg</a> and that means
--   only messages passing the <a>LogPredicate</a> are received.
--   
--   The <a>LogMessage</a>s are <b>consumed</b> once they are passed to the
--   given callback function, previous <a>respondToLogMessage</a>
--   invocations further up in the call stack will not get the messages
--   anymore.
--   
--   Use <a>interceptLogMessages</a> if the messages shall be passed any
--   previous handler.
--   
--   NOTE: The effects of this function are <b>lost</b> when using
--   <a>MonadBaseControl</a>, <a>MonadMask</a>, <a>MonadCatch</a> and
--   <a>MonadThrow</a>.
--   
--   In contrast the functions based on modifying the <a>LogWriter</a>,
--   such as <a>addLogWriter</a> or <a>censorLogs</a>, are save to use in
--   combination with the aforementioned liftings.
respondToLogMessage :: forall r b. Member Logs r => (LogMessage -> Eff r ()) -> Eff r b -> Eff r b

-- | Change the <a>LogMessage</a>s using an effectful function.
--   
--   Exposed for custom extensions, if in doubt use <a>withLogging</a>.
--   
--   This differs from <a>respondToLogMessage</a> in that the intercepted
--   messages will be written either way, albeit in altered form.
--   
--   NOTE: The effects of this function are <b>lost</b> when using
--   <a>MonadBaseControl</a>, <a>MonadMask</a>, <a>MonadCatch</a> and
--   <a>MonadThrow</a>.
--   
--   In contrast the functions based on modifying the <a>LogWriter</a>,
--   such as <a>addLogWriter</a> or <a>censorLogs</a>, are save to use in
--   combination with the aforementioned liftings.
interceptLogMessages :: forall r b. Member Logs r => (LogMessage -> Eff r LogMessage) -> Eff r b -> Eff r b


-- | Support code to implement <a>Api</a> _server_ processes.
module Control.Eff.Concurrent.Api.Server

-- | <i>Serve</i> an <a>Api</a> in a newly spawned process.
spawnApiServer :: forall api eff. (ToServerPids api, HasCallStack, Member Logs eff, PrettyTypeShow (PrettyServerPids api)) => MessageCallback api (InterruptableProcess eff) -> InterruptCallback (ConsProcess eff) -> Eff (InterruptableProcess eff) (ServerPids api)

-- | <i>Serve</i> an <a>Api</a> in a newly spawned -and linked - process.
spawnLinkApiServer :: forall api eff. (ToServerPids api, HasCallStack, Member Logs eff, Typeable api, PrettyTypeShow (PrettyServerPids api)) => MessageCallback api (InterruptableProcess eff) -> InterruptCallback (ConsProcess eff) -> Eff (InterruptableProcess eff) (ServerPids api)

-- | <i>Server</i> an <a>Api</a> in a newly spawned process; the callbacks
--   have access to a state value.
--   
--   The initial state value is returned by the action given as parameter,
--   from within the new process.
spawnApiServerStateful :: forall api eff state. (HasCallStack, ToServerPids api, NFData state, PrettyTypeShow (PrettyServerPids api)) => Eff (InterruptableProcess eff) state -> MessageCallback api (State state : InterruptableProcess eff) -> InterruptCallback (State state : ConsProcess eff) -> Eff (InterruptableProcess eff) (ServerPids api)

-- | <i>Server</i> an <a>Api</a> in a newly spawned process; The caller
--   provides an effect handler for arbitrary effects used by the server
--   callbacks.
spawnApiServerEffectful :: forall api eff serverEff. (HasCallStack, ToServerPids api, Member Interrupts serverEff, SetMember Process (Process eff) serverEff, Member Logs serverEff, PrettyTypeShow (PrettyServerPids api)) => (forall b. Eff serverEff b -> Eff (InterruptableProcess eff) b) -> MessageCallback api serverEff -> InterruptCallback serverEff -> Eff (InterruptableProcess eff) (ServerPids api)

-- | <i>Server</i> an <a>Api</a> in a newly spawned process; The caller
--   provides an effect handler for arbitrary effects used by the server
--   callbacks. Links to the calling process like <a>linkProcess</a> would.
spawnLinkApiServerEffectful :: forall api eff serverEff. (HasCallStack, ToServerPids api, Member Interrupts serverEff, SetMember Process (Process eff) serverEff, Member Logs serverEff, PrettyTypeShow (PrettyServerPids api)) => (forall b. Eff serverEff b -> Eff (InterruptableProcess eff) b) -> MessageCallback api serverEff -> InterruptCallback serverEff -> Eff (InterruptableProcess eff) (ServerPids api)

-- | Receive loop for <a>Api</a> <a>call</a>s. This starts a receive loop
--   for a <a>MessageCallback</a>. It is used behind the scenes by
--   <a>spawnLinkApiServerEffectful</a> and <a>spawnApiServerEffectful</a>.
apiServerLoop :: forall api eff serverEff. (HasCallStack, ToServerPids api, Member Interrupts serverEff, SetMember Process (Process eff) serverEff, Member Logs serverEff, PrettyTypeShow (PrettyServerPids api)) => MessageCallback api serverEff -> InterruptCallback serverEff -> Eff serverEff ()

-- | A command to the server loop started by <a>apiServerLoop</a>.
--   Typically returned by a <a>MessageCallback</a> to indicate if the
--   server should continue or stop.
data CallbackResult (r :: ExitRecovery)

-- | Tell the server to keep the server loop running
[AwaitNext] :: CallbackResult r

-- | Tell the server to exit, this will cause <a>apiServerLoop</a> to stop
--   handling requests without exiting the process.
[StopServer] :: Interrupt r -> CallbackResult r

-- | An existential wrapper around a <a>MessageSelector</a> and a function
--   that handles the selected message. The <tt>api</tt> type parameter is
--   a phantom type.
--   
--   The return value of the handler function is a <a>CallbackResult</a>.
data MessageCallback api eff
[MessageCallback] :: MessageSelector a -> (a -> Eff eff (CallbackResult  'Recoverable)) -> MessageCallback api eff

-- | A smart constructor for <a>MessageCallback</a>s
handleCasts :: forall api eff. (HasCallStack, Typeable api, Typeable (Api api  'Asynchronous), NFData (Request api)) => (Api api  'Asynchronous -> Eff eff (CallbackResult  'Recoverable)) -> MessageCallback api eff

-- | A smart constructor for <a>MessageCallback</a>s
--   
--   <h4><b>Example</b></h4>
--   
--   <pre>
--   handleCalls
--     ( (RentBook bookId customerId) runCall -&gt;
--        runCall $ do
--            rentalIdE &lt;- rentBook bookId customerId
--            case rentalIdE of
--              -- on fail we just don't send a reply, let the caller run into
--              -- timeout
--              Left err -&gt; return (Nothing, AwaitNext)
--              Right rentalId -&gt; return (Just rentalId, AwaitNext))
--   </pre>
handleCalls :: forall api eff effScheduler. (HasCallStack, Typeable api, SetMember Process (Process effScheduler) eff, Member Interrupts eff) => (forall secret reply. (NFData reply, Typeable reply, Typeable (Api api ( 'Synchronous reply))) => Api api ( 'Synchronous reply) -> (Eff eff (Maybe reply, CallbackResult  'Recoverable) -> secret) -> secret) -> MessageCallback api eff

-- | A smart constructor for <a>MessageCallback</a>s
handleCastsAndCalls :: forall api eff effScheduler. (HasCallStack, Typeable api, Typeable (Api api  'Asynchronous), NFData (Request api), SetMember Process (Process effScheduler) eff, Member Interrupts eff) => (Api api  'Asynchronous -> Eff eff (CallbackResult  'Recoverable)) -> (forall secret reply. (Typeable reply, Typeable (Api api ( 'Synchronous reply)), NFData reply) => Api api ( 'Synchronous reply) -> (Eff eff (Maybe reply, CallbackResult  'Recoverable) -> secret) -> secret) -> MessageCallback api eff

-- | A variation of <a>handleCalls</a> that allows to defer a reply to a
--   call.
handleCallsDeferred :: forall api eff effScheduler. (HasCallStack, Typeable api, SetMember Process (Process effScheduler) eff, Member Interrupts eff) => (forall reply. (Typeable reply, NFData reply, Typeable (Api api ( 'Synchronous reply))) => RequestOrigin (Api api ( 'Synchronous reply)) -> Api api ( 'Synchronous reply) -> Eff eff (CallbackResult  'Recoverable)) -> MessageCallback api eff

-- | A smart constructor for <a>MessageCallback</a>s
handleMessages :: forall eff a. (HasCallStack, NFData a, Typeable a) => (a -> Eff eff (CallbackResult  'Recoverable)) -> MessageCallback '[] eff

-- | A smart constructor for <a>MessageCallback</a>s
handleSelectedMessages :: forall eff a. HasCallStack => MessageSelector a -> (a -> Eff eff (CallbackResult  'Recoverable)) -> MessageCallback '[] eff

-- | A smart constructor for <a>MessageCallback</a>s
handleAnyMessages :: forall eff. HasCallStack => (StrictDynamic -> Eff eff (CallbackResult  'Recoverable)) -> MessageCallback '[] eff

-- | A smart constructor for <a>MessageCallback</a>s
handleProcessDowns :: forall eff. HasCallStack => (MonitorReference -> Eff eff (CallbackResult  'Recoverable)) -> MessageCallback '[] eff

-- | A <a>fallbackHandler</a> that drops the left-over messages.
dropUnhandledMessages :: forall eff. HasCallStack => MessageCallback '[] eff

-- | A <a>fallbackHandler</a> that terminates if there are unhandled
--   messages.
exitOnUnhandled :: forall eff. HasCallStack => MessageCallback '[] eff

-- | A <a>fallbackHandler</a> that drops the left-over messages.
logUnhandledMessages :: forall eff. (Member Logs eff, HasCallStack) => MessageCallback '[] eff

-- | Compose two <a>Api</a>s to a type-level pair of them.
--   
--   <pre>
--   handleCalls api1calls ^: handleCalls api2calls ^:
--   </pre>
(^:) :: forall (api1 :: Type) (apis2 :: [Type]) eff. HasCallStack => MessageCallback api1 eff -> MessageCallback apis2 eff -> MessageCallback (api1 : apis2) eff
infixr 5 ^:

-- | Make a fallback handler, i.e. a handler to which no other can be
--   composed to from the right.
fallbackHandler :: forall api eff. HasCallStack => MessageCallback api eff -> MessageCallback '[] eff

-- | Helper type class for the return values of <a>spawnApiServer</a> et
--   al.
class ToServerPids (t :: k) where {
    type family PrettyServerPids t :: PrettyType;
    type family ServerPids t;
}
toServerPids :: ToServerPids t => proxy t -> ProcessId -> ServerPids t

-- | Just a wrapper around a function that will be applied to the result of
--   a <a>MessageCallback</a>s <a>StopServer</a> clause, or an
--   <a>Interrupt</a> caught during the execution of <tt>receive</tt> or a
--   <a>MessageCallback</a>
data InterruptCallback eff
[InterruptCallback] :: (Interrupt  'Recoverable -> Eff eff (CallbackResult  'NoRecovery)) -> InterruptCallback eff

-- | A smart constructor for <a>InterruptCallback</a>s
stopServerOnInterrupt :: forall eff. HasCallStack => InterruptCallback eff
instance Data.Default.Class.Default (Control.Eff.Concurrent.Api.Server.InterruptCallback eff)
instance Control.Eff.Concurrent.Api.Server.ToServerPids '[]
instance (Control.Eff.Concurrent.Api.Server.ToServerPids api1, Control.Eff.Concurrent.Api.Server.ToServerPids api2) => Control.Eff.Concurrent.Api.Server.ToServerPids (api1 : api2)
instance Control.Eff.Concurrent.Api.Server.ToServerPids api1 => Control.Eff.Concurrent.Api.Server.ToServerPids api1
instance forall k (api :: k) (eff :: [* -> *]). GHC.Base.Semigroup (Control.Eff.Concurrent.Api.Server.MessageCallback api eff)
instance forall k (api :: k) (eff :: [* -> *]). GHC.Base.Monoid (Control.Eff.Concurrent.Api.Server.MessageCallback api eff)
instance forall k (api :: k) (eff :: [* -> *]). Data.Default.Class.Default (Control.Eff.Concurrent.Api.Server.MessageCallback api eff)


-- | A better, more safe implementation of the Erlang/OTP gen_server
--   behaviour. **PLANNED TODO** @since 0.24.0
module Control.Eff.Concurrent.Api.GenServer

-- | A type class for <a>Api</a> values that have an implementation which
--   handles the <a>Api</a>.
class (Typeable (GenServerState a), NFData (GenServerState a)) => GenServer a eff where {
    type family GenServerState a :: Type;
}
genServerInit :: (GenServer a eff, '[Interrupts, Logs] <:: eff, SetMember Process (Process q) eff) => a -> Eff eff (GenServerState a)
genServerHandle :: (GenServer a eff, '[Interrupts, Logs] <:: eff, SetMember Process (Process q) eff) => Api a v -> Eff (State (GenServerState a) : eff) (ApiReply v)
genServerInterrupt :: (GenServer a eff, '[Interrupts, Logs] <:: eff, SetMember Process (Process q) eff) => Interrupt  'Recoverable -> Eff (State (GenServerState a) : eff) ()
genServerInfoCommand :: GenServer a eff => Api a ( 'Synchronous Text)
type family ApiReply (s :: Synchronicity)
data SomeMessage a
MkSomeMessage :: SomeMessage a
runGenServer :: forall q e h a. (GenServer a e, SetMember Process (Process q) e, Member Interrupts e, LogsTo h e) => a -> Eff e (Server a)


-- | Functions for <a>Api</a> clients.
--   
--   This modules is required to write clients that consume an <a>Api</a>.
module Control.Eff.Concurrent.Api.Client

-- | Send an <a>Api</a> request that has no return value and return as fast
--   as possible. The type signature enforces that the corresponding
--   <a>Api</a> clause is <a>Asynchronous</a>. The operation never fails,
--   if it is important to know if the message was delivered, use
--   <a>call</a> instead.
--   
--   The message will be reduced to normal form (<a>rnf</a>) in the caller
--   process.
cast :: forall r q o. (HasCallStack, SetMember Process (Process q) r, PrettyTypeShow (ToPretty o), Member Interrupts r, Typeable o, Typeable (Api o  'Asynchronous), NFData (Api o  'Asynchronous)) => Server o -> Api o  'Asynchronous -> Eff r ()

-- | Send an <a>Api</a> request and wait for the server to return a result
--   value.
--   
--   The type signature enforces that the corresponding <a>Api</a> clause
--   is <a>Synchronous</a>.
--   
--   <b>Always prefer <a>callWithTimeout</a> over <a>call</a></b>
call :: forall result api r q. (SetMember Process (Process q) r, Member Interrupts r, Typeable api, PrettyTypeShow (ToPretty api), Typeable (Api api ( 'Synchronous result)), NFData (Api api ( 'Synchronous result)), Typeable result, NFData result, Show result, HasCallStack) => Server api -> Api api ( 'Synchronous result) -> Eff r result

-- | Send an <a>Api</a> request and wait for the server to return a result
--   value.
--   
--   The type signature enforces that the corresponding <a>Api</a> clause
--   is <a>Synchronous</a>.
--   
--   If the server that was called dies, this function interrupts the
--   process with <a>ProcessDown</a>. If the server takes longer to reply
--   than the given timeout, this function interrupts the process with
--   <a>TimeoutInterrupt</a>.
--   
--   <b>Always prefer this function over <a>call</a></b>
callWithTimeout :: forall result api r q. (SetMember Process (Process q) r, Member Interrupts r, Typeable api, Typeable (Api api ( 'Synchronous result)), NFData (Api api ( 'Synchronous result)), Typeable result, NFData result, Show result, Member Logs r, Lifted IO q, Lifted IO r, HasCallStack, PrettyTypeShow (ToPretty api)) => Server api -> Api api ( 'Synchronous result) -> Timeout -> Eff r result

-- | Like <a>cast</a> but take the <a>Server</a> from the reader provided
--   by <a>registerServer</a>.
castRegistered :: (Typeable o, ServesApi o r q, HasCallStack, Member Interrupts r, NFData (Api o  'Asynchronous)) => Api o  'Asynchronous -> Eff r ()

-- | Like <a>call</a> but take the <a>Server</a> from the reader provided
--   by <a>registerServer</a>.
callRegistered :: (Typeable reply, ServesApi o r q, HasCallStack, NFData reply, Show reply, NFData (Api o ( 'Synchronous reply)), Member Interrupts r) => Api o ( 'Synchronous reply) -> Eff r reply

-- | Instead of passing around a <a>Server</a> value and passing to
--   functions like <a>cast</a> or <a>call</a>, a <a>Server</a> can
--   provided by a <a>Reader</a> effect, if there is only a <b>single
--   server</b> for a given <a>Api</a> instance. This type alias is
--   convenience to express that an effect has <a>Process</a> and a reader
--   for a <a>Server</a>.
type ServesApi o r q = (Typeable o, PrettyTypeShow (ToPretty o), SetMember Process (Process q) r, Member (ServerReader o) r)

-- | The reader effect for <a>ProcessId</a>s for <a>Api</a>s, see
--   <a>registerServer</a>
type ServerReader o = Reader (Server o)

-- | Get the <a>Server</a> registered with <a>registerServer</a>.
whereIsServer :: Member (ServerReader o) e => Eff e (Server o)

-- | Run a reader effect that contains <b>the one</b> server handling a
--   specific <a>Api</a> instance.
registerServer :: HasCallStack => Server o -> Eff (ServerReader o : r) a -> Eff r a


-- | This module provides support for executing <a>Process</a> actions from
--   <a>IO</a>.
--   
--   One use case is interacting with processes from the REPL, e.g.:
--   
--   <pre>
--   &gt;&gt;&gt; import Control.Eff.Concurrent.Process.SingleThreadedScheduler (defaultMain)
--   </pre>
--   
--   <pre>
--   &gt;&gt;&gt; import Control.Eff.Loop
--   </pre>
--   
--   <pre>
--   &gt;&gt;&gt; import Data.Dynamic
--   </pre>
--   
--   <pre>
--   &gt;&gt;&gt; import Data.Maybe
--   </pre>
--   
--   <pre>
--   &gt;&gt;&gt; s &lt;- forkInteractiveScheduler Control.Eff.Concurrent.Process.SingleThreadedScheduler.defaultMain
--   </pre>
--   
--   <pre>
--   &gt;&gt;&gt; fooPid &lt;- submit s (spawn (foreverCheap (receiveAnyMessage SP &gt;&gt;= (logMsg . fromMaybe "Huh!??" . fromDynamic))))
--   </pre>
--   
--   <pre>
--   &gt;&gt;&gt; fooPid
--   &lt;0.1.0&gt;
--   </pre>
--   
--   <pre>
--   &gt;&gt;&gt; submit s (sendMessageAs SP fooPid "test")
--   test
--   </pre>
--   
--   <pre>
--   &gt;&gt;&gt; submit s (sendShutdown SP fooPid)
--   </pre>
module Control.Eff.Concurrent.Process.Interactive

-- | Contains the communication channels to interact with a scheduler
--   running in its' own thread.
data SchedulerSession r

-- | Fork a scheduler with a process that communicates with it via
--   <a>MVar</a>, which is also the reason for the <tt>Lift IO</tt>
--   constraint.
forkInteractiveScheduler :: forall r. SetMember Lift (Lift IO) r => (Eff (InterruptableProcess r) () -> IO ()) -> IO (SchedulerSession r)

-- | Exit the scheduler immediately using an asynchronous exception.
killInteractiveScheduler :: SchedulerSession r -> IO ()

-- | Send a <a>Process</a> effect to the main process of a scheduler, this
--   blocks until the effect is executed.
submit :: forall r a. SetMember Lift (Lift IO) r => SchedulerSession r -> Eff (InterruptableProcess r) a -> IO a

-- | Combination of <a>submit</a> and <a>cast</a>.
submitCast :: forall o r. (SetMember Lift (Lift IO) r, Typeable o, PrettyTypeShow (ToPretty o), NFData (Api o  'Asynchronous), Member Interrupts r) => SchedulerSession r -> Server o -> Api o  'Asynchronous -> IO ()

-- | Combination of <a>submit</a> and <a>cast</a>.
submitCall :: forall o q r. (SetMember Lift (Lift IO) r, Typeable o, PrettyTypeShow (ToPretty o), Typeable q, NFData q, Show q, Member Interrupts r, NFData (Api o ( 'Synchronous q))) => SchedulerSession r -> Server o -> Api o ( 'Synchronous q) -> IO q


-- | A process supervisor spawns and monitors child processes.
--   
--   The child processes are mapped to symbolic identifier values:
--   Child-IDs.
--   
--   This is the barest, most minimal version of a supervisor. Children can
--   be started, but not restarted.
--   
--   Children can efficiently be looked-up by an id-value, and when the
--   supervisor is shutdown, all children will be shutdown these are
--   actually all the features of this supervisor implementation.
--   
--   Also, this minimalist supervisor only knows how to spawn a single kind
--   of child process.
--   
--   When a supervisor spawns a new child process, it expects the child
--   process to return a <a>ProcessId</a>. The supervisor will
--   <a>monitor</a> the child process.
--   
--   This is in stark contrast to how Erlang/OTP handles things; In the OTP
--   Supervisor, the child has to link to the parent. This allows the child
--   spec to be more flexible in that no <tt>pid</tt> has to be passed from
--   the child start function to the supervisor process, and also, a child
--   may break free from the supervisor by unlinking.
--   
--   Now while this seems nice at first, this might actually cause
--   surprising results, since it is usually expected that stopping a
--   supervisor also stops the children, or that a child exit shows up in
--   the logging originating from the former supervisor.
--   
--   The approach here is to allow any child to link to the supervisor to
--   realize when the supervisor was violently killed, and otherwise give
--   the child no chance to unlink itself from its supervisor.
--   
--   This module is far simpler than the Erlang/OTP counter part, of a
--   <tt>simple_one_for_one</tt> supervisor.
--   
--   The future of this supervisor might not be a-lot more than it
--   currently is. The ability to restart processes might be implemented
--   outside of this supervisor module.
--   
--   One way to do that is to implement the restart logic in a seperate
--   module, since the child-id can be reused when a child exits.
module Control.Eff.Concurrent.Api.Supervisor

-- | <a>Api</a> type for supervisor processes.
--   
--   The <i>supervisor</i> process contains a <a>SpawnFun</a> from which it
--   can spawn new child processes.
--   
--   The supervisor maps an identifier value of type <tt>childId</tt> to a
--   <a>ProcessId</a> and a <tt>spawnResult</tt> type.
--   
--   This <tt>spawnResult</tt> is likely a tuple of <a>Server</a> process
--   ids that allow type-safe interaction with the process.
--   
--   Also, this serves as handle or reference for interacting with a
--   supervisor process.
--   
--   A value of this type is returned by <a>startSupervisor</a>
data Sup childId spawnResult

-- | A function that will initialize the child process.
--   
--   The process-id returned from this function is kept private, but it is
--   possible to return '(ProcessId, ProcessId)' for example.
--   
--   The function is expected to return a value - usually a tuple of
--   <a>Server</a> values for the different aspects of a process, such as
--   sending API requests, managing observers and receiving other auxiliary
--   API messages.
type SpawnFun i e o = i -> Eff e (o, ProcessId)

-- | Options that control the 'Sup i o' process.
--   
--   This contains:
--   
--   <ul>
--   <li>a <a>SpawnFun</a></li>
--   <li>the <a>Timeout</a> after requesting a normal child exit before
--   brutally killing the child.</li>
--   </ul>
data SupConfig i e o
MkSupConfig :: SpawnFun i e o -> Timeout -> SupConfig i e o
supConfigChildStopTimeout :: forall i_a16I9 e_a16Ia o_a16Ib. Lens' (SupConfig i_a16I9 e_a16Ia o_a16Ib) Timeout
supConfigSpawnFun :: forall i_a16I9 e_a16Ia o_a16Ib i_a16Ja e_a16Jb o_a16Jc. Lens (SupConfig i_a16I9 e_a16Ia o_a16Ib) (SupConfig i_a16Ja e_a16Jb o_a16Jc) (SpawnFun i_a16I9 e_a16Ia o_a16Ib) (SpawnFun i_a16Ja e_a16Jb o_a16Jc)

-- | Runtime-Errors occurring when spawning child-processes.
data SpawnErr i o
AlreadyStarted :: i -> o -> SpawnErr i o

-- | Start and link a new supervisor process with the given
--   <a>SpawnFun</a>unction.
--   
--   To spawn new child processes use <a>spawnChild</a>.
startSupervisor :: forall i e o. (HasCallStack, Member Logs e, Lifted IO e, Ord i, Tangible i, Tangible o) => SupConfig i (InterruptableProcess e) o -> Eff (InterruptableProcess e) (Sup i o)

-- | Stop the supervisor and shutdown all processes.
--   
--   Block until the supervisor has finished.
stopSupervisor :: (HasCallStack, Member Interrupts e, SetMember Process (Process q0) e, Member Logs e, Lifted IO e, Ord i, Tangible i, Tangible o) => Sup i o -> Eff e ()

-- | Check if a supervisor process is still alive.
isSupervisorAlive :: (HasCallStack, Member Interrupts e, Member Logs e, Typeable i, Typeable o, NFData i, NFData o, Show i, Show o, SetMember Process (Process q0) e) => Sup i o -> Eff e Bool

-- | Monitor a supervisor process.
monitorSupervisor :: (HasCallStack, Member Interrupts e, Member Logs e, Typeable i, Typeable o, NFData i, NFData o, Show i, Show o, SetMember Process (Process q0) e) => Sup i o -> Eff e MonitorReference

-- | Return a <a>Text</a> describing the current state of the supervisor.
getDiagnosticInfo :: (Ord i, Tangible i, Tangible o, Typeable e, HasCallStack, Member Interrupts e, SetMember Process (Process q0) e) => Sup i o -> Eff e Text

-- | Start, link and monitor a new child process using the <a>SpawnFun</a>
--   passed to <a>startSupervisor</a>.
spawnChild :: (HasCallStack, Member Interrupts e, Member Logs e, Ord i, Tangible i, Tangible o, SetMember Process (Process q0) e) => Sup i o -> i -> Eff e (Either (SpawnErr i o) o)

-- | Lookup the given child-id and return the output value of the
--   <a>SpawnFun</a> if the client process exists.
lookupChild :: (HasCallStack, Member Interrupts e, Member Logs e, Ord i, Tangible i, Tangible o, SetMember Process (Process q0) e) => Sup i o -> i -> Eff e (Maybe o)

-- | Stop a child process, and block until the child has exited.
--   
--   Return <a>True</a> if a process with that ID was found, <a>False</a>
--   if no process with the given ID was running.
stopChild :: (HasCallStack, Member Interrupts e, Member Logs e, Ord i, Tangible i, Tangible o, SetMember Process (Process q0) e) => Sup i o -> i -> Eff e Bool
instance GHC.Generics.Generic (Control.Eff.Concurrent.Api.Supervisor.SpawnErr i o)
instance (GHC.Show.Show i, GHC.Show.Show o) => GHC.Show.Show (Control.Eff.Concurrent.Api.Supervisor.SpawnErr i o)
instance (GHC.Classes.Ord i, GHC.Classes.Ord o) => GHC.Classes.Ord (Control.Eff.Concurrent.Api.Supervisor.SpawnErr i o)
instance (GHC.Classes.Eq i, GHC.Classes.Eq o) => GHC.Classes.Eq (Control.Eff.Concurrent.Api.Supervisor.SpawnErr i o)
instance forall k1 (childId :: k1) k2 (spawnResult :: k2). Control.DeepSeq.NFData (Control.Eff.Concurrent.Api.Supervisor.Sup childId spawnResult)
instance forall k1 (childId :: k1) k2 (spawnResult :: k2). GHC.Classes.Eq (Control.Eff.Concurrent.Api.Supervisor.Sup childId spawnResult)
instance forall k1 (childId :: k1) k2 (spawnResult :: k2). GHC.Classes.Ord (Control.Eff.Concurrent.Api.Supervisor.Sup childId spawnResult)
instance (Control.DeepSeq.NFData i, Control.DeepSeq.NFData o) => Control.DeepSeq.NFData (Control.Eff.Concurrent.Api.Supervisor.SpawnErr i o)
instance forall k1 k2 (childId :: k2) (spawnResult :: k1). (Data.Type.Pretty.PrettyTypeShow (Data.Type.Pretty.ToPretty childId), Data.Type.Pretty.PrettyTypeShow (Data.Type.Pretty.ToPretty spawnResult)) => GHC.Show.Show (Control.Eff.Concurrent.Api.Supervisor.Sup childId spawnResult)
instance forall k i (o :: k) r. GHC.Show.Show i => GHC.Show.Show (Control.Eff.Concurrent.Api.Api (Control.Eff.Concurrent.Api.Supervisor.Sup i o) ('Control.Eff.Concurrent.Api.Synchronous r))
instance forall k i (o :: k) r. Control.DeepSeq.NFData i => Control.DeepSeq.NFData (Control.Eff.Concurrent.Api.Api (Control.Eff.Concurrent.Api.Supervisor.Sup i o) ('Control.Eff.Concurrent.Api.Synchronous r))


-- | Observer Effects
--   
--   This module supports the implementation of observers and observables.
--   Expected use case is event propagation.
module Control.Eff.Concurrent.Api.Observer

-- | Describes a process that observes another via <a>Asynchronous</a>
--   <a>Api</a> messages.
--   
--   An observer consists of a filter and a process id. The filter converts
--   an observation to a message understood by the observer process, and
--   the <a>ProcessId</a> is used to send the message.
data Observer o
[Observer] :: (PrettyTypeShow (ToPretty p), Show (Server p), Typeable p, Typeable o, NFData o, NFData (Api p  'Asynchronous)) => (o -> Maybe (Api p  'Asynchronous)) -> Server p -> Observer o

-- | This data family defines an API, a communication interface description
--   between at least two processes. The processes act as <b>servers</b> or
--   <b>client(s)</b> regarding a specific instance of this type.
--   
--   The first parameter is usually a user defined phantom type that
--   identifies the <a>Api</a> instance.
--   
--   The second parameter specifies if a specific constructor of an
--   (GADT-like) <tt>Api</tt> instance is <a>Synchronous</a>, i.e. returns
--   a result and blocks the caller or if it is <a>Asynchronous</a>
--   
--   Also, for better logging, the an instance of <a>ToPretty</a> for the
--   <a>Api</a> index type must be given.
--   
--   Example:
--   
--   <pre>
--   data BookShop deriving Typeable
--   
--   data instance Api BookShop r where
--     RentBook  :: BookId   -&gt; Api BookShop ('Synchronous (Either RentalError RentalId))
--     BringBack :: RentalId -&gt; Api BookShop 'Asynchronous
--   
--   type instance ToPretty BookShop = PutStr "book shop"
--   
--   type BookId = Int
--   type RentalId = Int
--   type RentalError = String
--   </pre>
data family Api (api :: Type) (reply :: Synchronicity)

-- | And an <a>Observer</a> to the set of recipients for all observations
--   reported by <a>observed</a>. Note that the observers are keyed by the
--   observing process, i.e. a previous entry for the process contained in
--   the <a>Observer</a> is overwritten. If you want multiple entries for a
--   single process, just combine several filter functions.
registerObserver :: (SetMember Process (Process q) r, HasCallStack, Member Interrupts r, Typeable o, NFData o, PrettyTypeShow (ToPretty o)) => Observer o -> Server (ObserverRegistry o) -> Eff r ()

-- | Send the <a>ForgetObserver</a> message
forgetObserver :: (SetMember Process (Process q) r, HasCallStack, Member Interrupts r, Typeable o, NFData o, PrettyTypeShow (ToPretty o)) => Observer o -> Server (ObserverRegistry o) -> Eff r ()

-- | Based on the <a>Api</a> instance for <a>Observer</a> this simplified
--   writing a callback handler for observations. In order to register to
--   and <a>ObserverRegistry</a> use <a>toObserver</a>.
handleObservations :: (HasCallStack, Typeable o, SetMember Process (Process q) r, NFData (Observer o)) => (o -> Eff r (CallbackResult  'Recoverable)) -> MessageCallback (Observer o) r

-- | Use a <a>Server</a> as an <a>Observer</a> for
--   <a>handleObservations</a>.
toObserver :: (NFData o, Typeable o, NFData (Api (Observer o)  'Asynchronous), PrettyTypeShow (ToPretty o)) => Server (Observer o) -> Observer o

-- | Create an <a>Observer</a> that conditionally accepts all observations
--   of the given type and applies the given function to them; the function
--   takes an observation and returns an <a>Api</a> cast that the observer
--   server is compatible to.
toObserverFor :: (Typeable a, PrettyTypeShow (ToPretty a), NFData (Api a  'Asynchronous), Typeable o, NFData o) => (o -> Api a  'Asynchronous) -> Server a -> Observer o

-- | An <a>Api</a> for managing <a>Observer</a>s, encompassing registration
--   and de-registration of <a>Observer</a>s.
data ObserverRegistry o

-- | Alias for the effect that contains the observers managed by
--   <a>manageObservers</a>
type ObserverState o = State (Observers o)

-- | Provide the implementation for the <a>ObserverRegistry</a> Api, this
--   handled <a>RegisterObserver</a> and <a>ForgetObserver</a> messages. It
--   also adds the <a>ObserverState</a> constraint to the effect list.
handleObserverRegistration :: forall o q r. (HasCallStack, Typeable o, SetMember Process (Process q) r, Member (ObserverState o) r, Member Logs r) => MessageCallback (ObserverRegistry o) r

-- | Keep track of registered <a>Observer</a>s.
--   
--   Handle the <a>ObserverState</a> introduced by
--   <a>handleObserverRegistration</a>.
manageObservers :: Eff (ObserverState o : r) a -> Eff r a

-- | Report an observation to all observers. The process needs to
--   <a>manageObservers</a> and to <a>handleObserverRegistration</a>.
observed :: forall o r q. (SetMember Process (Process q) r, PrettyTypeShow (ToPretty o), Member (ObserverState o) r, Member Interrupts r) => o -> Eff r ()
instance forall k (o :: k) (r :: Control.Eff.Concurrent.Api.Synchronicity). Control.DeepSeq.NFData (Control.Eff.Concurrent.Api.Api (Control.Eff.Concurrent.Api.Observer.ObserverRegistry o) r)
instance Control.DeepSeq.NFData o => Control.DeepSeq.NFData (Control.Eff.Concurrent.Api.Observer.Observer o)
instance GHC.Show.Show (Control.Eff.Concurrent.Api.Observer.Observer o)
instance GHC.Classes.Ord (Control.Eff.Concurrent.Api.Observer.Observer o)
instance GHC.Classes.Eq (Control.Eff.Concurrent.Api.Observer.Observer o)
instance Control.DeepSeq.NFData o => Control.DeepSeq.NFData (Control.Eff.Concurrent.Api.Api (Control.Eff.Concurrent.Api.Observer.Observer o) 'Control.Eff.Concurrent.Api.Asynchronous)


-- | A small process to capture and _share_ observation's by enqueueing
--   them into an STM <a>TBQueue</a>.
module Control.Eff.Concurrent.Api.Observer.Queue

-- | Contains a <a>TBQueue</a> capturing observations. See
--   <a>spawnLinkObservationQueueWriter</a>, <a>readObservationQueue</a>.
data ObservationQueue a

-- | A <a>Reader</a> for an <a>ObservationQueue</a>.
type ObservationQueueReader a = Reader (ObservationQueue a)

-- | Read queued observations captured and enqueued in the shared
--   <a>TBQueue</a> by <a>spawnLinkObservationQueueWriter</a>. This blocks
--   until something was captured or an interrupt or exceptions was thrown.
--   For a non-blocking variant use <a>tryReadObservationQueue</a> or
--   <a>flushObservationQueue</a>.
readObservationQueue :: forall o r. (Member (ObservationQueueReader o) r, HasCallStack, MonadIO (Eff r), Typeable o, Member Logs r) => Eff r o

-- | Read queued observations captured and enqueued in the shared
--   <a>TBQueue</a> by <a>spawnLinkObservationQueueWriter</a>. Return the
--   oldest enqueued observation immediately or <a>Nothing</a> if the queue
--   is empty. Use <a>readObservationQueue</a> to block until an
--   observation is observed.
tryReadObservationQueue :: forall o r. (Member (ObservationQueueReader o) r, HasCallStack, MonadIO (Eff r), Typeable o, Member Logs r) => Eff r (Maybe o)

-- | Read at once all currently queued observations captured and enqueued
--   in the shared <a>TBQueue</a> by
--   <a>spawnLinkObservationQueueWriter</a>. This returns immediately all
--   currently enqueued observations. For a blocking variant use
--   <a>readObservationQueue</a>.
flushObservationQueue :: forall o r. (Member (ObservationQueueReader o) r, HasCallStack, MonadIO (Eff r), Typeable o, Member Logs r) => Eff r [o]

-- | Create a mutable queue for observations. Use
--   <a>spawnLinkObservationQueueWriter</a> for a simple way to get a
--   process that enqueues all observations.
--   
--   <h4><b>Example</b></h4>
--   
--   <pre>
--   withObservationQueue 100 $ do
--     q  &lt;- ask @(ObservationQueueReader TestEvent)
--     wq &lt;- spawnLinkObservationQueueWriter q
--     registerObserver wq testServer
--     ...
--     cast testServer DoSomething
--     evt &lt;- readObservationQueue @TestEvent
--     ...
--   </pre>
withObservationQueue :: forall o b e len. (HasCallStack, Typeable o, Show o, Member Logs e, Lifted IO e, Integral len, Member Interrupts e) => len -> Eff (ObservationQueueReader o : e) b -> Eff e b

-- | Spawn a process that can be used as an <a>Observer</a> that enqueues
--   the observations into an <a>ObservationQueue</a>. See
--   <a>withObservationQueue</a> for an example.
--   
--   The observations can be obtained by <a>readObservationQueue</a>. All
--   observations are captured up to the queue size limit, such that the
--   first message received will be first message returned by
--   <a>readObservationQueue</a>.
spawnLinkObservationQueueWriter :: forall o q. (Tangible o, NFData (Api (Observer o)  'Asynchronous), Member Logs q, Lifted IO q, HasCallStack) => ObservationQueue o -> Eff (InterruptableProcess q) (Observer o)


-- | Capture <a>LogMessage</a>s to a <a>Writer</a>.
--   
--   See <a>exampleLogCapture</a>
module Control.Eff.LogWriter.Capture

-- | A <a>LogWriter</a> monad that provides pure logging by capturing via
--   the <a>Writer</a> effect.
--   
--   See <a>exampleLogCapture</a>
captureLogWriter :: LogWriter CaptureLogs

-- | A <a>LogWriter</a> monad that provides pure logging by capturing via
--   the <a>Writer</a> effect.
newtype CaptureLogs a
MkCaptureLogs :: Eff '[CaptureLogWriter] a -> CaptureLogs a
[unCaptureLogs] :: CaptureLogs a -> Eff '[CaptureLogWriter] a

-- | Alias for the <a>Writer</a> that contains the captured
--   <a>LogMessage</a>s from <a>CaptureLogs</a>.
type CaptureLogWriter = Writer LogMessage

-- | Run a <a>Writer</a> for <a>LogMessage</a>s.
--   
--   Such a <a>Writer</a> is needed to handle <a>CaptureLogWriter</a>
runCaptureLogWriter :: Eff (CaptureLogWriter : e) a -> Eff e (a, [LogMessage])
instance GHC.Base.Monad Control.Eff.LogWriter.Capture.CaptureLogs
instance GHC.Base.Applicative Control.Eff.LogWriter.Capture.CaptureLogs
instance GHC.Base.Functor Control.Eff.LogWriter.Capture.CaptureLogs
instance Control.Eff.Log.Writer.HandleLogWriter Control.Eff.LogWriter.Capture.CaptureLogs


-- | Functions for generic, IO-based <a>LogWriter</a>s.
--   
--   This module is more low-level than the others in this directory.
module Control.Eff.LogWriter.IO

-- | A <a>LogWriter</a> that uses an <a>IO</a> action to write the message.
--   
--   This is just an alias for <a>MkLogWriter</a> but with <tt>IO</tt> as
--   parameter. This reduces the need to apply something to the extra type
--   argument <tt>@IO</tt>.
--   
--   Example use cases for this function are the <tt>consoleLogWriter</tt>
--   and the <a>ioHandleLogWriter</a>.
mkLogWriterIO :: HasCallStack => (LogMessage -> IO ()) -> LogWriter IO

-- | A <a>LogWriter</a> that renders <a>LogMessage</a>s to strings via
--   <a>renderLogMessageConsoleLog</a> and prints them to an <a>Handle</a>
--   using <tt>hPutStrLn</tt>.
ioHandleLogWriter :: HasCallStack => Handle -> LogWriter IO

-- | Decorate an IO based <a>LogWriter</a> to fill out these fields in
--   <a>LogMessage</a>s:
--   
--   <ul>
--   <li>The messages will carry the given application name in the
--   <a>lmAppName</a> field.</li>
--   <li>The <a>lmTimestamp</a> field contains the UTC time of the log
--   event</li>
--   <li>The <a>lmHostname</a> field contains the FQDN of the current
--   host</li>
--   <li>The <a>lmFacility</a> field contains the given
--   <a>Facility</a></li>
--   </ul>
--   
--   It works by using <a>mappingLogWriterM</a>.
defaultIoLogWriter :: Text -> Facility -> LogWriter IO -> LogWriter IO

-- | Enable logging to IO using the <a>defaultIoLogWriter</a>.
--   
--   Example:
--   
--   <pre>
--   exampleWithIoLogging :: IO ()
--   exampleWithIoLogging =
--       runLift
--     $ withIoLogging debugTraceLogWriter
--                     "my-app"
--                     local7
--                     (lmSeverityIsAtLeast informationalSeverity)
--     $ logInfo "Oh, hi there"
--   </pre>
withIoLogging :: SetMember Lift (Lift IO) e => LogWriter IO -> Text -> Facility -> LogPredicate -> Eff (Logs : (LogWriterReader IO : e)) a -> Eff e a

-- | The concrete list of <a>Eff</a>ects for logging with an IO based
--   <a>LogWriter</a>, and a <a>LogWriterReader</a>.
type LoggingAndIo = '[Logs, LogWriterReader IO, Lift IO]

-- | Render a <a>LogMessage</a> but set the timestamp and thread id fields.
printLogMessage :: LogMessage -> IO ()


-- | This helps to setup logging to a <i>file</i>.
module Control.Eff.LogWriter.File

-- | Enable logging to a file, with some <a>LogMessage</a> fields preset as
--   described in <a>withIoLogging</a>.
--   
--   If the file or its directory does not exist, it will be created.
--   
--   Example:
--   
--   <pre>
--   exampleWithFileLogging :: IO ()
--   exampleWithFileLogging =
--       runLift
--     $ withFileLogging "/var/log/my-app.log" "my-app" local7 allLogMessages
--     $ logInfo "Oh, hi there"
--   </pre>
--   
--   To vary the <a>LogWriter</a> use <a>withIoLogging</a>.
withFileLogging :: (Lifted IO e, MonadBaseControl IO (Eff e)) => FilePath -> Text -> Facility -> LogPredicate -> Eff (Logs : (LogWriterReader IO : e)) a -> Eff e a

-- | Enable logging to a file.
--   
--   If the file or its directory does not exist, it will be created.
--   Example:
--   
--   <pre>
--   exampleWithFileLogWriter :: IO ()
--   exampleWithFileLogWriter =
--       runLift
--     $ withSomeLogging @IO
--     $ withFileLogWriter "test.log"
--     $ logInfo "Oh, hi there"
--   </pre>
withFileLogWriter :: (Lifted IO e, LogsTo IO e, MonadBaseControl IO (Eff e)) => FilePath -> Eff e b -> Eff e b


-- | This helps to setup logging via <a>Debug.Trace</a>.
module Control.Eff.LogWriter.DebugTrace

-- | Enable logging via <a>traceM</a> using the <a>debugTraceLogWriter</a>.
--   The logging monad type can be <i>any</i> type with a <a>Monad</a>
--   instance.
--   
--   Log messages are rendered using <a>renderLogMessageConsoleLog</a>.
--   
--   Example:
--   
--   <pre>
--   exampleWithTraceLogWriter :: IO ()
--   exampleWithTraceLogWriter =
--       runLift
--     $ withSomeLogging @IO
--     $ withTraceLogWriter
--     $ logInfo "Oh, hi there"
--   </pre>
withTraceLogWriter :: forall h e a. (Monad h, LogsTo h e) => Eff e a -> Eff e a

-- | Enable logging via <a>traceM</a> using the <a>debugTraceLogWriter</a>,
--   with some <a>LogMessage</a> fields preset as in <a>withIoLogging</a>.
--   
--   Log messages are rendered using <a>renderLogMessageConsoleLog</a>.
--   
--   Example:
--   
--   <pre>
--   exampleWithTraceLogging :: IO ()
--   exampleWithTraceLogging =
--       runLift
--     $ withTraceLogging "my-app" local7 allLogMessages
--     $ logInfo "Oh, hi there"
--   </pre>
withTraceLogging :: Lifted IO e => Text -> Facility -> LogPredicate -> Eff (Logs : (LogWriterReader IO : e)) a -> Eff e a

-- | Write <a>LogMessage</a>s via <a>traceM</a>.
debugTraceLogWriter :: forall h. Monad h => LogMessageRenderer Text -> LogWriter h


-- | This helps to setup logging to <i>standard ouput</i>.
module Control.Eff.LogWriter.Console

-- | Enable logging to <tt>standard output</tt> using the
--   <a>consoleLogWriter</a>.
--   
--   Log messages are rendered using <a>renderLogMessageConsoleLog</a>.
--   
--   Example:
--   
--   <pre>
--   exampleWithConsoleLogWriter :: IO ()
--   exampleWithConsoleLogWriter =
--       runLift
--     $ withSomeLogging @IO
--     $ withConsoleLogWriter
--     $ logInfo "Oh, hi there"
--   </pre>
withConsoleLogWriter :: (LogsTo IO e, Lifted IO e) => Eff e a -> Eff e a

-- | Enable logging to <tt>standard output</tt> using the
--   <a>consoleLogWriter</a>, with some <a>LogMessage</a> fields preset as
--   in <a>withIoLogging</a>.
--   
--   Log messages are rendered using <a>renderLogMessageConsoleLog</a>.
--   
--   Example:
--   
--   <pre>
--   exampleWithConsoleLogging :: IO ()
--   exampleWithConsoleLogging =
--       runLift
--     $ withConsoleLogging "my-app" local7 allLogMessages
--     $ logInfo "Oh, hi there"
--   </pre>
--   
--   To vary the <a>LogWriter</a> use <a>withIoLogging</a>.
withConsoleLogging :: Lifted IO e => Text -> Facility -> LogPredicate -> Eff (Logs : (LogWriterReader IO : e)) a -> Eff e a

-- | Write <a>LogMessage</a>s to standard output, formatted with
--   <a>printLogMessage</a>.
--   
--   It uses <a>stdoutLogWriter</a> with <a>renderLogMessageConsoleLog</a>.
consoleLogWriter :: LogWriter IO

-- | A <a>LogWriter</a> that uses a <a>LogMessageRenderer</a> to render,
--   and <a>putStrLn</a> to print it.
stdoutLogWriter :: LogMessageRenderer Text -> LogWriter IO


-- | This module only exposes a <a>LogWriter</a> for asynchronous logging;
module Control.Eff.LogWriter.Async

-- | <i>Move</i> the current <a>LogWriter</a> into its own thread.
--   
--   A bounded queue is used to forward logs to the process.
--   
--   If an exception is received, the logging process will be killed.
--   
--   Log messages are deeply evaluated before being sent to the logger
--   process, to prevent that lazy evaluation leads to heavy work being
--   done in the logger process instead of the caller process.
--   
--   Example:
--   
--   <pre>
--   exampleAsyncLogWriter :: IO ()
--   exampleAsyncLogWriter =
--       runLift
--     $ withLogging consoleLogWriter
--     $ withAsyncLogWriter (1000::Int)
--     $ do logMsg "test 1"
--          logMsg "test 2"
--          logMsg "test 3"
--   </pre>
withAsyncLogWriter :: (LogsTo IO e, Lifted IO e, MonadBaseControl IO (Eff e), Integral len) => len -> Eff e a -> Eff e a

-- | This is a wrapper around <a>withAsyncLogWriter</a> and
--   <a>withIoLogging</a>.
--   
--   Example:
--   
--   <pre>
--   exampleWithAsyncLogging :: IO ()
--   exampleWithAsyncLogging =
--       runLift
--     $ withAsyncLogWriter consoleLogWriter (1000::Int) "my-app" local0 allLogMessages
--     $ do logMsg "test 1"
--          logMsg "test 2"
--          logMsg "test 3"
--   </pre>
withAsyncLogging :: (Lifted IO e, MonadBaseControl IO (Eff e), Integral len) => LogWriter IO -> len -> Text -> Facility -> LogPredicate -> Eff (Logs : (LogWriterReader IO : e)) a -> Eff e a


-- | A coroutine based, single threaded scheduler for <a>Process</a>es.
module Control.Eff.Concurrent.Process.SingleThreadedScheduler

-- | Handle the <a>Process</a> effect, as well as all lower effects using
--   an effect handler function.
--   
--   Execute the <b>main</b> <a>Process</a> and all the other processes
--   <a>spawn</a>ed by it in the current thread concurrently, using a
--   co-routine based, round-robin scheduler. If a process exits with eg.g
--   <a>exitNormally</a> or <a>exitWithError</a> or is killed by another
--   process <tt>Left ...</tt> is returned. Otherwise, the result will be
--   wrapped in a <tt>Right</tt>.
--   
--   Every time a process _yields_ the effects are evaluated down to the a
--   value of type <tt>m (Either String a)</tt>.
--   
--   If the evaluator function runs the action down e.g. <tt>IO</tt> this
--   might improve memory consumption, for long running services, with
--   processes that loop endlessly.
scheduleM :: forall m r a. Monad m => (forall b. Eff r b -> m b) -> m () -> Eff (InterruptableProcess r) a -> m (Either (Interrupt  'NoRecovery) a)

-- | Like <a>scheduleIO</a> but <i>pure</i>. The <tt>yield</tt> effect is
--   just <tt>return ()</tt>. <tt>schedulePure == runIdentity .
--   <a>scheduleM</a> (Identity . run) (return ())</tt>
schedulePure :: Eff (InterruptableProcess '[Logs, LogWriterReader PureLogWriter]) a -> Either (Interrupt  'NoRecovery) a

-- | Invoke <a>scheduleM</a> with <tt>lift <a>yield</a></tt> as yield
--   effect. <tt>scheduleIO runEff == <a>scheduleM</a> (runLift . runEff)
--   (liftIO <a>yield</a>)</tt>
scheduleIO :: MonadIO m => (forall b. Eff r b -> Eff '[Lift m] b) -> Eff (InterruptableProcess r) a -> m (Either (Interrupt  'NoRecovery) a)

-- | Invoke <a>scheduleM</a> with <tt>lift <a>yield</a></tt> as yield
--   effect. <tt>scheduleMonadIOEff == <a>scheduleM</a> id (liftIO
--   <a>yield</a>)</tt>
scheduleMonadIOEff :: MonadIO (Eff r) => Eff (InterruptableProcess r) a -> Eff r (Either (Interrupt  'NoRecovery) a)

-- | Run processes that have the <a>Logs</a> and the <a>Lift</a> effects.
--   The user must provide a log handler function.
--   
--   Log messages are evaluated strict.
--   
--   <pre>
--   scheduleIOWithLogging == <a>scheduleIO</a> . <a>withLogging</a>
--   </pre>
scheduleIOWithLogging :: HasCallStack => LogWriter IO -> Eff (InterruptableProcess LoggingAndIo) a -> IO (Either (Interrupt  'NoRecovery) a)

-- | Execute a <a>Process</a> using <a>scheduleM</a> on top of <a>Lift</a>
--   <tt>IO</tt> and <a>withLogging</a> <tt>String</tt> effects.
defaultMainSingleThreaded :: HasCallStack => Eff (InterruptableProcess LoggingAndIo) () -> IO ()
instance GHC.Show.Show (Control.Eff.Concurrent.Process.SingleThreadedScheduler.OnYield r a)
instance GHC.Show.Show (Control.Eff.Concurrent.Process.SingleThreadedScheduler.STS r m)


-- | Implement Erlang style message passing concurrency.
--   
--   This module contains <a>spawn</a> which handles the <a>Process</a>
--   effects, using <a>TQueue</a>s and <a>withAsync</a>.
--   
--   This aims to be a pragmatic implementation, so even logging is
--   supported.
--   
--   At the core is a <i>main process</i> that enters <a>schedule</a> and
--   creates all of the internal state stored in <a>TVar</a>s to manage
--   processes with message queues.
module Control.Eff.Concurrent.Process.ForkIOScheduler

-- | This is the main entry point to running a message passing concurrency
--   application. This function takes a <a>Process</a> on top of the
--   <a>SchedulerIO</a> effect for concurrent logging.
schedule :: HasCallStack => Eff InterruptableProcEff () -> Eff LoggingAndIo ()

-- | Start the message passing concurrency system then execute a
--   <a>Process</a> on top of <a>SchedulerIO</a> effect. All logging is
--   sent to standard output.
defaultMain :: HasCallStack => Eff InterruptableProcEff () -> IO ()

-- | Start the message passing concurrency system then execute a
--   <a>Process</a> on top of <a>SchedulerIO</a> effect. All logging is
--   sent to standard output.
defaultMainWithLogWriter :: HasCallStack => LogWriter IO -> Eff InterruptableProcEff () -> IO ()

-- | The concrete list of <a>Eff</a>ects of processes compatible with this
--   scheduler. This builds upon <a>SchedulerIO</a>.
type ProcEff = ConsProcess SchedulerIO

-- | The concrete list of the effects, that the <a>Process</a> uses
type InterruptableProcEff = InterruptableProcess SchedulerIO

-- | The concrete list of <a>Eff</a>ects for this scheduler implementation.
type SchedulerIO = (Reader SchedulerState : LoggingAndIo)

-- | Type class constraint to indicate that an effect union contains the
--   effects required by every process and the scheduler implementation
--   itself.
type HasSchedulerIO r = (HasCallStack, Lifted IO r, SchedulerIO <:: r)
instance GHC.Show.Show Control.Eff.Concurrent.Process.ForkIOScheduler.ProcessInfo
instance Data.Default.Class.Default Control.Eff.Concurrent.Process.ForkIOScheduler.MessageQ


-- | This helps to setup logging to <i>standard ouput</i>.
module Control.Eff.LogWriter.UDP

-- | Enable logging to a (remote-) host via UDP.
--   
--   See <a>exampleUdpRFC3164Logging</a>
withUDPLogWriter :: (Lifted IO e, LogsTo IO e, MonadBaseControl IO (Eff e), HasCallStack) => (LogMessage -> Text) -> String -> String -> Eff e b -> Eff e b

-- | Enable logging to a remote host via <b>UDP</b>, with some
--   <a>LogMessage</a> fields preset as in <a>withIoLogging</a>.
--   
--   See <a>exampleUdpRFC3164Logging</a>
withUDPLogging :: (HasCallStack, MonadBaseControl IO (Eff e), Lifted IO e) => (LogMessage -> Text) -> String -> String -> Text -> Facility -> LogPredicate -> Eff (Logs : (LogWriterReader IO : e)) a -> Eff e a


-- | This helps to setup logging to <i>standard ouput</i>.
module Control.Eff.LogWriter.UnixSocket

-- | Enable logging to a (remote-) host via UnixSocket.
--   
--   See <a>exampleDevLogSyslogLogging</a>
withUnixSocketLogWriter :: (Lifted IO e, LogsTo IO e, MonadBaseControl IO (Eff e), HasCallStack) => LogMessageRenderer Text -> FilePath -> Eff e b -> Eff e b

-- | Enable logging to a <i>unix domain socket</i>, with some
--   <a>LogMessage</a> fields preset as in <a>withIoLogging</a>.
--   
--   See <a>exampleDevLogSyslogLogging</a>
withUnixSocketLogging :: (HasCallStack, MonadBaseControl IO (Eff e), Lifted IO e) => LogMessageRenderer Text -> FilePath -> Text -> Facility -> LogPredicate -> Eff (Logs : (LogWriterReader IO : e)) a -> Eff e a


-- | Examples for Logging.
module Control.Eff.Log.Examples

-- | Example code for:
--   
--   <ul>
--   <li><a>withConsoleLogging</a></li>
--   <li><a>mkLogWriterIO</a> See <a>loggingExampleClient</a></li>
--   </ul>
exampleLogging :: HasCallStack => IO ()

-- | Example code for:
--   
--   <ul>
--   <li><a>withLogging</a></li>
--   <li><a>consoleLogWriter</a></li>
--   </ul>
exampleWithLogging :: HasCallStack => IO ()

-- | Example code for:
--   
--   <ul>
--   <li><a>withSomeLogging</a></li>
--   <li><a>PureLogWriter</a></li>
--   <li><a>logDebug</a></li>
--   </ul>
exampleWithSomeLogging :: HasCallStack => ()

-- | Example code for:
--   
--   <ul>
--   <li><a>setLogPredicate</a></li>
--   <li><a>modifyLogPredicate</a></li>
--   <li><a>lmMessageStartsWith</a></li>
--   <li><a>lmSeverityIs</a></li>
--   <li><a>lmSeverityIsAtLeast</a></li>
--   <li><a>includeLogMessages</a></li>
--   <li><a>excludeLogMessages</a></li>
--   </ul>
exampleLogPredicate :: HasCallStack => IO Int

-- | Example code for:
--   
--   <ul>
--   <li><a>runCaptureLogWriter</a></li>
--   <li><a>captureLogWriter</a></li>
--   <li><a>mappingLogWriter</a></li>
--   <li><a>filteringLogWriter</a></li>
--   </ul>
exampleLogCapture :: IO ()

-- | Example code for:
--   
--   <ul>
--   <li><a>withAsyncLogging</a></li>
--   </ul>
exampleAsyncLogging :: IO ()

-- | Example code for RFC5424 formatted logs.
exampleRFC5424Logging :: IO Int

-- | Example code for RFC3164 with RFC5424 time stamp formatted logs.
exampleRFC3164WithRFC5424TimestampsLogging :: IO Int

-- | Example code logging via a unix domain socket to
--   <tt><i>dev</i>log</tt>.
exampleDevLogSyslogLogging :: IO Int

-- | Example code logging via a unix domain socket to
--   <tt><i>dev</i>log</tt>.
exampleDevLogRFC5424Logging :: IO Int

-- | Example code logging RFC5424 via UDP port 514 on localhost.
exampleUdpRFC5424Logging :: IO Int

-- | Example code logging RFC5424 via UDP port 514 on localhost.
exampleUdpRFC3164Logging :: IO Int

-- | Example logging client code
--   
--   <ul>
--   <li><a>addLogWriter</a></li>
--   <li><a>debugTraceLogWriter</a></li>
--   <li><a>setLogPredicate</a></li>
--   <li><a>prefixLogMessagesWith</a></li>
--   <li><a>renderRFC3164</a></li>
--   <li><a>logMsg</a></li>
--   <li><a>logDebug</a></li>
--   <li><a>logError</a></li>
--   <li><a>logInfo</a></li>
--   <li><a>logWarning</a></li>
--   <li><a>logCritical</a></li>
--   <li><a>lmMessage</a></li>
--   </ul>
loggingExampleClient :: (HasCallStack, Monad h, LogsTo h e) => Eff e ()

-- | Example logging client code using many <a>LogPredicate</a>s.
--   
--   <ul>
--   <li><a>setLogPredicate</a></li>
--   <li><a>modifyLogPredicate</a></li>
--   <li><a>lmMessageStartsWith</a></li>
--   <li><a>lmSeverityIs</a></li>
--   <li><a>lmSeverityIsAtLeast</a></li>
--   <li><a>includeLogMessages</a></li>
--   <li><a>excludeLogMessages</a></li>
--   </ul>
logPredicatesExampleClient :: (HasCallStack, Monad h, LogsTo h e) => Eff e Int


-- | In rare occasions GHC optimizes innocent looking loops into
--   space-leaking monsters. See the discussion here: <a>GHC issue
--   13080</a> for more details, or <a>this blog post about space leaks in
--   nested loops</a>
--   
--   These functions in this module <b><i>might</i></b> help, at least in
--   conjunction with the <tt>-fno-full-laziness</tt> GHC option.
--   
--   There is a unit test in the sources of this module, which can be used
--   to do a comparative heap profiling of these function vs. their
--   counterparts in the <tt>base</tt> package.
--   
--   Here are the images of the profiling results, the images show that the
--   functions in this module do not leak space, compared to the original
--   functions (<a>forever</a> and <a>replicateM_</a>):
--   
module Control.Eff.Loop

-- | A version of <a>forever</a> that hopefully tricks GHC into
--   <b><i>not</i></b> creating a space leak. The intuition is, that we
--   want to do something that is <i>cheap</i>, and hence should be
--   <b>recomputed</b> instead of shared.
foreverCheap :: Monad m => m a -> m ()

-- | A version of <a>replicateM_</a> that hopefully tricks GHC into
--   <b><i>not</i></b> creating a space leak. The intuition is, that we
--   want to do something that is <i>cheap</i>, and hence should be
--   <b>recomputed</b> instead of shared.
replicateCheapM_ :: Monad m => Int -> m a -> m ()


-- | Erlang style processes with message passing concurrency based on
--   (more) <tt>extensible-effects</tt>.
module Control.Eff.Concurrent

-- | Each process is identified by a single process id, that stays constant
--   throughout the life cycle of a process. Also, message sending relies
--   on these values to address messages to processes.
newtype ProcessId
ProcessId :: Int -> ProcessId
[_fromProcessId] :: ProcessId -> Int

-- | A monitored process exited. This message is sent to a process by the
--   scheduler, when a process that was monitored died.
data ProcessDown
ProcessDown :: !MonitorReference -> !SomeExitReason -> ProcessDown
[downReference] :: ProcessDown -> !MonitorReference
[downReason] :: ProcessDown -> !SomeExitReason

-- | A value that contains a unique reference of a process monitoring.
data MonitorReference
MonitorReference :: Int -> ProcessId -> MonitorReference
[monitorIndex] :: MonitorReference -> Int
[monitoredProcess] :: MonitorReference -> ProcessId

-- | An existential wrapper around <a>Interrupt</a>
data SomeExitReason
[SomeExitReason] :: Interrupt x -> SomeExitReason

-- | This adds a layer of the <a>Interrupts</a> effect on top of
--   <a>ConsProcess</a>
type InterruptableProcess e = Interrupts : ConsProcess e

-- | <a>Exc</a>eptions containing <a>Interrupt</a>s. See
--   <a>handleInterrupts</a>, <a>exitOnInterrupt</a> or
--   <a>provideInterrupts</a>
type Interrupts = Exc (Interrupt  'Recoverable)

-- | <a>Interrupt</a>s which are <a>Recoverable</a>.
type RecoverableInterrupt = Interrupt  'Recoverable

-- | A sum-type with reasons for why a process operation, such as receiving
--   messages, is interrupted in the scheduling loop.
--   
--   This includes errors, that can occur when scheduling messages.
data Interrupt (t :: ExitRecovery)

-- | A process has finished a unit of work and might exit or work on
--   something else. This is primarily used for interrupting infinite
--   server loops, allowing for additional cleanup work before exiting
--   (e.g. with <a>ExitNormally</a>)
[NormalExitRequested] :: Interrupt  'Recoverable

-- | A process that should be running was not running.
[OtherProcessNotRunning] :: ProcessId -> Interrupt  'Recoverable

-- | A <a>Recoverable</a> timeout has occurred.
[TimeoutInterrupt] :: String -> Interrupt  'Recoverable

-- | A linked process is down
[LinkedProcessCrashed] :: ProcessId -> Interrupt  'Recoverable

-- | An exit reason that has an error message and is <a>Recoverable</a>.
[ErrorInterrupt] :: String -> Interrupt  'Recoverable

-- | A process function returned or exited without any error.
[ExitNormally] :: Interrupt  'NoRecovery

-- | An error causes the process to exit immediately. For example an
--   unexpected runtime exception was thrown, i.e. an exception derived
--   from <a>SomeException</a> Or a <a>Recoverable</a> Interrupt was not
--   recoverd.
[ExitUnhandledError] :: Text -> Interrupt  'NoRecovery

-- | A process shall exit immediately, without any cleanup was cancelled
--   (e.g. killed, in <a>cancel</a>)
[ExitProcessCancelled] :: Interrupt  'NoRecovery

-- | This value indicates whether a process exited in way consistent with
--   the planned behaviour or not.
data ExitSeverity
NormalExit :: ExitSeverity
Crash :: ExitSeverity

-- | This kind is used to indicate if a <a>Interrupt</a> can be treated
--   like a short interrupt which can be handled or ignored.
data ExitRecovery
Recoverable :: ExitRecovery
NoRecovery :: ExitRecovery

-- | The state that a <a>Process</a> is currently in.
data ProcessState

-- | The process has just been started but not scheduled yet.
ProcessBooting :: ProcessState

-- | The process yielded it's time slice
ProcessIdle :: ProcessState

-- | The process is busy with non-blocking
ProcessBusy :: ProcessState

-- | The process is busy with sending a message
ProcessBusySending :: ProcessState

-- | The process is busy with killing
ProcessBusySendingShutdown :: ProcessState

-- | The process is busy with killing
ProcessBusySendingInterrupt :: ProcessState

-- | The process blocked by a <a>receiveAnyMessage</a>
ProcessBusyReceiving :: ProcessState

-- | The process blocked by a <a>linkProcess</a>
ProcessBusyLinking :: ProcessState

-- | The process blocked by a <a>unlinkProcess</a>
ProcessBusyUnlinking :: ProcessState

-- | The process blocked by a <a>monitor</a>
ProcessBusyMonitoring :: ProcessState

-- | The process blocked by a <a>demonitor</a>
ProcessBusyDemonitoring :: ProcessState

-- | The process was interrupted
ProcessInterrupted :: ProcessState

-- | The process was shutdown or crashed
ProcessShuttingDown :: ProcessState

-- | <i>Cons</i> <a>Process</a> onto a list of effects.
type ConsProcess r = Process r : r

-- | A function that decided if the next message will be received by
--   <a>ReceiveSelectedMessage</a>. It conveniently is an instance of
--   <a>Alternative</a> so the message selector can be combined: &gt; &gt;
--   selectInt :: MessageSelector Int &gt; selectInt = selectMessage &gt;
--   &gt; selectString :: MessageSelector String &gt; selectString =
--   selectMessage &gt; &gt; selectIntOrString :: MessageSelector (Either
--   Int String) &gt; selectIntOrString = &gt; Left <a>$</a>
--   selectTimeout<a>|</a> Right <a>$</a> selectString
data MessageSelector a

-- | Every <a>Process</a> action returns it's actual result wrapped in this
--   type. It will allow to signal errors as well as pass on normal results
--   such as incoming messages.
data ResumeProcess v

-- | The current operation of the process was interrupted with a
--   <a>Interrupt</a>. If <a>isRecoverable</a> holds for the given reason,
--   the process may choose to continue.
[Interrupted] :: Interrupt  'Recoverable -> ResumeProcess v

-- | The process may resume to do work, using the given result.
[ResumeWith] :: a -> ResumeProcess a

-- | Data flows between <a>Process</a>es via these messages.
--   
--   This is just a newtype wrapper around <a>Dynamic</a>. The reason this
--   type exists is to force construction through the code in this module,
--   which always evaluates a message to <i>normal form</i> <b>before</b>
--   sending it to another process.
data StrictDynamic

-- | The process effect is the basis for message passing concurrency. This
--   effect describes an interface for concurrent, communicating isolated
--   processes identified uniquely by a process-id.
--   
--   Processes can raise exceptions that can be caught, exit gracefully or
--   with an error, or be killed by other processes, with the option of
--   ignoring the shutdown request.
--   
--   Process Scheduling is implemented in different modules. All scheduler
--   implementations should follow some basic rules:
--   
--   <ul>
--   <li>fair scheduling</li>
--   <li>sending a message does not block</li>
--   <li>receiving a message does block</li>
--   <li>spawning a child blocks only a very moment</li>
--   <li>a newly spawned process shall be scheduled before the parent
--   process after</li>
--   <li>the spawnRaw</li>
--   <li>when the first process exists, all process should be killed
--   immediately</li>
--   </ul>
data Process (r :: [Type -> Type]) b

-- | Remove all messages from the process' message queue
[FlushMessages] :: Process r (ResumeProcess [StrictDynamic])

-- | In cooperative schedulers, this will give processing time to the
--   scheduler. Every other operation implicitly serves the same purpose.
[YieldProcess] :: Process r (ResumeProcess ())

-- | Return the current <a>ProcessId</a>
[SelfPid] :: Process r (ResumeProcess ProcessId)

-- | Start a new process, the new process will execute an effect, the
--   function will return immediately with a <a>ProcessId</a>.
[Spawn] :: Eff (Process r : r) () -> Process r (ResumeProcess ProcessId)

-- | Start a new process, and <a>Link</a> to it .
[SpawnLink] :: Eff (Process r : r) () -> Process r (ResumeProcess ProcessId)

-- | Get the process state (or <a>Nothing</a> if the process is dead)
[GetProcessState] :: ProcessId -> Process r (ResumeProcess (Maybe ProcessState))

-- | Shutdown the process; irregardless of the exit reason, this function
--   never returns,
[Shutdown] :: Interrupt  'NoRecovery -> Process r a

-- | Shutdown another process immediately, the other process has no way of
--   handling this!
[SendShutdown] :: ProcessId -> Interrupt  'NoRecovery -> Process r (ResumeProcess ())

-- | Request that another a process interrupts. The targeted process is
--   interrupted and gets an <a>Interrupted</a>, the target process may
--   decide to ignore the interrupt and continue as if nothing happened.
[SendInterrupt] :: ProcessId -> Interrupt  'Recoverable -> Process r (ResumeProcess ())

-- | Send a message to a process addressed by the <a>ProcessId</a>. Sending
--   a message should <b>always succeed</b> and return <b>immediately</b>,
--   even if the destination process does not exist, or does not accept
--   messages of the given type.
[SendMessage] :: ProcessId -> StrictDynamic -> Process r (ResumeProcess ())

-- | Receive a message that matches a criteria. This should block until an
--   a message was received. The message is returned as a
--   <a>ResumeProcess</a> value. The function should also return if an
--   exception was caught or a shutdown was requested.
[ReceiveSelectedMessage] :: forall r a. MessageSelector a -> Process r (ResumeProcess a)

-- | Generate a unique <a>Int</a> for the current process.
[MakeReference] :: Process r (ResumeProcess Int)

-- | Monitor another process. When the monitored process exits a
--   <a>ProcessDown</a> is sent to the calling process. The return value is
--   a unique identifier for that monitor. There can be multiple monitors
--   on the same process, and a message for each will be sent. If the
--   process is already dead, the <a>ProcessDown</a> message will be sent
--   immediately, without exit reason
[Monitor] :: ProcessId -> Process r (ResumeProcess MonitorReference)

-- | Remove a monitor.
[Demonitor] :: MonitorReference -> Process r (ResumeProcess ())

-- | Connect the calling process to another process, such that if one of
--   the processes crashes (i.e. <a>isCrash</a> returns <a>True</a>), the
--   other is shutdown with the <a>Interrupt</a>
--   <a>LinkedProcessCrashed</a>.
[Link] :: ProcessId -> Process r (ResumeProcess ())

-- | Unlink the calling process from the other process.
[Unlink] :: ProcessId -> Process r (ResumeProcess ())

-- | Deeply evaluate the given value and wrap it into a
--   <a>StrictDynamic</a>.
toStrictDynamic :: (Typeable a, NFData a) => a -> StrictDynamic

-- | Convert a <a>StrictDynamic</a> back to a value.
fromStrictDynamic :: Typeable a => StrictDynamic -> Maybe a

-- | Convert a <a>StrictDynamic</a> back to an unwrapped <a>Dynamic</a>.
unwrapStrictDynamic :: StrictDynamic -> Dynamic

-- | Create a message selector for a value that can be obtained by
--   <a>fromStrictDynamic</a>.
selectMessage :: Typeable t => MessageSelector t

-- | Create a message selector from a predicate.
filterMessage :: Typeable a => (a -> Bool) -> MessageSelector a

-- | Select a message of type <tt>a</tt> and apply the given function to
--   it. If the function returns <a>Just</a> The
--   <a>ReceiveSelectedMessage</a> function will return the result (sans
--   <tt>Maybe</tt>).
selectMessageWith :: Typeable a => (a -> Maybe b) -> MessageSelector b

-- | Create a message selector.
selectDynamicMessage :: (StrictDynamic -> Maybe a) -> MessageSelector a

-- | Create a message selector that will match every message. This is
--   <i>lazy</i> because the result is not <a>force</a>ed.
selectAnyMessage :: MessageSelector StrictDynamic

-- | Get the <a>ExitRecovery</a>
toExitRecovery :: Interrupt r -> ExitRecovery

-- | Get the <a>ExitSeverity</a> of a <a>Interrupt</a>.
toExitSeverity :: Interrupt e -> ExitSeverity

-- | Return either <a>ExitNormally</a> or <a>interruptToExit</a> from a
--   <a>Recoverable</a> <a>Interrupt</a>;
--   
--   If the <a>Interrupt</a> is <a>NormalExitRequested</a> then return
--   <a>ExitNormally</a>
interruptToExit :: Interrupt  'Recoverable -> Interrupt  'NoRecovery

-- | A predicate for linked process <b>crashes</b>.
isProcessDownInterrupt :: Maybe ProcessId -> Interrupt r -> Bool

-- | Handle all <a>Interrupt</a>s of an <a>InterruptableProcess</a> by
--   wrapping them up in <a>interruptToExit</a> and then do a process
--   <a>Shutdown</a>.
provideInterruptsShutdown :: forall e a. Eff (InterruptableProcess e) a -> Eff (ConsProcess e) a

-- | Handle <a>Interrupt</a>s arising during process operations, e.g. when
--   a linked process crashes while we wait in a
--   <a>receiveSelectedMessage</a> via a call to <a>interrupt</a>.
handleInterrupts :: (HasCallStack, Member Interrupts r) => (Interrupt  'Recoverable -> Eff r a) -> Eff r a -> Eff r a

-- | Like <a>handleInterrupts</a>, but instead of passing the
--   <a>Interrupt</a> to a handler function, <a>Either</a> is returned.
tryUninterrupted :: (HasCallStack, Member Interrupts r) => Eff r a -> Eff r (Either (Interrupt  'Recoverable) a)

-- | Handle interrupts by logging them with <a>logProcessExit</a> and
--   otherwise ignoring them.
logInterrupts :: forall r. (Member Logs r, HasCallStack, Member Interrupts r) => Eff r () -> Eff r ()

-- | Handle <a>Interrupt</a>s arising during process operations, e.g. when
--   a linked process crashes while we wait in a
--   <a>receiveSelectedMessage</a> via a call to <a>interrupt</a>.
exitOnInterrupt :: (HasCallStack, Member Interrupts r, SetMember Process (Process q) r) => Eff r a -> Eff r a

-- | Handle <a>Interrupt</a>s arising during process operations, e.g. when
--   a linked process crashes while we wait in a
--   <a>receiveSelectedMessage</a> via a call to <a>interrupt</a>.
provideInterrupts :: HasCallStack => Eff (Interrupts : r) a -> Eff r (Either (Interrupt  'Recoverable) a)

-- | Wrap all (left) <a>Interrupt</a>s into <a>interruptToExit</a> and
--   return the (right) <a>NoRecovery</a> <a>Interrupt</a>s as is.
mergeEitherInterruptAndExitReason :: Either (Interrupt  'Recoverable) (Interrupt  'NoRecovery) -> Interrupt  'NoRecovery

-- | Throw an <a>Interrupt</a>, can be handled by <a>handleInterrupts</a>
--   or <a>exitOnInterrupt</a> or <a>provideInterrupts</a>.
interrupt :: (HasCallStack, Member Interrupts r) => Interrupt  'Recoverable -> Eff r a

-- | A predicate for crashes. A <i>crash</i> happens when a process exits
--   with an <a>Interrupt</a> other than <a>ExitNormally</a>
isCrash :: Interrupt x -> Bool

-- | A predicate for recoverable exit reasons. This predicate defines the
--   exit reasons which functions such as <a>executeAndResume</a>
isRecoverable :: Interrupt x -> Bool

-- | Partition a <a>SomeExitReason</a> back into either a <a>NoRecovery</a>
--   or a <a>Recoverable</a> <a>Interrupt</a>
fromSomeExitReason :: SomeExitReason -> Either (Interrupt  'NoRecovery) (Interrupt  'Recoverable)

-- | Print a <a>Interrupt</a> to <a>Just</a> a formatted <a>String</a> when
--   <a>isCrash</a> is <a>True</a>. This can be useful in combination with
--   view patterns, e.g.:
--   
--   <pre>
--   logCrash :: Interrupt -&gt; Eff e ()
--   logCrash (toCrashReason -&gt; Just reason) = logError reason
--   logCrash _ = return ()
--   </pre>
--   
--   Though this can be improved to:
--   
--   <pre>
--   logCrash = traverse_ logError . toCrashReason
--   </pre>
toCrashReason :: Interrupt x -> Maybe Text

-- | Log the <a>Interrupt</a>s
logProcessExit :: forall e x. (Member Logs e, HasCallStack) => Interrupt x -> Eff e ()

-- | Execute a and action and return the result; if the process is
--   interrupted by an error or exception, or an explicit shutdown from
--   another process, or through a crash of a linked process, i.e. whenever
--   the exit reason satisfies <a>isRecoverable</a>, return the exit
--   reason.
executeAndResume :: forall q r v. (SetMember Process (Process q) r, HasCallStack) => Process q (ResumeProcess v) -> Eff r (Either (Interrupt  'Recoverable) v)

-- | Execute a <a>Process</a> action and resume the process, exit the
--   process when an <a>Interrupts</a> was raised. Use
--   <a>executeAndResume</a> to catch interrupts.
executeAndResumeOrExit :: forall r q v. (SetMember Process (Process q) r, HasCallStack) => Process q (ResumeProcess v) -> Eff r v

-- | Execute a <a>Process</a> action and resume the process, exit the
--   process when an <a>Interrupts</a> was raised. Use
--   <a>executeAndResume</a> to catch interrupts.
executeAndResumeOrThrow :: forall q r v. (SetMember Process (Process q) r, HasCallStack, Member Interrupts r) => Process q (ResumeProcess v) -> Eff r v

-- | Use <a>executeAndResumeOrExit</a> to execute <a>YieldProcess</a>.
--   Refer to <a>YieldProcess</a> for more information.
yieldProcess :: forall r q. (SetMember Process (Process q) r, HasCallStack, Member Interrupts r) => Eff r ()

-- | Send a message to a process addressed by the <a>ProcessId</a>. See
--   <a>SendMessage</a>.
--   
--   The message will be reduced to normal form (<a>rnf</a>) by/in the
--   caller process.
sendMessage :: forall r q o. (SetMember Process (Process q) r, HasCallStack, Member Interrupts r, Typeable o, NFData o) => ProcessId -> o -> Eff r ()

-- | Send a <a>Dynamic</a> value to a process addressed by the
--   <a>ProcessId</a>. See <a>SendMessage</a>.
sendAnyMessage :: forall r q. (SetMember Process (Process q) r, HasCallStack, Member Interrupts r) => ProcessId -> StrictDynamic -> Eff r ()

-- | Exit a process addressed by the <a>ProcessId</a>. The process will
--   exit, it might do some cleanup, but is ultimately unrecoverable. See
--   <a>SendShutdown</a>.
sendShutdown :: forall r q. (SetMember Process (Process q) r, HasCallStack, Member Interrupts r) => ProcessId -> Interrupt  'NoRecovery -> Eff r ()

-- | Interrupts a process addressed by the <a>ProcessId</a>. The process
--   might exit, or it may continue. | Like <a>sendInterrupt</a>, but also
--   return <tt>True</tt> iff the process to exit exists.
sendInterrupt :: forall r q. (SetMember Process (Process q) r, HasCallStack, Member Interrupts r) => ProcessId -> Interrupt  'Recoverable -> Eff r ()

-- | Start a new process, the new process will execute an effect, the
--   function will return immediately with a <a>ProcessId</a>. If the new
--   process is interrupted, the process will <a>Shutdown</a> with the
--   <a>Interrupt</a> wrapped in <a>interruptToExit</a>. For specific use
--   cases it might be better to use <a>spawnRaw</a>.
spawn :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => Eff (InterruptableProcess q) () -> Eff r ProcessId

-- | Like <a>spawn</a> but return <tt>()</tt>.
spawn_ :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => Eff (InterruptableProcess q) () -> Eff r ()

-- | Start a new process, and immediately link to it.
spawnLink :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => Eff (InterruptableProcess q) () -> Eff r ProcessId

-- | Start a new process, the new process will execute an effect, the
--   function will return immediately with a <a>ProcessId</a>. The spawned
--   process has only the <i>raw</i> <a>ConsProcess</a> effects. For
--   non-library code <a>spawn</a> might be better suited.
spawnRaw :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => Eff (ConsProcess q) () -> Eff r ProcessId

-- | Like <a>spawnRaw</a> but return <tt>()</tt>.
spawnRaw_ :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => Eff (ConsProcess q) () -> Eff r ()

-- | Return <a>True</a> if the process is alive.
isProcessAlive :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => ProcessId -> Eff r Bool

-- | Block until a message was received. See <a>ReceiveSelectedMessage</a>
--   for more documentation.
receiveAnyMessage :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => Eff r StrictDynamic

-- | Block until a message was received, that is not <a>Nothing</a> after
--   applying a callback to it. See <a>ReceiveSelectedMessage</a> for more
--   documentation.
receiveSelectedMessage :: forall r q a. (HasCallStack, Show a, SetMember Process (Process q) r, Member Interrupts r) => MessageSelector a -> Eff r a

-- | Receive and cast the message to some <a>Typeable</a> instance. See
--   <a>ReceiveSelectedMessage</a> for more documentation. This will wait
--   for a message of the return type using <a>receiveSelectedMessage</a>
receiveMessage :: forall a r q. (HasCallStack, Typeable a, NFData a, Show a, SetMember Process (Process q) r, Member Interrupts r) => Eff r a

-- | Remove and return all messages currently enqueued in the process
--   message queue.
flushMessages :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => Eff r [StrictDynamic]

-- | Enter a loop to receive messages and pass them to a callback, until
--   the function returns <a>Just</a> a result. Only the messages of the
--   given type will be received. If the process is interrupted by an
--   exception of by a <a>SendShutdown</a> from another process, with an
--   exit reason that satisfies <a>isRecoverable</a>, then the callback
--   will be invoked with <tt><a>Left</a> <a>Interrupt</a></tt>, otherwise
--   the process will be exited with the same reason using
--   <a>exitBecause</a>. See also <a>ReceiveSelectedMessage</a> for more
--   documentation.
receiveSelectedLoop :: forall r q a endOfLoopResult. (SetMember Process (Process q) r, HasCallStack) => MessageSelector a -> (Either (Interrupt  'Recoverable) a -> Eff r (Maybe endOfLoopResult)) -> Eff r endOfLoopResult

-- | Like <a>receiveSelectedLoop</a> but <i>not selective</i>. See also
--   <a>selectAnyMessage</a>, <a>receiveSelectedLoop</a>.
receiveAnyLoop :: forall r q endOfLoopResult. (SetMember Process (Process q) r, HasCallStack) => (Either (Interrupt  'Recoverable) StrictDynamic -> Eff r (Maybe endOfLoopResult)) -> Eff r endOfLoopResult

-- | Like <a>receiveSelectedLoop</a> but refined to casting to a specific
--   <a>Typeable</a> using <a>selectMessage</a>.
receiveLoop :: forall r q a endOfLoopResult. (SetMember Process (Process q) r, HasCallStack, NFData a, Typeable a) => (Either (Interrupt  'Recoverable) a -> Eff r (Maybe endOfLoopResult)) -> Eff r endOfLoopResult

-- | Returns the <a>ProcessId</a> of the current process.
self :: (HasCallStack, SetMember Process (Process q) r) => Eff r ProcessId

-- | Generate a unique <a>Int</a> for the current process.
makeReference :: (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => Eff r Int

-- | Monitor another process. When the monitored process exits a
--   <a>ProcessDown</a> is sent to the calling process. The return value is
--   a unique identifier for that monitor. There can be multiple monitors
--   on the same process, and a message for each will be sent. If the
--   process is already dead, the <a>ProcessDown</a> message will be sent
--   immediately, without exit reason
monitor :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => ProcessId -> Eff r MonitorReference

-- | Remove a monitor created with <a>monitor</a>.
demonitor :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => MonitorReference -> Eff r ()

-- | <a>monitor</a> another process before while performing an action and
--   <a>demonitor</a> afterwards.
withMonitor :: (HasCallStack, Member Interrupts r, SetMember Process (Process q) r, Member Interrupts r) => ProcessId -> (MonitorReference -> Eff r a) -> Eff r a

-- | A <a>MessageSelector</a> for receiving either a monitor of the given
--   process or another message.
receiveWithMonitor :: (HasCallStack, Member Interrupts r, SetMember Process (Process q) r, Member Interrupts r, Typeable a, Show a) => ProcessId -> MessageSelector a -> Eff r (Either ProcessDown a)

-- | Make an <a>Interrupt</a> for a <a>ProcessDown</a> message.
--   
--   For example: <tt>doSomething &gt;&gt;= either (interrupt .
--   becauseProcessIsDown) return</tt>
becauseProcessIsDown :: ProcessDown -> Interrupt  'Recoverable

-- | A <a>MessageSelector</a> for the <a>ProcessDown</a> message of a
--   specific process.
selectProcessDown :: MonitorReference -> MessageSelector ProcessDown

-- | Connect the calling process to another process, such that if one of
--   the processes crashes (i.e. <a>isCrash</a> returns <a>True</a>), the
--   other is shutdown with the <a>Interrupt</a>
--   <a>LinkedProcessCrashed</a>.
linkProcess :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => ProcessId -> Eff r ()

-- | Unlink the calling process from the other process.
unlinkProcess :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => ProcessId -> Eff r ()

-- | Exit the process with a <a>Interrupt</a>.
exitBecause :: forall r q a. (HasCallStack, SetMember Process (Process q) r) => Interrupt  'NoRecovery -> Eff r a

-- | Exit the process.
exitNormally :: forall r q a. (HasCallStack, SetMember Process (Process q) r) => Eff r a

-- | Exit the process with an error.
exitWithError :: forall r q a. (HasCallStack, SetMember Process (Process q) r) => String -> Eff r a
fromProcessId :: Iso' ProcessId Int

-- | A value to be sent when timer started with <a>startTimer</a> has
--   elapsed.
data TimerElapsed

-- | The reference to a timer started by <a>startTimer</a>, required to
--   stop a timer via <a>cancelTimer</a>.
data TimerReference

-- | A number of micro seconds.
data Timeout

-- | Wait for a message of the given type for the given time. When no
--   message arrives in time, return <a>Nothing</a>. This is based on
--   <a>receiveSelectedAfter</a>.
receiveAfter :: forall a r q. (Lifted IO q, HasCallStack, SetMember Process (Process q) r, Member Interrupts r, Typeable a, NFData a, Show a) => Timeout -> Eff r (Maybe a)

-- | Wait for a message of the given type for the given time. When no
--   message arrives in time, return <a>Left</a> <a>TimerElapsed</a>. This
--   is based on <a>selectTimerElapsed</a> and <a>startTimer</a>.
receiveSelectedAfter :: forall a r q. (Lifted IO q, HasCallStack, SetMember Process (Process q) r, Member Interrupts r, Show a) => MessageSelector a -> Timeout -> Eff r (Either TimerElapsed a)

-- | Like <a>receiveWithMonitor</a> combined with
--   <a>receiveSelectedAfter</a>.
receiveSelectedWithMonitorAfter :: forall a r q. (Lifted IO q, HasCallStack, SetMember Process (Process q) r, Member Interrupts r, Show a) => ProcessId -> MessageSelector a -> Timeout -> Eff r (Either (Either ProcessDown TimerElapsed) a)

-- | A <a>MessageSelector</a> matching <a>TimerElapsed</a> messages created
--   by <a>startTimer</a>.
selectTimerElapsed :: TimerReference -> MessageSelector TimerElapsed

-- | Send a message to a given process after waiting. The message is
--   created by applying the function parameter to the
--   <a>TimerReference</a>, such that the message can directly refer to the
--   timer.
sendAfter :: forall r q message. (Lifted IO q, HasCallStack, SetMember Process (Process q) r, Member Interrupts r, Typeable message, NFData message) => ProcessId -> Timeout -> (TimerReference -> message) -> Eff r TimerReference

-- | Start a new timer, after the time has elapsed, <a>TimerElapsed</a> is
--   sent to calling process. The message also contains the
--   <a>TimerReference</a> returned by this function. Use
--   <a>cancelTimer</a> to cancel the timer. Use <a>selectTimerElapsed</a>
--   to receive the message using <a>receiveSelectedMessage</a>. To receive
--   messages with guarded with a timeout see <a>receiveAfter</a>.
startTimer :: forall r q. (Lifted IO q, HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => Timeout -> Eff r TimerReference

-- | Cancel a timer started with <a>startTimer</a>.
cancelTimer :: forall r q. (Lifted IO q, HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => TimerReference -> Eff r ()

-- | This is a tag-type that wraps around a <a>ProcessId</a> and holds an
--   <a>Api</a> index type.
newtype Server api
Server :: ProcessId -> Server api
[_fromServer] :: Server api -> ProcessId

-- | The (promoted) constructors of this type specify (at the type level)
--   the reply behavior of a specific constructor of an <tt>Api</tt>
--   instance.
data Synchronicity

-- | Specify that handling a request is a blocking operation with a
--   specific return type, e.g. <tt>('Synchronous (Either RentalError
--   RentalId))</tt>
Synchronous :: Type -> Synchronicity

-- | Non-blocking, asynchronous, request handling
Asynchronous :: Synchronicity

-- | A set of constraints for types that can evaluated via <a>NFData</a>,
--   compared via <a>Ord</a> and presented dynamically via <a>Typeable</a>,
--   and represented both as values via <a>Show</a>, as well as on the type
--   level via <a>ToPretty</a>.
type Tangible i = (NFData i, Typeable i, Show i, PrettyTypeShow (ToPretty i))

-- | This data family defines an API, a communication interface description
--   between at least two processes. The processes act as <b>servers</b> or
--   <b>client(s)</b> regarding a specific instance of this type.
--   
--   The first parameter is usually a user defined phantom type that
--   identifies the <a>Api</a> instance.
--   
--   The second parameter specifies if a specific constructor of an
--   (GADT-like) <tt>Api</tt> instance is <a>Synchronous</a>, i.e. returns
--   a result and blocks the caller or if it is <a>Asynchronous</a>
--   
--   Also, for better logging, the an instance of <a>ToPretty</a> for the
--   <a>Api</a> index type must be given.
--   
--   Example:
--   
--   <pre>
--   data BookShop deriving Typeable
--   
--   data instance Api BookShop r where
--     RentBook  :: BookId   -&gt; Api BookShop ('Synchronous (Either RentalError RentalId))
--     BringBack :: RentalId -&gt; Api BookShop 'Asynchronous
--   
--   type instance ToPretty BookShop = PutStr "book shop"
--   
--   type BookId = Int
--   type RentalId = Int
--   type RentalError = String
--   </pre>
data family Api (api :: Type) (reply :: Synchronicity)
fromServer :: forall api_aXxm api_aXVF. Iso (Server api_aXxm) (Server api_aXVF) ProcessId ProcessId

-- | Tag a <a>ProcessId</a> with an <a>Api</a> type index to mark it a
--   <a>Server</a> process handling that API
proxyAsServer :: proxy api -> ProcessId -> Server api

-- | Tag a <a>ProcessId</a> with an <a>Api</a> type index to mark it a
--   <a>Server</a> process handling that API
asServer :: forall api. ProcessId -> Server api

-- | The reader effect for <a>ProcessId</a>s for <a>Api</a>s, see
--   <a>registerServer</a>
type ServerReader o = Reader (Server o)

-- | Instead of passing around a <a>Server</a> value and passing to
--   functions like <a>cast</a> or <a>call</a>, a <a>Server</a> can
--   provided by a <a>Reader</a> effect, if there is only a <b>single
--   server</b> for a given <a>Api</a> instance. This type alias is
--   convenience to express that an effect has <a>Process</a> and a reader
--   for a <a>Server</a>.
type ServesApi o r q = (Typeable o, PrettyTypeShow (ToPretty o), SetMember Process (Process q) r, Member (ServerReader o) r)

-- | Send an <a>Api</a> request that has no return value and return as fast
--   as possible. The type signature enforces that the corresponding
--   <a>Api</a> clause is <a>Asynchronous</a>. The operation never fails,
--   if it is important to know if the message was delivered, use
--   <a>call</a> instead.
--   
--   The message will be reduced to normal form (<a>rnf</a>) in the caller
--   process.
cast :: forall r q o. (HasCallStack, SetMember Process (Process q) r, PrettyTypeShow (ToPretty o), Member Interrupts r, Typeable o, Typeable (Api o  'Asynchronous), NFData (Api o  'Asynchronous)) => Server o -> Api o  'Asynchronous -> Eff r ()

-- | Send an <a>Api</a> request and wait for the server to return a result
--   value.
--   
--   The type signature enforces that the corresponding <a>Api</a> clause
--   is <a>Synchronous</a>.
--   
--   <b>Always prefer <a>callWithTimeout</a> over <a>call</a></b>
call :: forall result api r q. (SetMember Process (Process q) r, Member Interrupts r, Typeable api, PrettyTypeShow (ToPretty api), Typeable (Api api ( 'Synchronous result)), NFData (Api api ( 'Synchronous result)), Typeable result, NFData result, Show result, HasCallStack) => Server api -> Api api ( 'Synchronous result) -> Eff r result

-- | Send an <a>Api</a> request and wait for the server to return a result
--   value.
--   
--   The type signature enforces that the corresponding <a>Api</a> clause
--   is <a>Synchronous</a>.
--   
--   If the server that was called dies, this function interrupts the
--   process with <a>ProcessDown</a>. If the server takes longer to reply
--   than the given timeout, this function interrupts the process with
--   <a>TimeoutInterrupt</a>.
--   
--   <b>Always prefer this function over <a>call</a></b>
callWithTimeout :: forall result api r q. (SetMember Process (Process q) r, Member Interrupts r, Typeable api, Typeable (Api api ( 'Synchronous result)), NFData (Api api ( 'Synchronous result)), Typeable result, NFData result, Show result, Member Logs r, Lifted IO q, Lifted IO r, HasCallStack, PrettyTypeShow (ToPretty api)) => Server api -> Api api ( 'Synchronous result) -> Timeout -> Eff r result

-- | Run a reader effect that contains <b>the one</b> server handling a
--   specific <a>Api</a> instance.
registerServer :: HasCallStack => Server o -> Eff (ServerReader o : r) a -> Eff r a

-- | Get the <a>Server</a> registered with <a>registerServer</a>.
whereIsServer :: Member (ServerReader o) e => Eff e (Server o)

-- | Like <a>call</a> but take the <a>Server</a> from the reader provided
--   by <a>registerServer</a>.
callRegistered :: (Typeable reply, ServesApi o r q, HasCallStack, NFData reply, Show reply, NFData (Api o ( 'Synchronous reply)), Member Interrupts r) => Api o ( 'Synchronous reply) -> Eff r reply

-- | Like <a>cast</a> but take the <a>Server</a> from the reader provided
--   by <a>registerServer</a>.
castRegistered :: (Typeable o, ServesApi o r q, HasCallStack, Member Interrupts r, NFData (Api o  'Asynchronous)) => Api o  'Asynchronous -> Eff r ()

-- | Just a wrapper around a function that will be applied to the result of
--   a <a>MessageCallback</a>s <a>StopServer</a> clause, or an
--   <a>Interrupt</a> caught during the execution of <tt>receive</tt> or a
--   <a>MessageCallback</a>
data InterruptCallback eff
[InterruptCallback] :: (Interrupt  'Recoverable -> Eff eff (CallbackResult  'NoRecovery)) -> InterruptCallback eff

-- | Helper type class for the return values of <a>spawnApiServer</a> et
--   al.
class ToServerPids (t :: k) where {
    type family PrettyServerPids t :: PrettyType;
    type family ServerPids t;
}
toServerPids :: ToServerPids t => proxy t -> ProcessId -> ServerPids t

-- | An existential wrapper around a <a>MessageSelector</a> and a function
--   that handles the selected message. The <tt>api</tt> type parameter is
--   a phantom type.
--   
--   The return value of the handler function is a <a>CallbackResult</a>.
data MessageCallback api eff
[MessageCallback] :: MessageSelector a -> (a -> Eff eff (CallbackResult  'Recoverable)) -> MessageCallback api eff

-- | A command to the server loop started by <a>apiServerLoop</a>.
--   Typically returned by a <a>MessageCallback</a> to indicate if the
--   server should continue or stop.
data CallbackResult (r :: ExitRecovery)

-- | Tell the server to keep the server loop running
[AwaitNext] :: CallbackResult r

-- | Tell the server to exit, this will cause <a>apiServerLoop</a> to stop
--   handling requests without exiting the process.
[StopServer] :: Interrupt r -> CallbackResult r

-- | <i>Serve</i> an <a>Api</a> in a newly spawned process.
spawnApiServer :: forall api eff. (ToServerPids api, HasCallStack, Member Logs eff, PrettyTypeShow (PrettyServerPids api)) => MessageCallback api (InterruptableProcess eff) -> InterruptCallback (ConsProcess eff) -> Eff (InterruptableProcess eff) (ServerPids api)

-- | <i>Serve</i> an <a>Api</a> in a newly spawned -and linked - process.
spawnLinkApiServer :: forall api eff. (ToServerPids api, HasCallStack, Member Logs eff, Typeable api, PrettyTypeShow (PrettyServerPids api)) => MessageCallback api (InterruptableProcess eff) -> InterruptCallback (ConsProcess eff) -> Eff (InterruptableProcess eff) (ServerPids api)

-- | <i>Server</i> an <a>Api</a> in a newly spawned process; the callbacks
--   have access to a state value.
--   
--   The initial state value is returned by the action given as parameter,
--   from within the new process.
spawnApiServerStateful :: forall api eff state. (HasCallStack, ToServerPids api, NFData state, PrettyTypeShow (PrettyServerPids api)) => Eff (InterruptableProcess eff) state -> MessageCallback api (State state : InterruptableProcess eff) -> InterruptCallback (State state : ConsProcess eff) -> Eff (InterruptableProcess eff) (ServerPids api)

-- | <i>Server</i> an <a>Api</a> in a newly spawned process; The caller
--   provides an effect handler for arbitrary effects used by the server
--   callbacks.
spawnApiServerEffectful :: forall api eff serverEff. (HasCallStack, ToServerPids api, Member Interrupts serverEff, SetMember Process (Process eff) serverEff, Member Logs serverEff, PrettyTypeShow (PrettyServerPids api)) => (forall b. Eff serverEff b -> Eff (InterruptableProcess eff) b) -> MessageCallback api serverEff -> InterruptCallback serverEff -> Eff (InterruptableProcess eff) (ServerPids api)

-- | <i>Server</i> an <a>Api</a> in a newly spawned process; The caller
--   provides an effect handler for arbitrary effects used by the server
--   callbacks. Links to the calling process like <a>linkProcess</a> would.
spawnLinkApiServerEffectful :: forall api eff serverEff. (HasCallStack, ToServerPids api, Member Interrupts serverEff, SetMember Process (Process eff) serverEff, Member Logs serverEff, PrettyTypeShow (PrettyServerPids api)) => (forall b. Eff serverEff b -> Eff (InterruptableProcess eff) b) -> MessageCallback api serverEff -> InterruptCallback serverEff -> Eff (InterruptableProcess eff) (ServerPids api)

-- | A smart constructor for <a>MessageCallback</a>s
handleMessages :: forall eff a. (HasCallStack, NFData a, Typeable a) => (a -> Eff eff (CallbackResult  'Recoverable)) -> MessageCallback '[] eff

-- | A smart constructor for <a>MessageCallback</a>s
handleSelectedMessages :: forall eff a. HasCallStack => MessageSelector a -> (a -> Eff eff (CallbackResult  'Recoverable)) -> MessageCallback '[] eff

-- | A smart constructor for <a>MessageCallback</a>s
handleAnyMessages :: forall eff. HasCallStack => (StrictDynamic -> Eff eff (CallbackResult  'Recoverable)) -> MessageCallback '[] eff

-- | A smart constructor for <a>MessageCallback</a>s
handleCasts :: forall api eff. (HasCallStack, Typeable api, Typeable (Api api  'Asynchronous), NFData (Request api)) => (Api api  'Asynchronous -> Eff eff (CallbackResult  'Recoverable)) -> MessageCallback api eff

-- | A smart constructor for <a>MessageCallback</a>s
--   
--   <h4><b>Example</b></h4>
--   
--   <pre>
--   handleCalls
--     ( (RentBook bookId customerId) runCall -&gt;
--        runCall $ do
--            rentalIdE &lt;- rentBook bookId customerId
--            case rentalIdE of
--              -- on fail we just don't send a reply, let the caller run into
--              -- timeout
--              Left err -&gt; return (Nothing, AwaitNext)
--              Right rentalId -&gt; return (Just rentalId, AwaitNext))
--   </pre>
handleCalls :: forall api eff effScheduler. (HasCallStack, Typeable api, SetMember Process (Process effScheduler) eff, Member Interrupts eff) => (forall secret reply. (NFData reply, Typeable reply, Typeable (Api api ( 'Synchronous reply))) => Api api ( 'Synchronous reply) -> (Eff eff (Maybe reply, CallbackResult  'Recoverable) -> secret) -> secret) -> MessageCallback api eff

-- | A smart constructor for <a>MessageCallback</a>s
handleCastsAndCalls :: forall api eff effScheduler. (HasCallStack, Typeable api, Typeable (Api api  'Asynchronous), NFData (Request api), SetMember Process (Process effScheduler) eff, Member Interrupts eff) => (Api api  'Asynchronous -> Eff eff (CallbackResult  'Recoverable)) -> (forall secret reply. (Typeable reply, Typeable (Api api ( 'Synchronous reply)), NFData reply) => Api api ( 'Synchronous reply) -> (Eff eff (Maybe reply, CallbackResult  'Recoverable) -> secret) -> secret) -> MessageCallback api eff

-- | A variation of <a>handleCalls</a> that allows to defer a reply to a
--   call.
handleCallsDeferred :: forall api eff effScheduler. (HasCallStack, Typeable api, SetMember Process (Process effScheduler) eff, Member Interrupts eff) => (forall reply. (Typeable reply, NFData reply, Typeable (Api api ( 'Synchronous reply))) => RequestOrigin (Api api ( 'Synchronous reply)) -> Api api ( 'Synchronous reply) -> Eff eff (CallbackResult  'Recoverable)) -> MessageCallback api eff

-- | A smart constructor for <a>MessageCallback</a>s
handleProcessDowns :: forall eff. HasCallStack => (MonitorReference -> Eff eff (CallbackResult  'Recoverable)) -> MessageCallback '[] eff

-- | Compose two <a>Api</a>s to a type-level pair of them.
--   
--   <pre>
--   handleCalls api1calls ^: handleCalls api2calls ^:
--   </pre>
(^:) :: forall (api1 :: Type) (apis2 :: [Type]) eff. HasCallStack => MessageCallback api1 eff -> MessageCallback apis2 eff -> MessageCallback (api1 : apis2) eff
infixr 5 ^:

-- | Make a fallback handler, i.e. a handler to which no other can be
--   composed to from the right.
fallbackHandler :: forall api eff. HasCallStack => MessageCallback api eff -> MessageCallback '[] eff

-- | A <a>fallbackHandler</a> that drops the left-over messages.
dropUnhandledMessages :: forall eff. HasCallStack => MessageCallback '[] eff

-- | A <a>fallbackHandler</a> that terminates if there are unhandled
--   messages.
exitOnUnhandled :: forall eff. HasCallStack => MessageCallback '[] eff

-- | A <a>fallbackHandler</a> that drops the left-over messages.
logUnhandledMessages :: forall eff. (Member Logs eff, HasCallStack) => MessageCallback '[] eff

-- | A smart constructor for <a>InterruptCallback</a>s
stopServerOnInterrupt :: forall eff. HasCallStack => InterruptCallback eff

-- | Wraps the source <a>ProcessId</a> and a unique identifier for a
--   <a>Call</a>.
data RequestOrigin request
RequestOrigin :: !ProcessId -> !Int -> RequestOrigin request
[_requestOriginPid] :: RequestOrigin request -> !ProcessId
[_requestOriginCallRef] :: RequestOrigin request -> !Int

-- | The wrapper around replies to <a>Call</a>s.
data Reply request
[Reply] :: (Typeable api, Typeable reply, NFData reply) => Proxy (Api api ( 'Synchronous reply)) -> Int -> reply -> Reply (Api api ( 'Synchronous reply))

-- | A wrapper sum type for calls and casts for the methods of an
--   <a>Api</a> subtype
data Request api
[Call] :: forall api reply. (Typeable api, Typeable reply, NFData reply, Typeable (Api api ( 'Synchronous reply)), NFData (Api api ( 'Synchronous reply))) => Int -> ProcessId -> Api api ( 'Synchronous reply) -> Request api
[Cast] :: forall api. (Typeable api, Typeable (Api api  'Asynchronous), NFData (Api api  'Asynchronous)) => Api api  'Asynchronous -> Request api

-- | TODO remove
mkRequestOrigin :: request -> ProcessId -> Int -> RequestOrigin request

-- | Send a <a>Reply</a> to a <a>Call</a>.
--   
--   The reply will be deeply evaluated to <a>rnf</a>.
sendReply :: forall request reply api eff q. (SetMember Process (Process q) eff, Member Interrupts eff, Typeable api, ApiType request ~ api, ReplyType request ~ reply, request ~ Api api ( 'Synchronous reply), Typeable reply, NFData reply) => RequestOrigin request -> reply -> Eff eff ()

-- | This data family defines an API, a communication interface description
--   between at least two processes. The processes act as <b>servers</b> or
--   <b>client(s)</b> regarding a specific instance of this type.
--   
--   The first parameter is usually a user defined phantom type that
--   identifies the <a>Api</a> instance.
--   
--   The second parameter specifies if a specific constructor of an
--   (GADT-like) <tt>Api</tt> instance is <a>Synchronous</a>, i.e. returns
--   a result and blocks the caller or if it is <a>Asynchronous</a>
--   
--   Also, for better logging, the an instance of <a>ToPretty</a> for the
--   <a>Api</a> index type must be given.
--   
--   Example:
--   
--   <pre>
--   data BookShop deriving Typeable
--   
--   data instance Api BookShop r where
--     RentBook  :: BookId   -&gt; Api BookShop ('Synchronous (Either RentalError RentalId))
--     BringBack :: RentalId -&gt; Api BookShop 'Asynchronous
--   
--   type instance ToPretty BookShop = PutStr "book shop"
--   
--   type BookId = Int
--   type RentalId = Int
--   type RentalError = String
--   </pre>
data family Api (api :: Type) (reply :: Synchronicity)

-- | Alias for the effect that contains the observers managed by
--   <a>manageObservers</a>
type ObserverState o = State (Observers o)

-- | An <a>Api</a> for managing <a>Observer</a>s, encompassing registration
--   and de-registration of <a>Observer</a>s.
data ObserverRegistry o

-- | Describes a process that observes another via <a>Asynchronous</a>
--   <a>Api</a> messages.
--   
--   An observer consists of a filter and a process id. The filter converts
--   an observation to a message understood by the observer process, and
--   the <a>ProcessId</a> is used to send the message.
data Observer o
[Observer] :: (PrettyTypeShow (ToPretty p), Show (Server p), Typeable p, Typeable o, NFData o, NFData (Api p  'Asynchronous)) => (o -> Maybe (Api p  'Asynchronous)) -> Server p -> Observer o

-- | And an <a>Observer</a> to the set of recipients for all observations
--   reported by <a>observed</a>. Note that the observers are keyed by the
--   observing process, i.e. a previous entry for the process contained in
--   the <a>Observer</a> is overwritten. If you want multiple entries for a
--   single process, just combine several filter functions.
registerObserver :: (SetMember Process (Process q) r, HasCallStack, Member Interrupts r, Typeable o, NFData o, PrettyTypeShow (ToPretty o)) => Observer o -> Server (ObserverRegistry o) -> Eff r ()

-- | Send the <a>ForgetObserver</a> message
forgetObserver :: (SetMember Process (Process q) r, HasCallStack, Member Interrupts r, Typeable o, NFData o, PrettyTypeShow (ToPretty o)) => Observer o -> Server (ObserverRegistry o) -> Eff r ()

-- | Based on the <a>Api</a> instance for <a>Observer</a> this simplified
--   writing a callback handler for observations. In order to register to
--   and <a>ObserverRegistry</a> use <a>toObserver</a>.
handleObservations :: (HasCallStack, Typeable o, SetMember Process (Process q) r, NFData (Observer o)) => (o -> Eff r (CallbackResult  'Recoverable)) -> MessageCallback (Observer o) r

-- | Use a <a>Server</a> as an <a>Observer</a> for
--   <a>handleObservations</a>.
toObserver :: (NFData o, Typeable o, NFData (Api (Observer o)  'Asynchronous), PrettyTypeShow (ToPretty o)) => Server (Observer o) -> Observer o

-- | Create an <a>Observer</a> that conditionally accepts all observations
--   of the given type and applies the given function to them; the function
--   takes an observation and returns an <a>Api</a> cast that the observer
--   server is compatible to.
toObserverFor :: (Typeable a, PrettyTypeShow (ToPretty a), NFData (Api a  'Asynchronous), Typeable o, NFData o) => (o -> Api a  'Asynchronous) -> Server a -> Observer o

-- | Provide the implementation for the <a>ObserverRegistry</a> Api, this
--   handled <a>RegisterObserver</a> and <a>ForgetObserver</a> messages. It
--   also adds the <a>ObserverState</a> constraint to the effect list.
handleObserverRegistration :: forall o q r. (HasCallStack, Typeable o, SetMember Process (Process q) r, Member (ObserverState o) r, Member Logs r) => MessageCallback (ObserverRegistry o) r

-- | Keep track of registered <a>Observer</a>s.
--   
--   Handle the <a>ObserverState</a> introduced by
--   <a>handleObserverRegistration</a>.
manageObservers :: Eff (ObserverState o : r) a -> Eff r a

-- | Report an observation to all observers. The process needs to
--   <a>manageObservers</a> and to <a>handleObserverRegistration</a>.
observed :: forall o r q. (SetMember Process (Process q) r, PrettyTypeShow (ToPretty o), Member (ObserverState o) r, Member Interrupts r) => o -> Eff r ()

-- | A <a>Reader</a> for an <a>ObservationQueue</a>.
type ObservationQueueReader a = Reader (ObservationQueue a)

-- | Contains a <a>TBQueue</a> capturing observations. See
--   <a>spawnLinkObservationQueueWriter</a>, <a>readObservationQueue</a>.
data ObservationQueue a

-- | Read queued observations captured and enqueued in the shared
--   <a>TBQueue</a> by <a>spawnLinkObservationQueueWriter</a>. This blocks
--   until something was captured or an interrupt or exceptions was thrown.
--   For a non-blocking variant use <a>tryReadObservationQueue</a> or
--   <a>flushObservationQueue</a>.
readObservationQueue :: forall o r. (Member (ObservationQueueReader o) r, HasCallStack, MonadIO (Eff r), Typeable o, Member Logs r) => Eff r o

-- | Read queued observations captured and enqueued in the shared
--   <a>TBQueue</a> by <a>spawnLinkObservationQueueWriter</a>. Return the
--   oldest enqueued observation immediately or <a>Nothing</a> if the queue
--   is empty. Use <a>readObservationQueue</a> to block until an
--   observation is observed.
tryReadObservationQueue :: forall o r. (Member (ObservationQueueReader o) r, HasCallStack, MonadIO (Eff r), Typeable o, Member Logs r) => Eff r (Maybe o)

-- | Read at once all currently queued observations captured and enqueued
--   in the shared <a>TBQueue</a> by
--   <a>spawnLinkObservationQueueWriter</a>. This returns immediately all
--   currently enqueued observations. For a blocking variant use
--   <a>readObservationQueue</a>.
flushObservationQueue :: forall o r. (Member (ObservationQueueReader o) r, HasCallStack, MonadIO (Eff r), Typeable o, Member Logs r) => Eff r [o]

-- | Create a mutable queue for observations. Use
--   <a>spawnLinkObservationQueueWriter</a> for a simple way to get a
--   process that enqueues all observations.
--   
--   <h4><b>Example</b></h4>
--   
--   <pre>
--   withObservationQueue 100 $ do
--     q  &lt;- ask @(ObservationQueueReader TestEvent)
--     wq &lt;- spawnLinkObservationQueueWriter q
--     registerObserver wq testServer
--     ...
--     cast testServer DoSomething
--     evt &lt;- readObservationQueue @TestEvent
--     ...
--   </pre>
withObservationQueue :: forall o b e len. (HasCallStack, Typeable o, Show o, Member Logs e, Lifted IO e, Integral len, Member Interrupts e) => len -> Eff (ObservationQueueReader o : e) b -> Eff e b

-- | Spawn a process that can be used as an <a>Observer</a> that enqueues
--   the observations into an <a>ObservationQueue</a>. See
--   <a>withObservationQueue</a> for an example.
--   
--   The observations can be obtained by <a>readObservationQueue</a>. All
--   observations are captured up to the queue size limit, such that the
--   first message received will be first message returned by
--   <a>readObservationQueue</a>.
spawnLinkObservationQueueWriter :: forall o q. (Tangible o, NFData (Api (Observer o)  'Asynchronous), Member Logs q, Lifted IO q, HasCallStack) => ObservationQueue o -> Eff (InterruptableProcess q) (Observer o)

-- | The concrete list of <a>Eff</a>ects for this scheduler implementation.
type SchedulerIO = (Reader SchedulerState : LoggingAndIo)

-- | Type class constraint to indicate that an effect union contains the
--   effects required by every process and the scheduler implementation
--   itself.
type HasSchedulerIO r = (HasCallStack, Lifted IO r, SchedulerIO <:: r)

-- | The concrete list of the effects, that the <a>Process</a> uses
type InterruptableProcEff = InterruptableProcess SchedulerIO

-- | The concrete list of <a>Eff</a>ects of processes compatible with this
--   scheduler. This builds upon <a>SchedulerIO</a>.
type ProcEff = ConsProcess SchedulerIO

-- | Start the message passing concurrency system then execute a
--   <a>Process</a> on top of <a>SchedulerIO</a> effect. All logging is
--   sent to standard output.
defaultMain :: HasCallStack => Eff InterruptableProcEff () -> IO ()

-- | Start the message passing concurrency system then execute a
--   <a>Process</a> on top of <a>SchedulerIO</a> effect. All logging is
--   sent to standard output.
defaultMainWithLogWriter :: HasCallStack => LogWriter IO -> Eff InterruptableProcEff () -> IO ()

-- | This is the main entry point to running a message passing concurrency
--   application. This function takes a <a>Process</a> on top of the
--   <a>SchedulerIO</a> effect for concurrent logging.
schedule :: HasCallStack => Eff InterruptableProcEff () -> Eff LoggingAndIo ()

-- | Like <a>scheduleIO</a> but <i>pure</i>. The <tt>yield</tt> effect is
--   just <tt>return ()</tt>. <tt>schedulePure == runIdentity .
--   <a>scheduleM</a> (Identity . run) (return ())</tt>
schedulePure :: Eff (InterruptableProcess '[Logs, LogWriterReader PureLogWriter]) a -> Either (Interrupt  'NoRecovery) a

-- | Execute a <a>Process</a> using <a>scheduleM</a> on top of <a>Lift</a>
--   <tt>IO</tt> and <a>withLogging</a> <tt>String</tt> effects.
defaultMainSingleThreaded :: HasCallStack => Eff (InterruptableProcess LoggingAndIo) () -> IO ()