Documentation ¶
Index ¶
- func AnyOutOfDate(ctx context.Context) (bool, error)
- func IsClientNotFound(err error) bool
- func IsInvalidConfig(err error) bool
- func IsScaleSetNotFound(err error) bool
- type Config
- type Resource
- func (r *Resource) AllInstances(ctx context.Context, customObject providerv1alpha1.AzureConfig, ...) ([]compute.VirtualMachineScaleSetVM, error)
- func (r *Resource) CreateDrainerConfig(ctx context.Context, customObject providerv1alpha1.AzureConfig, ...) error
- func (r *Resource) GetEncrypterObject(ctx context.Context, secretName string) (encrypter.Interface, error)
- func (r *Resource) GetResourceStatus(customObject providerv1alpha1.AzureConfig, t string) (string, error)
- func (r *Resource) Name() string
- func (r *Resource) SetResourceStatus(customObject providerv1alpha1.AzureConfig, t string, s string) error
- func (r *Resource) SetStateMachine(stateMachine state.Machine)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AnyOutOfDate ¶
AnyOutOfDate iterates over all nodes in tenant cluster and finds corresponding azure-operator version from node labels. If node doesn't have this label or was created with older version than currently reconciling one, then this function returns true. Otherwise (including on error) false.
func IsClientNotFound ¶
IsClientNotFound asserts clientNotFoundError.
func IsInvalidConfig ¶
IsInvalidConfig asserts invalidConfigError.
func IsScaleSetNotFound ¶
IsScaleSetNotFound asserts scaleSetNotFoundError.
Types ¶
type Config ¶
type Config struct { Debugger *debugger.Debugger G8sClient versioned.Interface K8sClient kubernetes.Interface Logger micrologger.Logger Azure setting.Azure ClientFactory *client.Factory InstanceWatchdog vmsscheck.InstanceWatchdog Name string }
type Resource ¶
type Resource struct { Debugger *debugger.Debugger G8sClient versioned.Interface Logger micrologger.Logger StateMachine state.Machine Azure setting.Azure ClientFactory *client.Factory InstanceWatchdog vmsscheck.InstanceWatchdog // contains filtered or unexported fields }
func (*Resource) AllInstances ¶
func (r *Resource) AllInstances(ctx context.Context, customObject providerv1alpha1.AzureConfig, deploymentNameFunc func(customObject providerv1alpha1.AzureConfig) string) ([]compute.VirtualMachineScaleSetVM, error)
func (*Resource) CreateDrainerConfig ¶
func (r *Resource) CreateDrainerConfig(ctx context.Context, customObject providerv1alpha1.AzureConfig, nodeName string) error
func (*Resource) GetEncrypterObject ¶
func (*Resource) GetResourceStatus ¶
func (r *Resource) GetResourceStatus(customObject providerv1alpha1.AzureConfig, t string) (string, error)
func (*Resource) SetResourceStatus ¶
func (r *Resource) SetResourceStatus(customObject providerv1alpha1.AzureConfig, t string, s string) error
func (*Resource) SetStateMachine ¶
Click to show internal directories.
Click to hide internal directories.