scheme

Dec 18, 2022

Changes in this version

+ type FTPScheme struct

+ func NewFTPScheme(u *api.URL) (FTPScheme, error)

+ func (s FTPScheme) Alert(ctx context.Context, r Reporter, lastRecord api.Record)

+ func (s FTPScheme) Probe(ctx context.Context, r Reporter)

+ func (s FTPScheme) Target() *api.URL

Jun 26, 2022

Changes in this version

+ type FileScheme struct

+ func NewFileScheme(u *api.URL) (FileScheme, error)

+ func (s FileScheme) Alert(ctx context.Context, r Reporter, lastRecord api.Record)

+ func (s FileScheme) Probe(ctx context.Context, r Reporter)

+ func (s FileScheme) Target() *api.URL

Dec 3, 2021

Changes in this version

+ var ErrMissingPassword = errors.New("password is required if set username")

+ var ErrMissingUsername = errors.New("username is required if set password")

+ var ErrUnsupportedAlertScheme = errors.New("unsupported scheme for alert")

+ type DNSProbe struct

+ func NewDNSProbe(u *url.URL) (DNSProbe, error)

+ func (s DNSProbe) Probe(ctx context.Context, r Reporter)

+ func (s DNSProbe) Target() *url.URL

+ type FTPProbe struct

+ func NewFTPProbe(u *url.URL) (FTPProbe, error)

+ func (p FTPProbe) Probe(ctx context.Context, r Reporter)

+ func (p FTPProbe) Target() *url.URL

+ type PingProbe struct

+ func NewPingProbe(u *url.URL) (PingProbe, error)

+ func (s PingProbe) Probe(ctx context.Context, r Reporter)

+ func (s PingProbe) Target() *url.URL

+ type TCPProbe struct

+ func NewTCPProbe(u *url.URL) (TCPProbe, error)

+ func (s TCPProbe) Probe(ctx context.Context, r Reporter)

+ func (s TCPProbe) Target() *url.URL

Nov 9, 2021

Changes in this version

+ const HTTP_REDIRECT_MAX

+ var ErrConflictDNSType = errors.New("DNS type in scheme and query is conflicted")

+ var ErrFailedToPreparePing = errors.New("failed to setup ping service")

+ var ErrInvalidAlertURL = errors.New("invalid alert URL")

+ var ErrInvalidSource = errors.New("invalid source")

+ var ErrInvalidSourceURL = errors.New("invalid source URL")

+ var ErrInvalidURL = errors.New("invalid URL")

+ var ErrMissingCommand = errors.New("missing command")

+ var ErrMissingDomainName = errors.New("missing domain name")

+ var ErrMissingFile = errors.New("missing file")

+ var ErrMissingHost = errors.New("missing target host")

+ var ErrMissingScheme = errors.New("missing scheme in URL")

+ var ErrRedirectLoopDetected = errors.New("redirect loop detected")

+ var ErrTCPPortMissing = errors.New("TCP target's port number is required")

+ var ErrUnsupportedDNSType = errors.New("unsupported DNS type")

+ var ErrUnsupportedScheme = errors.New("unsupported scheme")

+ var HTTPUserAgent = "ayd health check"

+ func SplitScheme(scheme string) (subScheme string, separator rune, variant string)

+ type AlertReporter struct

+ Source *url.URL

+ Upstream Reporter

+ func (r AlertReporter) DeactivateTarget(source *url.URL, targets ...*url.URL)

+ func (r AlertReporter) Report(_ *url.URL, rec api.Record)

+ type Alerter interface

+ Alert func(context.Context, Reporter, api.Record)

+ Target func() *url.URL

+ func NewAlerter(target string) (Alerter, error)

+ func NewAlerterFromURL(u *url.URL) (Alerter, error)

+ type AlerterSet []Alerter

+ func NewAlerterSet(targets []string) (AlerterSet, error)

+ func (as AlerterSet) Alert(ctx context.Context, r Reporter, lastRecord api.Record)

+ func (as AlerterSet) Target() *url.URL

+ type DNSScheme struct

+ func NewDNSScheme(u *url.URL) (DNSScheme, error)

+ func (s DNSScheme) Alert(ctx context.Context, r Reporter, _ api.Record)

+ func (s DNSScheme) Probe(ctx context.Context, r Reporter)

+ func (s DNSScheme) Target() *url.URL

+ type DummyScheme struct

+ func NewDummyScheme(u *url.URL) (DummyScheme, error)

+ func (s DummyScheme) Alert(ctx context.Context, r Reporter, _ api.Record)

+ func (s DummyScheme) Probe(ctx context.Context, r Reporter)

+ func (s DummyScheme) Status() api.Status

+ func (s DummyScheme) Target() *url.URL

+ type ExecScheme struct

+ func NewExecScheme(u *url.URL) (ExecScheme, error)

+ func (s ExecScheme) Alert(ctx context.Context, r Reporter, lastRecord api.Record)

+ func (s ExecScheme) Probe(ctx context.Context, r Reporter)

+ func (s ExecScheme) Target() *url.URL

+ type FixedSourceReporter struct

+ Source *url.URL

+ Upstreams []Reporter

+ func (r FixedSourceReporter) DeactivateTarget(source *url.URL, targets ...*url.URL)

+ func (r FixedSourceReporter) Report(_ *url.URL, rec api.Record)

+ type HTTPScheme struct

+ func NewHTTPScheme(u *url.URL) (HTTPScheme, error)

+ func (s HTTPScheme) Alert(ctx context.Context, r Reporter, lastRecord api.Record)

+ func (s HTTPScheme) Probe(ctx context.Context, r Reporter)

+ func (s HTTPScheme) Target() *url.URL

+ type PingScheme struct

+ func NewPingScheme(u *url.URL) (PingScheme, error)

+ func (s PingScheme) Alert(ctx context.Context, r Reporter, _ api.Record)

+ func (s PingScheme) Probe(ctx context.Context, r Reporter)

+ func (s PingScheme) Target() *url.URL

+ type PluginScheme struct

+ func NewPluginAlert(u *url.URL) (PluginScheme, error)

+ func NewPluginProbe(u *url.URL) (PluginScheme, error)

+ func NewPluginScheme(u *url.URL, scope string) (PluginScheme, error)

+ func (p PluginScheme) Alert(ctx context.Context, r Reporter, lastRecord api.Record)

+ func (p PluginScheme) Probe(ctx context.Context, r Reporter)

+ func (p PluginScheme) Target() *url.URL

+ type Prober interface

+ Probe func(context.Context, Reporter)

+ Target func() *url.URL

+ func NewProber(rawURL string) (Prober, error)

+ func NewProberFromURL(u *url.URL) (Prober, error)

+ type Reporter interface

+ DeactivateTarget func(source *url.URL, targets ...*url.URL)

+ Report func(source *url.URL, r api.Record)

+ type SourceScheme struct

+ func NewSourceAlert(u *url.URL) (SourceScheme, error)

+ func NewSourceProbe(u *url.URL) (SourceScheme, error)

+ func (p SourceScheme) Alert(ctx context.Context, r Reporter, lastRecord api.Record)

+ func (p SourceScheme) Probe(ctx context.Context, r Reporter)

+ func (p SourceScheme) Target() *url.URL

+ type TCPScheme struct

+ func NewTCPScheme(u *url.URL) (TCPScheme, error)

+ func (s TCPScheme) Alert(ctx context.Context, r Reporter, _ api.Record)

+ func (s TCPScheme) Probe(ctx context.Context, r Reporter)

+ func (s TCPScheme) Target() *url.URL

+ type TargetTracker struct

+ func (t *TargetTracker) Activate(target *url.URL)

+ func (t *TargetTracker) DeactivateTarget(_ *url.URL, _ ...*url.URL)

+ func (t *TargetTracker) Inactives() []*url.URL

+ func (t *TargetTracker) PrepareReporter(source *url.URL, r Reporter) Reporter

+ func (t *TargetTracker) Report(_ *url.URL, rec api.Record)