ratelimit

Jan 10, 2026

Changes in this version

type Limiter — darwin/amd64, linux/amd64, windows/amd64

+ func NewMemoryOnlyLimiter(config Config) *Limiter

+ type MemoryMonitor struct — darwin/amd64, linux/amd64, windows/amd64

+ func NewMemoryMonitor(pollInterval time.Duration) *MemoryMonitor

+ func (m *MemoryMonitor) ForceEmergencyMode(duration time.Duration)

+ func (m *MemoryMonitor) GetEmergencyThreshold() float64

+ func (m *MemoryMonitor) GetMetrics() loadmonitor.Metrics

+ func (m *MemoryMonitor) RecordQueryLatency(latency time.Duration)

+ func (m *MemoryMonitor) RecordWriteLatency(latency time.Duration)

+ func (m *MemoryMonitor) SetEmergencyThreshold(threshold float64)

+ func (m *MemoryMonitor) SetMemoryTarget(bytes uint64)

+ func (m *MemoryMonitor) Start() <-chan struct{}

+ func (m *MemoryMonitor) Stop()

Dec 14, 2025

Changes in this version

+ const AutoDetectMemoryFraction — darwin/amd64, linux/amd64, windows/amd64

+ const DefaultMaxMemoryMB — darwin/amd64, linux/amd64, windows/amd64

+ const MinimumMemoryMB — darwin/amd64, linux/amd64, windows/amd64

+ const ThrottleCheckInterval

+ var ErrInsufficientMemory = errors.New("insufficient memory: relay requires at least 500MB of available memory") — darwin/amd64, linux/amd64, windows/amd64

+ func CalculateTargetMemoryMB(configuredMB int) (int, error) — darwin/amd64, linux/amd64, windows/amd64

+ func DetectAvailableMemoryMB() uint64 — darwin/amd64, linux/amd64, windows/amd64

+ func DetectTotalMemoryMB() uint64 — darwin/amd64, linux/amd64, windows/amd64

type BadgerMonitor — darwin/amd64, linux/amd64, windows/amd64

+ func (m *BadgerMonitor) ForceEmergencyMode(duration time.Duration)

+ func (m *BadgerMonitor) GetEmergencyThreshold() float64

+ func (m *BadgerMonitor) IsCompacting() bool

+ func (m *BadgerMonitor) SetEmergencyThreshold(threshold float64)

+ func (m *BadgerMonitor) TriggerCompaction() error

type Config

+ CompactionCheckInterval time.Duration

+ EmergencyMaxDelayMs int

+ EmergencyThreshold float64

+ RecoveryThreshold float64

type Limiter

+ func (l *Limiter) InEmergencyMode() bool

+ type MemoryStats struct — darwin/amd64, linux/amd64, windows/amd64

+ AvailableMB uint64

+ GoAllocatedMB uint64

+ GoSysMB uint64

+ TargetMB int

+ TotalMB uint64

+ func GetMemoryStats(targetMB int) MemoryStats

type Neo4jMonitor

+ func (m *Neo4jMonitor) ForceEmergencyMode(duration time.Duration)

+ func (m *Neo4jMonitor) GetEmergencyThreshold() float64

+ func (m *Neo4jMonitor) GetThrottleMultiplier() float64

+ func (m *Neo4jMonitor) SetEmergencyThreshold(threshold float64)

+ type ProcessMemoryStats struct — darwin/amd64, linux/amd64, windows/amd64

+ RssAnon uint64

+ RssShmem uint64

+ VmHWM uint64

+ VmRSS uint64

+ func ReadProcessMemoryStats() ProcessMemoryStats

+ func (p ProcessMemoryStats) PhysicalMemoryBytes() uint64

+ func (p ProcessMemoryStats) PhysicalMemoryMB() uint64

type Stats

+ EmergencyEvents int64

+ InEmergencyMode bool

Dec 12, 2025

Changes in this version

+ func MonitorFromBadgerDB(db *badger.DB) loadmonitor.Monitor — darwin/amd64, linux/amd64, windows/amd64

+ func MonitorFromNeo4jDriver(driver neo4j.DriverWithContext, querySem chan struct{}, maxConcurrency int) loadmonitor.Monitor — darwin/amd64, linux/amd64, windows/amd64

+ type BadgerMonitor struct — darwin/amd64, linux/amd64, windows/amd64

+ func NewBadgerMonitor(db *badger.DB, updateInterval time.Duration) *BadgerMonitor

+ func (m *BadgerMonitor) GetL0Stats() (tables int, score float64)

+ func (m *BadgerMonitor) GetMetrics() loadmonitor.Metrics

+ func (m *BadgerMonitor) RecordQueryLatency(latency time.Duration)

+ func (m *BadgerMonitor) RecordWriteLatency(latency time.Duration)

+ func (m *BadgerMonitor) SetMemoryTarget(bytes uint64)

+ func (m *BadgerMonitor) Start() <-chan struct{}

+ func (m *BadgerMonitor) Stop()

+ type Config struct

+ Enabled bool

+ MaxReadDelayMs int

+ MaxWriteDelayMs int

+ MemoryWeight float64

+ MetricUpdateInterval time.Duration

+ ReadKd float64

+ ReadKi float64

+ ReadKp float64

+ ReadSetpoint float64

+ TargetMemoryMB int

+ WriteKd float64

+ WriteKi float64

+ WriteKp float64

+ WriteSetpoint float64

+ func DefaultConfig() Config

+ func NewConfigFromValues(enabled bool, targetMB int, writeKp, writeKi, writeKd float64, ...) Config

+ type Limiter struct

+ func NewBadgerLimiter(config Config, db *badger.DB) *Limiter

+ func NewDisabledLimiter() *Limiter

+ func NewLimiter(config Config, monitor loadmonitor.Monitor) *Limiter

+ func NewNeo4jLimiter(config Config, driver neo4j.DriverWithContext, querySem chan struct{}, ...) *Limiter

+ func (l *Limiter) ComputeDelay(opType OperationType) time.Duration

+ func (l *Limiter) GetStats() Stats

+ func (l *Limiter) IsEnabled() bool

+ func (l *Limiter) RecordLatency(opType OperationType, latency time.Duration)

+ func (l *Limiter) Reset()

+ func (l *Limiter) Start()

+ func (l *Limiter) Stop()

+ func (l *Limiter) Stopped() <-chan struct{}

+ func (l *Limiter) UpdateConfig(config Config)

+ func (l *Limiter) Wait(ctx context.Context, opType OperationType) time.Duration

+ type Neo4jMonitor struct

+ func NewNeo4jMonitor(driver neo4j.DriverWithContext, querySem chan struct{}, maxConcurrency int, ...) *Neo4jMonitor

+ func (m *Neo4jMonitor) CheckConnectivity(ctx context.Context) error

+ func (m *Neo4jMonitor) GetConcurrencyStats() (reads, writes int32, semUsed int)

+ func (m *Neo4jMonitor) GetMetrics() loadmonitor.Metrics

+ func (m *Neo4jMonitor) IncrementActiveReads() func()

+ func (m *Neo4jMonitor) IncrementActiveWrites() func()

+ func (m *Neo4jMonitor) RecordQueryLatency(latency time.Duration)

+ func (m *Neo4jMonitor) RecordWriteLatency(latency time.Duration)

+ func (m *Neo4jMonitor) SetMemoryTarget(bytes uint64)

+ func (m *Neo4jMonitor) Start() <-chan struct{}

+ func (m *Neo4jMonitor) Stop()

+ type OperationType int

+ const Read

+ const Write

+ func (o OperationType) String() string

+ type PIDController struct

+ DerivativeFilterAlpha float64

+ IntegralMax float64

+ IntegralMin float64

+ Kd float64

+ Ki float64

+ Kp float64

+ OutputMax float64

+ OutputMin float64

+ Setpoint float64

+ func DefaultPIDControllerForReads() *PIDController

+ func DefaultPIDControllerForWrites() *PIDController

+ func NewPIDController(kp, ki, kd float64, setpoint float64, derivativeFilterAlpha float64, ...) *PIDController

+ func (p *PIDController) GetState() (integral, prevError, prevFilteredError float64)

+ func (p *PIDController) Reset()

+ func (p *PIDController) SetGains(kp, ki, kd float64)

+ func (p *PIDController) SetSetpoint(setpoint float64)

+ func (p *PIDController) Update(processVariable float64) float64

+ type PIDState struct

+ Integral float64

+ PrevError float64

+ PrevFilteredError float64

+ type Stats struct

+ CurrentMetrics loadmonitor.Metrics

+ ReadPIDState PIDState

+ ReadThrottles int64

+ TotalReadDelayMs int64

+ TotalWriteDelayMs int64

+ WritePIDState PIDState

+ WriteThrottles int64