chunk

Documentation

Index

• type Deleter
• type FilterFunc
• type ScanRequest
  • func (s *ScanRequest) CheckTime(from, through model.Time) bool
• type Scanner
• type ScannerProvider

Types

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 (*ScanRequest) CheckTime

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