1. import java.util.HashMap;
  2. import java.util.Map;
  3. import java.time.Instant;
  4. import java.time.Duration;
  6. public class LogDecoder {
  8. private final Map<String, Long> lastRunTimes = new HashMap<>();
  9. private final long rateLimitIntervalSeconds; // e.g., 60 for 1 minute
  11. public LogDecoder(long rateLimitIntervalSeconds) {
  12. this.rateLimitIntervalSeconds = rateLimitIntervalSeconds;
  13. }
  15. public boolean isAllowed(String logEntry) {
  16. // Get the current time
  17. Instant now = Instant.now();
  19. // Get the last run time for this log entry type (key)
  20. Long lastRunTime = lastRunTimes.get(logEntry);
  22. // If this is the first time we've seen this log entry type...
  23. if (lastRunTime == null) {
  24. // ...allow it.
  25. lastRunTimes.put(logEntry, now.toEpochMilli());
  26. return true;
  27. }
  29. // Calculate the time elapsed since the last run
  30. Duration timeElapsed = Duration.between(Instant.ofEpochMilli(lastRunTime), now);
  32. // Check if the time elapsed is greater than or equal to the rate limit interval
  33. if (timeElapsed.getSeconds() >= rateLimitIntervalSeconds) {
  34. // Allow the log entry
  35. lastRunTimes.put(logEntry, now.toEpochMilli());
  36. return true;
  37. } else {
  38. // Rate limited - don't allow the log entry
  39. return false;
  40. }
  41. }
  42. }

Add your comment