Documentation ¶
Index ¶
- func AddMessagesToQueue(client sqsiface.SQSAPI, qname string, nBatches, messageBatchSize int) (err error)
- func CountMessagesInQueue(client sqsiface.SQSAPI, qname string, ...) (totalMessages, totalMessagesWithAttrs int, err error)
- func CountObjectsInBucket(client s3iface.S3API, bucket, prefix string) (count int, err error)
- func CreateQueue(client sqsiface.SQSAPI, qname string) (err error)
- func CreateTopic(client snsiface.SNSAPI, topic string) (output *sns.CreateTopicOutput, err error)
- func DeleteQueue(client sqsiface.SQSAPI, qname string) (err error)
- func DeleteTopic(client snsiface.SNSAPI, topicArn string) (err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddMessagesToQueue ¶
func CountMessagesInQueue ¶
func CountObjectsInBucket ¶ added in v1.15.0
func CreateTopic ¶ added in v1.15.0
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.