Versions in this module Expand all Collapse all v3 v3.0.1 Feb 23, 2021 Changes in this version + const DefaultMetricsServerPath + const DefaultMetricsServerPort + var K8sRequestTotalMetric = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... }) + var PodMissingMetric = prometheus.NewGaugeVec(prometheus.GaugeOpts{ ... }, []string{ ... }) + var WorkflowConditionMetric = prometheus.NewGaugeVec(prometheus.GaugeOpts{ ... }, []string{ ... }) + func AddMetricsTransportWrapper(config *rest.Config) *rest.Config + func ConstructOrUpdateMetric(metric prometheus.Metric, metricSpec *wfv1.Prometheus) (prometheus.Metric, error) + func ConstructRealTimeGaugeMetric(metricSpec *wfv1.Prometheus, valueFunc func() float64) (prometheus.Metric, error) + func IsValidMetricName(name string) bool + func ValidateMetricLabels(metrics map[string]string) error + type ErrorCause string + const ErrorCauseCronWorkflowSubmissionError + const ErrorCauseOperationPanic + type Metrics struct + func New(metricsConfig, telemetryConfig ServerConfig) *Metrics + func (m *Metrics) Collect(ch chan<- prometheus.Metric) + func (m *Metrics) CronWorkflowSubmissionError() + func (m *Metrics) Describe(ch chan<- *prometheus.Desc) + func (m *Metrics) Fire(entry *log.Entry) error + func (m *Metrics) GetCustomMetric(key string) prometheus.Metric + func (m *Metrics) Levels() []log.Level + func (m *Metrics) NewAddsMetric(name string) workqueue.CounterMetric + func (m *Metrics) NewDepthMetric(name string) workqueue.GaugeMetric + func (m *Metrics) NewLatencyMetric(name string) workqueue.HistogramMetric + func (m *Metrics) NewLongestRunningProcessorSecondsMetric(name string) workqueue.SettableGaugeMetric + func (m *Metrics) NewRetriesMetric(name string) workqueue.CounterMetric + func (m *Metrics) NewUnfinishedWorkSecondsMetric(name string) workqueue.SettableGaugeMetric + func (m *Metrics) NewWorkDurationMetric(name string) workqueue.HistogramMetric + func (m *Metrics) OperationCompleted(durationSeconds float64) + func (m *Metrics) OperationPanic() + func (m *Metrics) RateLimiterWithBusyWorkers(workQueue workqueue.RateLimiter, queueName string) workqueue.RateLimitingInterface + func (m *Metrics) RunServer(ctx context.Context) + func (m *Metrics) SetPodPhaseGauge(phase corev1.PodPhase, num int) + func (m *Metrics) SetWorkflowPhaseGauge(phase v1alpha1.NodePhase, num int) + func (m *Metrics) StopRealtimeMetricsForKey(key string) + func (m *Metrics) UpsertCustomMetric(key string, ownerKey string, newMetric prometheus.Metric, realtime bool) error + type RealTimeMetric struct + Func func() float64 + type ServerConfig struct + Enabled bool + IgnoreErrors bool + Path string + Port int + TTL time.Duration + func (s ServerConfig) SameServerAs(other ServerConfig) bool Other modules containing this package github.com/akshayflipkart/argo-workflows
Go to main page