diff options
author | Michael Muré <batolettre@gmail.com> | 2021-01-25 12:39:34 +0100 |
---|---|---|
committer | Michael Muré <batolettre@gmail.com> | 2021-02-14 12:19:01 +0100 |
commit | fe4237df3c62bd6dfd1f385893295f93072d0e51 (patch) | |
tree | 66eabac7a2aaae9f7b4f2aff07092556e3a2a2ac /entity/dag/entity_actions.go | |
parent | dc5059bc3372941e2908739831188768335ac50b (diff) | |
download | git-bug-fe4237df3c62bd6dfd1f385893295f93072d0e51.tar.gz |
entity: readAll and more testing
Diffstat (limited to 'entity/dag/entity_actions.go')
-rw-r--r-- | entity/dag/entity_actions.go | 8 |
1 files changed, 2 insertions, 6 deletions
diff --git a/entity/dag/entity_actions.go b/entity/dag/entity_actions.go index 83ff7ddc..db3a545c 100644 --- a/entity/dag/entity_actions.go +++ b/entity/dag/entity_actions.go @@ -10,8 +10,8 @@ import ( ) // ListLocalIds list all the available local Entity's Id -func ListLocalIds(typename string, repo repository.RepoData) ([]entity.Id, error) { - refs, err := repo.ListRefs(fmt.Sprintf("refs/%s/", typename)) +func ListLocalIds(def Definition, repo repository.RepoData) ([]entity.Id, error) { + refs, err := repo.ListRefs(fmt.Sprintf("refs/%s/", def.namespace)) if err != nil { return nil, err } @@ -75,10 +75,6 @@ func Pull(def Definition, repo repository.ClockedRepo, remote string) error { func MergeAll(def Definition, repo repository.ClockedRepo, remote string) <-chan entity.MergeResult { out := make(chan entity.MergeResult) - // no caching for the merge, we load everything from git even if that means multiple - // copy of the same entity in memory. The cache layer will intercept the results to - // invalidate entities if necessary. - go func() { defer close(out) |