prome

Documentation

Index

• Constants
• type CostBucket
  • func (h *CostBucket) Observe(v float64)
• type Exporter
  • func NewExporter(namespace string) *Exporter
  • func (exporter *Exporter) Close()
  • func (exporter *Exporter) Collect(ch chan<- prometheus.Metric)
  • func (exporter *Exporter) Describe(ch chan<- *prometheus.Desc)
  • func (exporter *Exporter) Start(port int) error
• type MetricsGather
• type MetricsInfo
  • func (info *MetricsInfo) String() string
• type MetricsInstance
  • func (mInstance *MetricsInstance) AddItem(mi *MetricsItem)
  • func (mInstance *MetricsInstance) GetMetricsInfo() []MetricsInfo
• type MetricsItem
  • func NewCounterStat(name string, counter int) *MetricsItem
  • func NewStat(name string) *MetricsItem
  • func (mi *MetricsItem) End()
  • func (mi *MetricsItem) MarkErr() *MetricsItem
  • func (mi *MetricsItem) MarkOk() *MetricsItem
  • func (mi *MetricsItem) SampleRate(rate float32) *MetricsItem
  • func (mi *MetricsItem) SetCounter(counter int) *MetricsItem
• type ServerExporter
  • func NewServerExporter(namespace string) *ServerExporter
  • func (serverE *ServerExporter) Collect(ch chan<- prometheus.Metric)
  • func (serverE *ServerExporter) Describe(ch chan<- *prometheus.Desc)
  • func (serverE *ServerExporter) Reset()

Constants

const (
	StatusOK int8 = iota
	StatusERR
	StatusMax
)

const (
	MetricsChannelBuff          = 30000
	MetricsCollectInterval      = 30
	MetricsGatherDBBuffSize     = 300
	MetricsGatherBucketSize     = 20
	MetricsGatherBucketMaxValue = 100
)

Types

type CostBucket

type CostBucket struct {
	// contains filtered or unexported fields
}

func (*CostBucket) Observe

func (h *CostBucket) Observe(v float64)

type Exporter

type Exporter struct {
	ServerExporter
	// contains filtered or unexported fields
}

func NewExporter

func NewExporter(namespace string) *Exporter

func (*Exporter) Close

func (exporter *Exporter) Close()

func (*Exporter) Collect

func (exporter *Exporter) Collect(ch chan<- prometheus.Metric)

Implements prometheus.Collector.

func (*Exporter) Describe

func (exporter *Exporter) Describe(ch chan<- *prometheus.Desc)

Implements prometheus.Collector.

func (*Exporter) Start

func (exporter *Exporter) Start(port int) error

type MetricsGather

type MetricsGather struct {
	// contains filtered or unexported fields
}

type MetricsInfo

type MetricsInfo struct {
	Name       string  `json:"name"`
	Status     string  `json:"status"`
	QPS        float32 `json:"qps"`
	Total      int     `json:"total"`
	AvgCost    float64 `json:"avg_cost"`
	MaxCost    float64 `json:"max_cost"`
	AvgCounter float32 `json:"avg_counter"`
}

func (*MetricsInfo) String

func (info *MetricsInfo) String() string

type MetricsInstance

type MetricsInstance struct {
	// contains filtered or unexported fields
}

func (*MetricsInstance) AddItem

func (mInstance *MetricsInstance) AddItem(mi *MetricsItem)

func (*MetricsInstance) GetMetricsInfo

func (mInstance *MetricsInstance) GetMetricsInfo() []MetricsInfo

type MetricsItem

type MetricsItem struct {
	// contains filtered or unexported fields
}

func NewCounterStat

func NewCounterStat(name string, counter int) *MetricsItem

func NewStat

func NewStat(name string) *MetricsItem

func (*MetricsItem) End

func (mi *MetricsItem) End()

func (*MetricsItem) MarkErr

func (mi *MetricsItem) MarkErr() *MetricsItem

func (*MetricsItem) MarkOk

func (mi *MetricsItem) MarkOk() *MetricsItem

func (*MetricsItem) SampleRate

func (mi *MetricsItem) SampleRate(rate float32) *MetricsItem

func (*MetricsItem) SetCounter

func (mi *MetricsItem) SetCounter(counter int) *MetricsItem

type ServerExporter

type ServerExporter struct {
	// contains filtered or unexported fields
}

func NewServerExporter

func NewServerExporter(namespace string) *ServerExporter

func (*ServerExporter) Collect

func (serverE *ServerExporter) Collect(ch chan<- prometheus.Metric)

func (*ServerExporter) Describe

func (serverE *ServerExporter) Describe(ch chan<- *prometheus.Desc)

func (*ServerExporter) Reset

func (serverE *ServerExporter) Reset()