metrics

Documentation

Index

• Constants
• type Metric
• type MetricsCollector
  • func GetMetricsCollector() *MetricsCollector
  • func (m *MetricsCollector) GetMetrics() map[string]interface{}
  • func (m *MetricsCollector) RegisterMetric(metric Metric)
  • func (m *MetricsCollector) RegisterOneTimeMetric(metric Metric)
  • func (m *MetricsCollector) UpdateMetrics()
  • func (m *MetricsCollector) UpdateOneTimeMetrics()
• type MinioMetrics
  • func (m *MinioMetrics) GetMetrics() map[string]string
  • func (m *MinioMetrics) GetMetricsName() string
  • func (m *MinioMetrics) Update() error
• type NFSMetrics
  • func (n *NFSMetrics) GetMetrics() map[string]string
  • func (n *NFSMetrics) GetMetricsName() string
  • func (n *NFSMetrics) Update() error
• type PodMetrics
  • func (p *PodMetrics) GetMetrics() map[string]string
  • func (p *PodMetrics) GetMetricsName() string
  • func (p *PodMetrics) Update() error
• type TimeMetrics
  • func (t *TimeMetrics) End(name string)
  • func (t *TimeMetrics) GetMetrics() map[string]string
  • func (t *TimeMetrics) GetMetricsName() string
  • func (t *TimeMetrics) Start(name string)
  • func (t *TimeMetrics) Update() error

Constants

const MinioDesc = "Minio disk usage"

const NFSDesc = "NFS disk usage"

const PodResourceDesc = "Resource consumption"

const TimeCaseDesc = "Time cost"

Types

type Metric

type Metric interface {
	Update() error
	GetMetricsName() string
	GetMetrics() map[string]string
}

Metric is an interface for metrics that test needs.

type MetricsCollector

type MetricsCollector struct {
	Metrics        []Metric   // metrics need update periodically
	OneTimeMetrics []Metric   // OneTimeMetrics just update one time
	Mu             sync.Mutex // mutex for protecting shared resources
}

MetricsCollector is a singleton struct for collecting metrics.

func GetMetricsCollector

func GetMetricsCollector() *MetricsCollector

GetMetricsCollector returns the singleton instance of MetricsCollector

func (*MetricsCollector) GetMetrics

func (m *MetricsCollector) GetMetrics() map[string]interface{}

GetMetrics returns the metrics from all metrics

func (*MetricsCollector) RegisterMetric

func (m *MetricsCollector) RegisterMetric(metric Metric)

RegisterMetric adds a metric to the MetricsCollector

func (*MetricsCollector) RegisterOneTimeMetric

func (m *MetricsCollector) RegisterOneTimeMetric(metric Metric)

RegisterOneTimeMetric adds a one-time metric to the MetricsCollector

func (*MetricsCollector) UpdateMetrics

func (m *MetricsCollector) UpdateMetrics()

UpdateMetrics periodically updates the metrics for all metrics

func (*MetricsCollector) UpdateOneTimeMetrics

func (m *MetricsCollector) UpdateOneTimeMetrics()

UpdateMetrics periodically updates the one-time metrics for all metrics

type MinioMetrics

type MinioMetrics struct {
	Metrics              map[string]string
	CloudCredentialsFile string
	BslBucket            string
	BslPrefix            string
	BslConfig            string
}

func (*MinioMetrics) GetMetrics

func (m *MinioMetrics) GetMetrics() map[string]string

func (*MinioMetrics) GetMetricsName

func (m *MinioMetrics) GetMetricsName() string

func (*MinioMetrics) Update

func (m *MinioMetrics) Update() error

type NFSMetrics

type NFSMetrics struct {
	Metrics       map[string]string
	NFSServerPath string
	Ctx           context.Context
}

func (*NFSMetrics) GetMetrics

func (n *NFSMetrics) GetMetrics() map[string]string

func (*NFSMetrics) GetMetricsName

func (n *NFSMetrics) GetMetricsName() string

func (*NFSMetrics) Update

func (n *NFSMetrics) Update() error

type PodMetrics

type PodMetrics struct {
	Client  *metricsclientset.Clientset
	Metrics map[string]int64

	PodName, Namespace string
	Ctx                context.Context
	// contains filtered or unexported fields
}

func (*PodMetrics) GetMetrics

func (p *PodMetrics) GetMetrics() map[string]string

func (*PodMetrics) GetMetricsName

func (p *PodMetrics) GetMetricsName() string

func (*PodMetrics) Update

func (p *PodMetrics) Update() error

type TimeMetrics

type TimeMetrics struct {
	Name     string
	TimeInfo map[string]time.Time // metric name : start timestamp
	Metrics  map[string]float64   // metric name : time duration
}

func (*TimeMetrics) End

func (t *TimeMetrics) End(name string)

func (*TimeMetrics) GetMetrics

func (t *TimeMetrics) GetMetrics() map[string]string

func (*TimeMetrics) GetMetricsName

func (t *TimeMetrics) GetMetricsName() string

func (*TimeMetrics) Start

func (t *TimeMetrics) Start(name string)

func (*TimeMetrics) Update

func (t *TimeMetrics) Update() error