| Safe Haskell | None |
|---|---|
| Language | Haskell2010 |
Hasql.Queue.Low.ExactlyOnce
Synopsis
- enqueue :: Text -> Value a -> [a] -> Session ()
- withDequeue :: Text -> Connection -> Value a -> Int -> (Session [a] -> Session b) -> IO b
- withDequeueWith :: WithNotifyHandlers -> Text -> Connection -> Value a -> Int -> (Session [a] -> Session b) -> IO b
Documentation
Arguments
| :: Text | Notification channel name. Any valid PostgreSQL identifier |
| -> Value a | Payload encoder |
| -> [a] | List of payloads to enqueue |
| -> Session () |
Enqueue a payload send a notification on the specified channel.
Arguments
| :: WithNotifyHandlers | Event handlers for events that occur as |
| -> Text | Notification channel name. Any valid PostgreSQL identifier |
| -> Connection | Connection |
| -> Value a | Payload decoder |
| -> Int | Batch count |
| -> (Session [a] -> Session b) | Transaction runner |
| -> IO b |