package deps
import (
"net/http"
"time"
package api
import (
"io"
"net/http"
)
export class AppError extends Error {
public readonly statusCode: number;
public readonly code: string;
public readonly isOperational: boolean;
constructor(message: string, statusCode = 500, code = 'INTERNAL_ERROR', isOperational = true) {
export type CircuitState = "closed" | "open" | "half-open";
export interface CircuitBreakerOptions {
failureThreshold: number;
resetTimeout: number; // ms to wait in "open" before probing
onStateChange?: (from: CircuitState, to: CircuitState) => void;
package api
import (
"encoding/json"
"net/http"
)
<?php
namespace App\Http\Middleware;
use Closure;
use Illuminate\Http\Request;
const express = require('express');
const { toCsv } = require('./csvSerializer');
const { fetchOrders } = require('./orderRepository');
const router = express.Router();
from typing import Any, Optional
from fastapi.responses import JSONResponse
from pydantic import BaseModel
package com.example.ratelimit;
public class TokenBucket {
private final long capacity;
private final long refillTokens;
import time
import threading
from collections import deque, defaultdict
class SlidingWindowLimiter:
package optimistic
import (
"errors"
"sync"
)
const { Pool } = require('pg');
const Cursor = require('pg-cursor');
const pool = new Pool();
async function* streamUsers({ since, batchSize = 500 }) {