pkg

Documentation

Index

• Variables
• func ApplyTemplates(config v1.CanarySpec) v1.CanarySpec
• func GetClusterName(config *rest.Config) string
• func GetKubeconfig() string
• func LoadLabels(path string) map[string]string
• func NewK8sClient() (*kubernetes.Clientset, error)
• func NewKommonsClient() (*kommons.Client, error)
• func ParseConfig(configfile string) v1.CanarySpec
• type Check
  • func (c Check) GetDescription() string
  • func (c Check) GetName() string
  • func (c Check) GetNamespace() string
  • func (c Check) ID() 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 URL

Variables

var RunnerLabels map[string]string = make(map[string]string)

Functions

func ApplyTemplates

func ApplyTemplates(config v1.CanarySpec) v1.CanarySpec

func GetClusterName

func GetClusterName(config *rest.Config) string

func GetKubeconfig

func GetKubeconfig() string

func LoadLabels

func LoadLabels(path string) map[string]string

func NewK8sClient

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

func NewKommonsClient

func NewKommonsClient() (*kommons.Client, 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"`
	Namespace    string            `json:"namespace"`
	Labels       map[string]string `json:"labels"`
	RunnerLabels map[string]string `json:"runnerLabels"`
	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:"-"`
	Interval     uint64            `json:"interval"`
	Schedule     string            `json:"schedule"`
	Owner        string            `json:"owner"`
	Severity     string            `json:"severity"`
	IconURL      string            `json:"iconURL"`
	DisplayType  string            `json:"displayType"`
	CheckCanary  *v1.Canary        `json:"-"`
}

func (Check) GetDescription

func (c Check) GetDescription() string

func (Check) GetName

func (c Check) GetName() string

func (Check) GetNamespace

func (c Check) GetNamespace() string

func (Check) ID

func (c Check) ID() string

func (Check) ToString

func (c Check) ToString() string

type CheckResult

type CheckResult struct {
	Pass        bool
	Invalid     bool
	Duration    int64
	Description string
	DisplayType 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"`
	ICMP           []v1.ICMPCheck           `yaml:"icmp,omitempty" json:"icmp,omitempty"`
	Postgres       []v1.PostgresCheck       `yaml:"postgres,omitempty" json:"postgres,omitempty"`
	Mssql          []v1.MssqlCheck          `yaml:"mssql,omitempty" json:"mssql,omitempty"`
	Redis          []v1.RedisCheck          `yaml:"redis,omitempty" json:"redis,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 URL

type URL struct {
	IP       string
	Port     int
	Host     string
	Scheme   string
	Path     string
	Username string
	Password string
	Method   string
	Headers  map[string]string
	Body     string
}

URL information