cloudprovider

package

v1.7.1 Latest Latest Go to latest Published: Feb 12, 2026 License: Apache-2.0, Apache-2.0 Imports: 43 Imported by: 0

Documentation ¶

Index ¶

Constants
func GetNodeClaimNameFromVMName(vmName string) string
type CloudProvider
- func New(instanceTypeProvider instancetype.Provider, ...) *CloudProvider

Constants ¶

const (
	NodeClassReadinessUnknownReason    = "NodeClassReadinessUnknown"
	InstanceTypeResolutionFailedReason = "InstanceTypeResolutionFailed"
	CreateInstanceFailedReason         = "CreateInstanceFailed"
)

View Source

const (
	NodeClassDrift       cloudprovider.DriftReason = "NodeClassDrift"
	K8sVersionDrift      cloudprovider.DriftReason = "K8sVersionDrift"
	ImageDrift           cloudprovider.DriftReason = "ImageDrift"
	SubnetDrift          cloudprovider.DriftReason = "SubnetDrift"
	KubeletIdentityDrift cloudprovider.DriftReason = "KubeletIdentityDrift"
	ClusterConfigDrift   cloudprovider.DriftReason = "ClusterConfigDrift" // This is a catch-all for cluster-level config changes (e.g., from PUT ManagedCluster), where Karpenter does not directly "own" them.

	// TODO (charliedmcb): Use this const across code and test locations which are signaling/checking for "no drift"
	NoDrift cloudprovider.DriftReason = ""
)

Variables ¶

This section is empty.

Functions ¶

func GetNodeClaimNameFromVMName ¶ added in v1.6.6

func GetNodeClaimNameFromVMName(vmName string) string

Types ¶

type CloudProvider ¶

type CloudProvider struct {
	// contains filtered or unexported fields
}

func New ¶

func New(
	instanceTypeProvider instancetype.Provider,
	vmInstanceProvider instance.VMProvider,
	aksMachineInstanceProvider instance.AKSMachineProvider,
	recorder events.Recorder,
	kubeClient client.Client,
	imageProvider imagefamily.NodeImageProvider,
	store *nodeoverlay.InstanceTypeStore,
) *CloudProvider

func (*CloudProvider) Create ¶

func (c *CloudProvider) Create(ctx context.Context, nodeClaim *karpv1.NodeClaim) (*karpv1.NodeClaim, error)

func (*CloudProvider) Delete ¶

func (c *CloudProvider) Delete(ctx context.Context, nodeClaim *karpv1.NodeClaim) error

func (*CloudProvider) Get ¶

func (c *CloudProvider) Get(ctx context.Context, providerID string) (*karpv1.NodeClaim, error)

func (*CloudProvider) GetInstanceTypes ¶

func (c *CloudProvider) GetInstanceTypes(ctx context.Context, nodePool *karpv1.NodePool) ([]*cloudprovider.InstanceType, error)

GetInstanceTypes returns all available InstanceTypes May return apimachinery.NotFoundError if NodeClass is not found.

func (*CloudProvider) GetSupportedNodeClasses ¶ added in v0.4.0

func (c *CloudProvider) GetSupportedNodeClasses() []status.Object

func (*CloudProvider) IsDrifted ¶

func (c *CloudProvider) IsDrifted(ctx context.Context, nodeClaim *karpv1.NodeClaim) (cloudprovider.DriftReason, error)

func (*CloudProvider) List ¶

func (c *CloudProvider) List(ctx context.Context) ([]*karpv1.NodeClaim, error)

func (*CloudProvider) LivenessProbe ¶

func (c *CloudProvider) LivenessProbe(req *http.Request) error

func (*CloudProvider) Name ¶

func (c *CloudProvider) Name() string

Name returns the CloudProvider implementation name.

func (*CloudProvider) RepairPolicies ¶ added in v1.4.0

func (c *CloudProvider) RepairPolicies() []cloudprovider.RepairPolicy

TODO: review repair policies

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
events

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