canary

Documentation

Index

• Variables
• func CleanupMetricsGauges()
• func DeleteCanaryJob(id string)
• func ReconcileDeletedCanaryChecks()
• func ScanCanaryConfigs()
• func ScheduleFunc(schedule string, fn func()) (interface{}, error)
• func StartScanCanaryConfigs(dataFile string, configFiles []string)
• func SyncCanaryJob(dbCanary pkg.Canary) error
• func SyncCanaryJobs()
• type CanaryJob
  • func (job CanaryJob) GetNamespacedName() types.NamespacedName
  • func (job *CanaryJob) NewContext() *context.Context
  • func (job CanaryJob) Run()
• type CanaryStatusPayload

Variables

var CanaryConfigFiles []string

var CanaryScheduler = cron.New()

var CanaryStatusChannel chan CanaryStatusPayload

var DataFile string

var Executor bool

var FuncScheduler = cron.New()

var Kommons *kommons.Client

var Kubernetes kubernetes.Interface

var LogPass, LogFail bool

Functions

func CleanupMetricsGauges

func CleanupMetricsGauges()

CleanupMetricsGauges removes gauges for checks that no longer exist.

func DeleteCanaryJob

func DeleteCanaryJob(id string)

func ReconcileDeletedCanaryChecks

func ReconcileDeletedCanaryChecks()

func ScanCanaryConfigs

func ScanCanaryConfigs()

func ScheduleFunc

func ScheduleFunc(schedule string, fn func()) (interface{}, error)

func StartScanCanaryConfigs

func StartScanCanaryConfigs(dataFile string, configFiles []string)

func SyncCanaryJob

func SyncCanaryJob(dbCanary pkg.Canary) error

TODO: Refactor to use database object instead of kubernetes

func SyncCanaryJobs

func SyncCanaryJobs()

Types

type CanaryJob

type CanaryJob struct {
	*kommons.Client
	Kubernetes kubernetes.Interface
	Canary     v1.Canary
	DBCanary   pkg.Canary
	LogPass    bool
	LogFail    bool
}

func (CanaryJob) GetNamespacedName

func (job CanaryJob) GetNamespacedName() types.NamespacedName

func (*CanaryJob) NewContext

func (job *CanaryJob) NewContext() *context.Context

func (CanaryJob) Run

func (job CanaryJob) Run()

type CanaryStatusPayload

type CanaryStatusPayload struct {
	Pass                 bool
	CheckStatus          map[string]*v1.CheckStatus
	FailEvents           []string
	LastTransitionedTime *metav1.Time
	Message              string
	ErrorMessage         string
	Uptime               string
	Latency              string
	NamespacedName       types.NamespacedName
}