Stability	experimental
Portability	portable
Safe Haskell	None
Language	Haskell2010

GHC.Eventlog.Live.Machine.Source

Contents

Eventlog source

Description

Synopsis

sourceHandleWait :: forall (m :: Type -> Type) (k :: Type -> Type). MonadIO m => Int -> Int -> Handle -> MachineT m k (Tick ByteString)
sourceHandleBatch :: forall (m :: Type -> Type) (k :: Type -> Type). MonadIO m => Int -> Int -> Handle -> MachineT m k (Tick ByteString)
defaultChunkSizeBytes :: Int

Eventlog source

sourceHandleWait Source #

Arguments

:: forall (m :: Type -> Type) (k :: Type -> Type). MonadIO m
=> Int	The wait timeout in milliseconds.
-> Int	The number of bytes to read.
-> Handle	The eventlog socket handle.
-> MachineT m k (Tick ByteString)

A source which reads chunks from a Handle. When an input is available, it yields an Item. When the timeout is reached, it yields a Tick.

sourceHandleBatch Source #

Arguments

:: forall (m :: Type -> Type) (k :: Type -> Type). MonadIO m
=> Int	The batch interval in milliseconds.
-> Int	The number of bytes to read.
-> Handle	The eventlog socket handle.
-> MachineT m k (Tick ByteString)

A source which reads chunks from a Handle. When input is available, it yields an Item. It yields a Tick at each increment of the batch interval.

defaultChunkSizeBytes :: Int Source #

Eventlog chunk size in bytes. This should be equal to the page size.