external

Documentation

Index

• type WatchLoadAvg
  • func (this *WatchLoadAvg) Init(ctx monitor.Context)
  • func (this *WatchLoadAvg) Run()

Types

type WatchLoadAvg

type WatchLoadAvg struct {
	Stop <-chan struct{}
	Wg   *sync.WaitGroup
}

WatchLoadAvg watches all servers load avg within a zone. These includes kateway/kafka/zk/, etc.

func (*WatchLoadAvg) Init

func (this *WatchLoadAvg) Init(ctx monitor.Context)

func (*WatchLoadAvg) Run

func (this *WatchLoadAvg) Run()