cortex

Documentation

Index

• Constants
• func ConstructFiltersFromMap(in map[string]string) string
• func ConstructIdLabelsForRecordingRule(alertId string) map[string]string
• func ConstructRecordingRuleName(prefix, typeName string) string
• func NewPrometheusAlertingRule(alertId, _ string, opniLabels, opniAnnotations map[string]string, ...) (ruleGroup *rulefmt.RuleGroup, metadata map[string]string, err error)
• func ReducePrometheusMatrix(matrix *model.Matrix) []*alertingv1.ActiveWindow
• func RuleIdFromUuid(id string) string
• func TimeDurationToPromStr(t time.Duration) string
• type MatrixHeap
  • func (h MatrixHeap) Len() int
  • func (h MatrixHeap) Less(i, j int) bool
  • func (h *MatrixHeap) Pop() any
  • func (h *MatrixHeap) Push(x any)
  • func (h MatrixHeap) Swap(i, j int)
• type MatrixRef

Constants

const (
	MetadataCortexNamespace = "opni.io/cortex-rule-namespace"
	MetadataCortexGroup     = "opni.io/cortex-rule-group"
	MetadataCortexRuleName  = "opni.io/cortex-rule-name"
)

Functions

func ConstructFiltersFromMap

func ConstructFiltersFromMap(in map[string]string) string

func ConstructIdLabelsForRecordingRule

func ConstructIdLabelsForRecordingRule(alertId string) map[string]string

func ConstructRecordingRuleName

func ConstructRecordingRuleName(prefix, typeName string) string

func NewPrometheusAlertingRule

func NewPrometheusAlertingRule(
	alertId,
	_ string,
	opniLabels,
	opniAnnotations map[string]string,
	info alertingv1.IndexableMetric,
	interval *time.Duration,
	rule metrics.AlertRuleBuilder,
) (ruleGroup *rulefmt.RuleGroup, metadata map[string]string, err error)

func ReducePrometheusMatrix

func ReducePrometheusMatrix(matrix *model.Matrix) []*alertingv1.ActiveWindow

`ALERTS` can have several root causes for causing the active alerting rule to fire; prometheus store each root cause as a separate synthetic timeseries. This function reduces the matrix of synthetic timeseries into a single array of sorted active windows !! Assumes the input matrix is non-nil

func RuleIdFromUuid

func RuleIdFromUuid(id string) string

func TimeDurationToPromStr

func TimeDurationToPromStr(t time.Duration) string

Types

type MatrixHeap

type MatrixHeap []MatrixRef

Implements the container/heap.Heap interface

func (MatrixHeap) Len

func (h MatrixHeap) Len() int

func (MatrixHeap) Less

func (h MatrixHeap) Less(i, j int) bool

func (*MatrixHeap) Pop

func (h *MatrixHeap) Pop() any

func (*MatrixHeap) Push

func (h *MatrixHeap) Push(x any)

func (MatrixHeap) Swap

func (h MatrixHeap) Swap(i, j int)

type MatrixRef

type MatrixRef lo.Tuple3[int, int, *model.SamplePair]

MatrixRef A : Refers to the index of a specific metric in the matrix B : Refers to the position in the metric.Values array to process