Function FilesystemKeyRefs

core/cache_response.go:92–136

FilesystemKeyRefs builds refs affected by a write/delete to key. Directory prefixes are included so list fragments for common prefix queries are evicted.

(name, key string)

// FilesystemKeyRefs builds refs affected by a write/delete to key. Directory
// prefixes are included so list fragments for common prefix queries are evicted.
func FilesystemKeyRefs(name, key string) []RowRef {
	key = normalizeFilesystemCacheID(key)
	refs := []RowRef{{
		Source: CacheSourceFS,
		Scope:  name,
		Kind:   CacheKindKey,
		ID:     key,
	}}

	seen := map[string]struct{}{}
	addPrefix := func(prefix string) {
		prefix = normalizeFilesystemCacheID(prefix)
		if _, ok := seen[prefix]; ok {
			return
		}
		seen[prefix] = struct{}{}
		refs = append(refs, RowRef{
			Source: CacheSourceFS,
			Scope:  name,
			Kind:   CacheKindPrefix,
			ID:     prefix,
		})
	}
	addPrefixVariants := func(prefix string) {
		addPrefix(prefix)
		if strings.HasSuffix(prefix, "/") {
			addPrefix(strings.TrimSuffix(prefix, "/"))
		}
	}

	addPrefix("")
	parts := strings.Split(key, "/")
	if len(parts) > 1 {
		var b strings.Builder
		for i := 0; i < len(parts)-1; i++ {
			if parts[i] == "" {
				continue
			}
			b.WriteString(parts[i])
			b.WriteByte('/')
			addPrefixVariants(b.String())
		}
	}
	return refs
}

// FilesystemPrefixRefs builds refs for a filesystem list prefix. The root
// prefix is included so broad filesystem invalidations can evict all entries.