canary

Documentation

Index

• Constants
• Variables
• func CleanupMetricsGauges()
• func DeleteCanaryJob(id string)
• func ReconcileChecks()
• func ScanCanaryConfigs()
• func ScheduleFunc(schedule string, fn func()) (interface{}, error)
• func StartScanCanaryConfigs(dataFile string, configFiles []string)
• func StartUpstreamEventQueueConsumer(ctx *context.Context) error
• func SyncCanaryJob(ctx context.Context, dbCanary pkg.Canary) error
• func SyncCanaryJobs(ctx dutyjob.JobRuntime) error
• func SyncCheckStatuses()
• type CanaryJob
  • func (j CanaryJob) GetNamespacedName() types.NamespacedName
  • func (j CanaryJob) Run(ctx dutyjob.JobRuntime) error
• type CanaryPullResponse
• type CanaryStatusPayload
• type UpstreamPullJob
  • func (t *UpstreamPullJob) Run()

Constants

const (
	EventPushQueueCreate = "push_queue.create"
)

Variables

var (
	ReconcilePageSize int

	// Only sync data created/updated in the last ReconcileMaxAge duration
	ReconcileMaxAge time.Duration

	// UpstreamConf is the global configuration for upstream
	UpstreamConf upstream.UpstreamConfig
)

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

var MinimumTimeBetweenCanaryRuns = 10 * time.Second

Functions

func CleanupMetricsGauges

func CleanupMetricsGauges()

CleanupMetricsGauges removes gauges for checks that no longer exist.

func DeleteCanaryJob

func DeleteCanaryJob(id string)

func ReconcileChecks

func ReconcileChecks()

ReconcileChecks 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 StartUpstreamEventQueueConsumer

func StartUpstreamEventQueueConsumer(ctx *context.Context) error

func SyncCanaryJob

func SyncCanaryJob(ctx context.Context, dbCanary pkg.Canary) error

TODO: Refactor to use database object instead of kubernetes

func SyncCanaryJobs

func SyncCanaryJobs(ctx dutyjob.JobRuntime) error

func SyncCheckStatuses

func SyncCheckStatuses()

Types

type CanaryJob

type CanaryJob struct {
	Canary   v1.Canary
	DBCanary pkg.Canary
	LogPass  bool
	LogFail  bool
}

func (CanaryJob) GetNamespacedName

func (j CanaryJob) GetNamespacedName() types.NamespacedName

func (CanaryJob) Run

func (j CanaryJob) Run(ctx dutyjob.JobRuntime) error

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 {
	Client *upstream.UpstreamClient
	// contains filtered or unexported fields
}

UpstreamPullJob pulls canaries from the upstream

func (*UpstreamPullJob) Run

func (t *UpstreamPullJob) Run()