eks

Dec 2, 2024

Changes in this version

type KubeProvider

+ NewDynamicClient func(clusterInfo kubeconfig.ClusterInfo) (*dynamic.DynamicClient, error)

type KubernetesProvider

+ func (c *KubernetesProvider) NewDynamicClient(clusterInfo kubeconfig.ClusterInfo) (*dynamic.DynamicClient, error)

+ type NodeGroupLister struct

+ NodeGroupStackLister NodeGroupStackLister

+ func (n *NodeGroupLister) List(ctx context.Context) ([]KubeNodeGroup, error)

+ type NodeGroupStackLister interface

+ ListNodeGroupStacksWithStatuses func(ctx context.Context) ([]manager.NodeGroupStack, error)

Jul 11, 2024

Changes in this version

+ func LoadConfigWithReader(configFile string, configReader io.Reader) (*api.ClusterConfig, error)

Dec 20, 2023

Changes in this version

+ func IsAccessEntryEnabled(accessConfig *ekstypes.AccessConfigResponse) bool

type ClusterProvider

+ func (c *ClusterProvider) GetClusterState() *ekstypes.Cluster

+ func (c *ClusterProvider) IsAccessEntryEnabled() bool

Oct 24, 2023

Changes in this version

type ClusterProvider

+ func (c *ClusterProvider) UpdateClusterConfig(ctx context.Context, input *eks.UpdateClusterConfigInput) error

Aug 11, 2023

Changes in this version

+ type AWSConfigurationLoader interface

+ LoadDefaultConfig func(ctx context.Context, optFns ...func(*config.LoadOptions) error) (cfg aws.Config, err error)

+ type ConfigurationLoader struct

+ func (cl ConfigurationLoader) LoadDefaultConfig(ctx context.Context, optFns ...func(*config.LoadOptions) error) (aws.Config, error)

Jul 5, 2023

Changes in this version

type ServicesV2

+ func (s *ServicesV2) AWSConfig() aws.Config

+ func (s *ServicesV2) CredentialsProvider() aws.CredentialsProvider

Apr 6, 2023

Changes in this version

+ func GetNodes(clientSet kubernetes.Interface, ng KubeNodeGroup) (int, error)

Jan 27, 2023

Changes in this version

type FargateClient

+ ListProfiles func(ctx context.Context) ([]string, error)

Sep 19, 2022

Changes in this version

type ServicesV2

+ func (s *ServicesV2) Outposts() awsapi.Outposts

Jul 8, 2022

Changes in this version

+ func CheckInstanceAvailability(ctx context.Context, spec *api.ClusterConfig, ec2API awsapi.EC2) error

Jun 3, 2022

Changes in this version

type KubeProvider

+ WaitForControlPlane func(meta *api.ClusterMeta, clientSet *kubewrapper.RawClient, ...) error

type KubernetesProvider

+ func (c *KubernetesProvider) WaitForControlPlane(meta *api.ClusterMeta, clientSet *kubewrapper.RawClient, ...) error

type ProviderStatus

+ SessionCreds SessionProvider

+ type SessionProvider interface

+ Get func() (credentials.Value, error)

May 27, 2022

Changes in this version

+ func DoAllNodegroupStackTasks(taskTree *tasks.TaskTree, region, name string) error

+ func GetUsername(roleArn string) string

+ func UpdateAuthConfigMap(ctx context.Context, nodeGroups []*api.NodeGroup, ...) error

+ func ValidateExistingNodeGroupsForCompatibility(ctx context.Context, cfg *api.ClusterConfig, stackManager manager.StackManager) error

+ func WaitForNodes(ctx context.Context, clientSet kubernetes.Interface, ng KubeNodeGroup) error

type ClusterProvider

+ AWSProvider api.ClusterProvider

type KubeProvider

+ NewStdClientSet func(spec *api.ClusterConfig) (*k8sclient.Clientset, error)

+ type KubernetesProvider struct

+ RoleARN string

+ Signer api.STSPresigner

+ WaitTimeout time.Duration

+ func (c *KubernetesProvider) NewClient(spec *api.ClusterConfig) (*Client, error)

+ func (c *KubernetesProvider) NewRawClient(spec *api.ClusterConfig) (*kubewrapper.RawClient, error)

+ func (c *KubernetesProvider) NewStdClientSet(spec *api.ClusterConfig) (*kubernetes.Clientset, error)

+ func (c *KubernetesProvider) ServerVersion(rawClient *kubewrapper.RawClient) (string, error)

type ProviderStatus

+ IAMRoleARN string

May 20, 2022

Changes in this version

type ServicesV2

+ func (s *ServicesV2) EKS() awsapi.EKS

May 13, 2022

Changes in this version

+ func ValidateLocalZones(ctx context.Context, ec2API awsapi.EC2, localZones []string, region string) error

Apr 28, 2022

Changes in this version

type ServicesV2

+ func (s *ServicesV2) CloudFormation() awsapi.CloudFormation

Apr 22, 2022

Changes in this version

type ServicesV2

+ func (s *ServicesV2) EC2() awsapi.EC2

+ func (s *ServicesV2) IAM() awsapi.IAM

type VPCControllerTask

+ Context context.Context

Apr 8, 2022

Changes in this version

type Client

+ Generator TokenGenerator

+ type Generator struct

+ func NewGenerator(client api.STSPresigner, clock credentials.Clock) Generator

+ func (g Generator) GetWithSTS(ctx context.Context, clusterID string) (Token, error)

type ServicesV2

+ func (s *ServicesV2) STS() awsapi.STS

+ func (s *ServicesV2) STSPresigner() api.STSPresigner

+ type Token struct

+ Expiration time.Time

+ Token string

+ type TokenGenerator interface

+ GetWithSTS func(ctx context.Context, clusterID string) (Token, error)

Apr 5, 2022

Changes in this version

type ServicesV2

+ func (s *ServicesV2) ELB() awsapi.ELB

+ func (s *ServicesV2) ELBV2() awsapi.ELBV2

+ func (s *ServicesV2) SSM() awsapi.SSM

Apr 1, 2022

Changes in this version

+ type RetryerV2 struct

+ func NewRetryerV2() *RetryerV2

+ func (r *RetryerV2) IsErrorRetryable(err error) bool

+ type ServicesV2 struct

+ func (s *ServicesV2) CloudFormationV2() awsapi.CloudFormation

+ func (s *ServicesV2) STSV2() awsapi.STS

Mar 11, 2022

Changes in this version

+ func SetAvailabilityZones(spec *api.ClusterConfig, given []string, ec2 ec2iface.EC2API, region string) error

Feb 25, 2022

Changes in this version

type ClusterProvider

+ func (c *ClusterProvider) CanOperateWithRefresh(spec *api.ClusterConfig) (bool, error)

Jan 21, 2022

Changes in this version

+ func LogEnabledFeatures(clusterConfig *api.ClusterConfig)

Nov 18, 2021

Changes in this version

+ type WindowsIPAMTask struct

+ ClientsetFunc func() (kubernetes.Interface, error)

+ Info string

+ func (w *WindowsIPAMTask) Describe() string

+ func (w *WindowsIPAMTask) Do(errCh chan error) error

Nov 10, 2021

Changes in this version

type ClusterProvider

+ func (c *ClusterProvider) RefreshClusterStatusIfStale(spec *api.ClusterConfig) error

type ProviderServices

+ func (p ProviderServices) CloudWatchLogs() cloudwatchlogsiface.CloudWatchLogsAPI

Jul 9, 2021

Changes in this version

+ func SelectInstanceType(np api.NodePool) string

Jun 11, 2021

Changes in this version

type ClusterProvider

+ func (c *ClusterProvider) ServerVersion(rawClient *kubewrapper.RawClient) (string, error)

+ func (c *ClusterProvider) UpdateAuthConfigMap(nodeGroups []*api.NodeGroup, clientSet kubernetes.Interface) error

+ type KubeProvider interface

+ LoadClusterIntoSpecFromStack func(spec *api.ClusterConfig, stackManager manager.StackManager) error

+ NewRawClient func(spec *api.ClusterConfig) (*kubewrapper.RawClient, error)

+ ServerVersion func(rawClient *kubernetes.RawClient) (string, error)

+ SupportsManagedNodes func(clusterConfig *api.ClusterConfig) (bool, error)

+ UpdateAuthConfigMap func(nodeGroups []*api.NodeGroup, clientSet kubernetes.Interface) error

+ ValidateClusterForCompatibility func(cfg *api.ClusterConfig, stackManager manager.StackManager) error

+ WaitForNodes func(clientSet kubernetes.Interface, ng KubeNodeGroup) error

+ type NodeGroupInitialiser interface

+ DoAllNodegroupStackTasks func(taskTree *tasks.TaskTree, region, name string) error

+ DoesAWSNodeUseIRSA func(provider api.ClusterProvider, clientSet kubernetes.Interface) (bool, error)

+ ExpandInstanceSelectorOptions func(nodePools []api.NodePool, clusterAZs []string) error

+ NewAWSSelectorSession func(provider api.ClusterProvider) *selector.Selector

+ Normalize func(nodePools []api.NodePool, clusterMeta *api.ClusterMeta) error

+ ValidateExistingNodeGroupsForCompatibility func(cfg *api.ClusterConfig, stackManager manager.StackManager) error

+ ValidateLegacySubnetsForNodeGroups func(spec *api.ClusterConfig, provider api.ClusterProvider) error

type NodeGroupService

+ Provider api.ClusterProvider

+ func (m *NodeGroupService) DoAllNodegroupStackTasks(taskTree *tasks.TaskTree, region, name string) error

+ func (m *NodeGroupService) NewAWSSelectorSession(provider api.ClusterProvider) *selector.Selector

+ func (m *NodeGroupService) ValidateExistingNodeGroupsForCompatibility(cfg *api.ClusterConfig, stackManager manager.StackManager) error

+ func (m *NodeGroupService) ValidateLegacySubnetsForNodeGroups(spec *api.ClusterConfig, provider api.ClusterProvider) error

+ func (n *NodeGroupService) DoesAWSNodeUseIRSA(provider api.ClusterProvider, clientSet kubernetes.Interface) (bool, error)

Apr 16, 2021

Changes in this version

+ type InstanceSelector interface

+ Filter func(selector.Filters) ([]string, error)

type ProviderServices

+ func (p ProviderServices) Session() *session.Session

Apr 7, 2021

Changes in this version

+ func ParseConfig(data []byte) (*api.ClusterConfig, error)

type NodeGroupService

+ func (m *NodeGroupService) ExpandInstanceSelectorOptions(nodePools []api.NodePool) error

Mar 4, 2021

Changes in this version

type ClusterProvider

+ func (c *ClusterProvider) ControlPlaneVPCInfo() eks.VpcConfigResponse

+ func (c *ClusterProvider) LoadClusterIntoSpecFromStack(spec *api.ClusterConfig, stackManager manager.StackManager) error

Feb 26, 2021

Changes in this version

+ func ValidateKMSSupport(clusterConfig *api.ClusterConfig, eksVersion string) error

type ClusterProvider

+ func (c *ClusterProvider) EnableKMSEncryption(ctx context.Context, clusterConfig *api.ClusterConfig) error

type LoggingRetryer

+ func (l LoggingRetryer) ShouldRetry(r *request.Request) bool

type ProviderServices

+ func (p ProviderServices) ASG() autoscalingiface.AutoScalingAPI

+ func (p ProviderServices) ConfigProvider() client.ConfigProvider

Jan 29, 2021

Changes in this version

+ func ClusterSupportsFargate(cluster *awseks.Cluster) (bool, error)

+ func ClusterSupportsManagedNodes(cluster *awseks.Cluster) (bool, error)

+ func DoCreateFargateProfiles(config *api.ClusterConfig, fargateClient FargateClient) error

+ func DoesAWSNodeUseIRSA(provider api.ClusterProvider, clientSet kubernetes.Interface) (bool, error)

+ func LoadConfigFromFile(configFile string) (*api.ClusterConfig, error)

+ func LogWindowsCompatibility(nodeGroups []KubeNodeGroup, clusterMeta *api.ClusterMeta)

+ func PlatformVersion(platformVersion string) (int, error)

+ func ResolveAMI(provider api.ClusterProvider, version string, ng *api.NodeGroup) error

+ func ScheduleCoreDNSOnFargateIfRelevant(config *api.ClusterConfig, ctl *ClusterProvider, ...) error

+ func SupportsWindowsWorkloads(nodeGroups []KubeNodeGroup) bool

+ func ValidateBottlerocketSupport(controlPlaneVersion string, kubeNodeGroups []KubeNodeGroup) error

+ func ValidateFeatureCompatibility(clusterConfig *api.ClusterConfig, kubeNodeGroups []KubeNodeGroup) error

+ func ValidateManagedNodesSupport(clusterConfig *api.ClusterConfig) error

+ func ValidateWindowsCompatibility(kubeNodeGroups []KubeNodeGroup, controlPlaneVersion string) error

+ func VersionSupportsManagedNodes(controlPlaneVersion string) (bool, error)

+ type Client struct

+ Config *clientcmdapi.Config

+ func (c *Client) NewClientSet() (*kubernetes.Clientset, error)

+ type ClusterInfo struct

+ Cluster *awseks.Cluster

+ type ClusterProvider struct

+ Provider api.ClusterProvider

+ Status *ProviderStatus

+ func New(spec *api.ProviderConfig, clusterSpec *api.ClusterConfig) *ClusterProvider

+ func (c *ClusterProvider) CanDelete(spec *api.ClusterConfig) (bool, error)

+ func (c *ClusterProvider) CanOperate(spec *api.ClusterConfig) (bool, error)

+ func (c *ClusterProvider) CanUpdate(spec *api.ClusterConfig) (bool, error)

+ func (c *ClusterProvider) CheckAuth() error

+ func (c *ClusterProvider) ClusterTasksForNodeGroups(cfg *api.ClusterConfig, ...) *tasks.TaskTree

+ func (c *ClusterProvider) ControlPlaneVersion() string

+ func (c *ClusterProvider) CreateExtraClusterConfigTasks(cfg *api.ClusterConfig, installVPCController bool) *tasks.TaskTree

+ func (c *ClusterProvider) DescribeControlPlane(meta *api.ClusterMeta) (*awseks.Cluster, error)

+ func (c *ClusterProvider) GetCluster(clusterName string) (*awseks.Cluster, error)

+ func (c *ClusterProvider) GetCredentialsEnv() ([]string, error)

+ func (c *ClusterProvider) GetCurrentClusterConfigForLogging(spec *api.ClusterConfig) (sets.String, sets.String, error)

+ func (c *ClusterProvider) GetCurrentClusterVPCConfig(spec *api.ClusterConfig) (*ClusterVPCConfig, error)

+ func (c *ClusterProvider) GetNodeGroupIAM(stackManager *manager.StackCollection, ng *api.NodeGroup) error

+ func (c *ClusterProvider) GetUsername() string

+ func (c *ClusterProvider) IsSupportedRegion() bool

+ func (c *ClusterProvider) ListClusters(chunkSize int, listAllRegions bool) ([]*api.ClusterConfig, error)

+ func (c *ClusterProvider) LoadClusterIntoSpec(spec *api.ClusterConfig) error

+ func (c *ClusterProvider) LoadClusterVPC(spec *api.ClusterConfig) error

+ func (c *ClusterProvider) NewClient(spec *api.ClusterConfig) (*Client, error)

+ func (c *ClusterProvider) NewOpenIDConnectManager(spec *api.ClusterConfig) (*iamoidc.OpenIDConnectManager, error)

+ func (c *ClusterProvider) NewRawClient(spec *api.ClusterConfig) (*kubewrapper.RawClient, error)

+ func (c *ClusterProvider) NewStackManager(spec *api.ClusterConfig) *manager.StackCollection

+ func (c *ClusterProvider) NewStdClientSet(spec *api.ClusterConfig) (*kubernetes.Clientset, error)

+ func (c *ClusterProvider) RefreshClusterStatus(spec *api.ClusterConfig) error

+ func (c *ClusterProvider) SetAvailabilityZones(spec *api.ClusterConfig, given []string) error

+ func (c *ClusterProvider) SupportsFargate(clusterConfig *api.ClusterConfig) (bool, error)

+ func (c *ClusterProvider) SupportsManagedNodes(clusterConfig *api.ClusterConfig) (bool, error)

+ func (c *ClusterProvider) UpdateClusterConfigForEndpoints(cfg *api.ClusterConfig) error

+ func (c *ClusterProvider) UpdateClusterConfigForLogging(cfg *api.ClusterConfig) error

+ func (c *ClusterProvider) UpdateClusterTags(cfg *api.ClusterConfig) error

+ func (c *ClusterProvider) UpdateClusterVersion(cfg *api.ClusterConfig) (*awseks.Update, error)

+ func (c *ClusterProvider) UpdateClusterVersionBlocking(cfg *api.ClusterConfig) error

+ func (c *ClusterProvider) UpdatePublicAccessCIDRs(clusterConfig *api.ClusterConfig) error

+ func (c *ClusterProvider) ValidateClusterForCompatibility(cfg *api.ClusterConfig, stackManager *manager.StackCollection) error

+ func (c *ClusterProvider) ValidateExistingNodeGroupsForCompatibility(cfg *api.ClusterConfig, stackManager *manager.StackCollection) error

+ func (c *ClusterProvider) WaitForControlPlane(meta *api.ClusterMeta, clientSet *kubernetes.Clientset) error

+ func (c *ClusterProvider) WaitForNodes(clientSet kubernetes.Interface, ng KubeNodeGroup) error

+ type ClusterVPCConfig struct

+ ClusterEndpoints *api.ClusterEndpoints

+ PublicAccessCIDRs []string

+ type FargateClient interface

+ CreateProfile func(profile *api.FargateProfile, waitForCreation bool) error

+ type KubeNodeGroup interface

+ GetAMIFamily func() string

+ ListOptions func() metav1.ListOptions

+ NameString func() string

+ Size func() int

+ type LoggingRetryer struct

+ func (l LoggingRetryer) RetryRules(r *request.Request) time.Duration

+ type NodeGroupService struct

+ func NewNodeGroupService(clusterConfig *api.ClusterConfig, provider api.ClusterProvider) *NodeGroupService

+ func (m *NodeGroupService) Normalize(nodePools []api.NodePool) error

+ type ProviderServices struct

+ func (p ProviderServices) CloudFormation() cloudformationiface.CloudFormationAPI

+ func (p ProviderServices) CloudFormationDisableRollback() bool

+ func (p ProviderServices) CloudFormationRoleARN() string

+ func (p ProviderServices) CloudTrail() cloudtrailiface.CloudTrailAPI

+ func (p ProviderServices) EC2() ec2iface.EC2API

+ func (p ProviderServices) EKS() eksiface.EKSAPI

+ func (p ProviderServices) ELB() elbiface.ELBAPI

+ func (p ProviderServices) ELBV2() elbv2iface.ELBV2API

+ func (p ProviderServices) IAM() iamiface.IAMAPI

+ func (p ProviderServices) Profile() string

+ func (p ProviderServices) Region() string

+ func (p ProviderServices) SSM() ssmiface.SSMAPI

+ func (p ProviderServices) STS() stsiface.STSAPI

+ func (p ProviderServices) WaitTimeout() time.Duration

+ type ProviderStatus struct

+ ClusterInfo *ClusterInfo

+ type UnsupportedOIDCError struct

+ func (u *UnsupportedOIDCError) Error() string

+ type VPCControllerTask struct

+ ClusterConfig *api.ClusterConfig

+ ClusterProvider *ClusterProvider

+ Info string

+ PlanMode bool

+ func (v *VPCControllerTask) Describe() string

+ func (v *VPCControllerTask) Do(errCh chan error) error