Help us shape the future of Go! Take the 2026 Go Developer Survey

replicate

package
v0.26.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 9, 2022 License: Apache-2.0 Imports: 33 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ParseFlagMatchers

func ParseFlagMatchers(s []string) ([]*labels.Matcher, error)

ParseFlagMatchers parse flag into matchers.

func RunReplicate

func RunReplicate(
	g *run.Group,
	logger log.Logger,
	reg *prometheus.Registry,
	_ opentracing.Tracer,
	httpBindAddr string,
	httpTLSConfig string,
	httpGracePeriod time.Duration,
	labelSelector labels.Selector,
	resolutions []compact.ResolutionLevel,
	compactions []int,
	fromObjStoreConfig *extflag.PathOrContent,
	toObjStoreConfig *extflag.PathOrContent,
	singleRun bool,
	minTime, maxTime *thanosmodel.TimeOrDurationValue,
	blockIDs []ulid.ULID,
	ignoreMarkedForDeletion bool,
) error

RunReplicate replicate data based on config.

Types

type BlockFilter

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

BlockFilter is block filter that filters out compacted and unselected blocks.

func NewBlockFilter

func NewBlockFilter(
	logger log.Logger,
	labelSelector labels.Selector,
	resolutionLevels []compact.ResolutionLevel,
	compactionLevels []int,
	blockIDs []ulid.ULID,
) *BlockFilter

NewBlockFilter returns block filter.

func (*BlockFilter) Filter

func (bf *BlockFilter) Filter(b *metadata.Meta) bool

Filter return true if block is non-compacted and matches selector.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL