operator

Documentation

Index

• func CheckEC2Connectivity(ctx context.Context, api ec2iface.EC2API) error
• func GetCABundle(ctx context.Context, restConfig *rest.Config) (*string, error)
• func KubeDNSIP(ctx context.Context, kubernetesInterface kubernetes.Interface) (net.IP, error)
• func ResolveClusterEndpoint(ctx context.Context, eksAPI eksiface.EKSAPI) (string, error)
• func WithUserAgent(sess *session.Session) *session.Session
• type Operator
  • func NewOperator(ctx context.Context, operator *operator.Operator) (context.Context, *Operator)

Functions

func CheckEC2Connectivity

func CheckEC2Connectivity(ctx context.Context, api ec2iface.EC2API) error

CheckEC2Connectivity makes a dry-run call to DescribeInstanceTypes. If it fails, we provide an early indicator that we are having issues connecting to the EC2 API.

func GetCABundle

func GetCABundle(ctx context.Context, restConfig *rest.Config) (*string, error)

func KubeDNSIP

func KubeDNSIP(ctx context.Context, kubernetesInterface kubernetes.Interface) (net.IP, error)

func ResolveClusterEndpoint

func ResolveClusterEndpoint(ctx context.Context, eksAPI eksiface.EKSAPI) (string, error)

func WithUserAgent

func WithUserAgent(sess *session.Session) *session.Session

WithUserAgent adds a karpenter specific user-agent string to AWS session

Types

type Operator

type Operator struct {
	*operator.Operator

	Session                   *session.Session
	UnavailableOfferingsCache *awscache.UnavailableOfferings
	EC2API                    ec2iface.EC2API
	SubnetProvider            subnet.Provider
	SecurityGroupProvider     securitygroup.Provider
	InstanceProfileProvider   instanceprofile.Provider
	AMIProvider               amifamily.Provider
	AMIResolver               *amifamily.Resolver
	LaunchTemplateProvider    launchtemplate.Provider
	PricingProvider           pricing.Provider
	VersionProvider           version.Provider
	InstanceTypesProvider     instancetype.Provider
	InstanceProvider          instance.Provider
	SSMProvider               ssmp.Provider
}

Operator is injected into the AWS CloudProvider's factories

func NewOperator

func NewOperator(ctx context.Context, operator *operator.Operator) (context.Context, *Operator)