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.
Source Files
Click to show internal directories.
Click to hide internal directories.