cloudprovider

package

v1.4.1 Latest Latest Go to latest Published: Jun 16, 2025 License: Apache-2.0, Apache-2.0 Imports: 36 Imported by: 0

Documentation ¶

Index ¶

Constants
func GenerateNodeClaimName(vmName string) string
type CloudProvider
- func New(instanceTypeProvider instancetype.Provider, instanceProvider instance.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"

	// 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 GenerateNodeClaimName ¶

func GenerateNodeClaimName(vmName string) string

Types ¶

type CloudProvider ¶

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

func New ¶

func New(instanceTypeProvider instancetype.Provider, instanceProvider instance.Provider, recorder events.Recorder,
	kubeClient client.Client, imageProvider *imagefamily.Provider) *CloudProvider

func (*CloudProvider) Create ¶

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

Create a node given the constraints.

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

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