exporter

package

v2.0.0+incompatible Latest Latest Go to latest Published: Apr 10, 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/chubaofs

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
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 RegistConsul(cluster string, role string, cfg *config.Config)
func RegisterConsul(addr, app, role, cluster string, port int64)
func SendRegisterReq(addr string, app string, role string, cluster string, port int64)
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) Set(val int64)
- func (g *Gauge) SetWithLabels(val int64, labels map[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(1) * time.Minute
	RegisterPath   = "/v1/agent/service/register"
)

View Source

const (
	PromHandlerPattern    = "/metrics"     // prometheus handler
	AppName               = "cfs"          //app name
	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 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 RegistConsul ¶ added in v1.4.0

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

func RegisterConsul ¶

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

func SendRegisterReq ¶

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

SendRegisterReq sends the register request.

Types ¶

type Alarm ¶

type Alarm struct {
	Counter
}

func Warning ¶ added in v1.4.0

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) Set ¶

func (g *Gauge) Set(val int64)

func (*Gauge) SetWithLabels ¶

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