Documentation ¶
Index ¶
- Variables
- func NewEC2Client(scopeUser cloud.ScopeUsage, session cloud.Session, target runtime.Object) ec2iface.EC2API
- func NewEKSClient(scopeUser cloud.ScopeUsage, session cloud.Session, target runtime.Object) eksiface.EKSAPI
- func NewELBClient(scopeUser cloud.ScopeUsage, session cloud.Session, target runtime.Object) elbiface.ELBAPI
- func NewIAMClient(scopeUser cloud.ScopeUsage, session cloud.Session, target runtime.Object) iamiface.IAMAPI
- func NewResourgeTaggingClient(scopeUser cloud.ScopeUsage, session cloud.Session, target runtime.Object) resourcegroupstaggingapiiface.ResourceGroupsTaggingAPIAPI
- func NewSSMClient(scopeUser cloud.ScopeUsage, session cloud.Session, target runtime.Object) ssmiface.SSMAPI
- func NewSTSClient(scopeUser cloud.ScopeUsage, session cloud.Session, target runtime.Object) stsiface.STSAPI
- func NewSecretsManagerClient(scopeUser cloud.ScopeUsage, session cloud.Session, target runtime.Object) secretsmanageriface.SecretsManagerAPI
- type ClusterScope
- func (s *ClusterScope) APIServerPort() int32
- func (s *ClusterScope) AdditionalTags() infrav1.Tags
- func (s *ClusterScope) Bastion() *infrav1.Bastion
- func (s *ClusterScope) CNIIngressRules() infrav1.CNIIngressRules
- func (s *ClusterScope) Close() error
- func (s *ClusterScope) ControlPlaneConfigMapName() string
- func (s *ClusterScope) ControlPlaneLoadBalancer() *infrav1.AWSLoadBalancerSpec
- func (s *ClusterScope) ControlPlaneLoadBalancerScheme() infrav1.ClassicELBScheme
- func (s *ClusterScope) ControllerName() string
- func (s *ClusterScope) ImageLookupBaseOS() string
- func (s *ClusterScope) ImageLookupFormat() string
- func (s *ClusterScope) ImageLookupOrg() string
- func (s *ClusterScope) InfraCluster() cloud.ClusterObject
- func (s *ClusterScope) KubernetesClusterName() string
- func (s *ClusterScope) ListOptionsLabelSelector() client.ListOption
- func (s *ClusterScope) Name() string
- func (s *ClusterScope) Namespace() string
- func (s *ClusterScope) Network() *infrav1.Network
- func (s *ClusterScope) PatchObject() error
- func (s *ClusterScope) Region() string
- func (s *ClusterScope) SSHKeyName() *string
- func (s *ClusterScope) SecurityGroups() map[infrav1.SecurityGroupRole]infrav1.SecurityGroup
- func (s *ClusterScope) Session() awsclient.ConfigProvider
- func (s *ClusterScope) SetBastionInstance(instance *infrav1.Instance)
- func (s *ClusterScope) SetFailureDomain(id string, spec clusterv1.FailureDomainSpec)
- func (s *ClusterScope) SetSubnets(subnets infrav1.Subnets)
- func (s *ClusterScope) Subnets() infrav1.Subnets
- func (s *ClusterScope) VPC() *infrav1.VPCSpec
- type ClusterScopeGetter
- type ClusterScopeGetterFunc
- type ClusterScopeParams
- type EC2Scope
- type ELBScope
- type MachineScope
- func (m *MachineScope) AWSMachineIsDeleted() bool
- func (m *MachineScope) AdditionalTags() infrav1.Tags
- func (m *MachineScope) Close() error
- func (m *MachineScope) DeleteSecretPrefix()
- func (m *MachineScope) GetBootstrapData() (string, error)
- func (m *MachineScope) GetInstanceID() *string
- func (m *MachineScope) GetInstanceState() *infrav1.InstanceState
- func (m *MachineScope) GetProviderID() string
- func (m *MachineScope) GetRawBootstrapData() ([]byte, error)
- func (m *MachineScope) GetSecretCount() int32
- func (m *MachineScope) GetSecretPrefix() string
- func (m *MachineScope) HasFailed() bool
- func (m *MachineScope) InstanceIsInKnownState() bool
- func (m *MachineScope) InstanceIsOperational() bool
- func (m *MachineScope) InstanceIsRunning() bool
- func (m *MachineScope) IsControlPlane() bool
- func (m *MachineScope) IsEKSManaged() bool
- func (m *MachineScope) Name() string
- func (m *MachineScope) Namespace() string
- func (m *MachineScope) PatchObject() error
- func (m *MachineScope) Role() string
- func (m *MachineScope) SetAddresses(addrs []clusterv1.MachineAddress)
- func (m *MachineScope) SetAnnotation(key, value string)
- func (m *MachineScope) SetFailureMessage(v error)
- func (m *MachineScope) SetFailureReason(v capierrors.MachineStatusError)
- func (m *MachineScope) SetInstanceState(v infrav1.InstanceState)
- func (m *MachineScope) SetNotReady()
- func (m *MachineScope) SetProviderID(instanceID, availabilityZone string)
- func (m *MachineScope) SetReady()
- func (m *MachineScope) SetSecretCount(i int32)
- func (m *MachineScope) SetSecretPrefix(value string)
- func (m *MachineScope) UseSecretsManager() bool
- func (m *MachineScope) UserDataIsUncompressed() bool
- type MachineScopeGetter
- type MachineScopeGetterFunc
- type MachineScopeParams
- type ManagedControlPlaneScope
- func (s *ManagedControlPlaneScope) APIServerPort() int32
- func (s *ManagedControlPlaneScope) AdditionalTags() infrav1.Tags
- func (s *ManagedControlPlaneScope) AllowAdditionalRoles() bool
- func (s *ManagedControlPlaneScope) Bastion() *infrav1.Bastion
- func (s *ManagedControlPlaneScope) CNIIngressRules() infrav1.CNIIngressRules
- func (s *ManagedControlPlaneScope) Close() error
- func (s *ManagedControlPlaneScope) ControllerName() string
- func (s *ManagedControlPlaneScope) EnableIAM() bool
- func (s *ManagedControlPlaneScope) ImageLookupBaseOS() string
- func (s *ManagedControlPlaneScope) ImageLookupFormat() string
- func (s *ManagedControlPlaneScope) ImageLookupOrg() string
- func (s *ManagedControlPlaneScope) InfraCluster() cloud.ClusterObject
- func (s *ManagedControlPlaneScope) KubernetesClusterName() string
- func (s *ManagedControlPlaneScope) ListOptionsLabelSelector() client.ListOption
- func (s *ManagedControlPlaneScope) Name() string
- func (s *ManagedControlPlaneScope) Namespace() string
- func (s *ManagedControlPlaneScope) Network() *infrav1.Network
- func (s *ManagedControlPlaneScope) PatchObject() error
- func (s *ManagedControlPlaneScope) Region() string
- func (s *ManagedControlPlaneScope) SSHKeyName() *string
- func (s *ManagedControlPlaneScope) SecurityGroups() map[infrav1.SecurityGroupRole]infrav1.SecurityGroup
- func (s *ManagedControlPlaneScope) Session() awsclient.ConfigProvider
- func (s *ManagedControlPlaneScope) SetBastionInstance(instance *infrav1.Instance)
- func (s *ManagedControlPlaneScope) SetFailureDomain(id string, spec clusterv1.FailureDomainSpec)
- func (s *ManagedControlPlaneScope) SetSubnets(subnets infrav1.Subnets)
- func (s *ManagedControlPlaneScope) Subnets() infrav1.Subnets
- func (s *ManagedControlPlaneScope) TokenMethod() infrav1exp.EKSTokenMethod
- func (s *ManagedControlPlaneScope) VPC() *infrav1.VPCSpec
- type ManagedControlPlaneScopeParams
Constants ¶
This section is empty.
Variables ¶
var ( DefaultClusterScopeGetter ClusterScopeGetter = ClusterScopeGetterFunc(NewClusterScope) DefaultMachineScopeGetter MachineScopeGetter = MachineScopeGetterFunc(NewMachineScope) )
Functions ¶
func NewEC2Client ¶ added in v0.5.5
func NewEC2Client(scopeUser cloud.ScopeUsage, session cloud.Session, target runtime.Object) ec2iface.EC2API
NewEC2Client creates a new EC2 API client for a given session
func NewEKSClient ¶ added in v0.6.0
func NewEKSClient(scopeUser cloud.ScopeUsage, session cloud.Session, target runtime.Object) eksiface.EKSAPI
NewEKSClient creates a new EKS API client for a given session
func NewELBClient ¶ added in v0.5.5
func NewELBClient(scopeUser cloud.ScopeUsage, session cloud.Session, target runtime.Object) elbiface.ELBAPI
NewELBClient creates a new ELB API client for a given session
func NewIAMClient ¶ added in v0.6.0
func NewIAMClient(scopeUser cloud.ScopeUsage, session cloud.Session, target runtime.Object) iamiface.IAMAPI
NewIAMClient creates a new IAM API client for a given session
func NewResourgeTaggingClient ¶ added in v0.5.5
func NewResourgeTaggingClient(scopeUser cloud.ScopeUsage, session cloud.Session, target runtime.Object) resourcegroupstaggingapiiface.ResourceGroupsTaggingAPIAPI
NewResourgeTaggingClient creates a new Resource Tagging API client for a given session
func NewSSMClient ¶ added in v0.6.0
func NewSSMClient(scopeUser cloud.ScopeUsage, session cloud.Session, target runtime.Object) ssmiface.SSMAPI
NewSSMClient creates a new Secrets API client for a given session
func NewSTSClient ¶ added in v0.6.0
func NewSTSClient(scopeUser cloud.ScopeUsage, session cloud.Session, target runtime.Object) stsiface.STSAPI
NewSTSClient creates a new STS API client for a given session
func NewSecretsManagerClient ¶ added in v0.5.5
func NewSecretsManagerClient(scopeUser cloud.ScopeUsage, session cloud.Session, target runtime.Object) secretsmanageriface.SecretsManagerAPI
NewSecretsManagerClient creates a new Secrets API client for a given session
Types ¶
type ClusterScope ¶
type ClusterScope struct { logr.Logger Cluster *clusterv1.Cluster AWSCluster *infrav1.AWSCluster // contains filtered or unexported fields }
ClusterScope defines the basic context for an actuator to operate upon.
func NewClusterScope ¶
func NewClusterScope(params ClusterScopeParams) (*ClusterScope, error)
NewClusterScope creates a new Scope from the supplied parameters. This is meant to be called for each reconcile iteration.
func (*ClusterScope) APIServerPort ¶ added in v0.4.1
func (s *ClusterScope) APIServerPort() int32
APIServerPort returns the APIServerPort to use when creating the load balancer.
func (*ClusterScope) AdditionalTags ¶ added in v0.4.1
func (s *ClusterScope) AdditionalTags() infrav1.Tags
AdditionalTags returns AdditionalTags from the scope's AWSCluster. The returned value will never be nil.
func (*ClusterScope) Bastion ¶ added in v0.5.5
func (s *ClusterScope) Bastion() *infrav1.Bastion
Bastion returns the bastion details.
func (*ClusterScope) CNIIngressRules ¶ added in v0.5.5
func (s *ClusterScope) CNIIngressRules() infrav1.CNIIngressRules
CNIIngressRules returns the CNI spec ingress rules.
func (*ClusterScope) Close ¶
func (s *ClusterScope) Close() error
Close closes the current scope persisting the cluster configuration and status.
func (*ClusterScope) ControlPlaneConfigMapName ¶
func (s *ClusterScope) ControlPlaneConfigMapName() string
ControlPlaneConfigMapName returns the name of the ConfigMap used to coordinate the bootstrapping of control plane nodes.
func (*ClusterScope) ControlPlaneLoadBalancer ¶ added in v0.4.3
func (s *ClusterScope) ControlPlaneLoadBalancer() *infrav1.AWSLoadBalancerSpec
ControlPlaneLoadBalancer returns the AWSLoadBalancerSpec
func (*ClusterScope) ControlPlaneLoadBalancerScheme ¶ added in v0.4.3
func (s *ClusterScope) ControlPlaneLoadBalancerScheme() infrav1.ClassicELBScheme
ControlPlaneLoadBalancerScheme returns the Classic ELB scheme (public or internal facing)
func (*ClusterScope) ControllerName ¶ added in v0.5.5
func (s *ClusterScope) ControllerName() string
ControllerName returns the name of the controller that created the ClusterScope.
func (*ClusterScope) ImageLookupBaseOS ¶ added in v0.6.0
func (s *ClusterScope) ImageLookupBaseOS() string
ImageLookupBaseOS returns the base operating system name to use when looking up AMIs
func (*ClusterScope) ImageLookupFormat ¶ added in v0.6.0
func (s *ClusterScope) ImageLookupFormat() string
ImageLookupFormat returns the format string to use when looking up AMIs
func (*ClusterScope) ImageLookupOrg ¶ added in v0.6.0
func (s *ClusterScope) ImageLookupOrg() string
ImageLookupOrg returns the organization name to use when looking up AMIs
func (*ClusterScope) InfraCluster ¶ added in v0.5.5
func (s *ClusterScope) InfraCluster() cloud.ClusterObject
InfraCluster returns the AWS infrastructure cluster or control plane object.
func (*ClusterScope) KubernetesClusterName ¶ added in v0.6.0
func (s *ClusterScope) KubernetesClusterName() string
KubernetesClusterName is the name of the Kubernetes cluster. For the cluster scope this is the same as the CAPI cluster name
func (*ClusterScope) ListOptionsLabelSelector ¶
func (s *ClusterScope) ListOptionsLabelSelector() client.ListOption
ListOptionsLabelSelector returns a ListOptions with a label selector for clusterName.
func (*ClusterScope) Name ¶
func (s *ClusterScope) Name() string
Name returns the CAPI cluster name.
func (*ClusterScope) Namespace ¶
func (s *ClusterScope) Namespace() string
Namespace returns the cluster namespace.
func (*ClusterScope) Network ¶
func (s *ClusterScope) Network() *infrav1.Network
Network returns the cluster network object.
func (*ClusterScope) PatchObject ¶ added in v0.5.0
func (s *ClusterScope) PatchObject() error
PatchObject persists the cluster configuration and status.
func (*ClusterScope) Region ¶
func (s *ClusterScope) Region() string
Region returns the cluster region.
func (*ClusterScope) SSHKeyName ¶ added in v0.5.5
func (s *ClusterScope) SSHKeyName() *string
SSHKeyName returns the SSH key name to use for instances.
func (*ClusterScope) SecurityGroups ¶
func (s *ClusterScope) SecurityGroups() map[infrav1.SecurityGroupRole]infrav1.SecurityGroup
SecurityGroups returns the cluster security groups as a map, it creates the map if empty.
func (*ClusterScope) Session ¶ added in v0.5.5
func (s *ClusterScope) Session() awsclient.ConfigProvider
Session returns the AWS SDK session. Used for creating clients
func (*ClusterScope) SetBastionInstance ¶ added in v0.5.5
func (s *ClusterScope) SetBastionInstance(instance *infrav1.Instance)
SetBastionInstance sets the bastion instance in the status of the cluster.
func (*ClusterScope) SetFailureDomain ¶ added in v0.5.0
func (s *ClusterScope) SetFailureDomain(id string, spec clusterv1.FailureDomainSpec)
SetFailureDomain sets the infrastructure provider failure domain key to the spec given as input.
func (*ClusterScope) SetSubnets ¶ added in v0.5.5
func (s *ClusterScope) SetSubnets(subnets infrav1.Subnets)
SetSubnets updates the clusters subnets.
func (*ClusterScope) Subnets ¶
func (s *ClusterScope) Subnets() infrav1.Subnets
Subnets returns the cluster subnets.
func (*ClusterScope) VPC ¶
func (s *ClusterScope) VPC() *infrav1.VPCSpec
VPC returns the cluster VPC.
type ClusterScopeGetter ¶
type ClusterScopeGetter interface {
ClusterScope(params ClusterScopeParams) (*ClusterScope, error)
}
type ClusterScopeGetterFunc ¶
type ClusterScopeGetterFunc func(params ClusterScopeParams) (*ClusterScope, error)
func (ClusterScopeGetterFunc) ClusterScope ¶
func (f ClusterScopeGetterFunc) ClusterScope(params ClusterScopeParams) (*ClusterScope, error)
type ClusterScopeParams ¶
type ClusterScopeParams struct { Client client.Client Logger logr.Logger Cluster *clusterv1.Cluster AWSCluster *infrav1.AWSCluster ControllerName string Session awsclient.ConfigProvider }
ClusterScopeParams defines the input parameters used to create a new Scope.
type EC2Scope ¶ added in v0.6.0
type EC2Scope interface { cloud.ClusterScoper // VPC returns the cluster VPC. VPC() *infrav1.VPCSpec // Subnets returns the cluster subnets. Subnets() infrav1.Subnets // Network returns the cluster network object. Network() *infrav1.Network // SecurityGroups returns the cluster security groups as a map, it creates the map if empty. SecurityGroups() map[infrav1.SecurityGroupRole]infrav1.SecurityGroup // Bastion returns the bastion details for the cluster. Bastion() *infrav1.Bastion // SetBastionInstance sets the bastion instance in the status of the cluster. SetBastionInstance(instance *infrav1.Instance) // SSHKeyName returns the SSH key name to use for instances. SSHKeyName() *string // ImageLookupFormat returns the format string to use when looking up AMIs ImageLookupFormat() string // ImageLookupOrg returns the organization name to use when looking up AMIs ImageLookupOrg() string // ImageLookupBaseOS returns the base operating system name to use when looking up AMIs ImageLookupBaseOS() string }
Scope is the interface for the scoep to be used with the ec2 service
type ELBScope ¶ added in v0.6.0
type ELBScope interface { cloud.ClusterScoper // Network returns the cluster network object. Network() *infrav1.Network // Subnets returns the cluster subnets. Subnets() infrav1.Subnets // SecurityGroups returns the cluster security groups as a map, it creates the map if empty. SecurityGroups() map[infrav1.SecurityGroupRole]infrav1.SecurityGroup // VPC returns the cluster VPC. VPC() *infrav1.VPCSpec // ControlPlaneLoadBalancer returns the AWSLoadBalancerSpec ControlPlaneLoadBalancer() *infrav1.AWSLoadBalancerSpec // ControlPlaneLoadBalancerScheme returns the Classic ELB scheme (public or internal facing) ControlPlaneLoadBalancerScheme() infrav1.ClassicELBScheme }
Scope is a scope for use with the ELB reconciling service
type MachineScope ¶
type MachineScope struct { logr.Logger Cluster *clusterv1.Cluster Machine *clusterv1.Machine InfraCluster EC2Scope AWSMachine *infrav1.AWSMachine // contains filtered or unexported fields }
MachineScope defines a scope defined around a machine and its cluster.
func NewMachineScope ¶
func NewMachineScope(params MachineScopeParams) (*MachineScope, error)
NewMachineScope creates a new MachineScope from the supplied parameters. This is meant to be called for each reconcile iteration.
func (*MachineScope) AWSMachineIsDeleted ¶ added in v0.4.9
func (m *MachineScope) AWSMachineIsDeleted() bool
func (*MachineScope) AdditionalTags ¶ added in v0.4.1
func (m *MachineScope) AdditionalTags() infrav1.Tags
AdditionalTags merges AdditionalTags from the scope's AWSCluster and AWSMachine. If the same key is present in both, the value from AWSMachine takes precedence. The returned Tags will never be nil.
func (*MachineScope) Close ¶
func (m *MachineScope) Close() error
Close the MachineScope by updating the machine spec, machine status.
func (*MachineScope) DeleteSecretPrefix ¶ added in v0.4.9
func (m *MachineScope) DeleteSecretPrefix()
DeleteSecretPrefix deletes the prefix for the secret belonging to the AWSMachine in AWS Secrets Manager
func (*MachineScope) GetBootstrapData ¶ added in v0.4.9
func (m *MachineScope) GetBootstrapData() (string, error)
GetBootstrapData returns the bootstrap data from the secret in the Machine's bootstrap.dataSecretName as base64.
func (*MachineScope) GetInstanceID ¶
func (m *MachineScope) GetInstanceID() *string
GetInstanceID returns the AWSMachine instance id by parsing Spec.ProviderID.
func (*MachineScope) GetInstanceState ¶
func (m *MachineScope) GetInstanceState() *infrav1.InstanceState
GetInstanceState returns the AWSMachine instance state from the status.
func (*MachineScope) GetProviderID ¶
func (m *MachineScope) GetProviderID() string
GetProviderID returns the AWSMachine providerID from the spec.
func (*MachineScope) GetRawBootstrapData ¶ added in v0.4.9
func (m *MachineScope) GetRawBootstrapData() ([]byte, error)
GetRawBootstrapData returns the bootstrap data from the secret in the Machine's bootstrap.dataSecretName.
func (*MachineScope) GetSecretCount ¶ added in v0.4.9
func (m *MachineScope) GetSecretCount() int32
GetSecretCount returns the number of AWS Secret Manager entries making up the complete userdata
func (*MachineScope) GetSecretPrefix ¶ added in v0.4.9
func (m *MachineScope) GetSecretPrefix() string
GetSecretPrefix returns the prefix for the secrets belonging to the AWSMachine in AWS Secrets Manager
func (*MachineScope) HasFailed ¶ added in v0.4.9
func (m *MachineScope) HasFailed() bool
func (*MachineScope) InstanceIsInKnownState ¶ added in v0.4.9
func (m *MachineScope) InstanceIsInKnownState() bool
func (*MachineScope) InstanceIsOperational ¶ added in v0.4.9
func (m *MachineScope) InstanceIsOperational() bool
func (*MachineScope) InstanceIsRunning ¶ added in v0.5.4
func (m *MachineScope) InstanceIsRunning() bool
func (*MachineScope) IsControlPlane ¶
func (m *MachineScope) IsControlPlane() bool
IsControlPlane returns true if the machine is a control plane.
func (*MachineScope) IsEKSManaged ¶ added in v0.6.0
func (m *MachineScope) IsEKSManaged() bool
func (*MachineScope) Namespace ¶
func (m *MachineScope) Namespace() string
Namespace returns the namespace name.
func (*MachineScope) PatchObject ¶ added in v0.4.9
func (m *MachineScope) PatchObject() error
PatchObject persists the machine spec and status.
func (*MachineScope) Role ¶
func (m *MachineScope) Role() string
Role returns the machine role from the labels.
func (*MachineScope) SetAddresses ¶ added in v0.5.0
func (m *MachineScope) SetAddresses(addrs []clusterv1.MachineAddress)
SetAddresses sets the AWSMachine address status.
func (*MachineScope) SetAnnotation ¶
func (m *MachineScope) SetAnnotation(key, value string)
SetAnnotation sets a key value annotation on the AWSMachine.
func (*MachineScope) SetFailureMessage ¶ added in v0.5.0
func (m *MachineScope) SetFailureMessage(v error)
SetFailureMessage sets the AWSMachine status failure message.
func (*MachineScope) SetFailureReason ¶ added in v0.5.0
func (m *MachineScope) SetFailureReason(v capierrors.MachineStatusError)
SetFailureReason sets the AWSMachine status failure reason.
func (*MachineScope) SetInstanceState ¶
func (m *MachineScope) SetInstanceState(v infrav1.InstanceState)
SetInstanceState sets the AWSMachine status instance state.
func (*MachineScope) SetNotReady ¶ added in v0.5.0
func (m *MachineScope) SetNotReady()
SetNotReady sets the AWSMachine Ready Status to false
func (*MachineScope) SetProviderID ¶
func (m *MachineScope) SetProviderID(instanceID, availabilityZone string)
SetProviderID sets the AWSMachine providerID in spec.
func (*MachineScope) SetReady ¶
func (m *MachineScope) SetReady()
SetReady sets the AWSMachine Ready Status
func (*MachineScope) SetSecretCount ¶ added in v0.4.9
func (m *MachineScope) SetSecretCount(i int32)
SetSecretCount sets the number of AWS Secret Manager entries making up the complete userdata
func (*MachineScope) SetSecretPrefix ¶ added in v0.4.9
func (m *MachineScope) SetSecretPrefix(value string)
SetSecretPrefix sets the prefix for the secrets belonging to the AWSMachine in AWS Secrets Manager
func (*MachineScope) UseSecretsManager ¶ added in v0.4.9
func (m *MachineScope) UseSecretsManager() bool
UseSecretsManager returns the computed value of whether or not userdata should be stored using AWS Secrets Manager.
func (*MachineScope) UserDataIsUncompressed ¶ added in v0.5.2
func (m *MachineScope) UserDataIsUncompressed() bool
UserDataIsCompressed returns the computed value of whether or not userdata should be compressed using gzip.
type MachineScopeGetter ¶
type MachineScopeGetter interface {
MachineScope(params MachineScopeParams) (*MachineScope, error)
}
type MachineScopeGetterFunc ¶
type MachineScopeGetterFunc func(params MachineScopeParams) (*MachineScope, error)
func (MachineScopeGetterFunc) MachineScope ¶
func (f MachineScopeGetterFunc) MachineScope(params MachineScopeParams) (*MachineScope, error)
type MachineScopeParams ¶
type MachineScopeParams struct { Client client.Client Logger logr.Logger Cluster *clusterv1.Cluster Machine *clusterv1.Machine InfraCluster EC2Scope AWSMachine *infrav1.AWSMachine }
MachineScopeParams defines the input parameters used to create a new MachineScope.
type ManagedControlPlaneScope ¶ added in v0.6.0
type ManagedControlPlaneScope struct { logr.Logger Client client.Client Cluster *clusterv1.Cluster ControlPlane *infrav1exp.AWSManagedControlPlane // contains filtered or unexported fields }
ManagedControlPlaneScope defines the basic context for an actuator to operate upon.
func NewManagedControlPlaneScope ¶ added in v0.6.0
func NewManagedControlPlaneScope(params ManagedControlPlaneScopeParams) (*ManagedControlPlaneScope, error)
NewManagedControlPlaneScope creates a new Scope from the supplied parameters. This is meant to be called for each reconcile iteration.
func (*ManagedControlPlaneScope) APIServerPort ¶ added in v0.6.0
func (s *ManagedControlPlaneScope) APIServerPort() int32
APIServerPort returns the port to use when communicating with the API server
func (*ManagedControlPlaneScope) AdditionalTags ¶ added in v0.6.0
func (s *ManagedControlPlaneScope) AdditionalTags() infrav1.Tags
AdditionalTags returns AdditionalTags from the scope's EksControlPlane. The returned value will never be nil.
func (*ManagedControlPlaneScope) AllowAdditionalRoles ¶ added in v0.6.0
func (s *ManagedControlPlaneScope) AllowAdditionalRoles() bool
AllowAdditionalRoles indicates if additional roles can be added to the created IAM roles
func (*ManagedControlPlaneScope) Bastion ¶ added in v0.6.0
func (s *ManagedControlPlaneScope) Bastion() *infrav1.Bastion
Bastion returns the bastion details.
func (*ManagedControlPlaneScope) CNIIngressRules ¶ added in v0.6.0
func (s *ManagedControlPlaneScope) CNIIngressRules() infrav1.CNIIngressRules
CNIIngressRules returns the CNI spec ingress rules.
func (*ManagedControlPlaneScope) Close ¶ added in v0.6.0
func (s *ManagedControlPlaneScope) Close() error
Close closes the current scope persisting the control plane configuration and status.
func (*ManagedControlPlaneScope) ControllerName ¶ added in v0.6.0
func (s *ManagedControlPlaneScope) ControllerName() string
ControllerName returns the name of the controller that created the ManagedControlPlane.
func (*ManagedControlPlaneScope) EnableIAM ¶ added in v0.6.0
func (s *ManagedControlPlaneScope) EnableIAM() bool
EnableIAM indicates that reconciliation should create IAM roles
func (*ManagedControlPlaneScope) ImageLookupBaseOS ¶ added in v0.6.0
func (s *ManagedControlPlaneScope) ImageLookupBaseOS() string
ImageLookupBaseOS returns the base operating system name to use when looking up AMIs
func (*ManagedControlPlaneScope) ImageLookupFormat ¶ added in v0.6.0
func (s *ManagedControlPlaneScope) ImageLookupFormat() string
ImageLookupFormat returns the format string to use when looking up AMIs
func (*ManagedControlPlaneScope) ImageLookupOrg ¶ added in v0.6.0
func (s *ManagedControlPlaneScope) ImageLookupOrg() string
ImageLookupOrg returns the organization name to use when looking up AMIs
func (*ManagedControlPlaneScope) InfraCluster ¶ added in v0.6.0
func (s *ManagedControlPlaneScope) InfraCluster() cloud.ClusterObject
InfraCluster returns the AWS infrastructure cluster or control plane object.
func (*ManagedControlPlaneScope) KubernetesClusterName ¶ added in v0.6.0
func (s *ManagedControlPlaneScope) KubernetesClusterName() string
KubernetesClusterName is the name of the Kubernetes cluster. For the managed scope this is the different to the CAPI cluster name and is the EKS cluster name
func (*ManagedControlPlaneScope) ListOptionsLabelSelector ¶ added in v0.6.0
func (s *ManagedControlPlaneScope) ListOptionsLabelSelector() client.ListOption
ListOptionsLabelSelector returns a ListOptions with a label selector for clusterName.
func (*ManagedControlPlaneScope) Name ¶ added in v0.6.0
func (s *ManagedControlPlaneScope) Name() string
Name returns the CAPI cluster name.
func (*ManagedControlPlaneScope) Namespace ¶ added in v0.6.0
func (s *ManagedControlPlaneScope) Namespace() string
Namespace returns the cluster namespace.
func (*ManagedControlPlaneScope) Network ¶ added in v0.6.0
func (s *ManagedControlPlaneScope) Network() *infrav1.Network
Network returns the control plane network object.
func (*ManagedControlPlaneScope) PatchObject ¶ added in v0.6.0
func (s *ManagedControlPlaneScope) PatchObject() error
PatchObject persists the control plane configuration and status.
func (*ManagedControlPlaneScope) Region ¶ added in v0.6.0
func (s *ManagedControlPlaneScope) Region() string
Region returns the cluster region.
func (*ManagedControlPlaneScope) SSHKeyName ¶ added in v0.6.0
func (s *ManagedControlPlaneScope) SSHKeyName() *string
SSHKeyName returns the SSH key name to use for instances.
func (*ManagedControlPlaneScope) SecurityGroups ¶ added in v0.6.0
func (s *ManagedControlPlaneScope) SecurityGroups() map[infrav1.SecurityGroupRole]infrav1.SecurityGroup
SecurityGroups returns the control plane security groups as a map, it creates the map if empty.
func (*ManagedControlPlaneScope) Session ¶ added in v0.6.0
func (s *ManagedControlPlaneScope) Session() awsclient.ConfigProvider
Session returns the AWS SDK session. Used for creating clients
func (*ManagedControlPlaneScope) SetBastionInstance ¶ added in v0.6.0
func (s *ManagedControlPlaneScope) SetBastionInstance(instance *infrav1.Instance)
SetBastionInstance sets the bastion instance in the status of the cluster.
func (*ManagedControlPlaneScope) SetFailureDomain ¶ added in v0.6.0
func (s *ManagedControlPlaneScope) SetFailureDomain(id string, spec clusterv1.FailureDomainSpec)
SetFailureDomain sets the infrastructure provider failure domain key to the spec given as input.
func (*ManagedControlPlaneScope) SetSubnets ¶ added in v0.6.0
func (s *ManagedControlPlaneScope) SetSubnets(subnets infrav1.Subnets)
SetSubnets updates the control planes subnets.
func (*ManagedControlPlaneScope) Subnets ¶ added in v0.6.0
func (s *ManagedControlPlaneScope) Subnets() infrav1.Subnets
Subnets returns the control plane subnets.
func (*ManagedControlPlaneScope) TokenMethod ¶ added in v0.6.0
func (s *ManagedControlPlaneScope) TokenMethod() infrav1exp.EKSTokenMethod
TokenMethod returns the token method to use in the kubeconfig
func (*ManagedControlPlaneScope) VPC ¶ added in v0.6.0
func (s *ManagedControlPlaneScope) VPC() *infrav1.VPCSpec
VPC returns the control plane VPC.
type ManagedControlPlaneScopeParams ¶ added in v0.6.0
type ManagedControlPlaneScopeParams struct { Client client.Client Logger logr.Logger Cluster *clusterv1.Cluster ControlPlane *infrav1exp.AWSManagedControlPlane ControllerName string Session awsclient.ConfigProvider EnableIAM bool AllowAdditionalRoles bool }
ManagedControlPlaneScopeParams defines the input parameters used to create a new Scope.