canary

Documentation

Index

• Variables
• func CleanupMetricsGauges()
• func DeleteCanaryJob(id string)
• func ReconcileCanaryResults()
• 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 CanaryPullResponse
• type CanaryStatusPayload
• type UpstreamPullJob
  • func (t *UpstreamPullJob) Run()
• type UpstreamPushJob
  • func (t *UpstreamPushJob) Run()

Variables

var CanaryConfigFiles []string

var CanaryNamespaces []string

CanaryNamespaces is a list of namespaces whose canary specs should be synced. If empty, all namespaces will be synced

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

var UpstreamConf upstream.UpstreamConfig

Functions

func CleanupMetricsGauges

func CleanupMetricsGauges()

CleanupMetricsGauges removes gauges for checks that no longer exist.

func DeleteCanaryJob

func DeleteCanaryJob(id string)

func ReconcileCanaryResults

func ReconcileCanaryResults()

ReconcileCanaryResults coordinates with upstream and pushes any resource that are missing on the upstream.

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 CanaryPullResponse

type CanaryPullResponse struct {
	Before   time.Time       `json:"before"`
	Canaries []models.Canary `json:"canaries,omitempty"`
}

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
}

type UpstreamPullJob

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

UpstreamPullJob pulls canaries from the upstream

func (*UpstreamPullJob) Run

func (t *UpstreamPullJob) Run()

type UpstreamPushJob

type UpstreamPushJob struct {

	// MaxAge defines how far back we look into the past on startup whe
	// lastRuntime is zero.
	MaxAge time.Duration
	// contains filtered or unexported fields
}

func (*UpstreamPushJob) Run

func (t *UpstreamPushJob) Run()