Function validateRateLimitConfig

lib/api/bucketPutRateLimit.js:20–48

(requestConfig, callback)

}

function validateRateLimitConfig(requestConfig, callback) {
    const limit = requestConfig.RequestsPerSecond;
    if (Number.isNaN(limit) || !Number.isInteger(limit) || limit < 0) {
        return callback(errorInstances.InvalidArgument
            .customizeDescription('RequestsPerSecond must be a positive integer'));
    }

    // Validate limit against node count AND worker count
    const nodes = config.rateLimiting?.nodes || 1;
    const workers = config.clusters || 1;
    const minLimit = nodes * workers;

    if (limit > 0 && limit < minLimit) {
        return callback(errorInstances.InvalidArgument
            .customizeDescription(
                `RequestsPerSecond (${limit}) must be >= ` +
                `(nodes x workers = ${nodes} x ${workers} = ${minLimit}) or 0 (unlimited). ` +
                'Each worker enforces limit/nodes/workers locally. ' +
                `With limit less than ${minLimit}, per-worker rate would be less than 1 req/s, ` +
                'effectively blocking traffic.'
            ));
    }

    return callback(null, new models.RateLimitConfiguration({
        RequestsPerSecond: {
            Limit: limit,
        },
    }));
}

/**
 * bucketPutRateLimit - create or update a bucket policy