nodes

Documentation

Index

• func AnyOutOfDate(ctx context.Context, destinationRelease string, ...) (bool, error)
• func IsClientNotFound(err error) bool
• func IsInvalidConfig(err error) bool
• func IsScaleSetNotFound(err error) bool
• type Config
• type Resource
  • func New(config Config) (*Resource, error)
  • func (r *Resource) AllInstances(ctx context.Context, customObject providerv1alpha1.AzureConfig, ...) ([]compute.VirtualMachineScaleSetVM, error)
  • func (r *Resource) CreateARMDeployment(ctx context.Context, deploymentsClient *azureresource.DeploymentsClient, ...) error
  • func (r *Resource) CreateDrainerConfig(ctx context.Context, clusterID, clusterAPIEndpoint string, nodeName string) error
  • func (r *Resource) GetEncrypterObject(ctx context.Context, secretName string) (encrypter.Interface, error)
  • func (r *Resource) GetInstancesCount(ctx context.Context, ...) (int64, error)
  • func (r *Resource) GetResourceStatus(ctx context.Context, customObject providerv1alpha1.AzureConfig, t string) (string, error)
  • func (r *Resource) GetVMSSInstances(ctx context.Context, ...) ([]compute.VirtualMachineScaleSetVM, error)
  • func (r *Resource) Name() string
  • func (r *Resource) ScaleVMSS(ctx context.Context, ...) error
  • func (r *Resource) SetResourceStatus(ctx context.Context, customObject providerv1alpha1.AzureConfig, t string, ...) error
  • func (r *Resource) SetStateMachine(stateMachine state.Machine)

Functions

func AnyOutOfDate

func AnyOutOfDate(ctx context.Context, destinationRelease string, releases []releasev1alpha1.Release, nodeLabels map[string]string) (bool, error)

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

func IsClientNotFound(err error) bool

IsClientNotFound asserts clientNotFoundError.

func IsInvalidConfig

func IsInvalidConfig(err error) bool

IsInvalidConfig asserts invalidConfigError.

func IsScaleSetNotFound

func IsScaleSetNotFound(err error) bool

IsScaleSetNotFound asserts scaleSetNotFoundError.

Types

type Config

type Config struct {
	CtrlClient ctrlclient.Client
	Debugger   *debugger.Debugger
	G8sClient  versioned.Interface
	K8sClient  kubernetes.Interface
	Logger     micrologger.Logger

	Azure         setting.Azure
	ClientFactory client.OrganizationFactory
	Name          string
}

type Resource

type Resource struct {
	CtrlClient ctrlclient.Client
	Debugger   *debugger.Debugger
	G8sClient  versioned.Interface

	Logger       micrologger.Logger
	StateMachine state.Machine

	Azure         setting.Azure
	ClientFactory client.OrganizationFactory
	// contains filtered or unexported fields
}

func New

func New(config Config) (*Resource, error)

func (*Resource) AllInstances

func (r *Resource) AllInstances(ctx context.Context, customObject providerv1alpha1.AzureConfig, deploymentNameFunc func(customObject providerv1alpha1.AzureConfig) string) ([]compute.VirtualMachineScaleSetVM, error)

func (*Resource) CreateARMDeployment

func (r *Resource) CreateARMDeployment(ctx context.Context, deploymentsClient *azureresource.DeploymentsClient, computedDeployment azureresource.Deployment, resourceGroupName, deploymentName string) error

func (*Resource) CreateDrainerConfig

func (r *Resource) CreateDrainerConfig(ctx context.Context, clusterID, clusterAPIEndpoint string, nodeName string) error

func (*Resource) GetEncrypterObject

func (r *Resource) GetEncrypterObject(ctx context.Context, secretName string) (encrypter.Interface, error)

func (*Resource) GetInstancesCount

func (r *Resource) GetInstancesCount(ctx context.Context, virtualMachineScaleSetsClient *compute.VirtualMachineScaleSetsClient, resourceGroupName, vmssName string) (int64, error)

func (*Resource) GetResourceStatus

func (r *Resource) GetResourceStatus(ctx context.Context, customObject providerv1alpha1.AzureConfig, t string) (string, error)

func (*Resource) GetVMSSInstances

func (r *Resource) GetVMSSInstances(ctx context.Context, virtualMachineScaleSetVMsClient *compute.VirtualMachineScaleSetVMsClient, resourceGroupName, vmssName string) ([]compute.VirtualMachineScaleSetVM, error)

func (*Resource) Name

func (r *Resource) Name() string

func (*Resource) ScaleVMSS

func (r *Resource) ScaleVMSS(ctx context.Context, virtualMachineScaleSetsClient *compute.VirtualMachineScaleSetsClient, resourceGroup, vmssName string, desiredNodeCount int64, scaleStrategy scalestrategy.Interface) error

func (*Resource) SetResourceStatus

func (r *Resource) SetResourceStatus(ctx context.Context, customObject providerv1alpha1.AzureConfig, t string, s string) error

func (*Resource) SetStateMachine

func (r *Resource) SetStateMachine(stateMachine state.Machine)