cloudprovider

package

Go to main page

Versions in this module

v0

v0.33.4

Apr 2, 2024

v0.33.3

Mar 14, 2024

v0.33.2

Jan 30, 2024

v0.33.1

Dec 19, 2023

v0.33.0

Dec 5, 2023

v0.32.10

May 17, 2024

v0.32.9

Apr 2, 2024

v0.32.8

Mar 14, 2024

v0.32.7

Feb 8, 2024

v0.32.6

Jan 26, 2024

v0.32.5

Jan 11, 2024

v0.32.4

Dec 19, 2023

v0.32.3

Nov 29, 2023

v0.32.2

Nov 22, 2023

v0.32.1

Oct 31, 2023

v0.32.0

Oct 31, 2023

v0.31.4

Feb 9, 2024

v0.31.3

Dec 1, 2023

v0.31.2

Oct 30, 2023

v0.31.1

Oct 11, 2023

v0.31.0

Sep 27, 2023

Changes in this version

+ const NodeClassDrift

type CloudProvider

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

v0.30.0

Aug 31, 2023

Changes in this version

+ const AMIDrift

+ const NodeTemplateDrift

+ const SecurityGroupDrift

+ const SubnetDrift

v0.30.0-rc.0

Aug 10, 2023

v0.29.2

Jul 19, 2023

v0.29.1

Jul 17, 2023

v0.29.0

Jul 6, 2023

v0.28.1

Jun 22, 2023

v0.28.0

Jun 14, 2023

v0.28.0-rc.2

May 30, 2023

v0.28.0-rc.1

May 4, 2023

v0.27.8

Nov 10, 2023

v0.27.6

Jun 12, 2023

v0.27.5

May 18, 2023

v0.27.4

May 18, 2023

v0.27.3

Apr 19, 2023

v0.27.2

Apr 11, 2023

v0.27.1

Mar 27, 2023

v0.27.0

Mar 7, 2023

v0.26.1

Mar 2, 2023

v0.26.0

Mar 1, 2023

Changes in this version

+ var InstanceTypeBandwidthMegabits = map[string]int64

type CloudProvider

+ func (c *CloudProvider) Link(ctx context.Context, machine *v1alpha5.Machine) error

type InstanceProvider

+ func (p *InstanceProvider) Link(ctx context.Context, id string) error

v0.25.0

Feb 21, 2023

Changes in this version

type CloudProvider

+ func (c *CloudProvider) List(ctx context.Context) ([]*v1alpha5.Machine, error)

v0.24.0

Feb 7, 2023

Changes in this version

type CloudProvider

+ func (c *CloudProvider) Hydrate(ctx context.Context, machine *v1alpha5.Machine) error

type InstanceProvider

+ func (p *InstanceProvider) Update(ctx context.Context, machine *v1alpha5.Machine) (*ec2.Instance, error)

v0.23.0

Jan 24, 2023

Changes in this version

type CloudProvider

+ func (c *CloudProvider) Get(ctx context.Context, machineName, provisionerName string) (*v1alpha5.Machine, error)

type InstanceProvider

+ func (p *InstanceProvider) DeleteByID(ctx context.Context, id string) error

+ func (p *InstanceProvider) GetByID(ctx context.Context, id string) (*ec2.Instance, error)

+ func (p *InstanceProvider) List(ctx context.Context, machineName string) ([]*ec2.Instance, error)

v0.22.1

Jan 11, 2023

v0.22.0

Jan 6, 2023

Changes in this version

type InstanceProvider

+ func (p *InstanceProvider) Delete(ctx context.Context, machine *v1alpha5.Machine) error

+ func (p *InstanceProvider) Get(ctx context.Context, id string) (*ec2.Instance, error)

type InstanceTypeProvider

+ func (p *InstanceTypeProvider) List(ctx context.Context, kc *v1alpha5.KubeletConfiguration, ...) ([]*cloudprovider.InstanceType, error)

type LaunchTemplateProvider

+ func (p *LaunchTemplateProvider) EnsureAll(ctx context.Context, nodeTemplate *v1alpha1.AWSNodeTemplate, ...) (map[string][]*cloudprovider.InstanceType, error)

v0.21.1

Dec 28, 2022

v0.21.0

Dec 27, 2022

Changes in this version

type CloudProvider

+ func (c *CloudProvider) IsMachineDrifted(ctx context.Context, machine *corev1alpha1.Machine) (bool, error)

v0.20.0

Dec 8, 2022

v0.19.3

Dec 2, 2022

v0.19.2

Nov 21, 2022

v0.19.1

Nov 18, 2022

v0.19.0

Nov 15, 2022

Changes in this version

+ const InstanceTypeZonesCacheKeyPrefix

+ const InstanceTypesAndZonesCacheTTL

+ const InstanceTypesCacheKey

+ const MaxInstanceTypes

+ var Limits = map[string]*VPCLimits

+ func NewPricingAPI(sess *session.Session, region string) pricingiface.PricingAPI

type CloudProvider

+ func New(ctx awscontext.Context) *CloudProvider

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

+ type CreateFleetBatcher struct

+ func NewCreateFleetBatcher(ctx context.Context, ec2api ec2iface.EC2API) *CreateFleetBatcher

+ func (b *CreateFleetBatcher) CreateFleet(ctx context.Context, createFleetInput *ec2.CreateFleetInput) (*ec2.CreateFleetOutput, error)

+ type InstanceProvider struct

+ func NewInstanceProvider(ctx context.Context, ec2api ec2iface.EC2API, ...) *InstanceProvider

+ func (p *InstanceProvider) Create(ctx context.Context, provider *v1alpha1.AWS, ...) (*v1.Node, error)

+ func (p *InstanceProvider) Terminate(ctx context.Context, node *v1.Node) error

type InstanceType

+ func NewInstanceType(ctx context.Context, info *ec2.InstanceTypeInfo, ...) *InstanceType

+ type InstanceTypeProvider struct

+ func NewInstanceTypeProvider(ctx context.Context, sess *session.Session, ec2api ec2iface.EC2API, ...) *InstanceTypeProvider

+ func (p *InstanceTypeProvider) Get(ctx context.Context, provider *v1alpha1.AWS, kc *v1alpha5.KubeletConfiguration) ([]cloudprovider.InstanceType, error)

+ func (p *InstanceTypeProvider) LivenessProbe(req *http.Request) error

+ type LaunchTemplateProvider struct

+ func NewLaunchTemplateProvider(ctx context.Context, ec2api ec2iface.EC2API, ...) *LaunchTemplateProvider

+ func (p *LaunchTemplateProvider) Get(ctx context.Context, provider *v1alpha1.AWS, ...) (map[string][]cloudprovider.InstanceType, error)

+ func (p *LaunchTemplateProvider) Invalidate(ctx context.Context, ltName string)

+ type PricingProvider struct

+ func NewPricingProvider(ctx context.Context, pricing pricingiface.PricingAPI, ec2Api ec2iface.EC2API, ...) *PricingProvider

+ func (p *PricingProvider) InstanceTypes() []string

+ func (p *PricingProvider) LivenessProbe(req *http.Request) error

+ func (p *PricingProvider) OnDemandLastUpdated() time.Time

+ func (p *PricingProvider) OnDemandPrice(instanceType string) (float64, bool)

+ func (p *PricingProvider) SpotLastUpdated() time.Time

+ func (p *PricingProvider) SpotPrice(instanceType string, zone string) (float64, bool)

+ type SecurityGroupProvider struct

+ func NewSecurityGroupProvider(ec2api ec2iface.EC2API) *SecurityGroupProvider

+ func (p *SecurityGroupProvider) Get(ctx context.Context, provider *v1alpha1.AWS) ([]string, error)

+ type SubnetProvider struct

+ func NewSubnetProvider(ec2api ec2iface.EC2API) *SubnetProvider

+ func (p *SubnetProvider) Get(ctx context.Context, provider *v1alpha1.AWS) ([]*ec2.Subnet, error)

+ func (p *SubnetProvider) LivenessProbe(req *http.Request) error

+ type VPCLimits struct

+ BranchInterface int

+ IPv4PerInterface int

+ Interface int

+ IsTrunkingCompatible bool

v0.18.1

Oct 19, 2022

v0.18.0

Oct 11, 2022

v0.17.0

Oct 4, 2022

v0.17.0-test3

Oct 3, 2022

v0.17.0-test13

Oct 3, 2022

v0.16.3

Sep 27, 2022

v0.16.2

Sep 20, 2022

v0.16.1

Aug 31, 2022

Changes in this version

type Offering

+ Available bool

+ Price float64

+ func AvailableOfferings(it InstanceType) []Offering

+ func GetOffering(it InstanceType, ct, zone string) (Offering, bool)

v0.16.0

Aug 23, 2022

v0.15.0

Aug 17, 2022

v0.14.0

Aug 10, 2022

v0.14.0-rc.0

Jul 29, 2022

v0.13.2

Jul 7, 2022

Changes in this version

type Options

+ WebhookOnly bool

v0.13.1

Jun 28, 2022

v0.13.0

Jun 27, 2022

Changes in this version

type Options

+ StartAsync <-chan struct{}

v0.12.1

Jun 21, 2022

v0.12.0

Jun 21, 2022

v0.11.1

Jun 15, 2022

v0.11.0

Jun 14, 2022

Changes in this version

type InstanceType

+ Requirements func() scheduling.Requirements

type Options

+ KubeClient client.Client

v0.10.1

May 23, 2022

Changes in this version

+ func InstanceTypeRequirements(instanceTypes []InstanceType) scheduling.Requirements

v0.10.0

May 9, 2022

v0.9.1

May 2, 2022

Changes in this version

type CloudProvider

+ GetRequirements func(context.Context, *v1alpha5.Provider) (v1alpha5.Requirements, error)

v0.9.0

Apr 25, 2022

v0.9.0-rc.1

Apr 19, 2022

v0.9.0-rc.0

Apr 19, 2022

v0.8.2

Apr 11, 2022

v0.8.1

Apr 5, 2022

Changes in this version

type NodeRequest

+ Template *NodeTemplate

+ type NodeTemplate struct

+ KubeletConfiguration *v1alpha5.KubeletConfiguration

+ Labels map[string]string

+ Provider *v1alpha5.Provider

+ Requirements v1alpha5.Requirements

+ Taints []v1.Taint

v0.8.0

Mar 29, 2022

Changes in this version

type InstanceType

+ func FilterInstanceTypes(instanceTypes []InstanceType, requirements v1alpha5.Requirements, ...) []InstanceType

+ type NodeRequest struct

+ Constraints *v1alpha5.Constraints

+ InstanceTypeOptions []InstanceType

v0.7.3

Mar 24, 2022

Changes in this version

+ func Compatible(it InstanceType, requirements v1alpha5.Requirements) bool

+ func Requirements(instanceTypes []InstanceType) v1alpha5.Requirements

type InstanceType

+ Price func() float64

+ Resources func() v1.ResourceList

v0.7.2

Mar 19, 2022

v0.7.1

Mar 16, 2022

v0.7.0

Mar 14, 2022

v0.6.5

Mar 8, 2022

v0.6.4

Mar 1, 2022

v0.6.3

Feb 16, 2022

v0.6.2

Feb 15, 2022

v0.6.1

Feb 7, 2022

v0.6.0

Feb 1, 2022

v0.5.6

Jan 25, 2022

v0.5.5

Jan 19, 2022

v0.5.4

Jan 8, 2022

v0.5.3

Dec 18, 2021

Changes in this version

type CloudProvider

+ Name func() string

v0.5.2

Dec 9, 2021

Changes in this version

type InstanceType

+ AWSPodENI func() *resource.Quantity

+ OperatingSystems func() sets.String

v0.5.1

Dec 3, 2021

v0.5.0

Nov 26, 2021

Changes in this version

+ type CloudProvider interface

+ Create func(context.Context, *v1alpha5.Constraints, []InstanceType, int, ...) chan error

+ Default func(context.Context, *v1alpha5.Constraints)

+ Delete func(context.Context, *v1.Node) error

+ GetInstanceTypes func(context.Context, *v1alpha5.Constraints) ([]InstanceType, error)

+ Validate func(context.Context, *v1alpha5.Constraints) *apis.FieldError

+ type InstanceType interface

+ AMDGPUs func() *resource.Quantity

+ AWSNeurons func() *resource.Quantity

+ Architecture func() string

+ CPU func() *resource.Quantity

+ Memory func() *resource.Quantity

+ Name func() string

+ NvidiaGPUs func() *resource.Quantity

+ Offerings func() []Offering

+ Overhead func() v1.ResourceList

+ Pods func() *resource.Quantity

+ type Offering struct

+ CapacityType string

+ Zone string

+ type Options struct

+ ClientSet *kubernetes.Clientset

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