analyze

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

type Option func(*Analyzer)

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

type RebalancerOption func(*Rebalancer)

type Snapshot struct {
	At         time.Time
	Constraint string          // empty if none identified
	Confidence float64         // 0.0-1.0
	Stages     []StageSnapshot // ordered by registration

	// DrumStarvationCount tracks consecutive intervals the identified
	// constraint was classified as [StateStarved] (high idle ratio,
	// queue draining). A non-zero value is a Step 2 violation — the
	// drum is being wasted. Reset when the drum stops being starved.
	DrumStarvationCount int
}

type StageAnalysis struct {
	State           StageState
	Utilization     float64
	IdleRatio       float64
	BlockedRatio    float64
	QueueGrowth     float64
	ErrorRate       float64
	Goodput         float64 // successful completions/sec
	ArrivalRate     float64 // submitted items/sec
	CurrentWorkers  int
	Recommendation  int    // suggested workers; 0 = no recommendation
	RecommendReason string // human-readable explanation
}

type StageControl struct {
	Name       string
	SetWorkers func(int) (int, error)
	Stats      func() toc.Stats
	Policy     WorkerPolicy
}

type StageSnapshot struct {
	Name     string
	Analysis StageAnalysis
}

type StageSpec struct {
	Name       string
	Stats      func() toc.Stats
	MinWorkers int  // default 1
	MaxWorkers int  // 0 = unlimited
	Scalable   bool // false = don't recommend changes
}

type StageState int

type WorkerPolicy struct {
	Min       int  // minimum workers (default 1)
	Max       int  // maximum workers (0 = unlimited)
	DonateOK  bool // can workers be taken from this stage
	ReceiveOK bool // can workers be added to this stage
}