apply

Documentation

Index

• Constants
• func DeleteAll(kv *v1.KubeVirt, stores util.Stores, clientset kubecli.KubevirtClient, ...) error
• func ExpectedMutatingWebhookConfigurationGeneration(required *admissionregistrationv1beta1.MutatingWebhookConfiguration, ...) int64
• func ExpectedValidatingWebhookConfigurationGeneration(required *admissionregistrationv1beta1.ValidatingWebhookConfiguration, ...) int64
• func SetMutatingWebhookConfigurationGeneration(generations *[]operatorsv1.GenerationStatus, ...)
• func SetValidatingWebhookConfigurationGeneration(generations *[]operatorsv1.GenerationStatus, ...)
• type Customizer
  • func NewCustomizer(customizations v1.CustomizeComponents) (*Customizer, error)
  • func (c *Customizer) Apply(targetStrategy *install.Strategy) error
  • func (c *Customizer) GenericApplyPatches(objects interface{}) error
  • func (c *Customizer) GetPatches() []v1.CustomizeComponentsPatch
  • func (c *Customizer) GetPatchesForResource(resourceType, name string) []v1.CustomizeComponentsPatch
  • func (c *Customizer) Hash() string
• type Reconciler
  • func NewReconciler(kv *v1.KubeVirt, targetStrategy *install.Strategy, stores util.Stores, ...) (*Reconciler, error)
  • func (r *Reconciler) Sync(queue workqueue.RateLimitingInterface) (bool, error)

Constants

const Duration1d = time.Hour * 24

const Duration7d = time.Hour * 24 * 7

Functions

func DeleteAll

func DeleteAll(kv *v1.KubeVirt,
	stores util.Stores,
	clientset kubecli.KubevirtClient,
	aggregatorclient install.APIServiceInterface,
	expectations *util.Expectations) error

func ExpectedMutatingWebhookConfigurationGeneration

func ExpectedMutatingWebhookConfigurationGeneration(required *admissionregistrationv1beta1.MutatingWebhookConfiguration, previousGenerations []operatorsv1.GenerationStatus) int64

func ExpectedValidatingWebhookConfigurationGeneration

func ExpectedValidatingWebhookConfigurationGeneration(required *admissionregistrationv1beta1.ValidatingWebhookConfiguration, previousGenerations []operatorsv1.GenerationStatus) int64

func SetMutatingWebhookConfigurationGeneration

func SetMutatingWebhookConfigurationGeneration(generations *[]operatorsv1.GenerationStatus, actual *admissionregistrationv1beta1.MutatingWebhookConfiguration)

func SetValidatingWebhookConfigurationGeneration

func SetValidatingWebhookConfigurationGeneration(generations *[]operatorsv1.GenerationStatus, actual *admissionregistrationv1beta1.ValidatingWebhookConfiguration)

Types

type Customizer

type Customizer struct {
	Patches []v1.CustomizeComponentsPatch
	// contains filtered or unexported fields
}

func NewCustomizer

func NewCustomizer(customizations v1.CustomizeComponents) (*Customizer, error)

func (*Customizer) Apply

func (c *Customizer) Apply(targetStrategy *install.Strategy) error

func (*Customizer) GenericApplyPatches

func (c *Customizer) GenericApplyPatches(objects interface{}) error

func (*Customizer) GetPatches

func (c *Customizer) GetPatches() []v1.CustomizeComponentsPatch

func (*Customizer) GetPatchesForResource

func (c *Customizer) GetPatchesForResource(resourceType, name string) []v1.CustomizeComponentsPatch

func (*Customizer) Hash

func (c *Customizer) Hash() string

type Reconciler

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

func NewReconciler

func NewReconciler(kv *v1.KubeVirt, targetStrategy *install.Strategy, stores util.Stores, clientset kubecli.KubevirtClient, aggregatorclient install.APIServiceInterface, expectations *util.Expectations) (*Reconciler, error)

func (*Reconciler) Sync

func (r *Reconciler) Sync(queue workqueue.RateLimitingInterface) (bool, error)