Skip to content

Commit

Permalink
Skip key generation if cache disabled
Browse files Browse the repository at this point in the history
  • Loading branch information
rmweir committed Feb 26, 2024
1 parent bf2e965 commit 0462af3
Showing 1 changed file with 16 additions and 13 deletions.
29 changes: 16 additions & 13 deletions pkg/stores/partition/store.go
Original file line number Diff line number Diff line change
Expand Up @@ -175,18 +175,21 @@ func (s *Store) List(apiOp *types.APIRequest, schema *types.APISchema) (types.AP

opts := listprocessor.ParseQuery(apiOp)

key, err := s.getCacheKey(apiOp, opts)
if err != nil {
return result, err
}

var list []unstructured.Unstructured
if key.revision != "" && s.listCache != nil {
cachedList, ok := s.listCache.Get(key)
if ok {
logrus.Tracef("found cached list for query %s?%s", apiOp.Request.URL.Path, apiOp.Request.URL.RawQuery)
list = cachedList.(*unstructured.UnstructuredList).Items
result.Continue = cachedList.(*unstructured.UnstructuredList).GetContinue()
var key cacheKey
if s.listCache != nil {
key, err = s.getCacheKey(apiOp, opts)
if err != nil {
return result, err
}

if key.revision != "" && s.listCache != nil {
cachedList, ok := s.listCache.Get(key)
if ok {
logrus.Tracef("found cached list for query %s?%s", apiOp.Request.URL.Path, apiOp.Request.URL.RawQuery)
list = cachedList.(*unstructured.UnstructuredList).Items
result.Continue = cachedList.(*unstructured.UnstructuredList).GetContinue()
}
}
}
if list == nil { // did not look in cache or was not found in cache
Expand All @@ -202,7 +205,7 @@ func (s *Store) List(apiOp *types.APIRequest, schema *types.APISchema) (types.AP
return result, lister.Err()
}
list = listprocessor.SortList(list, opts.Sort)
key.revision = lister.Revision()
result.Revision = lister.Revision()
listToCache := &unstructured.UnstructuredList{
Items: list,
}
Expand All @@ -212,6 +215,7 @@ func (s *Store) List(apiOp *types.APIRequest, schema *types.APISchema) (types.AP
listToCache.SetContinue(c)
}
if s.listCache != nil {
key.revision = result.Revision
s.listCache.Add(key, listToCache, 30*time.Minute)
}
result.Continue = lister.Continue()
Expand All @@ -224,7 +228,6 @@ func (s *Store) List(apiOp *types.APIRequest, schema *types.APISchema) (types.AP
result.Objects = append(result.Objects, toAPI(schema, &item, nil))
}

result.Revision = key.revision
result.Pages = pages
return result, lister.Err()
}
Expand Down

0 comments on commit 0462af3

Please sign in to comment.