Function createWALBlock

tempodb/encoding/vparquet5/wal_block.go:158–193

createWALBlock creates a new appendable block

(meta *backend.BlockMeta, filepath, dataEncoding string, ingestionSlack time.Duration)

// createWALBlock creates a new appendable block
func createWALBlock(meta *backend.BlockMeta, filepath, dataEncoding string, ingestionSlack time.Duration) (*walBlock, error) {
	newMeta := &backend.BlockMeta{
		Version:           VersionString,
		BlockID:           meta.BlockID,
		TenantID:          meta.TenantID,
		ReplicationFactor: meta.ReplicationFactor,
		// remove unsupported dedicated columns
		DedicatedColumns: filterDedicatedColumns(meta.DedicatedColumns),
	}

	b := &walBlock{
		meta:           newMeta,
		path:           filepath,
		ids:            common.NewIDMap[int64](0),
		ingestionSlack: ingestionSlack,
		dedcolsRes:     dedicatedColumnsToColumnMapping(meta.DedicatedColumns, backend.DedicatedColumnScopeResource),
		dedcolsSpan:    dedicatedColumnsToColumnMapping(meta.DedicatedColumns, backend.DedicatedColumnScopeSpan),
		dedcolsEvent:   dedicatedColumnsToColumnMapping(meta.DedicatedColumns, backend.DedicatedColumnScopeEvent),
	}

	// build folder
	err := os.MkdirAll(b.walPath(), 0o700)
	if err != nil {
		return nil, err
	}

	dec, err := model.NewObjectDecoder(dataEncoding)
	if err != nil {
		return nil, err
	}
	b.decoder = dec

	err = b.openWriter()

	return b, err
}

func ownsWALBlock(entry fs.DirEntry) bool {
	// all vParquet wal blocks are folders