eks

package
v0.35.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 21, 2022 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreatePatch 

func CreatePatch(in *ekstypes.Cluster, target *v1beta1.ClusterParameters) (*v1beta1.ClusterParameters, error)

CreatePatch creates a *v1beta1.ClusterParameters that has only the changed values between the target *v1beta1.ClusterParameters and the current *ekstypes.Cluster.

func GenerateAssociateIdentityProviderConfigInput 

func GenerateAssociateIdentityProviderConfigInput(name string, p *manualv1alpha1.IdentityProviderConfigParameters) *eks.AssociateIdentityProviderConfigInput

GenerateAssociateIdentityProviderConfigInput from IdentityProviderConfigParameters

func GenerateCreateClusterInput 

func GenerateCreateClusterInput(name string, p *v1beta1.ClusterParameters) *eks.CreateClusterInput

GenerateCreateClusterInput from ClusterParameters.

func GenerateCreateFargateProfileInput 

func GenerateCreateFargateProfileInput(name string, p v1beta1.FargateProfileParameters) *eks.CreateFargateProfileInput

GenerateCreateFargateProfileInput from FargateProfileInputParameters.

func GenerateCreateNodeGroupInput 

func GenerateCreateNodeGroupInput(name string, p *manualv1alpha1.NodeGroupParameters) *eks.CreateNodegroupInput

GenerateCreateNodeGroupInput from NodeGroupParameters.

func GenerateDisassociateIdentityProviderConfigInput 

func GenerateDisassociateIdentityProviderConfigInput(name string, clusterName string) *eks.DisassociateIdentityProviderConfigInput

GenerateDisassociateIdentityProviderConfigInput from IdentityProviderConfigParameters

func GenerateEncryptionConfig added in v0.31.0 

func GenerateEncryptionConfig(parameters *v1beta1.ClusterParameters) []ekstypes.EncryptionConfig

GenerateEncryptionConfig creates the config needed to enable encryption

func GenerateFargateProfileObservation 

func GenerateFargateProfileObservation(fp *ekstypes.FargateProfile) v1beta1.FargateProfileObservation

GenerateFargateProfileObservation is used to produce FargateProfileObservation from eks.FargateProfile.

func GenerateIdentityProviderConfigObservation 

func GenerateIdentityProviderConfigObservation(ip *types.IdentityProviderConfigResponse) manualv1alpha1.IdentityProviderConfigObservation

GenerateIdentityProviderConfigObservation is used to produce manualv1alpha1.IdentityProviderConfigObservation from eks.IdentityProviderConfigResponse.

func GenerateNodeGroupObservation 

func GenerateNodeGroupObservation(ng *ekstypes.Nodegroup) manualv1alpha1.NodeGroupObservation

GenerateNodeGroupObservation is used to produce manualv1alpha1.NodeGroupObservation from eks.Nodegroup.

func GenerateObservation 

func GenerateObservation(cluster *ekstypes.Cluster) v1beta1.ClusterObservation

GenerateObservation is used to produce v1beta1.ClusterObservation from ekstypes.Cluster.

func GenerateUpdateClusterConfigInputForLogging added in v0.29.0 

func GenerateUpdateClusterConfigInputForLogging(name string, p *v1beta1.ClusterParameters) *eks.UpdateClusterConfigInput

GenerateUpdateClusterConfigInputForLogging from ClusterParameters.

func GenerateUpdateClusterConfigInputForVPC added in v0.29.0 

func GenerateUpdateClusterConfigInputForVPC(name string, p *v1beta1.ClusterParameters) *eks.UpdateClusterConfigInput

GenerateUpdateClusterConfigInputForVPC from ClusterParameters.

func GenerateUpdateNodeGroupConfigInput 

func GenerateUpdateNodeGroupConfigInput(name string, p *manualv1alpha1.NodeGroupParameters, ng *ekstypes.Nodegroup) *eks.UpdateNodegroupConfigInput

GenerateUpdateNodeGroupConfigInput from NodeGroupParameters.

func GenerateUpdateNodeGroupVersionInput added in v0.32.0 

func GenerateUpdateNodeGroupVersionInput(name string, p *manualv1alpha1.NodeGroupParameters, ng *ekstypes.Nodegroup) (bool, *eks.UpdateNodegroupVersionInput)

GenerateUpdateNodeGroupVersionInput will check if version properties of the nodegroup have changed. If no version property has changed, it will return false and an incomplete update object. If true,

func GetConnectionDetails 

func GetConnectionDetails(ctx context.Context, cluster *ekstypes.Cluster, stsClient STSClient) managed.ConnectionDetails

GetConnectionDetails extracts managed.ConnectionDetails out of ekstypes.Cluster.

func IsErrorInUse 

func IsErrorInUse(err error) bool

IsErrorInUse helper function to test for eResourceInUseException error.

func IsErrorInvalidRequest 

func IsErrorInvalidRequest(err error) bool

IsErrorInvalidRequest helper function to test for InvalidRequestException error.

func IsErrorNotFound 

func IsErrorNotFound(err error) bool

IsErrorNotFound helper function to test for ResourceNotFoundException error.

func IsFargateProfileUpToDate 

func IsFargateProfileUpToDate(p v1beta1.FargateProfileParameters, fp *ekstypes.FargateProfile) bool

IsFargateProfileUpToDate checks whether there is a change in the tags. Any other field is immutable and can't be updated.

func IsIdentityProviderConfigUpToDate 

func IsIdentityProviderConfigUpToDate(p *manualv1alpha1.IdentityProviderConfigParameters, ip *types.IdentityProviderConfigResponse) bool

IsIdentityProviderConfigUpToDate checks whether there is a change in the tags. Any other field is immutable and can't be updated.

func IsNodeGroupUpToDate 

func IsNodeGroupUpToDate(p *manualv1alpha1.NodeGroupParameters, ng *ekstypes.Nodegroup) bool

IsNodeGroupUpToDate checks whether there is a change in any of the modifiable fields.

func IsUpToDate 

func IsUpToDate(p *v1beta1.ClusterParameters, cluster *ekstypes.Cluster) (bool, error)

IsUpToDate checks whether there is a change in any of the modifiable fields.

func LateInitialize 

func LateInitialize(in *v1beta1.ClusterParameters, cluster *ekstypes.Cluster)

LateInitialize fills the empty fields in *v1beta1.ClusterParameters with the values seen in ekstypes.Cluster.

func LateInitializeFargateProfile 

func LateInitializeFargateProfile(in *v1beta1.FargateProfileParameters, fp *ekstypes.FargateProfile)

LateInitializeFargateProfile fills the empty fields in *FargateProfileParameters with the values seen in eks.FargateProfile.

func LateInitializeIdentityProviderConfig 

func LateInitializeIdentityProviderConfig(in *manualv1alpha1.IdentityProviderConfigParameters, ip *types.IdentityProviderConfigResponse)

LateInitializeIdentityProviderConfig fills the empty fields in *manualv1alpha1.IdentityProviderConfigParameters with the values seen in eks.IdentityProviderConfigResponse.

func LateInitializeNodeGroup 

func LateInitializeNodeGroup(in *manualv1alpha1.NodeGroupParameters, ng *ekstypes.Nodegroup)

LateInitializeNodeGroup fills the empty fields in *manualv1alpha1.NodeGroupParameters with the values seen in eks.Nodegroup.

Types

type Client 

type Client interface {
	CreateCluster(ctx context.Context, input *eks.CreateClusterInput, opts ...func(*eks.Options)) (*eks.CreateClusterOutput, error)
	DescribeCluster(ctx context.Context, input *eks.DescribeClusterInput, opts ...func(*eks.Options)) (*eks.DescribeClusterOutput, error)
	UpdateClusterConfig(ctx context.Context, input *eks.UpdateClusterConfigInput, opts ...func(*eks.Options)) (*eks.UpdateClusterConfigOutput, error)
	DeleteCluster(ctx context.Context, input *eks.DeleteClusterInput, opts ...func(*eks.Options)) (*eks.DeleteClusterOutput, error)
	TagResource(ctx context.Context, input *eks.TagResourceInput, opts ...func(*eks.Options)) (*eks.TagResourceOutput, error)
	UntagResource(ctx context.Context, input *eks.UntagResourceInput, opts ...func(*eks.Options)) (*eks.UntagResourceOutput, error)
	UpdateClusterVersion(ctx context.Context, input *eks.UpdateClusterVersionInput, opts ...func(*eks.Options)) (*eks.UpdateClusterVersionOutput, error)
	AssociateEncryptionConfig(ctx context.Context, params *eks.AssociateEncryptionConfigInput, optFns ...func(*eks.Options)) (*eks.AssociateEncryptionConfigOutput, error)

	DescribeNodegroup(ctx context.Context, input *eks.DescribeNodegroupInput, opts ...func(*eks.Options)) (*eks.DescribeNodegroupOutput, error)
	CreateNodegroup(ctx context.Context, input *eks.CreateNodegroupInput, opts ...func(*eks.Options)) (*eks.CreateNodegroupOutput, error)
	UpdateNodegroupVersion(ctx context.Context, input *eks.UpdateNodegroupVersionInput, opts ...func(*eks.Options)) (*eks.UpdateNodegroupVersionOutput, error)
	UpdateNodegroupConfig(ctx context.Context, input *eks.UpdateNodegroupConfigInput, opts ...func(*eks.Options)) (*eks.UpdateNodegroupConfigOutput, error)
	DeleteNodegroup(ctx context.Context, input *eks.DeleteNodegroupInput, opts ...func(*eks.Options)) (*eks.DeleteNodegroupOutput, error)

	DescribeFargateProfile(ctx context.Context, input *eks.DescribeFargateProfileInput, opts ...func(*eks.Options)) (*eks.DescribeFargateProfileOutput, error)
	CreateFargateProfile(ctx context.Context, input *eks.CreateFargateProfileInput, opts ...func(*eks.Options)) (*eks.CreateFargateProfileOutput, error)
	DeleteFargateProfile(ctx context.Context, input *eks.DeleteFargateProfileInput, opts ...func(*eks.Options)) (*eks.DeleteFargateProfileOutput, error)

	DescribeIdentityProviderConfig(ctx context.Context, input *eks.DescribeIdentityProviderConfigInput, opts ...func(*eks.Options)) (*eks.DescribeIdentityProviderConfigOutput, error)
	AssociateIdentityProviderConfig(ctx context.Context, input *eks.AssociateIdentityProviderConfigInput, opts ...func(*eks.Options)) (*eks.AssociateIdentityProviderConfigOutput, error)
	DisassociateIdentityProviderConfig(ctx context.Context, input *eks.DisassociateIdentityProviderConfigInput, opts ...func(*eks.Options)) (*eks.DisassociateIdentityProviderConfigOutput, error)
}

Client defines EKS Client operations

func NewEKSClient 

func NewEKSClient(cfg aws.Config) Client

NewEKSClient creates new EKS Client with provided AWS Configurations/Credentials.

type STSClient 

type STSClient interface {
	PresignGetCallerIdentity(ctx context.Context, input *sts.GetCallerIdentityInput, opts ...func(*sts.PresignOptions)) (*v4.PresignedHTTPRequest, error)
}

STSClient STS presigner

func NewSTSClient 

func NewSTSClient(cfg aws.Config) STSClient

NewSTSClient creates a new STS Client.

Source Files

View all Source files

Directories

Path Synopsis
eksiface
Package eksiface is a generated GoMock package.
 Package eksiface is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.