pollers

package

Go to main page

Versions in this module

v0

v0.15.0

Dec 8, 2023

v0.14.0

Oct 20, 2022

v0.13.0

Sep 13, 2022

v0.12.0

Sep 9, 2022

Changes in this version

+ const PollerTypeHTTP

type TLSService

+ CertificateMatchesPin prometheus.Gauge

+ func (s *TLSService) Status() Status

v0.10.0

Aug 12, 2022

Changes in this version

+ const PollerTypeBasic

+ const PollerTypeChallengeResponse

+ const PollyerTypeHTTP

type BasicService

+ func (s *BasicService) Labels() prometheus.Labels

+ func (s *BasicService) LogFields() []zap.Field

type ChallengeResponseService

+ func (crs *ChallengeResponseService) PollerType() string

type Poller

+ Labels func() prometheus.Labels

+ LogFields func() []zap.Field

+ type ServiceStatusMetricCollector struct

+ ServiceStatus *prometheus.GaugeVec

+ func NewServiceStatusMetrics() *ServiceStatusMetricCollector

+ func (ssm *ServiceStatusMetricCollector) AddPoller(pollers ...Poller)

+ func (ssm *ServiceStatusMetricCollector) Collect(ch chan<- prometheus.Metric)

+ func (ssm *ServiceStatusMetricCollector) Describe(ch chan<- *prometheus.Desc)

v0.9.3

Aug 12, 2022

v0.9.2

Aug 11, 2022

v0.9.1

Aug 8, 2022

Changes in this version

+ var ErrTooManyRedirects = errors.New("Too many redirects")

+ type BasePoller interface

+ type ChallengeResponseMetricSet struct

+ ServiceChallengeStartTimeStamp prometheus.Gauge

+ ServiceChallengeTime prometheus.Gauge

+ ServiceRequestCount *prometheus.CounterVec

+ ServiceRequestSize prometheus.Gauge

+ ServiceRequestSuccessful prometheus.Gauge

+ ServiceRespondedCount *prometheus.CounterVec

+ ServiceRespondedSuccessfully prometheus.Gauge

+ ServiceResponseDuration prometheus.Gauge

+ ServiceResponseSize prometheus.Gauge

+ ServiceResponseTimeToFirstByte prometheus.Gauge

+ ServiceResponseTimeToFirstByteCount prometheus.Counter

+ func NewChallengeResponseMetricSet(constantLabels prometheus.Labels) ChallengeResponseMetricSet

+ func (crms *ChallengeResponseMetricSet) Collect(ch chan<- prometheus.Metric)

+ func (crms *ChallengeResponseMetricSet) Describe(ch chan<- *prometheus.Desc)

+ type PollConnection struct

+ func (p *PollConnection) Context() context.Context

+ func (p *PollConnection) Deadline() time.Time

+ func (p *PollConnection) Dialer() proxy.ContextDialer

type Status

+ func TryReadMatch(conn io.Reader, config *config.ChallengeResponseConfig) (Status, float64, time.Duration)

+ type TLSService struct

+ CertificateNotAfter *prometheus.GaugeVec

+ CertificateNotBefore *prometheus.GaugeVec

+ CertificateValid *prometheus.GaugeVec

+ CertificateValidCount *prometheus.CounterVec

+ func (s *TLSService) Collect(ch chan<- prometheus.Metric)

+ func (s *TLSService) Describe(ch chan<- *prometheus.Desc)

+ func (s *TLSService) Poll()

v0.9.0

Aug 4, 2022

Changes in this version

+ const MetricLabelFailed

+ const MetricLabelSuccess

+ const Namespace

+ const PollStatusFailed

+ const PollStatusSuccess

+ var PollStatusUnknown = Status(math.NaN())

+ func NewHTTPClient(conn net.Conn) *http.Client

+ type BasicService struct

+ PortOpen prometheus.Gauge

+ PortOpenCount *prometheus.CounterVec

+ func (s *BasicService) Collect(ch chan<- prometheus.Metric)

+ func (s *BasicService) Describe(ch chan<- *prometheus.Desc)

+ func (s *BasicService) Host() *Host

+ func (s *BasicService) Name() string

+ func (s *BasicService) Poll()

+ func (s *BasicService) Port() uint64

+ func (s *BasicService) Proto() string

+ func (s *BasicService) Status() Status

+ type ChallengeResponseService struct

+ ServiceChallengeTime prometheus.Gauge

+ ServiceRequestCount *prometheus.CounterVec

+ ServiceRequestSize prometheus.Gauge

+ ServiceRequestSuccessful prometheus.Gauge

+ ServiceRespondedCount *prometheus.CounterVec

+ ServiceRespondedSuccessfully prometheus.Gauge

+ ServiceResponseDuration prometheus.Gauge

+ ServiceResponseSize prometheus.Gauge

+ ServiceResponseTimeToFirstByte prometheus.Gauge

+ ServiceResponseTimeToFirstByteCount prometheus.Counter

+ func NewChallengeResponseService(host *Host, opts config.ChallengeResponseConfig) *ChallengeResponseService

+ func (crs *ChallengeResponseService) Challenge(conn io.Writer) Status

+ func (crs *ChallengeResponseService) Collect(ch chan<- prometheus.Metric)

+ func (crs *ChallengeResponseService) Describe(ch chan<- *prometheus.Desc)

+ func (crs *ChallengeResponseService) Poll()

+ func (crs *ChallengeResponseService) Status() Status

+ func (crs *ChallengeResponseService) TryReadMatch(conn io.Reader) (Status, float64, time.Duration)

+ type HTTPService struct

+ func NewHTTPService(host *Host, opts config.HTTPServiceConfig) *HTTPService

+ func (hs *HTTPService) Collect(ch chan<- prometheus.Metric)

+ func (hs *HTTPService) Describe(ch chan<- *prometheus.Desc)

+ func (hs *HTTPService) Poll()

+ func (hs *HTTPService) Status() Status

+ type Host struct

+ IP string

+ LastPollTime prometheus.Gauge

+ LatencyCount prometheus.Counter

+ NumPolls prometheus.Counter

+ PathReachable prometheus.Gauge

+ PingLatency prometheus.Gauge

+ PingResultCount *prometheus.CounterVec

+ Pollers []Poller

+ ReachableCount *prometheus.CounterVec

+ Resolvable prometheus.Gauge

+ ResolvableCount *prometheus.CounterVec

+ func NewHost(opts config.HostConfig) *Host

+ func (s *Host) Collect(ch chan<- prometheus.Metric)

+ func (s *Host) Describe(ch chan<- *prometheus.Desc)

+ func (s *Host) LastPoll() time.Time

+ func (s *Host) Latency() time.Duration

+ func (s *Host) NextPoll() time.Duration

+ func (s *Host) Poll(limiter *Limiter, hostQueue chan<- *Host)

+ func (s *Host) SincePoll() time.Duration

+ func (s *Host) Status() Status

+ type Limiter struct

+ func NewLimiter(size int) *Limiter

+ func (lim *Limiter) Lock()

+ func (lim *Limiter) Unlock()

+ type Poller interface

+ Collect func(ch chan<- prometheus.Metric)

+ Describe func(ch chan<- *prometheus.Desc)

+ Host func() *Host

+ Name func() string

+ Poll func()

+ Port func() uint64

+ Proto func() string

+ Status func() Status

+ func NewBasicService(host *Host, opts config.BasicServiceConfig) Poller

+ type SSLService struct

+ SSLNotAfter *prometheus.GaugeVec

+ SSLNotBefore *prometheus.GaugeVec

+ SSLValid *prometheus.GaugeVec

+ SSLValidCount *prometheus.CounterVec

+ func (s *SSLService) Collect(ch chan<- prometheus.Metric)

+ func (s *SSLService) Describe(ch chan<- *prometheus.Desc)

+ func (s *SSLService) Poll()

+ type Status float64

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