RegisterRepository register a named repository. Use this for multi-repo setup
(repo repository.ClockedRepo, name string)
| 22 | |
| 23 | // RegisterRepository register a named repository. Use this for multi-repo setup |
| 24 | func (c *MultiRepoCache) RegisterRepository(repo repository.ClockedRepo, name string) (*RepoCache, chan BuildEvent) { |
| 25 | r, events := NewNamedRepoCache(repo, name) |
| 26 | |
| 27 | // intercept events to make sure the cache building process succeed properly |
| 28 | out := make(chan BuildEvent) |
| 29 | go func() { |
| 30 | defer close(out) |
| 31 | |
| 32 | for event := range events { |
| 33 | out <- event |
| 34 | if event.Err != nil { |
| 35 | return |
| 36 | } |
| 37 | } |
| 38 | |
| 39 | c.repos[name] = r |
| 40 | }() |
| 41 | |
| 42 | return r, out |
| 43 | } |
| 44 | |
| 45 | // RegisterDefaultRepository register an unnamed repository. Use this for single-repo setup |
| 46 | func (c *MultiRepoCache) RegisterDefaultRepository(repo repository.ClockedRepo) (*RepoCache, chan BuildEvent) { |
no test coverage detected