func (s *StateStore) jobByIDAndVersionImpl(ws memdb.WatchSet, id string, version uint64, txn *memdb.Txn) (*structs.Job, error) {
	watchCh, existing, err := txn.FirstWatch("job_version", "id", id, version)
	if err != nil {
		return nil, err
	}

	if ws != nil {
		ws.Add(watchCh)
	}

	if existing != nil {
		job := existing.(*structs.Job)
		return job, nil
	}

	return nil, nil
}
// jobByIDAndVersionImpl returns the job identified by its ID and Version. The
// passed watchset may be nil.
jobByIDAndVersionImpl returns the job identified by its ID and Version. The
passed watchset may be nil.
// jobByIDAndVersionImpl returns the job identified by its ID and Version . The // passed watchset may be nil .
func (s *StateStore) jobByIDAndVersionImpl(ws memdb.WatchSet, id string, version uint64, txn *memdb.Txn) (*structs.Job, error) {
	watchCh, existing, err := txn.FirstWatch("job_version", "id", id, version)
	if err != nil {
		return nil, err
	}
	if ws != nil {
		ws.Add(watchCh)
	}
	if existing != nil {
		job := existing.(*structs.Job)
		return job, nil
	}
	return nil, nil
}
func ( s * StateStore ) jobByIDAndVersionImpl ( ws memdb . WatchSet , id string , version uint64 , txn * memdb . Txn ) ( * structs . Job , error ) { watchCh , existing , err := txn . FirstWatch ( " " , " " , id , version ) if err != nil { return nil , err } if ws != nil { ws . Add ( watchCh ) } if existing != nil { job := existing . ( * structs . Job ) return job , nil } return nil , nil }
jobByIDAndVersionImpl returns the job identified by its ID and Version.
jobByIDAndVersionImpl returns the job identified by its ID and Version .