cloudemu

Rate Limiting

Token bucket rate limiter that returns Throttled errors

Rate Limiting

Simulate API rate limits using a token bucket algorithm.

Setup

import "github.com/stackshy/cloudemu/ratelimit"

limiter := ratelimit.NewLimiter(100) // 100 requests per second

bucket := storage.NewBucket(aws.S3,
    storage.WithRateLimiter(limiter),
)

Behavior

When the rate limit is exceeded, operations return a Throttled error:

import cerrors "github.com/stackshy/cloudemu/errors"

err := bucket.PutObject(ctx, "bucket", "key", data, "text/plain", nil)
if cerrors.IsThrottled(err) {
    // Rate limit exceeded — back off and retry
}

Use Cases

  • Test that your retry logic handles rate limiting correctly
  • Verify circuit breaker behavior under sustained throttling
  • Simulate cloud provider API quotas

Metrics Collection

Track call counts, durations, and errors per operation

Error Injection

Simulate cloud failures deterministically

On this page

Rate LimitingSetupBehaviorUse Cases