apply

Documentation

Index

• Constants
• func DeleteAll(kv *v1.KubeVirt, stores util.Stores, clientset kubecli.KubevirtClient, ...) error
• func GetCADuration(config *k8sv1.KubeVirtSelfSignConfiguration) *metav1.Duration
• func GetCARenewBefore(config *k8sv1.KubeVirtSelfSignConfiguration) *metav1.Duration
• func GetCertDuration(config *k8sv1.KubeVirtSelfSignConfiguration) *metav1.Duration
• func GetCertRenewBefore(config *k8sv1.KubeVirtSelfSignConfiguration) *metav1.Duration
• func GetExpectedGeneration(required runtime.Object, previousGenerations []k6tv1.GenerationStatus) int64
• func InjectPlacementMetadata(componentConfig *v1.ComponentConfig, podSpec *corev1.PodSpec)
• func SetGeneration(generations *[]k6tv1.GenerationStatus, actual runtime.Object)
• type CanaryUpgradeStatus
• 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 GetCADuration

func GetCADuration(config *k8sv1.KubeVirtSelfSignConfiguration) *metav1.Duration

func GetCARenewBefore

func GetCARenewBefore(config *k8sv1.KubeVirtSelfSignConfiguration) *metav1.Duration

func GetCertDuration

func GetCertDuration(config *k8sv1.KubeVirtSelfSignConfiguration) *metav1.Duration

func GetCertRenewBefore

func GetCertRenewBefore(config *k8sv1.KubeVirtSelfSignConfiguration) *metav1.Duration

func GetExpectedGeneration

func GetExpectedGeneration(required runtime.Object, previousGenerations []k6tv1.GenerationStatus) int64

func InjectPlacementMetadata

func InjectPlacementMetadata(componentConfig *v1.ComponentConfig, podSpec *corev1.PodSpec)

Merge all Tolerations, Affinity and NodeSelectos from NodePlacement into pod spec

func SetGeneration

func SetGeneration(generations *[]k6tv1.GenerationStatus, actual runtime.Object)

Types

type CanaryUpgradeStatus

type CanaryUpgradeStatus string

const (
	CanaryUpgradeStatusStarted                 CanaryUpgradeStatus = "started"
	CanaryUpgradeStatusUpgradingDaemonSet      CanaryUpgradeStatus = "upgrading daemonset"
	CanaryUpgradeStatusWaitingDaemonSetRollout CanaryUpgradeStatus = "waiting for daemonset rollout"
	CanaryUpgradeStatusSuccessful              CanaryUpgradeStatus = "successful"
	CanaryUpgradeStatusFailed                  CanaryUpgradeStatus = "failed"
)

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, recorder record.EventRecorder) (*Reconciler, error)

func (*Reconciler) Sync

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