Database.PostgreSQL.Replicant.Queue

Shared FIFO queues

Documentation

data BoundedFifoQueueMeta a

Constructors

BoundedFifoQueueMeta

Fields

• boundedFifoQueueSize :: Int
• boundedFifoQueue :: Seq a

Instances

Eq a => Eq (BoundedFifoQueueMeta a)

Defined in Database.PostgreSQL.Replicant.Queue

Methods

(==) :: BoundedFifoQueueMeta a -> BoundedFifoQueueMeta a -> Bool

(/=) :: BoundedFifoQueueMeta a -> BoundedFifoQueueMeta a -> Bool

Show a => Show (BoundedFifoQueueMeta a)

Defined in Database.PostgreSQL.Replicant.Queue

Methods

showsPrec :: Int -> BoundedFifoQueueMeta a -> ShowS

show :: BoundedFifoQueueMeta a -> String

showList :: [BoundedFifoQueueMeta a] -> ShowS

newtype BoundedFifoQueue a

Constructors

BoundedFifoQueue (MVar (BoundedFifoQueueMeta a))

newtype BoundedQueueException a

Constructors

BoundedQueueOverflow a

Instances

Eq a => Eq (BoundedQueueException a)

Defined in Database.PostgreSQL.Replicant.Queue

Methods

(==) :: BoundedQueueException a -> BoundedQueueException a -> Bool

(/=) :: BoundedQueueException a -> BoundedQueueException a -> Bool

Show a => Show (BoundedQueueException a)

Defined in Database.PostgreSQL.Replicant.Queue

Methods

showsPrec :: Int -> BoundedQueueException a -> ShowS

show :: BoundedQueueException a -> String

showList :: [BoundedQueueException a] -> ShowS

emptyBounded :: Int -> IO (BoundedFifoQueue a)

enqueueBounded :: BoundedFifoQueue a -> a -> IO (Either (BoundedQueueException a) ())

newtype FifoQueue a

Constructors

FifoQueue (MVar (Seq a))

empty :: IO (FifoQueue a)

null :: FifoQueue a -> IO Bool

Return True if the queue is empty

dequeue :: FifoQueue a -> IO (Maybe a)

Remove an item from the end of the non-empty queue.

enqueue :: FifoQueue a -> a -> IO ()

Put an item on the front of the queue.

enqueueRight :: FifoQueue a -> a -> IO ()

Put an item on the end of the queue so that it will be dequeued first.