canary

Documentation

Index

• Variables
• func DeleteCanaryJob(canary v1.Canary)
• func ScanCanaryConfigs()
• func ScheduleFunc(schedule string, fn func()) (interface{}, error)
• func StartScanCanaryConfigs(dataFile string, configFiles []string)
• func SyncCanaryJob(canary v1.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 DeleteCanaryJob

func DeleteCanaryJob(canary v1.Canary)

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(canary v1.Canary) error

func SyncCanaryJobs

func SyncCanaryJobs()

Types

type CanaryJob

type CanaryJob struct {
	*kommons.Client
	Kubernetes kubernetes.Interface
	v1.Canary
	// model   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
}