Versions in this module Expand all Collapse all v2 v2.4.3 Feb 9, 2022 Changes in this version + func BuildIndexFileName(tableName, uploader, dbName string) string + func CompressFile(src, dest string, sync bool) error + func DoParallelQueries(ctx context.Context, tableQuerier TableQuerier, queries []chunk.IndexQuery, ...) error + func DownloadFileFromStorage(destination string, decompressFile, sync bool, logger log.Logger, ...) error + func GetUnsafeBytes(s string) []byte + func GetUnsafeString(buf []byte) string + func IsCompressedFile(filename string) bool + func LoggerWithFilename(logger log.Logger, filename string) log.Logger + func QueriesByTable(queries []chunk.IndexQuery) map[string][]chunk.IndexQuery + func QueryKey(q chunk.IndexQuery) string + func SafeOpenBoltdbFile(path string) (*bbolt.DB, error) + func ValidateSharedStoreKeyPrefix(prefix string) error + type GetFileFunc func() (io.ReadCloser, error) + type IndexDeduper struct + func NewIndexDeduper(callback chunk_util.Callback) *IndexDeduper + func (i *IndexDeduper) Callback(query chunk.IndexQuery, batch chunk.ReadBatch) bool + type IndexStorageClient interface + GetFile func(ctx context.Context, tableName, fileName string) (io.ReadCloser, error) + GetUserFile func(ctx context.Context, tableName, userID, fileName string) (io.ReadCloser, error) + type TableQuerier interface + MultiQueries func(ctx context.Context, queries []chunk.IndexQuery, callback chunk_util.Callback) error
Go to main page