probe

package

v0.9.1 Latest Latest Go to latest Published: Jul 15, 2021 License: MIT Imports: 19 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/macrat/ayd

Links

Open Source Insights

Documentation ¶

Rendered for

Index ¶

Constants
Variables
func CheckPingPermission() error
func ExecutePlugin(ctx context.Context, r Reporter, scope string, target *url.URL, command string, ...)
type DNSProbe
- func NewDNSProbe(u *url.URL) (DNSProbe, error)
- func (p DNSProbe) Check(ctx context.Context, r Reporter)
- func (p DNSProbe) Target() *url.URL
type DummyProbe
- func NewDummyProbe(u *url.URL) (DummyProbe, error)
- func (p DummyProbe) Check(ctx context.Context, r Reporter)
- func (p DummyProbe) Status() api.Status
- func (p DummyProbe) Target() *url.URL
type ExecuteProbe
- func NewExecuteProbe(u *url.URL) (ExecuteProbe, error)
- func (p ExecuteProbe) Check(ctx context.Context, r Reporter)
- func (p ExecuteProbe) Target() *url.URL
type HTTPProbe
- func NewHTTPProbe(u *url.URL) (HTTPProbe, error)
- func (p HTTPProbe) Check(ctx context.Context, r Reporter)
- func (p HTTPProbe) Target() *url.URL
type PingProbe
- func NewPingProbe(u *url.URL) (PingProbe, error)
- func (p PingProbe) Check(ctx context.Context, r Reporter)
- func (p PingProbe) Target() *url.URL
type PluginProbe
- func NewPluginProbe(u *url.URL) (PluginProbe, error)
- func (p PluginProbe) Check(ctx context.Context, r Reporter)
- func (p PluginProbe) Target() *url.URL
type Probe
- func New(rawURL string) (Probe, error)
- func NewFromURL(u *url.URL) (Probe, error)
- func WithoutPlugin(p Probe, err error) (Probe, error)
type Reporter
type ResourceLocker
- func NewResourceLocker() *ResourceLocker
- func (rl *ResourceLocker) Done()
- func (rl *ResourceLocker) Start(prepareResource func() error) error
- func (rl *ResourceLocker) Teardown(f func())
type SourceProbe
- func NewSourceProbe(u *url.URL) (SourceProbe, error)
- func (p SourceProbe) Check(ctx context.Context, r Reporter)
- func (p SourceProbe) Target() *url.URL
type TCPProbe
- func NewTCPProbe(u *url.URL) (TCPProbe, error)
- func (p TCPProbe) Check(ctx context.Context, r Reporter)
- func (p TCPProbe) Target() *url.URL

Constants ¶

View Source

const (
	HTTP_REDIRECT_MAX = 10
)

Variables ¶

View Source

var (
	ErrInvalidURL        = errors.New("invalid URL")
	ErrMissingScheme     = errors.New("missing scheme in URL")
	ErrUnsupportedScheme = errors.New("unsupported scheme")
)

View Source

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

View Source

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

View Source

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

View Source

var (
	HTTPUserAgent = "ayd health check"
)

Functions ¶

func CheckPingPermission ¶ added in v0.8.0

func CheckPingPermission() error

func ExecutePlugin ¶ added in v0.5.0

func ExecutePlugin(ctx context.Context, r Reporter, scope string, target *url.URL, command string, args, env []string)

Types ¶

type DNSProbe ¶

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

func NewDNSProbe ¶

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

func (DNSProbe) Check ¶

func (p DNSProbe) Check(ctx context.Context, r Reporter)

func (DNSProbe) Target ¶

func (p DNSProbe) Target() *url.URL

type DummyProbe ¶ added in v0.4.0

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

func NewDummyProbe ¶ added in v0.4.0

func NewDummyProbe(u *url.URL) (DummyProbe, error)

func (DummyProbe) Check ¶ added in v0.4.0

func (p DummyProbe) Check(ctx context.Context, r Reporter)

func (DummyProbe) Status ¶ added in v0.4.0

func (p DummyProbe) Status() api.Status

func (DummyProbe) Target ¶ added in v0.4.0

func (p DummyProbe) Target() *url.URL

type ExecuteProbe ¶

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

func NewExecuteProbe ¶

func NewExecuteProbe(u *url.URL) (ExecuteProbe, error)

func (ExecuteProbe) Check ¶

func (p ExecuteProbe) Check(ctx context.Context, r Reporter)

func (ExecuteProbe) Target ¶

func (p ExecuteProbe) Target() *url.URL

type HTTPProbe ¶

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

func NewHTTPProbe ¶

func NewHTTPProbe(u *url.URL) (HTTPProbe, error)

func (HTTPProbe) Check ¶

func (p HTTPProbe) Check(ctx context.Context, r Reporter)

func (HTTPProbe) Target ¶

func (p HTTPProbe) Target() *url.URL

type PingProbe ¶

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

func NewPingProbe ¶

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

func (PingProbe) Check ¶

func (p PingProbe) Check(ctx context.Context, r Reporter)

func (PingProbe) Target ¶

func (p PingProbe) Target() *url.URL

type PluginProbe ¶ added in v0.4.0

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

func NewPluginProbe ¶ added in v0.4.0

func NewPluginProbe(u *url.URL) (PluginProbe, error)

func (PluginProbe) Check ¶ added in v0.4.0

func (p PluginProbe) Check(ctx context.Context, r Reporter)

func (PluginProbe) Target ¶ added in v0.4.0

func (p PluginProbe) Target() *url.URL

type Probe ¶

type Probe interface {
	Target() *url.URL
	Check(context.Context, Reporter)
}

func New ¶ added in v0.3.0

func New(rawURL string) (Probe, error)

func NewFromURL ¶ added in v0.3.0

func NewFromURL(u *url.URL) (Probe, error)

func WithoutPlugin ¶ added in v0.4.0

func WithoutPlugin(p Probe, err error) (Probe, error)

type Reporter ¶ added in v0.4.0

type Reporter interface {
	Report(r api.Record)
}

type ResourceLocker ¶ added in v0.8.0

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

func NewResourceLocker ¶ added in v0.8.0

func NewResourceLocker() *ResourceLocker

func (*ResourceLocker) Done ¶ added in v0.8.0

func (rl *ResourceLocker) Done()

func (*ResourceLocker) Start ¶ added in v0.8.0

func (rl *ResourceLocker) Start(prepareResource func() error) error

func (*ResourceLocker) Teardown ¶ added in v0.8.0

func (rl *ResourceLocker) Teardown(f func())

type SourceProbe ¶

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

func NewSourceProbe ¶

func NewSourceProbe(u *url.URL) (SourceProbe, error)

func (SourceProbe) Check ¶

func (p SourceProbe) Check(ctx context.Context, r Reporter)

func (SourceProbe) Target ¶

func (p SourceProbe) Target() *url.URL

type TCPProbe ¶

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

func NewTCPProbe ¶

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

func (TCPProbe) Check ¶

func (p TCPProbe) Check(ctx context.Context, r Reporter)

func (TCPProbe) Target ¶

func (p TCPProbe) Target() *url.URL

Source Files ¶

View all Source files

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