func NewManager() *Manager {
	ret := &Manager{
		stop:                make(chan struct{}),
		updateThrottleLimit: defaultThrottleLimit,
	}

	ret.notEmpty = sync.NewCond(&ret.mutex)

	go ret.dispatcher()

	return ret
}
// NewManager initialises and returns a new Manager.
NewManager initialises and returns a new Manager.
// NewManager initialises and returns a new Manager .
func NewManager() *Manager {
	ret := &Manager{
		stop:                make(chan struct{}),
		updateThrottleLimit: defaultThrottleLimit,
	}
	ret.notEmpty = sync.NewCond(&ret.mutex)
	go ret.dispatcher()
	return ret
}
func NewManager ( ) * Manager { ret := & Manager { stop : make ( chan struct { } ) , updateThrottleLimit : defaultThrottleLimit , } ret . notEmpty = sync . NewCond ( & ret . mutex ) go ret . dispatcher ( ) return ret }
NewManager initialises and returns a new Manager.
NewManager initialises and returns a new Manager .