record

Documentation

Index

• Constants
• func ConvertToTimeSeries(value model.Value, rule *models.RecordingRule) (lst []*prompb.TimeSeries)
• type RecordRuleContext
  • func NewRecordRuleContext(rule *models.RecordingRule, datasourceId int64, ...) *RecordRuleContext
  • func (rrc *RecordRuleContext) Eval()
  • func (rrc *RecordRuleContext) Hash() string
  • func (rrc *RecordRuleContext) Key() string
  • func (rrc *RecordRuleContext) Prepare()
  • func (rrc *RecordRuleContext) Start()
  • func (rrc *RecordRuleContext) Stop()
• type Scheduler
  • func NewScheduler(aconf aconf.Alert, rrc *memsto.RecordingRuleCacheType, ...) *Scheduler
  • func (s *Scheduler) LoopSyncRules(ctx context.Context)

Constants

const (
	LabelName = "__name__"
)

Functions

func ConvertToTimeSeries

func ConvertToTimeSeries(value model.Value, rule *models.RecordingRule) (lst []*prompb.TimeSeries)

Types

type RecordRuleContext

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

func NewRecordRuleContext

func NewRecordRuleContext(rule *models.RecordingRule, datasourceId int64, promClients *prom.PromClientMap, writers *writer.WritersType) *RecordRuleContext

func (*RecordRuleContext) Eval

func (rrc *RecordRuleContext) Eval()

func (*RecordRuleContext) Hash

func (rrc *RecordRuleContext) Hash() string

func (*RecordRuleContext) Key

func (rrc *RecordRuleContext) Key() string

func (*RecordRuleContext) Prepare

func (rrc *RecordRuleContext) Prepare()

func (*RecordRuleContext) Start

func (rrc *RecordRuleContext) Start()

func (*RecordRuleContext) Stop

func (rrc *RecordRuleContext) Stop()

type Scheduler

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

func NewScheduler

func NewScheduler(aconf aconf.Alert, rrc *memsto.RecordingRuleCacheType, promClients *prom.PromClientMap, writers *writer.WritersType, stats *astats.Stats) *Scheduler

func (*Scheduler) LoopSyncRules

func (s *Scheduler) LoopSyncRules(ctx context.Context)