common

package

Go to main page

Versions in this module

v0

v0.2.4

Sep 18, 2025

v0.2.3

Sep 18, 2025

v0.2.2

Sep 18, 2025

v0.2.1

Sep 18, 2025

Changes in this version

type VerifierMetrics

+ func (vm *VerifierMetrics) RecordTestErrorByType(componentType, componentName, domain, country, errorType string, ...)

+ func (vm *VerifierMetrics) RecordTestStartByType(componentType, componentName, domain, country string)

+ func (vm *VerifierMetrics) RecordTestSuccessByType(componentType, componentName, domain, country string, duration float64)

v0.2.0

Sep 17, 2025

Changes in this version

+ func ExtractDomain(uri string) string

+ func NormalizeCountryForMetrics(country string) string

+ type VerifierMetrics struct

+ func NewVerifierMetrics(metrics *sreCommon.Metrics) *VerifierMetrics

+ func (vm *VerifierMetrics) GetMetrics() *sreCommon.Metrics

+ func (vm *VerifierMetrics) RecordTestError(verifier, domain, country, errorType string, duration float64)

+ func (vm *VerifierMetrics) RecordTestResult(verifier, domain, country string, probability float64, duration float64)

+ func (vm *VerifierMetrics) RecordTestStart(verifier, domain, country string)

+ func (vm *VerifierMetrics) RecordTestSuccess(verifier, domain, country string, duration float64)

v0.1.0

Jun 19, 2025

v0.0.4

Feb 18, 2025

v0.0.3

Jan 29, 2025

Changes in this version

type Observability

+ func (o *Observability) Panic(obj interface{}, args ...interface{})

v0.0.2

Oct 8, 2024

v0.0.1

Oct 7, 2024

Changes in this version

+ const URIPortHttp

+ const URIPortHttps

+ const URIPortUnknown

+ const URISchemeHttp

+ const URISchemeHttps

+ const URISchemeUnknown

+ func Duration(s string, def time.Duration) time.Duration

+ func Md5(b []byte) []byte

+ func Md5ToString(b []byte) string

+ func NormalizeCountries(countries []string) []string

+ func NormalizeCountry(s string) string

+ func NormalizeURI(s string) string

+ func URIScheme(uri string) string

+ type Detector interface

+ Detect func() error

+ Name func() string

+ Schedule func() string

+ Start func(ctx context.Context)

+ type DetectorOptions struct

+ StartTimeout int

+ type Detectors struct

+ func NewDetectors(options *DetectorOptions, observability *Observability) *Detectors

+ func (ds *Detectors) Add(d ...Detector)

+ func (ds *Detectors) Scheduled() bool

+ func (ds *Detectors) Start(once, wait bool, ctx context.Context)

+ type Notifier interface

+ Name func() string

+ Notify func(vr *VerifyResult) error

+ type NotifierConfiguration struct

+ Notifier Notifier

+ Probability NotifierProbability

+ type NotifierProbability = float64

+ type Notifiers struct

+ func NewNotifiers(observability *Observability) *Notifiers

+ func (ns *Notifiers) Add(n Notifier)

+ func (ns *Notifiers) FindConfigurationByPattern(pattern string) []*NotifierConfiguration

+ func (ns *Notifiers) GetDefaultConfigurations() []*NotifierConfiguration

+ func (ns *Notifiers) Items() []Notifier

+ type Observability struct

+ func NewObservability(logs *sre.Logs, metrics *sre.Metrics) *Observability

+ func (o *Observability) Debug(obj interface{}, args ...interface{})

+ func (o *Observability) Error(obj interface{}, args ...interface{})

+ func (o *Observability) Info(obj interface{}, args ...interface{})

+ func (o *Observability) Logs() *sre.Logs

+ func (o *Observability) Metrics() *sre.Metrics

+ func (o *Observability) Warn(obj interface{}, args ...interface{})

+ type ObserveCountries = map[string]*ObserveProbability

+ type ObserveEndpoint struct

+ Countries ObserveCountries

+ IPs []string

+ Response *SourceEndpointResponse

+ URI string

+ type ObserveEndpoints struct

+ func (oes *ObserveEndpoints) Add(e ...*ObserveEndpoint)

+ func (oes *ObserveEndpoints) Clone(oe *ObserveEndpoint) *ObserveEndpoint

+ func (oes *ObserveEndpoints) IsEmpty() bool

+ func (oes *ObserveEndpoints) Items() []*ObserveEndpoint

+ func (oes *ObserveEndpoints) Reduce() ObserveEndpoints

+ type ObserveProbability = float64

+ type ObserveResult struct

+ Configuration *ObserverConfiguration

+ Endpoints ObserveEndpoints

+ type Observer interface

+ Name func() string

+ Observe func(sr *SourceResult) (*ObserveResult, error)

+ type ObserverConfiguration struct

+ Observer Observer

+ Probability ObserveProbability

+ type Observers struct

+ func NewObservers(observability *Observability) *Observers

+ func (ob *Observers) Add(o Observer)

+ func (ob *Observers) FindConfigurationByPattern(pattern string) []*ObserverConfiguration

+ func (ob *Observers) GetDefaultConfigurations() []*ObserverConfiguration

+ func (ob *Observers) Items() []Observer

+ type Source interface

+ Load func() (*SourceResult, error)

+ Name func() string

+ Start func(ctx context.Context) error

+ type SourceEndpoint struct

+ Countries []string

+ Detectors []string

+ Disabled bool

+ IPs []string

+ Response *SourceEndpointResponse

+ URI string

+ func CheckSourceEndpoints(es []*SourceEndpoint) []*SourceEndpoint

+ type SourceEndpointResponse struct

+ Code string

+ Content string

+ type SourceEndpoints struct

+ func (ses *SourceEndpoints) Add(e ...*SourceEndpoint)

+ func (ses *SourceEndpoints) Clone(se *SourceEndpoint) *SourceEndpoint

+ func (ses *SourceEndpoints) IsEmpty() bool

+ func (ses *SourceEndpoints) Items() []*SourceEndpoint

+ func (ses *SourceEndpoints) Reduce() SourceEndpoints

+ type SourceResult struct

+ Endpoints SourceEndpoints

+ type Sources struct

+ func NewSources(observability *Observability) *Sources

+ func (ss *Sources) Add(s Source)

+ func (ss *Sources) FindByName(name string) Source

+ func (ss *Sources) Items() []Source

+ type TriggerOptions struct

+ TTL string

+ type Triggers struct

+ func NewTriggers(options *TriggerOptions, observability *Observability) *Triggers

+ func (t *Triggers) Exists(key string) bool

+ func (t *Triggers) Update(key string, ep *VerifyEndpoint)

+ type URI struct

+ Fragment string

+ Host string

+ Password string

+ Path string

+ Port string

+ Query string

+ Scheme string

+ UserName string

+ func URIParse(uri string) (*URI, error)

+ type Verifier interface

+ Name func() string

+ Verify func(or *ObserveResult) (*VerifyResult, error)

+ type VerifierConfiguration struct

+ Probability VerifyProbability

+ Verifier Verifier

+ type Verifiers struct

+ func NewVerifiers(observability *Observability) *Verifiers

+ func (vs *Verifiers) Add(v Verifier)

+ func (vs *Verifiers) FindConfigurationByPattern(pattern string) []*VerifierConfiguration

+ func (vs *Verifiers) GetDefaultConfigurations() []*VerifierConfiguration

+ func (vs *Verifiers) Items() []Verifier

+ type VerifyCountries = map[string]*VerifyStatus

+ type VerifyEndpoint struct

+ Countries VerifyCountries

+ URI string

+ func (ve *VerifyEndpoint) Ident() string

+ type VerifyEndpoints struct

+ func (ves *VerifyEndpoints) Add(e ...*VerifyEndpoint)

+ func (ves *VerifyEndpoints) Clone(ve *VerifyEndpoint) *VerifyEndpoint

+ func (ves *VerifyEndpoints) IsEmpty() bool

+ func (ves *VerifyEndpoints) Items() []*VerifyEndpoint

+ func (ves *VerifyEndpoints) Reduce() VerifyEndpoints

+ type VerifyProbability = float64

+ type VerifyResult struct

+ Configuration *VerifierConfiguration

+ Endpoints VerifyEndpoints

+ type VerifyStatus struct

+ Flags VerifyStatusFlags

+ Probability *VerifyProbability

+ type VerifyStatusFlag = string

+ const VerifyStatusFlagWrongIPAddress

+ const VerifyStatusFlagWrongResponseCode

+ type VerifyStatusFlags = map[VerifyStatusFlag]bool

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