MCPcopy
hub / github.com/cortexlabs/cortex / TotalMessages

Method TotalMessages

pkg/dequeuer/queue_attributes.go:33–35  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

31}
32
33func (attr QueueAttributes) TotalMessages() int {
34 return attr.VisibleMessages + attr.InvisibleMessages
35}
36
37func GetQueueAttributes(client *awslib.Client, queueURL string) (QueueAttributes, error) {
38 result, err := client.SQS().GetQueueAttributes(

Callers 2

onJobCompleteMethod · 0.80
workerMethod · 0.80

Calls

no outgoing calls

Tested by

no test coverage detected