Versions in this module Expand all Collapse all v1 v1.6.3 Jan 15, 2024 Changes in this version + func BuildObjectKey(tableName, uploader, dbName string) string + func CompressFile(src, dest string) error + func DoParallelQueries(ctx context.Context, tableQuerier TableQuerier, queries []chunk.IndexQuery, ...) error + func GetDBNameFromObjectKey(objectKey string) (string, error) + func GetFileFromStorage(ctx context.Context, storageClient StorageClient, ...) error + func IsDirectory(key string) bool + func QueriesByTable(queries []chunk.IndexQuery) map[string][]chunk.IndexQuery + func RemoveDirectories(incoming []chunk.StorageObject) []chunk.StorageObject + func SafeOpenBoltdbFile(path string) (*bbolt.DB, error) + func ValidateSharedStoreKeyPrefix(prefix string) error + type IndexDeduper struct + func NewIndexDeduper(callback chunk_util.Callback) *IndexDeduper + func (i *IndexDeduper) Callback(query chunk.IndexQuery, batch chunk.ReadBatch) bool + type StorageClient interface + GetObject func(ctx context.Context, objectKey string) (io.ReadCloser, error) + type TableQuerier interface + MultiQueries func(ctx context.Context, queries []chunk.IndexQuery, callback chunk_util.Callback) error
Go to main page