The highest tagged major version is
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 ¶
Source Files
Click to show internal directories.
Click to hide internal directories.