checks

package
v0.35.0 Latest Latest
Warning

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

 Go to latest Published: Aug 19, 2021 License: Apache-2.0 Imports: 78 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var All = []Checker{
	&HelmChecker{},
	&DNSChecker{},
	&HTTPChecker{},
	&IcmpChecker{},
	&S3Checker{},
	&S3BucketChecker{},
	&DockerPullChecker{},
	&DockerPushChecker{},
	&ContainerdPullChecker{},
	&PostgresChecker{},
	&MssqlChecker{},
	&LdapChecker{},
	&JmeterChecker{},
	&ResticChecker{},
	&RedisChecker{},
	&JunitChecker{},
	&SmbChecker{},
	&EC2Checker{},
	&PrometheusChecker{},
	NewPodChecker(),
	NewNamespaceChecker(),
	NewTCPChecker(),
}

Functions

func CheckSQL added in v0.19.2 

func CheckSQL(check v1.SQLCheck) *pkg.CheckResult

CheckSQL : Attempts to connect to a DB using the specified 

driver and connection string

Returns check result and metrics

func DNSLookup 

func DNSLookup(endpoint string) ([]pkg.URL, error)

func Error added in v0.33.1 

func Error(check external.Check, err error) *pkg.CheckResult

func Failf 

func Failf(check external.Check, msg string, args ...interface{}) *pkg.CheckResult

func GetAuthValues added in v0.30.0 

func GetAuthValues(auth *v1.Authentication, client *kommons.Client, namespace string) (v1.Authentication, error)

func HandleFail added in v0.33.0 

func HandleFail(check v1.EC2Check, message string) *pkg.CheckResult

func Passf 

func Passf(check external.Check, msg string, args ...interface{}) *pkg.CheckResult

func RunChecks added in v0.33.0 

func RunChecks(canary v1.Canary) []*pkg.CheckResult

func Success added in v0.11.4 

func Success(check external.Check, start time.Time) *pkg.CheckResult

func Successf added in v0.21.0 

func Successf(check external.Check, start time.Time, textResults bool, msg string, args ...interface{}) *pkg.CheckResult

func TextFailf added in v0.21.0 

func TextFailf(check external.Check, textResults bool, msg string, args ...interface{}) *pkg.CheckResult

TextFailf used for failure in case of text based results

Types

type AWS added in v0.33.1 

type AWS struct {
	EC2    *ec2.Client
	Config aws.Config
}

func NewAWS added in v0.33.1 

func NewAWS(kommonsClient *kommons.Client, canary v1.Canary, check v1.EC2Check) (*AWS, error)

func (*AWS) Describe added in v0.33.1 

func (cfg *AWS) Describe(instanceID string, timeout time.Duration) (internalIP string, internalDNS string, err error)

func (*AWS) GetAMI added in v0.33.1 

func (cfg *AWS) GetAMI(check v1.EC2Check) (*string, error)

func (*AWS) GetExistingInstanceIds added in v0.33.1 

func (cfg *AWS) GetExistingInstanceIds(idString string) ([]string, error)

func (*AWS) Launch added in v0.33.1 

func (cfg *AWS) Launch(check v1.EC2Check, name, ami string) (string, *time.Duration, error)

func (*AWS) TerminateInstances added in v0.33.1 

func (cfg *AWS) TerminateInstances(instanceIds []string, timeout time.Duration) (*time.Duration, error)

type BucketStatus added in v0.21.0 

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

type Checker 

type Checker interface {
	Run(config v1.Canary) []*pkg.CheckResult
	Type() string
	Check(canary v1.Canary, extConfig external.Check) *pkg.CheckResult
}

type ContainerdPullChecker added in v0.12.0 

type ContainerdPullChecker struct{}

func (*ContainerdPullChecker) Check added in v0.12.0 

func (c *ContainerdPullChecker) Check(canary v1.Canary, extConfig external.Check) *pkg.CheckResult

Run: Check every entry from config according to Checker interface Returns check result and metrics

func (*ContainerdPullChecker) Run added in v0.12.0 

func (c *ContainerdPullChecker) Run(canary v1.Canary) []*pkg.CheckResult

func (*ContainerdPullChecker) Type added in v0.12.0 

func (c *ContainerdPullChecker) Type() string

Type: returns checker type

type DNSChecker 

type DNSChecker struct{}

func (*DNSChecker) Check 

func (c *DNSChecker) Check(canary v1.Canary, extConfig external.Check) *pkg.CheckResult

func (*DNSChecker) Run 

func (c *DNSChecker) Run(canary v1.Canary) []*pkg.CheckResult

func (*DNSChecker) Type 

func (c *DNSChecker) Type() string

Type: returns checker type

type DockerPullChecker 

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

func (*DockerPullChecker) Check 

func (c *DockerPullChecker) Check(canary v1.Canary, extConfig external.Check) *pkg.CheckResult

Run: Check every entry from config according to Checker interface Returns check result and metrics

func (*DockerPullChecker) Run 

func (c *DockerPullChecker) Run(canary v1.Canary) []*pkg.CheckResult

func (*DockerPullChecker) SetClient added in v0.30.0 

func (c *DockerPullChecker) SetClient(client *kommons.Client)

func (*DockerPullChecker) Type 

func (c *DockerPullChecker) Type() string

Type: returns checker type

type DockerPushChecker 

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

func (*DockerPushChecker) Check 

func (c *DockerPushChecker) Check(canary v1.Canary, extConfig external.Check) *pkg.CheckResult

Run: Check every entry from config according to Checker interface Returns check result and metrics

func (*DockerPushChecker) Run 

func (c *DockerPushChecker) Run(canary v1.Canary) []*pkg.CheckResult

func (*DockerPushChecker) SetClient added in v0.30.0 

func (c *DockerPushChecker) SetClient(client *kommons.Client)

func (*DockerPushChecker) Type 

func (c *DockerPushChecker) Type() string

Type: returns checker type

type EC2Checker added in v0.33.0 

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

func (*EC2Checker) Check added in v0.33.0 

func (c *EC2Checker) Check(canary v1.Canary, extConfig external.Check) *pkg.CheckResult

func (EC2Checker) GetClient added in v0.33.0 

func (c EC2Checker) GetClient() *kommons.Client

func (*EC2Checker) Run added in v0.33.0 

func (c *EC2Checker) Run(canary v1.Canary) []*pkg.CheckResult

Run: Check every entry from config according to Checker interface Returns check result and metrics

func (*EC2Checker) SetClient added in v0.33.0 

func (c *EC2Checker) SetClient(client *kommons.Client)

func (*EC2Checker) Type added in v0.33.0 

func (c *EC2Checker) Type() string

Type: returns checker type

type HTTPCheckResult added in v0.11.0 

type HTTPCheckResult struct {
	// Check is the configuration
	Check        interface{}
	Endpoint     string
	Record       string
	ResponseCode int
	SSLExpiry    int
	Content      string
	ResponseTime int64
}

func (HTTPCheckResult) String added in v0.11.0 

func (check HTTPCheckResult) String() string

type HTTPChecker added in v0.19.2 

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

func (*HTTPChecker) Check added in v0.19.2 

func (c *HTTPChecker) Check(canary v1.Canary, extConfig external.Check) *pkg.CheckResult

CheckConfig : Check every record of DNS name against config information Returns check result and metrics

func (HTTPChecker) GetClient added in v0.19.2 

func (c HTTPChecker) GetClient() *kommons.Client

func (*HTTPChecker) ParseAuth added in v0.19.2 

func (c *HTTPChecker) ParseAuth(check v1.HTTPCheck, namespace string) (string, string, error)

func (*HTTPChecker) Run added in v0.19.2 

func (c *HTTPChecker) Run(canary v1.Canary) []*pkg.CheckResult

Run: Check every entry from config according to Checker interface Returns check result and metrics

func (*HTTPChecker) SetClient added in v0.19.2 

func (c *HTTPChecker) SetClient(client *kommons.Client)

func (*HTTPChecker) Type added in v0.19.2 

func (c *HTTPChecker) Type() string

Type: returns checker type

type HTTPStatus added in v0.21.0 

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

type HelmChecker 

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

func (*HelmChecker) Check 

func (c *HelmChecker) Check(canary v1.Canary, extConfig external.Check) *pkg.CheckResult

func (*HelmChecker) Run 

func (c *HelmChecker) Run(canary v1.Canary) []*pkg.CheckResult

func (*HelmChecker) SetClient added in v0.30.0 

func (c *HelmChecker) SetClient(client *kommons.Client)

func (*HelmChecker) Type 

func (c *HelmChecker) Type() string

Type: returns checker type

type IcmpChecker 

type IcmpChecker struct{}

func (*IcmpChecker) Check 

func (c *IcmpChecker) Check(canary v1.Canary, extConfig external.Check) *pkg.CheckResult

CheckConfig : Check every record of DNS name against config information Returns check result and metrics

func (*IcmpChecker) Run 

func (c *IcmpChecker) Run(canary v1.Canary) []*pkg.CheckResult

Run: Check every entry from config according to Checker interface Returns check result and metrics

func (*IcmpChecker) Type 

func (c *IcmpChecker) Type() string

Type: returns checker type

type JMeterRecord added in v0.30.0 

type JMeterRecord struct {
	Elapsed        int64  `csv:"elapsed"`
	Success        bool   `csv:"success"`
	FailureMessage string `csv:"failureMessage,omitempty"`
}

type JmeterChecker added in v0.19.1 

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

func (*JmeterChecker) Check added in v0.19.1 

func (c *JmeterChecker) Check(canary v1.Canary, extConfig external.Check) *pkg.CheckResult

func (JmeterChecker) GetClient added in v0.19.1 

func (c JmeterChecker) GetClient() *kommons.Client

func (*JmeterChecker) Run added in v0.19.1 

func (c *JmeterChecker) Run(canary v1.Canary) []*pkg.CheckResult

func (*JmeterChecker) SetClient added in v0.19.1 

func (c *JmeterChecker) SetClient(client *kommons.Client)

func (*JmeterChecker) Type added in v0.19.1 

func (c *JmeterChecker) Type() string

type JunitChecker added in v0.21.0 

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

func (*JunitChecker) Check added in v0.21.0 

func (c *JunitChecker) Check(canary v1.Canary, extConfig external.Check) *pkg.CheckResult

func (JunitChecker) GetClient added in v0.21.0 

func (c JunitChecker) GetClient() *kommons.Client

func (*JunitChecker) Run added in v0.21.0 

func (c *JunitChecker) Run(canary v1.Canary) []*pkg.CheckResult

func (*JunitChecker) SetClient added in v0.21.0 

func (c *JunitChecker) SetClient(client *kommons.Client)

func (*JunitChecker) Type added in v0.21.0 

func (c *JunitChecker) Type() string

type JunitStatus added in v0.21.0 

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

type LdapChecker 

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

func (*LdapChecker) Check 

func (c *LdapChecker) Check(canary v1.Canary, extConfig external.Check) *pkg.CheckResult

CheckConfig : Check every ldap entry for lookup and auth Returns check result and metrics

func (*LdapChecker) Run 

func (c *LdapChecker) Run(canary v1.Canary) []*pkg.CheckResult

Run: Check every entry from config according to Checker interface Returns check result and metrics

func (*LdapChecker) SetClient added in v0.30.0 

func (c *LdapChecker) SetClient(client *kommons.Client)

func (*LdapChecker) Type 

func (c *LdapChecker) Type() string

Type: returns checker type

type MssqlChecker added in v0.18.0 

type MssqlChecker struct{}

func (*MssqlChecker) Check added in v0.18.0 

func (c *MssqlChecker) Check(canary v1.Canary, extConfig external.Check) *pkg.CheckResult

Check CheckConfig : Attempts to connect to a DB using the specified 

driver and connection string

Returns check result and metrics

func (*MssqlChecker) Run added in v0.18.0 

func (c *MssqlChecker) Run(canary v1.Canary) []*pkg.CheckResult

Run - Check every entry from config according to Checker interface Returns check result and metrics

func (*MssqlChecker) Type added in v0.18.0 

func (c *MssqlChecker) Type() string

Type: returns checker type

type NameGenerator added in v0.9.0 

type NameGenerator struct {
	NamespacesCount int
	PodsCount       int
	// contains filtered or unexported fields
}

func (*NameGenerator) NamespaceName added in v0.9.0 

func (n *NameGenerator) NamespaceName(prefix string) string

func (*NameGenerator) PodName added in v0.9.0 

func (n *NameGenerator) PodName(prefix string) string

type NamespaceChecker added in v0.9.0 

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

func NewNamespaceChecker added in v0.9.0 

func NewNamespaceChecker() *NamespaceChecker

func (*NamespaceChecker) Check added in v0.9.0 

func (c *NamespaceChecker) Check(canary canaryv1.Canary, extConfig external.Check) *pkg.CheckResult

func (*NamespaceChecker) Cleanup added in v0.9.0 

func (c *NamespaceChecker) Cleanup(ns *v1.Namespace) error

func (*NamespaceChecker) Run added in v0.9.0 

func (c *NamespaceChecker) Run(canary canaryv1.Canary) []*pkg.CheckResult

Run: Check every entry from config according to Checker interface Returns check result and metrics

func (*NamespaceChecker) Type added in v0.9.0 

func (c *NamespaceChecker) Type() string

Type: returns checker type

func (*NamespaceChecker) WaitForPod added in v0.9.0 

func (c *NamespaceChecker) WaitForPod(ns, name string, timeout time.Duration, phases ...v1.PodPhase) (*v1.Pod, error)

WaitForPod waits for a pod to be in the specified phase, or returns an error if the timeout is exceeded

type PodChecker 

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

func NewPodChecker 

func NewPodChecker() *PodChecker

func (*PodChecker) Check 

func (c *PodChecker) Check(canary canaryv1.Canary, extConfig external.Check) *pkg.CheckResult

func (*PodChecker) Cleanup 

func (c *PodChecker) Cleanup(podCheck canaryv1.PodCheck) error

func (*PodChecker) Run 

func (c *PodChecker) Run(canary canaryv1.Canary) []*pkg.CheckResult

Run: Check every entry from config according to Checker interface Returns check result and metrics

func (*PodChecker) Type 

func (c *PodChecker) Type() string

Type: returns checker type

func (*PodChecker) WaitForPod 

func (c *PodChecker) WaitForPod(ns, name string, timeout time.Duration, phases ...v1.PodPhase) (*v1.Pod, error)

WaitForPod waits for a pod to be in the specified phase, or returns an error if the timeout is exceeded

type PostgresChecker 

type PostgresChecker struct{}

func (*PostgresChecker) Check 

func (c *PostgresChecker) Check(canary v1.Canary, extConfig external.Check) *pkg.CheckResult

func (*PostgresChecker) Run 

func (c *PostgresChecker) Run(canary v1.Canary) []*pkg.CheckResult

Run: Check every entry from config according to Checker interface Returns check result and metrics

func (*PostgresChecker) Type 

func (c *PostgresChecker) Type() string

Type: returns checker type

type PrometheusChecker added in v0.35.0 

type PrometheusChecker struct{}

func (*PrometheusChecker) Check added in v0.35.0 

func (c *PrometheusChecker) Check(canary v1.Canary, extConfig external.Check) *pkg.CheckResult

func (*PrometheusChecker) Run added in v0.35.0 

func (c *PrometheusChecker) Run(canary v1.Canary) []*pkg.CheckResult

func (*PrometheusChecker) Type added in v0.35.0 

func (c *PrometheusChecker) Type() string

type RedisChecker added in v0.18.0 

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

func (*RedisChecker) Check added in v0.18.0 

func (c *RedisChecker) Check(canary v1.Canary, extConfig external.Check) *pkg.CheckResult

func (*RedisChecker) Run added in v0.18.0 

func (c *RedisChecker) Run(canary v1.Canary) []*pkg.CheckResult

Run: Check every entry from config according to Checker interface Returns check result and metrics

func (*RedisChecker) SetClient added in v0.30.0 

func (c *RedisChecker) SetClient(client *kommons.Client)

func (*RedisChecker) Type added in v0.18.0 

func (c *RedisChecker) Type() string

Type: returns checker type

type ResticChecker added in v0.19.0 

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

func (*ResticChecker) Check added in v0.19.0 

func (c *ResticChecker) Check(canary v1.Canary, extConfig external.Check) *pkg.CheckResult

func (*ResticChecker) Run added in v0.19.0 

func (c *ResticChecker) Run(canary v1.Canary) []*pkg.CheckResult

func (*ResticChecker) SetClient added in v0.30.0 

func (c *ResticChecker) SetClient(client *kommons.Client)

func (*ResticChecker) Type added in v0.19.0 

func (c *ResticChecker) Type() string

type ResultWriter 

type ResultWriter struct{}

type S3BucketChecker 

type S3BucketChecker struct {
}

func (*S3BucketChecker) Check 

func (c *S3BucketChecker) Check(canary v1.Canary, extConfig external.Check) *pkg.CheckResult

func (*S3BucketChecker) Run 

func (c *S3BucketChecker) Run(canary v1.Canary) []*pkg.CheckResult

Run: Check every entry from config according to Checker interface Returns check result and metrics

func (*S3BucketChecker) Type 

func (c *S3BucketChecker) Type() string

Type: returns checker type

type S3Checker 

type S3Checker struct{}

func (*S3Checker) Check 

func (c *S3Checker) Check(canary v1.Canary, extConfig external.Check) *pkg.CheckResult

func (*S3Checker) Run 

func (c *S3Checker) Run(canary v1.Canary) []*pkg.CheckResult

Run: Check every entry from config according to Checker interface Returns check result and metrics

func (*S3Checker) Type 

func (c *S3Checker) Type() string

Type: returns checker type

type SetsClient added in v0.17.0 

type SetsClient interface {
	SetClient(client *kommons.Client)
}

type SmbChecker added in v0.21.0 

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

func (*SmbChecker) Check added in v0.21.0 

func (c *SmbChecker) Check(canary v1.Canary, extConfig external.Check) *pkg.CheckResult

func (SmbChecker) GetClient added in v0.30.0 

func (c SmbChecker) GetClient() *kommons.Client

func (*SmbChecker) Run added in v0.21.0 

func (c *SmbChecker) Run(canary v1.Canary) []*pkg.CheckResult

func (*SmbChecker) SetClient added in v0.30.0 

func (c *SmbChecker) SetClient(client *kommons.Client)

func (*SmbChecker) Type added in v0.21.0 

func (c *SmbChecker) Type() string

type SmbStatus added in v0.21.0 

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

type TCPChecker added in v0.11.4 

type TCPChecker struct{}

TCPChecker checks if the given port is open on the given host

func NewTCPChecker added in v0.11.4 

func NewTCPChecker() *TCPChecker

NewTCPChecker creates and returns a pointer to a TCPChecker

func (*TCPChecker) Check added in v0.11.4 

func (t *TCPChecker) Check(canary v1.Canary, extConfig external.Check) *pkg.CheckResult

Check performs a single tcp check, returning a checkResult

func (*TCPChecker) Run added in v0.11.4 

func (t *TCPChecker) Run(canary v1.Canary) []*pkg.CheckResult

Run executes tcp checks for the given config, returning results

func (*TCPChecker) Type added in v0.11.4 

func (t *TCPChecker) Type() string

Type returns the type

type Timer 

type Timer struct {
	Start time.Time
}

func NewTimer 

func NewTimer() Timer

func (Timer) Duration added in v0.33.1 

func (t Timer) Duration() *time.Duration

func (Timer) Elapsed 

func (t Timer) Elapsed() float64

func (Timer) Millis 

func (t Timer) Millis() int64

func (Timer) String 

func (t Timer) String() string

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.