Safe Haskell | None |
---|---|
Language | Haskell2010 |
Synopsis
- newtype QueueUrl = QueueUrl Text
- data SQSError = DeleteMessageBatchError
- readQueue :: (HasEnv e, MonadUnliftIO m) => e -> QueueUrl -> m [Message]
- drainQueue :: (HasEnv e, MonadUnliftIO m) => e -> QueueUrl -> m [Message]
- ackMessage :: (HasEnv e, MonadUnliftIO m) => e -> QueueUrl -> Message -> m (Either SQSError ())
- ackMessages :: (HasEnv e, MonadUnliftIO m) => e -> QueueUrl -> [Message] -> m (Either SQSError ())
- messageInBody :: Text -> Maybe Text
- messageToS3Uri :: Message -> Maybe S3Uri
- messageToS3Uri' :: Text -> Maybe S3Uri
Documentation
Instances
Eq QueueUrl Source # | |
Show QueueUrl Source # | |
IsString QueueUrl Source # | |
Defined in Antiope.SQS.Types fromString :: String -> QueueUrl # | |
Generic QueueUrl Source # | |
ToText QueueUrl Source # | |
Defined in Antiope.SQS.Types | |
FromText QueueUrl Source # | |
Defined in Antiope.SQS.Types | |
type Rep QueueUrl Source # | |
Defined in Antiope.SQS.Types |
readQueue :: (HasEnv e, MonadUnliftIO m) => e -> QueueUrl -> m [Message] Source #
Reads the specified SQS queue once returning a bath of messages
drainQueue :: (HasEnv e, MonadUnliftIO m) => e -> QueueUrl -> m [Message] Source #
Reads the specified SQS queue until it is empty and returns a list of messages
ackMessage :: (HasEnv e, MonadUnliftIO m) => e -> QueueUrl -> Message -> m (Either SQSError ()) Source #
ackMessages :: (HasEnv e, MonadUnliftIO m) => e -> QueueUrl -> [Message] -> m (Either SQSError ()) Source #