output

Documentation

Index

• Constants
• func ProcessSchedDelay(coll *ebpf.Collection, ctx context.Context, cfg config.Configuration)
• type SchedMetrics
  • func NewSchedMetrics(schedMetricsMap, schedPreemptedMap *sync.Map) *SchedMetrics
  • func (m *SchedMetrics) UpdateMetricsFromCache(nodeName string)
• type TraceMetrics
  • func NewTraceMetrics(schedMetrics *SchedMetrics) *TraceMetrics
  • func (m *TraceMetrics) MetricsHandler() gin.HandlerFunc

Constants

const (
	SchedLatencies = "sched_latencies"
	SchedPreempted = "sched_preempted"
	SchedPreempte  = "sched_preempte"
)

Functions

func ProcessSchedDelay

func ProcessSchedDelay(coll *ebpf.Collection, ctx context.Context, cfg config.Configuration)

Types

type SchedMetrics

type SchedMetrics struct {
	SchedLatencies    *prometheus.GaugeVec // 调度延迟
	SchedPreempted    *prometheus.GaugeVec // 被抢占的进程
	SchedPreempte     *prometheus.GaugeVec // 抢占的进程
	SchedMetricsMap   *sync.Map
	SchedPreemptedMap *sync.Map
}

func NewSchedMetrics

func NewSchedMetrics(schedMetricsMap, schedPreemptedMap *sync.Map) *SchedMetrics

func (*SchedMetrics) UpdateMetricsFromCache

func (m *SchedMetrics) UpdateMetricsFromCache(nodeName string)

type TraceMetrics

type TraceMetrics struct {
	SchedMetrics *SchedMetrics
}

func NewTraceMetrics

func NewTraceMetrics(schedMetrics *SchedMetrics) *TraceMetrics

func (*TraceMetrics) MetricsHandler

func (m *TraceMetrics) MetricsHandler() gin.HandlerFunc