Versions in this module Expand all Collapse all v2 v2.5.2 Apr 27, 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 []index.Query, ...) error + func DownloadFileFromStorage(destination string, decompressFile bool, 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 []index.Query) map[string][]index.Query + func QueryKey(q index.Query) 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 index.QueryPagesCallback) *IndexDeduper + func (i *IndexDeduper) Callback(query index.Query, batch index.ReadBatchResult) 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 []index.Query, callback index.QueryPagesCallback) error