ForEach runs method for each repository
(handler func(*RemoteRepo) error)
| 1006 | |
| 1007 | // ForEach runs method for each repository |
| 1008 | func (collection *RemoteRepoCollection) ForEach(handler func(*RemoteRepo) error) error { |
| 1009 | return collection.db.ProcessByPrefix([]byte("R"), func(_, blob []byte) error { |
| 1010 | r := &RemoteRepo{} |
| 1011 | if err := r.Decode(blob); err != nil { |
| 1012 | log.Printf("Error decoding mirror: %s\n", err) |
| 1013 | return nil |
| 1014 | } |
| 1015 | |
| 1016 | return handler(r) |
| 1017 | }) |
| 1018 | } |
| 1019 | |
| 1020 | // Len returns number of remote repos |
| 1021 | func (collection *RemoteRepoCollection) Len() int { |
no test coverage detected