The highest tagged major version is v5.

funcs

package

v1.4.0 Latest Latest Go to latest Published: Jun 13, 2020 License: Apache-2.0 Imports: 26 Imported by: 6

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/didi/nightingale

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func BuildMappers()
func CheckFS(file string, content string) error
func Collect()
func CollectorMetrics() []*dataobj.MetricValue
func CounterToGauge(item *dataobj.MetricValue) error
func CounterValue(metric string, val interface{}, tags ...string) *dataobj.MetricValue
func CpuContentSwitches() float64
func CpuGuest() float64
func CpuIdle() float64
func CpuIowait() float64
func CpuIrq() float64
func CpuMetrics() []*dataobj.MetricValue
func CpuNice() float64
func CpuPrepared() bool
func CpuSoftIrq() float64
func CpuSteal() float64
func CpuSystem() float64
func CpuUser() float64
func CurrentCpuSwitches() uint64
func DeviceMetrics() []*dataobj.MetricValue
func EntityNumMetrics() []*dataobj.MetricValue
func FsKernelMetrics() []*dataobj.MetricValue
func FsRWMetrics() []*dataobj.MetricValue
func GaugeValue(metric string, val interface{}, tags ...string) *dataobj.MetricValue
func IODelta(device string, f func([2]*nux.DiskStats) uint64) uint64
func IOMsecRead(arr [2]*nux.DiskStats) uint64
func IOMsecTotal(arr [2]*nux.DiskStats) uint64
func IOMsecWeightedTotal(arr [2]*nux.DiskStats) uint64
func IOMsecWrite(arr [2]*nux.DiskStats) uint64
func IOReadMerged(arr [2]*nux.DiskStats) uint64
func IOReadRequests(arr [2]*nux.DiskStats) uint64
func IOReadSectors(arr [2]*nux.DiskStats) uint64
func IOStatsMetrics() []*dataobj.MetricValue
func IOWriteMerged(arr [2]*nux.DiskStats) uint64
func IOWriteRequests(arr [2]*nux.DiskStats) uint64
func IOWriteSectors(arr [2]*nux.DiskStats) uint64
func InitRpcClients()
func LoadAvgMetrics() []*dataobj.MetricValue
func MemMetrics() []*dataobj.MetricValue
func NetMetrics() (ret []*dataobj.MetricValue)
func NewMetricValue(metric string, val interface{}, dataType string, tags ...string) *dataobj.MetricValue
func NfMetrics() []*dataobj.MetricValue
func NtpOffsetMetrics() []*dataobj.MetricValue
func PrepareCpuStat()
func PrepareDiskStats()
func ProcsNumMetrics() []*dataobj.MetricValue
func Push(metricItems []*dataobj.MetricValue) error
func ShouldHandleDevice(device string) bool
func SocketStatSummaryMetrics() []*dataobj.MetricValue
func TS(arr [2]*nux.DiskStats) uint64
func TcpMetrics() []*dataobj.MetricValue
func UdpMetrics() []*dataobj.MetricValue
func UpdateCpuStat() error
func UpdateDiskStats() error
type CpuStats
- func CpuIdles() (res []*CpuStats)
type CumIfStat
type FuncsAndInterval
type RpcClientContainer
- func (rcc *RpcClientContainer) Del(addr string)
- func (rcc *RpcClientContainer) Get(addr string) *rpc.Client
- func (rcc *RpcClientContainer) Put(addr string, client *rpc.Client) bool

Constants ¶

This section is empty.

Variables ¶

View Source

var Mappers []FuncsAndInterval

Functions ¶

func BuildMappers ¶

func BuildMappers()

func CheckFS ¶

func CheckFS(file string, content string) error

func Collect ¶

func Collect()

func CollectorMetrics ¶

func CollectorMetrics() []*dataobj.MetricValue

func CounterToGauge ¶ added in v1.1.0

func CounterToGauge(item *dataobj.MetricValue) error

func CounterValue ¶

func CounterValue(metric string, val interface{}, tags ...string) *dataobj.MetricValue

func CpuContentSwitches ¶

func CpuContentSwitches() float64

func CpuGuest ¶

func CpuGuest() float64

func CpuIdle ¶

func CpuIdle() float64

func CpuIowait ¶

func CpuIowait() float64

func CpuIrq ¶

func CpuIrq() float64

func CpuMetrics ¶

func CpuMetrics() []*dataobj.MetricValue

func CpuNice ¶

func CpuNice() float64

func CpuPrepared ¶

func CpuPrepared() bool

func CpuSoftIrq ¶

func CpuSoftIrq() float64

func CpuSteal ¶

func CpuSteal() float64

func CpuSystem ¶

func CpuSystem() float64

func CpuUser ¶

func CpuUser() float64

func CurrentCpuSwitches ¶

func CurrentCpuSwitches() uint64

func DeviceMetrics ¶

func DeviceMetrics() []*dataobj.MetricValue

func EntityNumMetrics ¶

func EntityNumMetrics() []*dataobj.MetricValue

func FsKernelMetrics ¶

func FsKernelMetrics() []*dataobj.MetricValue

func FsRWMetrics ¶

func FsRWMetrics() []*dataobj.MetricValue

func GaugeValue ¶

func GaugeValue(metric string, val interface{}, tags ...string) *dataobj.MetricValue

func IODelta ¶

func IODelta(device string, f func([2]*nux.DiskStats) uint64) uint64

func IOMsecRead ¶

func IOMsecRead(arr [2]*nux.DiskStats) uint64

func IOMsecTotal ¶

func IOMsecTotal(arr [2]*nux.DiskStats) uint64

func IOMsecWeightedTotal ¶

func IOMsecWeightedTotal(arr [2]*nux.DiskStats) uint64

func IOMsecWrite ¶

func IOMsecWrite(arr [2]*nux.DiskStats) uint64

func IOReadMerged ¶

func IOReadMerged(arr [2]*nux.DiskStats) uint64

func IOReadRequests ¶

func IOReadRequests(arr [2]*nux.DiskStats) uint64

func IOReadSectors ¶

func IOReadSectors(arr [2]*nux.DiskStats) uint64

func IOStatsMetrics ¶

func IOStatsMetrics() []*dataobj.MetricValue

func IOWriteMerged ¶

func IOWriteMerged(arr [2]*nux.DiskStats) uint64

func IOWriteRequests ¶

func IOWriteRequests(arr [2]*nux.DiskStats) uint64

func IOWriteSectors ¶

func IOWriteSectors(arr [2]*nux.DiskStats) uint64

func InitRpcClients ¶ added in v1.2.1

func InitRpcClients()

func LoadAvgMetrics ¶

func LoadAvgMetrics() []*dataobj.MetricValue

func MemMetrics ¶

func MemMetrics() []*dataobj.MetricValue

func NetMetrics ¶

func NetMetrics() (ret []*dataobj.MetricValue)

func NewMetricValue ¶

func NewMetricValue(metric string, val interface{}, dataType string, tags ...string) *dataobj.MetricValue

func NfMetrics ¶

func NfMetrics() []*dataobj.MetricValue

func NtpOffsetMetrics ¶

func NtpOffsetMetrics() []*dataobj.MetricValue

func PrepareCpuStat ¶

func PrepareCpuStat()

func PrepareDiskStats ¶

func PrepareDiskStats()

func ProcsNumMetrics ¶

func ProcsNumMetrics() []*dataobj.MetricValue

func Push ¶

func Push(metricItems []*dataobj.MetricValue) error

func ShouldHandleDevice ¶

func ShouldHandleDevice(device string) bool

func SocketStatSummaryMetrics ¶

func SocketStatSummaryMetrics() []*dataobj.MetricValue

func TS ¶

func TS(arr [2]*nux.DiskStats) uint64

func TcpMetrics ¶ added in v1.4.0

func TcpMetrics() []*dataobj.MetricValue

func UdpMetrics ¶ added in v1.4.0

func UdpMetrics() []*dataobj.MetricValue

func UpdateCpuStat ¶

func UpdateCpuStat() error

func UpdateDiskStats ¶

func UpdateDiskStats() error

Types ¶

type CpuStats ¶

type CpuStats struct {
	User    float64
	Nice    float64
	System  float64
	Idle    float64
	Iowait  float64
	Irq     float64
	SoftIrq float64
	Steal   float64
	Guest   float64
	Total   float64
}

func CpuIdles ¶

func CpuIdles() (res []*CpuStats)

type CumIfStat ¶

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

type FuncsAndInterval ¶

type FuncsAndInterval struct {
	Fs       []func() []*dataobj.MetricValue
	Interval int
}

type RpcClientContainer ¶ added in v1.2.1

type RpcClientContainer struct {
	M map[string]*rpc.Client
	sync.RWMutex
}

func (*RpcClientContainer) Del ¶ added in v1.2.2

func (rcc *RpcClientContainer) Del(addr string)

func (*RpcClientContainer) Get ¶ added in v1.2.1

func (rcc *RpcClientContainer) Get(addr string) *rpc.Client

func (*RpcClientContainer) Put ¶ added in v1.2.1

func (rcc *RpcClientContainer) Put(addr string, client *rpc.Client) bool

Put 返回的bool表示affected，确实把自己塞进去了

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