controllers

Documentation

Index

• Constants
• type CanaryJob
  • func (c CanaryJob) GetNamespacedName() types.NamespacedName
  • func (c CanaryJob) LoadSecrets() (v1.Canary, error)
  • func (c CanaryJob) Run()
• type CanaryReconciler
  • func (r *CanaryReconciler) Patch(canary *v1.Canary)
  • func (r *CanaryReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *CanaryReconciler) Report(key types.NamespacedName, results []*pkg.CheckResult)
  • func (r *CanaryReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

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

Types

type CanaryJob

type CanaryJob struct {
	Client CanaryReconciler
	Check  v1.Canary
	logr.Logger
}

func (CanaryJob) GetNamespacedName

func (c CanaryJob) GetNamespacedName() types.NamespacedName

func (CanaryJob) LoadSecrets

func (c CanaryJob) LoadSecrets() (v1.Canary, error)

func (CanaryJob) Run

func (c CanaryJob) Run()

type CanaryReconciler

type CanaryReconciler struct {
	IncludeCheck      string
	IncludeNamespaces []string
	client.Client
	Kubernetes kubernetes.Interface
	Kommons    *kommons.Client
	Log        logr.Logger
	Scheme     *runtime.Scheme
	Events     record.EventRecorder
	Cron       *cron.Cron
	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 context.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(key types.NamespacedName, results []*pkg.CheckResult)

func (*CanaryReconciler) SetupWithManager

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