Versions in this module Expand all Collapse all v1 v1.6.2 Jan 17, 2024 Changes in this version + type BoltDBIndexClient interface + QueryWithCursor func(_ context.Context, c *bbolt.Cursor, query chunk.IndexQuery, ...) error + WriteToDB func(ctx context.Context, db *bbolt.DB, writes local.TableWrites) error + type Config struct + DBRetainPeriod time.Duration + IndexDir string + UploadInterval time.Duration + Uploader string + type StorageClient interface + PutObject func(ctx context.Context, objectKey string, object io.ReadSeeker) error + type Table struct + func LoadTable(path, uploader string, storageClient StorageClient, ...) (*Table, error) + func NewTable(path, uploader string, storageClient StorageClient, ...) (*Table, error) + func (lt *Table) Cleanup(dbRetainPeriod time.Duration) error + func (lt *Table) MultiQueries(ctx context.Context, queries []chunk.IndexQuery, callback chunk_util.Callback) error + func (lt *Table) RemoveDB(name string) error + func (lt *Table) RemoveSnapshotDB(name string) error + func (lt *Table) Snapshot() error + func (lt *Table) Stop() + func (lt *Table) Upload(ctx context.Context, force bool) error + func (lt *Table) Write(ctx context.Context, writes local.TableWrites) error + type TableManager struct + func NewTableManager(cfg Config, boltIndexClient BoltDBIndexClient, storageClient StorageClient, ...) (*TableManager, error) + func (tm *TableManager) BatchWrite(ctx context.Context, batch chunk.WriteBatch) error + func (tm *TableManager) QueryPages(ctx context.Context, queries []chunk.IndexQuery, callback chunk_util.Callback) error + func (tm *TableManager) Stop()
Go to main page