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 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 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