resource

type Action struct {
	ProcessID    string
	Kind         string // "rss" | "cpu"
	Current      float64
	Limit        float64
	ExceedAction cliwrap.ExceedAction
}

type Evaluator struct {
	// contains filtered or unexported fields
}

type EvaluatorOptions struct {
	// OnAction is invoked (synchronously) when a sustained breach is detected.
	OnAction func(Action)

	// RSSBreachThreshold sets the consecutive breach count for memory.
	// Default 3.
	RSSBreachThreshold int

	// CPUBreachThreshold sets the consecutive breach count for CPU.
	// Default 10 (CPU samples are noisier).
	CPUBreachThreshold int
}

type Monitor struct {
	// contains filtered or unexported fields
}

type MonitorOptions struct {
	Interval         time.Duration
	Source           PIDSource
	ProcessCollector ProcessCollector
	SystemCollector  SystemCollector
	OnSample         func(id string, s Sample)
	OnSystem         func(s SystemSample)
}

type PIDSource interface {
	ChildPIDs() map[string]int
}

type ProcessCollector interface {
	Collect(pid int) (Sample, error)
}

type Sample struct {
	PID        int
	RSS        uint64  // bytes
	VMS        uint64  // bytes
	CPUPercent float64 // 0-100 normalized per core
	NumThreads int
	NumFDs     int
	SampledAt  time.Time
}

type SystemCollector interface {
	Collect() (SystemSample, error)
}

type SystemSample struct {
	TotalMemory     uint64
	AvailableMemory uint64
	LoadAvg1        float64
	LoadAvg5        float64
	NumCPU          int
	SampledAt       time.Time
}