operator

package

v0.36.3 Latest Latest Go to latest Published: Aug 14, 2024 License: Apache-2.0 Imports: 45 Imported by: 3

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/aws/karpenter-provider-aws

Links

Open Source Insights

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 SetDurationAndExpiry(ctx context.Context, provider *stscreds.AssumeRoleProvider)
func WithUserAgent(sess *session.Session) *session.Session
type Operator
- func NewOperator(ctx context.Context, operator *operator.Operator) (context.Context, *Operator)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CheckEC2Connectivity ¶ added in v0.36.0

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 ¶ added in v0.36.0

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

func KubeDNSIP ¶ added in v0.36.0

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

func ResolveClusterEndpoint ¶

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

func SetDurationAndExpiry ¶ added in v0.36.0

func SetDurationAndExpiry(ctx context.Context, provider *stscreds.AssumeRoleProvider)

func WithUserAgent ¶ added in v0.36.0

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)

Source Files ¶

View all Source files

operator.go

Directories ¶

Path	Synopsis
options

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