controllers

Documentation

Index

• Constants
• Variables
• func ScanCanaryConfigs()
• func ScheduleSystemFunc(schedule string, fn func()) (interface{}, error)
• func Start()
• func StartScanCanaryConfigs(dataFile string, configFiles []string)
• func SyncCanaryJobs()
• type CanaryJob
  • func (job CanaryJob) GetNamespacedName() types.NamespacedName
  • func (job *CanaryJob) NewContext() *context.Context
  • func (job CanaryJob) Run()
• type CanaryReconciler
  • func (r *CanaryReconciler) Patch(canary *v1.Canary)
  • func (r *CanaryReconciler) Reconcile(ctx gocontext.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *CanaryReconciler) Report(ctx *context.Context, canary v1.Canary, results []*pkg.CheckResult)
  • func (r *CanaryReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

const FinalizerName = "canary.canaries.flanksource.com"

Variables

var CanaryConfigFiles []string

var DataFile string

var Kommons *kommons.Client

var Scheduler = cron.New()

var SystemScheduler = cron.New()

Functions

func ScanCanaryConfigs

func ScanCanaryConfigs()

func ScheduleSystemFunc

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

func Start

func Start()

func StartScanCanaryConfigs

func StartScanCanaryConfigs(dataFile string, configFiles []string)

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

type CanaryReconciler

type CanaryReconciler struct {
	IncludeCheck      string
	IncludeNamespaces []string
	LogPass, LogFail  bool
	client.Client
	Kubernetes kubernetes.Interface
	Kommons    *kommons.Client
	Log        logr.Logger
	Scheme     *runtime.Scheme
	Events     record.EventRecorder
	Cron       *cron.Cron
	RunnerName string
	Done       chan *pkg.CheckResult
}

CanaryReconciler reconciles a Canary object

func (*CanaryReconciler) Patch

func (r *CanaryReconciler) Patch(canary *v1.Canary)

func (*CanaryReconciler) Reconcile

func (r *CanaryReconciler) Reconcile(ctx gocontext.Context, req ctrl.Request) (ctrl.Result, error)

+kubebuilder:rbac:groups=canaries.flanksource.com,resources=canaries,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=canaries.flanksource.com,resources=canaries/status,verbs=get;update;patch +kubebuilder:rbac:groups="",resources=pods/exec,verbs=* +kubebuilder:rbac:groups="",resources=pods/logs,verbs=*

func (*CanaryReconciler) Report

func (r *CanaryReconciler) Report(ctx *context.Context, canary v1.Canary, results []*pkg.CheckResult)

func (*CanaryReconciler) SetupWithManager

func (r *CanaryReconciler) SetupWithManager(mgr ctrl.Manager) error