installstrategy

Documentation

Index

• Constants
• func DeleteAll(kv *v1.KubeVirt, strategy *InstallStrategy, stores util.Stores, ...) error
• func DumpInstallStrategyToConfigMap(clientset kubecli.KubevirtClient, operatorNamespace string) error
• func NewInstallStrategyConfigMap(config *operatorutil.KubeVirtDeploymentConfig, addMonitorServiceResources bool, ...) (*corev1.ConfigMap, error)
• type APIServiceInterface
• type Customizer
  • func NewCustomizer(customizations v1.CustomizeComponents) (*Customizer, error)
  • func (c *Customizer) Apply(targetStrategy *InstallStrategy) error
  • func (c *Customizer) GenericApplyPatches(objects interface{}) error
  • func (c *Customizer) GetPatches() []v1.CustomizeComponentsPatch
  • func (c *Customizer) GetPatchesForResource(resourceType, name string) []v1.CustomizeComponentsPatch
• type InstallStrategy
  • func GenerateCurrentInstallStrategy(config *operatorutil.KubeVirtDeploymentConfig, addMonitorServiceResources bool, ...) (*InstallStrategy, error)
  • func LoadInstallStrategyFromCache(stores util.Stores, config *operatorutil.KubeVirtDeploymentConfig) (*InstallStrategy, error)
  • func (ins *InstallStrategy) ApiDeployments() []*appsv1.Deployment
  • func (ins *InstallStrategy) ControllerDeployments() []*appsv1.Deployment
  • func (ins *InstallStrategy) DaemonSets() []*appsv1.DaemonSet
• type MockAPIServiceInterface
  • func NewMockAPIServiceInterface(ctrl *gomock.Controller) *MockAPIServiceInterface
  • func (_m *MockAPIServiceInterface) Create(ctx context.Context, apiService *v1beta1.APIService, opts v1.CreateOptions) (*v1beta1.APIService, error)
  • func (_m *MockAPIServiceInterface) Delete(ctx context.Context, name string, options v1.DeleteOptions) error
  • func (_m *MockAPIServiceInterface) EXPECT() *_MockAPIServiceInterfaceRecorder
  • func (_m *MockAPIServiceInterface) Get(ctx context.Context, name string, options v1.GetOptions) (*v1beta1.APIService, error)
  • func (_m *MockAPIServiceInterface) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, ...) (*v1beta1.APIService, error)
• type Reconciler
  • func NewReconciler(kv *v1.KubeVirt, targetStrategy *InstallStrategy, 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,
	strategy *InstallStrategy,
	stores util.Stores,
	clientset kubecli.KubevirtClient,
	aggregatorclient APIServiceInterface,
	expectations *util.Expectations) error

func DumpInstallStrategyToConfigMap

func DumpInstallStrategyToConfigMap(clientset kubecli.KubevirtClient, operatorNamespace string) error

func NewInstallStrategyConfigMap

func NewInstallStrategyConfigMap(config *operatorutil.KubeVirtDeploymentConfig, addMonitorServiceResources bool, operatorNamespace string) (*corev1.ConfigMap, error)

Types

type APIServiceInterface

type APIServiceInterface interface {
	Get(ctx context.Context, name string, options metav1.GetOptions) (*v1beta1.APIService, error)
	Create(ctx context.Context, apiService *v1beta1.APIService, opts metav1.CreateOptions) (*v1beta1.APIService, error)
	Delete(ctx context.Context, name string, options metav1.DeleteOptions) error
	Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts metav1.PatchOptions, subresources ...string) (result *v1beta1.APIService, err error)
}

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 *InstallStrategy) 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

type InstallStrategy

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

func GenerateCurrentInstallStrategy

func GenerateCurrentInstallStrategy(config *operatorutil.KubeVirtDeploymentConfig, addMonitorServiceResources bool, operatorNamespace string) (*InstallStrategy, error)

func LoadInstallStrategyFromCache

func LoadInstallStrategyFromCache(stores util.Stores, config *operatorutil.KubeVirtDeploymentConfig) (*InstallStrategy, error)

func (*InstallStrategy) ApiDeployments

func (ins *InstallStrategy) ApiDeployments() []*appsv1.Deployment

func (*InstallStrategy) ControllerDeployments

func (ins *InstallStrategy) ControllerDeployments() []*appsv1.Deployment

func (*InstallStrategy) DaemonSets

func (ins *InstallStrategy) DaemonSets() []*appsv1.DaemonSet

type MockAPIServiceInterface

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

Mock of APIServiceInterface interface

func NewMockAPIServiceInterface

func NewMockAPIServiceInterface(ctrl *gomock.Controller) *MockAPIServiceInterface

func (*MockAPIServiceInterface) Create

func (_m *MockAPIServiceInterface) Create(ctx context.Context, apiService *v1beta1.APIService, opts v1.CreateOptions) (*v1beta1.APIService, error)

func (*MockAPIServiceInterface) Delete

func (_m *MockAPIServiceInterface) Delete(ctx context.Context, name string, options v1.DeleteOptions) error

func (*MockAPIServiceInterface) EXPECT

func (_m *MockAPIServiceInterface) EXPECT() *_MockAPIServiceInterfaceRecorder

func (*MockAPIServiceInterface) Get

func (_m *MockAPIServiceInterface) Get(ctx context.Context, name string, options v1.GetOptions) (*v1beta1.APIService, error)

func (*MockAPIServiceInterface) Patch

func (_m *MockAPIServiceInterface) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (*v1beta1.APIService, error)

type Reconciler

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

func NewReconciler

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

func (*Reconciler) Sync

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