octopinger

package
v0.1.11 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 6, 2022 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

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 Config 

func Config() config

Config ...

func NewAPI 

func NewAPI(opts ...APIOpt) *api

NewAPI ...

func NewDNSError added in v0.1.3 

func NewDNSError(nodeName string) *dnsError

NewDNSError ...

func NewDNSProbe added in v0.1.3 

func NewDNSProbe(nodeName, server string, names []string, opts ...Opt) *dnsProbe

NewDNSProbe ...

func NewDNSSuccess added in v0.1.3 

func NewDNSSuccess(nodeName string) *dnsSuccess

NewDNSSuccess ...

func NewICMPProbe 

func NewICMPProbe(nodeName string, opts ...Opt) *icmpProbe

NewICMPProbe ...

func NewMaxRtt added in v0.0.28 

func NewMaxRtt(probeName, nodeName string) *maxRtt

NewMaxRtt ...

func NewMeanRtt added in v0.0.28 

func NewMeanRtt(probeName, nodeName string) *meanRtt

NewMeanRtt ...

func NewMinRtt added in v0.0.28 

func NewMinRtt(probeName, nodeName string) *minRtt

NewMinRtt ...

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 NewServer 

func NewServer(opts ...Opt) *server

NewServer ...

func NewTotalNumber added in v0.0.28 

func NewTotalNumber(probeName, nodeName string) *totalNumber

NewTotalNumber ...

Types

type APIOpt added in v0.0.4 

type APIOpt func(*api)

APIOpt ...

func WithAddr added in v0.0.4 

func WithAddr(addr string) APIOpt

WithAddr ...

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 Metric added in v0.0.28 

type Metric interface {
	// Write ...
	Write(m *Monitor) error
}

Metric

type Metrics added in v0.0.4 

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

Metrics ...

func NewMetrics added in v0.0.4 

func NewMetrics() *Metrics

NewMetrics ...

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 

type Monitor struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Monitor ...

func NewMonitor added in v0.0.4 

func NewMonitor(metrics *Metrics) *Monitor

NewMonitor ...

func (*Monitor) Gather added in v0.0.28 

func (m *Monitor) Gather(collector Collector)

Gather ...

func (*Monitor) SetProbeDNSError added in v0.1.3 

func (m *Monitor) SetProbeDNSError(instance string, float float64)

SetProbeDNSError ...

func (*Monitor) SetProbeDNSSuccess added in v0.1.3 

func (m *Monitor) SetProbeDNSSuccess(instance string, float float64)

SetProbeDNSSuccess ...

func (*Monitor) SetProbeNodesReports added in v0.0.26 

func (m *Monitor) SetProbeNodesReports(instance, probe string, num float64)

SetProbeNodesReports ...

func (*Monitor) SetProbeNodesTotal added in v0.0.24 

func (m *Monitor) SetProbeNodesTotal(instance, probe string, num float64)

SetProbeNodesTotal ...

func (*Monitor) SetProbePacketLossMax added in v0.0.23 

func (m *Monitor) SetProbePacketLossMax(instance, probe string, percentage float64)

SetProbePacketLossMax ...

func (*Monitor) SetProbePacketLossMean added in v0.0.23 

func (m *Monitor) SetProbePacketLossMean(instance, probe string, percentage float64)

SetProbePacketLossMean ...

func (*Monitor) SetProbePacketLossMin added in v0.0.28 

func (m *Monitor) SetProbePacketLossMin(instance, probe string, percentage float64)

SetProbePacketLossMin ...

func (*Monitor) SetProbePacketLossTotal added in v0.1.7 

func (m *Monitor) SetProbePacketLossTotal(instance, probe string, total float64)

SetProbePacketLossTotal ...

func (*Monitor) SetProbeRttMax added in v0.0.23 

func (m *Monitor) SetProbeRttMax(instance, probe string, rtt float64)

SetProbeRttMax ...

func (*Monitor) SetProbeRttMean added in v0.0.23 

func (m *Monitor) SetProbeRttMean(instance, probe string, rtt float64)

SetProbeRttMean ...

func (*Monitor) SetProbeRttMin added in v0.0.23 

func (m *Monitor) SetProbeRttMin(instance, probe string, rtt float64)

SetProbeRttMin ...

type NodeFilter added in v0.0.30 

type NodeFilter func(node string) bool

NodeFilter ...

func FilterIP added in v0.0.30 

func FilterIP(ip string) NodeFilter

FilterIP ...

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 ...

func (*NodeList) Load added in v0.0.20 

func (n *NodeList) Load() ([]string, error)

Load ...

type NodeLoader added in v0.0.30 

type NodeLoader func() ([]string, error)

NodeLoader ...

func NodesLoader added in v0.0.30 

func NodesLoader(base string) NodeLoader

NodeLoader ...

type Opt 

type Opt func(*Opts)

Opt ...

func WithConfig added in v0.1.7 

func WithConfig(c *v1alpha1.Config) Opt

WithConfig ...

func WithConfigPath 

func WithConfigPath(path string) Opt

WithConfigPath ...

func WithHostIP added in v0.1.7 

func WithHostIP(ip string) Opt

WithHostIP ...

func WithInterval added in v0.0.20 

func WithInterval(time time.Duration) Opt

WithInterval ...

func WithLogger 

func WithLogger(logger *zap.Logger) Opt

WithLogger ...

func WithMonitor added in v0.0.4 

func WithMonitor(m *Monitor) Opt

WithMonitor ...

func WithNodeName added in v0.0.4 

func WithNodeName(nodeName string) Opt

WithNodeName ...

func WithPodIP added in v0.0.30 

func WithPodIP(ip string) Opt

WithPodIP ...

func WithTimeout added in v0.0.20 

func WithTimeout(time time.Duration) Opt

WithTimeout ...

type Opts added in v0.0.20 

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

Opts ...

func (*Opts) Configure added in v0.0.20 

func (o *Opts) Configure(opts ...Opt)

Configure ...

type Probe 

type Probe interface {
	// Do ...
	Do(ctx context.Context, monitor Monitor) error

	Collector
}

Probe ...

type Registry added in v0.0.4 

type Registry struct {
	*prometheus.Registry
}

Registry ...

func NewRegistry added in v0.0.4 

func NewRegistry() *Registry

NewRegistry ...

func (*Registry) Handler added in v0.0.4 

func (r *Registry) Handler() http.Handler

Handler returns a HTTP handler for this registry. Should be registered at "/metrics".

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.