nodes

package
v4.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 30, 2020 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AnyOutOfDate

func AnyOutOfDate(ctx context.Context) (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 {
	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 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) CreateDrainerConfig

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

func (*Resource) GetEncrypterObject

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

func (*Resource) GetResourceStatus

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

func (*Resource) Name

func (r *Resource) Name() string

func (*Resource) SetResourceStatus

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

func (*Resource) SetStateMachine

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL