Method Put

cache/filesystem_cache.go:167–198

(r io.Reader, contentMetadata ContentMetadata, key *Key)

}

func (f *fileSystemCache) Put(r io.Reader, contentMetadata ContentMetadata, key *Key) (time.Duration, error) {
	fp := key.filePath(f.dir)
	file, err := os.Create(fp)

	if err != nil {
		return 0, fmt.Errorf("cache %q: cannot create file: %s : %w", f.Name(), key, err)
	}

	if err := writeHeader(file, contentMetadata.Type); err != nil {
		fn := file.Name()
		return 0, fmt.Errorf("cannot write Content-Type to %q: %w", fn, err)
	}

	if err := writeHeader(file, contentMetadata.Encoding); err != nil {
		fn := file.Name()
		return 0, fmt.Errorf("cannot write Content-Encoding to %q: %w", fn, err)
	}

	if err := writeHeader(file, fmt.Sprintf("%d", contentMetadata.Length)); err != nil {
		fn := file.Name()
		return 0, fmt.Errorf("cannot write Content-Encoding to %q: %w", fn, err)
	}

	cnt, err := io.Copy(file, r)
	if err != nil {
		return 0, fmt.Errorf("cache %q: cannot write results to file: %s : %w", f.Name(), key, err)
	}

	atomic.AddUint64(&f.stats.Size, uint64(cnt))
	atomic.AddUint64(&f.stats.Items, 1)
	return f.expire, nil
}

func (f *fileSystemCache) cleaner() {
	d := f.expire / 2