pkg

Documentation

Index

• func ApplyTemplates(config v1.CanarySpec) v1.CanarySpec
• func GetClusterName(config *rest.Config) string
• func GetKubeconfig() string
• func NewK8sClient() (*kubernetes.Clientset, error)
• func ParseConfig(configfile string) v1.CanarySpec
• type Check
  • func (c Check) GetDescription() string
  • func (c Check) ToString() string
• type CheckResult
  • func (c CheckResult) GetDescription() string
  • func (c CheckResult) String() string
• type CheckStatus
• type Checker
• type Checks
  • func (c Checks) Len() int
  • func (c Checks) Less(i, j int) bool
  • func (c Checks) Swap(i, j int)
• type Config
• type Endpoint
  • func (e Endpoint) GetEndpoint() string
• type JSONTime
  • func (t JSONTime) MarshalJSON() ([]byte, error)
  • func (t *JSONTime) UnmarshalJSON(b []byte) error
• type Metric
  • func (m Metric) String() string
• type MetricType
• type StructTemplater
  • func (w StructTemplater) Struct(reflect.Value) error
  • func (w StructTemplater) StructField(f reflect.StructField, v reflect.Value) error
  • func (w StructTemplater) Template(val string) string
• type URL

Functions

func ApplyTemplates

func ApplyTemplates(config v1.CanarySpec) v1.CanarySpec

func GetClusterName

func GetClusterName(config *rest.Config) string

func GetKubeconfig

func GetKubeconfig() string

func NewK8sClient

func NewK8sClient() (*kubernetes.Clientset, error)

func ParseConfig

func ParseConfig(configfile string) v1.CanarySpec

ParseConfig : Read config file

Types

type Check

type Check struct {
	Key         string        `json:"key"`
	Type        string        `json:"type"`
	Name        string        `json:"name"`
	CanaryName  string        `json:"canaryName"`
	Description string        `json:"description"`
	Endpoint    string        `json:"endpoint"`
	Uptime      string        `json:"uptime"`
	Latency     string        `json:"latency"`
	Statuses    []CheckStatus `json:"checkStatuses" mapstructure:"-"`
	CheckCanary *v1.Canary    `json:"-"`
}

func (Check) GetDescription

func (c Check) GetDescription() string

func (Check) ToString

func (c Check) ToString() string

type CheckResult

type CheckResult struct {
	Pass        bool
	Invalid     bool
	Duration    int64
	Description string
	Message     string
	Metrics     []Metric
	// Check is the configuration
	Check external.Check
}

func (CheckResult) GetDescription

func (c CheckResult) GetDescription() string

func (CheckResult) String

func (c CheckResult) String() string

type CheckStatus

type CheckStatus struct {
	Status   bool     `json:"status"`
	Invalid  bool     `json:"invalid"`
	Time     JSONTime `json:"time"`
	Duration int      `json:"duration"`
	Message  string   `json:"message"`
}

type Checker

type Checker interface {
	CheckArgs(args map[string]interface{}) *CheckResult
}

type Checks

type Checks []Check

func (Checks) Len

func (c Checks) Len() int

func (Checks) Less

func (c Checks) Less(i, j int) bool

func (Checks) Swap

func (c Checks) Swap(i, j int)

type Config

type Config struct {
	HTTP           []v1.HTTPCheck           `yaml:"http,omitempty" json:"http,omitempty"`
	DNS            []v1.DNSCheck            `yaml:"dns,omitempty" json:"dns,omitempty"`
	ContainerdPull []v1.ContainerdPullCheck `yaml:"containerdPull,omitempty" json:"containerdPull,omitempty"`
	ContainerdPush []v1.ContainerdPushCheck `yaml:"containerdPush,omitempty" json:"containerdPush,omitempty"`
	DockerPull     []v1.DockerPullCheck     `yaml:"docker,omitempty" json:"docker,omitempty"`
	DockerPush     []v1.DockerPushCheck     `yaml:"dockerPush,omitempty" json:"dockerPush,omitempty"`
	S3             []v1.S3Check             `yaml:"s3,omitempty" json:"s3,omitempty"`
	S3Bucket       []v1.S3BucketCheck       `yaml:"s3Bucket,omitempty" json:"s3Bucket,omitempty"`
	TCP            []v1.TCPCheck            `yaml:"tcp,omitempty" json:"tcp,omitempty"`
	Pod            []v1.PodCheck            `yaml:"pod,omitempty" json:"pod,omitempty"`
	LDAP           []v1.LDAPCheck           `yaml:"ldap,omitempty" json:"ldap,omitempty"`
	SSL            []v1.SSLCheck            `yaml:"ssl,omitempty" json:"ssl,omitempty"`
	ICMP           []v1.ICMPCheck           `yaml:"icmp,omitempty" json:"icmp,omitempty"`
	Postgres       []v1.PostgresCheck       `yaml:"postgres,omitempty" json:"postgres,omitempty"`
	Helm           []v1.HelmCheck           `yaml:"helm,omitempty" json:"helm,omitempty"`
	Namespace      []v1.NamespaceCheck      `yaml:"namespace,omitempty" json:"namespace,omitempty"`
	Interval       metav1.Duration          `yaml:"-" json:"interval,omitempty"`
}

type Endpoint

type Endpoint struct {
	String string
}

func (Endpoint) GetEndpoint

func (e Endpoint) GetEndpoint() string

type JSONTime

type JSONTime time.Time

func (JSONTime) MarshalJSON

func (t JSONTime) MarshalJSON() ([]byte, error)

func (*JSONTime) UnmarshalJSON

func (t *JSONTime) UnmarshalJSON(b []byte) error

type Metric

type Metric struct {
	Name   string
	Type   MetricType
	Labels map[string]string
	Value  float64
}

func (Metric) String

func (m Metric) String() string

type MetricType

type MetricType string

type StructTemplater

type StructTemplater struct {
	Values map[string]string
}

func (StructTemplater) Struct

func (w StructTemplater) Struct(reflect.Value) error

this func is required to fulfil the reflectwalk.StructWalker interface

func (StructTemplater) StructField

func (w StructTemplater) StructField(f reflect.StructField, v reflect.Value) error

func (StructTemplater) Template

func (w StructTemplater) Template(val string) string

type URL

type URL struct {
	IP     string
	Port   int
	Host   string
	Scheme string
	Path   string
}

URL information