nodepool

Documentation

Index

• Constants
• func IsClientNotFound(err error) bool
• func IsDeploymentNotFound(err error) bool
• func IsMissingOperatorVersionLabel(err error) bool
• func IsMissingOrganizationLabel(err error) bool
• func IsMissingReleaseVersionLabel(err error) bool
• func IsNotAvailableFailureDomain(err error) bool
• func IsNotFound(err error) bool
• func IsOwnerReferenceNotSet(err error) bool
• func IsSubnetNotReadyError(err error) bool
• func IsTooManyCredentialsError(err error) bool
• func IsUnexpectedUpstreamResponse(err error) bool
• func IsWrongTypeError(err error) bool
• type Config
• type Resource
  • func New(config Config) (*Resource, error)
  • func (r *Resource) EnsureCreated(ctx context.Context, obj interface{}) error
  • func (r *Resource) EnsureDeleted(ctx context.Context, obj interface{}) error
  • func (r *Resource) Name() string

Constants

const (
	// Types
	Stage = "Stage"

	// States
	CordonOldWorkers            = "CordonOldWorkers"
	DeploymentUninitialized     = ""
	DrainOldWorkerNodes         = "DrainOldWorkerNodes"
	ScaleUpWorkerVMSS           = "ScaleUpWorkerVMSS"
	ScaleDownWorkerVMSS         = "ScaleDownWorkerVMSS"
	TerminateOldWorkerInstances = "TerminateOldWorkerInstances"
	WaitForWorkersToBecomeReady = "WaitForWorkersToBecomeReady"
)

const (
	Name = "nodepool"
)

const (
	// UnschedulablePatch is the JSON patch structure being applied to nodes using
	// a strategic merge patch in order to cordon them.
	UnschedulablePatch = `{"spec":{"unschedulable":true}}`
)

Functions

func IsClientNotFound

func IsClientNotFound(err error) bool

IsClientNotFound asserts clientNotFoundError.

func IsDeploymentNotFound

func IsDeploymentNotFound(err error) bool

IsDeploymentNotFound asserts deploymentNotFoundError.

func IsMissingOperatorVersionLabel

func IsMissingOperatorVersionLabel(err error) bool

IsMissingOperatorVersionLabel asserts missingOperatorVersionLabel.

func IsMissingOrganizationLabel

func IsMissingOrganizationLabel(err error) bool

IsMissingOrganizationLabel asserts missingOrganizationLabel.

func IsMissingReleaseVersionLabel

func IsMissingReleaseVersionLabel(err error) bool

IsMissingReleaseVersionLabel asserts missingReleaseVersionLabel.

func IsNotAvailableFailureDomain

func IsNotAvailableFailureDomain(err error) bool

IsNotAvailableFailureDomain asserts notAvailableFailureDomain.

func IsNotFound

func IsNotFound(err error) bool

IsNotFound asserts notFoundError or 404 response.

func IsOwnerReferenceNotSet

func IsOwnerReferenceNotSet(err error) bool

IsOwnerReferenceNotSet asserts ownerReferenceNotSet.

func IsSubnetNotReadyError

func IsSubnetNotReadyError(err error) bool

IsSubnetNotReadyError asserts subnetNotReadyError.

func IsTooManyCredentialsError

func IsTooManyCredentialsError(err error) bool

IsTooManyCredentialsError asserts tooManyCredentialsError.

func IsUnexpectedUpstreamResponse

func IsUnexpectedUpstreamResponse(err error) bool

IsUnexpectedUpstreamResponse asserts unexpectedUpstreamResponseError.

func IsWrongTypeError

func IsWrongTypeError(err error) bool

IsWrongTypeError asserts wrongTypeError.

Types

type Config

type Config struct {
	nodes.Config
	CredentialProvider        credential.Provider
	CtrlClient                ctrlclient.Client
	GSClientCredentialsConfig auth.ClientCredentialsConfig
	TenantClientFactory       tenantcluster.Factory
	VMSKU                     *vmsku.VMSKUs
}

type Resource

type Resource struct {
	nodes.Resource
	CredentialProvider credential.Provider
	CtrlClient         ctrlclient.Client
	// contains filtered or unexported fields
}

Resource takes care of node pool life cycle.

func New

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

func (*Resource) EnsureCreated

func (r *Resource) EnsureCreated(ctx context.Context, obj interface{}) error

EnsureCreated will create an ARM deployment for every node pool.

func (*Resource) EnsureDeleted

func (r *Resource) EnsureDeleted(ctx context.Context, obj interface{}) error

EnsureDeleted is a noop since the deletion of deployments is redirected to the deletion of resource groups because they garbage collect them.

func (*Resource) Name

func (r *Resource) Name() string