func()

in pkg/stream/local/local_file_streamer.go [36:58]


func (s *streamer) CreateStream(url string) (io.ReadSeeker, int64, string, error) {
	filePath, err := parseURL(url)
	if err != nil {
		return nil, 0, "", err
	}
	md5Sum, md5Err := md5SumFile(filePath, s.fileSystem)
	if md5Err != nil {
		return nil, 0, "", md5Err
	}

	file, openErr := s.fileSystem.Open(filePath)
	if openErr != nil {
		return nil, 0, "", openErr
	}

	fileInfo, statErr := file.Stat()
	if statErr != nil {
		return nil, 0, "", statErr
	}

	return file, fileInfo.Size(), md5Sum, nil

}