Module sqs_service_helper::autoscaling [−] [src]

Structs

MedianThrottler	`MedianThrottler` tracks the processing time for messages from the consumer to the deleter. It then uses this information to calculate how many messages we can process in 30 seconds, the time it takes for a message to time out. Ideally we process as many messages as we can while ensuring that we don't back our message visibility handlers up, which could lead to more frequent double processing.
StreamingMedian	`StreamingMedian` provides a simple interface for inserting values and calculating medians. By default we start with a repeated median of 31,000. 31,000 is chosen because it is a "worst case" - we assume, at first, that the time to process is longer than the time it takes for a message visibility to time out.
ThrottlerActor