1. <?php
  3. class LogStreamThrottler
  4. {
  5. private $logStreamName;
  6. private $requestsPerSecond;
  7. private $dryRun;
  8. private $lastRequestTime;
  9. private $requestCount;
  11. public function __construct(string $logStreamName, int $requestsPerSecond, bool $dryRun = false)
  12. {
  13. $this->logStreamName = $logStreamName;
  14. $this->requestsPerSecond = $requestsPerSecond;
  15. $this->dryRun = $dryRun;
  16. $this->lastRequestTime = 0;
  17. $this->requestCount = 0;
  18. }
  20. public function shouldThrottle(): bool
  21. {
  22. $currentTime = time();
  24. if ($this->dryRun) {
  25. return false; // Don't actually throttle in dry run mode
  26. }
  28. if ($currentTime - $this->lastRequestTime < (1 / $this->requestsPerSecond)) {
  29. return true; // Throttle if request frequency is too high
  30. }
  32. // Allow the request
  33. $this->lastRequestTime = $currentTime;
  34. $this->requestCount = 1;
  35. return false;
  36. }
  38. public function processRequest(): void
  39. {
  40. if ($this->shouldThrottle()) {
  41. if ($this->dryRun) {
  42. echo "DRY RUN: Request throttled for log stream: " . $this->logStreamName . "\n";
  43. } else {
  44. // Simulate throttling - in a real implementation, you would delay the request
  45. sleep(1 / $this->requestsPerSecond); // Introduce a delay
  46. echo "Throttling log stream: " . $this->logStreamName . "\n";
  47. }
  48. return;
  49. }
  51. // Process the request (e.g., write to the log stream)
  52. echo "Processing request for log stream: " . $this->logStreamName . "\n";
  53. // Your log stream processing code here
  54. }
  55. }
  57. // Example Usage:
  58. $throttler = new LogStreamThrottler("my_log_stream", 10, true); // Dry run mode
  59. // $throttler = new LogStreamThrottler("my_log_stream", 10); // Normal mode
  61. for ($i = 0; $i < 20; $i++) {
  62. $throttler->processRequest();
  63. }
  65. ?>

Add your comment