aaq_operator

Documentation

Index

• Constants
• func Add(mgr manager.Manager) error
• func SetConfigAsOwner(configMap *corev1.ConfigMap, object metav1.Object) error
• func SetOwnerRuntime(client client.Client, object metav1.Object) error
• type CertManager
  • func NewCertManager(mgr manager.Manager, installNamespace string, additionalNamespaces ...string) (CertManager, error)
• type ReconcileAAQ
  • func (r *ReconcileAAQ) Create() client.Object
  • func (r *ReconcileAAQ) GetAllResources(crObject client.Object) ([]client.Object, error)
  • func (r *ReconcileAAQ) GetDependantResourcesListObjects() []client.ObjectList
  • func (r *ReconcileAAQ) IsCreating(_ client.Object) (bool, error)
  • func (r *ReconcileAAQ) Reconcile(_ context.Context, request reconcile.Request) (reconcile.Result, error)
  • func (r *ReconcileAAQ) SetController(controller controller.Controller)
  • func (r *ReconcileAAQ) Status(cr client.Object) *sdkapi.Status

Constants

const (

	// LastAppliedConfigAnnotation is the annotation that holds the last resource state which we put on resources under our governance
	LastAppliedConfigAnnotation = "operator.aaq.kubevirt.io/lastAppliedConfiguration"
)

Functions

func Add

func Add(mgr manager.Manager) error

Add creates a new AAQ Controller and adds it to the Manager. The Manager will set fields on the Controller and Start it when the Manager is Started.

func SetConfigAsOwner

func SetConfigAsOwner(configMap *corev1.ConfigMap, object metav1.Object) error

SetConfigAsOwner sets the passed in config map as owner of the object

func SetOwnerRuntime

func SetOwnerRuntime(client client.Client, object metav1.Object) error

SetOwnerRuntime makes the current "active" AAQ CR the owner of the object using runtime lib client

Types

type CertManager

type CertManager interface {
	Sync(certs []aaqcerts.CertificateDefinition) error
}

CertManager is the client interface to the certificate manager/refresher

func NewCertManager

func NewCertManager(mgr manager.Manager, installNamespace string, additionalNamespaces ...string) (CertManager, error)

NewCertManager creates a new certificate manager/refresher

type ReconcileAAQ

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

ReconcileAAQ reconciles a AAQ object

func (*ReconcileAAQ) Create

func (r *ReconcileAAQ) Create() client.Object

Create creates new AAQ resource

func (*ReconcileAAQ) GetAllResources

func (r *ReconcileAAQ) GetAllResources(crObject client.Object) ([]client.Object, error)

GetAllResources provides slice of resources AAQ depends on

func (*ReconcileAAQ) GetDependantResourcesListObjects

func (r *ReconcileAAQ) GetDependantResourcesListObjects() []client.ObjectList

GetDependantResourcesListObjects provides slice of List resources corresponding to AAQ-dependant resource types

func (*ReconcileAAQ) IsCreating

func (r *ReconcileAAQ) IsCreating(_ client.Object) (bool, error)

IsCreating checks whether operator config is missing (which means it is create-type reconciliation)

func (*ReconcileAAQ) Reconcile

func (r *ReconcileAAQ) Reconcile(_ context.Context, request reconcile.Request) (reconcile.Result, error)

Reconcile reads that state of the cluster for a AAQ object and makes changes based on the state read and what is in the AAQ.Spec Note: The Controller will requeue the request to be processed again if the returned error is non-nil or Result.Requeue is true, otherwise upon completion it will remove the work from the queue.

func (*ReconcileAAQ) SetController

func (r *ReconcileAAQ) SetController(controller controller.Controller)

SetController sets the controller dependency

func (*ReconcileAAQ) Status

func (r *ReconcileAAQ) Status(cr client.Object) *sdkapi.Status

Status provides AAQ status sub-resource