Versions in this module Expand all Collapse all v2 v2.6.2 Aug 12, 2022 Changes in this version + var ErrUserIDMustBeEmpty = errors.New("userID must be empty") + var ErrUserIDMustNotBeEmpty = errors.New("userID must not be empty") + func DownloadFileFromStorage(destination string, decompressFile bool, sync bool, logger log.Logger, ...) error + func IsCompressedFile(filename string) bool + func LoggerWithFilename(logger log.Logger, filename string) log.Logger + func ValidateSharedStoreKeyPrefix(prefix string) error + type Client interface + IsFileNotFoundErr func(err error) bool + ListTables func(ctx context.Context) ([]string, error) + RefreshIndexListCache func(ctx context.Context) + Stop func() + func NewIndexStorageClient(origObjectClient client.ObjectClient, storagePrefix string) Client + type CommonIndexClient interface + DeleteFile func(ctx context.Context, tableName, fileName string) error + GetFile func(ctx context.Context, tableName, fileName string) (io.ReadCloser, error) + ListFiles func(ctx context.Context, tableName string, bypassCache bool) ([]IndexFile, []string, error) + PutFile func(ctx context.Context, tableName, fileName string, file io.ReadSeeker) error + type GetFileFunc func() (io.ReadCloser, error) + type IndexFile struct + ModifiedAt time.Time + Name string + type IndexSet interface + DeleteFile func(ctx context.Context, tableName, userID, fileName string) error + GetFile func(ctx context.Context, tableName, userID, fileName string) (io.ReadCloser, error) + IsFileNotFoundErr func(err error) bool + IsUserBasedIndexSet func() bool + ListFiles func(ctx context.Context, tableName, userID string, bypassCache bool) ([]IndexFile, error) + PutFile func(ctx context.Context, tableName, userID, fileName string, file io.ReadSeeker) error + RefreshIndexListCache func(ctx context.Context) + func NewIndexSet(client Client, userBasedIndex bool) IndexSet + type UserIndexClient interface + DeleteUserFile func(ctx context.Context, tableName, userID, fileName string) error + GetUserFile func(ctx context.Context, tableName, userID, fileName string) (io.ReadCloser, error) + ListUserFiles func(ctx context.Context, tableName, userID string, bypassCache bool) ([]IndexFile, error) + PutUserFile func(ctx context.Context, tableName, userID, fileName string, file io.ReadSeeker) error