collector

Documentation

Index

• type Collector
  • func NewCollector() *Collector
  • func (c *Collector) Collect(ch chan<- prometheus.Metric)
  • func (c *Collector) Describe(ch chan<- *prometheus.Desc)
• type RocketMQCollector
• type RocketMQMetric
  • func ParseLine(line string) *RocketMQMetric
  • func (m *RocketMQMetric) IntCount() float64
  • func (m *RocketMQMetric) IntDiffTotal() float64
  • func (m *RocketMQMetric) IntTPS() float64
  • func (m *RocketMQMetric) String() string
• type RocketMQMetricSet
  • func NewRocketMQMetricSet() *RocketMQMetricSet
  • func (s *RocketMQMetricSet) Add(item *RocketMQMetric)
  • func (s *RocketMQMetricSet) String() string

Types

type Collector

type Collector struct {
	Conf *conf.Config
	// contains filtered or unexported fields
}

func NewCollector

func NewCollector() *Collector

func (*Collector) Collect

func (c *Collector) Collect(ch chan<- prometheus.Metric)

func (*Collector) Describe

func (c *Collector) Describe(ch chan<- *prometheus.Desc)

type RocketMQCollector

type RocketMQCollector struct {
	prometheus.Collector
}

解析数据文件:data.txt --> RocketMQMetricSet RocketMQMetricSet 转换成Prometheus format data 将Prometheus format data输出到标准输出

type RocketMQMetric

type RocketMQMetric struct {
	Group     string
	Count     string
	Version   string
	Type      string
	Model     string
	TPS       string
	DiffTotal string
}

func ParseLine

func ParseLine(line string) *RocketMQMetric

func (*RocketMQMetric) IntCount

func (m *RocketMQMetric) IntCount() float64

func (*RocketMQMetric) IntDiffTotal

func (m *RocketMQMetric) IntDiffTotal() float64

func (*RocketMQMetric) IntTPS

func (m *RocketMQMetric) IntTPS() float64

func (*RocketMQMetric) String

func (m *RocketMQMetric) String() string

type RocketMQMetricSet

type RocketMQMetricSet struct {
	Items []*RocketMQMetric
}

func NewRocketMQMetricSet

func NewRocketMQMetricSet() *RocketMQMetricSet

func (*RocketMQMetricSet) Add

func (s *RocketMQMetricSet) Add(item *RocketMQMetric)

func (*RocketMQMetricSet) String

func (s *RocketMQMetricSet) String() string