instance

Documentation

Index

• func ParamsMap(instance *kudov1beta1.Instance, operatorVersion *kudov1beta1.OperatorVersion) (map[string]interface{}, error)
• func PipesMap(planName string, plan *kudov1beta1.Plan, tasks []kudov1beta1.Task, ...) (map[string]string, error)
• type InClusterResolver
  • func (r InClusterResolver) Resolve(name string, appVersion string, operatorVersion string) (*packages.Package, error)
• type Reconciler
  • func (r *Reconciler) Reconcile(request ctrl.Request) (ctrl.Result, error)
  • func (r *Reconciler) SetupWithManager(mgr ctrl.Manager) error

Functions

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 *kudov1beta1.Plan, tasks []kudov1beta1.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 InClusterResolver

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

InClusterResolver resolves packages that are already installed in the cluster. Note, that unlike other resolvers, the resulting 'packages.Package' struct does not contain package 'packages.Files' (we don't have the original files) and doesn't have an Instance resource because multiple Instances of the same Operator/OperatorVersion can exist

func (InClusterResolver) Resolve

func (r InClusterResolver) Resolve(name string, appVersion string, operatorVersion string) (*packages.Package, error)

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
+-------------------------------+
| Execute the scheduled plan    |
| if exists                     |
+-------------------------------+
               |
               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