Function New

tempodb/wal/wal.go:47–76

(c *Config)

}

func New(c *Config) (*WAL, error) {
	if c.Filepath == "" {
		return nil, fmt.Errorf("please provide a path for the WAL")
	}

	// make folder
	err := os.MkdirAll(c.Filepath, 0o700)
	if err != nil {
		return nil, err
	}

	// Setup local backend in /blocks/
	blocksFolderPath := filepath.Join(c.Filepath, blocksDir)
	err = os.MkdirAll(blocksFolderPath, 0o700)
	if err != nil {
		return nil, err
	}

	l, err := local.NewBackend(&local.Config{
		Path: blocksFolderPath,
	})
	if err != nil {
		return nil, err
	}

	return &WAL{
		c: c,
		l: l,
	}, nil
}

// RescanBlocks returns a slice of append blocks from the wal folder
func (w *WAL) RescanBlocks(additionalStartSlack time.Duration, log log.Logger) ([]common.WALBlock, error) {