eks

package
v0.40.0-rc.0 Latest Latest
Warning

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

Go to latest
Published: Apr 19, 2023 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreatePatch

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

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.

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