Function ownsWALBlock

tempodb/encoding/vparquet5/wal_block.go:195–207

(entry fs.DirEntry)

}

func ownsWALBlock(entry fs.DirEntry) bool {
	// all vParquet wal blocks are folders
	if !entry.IsDir() {
		return false
	}

	_, _, version, err := parseName(entry.Name())
	if err != nil {
		return false
	}

	return version == VersionString
}

type walBlockFlush struct {
	path    string