func (w *worker) createRepo(c *client.APIClient) error {
	repoName := w.randString(10)
	if err := c.CreateRepo(repoName); err != nil {
		return err
	}
	w.repos = append(w.repos, &pfs.Repo{Name: repoName})

	// Start the first commit in the repo (no parent). This is critical to
	// advanceCommit(), which will try to finish a commit the first time it's
	// called, and therefore must have an open commit to finish.
	commit, err := c.StartCommit(repoName, "")
	if err != nil {
		return err
	}
	w.started = append(w.started, commit)
	return nil
}
func (w *worker) createRepo(c *client.APIClient) error {
	repoName := w.randString(10)
	if err := c.CreateRepo(repoName); err != nil {
		return err
	}
	w.repos = append(w.repos, &pfs.Repo{Name: repoName})

	
	
	
	commit, err := c.StartCommit(repoName, "")
	if err != nil {
		return err
	}
	w.started = append(w.started, commit)
	return nil
}
func ( w * worker ) createRepo ( c * client . APIClient ) error { repoName := w . randString ( 10 ) if err := c . CreateRepo ( repoName ) ; err != nil { return err } w . repos = append ( w . repos , & pfs . Repo { Name : repoName } ) // Start the first commit in the repo (no parent). This is critical to // advanceCommit(), which will try to finish a commit the first time it's // called, and therefore must have an open commit to finish. commit , err := c . StartCommit ( repoName , " " ) if err != nil { return err } w . started = append ( w . started , commit ) return nil }
// createRepo creates a new repo in the cluster
createRepo creates a new repo in the cluster