Versions in this module Expand all Collapse all v0 v0.1.0 Mar 25, 2026 Changes in this version + type Rebalancer struct + func NewRebalancer(diagnosis func() *core.Diagnosis, opts ...RebalancerOption) *Rebalancer + func (r *Rebalancer) AddStage(sc StageControl) + func (r *Rebalancer) Disable() + func (r *Rebalancer) Enable() + func (r *Rebalancer) Enabled() bool + func (r *Rebalancer) FormatStatus() string + func (r *Rebalancer) Run(ctx context.Context, interval time.Duration) + type RebalancerOption func(*Rebalancer) + func WithCooldown(n int) RebalancerOption + func WithKillSwitch(fn func() bool) RebalancerOption + func WithRebalancerLogger(l *log.Logger) RebalancerOption + type StageControl struct + Name string + Policy WorkerPolicy + SetWorkers func(int) (int, error) + Stats func() toc.Stats + type WorkerPolicy struct + DonateOK bool + Max int + Min int + ReceiveOK bool
Go to main page