exporter

Documentation

Index

• Constants
• Variables
• func DoConsulRegisterProc(addr, app, role, cluster string, port int64)
• func GetConsulId(app string, role string, host string, port int64) string
• func GetLocalIpAddr() (ipaddr string, err error)
• func Init(role string, cfg *config.Config)
• func InitWithRouter(role string, cfg *config.Config, router *mux.Router, exPort string)
• func RegistConsul(cluster string, role string, cfg *config.Config)
• type Alarm
  • func Warning(detail string) (a *Alarm)
• type ConsulRegisterInfo
• type Counter
  • func NewCounter(name string) (c *Counter)
  • func (c *Counter) Add(val int64)
  • func (c *Counter) AddWithLabels(val int64, labels map[string]string)
  • func (c *Counter) Metric() prometheus.Counter
• type Gauge
  • func NewGauge(name string) (g *Gauge)
  • func (c *Gauge) Key() (key string)
  • func (c *Gauge) Metric() prometheus.Gauge
  • func (g *Gauge) Name() string
  • func (g *Gauge) Set(val float64)
  • func (g *Gauge) SetWithLabels(val float64, labels map[string]string)
  • func (g *Gauge) String() string
• type TimePoint
  • func NewTP(name string) (tp *TimePoint)
  • func (tp *TimePoint) Set()
• type TimePointCount
  • func NewTPCnt(name string) (tpc *TimePointCount)
  • func (tpc *TimePointCount) Set(err error)

Constants

const (
	RegisterPeriod = time.Duration(10) * time.Minute
	RegisterPath   = "/v1/agent/service/register"
)

const (
	PromHandlerPattern      = "/metrics"       // prometheus handler
	AppName                 = "cfs"            //app name
	ConfigKeyExporterEnable = "exporterEnable" //exporter enable
	ConfigKeyExporterPort   = "exporterPort"   //exporter port
	ConfigKeyConsulAddr     = "consulAddr"     //consul addr
	ChSize                  = 1024 * 10        //collect chan size
)

Variables

var (
	AlarmPool = &sync.Pool{New: func() interface{} {
		return new(Alarm)
	}}
	//AlarmGroup  sync.Map
	AlarmCh chan *Alarm
)

var (
	CounterGroup sync.Map
	CounterPool  = &sync.Pool{New: func() interface{} {
		return new(Counter)
	}}
	CounterCh chan *Counter
)

var (
	GaugePool = &sync.Pool{New: func() interface{} {
		return new(Gauge)
	}}

	GaugeGroup sync.Map
	GaugeCh    chan *Gauge
)

var (
	TPPool = &sync.Pool{New: func() interface{} {
		return new(TimePoint)
	}}
	TPCh chan *TimePoint
)

Functions

func DoConsulRegisterProc

func DoConsulRegisterProc(addr, app, role, cluster string, port int64)

do consul register process

func GetConsulId

func GetConsulId(app string, role string, host string, port int64) string

get consul id

func GetLocalIpAddr

func GetLocalIpAddr() (ipaddr string, err error)

GetLocalIpAddr returns the local IP address.

func Init

func Init(role string, cfg *config.Config)

Init initializes the exporter.

func InitWithRouter

func InitWithRouter(role string, cfg *config.Config, router *mux.Router, exPort string)

Init initializes the exporter.

func RegistConsul

func RegistConsul(cluster string, role string, cfg *config.Config)

Types

type Alarm

type Alarm struct {
	Counter
}

func Warning

func Warning(detail string) (a *Alarm)

type ConsulRegisterInfo

type ConsulRegisterInfo struct {
	Name    string   `json:"Name"`
	ID      string   `json:"ID"`
	Address string   `json:"Address"`
	Port    int64    `json:"Port"`
	Tags    []string `json:"Tags"`
}

*

• consul register info for prometheus
• optional for user when set prometheus exporter

type Counter

type Counter struct {
	Gauge
}

func NewCounter

func NewCounter(name string) (c *Counter)

func (*Counter) Add

func (c *Counter) Add(val int64)

func (*Counter) AddWithLabels

func (c *Counter) AddWithLabels(val int64, labels map[string]string)

func (*Counter) Metric

func (c *Counter) Metric() prometheus.Counter

type Gauge

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

func NewGauge

func NewGauge(name string) (g *Gauge)

func (*Gauge) Key

func (c *Gauge) Key() (key string)

func (*Gauge) Metric

func (c *Gauge) Metric() prometheus.Gauge

func (*Gauge) Name

func (g *Gauge) Name() string

func (*Gauge) Set

func (g *Gauge) Set(val float64)

func (*Gauge) SetWithLabels

func (g *Gauge) SetWithLabels(val float64, labels map[string]string)

func (*Gauge) String

func (g *Gauge) String() string

type TimePoint

type TimePoint struct {
	Gauge
	// contains filtered or unexported fields
}

func NewTP

func NewTP(name string) (tp *TimePoint)

func (*TimePoint) Set

func (tp *TimePoint) Set()

type TimePointCount

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

func NewTPCnt

func NewTPCnt(name string) (tpc *TimePointCount)

func (*TimePointCount) Set

func (tpc *TimePointCount) Set(err error)