memorylimiter

Oct 22, 2024

Changes in this version

+ var ErrDataRefused = errors.New("data refused due to high memory usage")

+ var ErrShutdownNotStarted = errors.New("no existing monitoring routine is running")

+ var GetMemoryFn = iruntime.TotalMemory

+ var ReadMemStatsFn = runtime.ReadMemStats

+ type Config struct

+ CheckInterval time.Duration

+ MemoryLimitMiB uint32

+ MemoryLimitPercentage uint32

+ MemorySpikeLimitMiB uint32

+ MemorySpikePercentage uint32

+ func (cfg *Config) Validate() error

+ type MemoryLimiter struct

+ func NewMemoryLimiter(cfg *Config, logger *zap.Logger) (*MemoryLimiter, error)

+ func (ml *MemoryLimiter) CheckMemLimits()

+ func (ml *MemoryLimiter) MustRefuse() bool

+ func (ml *MemoryLimiter) Shutdown(context.Context) error

+ func (ml *MemoryLimiter) Start(_ context.Context, _ component.Host) error