metrics

Documentation

Index

• Constants
• Variables
• type NodeMetricsCollector
  • func NewNodeMetricsCollector(interval time.Duration, logger *zap.Logger) (*NodeMetricsCollector, error)
  • func (c *NodeMetricsCollector) GetMetrics() (map[uint32]*meta.ProgMetricsStats, error)
• type TaskMetrics
  • func NewTaskMetrics(store *sync.Map) *TaskMetrics
  • func (m *TaskMetrics) Handler() gin.HandlerFunc
  • func (m *TaskMetrics) ResetMetrics()
  • func (m *TaskMetrics) UpdateMetricsFromCache(nodeName string)
• type TaskStatsMetrics
  • func NewTaskStatsMetrics() *TaskStatsMetrics

Constants

const (
	// 任务 CPU 使用率
	TaskCPUUsage = "beepf_task_cpu_usage"
	// 任务每秒事件数
	TaskEventsPerSecond = "beepf_task_events_per_second"
	// 任务平均运行时间(ns)
	TaskAvgRunTimeNS = "beepf_task_avg_run_time_ns"
	// 任务总平均运行时间(ns)
	TaskTotalAvgRunTimeNS = "beepf_task_total_avg_run_time_ns"
	// 任务采样周期(ns)
	TaskPeriodNS = "beepf_task_period_ns"
)

Variables

var (
	TaskMetricsLabels = []string{"task_id", "component_id", "program_id", "node_name"}
)

Types

type NodeMetricsCollector

type NodeMetricsCollector struct {
	*topology.NodeMetricsCollector
}

func NewNodeMetricsCollector

func NewNodeMetricsCollector(interval time.Duration, logger *zap.Logger) (*NodeMetricsCollector, error)

func (*NodeMetricsCollector) GetMetrics

func (c *NodeMetricsCollector) GetMetrics() (map[uint32]*meta.ProgMetricsStats, error)

type TaskMetrics

type TaskMetrics struct {
	TaskStore *sync.Map
	TaskStats *TaskStatsMetrics
}

func NewTaskMetrics

func NewTaskMetrics(store *sync.Map) *TaskMetrics

func (*TaskMetrics) Handler

func (m *TaskMetrics) Handler() gin.HandlerFunc

func (*TaskMetrics) ResetMetrics

func (m *TaskMetrics) ResetMetrics()

func (*TaskMetrics) UpdateMetricsFromCache

func (m *TaskMetrics) UpdateMetricsFromCache(nodeName string)

type TaskStatsMetrics

type TaskStatsMetrics struct {
	TaskCPUUsage          *prometheus.GaugeVec
	TaskEventsPerSecond   *prometheus.GaugeVec
	TaskAvgRunTimeNS      *prometheus.GaugeVec
	TaskTotalAvgRunTimeNS *prometheus.GaugeVec
	TaskPeriodNS          *prometheus.GaugeVec
}

func NewTaskStatsMetrics

func NewTaskStatsMetrics() *TaskStatsMetrics