Antiope.SQS

Documentation

newtype QueueUrl

Constructors

QueueUrl Text

Instances

Eq QueueUrl

Defined in Antiope.SQS.Types

Methods

(==) :: QueueUrl -> QueueUrl -> Bool

(/=) :: QueueUrl -> QueueUrl -> Bool

Show QueueUrl

Defined in Antiope.SQS.Types

Methods

showsPrec :: Int -> QueueUrl -> ShowS

show :: QueueUrl -> String

showList :: [QueueUrl] -> ShowS

IsString QueueUrl

Defined in Antiope.SQS.Types

Methods

fromString :: String -> QueueUrl

Generic QueueUrl

Defined in Antiope.SQS.Types

Associated Types

type Rep QueueUrl :: * -> *

Methods

from :: QueueUrl -> Rep QueueUrl x

to :: Rep QueueUrl x -> QueueUrl

ToText QueueUrl

Defined in Antiope.SQS.Types

Methods

toText :: QueueUrl -> Text

FromText QueueUrl

Defined in Antiope.SQS.Types

Methods

parser :: Parser QueueUrl

type Rep QueueUrl

Defined in Antiope.SQS.Types

type Rep QueueUrl = D1 (MetaData "QueueUrl" "Antiope.SQS.Types" "antiope-sqs-4.0.0-82ltYZrg8F5EsHyZuSCbLe" True) (C1 (MetaCons "QueueUrl" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))

data SQSError

Constructors

DeleteMessageBatchError

Instances

Eq SQSError

Defined in Antiope.SQS.Types

Methods

(==) :: SQSError -> SQSError -> Bool

(/=) :: SQSError -> SQSError -> Bool

Show SQSError

Defined in Antiope.SQS.Types

Methods

showsPrec :: Int -> SQSError -> ShowS

show :: SQSError -> String

showList :: [SQSError] -> ShowS

Generic SQSError

Defined in Antiope.SQS.Types

Associated Types

type Rep SQSError :: * -> *

Methods

from :: SQSError -> Rep SQSError x

to :: Rep SQSError x -> SQSError

type Rep SQSError

Defined in Antiope.SQS.Types

type Rep SQSError = D1 (MetaData "SQSError" "Antiope.SQS.Types" "antiope-sqs-4.0.0-82ltYZrg8F5EsHyZuSCbLe" False) (C1 (MetaCons "DeleteMessageBatchError" PrefixI False) (U1 :: * -> *))

readQueue :: (HasEnv e, MonadUnliftIO m) => e -> QueueUrl -> m [Message]

Reads the specified SQS queue once returning a bath of messages

drainQueue :: (HasEnv e, MonadUnliftIO m) => e -> QueueUrl -> m [Message]

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 ())

ackMessages :: (HasEnv e, MonadUnliftIO m) => e -> QueueUrl -> [Message] -> m (Either SQSError ())

messageInBody :: Text -> Maybe Text

messageToS3Uri :: Message -> Maybe S3Uri

messageToS3Uri' :: Text -> Maybe S3Uri