metrics

Documentation

Index

• Constants
• Variables
• func GetMetricsZipFile(startTime time.Time, endTime time.Time) (string, error)
• func GetStatusValue(err error) string
• func InitMetricsDumpJob(ctx context.Context)
• func IsMetricsDumpEnabled() bool
• func RegisterSyncCache()
• func RemoveRuleStatus(ruleID string)
• func SetRuleCPUUsageGauge(ruleID string, value int)
• func SetRuleStatus(ruleID string, value int)
• func SetRuleStatusCountGauge(isRunning bool, count int)
• func StartMetricsManager() error
• func StopMetricsManager()
• type MetricsDumpManager
  • func (m *MetricsDumpManager) Init(ctx context.Context) error
  • func (m *MetricsDumpManager) IsEnabled() bool
  • func (m *MetricsDumpManager) Start() error
  • func (m *MetricsDumpManager) Stop()

Constants

const (
	LblType       = "type"
	LblStatusType = "status"
	LblRuleIDType = "rule"
	LblOpIDType   = "op"
	LblIOType     = "io"

	LBlRuleRunning = "running"
	LblRuleStop    = "stop"
	LblSourceIO    = "source"
	LblSinkIO      = "sink"
	LblException   = "err"
	LblSuccess     = "success"
)

const OpenMetricsEOF = "# EOF\n"

Variables

var (
	IOCounter = prometheus.NewCounterVec(prometheus.CounterOpts{
		Namespace: "kuiper",
		Subsystem: "io",
		Name:      "counter",
		Help:      "counter of IO",
	}, []string{LblType, LblIOType, LblStatusType, LblRuleIDType, LblOpIDType})

	IODurationHist = prometheus.NewHistogramVec(prometheus.HistogramOpts{
		Namespace: "kuiper",
		Subsystem: "io",
		Name:      "duration_hist",
		Help:      "Historgram Duration of IO",
		Buckets:   prometheus.ExponentialBuckets(10, 2, 20),
	}, []string{LblType, LblIOType, LblRuleIDType, LblOpIDType})
)

var (
	RuleStatusCountGauge = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Namespace: "kuiper",
		Subsystem: "rule",
		Name:      "count",
		Help:      "gauge of rule status count",
	}, []string{LblStatusType})

	RuleStatusGauge = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Namespace: "kuiper",
		Subsystem: "rule",
		Name:      "status",
		Help:      "gauge of rule status",
	}, []string{LblRuleIDType})

	RuleCPUUsageGauge = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Namespace: "kuiper",
		Subsystem: "rule",
		Name:      "cpu_ms",
		Help:      "gauge of rule CPU usage",
	}, []string{LblRuleIDType})
)

var (
	SyncCacheHist = prometheus.NewHistogramVec(prometheus.HistogramOpts{
		Namespace: "kuiper",
		Subsystem: "sync_cache",
		Name:      "duration",
		Buckets:   prometheus.ExponentialBuckets(10, 2, 20),
		Help:      "hist of sync cache",
	}, []string{LblType, LblRuleIDType, LblOpIDType})

	SyncCacheCounter = prometheus.NewCounterVec(prometheus.CounterOpts{
		Namespace: "kuiper",
		Subsystem: "sync_cache",
		Name:      "counter",
		Help:      "counter of sync cache",
	}, []string{LblType, LblRuleIDType, LblOpIDType})

	SyncCacheGauge = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Namespace: "kuiper",
		Subsystem: "sync_cache",
		Name:      "gauge",
		Help:      "gauge of sync cache",
	}, []string{LblType, LblRuleIDType, LblOpIDType})
)

Functions

func GetMetricsZipFile

func GetMetricsZipFile(startTime time.Time, endTime time.Time) (string, error)

func GetStatusValue

func GetStatusValue(err error) string

func InitMetricsDumpJob

func InitMetricsDumpJob(ctx context.Context)

func IsMetricsDumpEnabled

func IsMetricsDumpEnabled() bool

func RegisterSyncCache

func RegisterSyncCache()

func RemoveRuleStatus

func RemoveRuleStatus(ruleID string)

func SetRuleCPUUsageGauge

func SetRuleCPUUsageGauge(ruleID string, value int)

func SetRuleStatus

func SetRuleStatus(ruleID string, value int)

func SetRuleStatusCountGauge

func SetRuleStatusCountGauge(isRunning bool, count int)

func StartMetricsManager

func StartMetricsManager() error

func StopMetricsManager

func StopMetricsManager()

Types

type MetricsDumpManager

type MetricsDumpManager struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*MetricsDumpManager) Init

func (m *MetricsDumpManager) Init(ctx context.Context) error

func (*MetricsDumpManager) IsEnabled

func (m *MetricsDumpManager) IsEnabled() bool

func (*MetricsDumpManager) Start

func (m *MetricsDumpManager) Start() error

func (*MetricsDumpManager) Stop

func (m *MetricsDumpManager) Stop()