src/client/pps.go
func (c APIClient) ListJobF(pipelineName string, inputCommit []*pfs.Commit, outputCommit *pfs.Commit, f func(*pps.JobInfo) error) error {
	var pipeline *pps.Pipeline
	if pipelineName != "" {
		pipeline = NewPipeline(pipelineName)
	}
	client, err := c.PpsAPIClient.ListJobStream(
		c.Ctx(),
		&pps.ListJobRequest{
			Pipeline:     pipeline,
			InputCommit:  inputCommit,
			OutputCommit: outputCommit,
		})
	if err != nil {
		return grpcutil.ScrubGRPC(err)
	}
	for {
		ji, err := client.Recv()
		if err == io.EOF {
			return nil
		} else if err != nil {
			return grpcutil.ScrubGRPC(err)
		}
		if err := f(ji); err != nil {
			if err == errutil.ErrBreak {
				return nil
			}
			return err
		}
	}
}
func (c APIClient) ListJobF(pipelineName string, inputCommit []*pfs.Commit, outputCommit *pfs.Commit, f func(*pps.JobInfo) error) error {
	var pipeline *pps.Pipeline
	if pipelineName != "" {
		pipeline = NewPipeline(pipelineName)
	}
	client, err := c.PpsAPIClient.ListJobStream(
		c.Ctx(),
		&pps.ListJobRequest{
			Pipeline:     pipeline,
			InputCommit:  inputCommit,
			OutputCommit: outputCommit,
		})
	if err != nil {
		return grpcutil.ScrubGRPC(err)
	}
	for {
		ji, err := client.Recv()
		if err == io.EOF {
			return nil
		} else if err != nil {
			return grpcutil.ScrubGRPC(err)
		}
		if err := f(ji); err != nil {
			if err == errutil.ErrBreak {
				return nil
			}
			return err
		}
	}
}
func ( c APIClient ) ListJobF ( pipelineName string , inputCommit [ ] * pfs . Commit , outputCommit * pfs . Commit , f func ( * pps . JobInfo ) error ) error { var pipeline * pps . Pipeline if pipelineName != " " { pipeline = NewPipeline ( pipelineName ) } client , err := c . PpsAPIClient . ListJobStream ( c . Ctx ( ) , & pps . ListJobRequest { Pipeline : pipeline , InputCommit : inputCommit , OutputCommit : outputCommit , } ) if err != nil { return grpcutil . ScrubGRPC ( err ) } for { ji , err := client . Recv ( ) if err == io . EOF { return nil } else if err != nil { return grpcutil . ScrubGRPC ( err ) } if err := f ( ji ) ; err != nil { if err == errutil . ErrBreak { return nil } return err } } }
// ListJobF returns info about all jobs, calling f with each JobInfo.
// If f returns an error iteration of jobs will stop and ListJobF will return
// that error, unless the error is errutil.ErrBreak in which case it will
// return nil.
// If pipelineName is non empty then only jobs that were started by the named pipeline will be returned
// If inputCommit is non-nil then only jobs which took the specific commits as inputs will be returned.
// The order of the inputCommits doesn't matter.
// If outputCommit is non-nil then only the job which created that commit as output will be returned.
ListJobF returns info about all jobs calling f with each JobInfo . If f returns an error iteration of jobs will stop and ListJobF will return that error unless the error is errutil . ErrBreak in which case it will return nil . If pipelineName is non empty then only jobs that were started by the named pipeline will be returned If inputCommit is non - nil then only jobs which took the specific commits as inputs will be returned . The order of the inputCommits doesn t matter . If outputCommit is non - nil then only the job which created that commit as output will be returned .