cache: rename RootCache into MultiRepoCache

Underline the fact that it's fine to use RepoCache alone
This commit is contained in:
Michael Muré 2018-09-02 15:45:14 +02:00
parent 6ff02ed842
commit 90a45b4c09
No known key found for this signature in database
GPG Key ID: A4457C029293126F
5 changed files with 16 additions and 16 deletions

View File

@ -9,18 +9,18 @@ import (
const lockfile = "lock"
const excerptsFile = "excerpts"
type RootCache struct {
type MultiRepoCache struct {
repos map[string]*RepoCache
}
func NewCache() RootCache {
return RootCache{
func NewMultiRepoCache() MultiRepoCache {
return MultiRepoCache{
repos: make(map[string]*RepoCache),
}
}
// RegisterRepository register a named repository. Use this for multi-repo setup
func (c *RootCache) RegisterRepository(ref string, repo repository.Repo) error {
func (c *MultiRepoCache) RegisterRepository(ref string, repo repository.Repo) error {
r, err := NewRepoCache(repo)
if err != nil {
return err
@ -31,7 +31,7 @@ func (c *RootCache) RegisterRepository(ref string, repo repository.Repo) error {
}
// RegisterDefaultRepository register a unnamed repository. Use this for mono-repo setup
func (c *RootCache) RegisterDefaultRepository(repo repository.Repo) error {
func (c *MultiRepoCache) RegisterDefaultRepository(repo repository.Repo) error {
r, err := NewRepoCache(repo)
if err != nil {
return err
@ -42,7 +42,7 @@ func (c *RootCache) RegisterDefaultRepository(repo repository.Repo) error {
}
// ResolveRepo retrieve a repository by name
func (c *RootCache) DefaultRepo() (*RepoCache, error) {
func (c *MultiRepoCache) DefaultRepo() (*RepoCache, error) {
if len(c.repos) != 1 {
return nil, fmt.Errorf("repository is not unique")
}
@ -55,7 +55,7 @@ func (c *RootCache) DefaultRepo() (*RepoCache, error) {
}
// DefaultRepo retrieve the default repository
func (c *RootCache) ResolveRepo(ref string) (*RepoCache, error) {
func (c *MultiRepoCache) ResolveRepo(ref string) (*RepoCache, error) {
r, ok := c.repos[ref]
if !ok {
return nil, fmt.Errorf("unknown repo")
@ -64,7 +64,7 @@ func (c *RootCache) ResolveRepo(ref string) (*RepoCache, error) {
}
// Close will do anything that is needed to close the cache properly
func (c *RootCache) Close() error {
func (c *MultiRepoCache) Close() error {
for _, cachedRepo := range c.repos {
err := cachedRepo.Close()
if err != nil {

View File

@ -12,11 +12,11 @@ type ConnectionInput struct {
}
type Repository struct {
Cache *cache.RootCache
Cache *cache.MultiRepoCache
Repo *cache.RepoCache
}
type RepositoryMutation struct {
Cache *cache.RootCache
Cache *cache.MultiRepoCache
Repo *cache.RepoCache
}

View File

@ -9,7 +9,7 @@ import (
)
type mutationResolver struct {
cache *cache.RootCache
cache *cache.MultiRepoCache
}
func (r mutationResolver) getRepo(repoRef *string) (*cache.RepoCache, error) {

View File

@ -8,7 +8,7 @@ import (
)
type rootQueryResolver struct {
cache *cache.RootCache
cache *cache.MultiRepoCache
}
func (r rootQueryResolver) DefaultRepository(ctx context.Context) (*models.Repository, error) {

View File

@ -6,24 +6,24 @@ import (
)
type RootResolver struct {
cache.RootCache
cache.MultiRepoCache
}
func NewRootResolver() *RootResolver {
return &RootResolver{
RootCache: cache.NewCache(),
MultiRepoCache: cache.NewMultiRepoCache(),
}
}
func (r RootResolver) Query() graph.QueryResolver {
return &rootQueryResolver{
cache: &r.RootCache,
cache: &r.MultiRepoCache,
}
}
func (r RootResolver) Mutation() graph.MutationResolver {
return &mutationResolver{
cache: &r.RootCache,
cache: &r.MultiRepoCache,
}
}