instance

Documentation

Index

• func GetOperatorVersion(instance *kudov1beta1.Instance, c client.Reader) (ov *kudov1beta1.OperatorVersion, err error)
• func ParamsMap(instance *kudov1beta1.Instance, operatorVersion *kudov1beta1.OperatorVersion) (map[string]interface{}, error)
• func PipesMap(planName string, plan *v1beta1.Plan, tasks []v1beta1.Task, ...) (map[string]string, error)
• type Reconciler
  • func (r *Reconciler) Reconcile(request ctrl.Request) (ctrl.Result, error)
  • func (r *Reconciler) SetupWithManager(mgr ctrl.Manager) error

Functions

func GetOperatorVersion

func GetOperatorVersion(instance *kudov1beta1.Instance, c client.Reader) (ov *kudov1beta1.OperatorVersion, err error)

GetOperatorVersion retrieves OperatorVersion belonging to the given instance

func ParamsMap

func ParamsMap(instance *kudov1beta1.Instance, operatorVersion *kudov1beta1.OperatorVersion) (map[string]interface{}, error)

ParamsMap generates {{ Params.* }} map of keys and values which is later used during template rendering.

func PipesMap

func PipesMap(planName string, plan *v1beta1.Plan, tasks []v1beta1.Task, emeta *engine.Metadata) (map[string]string, error)

PipesMap generates {{ Pipes.* }} map of keys and values which is later used during template rendering.

Types

type Reconciler

type Reconciler struct {
	client.Client
	Discovery discovery.CachedDiscoveryInterface
	Config    *rest.Config
	Recorder  record.EventRecorder
	Scheme    *runtime.Scheme
}

Reconciler reconciles an Instance object.

func (*Reconciler) Reconcile

func (r *Reconciler) Reconcile(request ctrl.Request) (ctrl.Result, error)

Reconcile is the main controller method that gets called every time something about the instance changes

+-------------------------------+
| Query state of Instance       |
| and OperatorVersion           |
+-------------------------------+
               |
               v
+-------------------------------+
| Update finalizers if cleanup  |
| plan exists                   |
+-------------------------------+
               |
               v
+-------------------------------+
| Start new plan if required    |
| and none is running           |
+-------------------------------+
               |
               v
+-------------------------------+
| If there is plan in progress, |
| proceed with the execution    |
+-------------------------------+
               |
               v
+-------------------------------+
| Update instance with new      |
| state of the execution        |
+-------------------------------+

Automatically generate RBAC rules to allow the Controller to read and write Deployments

func (*Reconciler) SetupWithManager

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

SetupWithManager registers this reconciler with the controller manager