Colog.Concurrent.Internal

This is internal module, use it on your own risk. The implementation here may be changed without a version bump.

Documentation

data BackgroundWorker msg

Wrapper for the background thread that may receive messages to process.

Constructors

BackgroundWorker

Fields

• backgroundWorkerThreadId :: !ThreadId

  Background ThreadId.

• backgroundWorkerWrite :: msg -> STM ()

  Method for communication with the thread.

• backgroundWorkerIsAlive :: TVar Bool

data Capacity

A wrapper type that carries capacity. The internal type may be differrent for the different GHC versions.

Constructors

Capacity Natural (Maybe Natural)

mkCapacity

Arguments

:: Natural

Size of the queue. Number of the messages in flight

-> Maybe Natural

Maximum number of messages that logger can read in a chunk.

-> Capacity

Creates new capacity.

Since: 0.5.0.0