thanosconvert

Documentation

Index

• type PerUserResults
  • func (r *PerUserResults) AddConverted(blockID string)
  • func (r *PerUserResults) AddFailed(blockID string)
  • func (r *PerUserResults) AddUnchanged(blockID string)
• type Results
• type ThanosBlockConverter
  • func NewThanosBlockConverter(ctx context.Context, cfg bucket.Config, dryRun bool, logger log.Logger) (*ThanosBlockConverter, error)
  • func (c ThanosBlockConverter) Run(ctx context.Context) (Results, error)

Types

type PerUserResults

type PerUserResults struct {
	FailedBlocks, ConvertedBlocks, UnchangedBlocks []string
}

func (*PerUserResults) AddConverted

func (r *PerUserResults) AddConverted(blockID string)

func (*PerUserResults) AddFailed

func (r *PerUserResults) AddFailed(blockID string)

func (*PerUserResults) AddUnchanged

func (r *PerUserResults) AddUnchanged(blockID string)

type Results

type Results map[string]PerUserResults

type ThanosBlockConverter

type ThanosBlockConverter struct {
	// contains filtered or unexported fields
}

ThanosBlockConverter converts blocks written by Thanos to make them readable by Cortex

func NewThanosBlockConverter

func NewThanosBlockConverter(ctx context.Context, cfg bucket.Config, dryRun bool, logger log.Logger) (*ThanosBlockConverter, error)

NewThanosBlockConverter creates a ThanosBlockConverter

func (ThanosBlockConverter) Run

func (c ThanosBlockConverter) Run(ctx context.Context) (Results, error)

Run iterates over all blocks from all users in a bucket