/** * MinMaxQueue implementation in Redis using a single sorted set * * ## Data Structure * - Uses a Redis sorted set where: * - Score: timestamp when value was added (seconds since epoch) * - Member: the actual bigint value (stored as string) * * ## Flow * 1. **Adding values**: New values are added/updated with current timestamp as score * 2. **Reading values**: Queries filter out expired entries based on timestamp * 3. **Cleanup**: Background process runs every minute to remove expired entries * * ## Optimization Strategy * - Lazy cleanup: expired entries filtered on read, bulk removed by background process (removing is expensive) * * ## TTL Management * - Entries expire based on `queueValidity` (configured via `gasPriceExpiry`) * - Background cleanup prevents unbounded growth * - Read operations ignore expired entries without removing them */ import type { MinMaxQueue } from "./index.js"; import type { AltoConfig } from "../../createConfig.js"; export declare const createRedisMinMaxQueue: ({ config, queueName, redisEndpoint }: { config: AltoConfig; queueName: string; redisEndpoint: string; }) => MinMaxQueue; //# sourceMappingURL=createRedisMinMaxQueue.d.ts.map