eventlog-live-0.3.0.0: Live processing of eventlog data.
Stabilityexperimental
Portabilityportable
Safe HaskellNone
LanguageHaskell2010

GHC.Eventlog.Live.Machine.Source

Description

 
Synopsis

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.