controllers

Documentation

Overview

Copyright 2020 The Kubernetes authors.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• Constants
• Variables
• func DeleteCanaryJob(canary v1.Canary)
• func DeleteSystemJob(systemTemplate v1.SystemTemplate)
• func ScanCanaryConfigs()
• func ScheduleFunc(schedule string, fn func()) (interface{}, error)
• func Start()
• func StartScanCanaryConfigs(dataFile string, configFiles []string)
• func SyncCanaryJob(canary v1.Canary) error
• func SyncCanaryJobs()
• func SyncSystemJob(systemTemplate v1.SystemTemplate) error
• func SyncSystemsJobs()
• 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
• type SystemJob
  • func (job SystemJob) GetNamespacedName() types.NamespacedName
  • func (job SystemJob) Run()
• type SystemReconciler
  • func (r *SystemReconciler) Patch(systemTemplate *v1.SystemTemplate)
  • func (r *SystemReconciler) Reconcile(ctx gocontext.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *SystemReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

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

const SystemTemplateFinalizerName = "systemTemplate.canaries.flanksource.com"

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

var SystemScheduler = cron.New()

Functions

func DeleteCanaryJob

func DeleteCanaryJob(canary v1.Canary)

func DeleteSystemJob

func DeleteSystemJob(systemTemplate v1.SystemTemplate)

func ScanCanaryConfigs

func ScanCanaryConfigs()

func ScheduleFunc

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

func Start

func Start()

func StartScanCanaryConfigs

func StartScanCanaryConfigs(dataFile string, configFiles []string)

func SyncCanaryJob

func SyncCanaryJob(canary v1.Canary) error

func SyncCanaryJobs

func SyncCanaryJobs()

func SyncSystemJob

func SyncSystemJob(systemTemplate v1.SystemTemplate) error

func SyncSystemsJobs

func SyncSystemsJobs()

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

type SystemJob

type SystemJob struct {
	*kommons.Client
	v1.SystemTemplate
}

func (SystemJob) GetNamespacedName

func (job SystemJob) GetNamespacedName() types.NamespacedName

func (SystemJob) Run

func (job SystemJob) Run()

type SystemReconciler

type SystemReconciler struct {
	client.Client
	Log        logr.Logger
	Scheme     *runtime.Scheme
	Events     record.EventRecorder
	RunnerName string
}

SystemReconciler reconciles a Canary object

func (*SystemReconciler) Patch

func (r *SystemReconciler) Patch(systemTemplate *v1.SystemTemplate)

func (*SystemReconciler) Reconcile

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

+kubebuilder:rbac:groups=canaries.flanksource.com,resources=systemtemplates,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=canaries.flanksource.com,resources=systemtemplates/status,verbs=get;update;patch

func (*SystemReconciler) SetupWithManager

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