Versions in this module Expand all Collapse all v2 v2.0.0 Jun 14, 2023 Changes in this version + var ErrMethodNotImplemented = errors.New("method is not implemented") + var ErrStorageObjectNotFound = errors.New("object not found in storage") + var FSEncoder = func(schema config.SchemaConfig, chk chunk.Chunk) string + type ChunkClientMetrics struct + func NewChunkClientMetrics(reg prometheus.Registerer) ChunkClientMetrics + type Client interface + DeleteChunk func(ctx context.Context, userID, chunkID string) error + GetChunks func(ctx context.Context, chunks []chunk.Chunk) ([]chunk.Chunk, error) + IsChunkNotFoundErr func(err error) bool + PutChunks func(ctx context.Context, chunks []chunk.Chunk) error + Stop func() + func NewClient(store ObjectClient, encoder KeyEncoder, schema config.SchemaConfig) Client + func NewClientWithMaxParallel(store ObjectClient, encoder KeyEncoder, maxParallel int, ...) Client + type KeyEncoder func(schema config.SchemaConfig, chk chunk.Chunk) string + type MetricsChunkClient struct + Client Client + func NewMetricsChunkClient(client Client, metrics ChunkClientMetrics) MetricsChunkClient + func (c MetricsChunkClient) DeleteChunk(ctx context.Context, userID, chunkID string) error + func (c MetricsChunkClient) GetChunks(ctx context.Context, chunks []chunk.Chunk) ([]chunk.Chunk, error) + func (c MetricsChunkClient) IsChunkNotFoundErr(err error) bool + func (c MetricsChunkClient) PutChunks(ctx context.Context, chunks []chunk.Chunk) error + func (c MetricsChunkClient) Stop() + type ObjectAndIndexClient interface + PutChunksAndIndex func(ctx context.Context, chunks []chunk.Chunk, index index.WriteBatch) error + type ObjectClient interface + DeleteObject func(ctx context.Context, objectKey string) error + GetObject func(ctx context.Context, objectKey string) (io.ReadCloser, int64, error) + IsObjectNotFoundErr func(err error) bool + List func(ctx context.Context, prefix string, delimiter string) ([]StorageObject, []StorageCommonPrefix, error) + PutObject func(ctx context.Context, objectKey string, object io.ReadSeeker) error + Stop func() + type StorageCommonPrefix string + type StorageObject struct + Key string + ModifiedAt time.Time
Go to main page