Code explainers tagged #sliding-window

package retry
 
import (
	"errors"

use axum::{
    body::Body,
    extract::State,
    http::{Request, StatusCode},

class DownloadTracker {
  constructor(totalBytes, { windowMs = 3000 } = {}) {
    this.totalBytes = totalBytes;
    this.windowMs = windowMs;

interface Reading {
  timestamp: number;
  value: number;
}

type Bucket = { start: number; count: number };
 
export class SlidingWindowCounter {
  private readonly windowMs: number;

class MovingAverage {
  constructor(windowSize) {
    if (!Number.isInteger(windowSize) || windowSize <= 0) {
      throw new RangeError('windowSize must be a positive integer');

package metrics
 
import (
	"sync"

import { NextResponse } from 'next/server';
import { Redis } from '@upstash/redis';
 
const redis = Redis.fromEnv();

<?php
 
namespace App\RateLimiting;
 

class SyncContactsJob < ApplicationJob
  queue_as :external_api
 
  MAX_CONCURRENCY = 5

public class SlidingLogRateLimiter {
 
    private final int maxRequests;
    private final long windowMillis;

use std::collections::VecDeque;
 
pub struct RollingAverage {
    window: VecDeque<f64>,

from django.core.cache import cache
from rest_framework.throttling import SimpleRateThrottle
 
 

class MetricSeries
  def initialize(readings, window: 5)
    @readings = readings
    @window = window

import time
from collections import defaultdict
from threading import Lock
 

import java.util.ArrayDeque;
import java.util.Deque;
 
public final class RollingAverage {

from collections import deque
 
 
class RollingAverage:

// Sliding window maximum using a monotonic decreasing deque.
// Returns an array of the maximum value within each window of size k.
function maxSlidingWindow(nums, k) {
  const result = [];