func NewDeploymentsWatcher(logger *log.Logger, watchers DeploymentStateWatchers,
	raft DeploymentRaftEndpoints, stateQueriesPerSecond float64,
	evalBatchDuration time.Duration) *Watcher {

	return &Watcher{
		stateWatchers:     watchers,
		raft:              raft,
		queryLimiter:      rate.NewLimiter(rate.Limit(stateQueriesPerSecond), 100),
		evalBatchDuration: evalBatchDuration,
		logger:            logger,
	}
}
// NewDeploymentsWatcher returns a deployments watcher that is used to watch
// deployments and trigger the scheduler as needed.
NewDeploymentsWatcher returns a deployments watcher that is used to watch
deployments and trigger the scheduler as needed.
// NewDeploymentsWatcher returns a deployments watcher that is used to watch // deployments and trigger the scheduler as needed .
func NewDeploymentsWatcher(logger *log.Logger, watchers DeploymentStateWatchers,
	raft DeploymentRaftEndpoints, stateQueriesPerSecond float64,
	evalBatchDuration time.Duration) *Watcher {
	return &Watcher{
		stateWatchers:     watchers,
		raft:              raft,
		queryLimiter:      rate.NewLimiter(rate.Limit(stateQueriesPerSecond), 100),
		evalBatchDuration: evalBatchDuration,
		logger:            logger,
	}
}
func NewDeploymentsWatcher ( logger * log . Logger , watchers DeploymentStateWatchers , raft DeploymentRaftEndpoints , stateQueriesPerSecond float64 , evalBatchDuration time . Duration ) * Watcher { return & Watcher { stateWatchers : watchers , raft : raft , queryLimiter : rate . NewLimiter ( rate . Limit ( stateQueriesPerSecond ) , 100 ) , evalBatchDuration : evalBatchDuration , logger : logger , } }
NewDeploymentsWatcher returns a deployments watcher that is used to watch
deployments and trigger the scheduler as needed.
NewDeploymentsWatcher returns a deployments watcher that is used to watch deployments and trigger the scheduler as needed .