controllers

Documentation

Index

• Constants
• type EnqueueForHelmTrigger
  • func (h *EnqueueForHelmTrigger) Create(e event.CreateEvent, q workqueue.RateLimitingInterface)
  • func (h *EnqueueForHelmTrigger) Delete(e event.DeleteEvent, q workqueue.RateLimitingInterface)
  • func (h *EnqueueForHelmTrigger) Generic(e event.GenericEvent, q workqueue.RateLimitingInterface)
  • func (h *EnqueueForHelmTrigger) Update(e event.UpdateEvent, q workqueue.RateLimitingInterface)
• type ErrorList
  • func (e *ErrorList) Append(err error)
  • func (e *ErrorList) Error() error
  • func (e *ErrorList) HasError() bool
• type HelmReleaseMeta
  • func ParseHelmReleaseSecret(secret *v1.Secret) (release *HelmReleaseMeta, ok bool)
  • func (hrm *HelmReleaseMeta) LabelValue() string
• type IsHelmRelease
  • func (h IsHelmRelease) Create(e event.CreateEvent) bool
  • func (h IsHelmRelease) Delete(e event.DeleteEvent) bool
  • func (h IsHelmRelease) Generic(e event.GenericEvent) bool
  • func (h IsHelmRelease) Update(e event.UpdateEvent) bool
• type TestReconciler
  • func (r *TestReconciler) Reconcile(ctx context.Context, req ctrl.Request) (res ctrl.Result, err error)
  • func (r *TestReconciler) SetupWithManager(mgr ctrl.Manager) error
• type TestRunReconciler
  • func (r *TestRunReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *TestRunReconciler) SetupWithManager(mgr ctrl.Manager) error
• type TestSuiteReconciler
  • func (r *TestSuiteReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *TestSuiteReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

const (
	PodCreatedCondition     = "PodCreated"
	TestCompletedCondition  = "TestCompleted"
	TestStartingEvent       = "PodCreated"
	TestPassedEvent         = "TestPassed"
	TestFailedEvent         = "TestFailed"
	TestErrorEvent          = "ErrorCreatingPod"
	TestControllerFinalizer = konfirm.GroupName + "/test-controller"
)

const (
	TestRunControllerFinalizer = konfirm.GroupName + "/testrun-controller"
	TestRunStartedCondition    = "RunStarted"
	TestRunCompletedCondition  = "RunCompleted"
)

const (
	TestSuiteControllerFinalizer       = konfirm.GroupName + "/testsuite-controller"
	TestSuiteScheduleAnnotation        = konfirm.GroupName + "/active-schedule"
	TestSuiteLastHelmReleaseAnnotation = konfirm.GroupName + "/last-helm-release"
	TestSuiteHelmTriggerLabel          = konfirm.GroupName + "/helm-trigger"
	TestSuiteNeedsRunCondition         = "NeedsRun"
	TestSuiteRunStartedCondition       = "RunStarted"
	TestSuiteHasScheduleCondition      = "HasSchedule"
	TestSuiteErrorCondition            = "HasError"
)

const (
	HelmSecretType = "helm.sh/release.v1"
)

Types

type EnqueueForHelmTrigger

type EnqueueForHelmTrigger struct {
	client.Client
}

EnqueueForHelmTrigger is a handler.Handler implementation for enqueuing TestSuites with a Helm trigger when a matching Helm Release is deployed. It only responds to Create and Update events.

func (*EnqueueForHelmTrigger) Create

func (h *EnqueueForHelmTrigger) Create(e event.CreateEvent, q workqueue.RateLimitingInterface)

func (*EnqueueForHelmTrigger) Delete

func (h *EnqueueForHelmTrigger) Delete(e event.DeleteEvent, q workqueue.RateLimitingInterface)

func (*EnqueueForHelmTrigger) Generic

func (h *EnqueueForHelmTrigger) Generic(e event.GenericEvent, q workqueue.RateLimitingInterface)

func (*EnqueueForHelmTrigger) Update

func (h *EnqueueForHelmTrigger) Update(e event.UpdateEvent, q workqueue.RateLimitingInterface)

type ErrorList

type ErrorList struct {
	// contains filtered or unexported fields
}

func (*ErrorList) Append

func (e *ErrorList) Append(err error)

func (*ErrorList) Error

func (e *ErrorList) Error() error

func (*ErrorList) HasError

func (e *ErrorList) HasError() bool

type HelmReleaseMeta

type HelmReleaseMeta struct {
	types.NamespacedName
	Version       int
	VersionString string
	Status        string
}

HelmReleaseMeta describes a Helm Release.

func ParseHelmReleaseSecret

func ParseHelmReleaseSecret(secret *v1.Secret) (release *HelmReleaseMeta, ok bool)

ParseHelmReleaseSecret generates HelmReleaseMeta based on the provided v1.Secret. If the provided Secret does not appear to be a valid Helm release, the return boolean will be false; otherwise it will be true.

func (*HelmReleaseMeta) LabelValue

func (hrm *HelmReleaseMeta) LabelValue() string

type IsHelmRelease

type IsHelmRelease struct{}

IsHelmRelease is a predicate.Predicate implementation that matches only Helm Release Secrets.

func (IsHelmRelease) Create

func (h IsHelmRelease) Create(e event.CreateEvent) bool

func (IsHelmRelease) Delete

func (h IsHelmRelease) Delete(e event.DeleteEvent) bool

func (IsHelmRelease) Generic

func (h IsHelmRelease) Generic(e event.GenericEvent) bool

func (IsHelmRelease) Update

func (h IsHelmRelease) Update(e event.UpdateEvent) bool

type TestReconciler

type TestReconciler struct {
	client.Client
	Scheme          *runtime.Scheme
	Recorder        record.EventRecorder
	ErrRequeueDelay time.Duration
}

TestReconciler reconciles a Test object

func (*TestReconciler) Reconcile

func (r *TestReconciler) Reconcile(ctx context.Context, req ctrl.Request) (res ctrl.Result, err error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.11.2/pkg/reconcile

func (*TestReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type TestRunReconciler

type TestRunReconciler struct {
	client.Client
	Scheme          *runtime.Scheme
	Recorder        record.EventRecorder
	ErrRequeueDelay time.Duration
}

TestRunReconciler reconciles a TestRun object

func (*TestRunReconciler) Reconcile

func (r *TestRunReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.11.2/pkg/reconcile

func (*TestRunReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type TestSuiteReconciler

type TestSuiteReconciler struct {
	client.Client
	Scheme          *runtime.Scheme
	Recorder        record.EventRecorder
	ErrRequeueDelay time.Duration
	CronParser      func(string) (cron.Schedule, error)
	Clock           clock.PassiveClock
}

TestSuiteReconciler reconciles a TestSuite object

func (*TestSuiteReconciler) Reconcile

func (r *TestSuiteReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.11.2/pkg/reconcile

func (*TestSuiteReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.