cache: remove unnecessary stagePath interface of CacheManager (#5545)

Signed-off-by: Changxin Miao <miaochangxin@step.ai>
juicedata · Jan 10, 2025 · 5714660 · 5714660
1 parent 7d3ecd4
commit 5714660
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 10 deletions.
diff --git a/pkg/chunk/disk_cache.go b/pkg/chunk/disk_cache.go
@@ -1041,7 +1041,6 @@ type CacheManager interface {
 	uploaded(key string, size int)
 	stage(key string, data []byte, keepCache bool) (string, error)
 	removeStage(key string) error
-	stagePath(key string) string
 	stats() (int64, int64)
 	usedMemory() int64
 	isEmpty() bool
@@ -1248,14 +1247,6 @@ func (m *cacheManager) stage(key string, data []byte, keepCache bool) (string, e
 	return "", errors.New("no available cache dir")
 }
 
-func (m *cacheManager) stagePath(key string) string {
-	store := m.getStore(key)
-	if store != nil {
-		return store.stagePath(key)
-	}
-	return ""
-}
-
 func (m *cacheManager) uploaded(key string, size int) {
 	store := m.getStore(key)
 	if store != nil {

diff --git a/pkg/chunk/mem_cache.go b/pkg/chunk/mem_cache.go
@@ -210,6 +210,5 @@ func (c *memcache) stage(key string, data []byte, keepCache bool) (string, error
 	return "", errors.New("not supported")
 }
 func (c *memcache) uploaded(key string, size int)    {}
-func (c *memcache) stagePath(key string) string      { return "" }
 func (c *memcache) isEmpty() bool                    { return false }
 func (c *memcache) getMetrics() *cacheManagerMetrics { return c.metrics }