chunk

type Deleter ¶

type Deleter interface {
	DeleteEntry(context.Context, chunk.IndexEntry, bool) error
	DeleteSeries(context.Context, chunk.IndexQuery) ([]error, error)
}

type FilterFunc ¶

type FilterFunc func(chunk.Chunk) bool

type ScanRequest ¶

type ScanRequest struct {
	Table    string
	User     string
	Prefix   string
	Interval *model.Interval
}

ScanRequest is used to designate the scope of a chunk table scan if Prefix is not set, scan all shards If Interval is not set, consider all chunks

func (s *ScanRequest) CheckTime(from, through model.Time) bool

type Scanner ¶

type Scanner interface {
	Scan(ctx context.Context, req ScanRequest, filterFunc FilterFunc, out chan chunk.Chunk) error
}

Scanner scans an

type ScannerProvider ¶

type ScannerProvider interface {
	NewScanner() Scanner
}

ScannerProvider allows creating a new Scanner