Versions in this module Expand all Collapse all v1 v1.6.1 Aug 24, 2020 v1.6.0 Aug 13, 2020 Changes in this version + type BoltDBIndexClient interface + QueryDB func(ctx context.Context, db *bbolt.DB, query chunk.IndexQuery, ...) error + type Config struct + CacheDir string + CacheTTL time.Duration + SyncInterval time.Duration + type StorageClient interface + GetObject func(ctx context.Context, objectKey string) (io.ReadCloser, error) + List func(ctx context.Context, prefix string) ([]chunk.StorageObject, []chunk.StorageCommonPrefix, error) + type Table struct + func NewTable(spanCtx context.Context, name, cacheLocation string, ...) *Table + func (t *Table) CleanupAllDBs() error + func (t *Table) Close() + func (t *Table) Err() error + func (t *Table) LastUsedAt() time.Time + func (t *Table) Query(ctx context.Context, query chunk.IndexQuery, callback chunk_util.Callback) error + func (t *Table) Sync(ctx context.Context) error + type TableManager struct + func NewTableManager(cfg Config, boltIndexClient BoltDBIndexClient, storageClient StorageClient, ...) (*TableManager, error) + func (tm *TableManager) QueryPages(ctx context.Context, queries []chunk.IndexQuery, callback chunk_util.Callback) error + func (tm *TableManager) Stop()
Go to main page