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()

Variables

var CanaryConfigFiles []string

var CanaryScheduler = cron.New()

var DataFile string

var Executor bool

var FuncScheduler = cron.New()

var Kommons *kommons.Client

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
	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()