Documentation ¶
Index ¶
- Variables
- func Config() config
- func NewAPI(opts ...APIOpt) *api
- func NewDNSError(nodeName string) *dnsError
- func NewDNSProbe(nodeName, server string, names []string, opts ...Opt) *dnsProbe
- func NewDNSSuccess(nodeName string) *dnsSuccess
- func NewICMPProbe(nodeName string, opts ...Opt) *icmpProbe
- func NewMaxRtt(probeName, nodeName string) *maxRtt
- func NewMeanRtt(probeName, nodeName string) *meanRtt
- func NewMinRtt(probeName, nodeName string) *minRtt
- func NewPacketLoss(probeName, nodeName string) *packetLoss
- func NewReportNumber(probeName, nodeName string) *reportNumber
- func NewServer(opts ...Opt) *server
- func NewTotalNumber(probeName, nodeName string) *totalNumber
- type APIOpt
- type Collector
- type Gatherer
- type Metric
- type Metrics
- type Monitor
- func (m *Monitor) Gather(collector Collector)
- func (m *Monitor) SetProbeDNSError(instance string, float float64)
- func (m *Monitor) SetProbeDNSSuccess(instance string, float float64)
- func (m *Monitor) SetProbeNodesReports(instance, probe string, num float64)
- func (m *Monitor) SetProbeNodesTotal(instance, probe string, num float64)
- func (m *Monitor) SetProbePacketLossMax(instance, probe string, percentage float64)
- func (m *Monitor) SetProbePacketLossMean(instance, probe string, percentage float64)
- func (m *Monitor) SetProbePacketLossMin(instance, probe string, percentage float64)
- func (m *Monitor) SetProbePacketLossTotal(instance, probe string, total float64)
- func (m *Monitor) SetProbeRttMax(instance, probe string, rtt float64)
- func (m *Monitor) SetProbeRttMean(instance, probe string, rtt float64)
- func (m *Monitor) SetProbeRttMin(instance, probe string, rtt float64)
- type NodeFilter
- type NodeList
- type NodeLoader
- type Opt
- func WithConfig(c *v1alpha1.Config) Opt
- func WithConfigPath(path string) Opt
- func WithHostIP(ip string) Opt
- func WithInterval(time time.Duration) Opt
- func WithLogger(logger *zap.Logger) Opt
- func WithMonitor(m *Monitor) Opt
- func WithNodeName(nodeName string) Opt
- func WithPodIP(ip string) Opt
- func WithTimeout(time time.Duration) Opt
- type Opts
- type Probe
- type Registry
Constants ¶
This section is empty.
Variables ¶
View Source
var ( DefaultRegistry = NewRegistry() DefaultRegisterer prometheus.Registerer = DefaultRegistry DefaultGatherer prometheus.Gatherer = DefaultRegistry )
View Source
var ( // DefaultMetrics ... DefaultMetrics = NewMetrics() )
View Source
var ( // ErrResolveHost ... ErrResolveHost = errors.New("could not resolve host") )
Functions ¶
func NewDNSProbe ¶ added in v0.1.3
NewDNSProbe ...
func NewDNSSuccess ¶ added in v0.1.3
func NewDNSSuccess(nodeName string) *dnsSuccess
NewDNSSuccess ...
func NewMeanRtt ¶ added in v0.0.28
func NewMeanRtt(probeName, nodeName string) *meanRtt
NewMeanRtt ...
func NewPacketLoss ¶ added in v0.0.28
func NewPacketLoss(probeName, nodeName string) *packetLoss
NewPacketLoss ...
func NewReportNumber ¶ added in v0.0.28
func NewReportNumber(probeName, nodeName string) *reportNumber
NewReportNumber ...
func NewTotalNumber ¶ added in v0.0.28
func NewTotalNumber(probeName, nodeName string) *totalNumber
NewTotalNumber ...
Types ¶
type Collector ¶ added in v0.0.28
type Collector interface { // Collect ... Collect(ch chan<- Metric) }
Collector ...
type Gatherer ¶ added in v0.0.28
type Gatherer interface { // Gather ... Gather(collector Collector) }
Gatherer ...
type Metrics ¶ added in v0.0.4
type Metrics struct {
// contains filtered or unexported fields
}
Metrics ...
func (*Metrics) Collect ¶ added in v0.0.4
func (m *Metrics) Collect(ch chan<- prometheus.Metric)
Collect ...
func (*Metrics) Describe ¶ added in v0.0.4
func (m *Metrics) Describe(ch chan<- *prometheus.Desc)
Describe ...
type Monitor ¶ added in v0.0.4
Monitor ...
func (*Monitor) SetProbeDNSError ¶ added in v0.1.3
SetProbeDNSError ...
func (*Monitor) SetProbeDNSSuccess ¶ added in v0.1.3
SetProbeDNSSuccess ...
func (*Monitor) SetProbeNodesReports ¶ added in v0.0.26
SetProbeNodesReports ...
func (*Monitor) SetProbeNodesTotal ¶ added in v0.0.24
SetProbeNodesTotal ...
func (*Monitor) SetProbePacketLossMax ¶ added in v0.0.23
SetProbePacketLossMax ...
func (*Monitor) SetProbePacketLossMean ¶ added in v0.0.23
SetProbePacketLossMean ...
func (*Monitor) SetProbePacketLossMin ¶ added in v0.0.28
SetProbePacketLossMin ...
func (*Monitor) SetProbePacketLossTotal ¶ added in v0.1.7
SetProbePacketLossTotal ...
func (*Monitor) SetProbeRttMax ¶ added in v0.0.23
SetProbeRttMax ...
func (*Monitor) SetProbeRttMean ¶ added in v0.0.23
SetProbeRttMean ...
func (*Monitor) SetProbeRttMin ¶ added in v0.0.23
SetProbeRttMin ...
type NodeFilter ¶ added in v0.0.30
NodeFilter ...
type NodeList ¶ added in v0.0.20
type NodeList struct {
// contains filtered or unexported fields
}
NodeList ...
func NewNodeList ¶ added in v0.0.20
func NewNodeList(loaders []NodeLoader, filters ...NodeFilter) *NodeList
NewNodeList ...
type NodeLoader ¶ added in v0.0.30
NodeLoader ...
type Opts ¶ added in v0.0.20
type Opts struct {
// contains filtered or unexported fields
}
Opts ...
Click to show internal directories.
Click to hide internal directories.