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
- type InstallStrategy
- type 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
Constants ¶
View Source
const Duration1d = time.Hour * 24
View Source
const Duration7d = time.Hour * 24 * 7
Variables ¶
This section is empty.
Functions ¶
func DeleteAll ¶ added in v0.16.0
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 ¶ added in v0.29.0
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 ¶ added in v0.34.0
type Customizer struct { Patches []v1.CustomizeComponentsPatch // contains filtered or unexported fields }
func NewCustomizer ¶ added in v0.34.0
func NewCustomizer(customizations v1.CustomizeComponents) (*Customizer, error)
func (*Customizer) Apply ¶ added in v0.38.0
func (c *Customizer) Apply(targetStrategy *InstallStrategy) error
func (*Customizer) GenericApplyPatches ¶ added in v0.34.0
func (c *Customizer) GenericApplyPatches(objects interface{}) error
func (*Customizer) GetPatches ¶ added in v0.34.0
func (c *Customizer) GetPatches() []v1.CustomizeComponentsPatch
func (*Customizer) GetPatchesForResource ¶ added in v0.34.0
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 ¶ added in v0.38.0
func (ins *InstallStrategy) ApiDeployments() []*appsv1.Deployment
func (*InstallStrategy) ControllerDeployments ¶ added in v0.38.0
func (ins *InstallStrategy) ControllerDeployments() []*appsv1.Deployment
func (*InstallStrategy) DaemonSets ¶ added in v0.38.0
func (ins *InstallStrategy) DaemonSets() []*appsv1.DaemonSet
type MockAPIServiceInterface ¶ added in v0.29.0
type MockAPIServiceInterface struct {
// contains filtered or unexported fields
}
Mock of APIServiceInterface interface
func NewMockAPIServiceInterface ¶ added in v0.29.0
func NewMockAPIServiceInterface(ctrl *gomock.Controller) *MockAPIServiceInterface
func (*MockAPIServiceInterface) Create ¶ added in v0.29.0
func (_m *MockAPIServiceInterface) Create(ctx context.Context, apiService *v1beta1.APIService, opts v1.CreateOptions) (*v1beta1.APIService, error)
func (*MockAPIServiceInterface) Delete ¶ added in v0.29.0
func (_m *MockAPIServiceInterface) Delete(ctx context.Context, name string, options v1.DeleteOptions) error
func (*MockAPIServiceInterface) EXPECT ¶ added in v0.29.0
func (_m *MockAPIServiceInterface) EXPECT() *_MockAPIServiceInterfaceRecorder
func (*MockAPIServiceInterface) Get ¶ added in v0.29.0
func (_m *MockAPIServiceInterface) Get(ctx context.Context, name string, options v1.GetOptions) (*v1beta1.APIService, error)
func (*MockAPIServiceInterface) Patch ¶ added in v0.29.0
func (_m *MockAPIServiceInterface) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (*v1beta1.APIService, error)
type Reconciler ¶ added in v0.38.0
type Reconciler struct {
// contains filtered or unexported fields
}
func NewReconciler ¶ added in v0.38.0
func NewReconciler(kv *v1.KubeVirt, targetStrategy *InstallStrategy, stores util.Stores, clientset kubecli.KubevirtClient, aggregatorclient APIServiceInterface, expectations *util.Expectations) (*Reconciler, error)
func (*Reconciler) Sync ¶ added in v0.38.0
func (r *Reconciler) Sync(queue workqueue.RateLimitingInterface) (bool, error)
Click to show internal directories.
Click to hide internal directories.