exporter

package

v0.0.0-...-020888f Latest Latest Go to latest Published: Aug 21, 2020 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/chengyu-l/ecnode_checker

Links

Open Source Insights

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 int64)
- func (g *Gauge) SetWithLabels(val int64, 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 ¶

View Source

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

View Source

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 ¶

View Source

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

View Source

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

View Source

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

	GaugeGroup sync.Map
	GaugeCh    chan *Gauge
)

View Source

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

func (*Gauge) SetWithLabels ¶

func (g *Gauge) SetWithLabels(val int64, 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)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL