scanner

Documentation

Index

• func GetSeriesToChunkMapping(HashValue string, RangeValue []byte) (user string, index int, seriesID string, chunkID string, err error)
• func IsMetricLabelToLabelValueMapping(RangeValue []byte) bool
• func IsMetricToSeriesMapping(RangeValue []byte) bool
• func IsSeriesToChunkMapping(RangeValue []byte) bool
• func IsSeriesToLabelValues(RangeValue []byte) bool
• func UnknownIndexEntryType(RangeValue []byte) string
• type Config
  • func (cfg *Config) RegisterFlags(f *flag.FlagSet)
• type Scanner
  • func NewScanner(cfg Config, scfg blocksconvert.SharedConfig, l log.Logger, ...) (*Scanner, error)

Functions

func GetSeriesToChunkMapping

func GetSeriesToChunkMapping(HashValue string, RangeValue []byte) (user string, index int, seriesID string, chunkID string, err error)

e.RangeValue is: "userID:d<Index>:base64(sha256(labels))". Index is integer, base64 doesn't contain ':'.

func IsMetricLabelToLabelValueMapping

func IsMetricLabelToLabelValueMapping(RangeValue []byte) bool

func IsMetricToSeriesMapping

func IsMetricToSeriesMapping(RangeValue []byte) bool

func IsSeriesToChunkMapping

func IsSeriesToChunkMapping(RangeValue []byte) bool

Series to Chunk mapping uses \0 "3" \0 suffix of range value.

func IsSeriesToLabelValues

func IsSeriesToLabelValues(RangeValue []byte) bool

func UnknownIndexEntryType

func UnknownIndexEntryType(RangeValue []byte) string

Types

type Config

type Config struct {
	TableNames  string
	TablesLimit int

	PeriodStart flagext.DayValue
	PeriodEnd   flagext.DayValue

	OutputDirectory string
	Concurrency     int

	VerifyPlans bool
	UploadFiles bool
	KeepFiles   bool

	AllowedUsers       string
	IgnoredUserPattern string
}

func (*Config) RegisterFlags

func (cfg *Config) RegisterFlags(f *flag.FlagSet)

type Scanner

type Scanner struct {
	services.Service
	// contains filtered or unexported fields
}

func NewScanner

func NewScanner(cfg Config, scfg blocksconvert.SharedConfig, l log.Logger, reg prometheus.Registerer) (*Scanner, error)