Versions in this module Expand all Collapse all v2 v2.5.2 Apr 27, 2022 Changes in this version + const MockStorageModeReadOnly + const MockStorageModeReadWrite + const MockStorageModeWriteOnly + func CreateChunks(scfg config.SchemaConfig, startIndex, batchSize int, from model.Time, ...) ([]string, []chunk.Chunk, error) + func DefaultSchemaConfig(kind string) config.SchemaConfig + func DummyChunkFor(from, through model.Time, metric labels.Labels) chunk.Chunk + func ResetMockStorage() + func SchemaConfig(store, schema string, from model.Time) config.SchemaConfig + func Setup(fixture Fixture, tableName string) (index.Client, chunkclient.Client, io.Closer, error) + type CloserFunc func() error + func (f CloserFunc) Close() error + type Fixture interface + Clients func() (index.Client, chunkclient.Client, index.TableClient, config.SchemaConfig, ...) + Name func() string + type MockStorage struct + func NewMockStorage() *MockStorage + func (*MockStorage) Stop() + func (m *MockStorage) BatchWrite(ctx context.Context, batch index.WriteBatch) error + func (m *MockStorage) CreateTable(_ context.Context, desc config.TableDesc) error + func (m *MockStorage) DeleteChunk(ctx context.Context, userID, chunkID string) error + func (m *MockStorage) DeleteObject(ctx context.Context, objectKey string) error + func (m *MockStorage) DeleteTable(_ context.Context, name string) error + func (m *MockStorage) DescribeTable(_ context.Context, name string) (desc config.TableDesc, isActive bool, err error) + func (m *MockStorage) GetChunks(ctx context.Context, chunkSet []chunk.Chunk) ([]chunk.Chunk, error) + func (m *MockStorage) GetObject(ctx context.Context, objectKey string) (io.ReadCloser, int64, error) + func (m *MockStorage) GetObjectCount() int + func (m *MockStorage) GetSortedObjectKeys() []string + func (m *MockStorage) IsChunkNotFoundErr(err error) bool + func (m *MockStorage) IsObjectNotFoundErr(err error) bool + func (m *MockStorage) List(ctx context.Context, prefix, delimiter string) ([]client.StorageObject, []client.StorageCommonPrefix, error) + func (m *MockStorage) ListTables(_ context.Context) ([]string, error) + func (m *MockStorage) NewWriteBatch() index.WriteBatch + func (m *MockStorage) PutChunks(_ context.Context, chunks []chunk.Chunk) error + func (m *MockStorage) PutObject(ctx context.Context, objectKey string, object io.ReadSeeker) error + func (m *MockStorage) QueryPages(ctx context.Context, queries []index.Query, callback index.QueryPagesCallback) error + func (m *MockStorage) SetMode(mode MockStorageMode) + func (m *MockStorage) UpdateTable(_ context.Context, _, desc config.TableDesc) error + type MockStorageMode int