func (s *StateStore) JobsByScheduler(ws memdb.WatchSet, schedulerType string) (memdb.ResultIterator, error) {
	txn := s.db.Txn(false)

	// Return an iterator for jobs with the specific type.
	iter, err := txn.Get("jobs", "type", schedulerType)
	if err != nil {
		return nil, err
	}

	ws.Add(iter.WatchCh())

	return iter, nil
}
// JobsByScheduler returns an iterator over all the jobs with the specific
// scheduler type.
JobsByScheduler returns an iterator over all the jobs with the specific
scheduler type.
// JobsByScheduler returns an iterator over all the jobs with the specific // scheduler type .
func (s *StateStore) JobsByScheduler(ws memdb.WatchSet, schedulerType string) (memdb.ResultIterator, error) {
	txn := s.db.Txn(false)
	iter, err := txn.Get("jobs", "type", schedulerType)
	if err != nil {
		return nil, err
	}
	ws.Add(iter.WatchCh())
	return iter, nil
}
func ( s * StateStore ) JobsByScheduler ( ws memdb . WatchSet , schedulerType string ) ( memdb . ResultIterator , error ) { txn := s . db . Txn ( false ) iter , err := txn . Get ( " " , " " , schedulerType ) if err != nil { return nil , err } ws . Add ( iter . WatchCh ( ) ) return iter , nil }
JobsByScheduler returns an iterator over all the jobs with the specific
scheduler type.
JobsByScheduler returns an iterator over all the jobs with the specific scheduler type .
// Return an iterator for jobs with the specific type.