key

package
v12.1.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	// CloudConfigVersion defines the version of k8scloudconfig in use. It is used
	// in the main stack output and S3 object paths.
	CloudConfigVersion = "v_6_1_0"
	CloudProvider      = "aws"
)
View Source 
const (
	EC2RoleK8s   = "EC2-K8S-Role"
	EC2PolicyK8s = "EC2-K8S-Policy"
)
View Source 
const (
	EtcdPort                     = 2379
	EtcdPrefix                   = "giantswarm.io"
	KubernetesSecurePort         = 443
	KubernetesApiHealthCheckPort = 8089
)
View Source 
const (
	// KubernetesAPIHealthzVersion is a tag representing the version of
	// https://github.com/giantswarm/k8s-api-healthz/ used.
	KubernetesAPIHealthzVersion = "0.1.1"
	// K8sSetupNetworkEnvironment is a tag representing the version of
	// https://github.com/giantswarm/k8s-setup-network-environment used.
	K8sSetupNetworkEnvironment = "0.2.0"
)
View Source 
const (
	TagAvailabilityZone  = "giantswarm.io/availability-zone"
	TagCluster           = "giantswarm.io/cluster"
	TagClusterType       = "giantswarm.io/cluster-type"
	TagControlPlane      = "giantswarm.io/control-plane"
	TagInstallation      = "giantswarm.io/installation"
	TagMachineDeployment = "giantswarm.io/machine-deployment"
	TagName              = "Name"
	TagOrganization      = "giantswarm.io/organization"
	TagRouteTableType    = "giantswarm.io/route-table-type"
	TagStack             = "giantswarm.io/stack"
	TagSnapshot          = "giantswarm.io/snapshot"
	TagSubnetType        = "giantswarm.io/subnet-type"
)

AWS Tags used for cost analysis and general resource tagging.

View Source 
const (
	StackTCCP  = "tccp"
	StackTCCPF = "tccpf"
	StackTCCPI = "tccpi"
	StackTCCPN = "tccpn"
	StackTCNP  = "tcnp"
	StackTCNPF = "tcnpf"
)
View Source 
const (
	LifeCycleHookControlPlane = "ControlPlane"
	LifeCycleHookNodePool     = "NodePool"
)
View Source 
const (
	AWSCNIComponentName          = "aws-cni"
	AWSCNIDefaultMinimumIPTarget = "40"
	AWSCNIDefaultWarmIPTarget    = "10"

	AWSCloudControllerManager = "aws-cloud-controller-manager"

	ELBInstanceStateInService = "InService"

	DrainerResyncPeriod = time.Minute * 2

	DefaultPauseTimeBetweenUpdates = "PT10M"

	NodeRoleLabel       = "kubernetes.io/role"
	MasterNodeRoleLabel = "master"

	EncryptionProviderConfig = "encryption"

	ServiceAccountV2Pub  = "pub"
	ServiceAccountV2Priv = "key"
)
View Source 
const (
	// ComponentOS is the name of the component specified in a Release CR which
	// determines the version of the OS to be used for tenant cluster nodes and
	// is ultimately transformed into an AMI based on TC region.
	ComponentOS = "containerlinux"
)
View Source 
const (
	HAMasterSnapshotIDValue = "ha-master-migration"
)
View Source 
const KeyCloudPrefix = "tag.provider.giantswarm.io/"
View Source 
const (
	RefWorkerASG = "workerAutoScalingGroup"
)
View Source 
const (
	// TerminateUnhealthyNodeResyncPeriod defines resync period for the terminateunhealthynode controller
	TerminateUnhealthyNodeResyncPeriod = time.Minute * 3
)

Variables

This section is empty.

Functions

func AMI 

func AMI(region string, release releasev1alpha1.Release) (string, error)

AMI returns the EC2 AMI for the configured region and given version.

func AWSBaseDomain 

func AWSBaseDomain(region string) string

func AWSCNINATRouteName 

func AWSCNINATRouteName(az string) string

func AWSCNIRouteTableName 

func AWSCNIRouteTableName(az string) string

func AWSCNISubnetName 

func AWSCNISubnetName(az string) string

func AWSCNISubnetRouteTableAssociationName 

func AWSCNISubnetRouteTableAssociationName(az string) string

func AWSTags 

func AWSTags(getter LabelsGetter, installationName string) map[string]string

func AvailabilityZoneRegionSuffix 

func AvailabilityZoneRegionSuffix(az string) string

AvailabilityZoneRegionSuffix takes region's full name and returns its suffix: e.g. "eu-central-1b" -> "1b"

func BucketName 

func BucketName(getter LabelsGetter, accountID string) string

func CloudConfigSmallTemplates 

func CloudConfigSmallTemplates() []string

func ClusterAPIEndpoint 

func ClusterAPIEndpoint(cluster infrastructurev1alpha3.AWSCluster) string

func ClusterBaseDomain 

func ClusterBaseDomain(cluster infrastructurev1alpha3.AWSCluster) string

func ClusterCloudProviderTag 

func ClusterCloudProviderTag(getter LabelsGetter) string

func ClusterEtcdEndpoint 

func ClusterEtcdEndpoint(cluster infrastructurev1alpha3.AWSCluster) string

func ClusterEtcdEndpointWithPort 

func ClusterEtcdEndpointWithPort(cluster infrastructurev1alpha3.AWSCluster) string

func ClusterID 

func ClusterID(getter LabelsGetter) string

func ClusterKubeletEndpoint 

func ClusterKubeletEndpoint(cluster infrastructurev1alpha3.AWSCluster) string

func ClusterNamespace 

func ClusterNamespace(cluster infrastructurev1alpha3.AWSCluster) string

func ComponentVersion 

func ComponentVersion(release releasev1alpha1.Release, componentName string) (string, error)

func ControlPlaneASGResourceName 

func ControlPlaneASGResourceName(getter LabelsGetter, id int) string

func ControlPlaneAvailabilityZones 

func ControlPlaneAvailabilityZones(cr infrastructurev1alpha3.AWSControlPlane) []string

func ControlPlaneENIName 

func ControlPlaneENIName(getter LabelsGetter, id int) string

func ControlPlaneENIResourceName 

func ControlPlaneENIResourceName(id int) string

func ControlPlaneEtcdNodeName 

func ControlPlaneEtcdNodeName(id int) string

func ControlPlaneID 

func ControlPlaneID(getter LabelsGetter) string

func ControlPlaneInstanceType 

func ControlPlaneInstanceType(cr infrastructurev1alpha3.AWSControlPlane) string

func ControlPlaneLaunchTemplateName 

func ControlPlaneLaunchTemplateName(getter LabelsGetter, id int) string

func ControlPlaneLaunchTemplateResourceName 

func ControlPlaneLaunchTemplateResourceName(getter LabelsGetter, id int) string

func ControlPlaneMetadataV2 

func ControlPlaneMetadataV2(cr infrastructurev1alpha3.AWSControlPlane) string

func ControlPlaneNodeRole 

func ControlPlaneNodeRole(cr infrastructurev1alpha3.AWSControlPlane) string

func ControlPlaneRecordSetsRecordValue 

func ControlPlaneRecordSetsRecordValue(id int) string

func ControlPlaneRecordSetsResourceName 

func ControlPlaneRecordSetsResourceName(id int) string

func ControlPlaneVolumeIops 

func ControlPlaneVolumeIops(cr infrastructurev1alpha3.AWSControlPlane) int

func ControlPlaneVolumeName 

func ControlPlaneVolumeName(getter LabelsGetter, id int) string

func ControlPlaneVolumeResourceName 

func ControlPlaneVolumeResourceName(id int) string

func ControlPlaneVolumeSnapshotID 

func ControlPlaneVolumeSnapshotID(snapshot string, master int) string

func ControlPlaneVolumeThroughput 

func ControlPlaneVolumeThroughput(cr infrastructurev1alpha3.AWSControlPlane) int

func CredentialName 

func CredentialName(cluster infrastructurev1alpha3.AWSCluster) string

func CredentialNamespace 

func CredentialNamespace(cluster infrastructurev1alpha3.AWSCluster) string

func EC2ServiceDomain 

func EC2ServiceDomain(region string) string

func ELBNameAPI 

func ELBNameAPI(getter LabelsGetter) string

func ELBNameEtcd 

func ELBNameEtcd(getter LabelsGetter) string

func EncryptionConfigSecretName 

func EncryptionConfigSecretName(clusterName string) string

func ExternalSNAT 

func ExternalSNAT(cluster infrastructurev1alpha3.AWSCluster) *bool

func G8sControlPlaneReplicas 

func G8sControlPlaneReplicas(cr infrastructurev1alpha3.G8sControlPlane) int

func HealthCheckHTTPTarget 

func HealthCheckHTTPTarget(port int) string

func HealthCheckTCPTarget 

func HealthCheckTCPTarget(port int) string

func InternalELBNameAPI 

func InternalELBNameAPI(getter LabelsGetter) string

func IsAlreadyCreatedCluster 

func IsAlreadyCreatedCluster(cluster infrastructurev1alpha3.AWSCluster) bool

func IsChinaRegion 

func IsChinaRegion(awsRegion string) bool

func IsDeleted 

func IsDeleted(getter DeletionTimestampGetter) bool

func IsInvalidParameter 

func IsInvalidParameter(err error) bool

IsInvalidParameter asserts invalidParameterError.

func IsNewCluster 

func IsNewCluster(cluster infrastructurev1alpha3.AWSCluster) bool

func IsNotFound 

func IsNotFound(err error) bool

IsNotFound asserts notFoundError.

func IsWrongDrainerConfig 

func IsWrongDrainerConfig(dc *g8sv1alpha1.DrainerConfig, clusterID string, instanceId string) bool

func IsWrongTypeError 

func IsWrongTypeError(err error) bool

IsWrongTypeError asserts wrongTypeError.

func KubeletLabelsTCCPN 

func KubeletLabelsTCCPN(getter LabelsGetter, masterID int) string

func KubeletLabelsTCNP 

func KubeletLabelsTCNP(getter LabelsGetter) string

func MachineDeploymentAvailabilityZones 

func MachineDeploymentAvailabilityZones(cr infrastructurev1alpha3.AWSMachineDeployment) []string

func MachineDeploymentDockerVolumeSizeGB 

func MachineDeploymentDockerVolumeSizeGB(cr infrastructurev1alpha3.AWSMachineDeployment) string

func MachineDeploymentID 

func MachineDeploymentID(getter LabelsGetter) string

func MachineDeploymentInstanceType 

func MachineDeploymentInstanceType(cr infrastructurev1alpha3.AWSMachineDeployment) string

func MachineDeploymentKubeletVolumeSizeGB 

func MachineDeploymentKubeletVolumeSizeGB(cr infrastructurev1alpha3.AWSMachineDeployment) string

func MachineDeploymentLaunchTemplateName 

func MachineDeploymentLaunchTemplateName(cr infrastructurev1alpha3.AWSMachineDeployment) string

func MachineDeploymentMetadataV2 

func MachineDeploymentMetadataV2(cr infrastructurev1alpha3.AWSMachineDeployment) string

func MachineDeploymentMinInstanceInServiceFromMaxBatchSize 

func MachineDeploymentMinInstanceInServiceFromMaxBatchSize(maxBatchSize string, workers int) (string, error)

MachineDeploymentMinInstanceInServiceFromMaxBatchSize will calculate the minInstanceInService value for ASG, the value is calculated by subtracting maxBatchSize from the worker count

func MachineDeploymentNodeRole 

func MachineDeploymentNodeRole(cr infrastructurev1alpha3.AWSMachineDeployment) string

func MachineDeploymentOnDemandBaseCapacity 

func MachineDeploymentOnDemandBaseCapacity(cr infrastructurev1alpha3.AWSMachineDeployment) int

func MachineDeploymentOnDemandPercentageAboveBaseCapacity 

func MachineDeploymentOnDemandPercentageAboveBaseCapacity(cr infrastructurev1alpha3.AWSMachineDeployment) int

func MachineDeploymentParseMaxBatchSize 

func MachineDeploymentParseMaxBatchSize(val string, workers int) string

MachineDeploymentParseMaxBatchSize will try parse the value into valid maxBatchSize valid values can be either: an integer between 0 < x a float between 0 < x <= 1 float value is used as ratio of a total worker count

func MachineDeploymentPauseTimeIsValid 

func MachineDeploymentPauseTimeIsValid(val string) bool

MachineDeploymentPauseTimeIsValid checks if the value is in proper ISO 8601 duration format and ensure that the duration is not bigger than 1 Hour

func MachineDeploymentScalingMax 

func MachineDeploymentScalingMax(cr infrastructurev1alpha3.AWSMachineDeployment) int

func MachineDeploymentScalingMin 

func MachineDeploymentScalingMin(cr infrastructurev1alpha3.AWSMachineDeployment) int

func MachineDeploymentSpotInstancePools 

func MachineDeploymentSpotInstancePools(overrides []template.LaunchTemplateOverride) int

MachineDeploymentSpotInstancePools ensures that the number of spot instance pools we submit to AWS is within AWS limits of more than 0 and less than 21 pools.

func MachineDeploymentSubnet 

func MachineDeploymentSubnet(cr infrastructurev1alpha3.AWSMachineDeployment) string

func MachineDeploymentWorkerCountRatio 

func MachineDeploymentWorkerCountRatio(workers int, ratio float32) string

func ManagedRecordSets 

func ManagedRecordSets(cluster infrastructurev1alpha3.AWSCluster) []string

func MasterAvailabilityZone 

func MasterAvailabilityZone(cluster infrastructurev1alpha3.AWSCluster) string

func MasterCount 

func MasterCount(cluster infrastructurev1alpha3.AWSCluster) int

func MasterInstanceName 

func MasterInstanceName(cluster infrastructurev1alpha3.AWSCluster) string

func MasterInstanceResourceName 

func MasterInstanceResourceName(cr infrastructurev1alpha3.AWSCluster, t time.Time) string

func MasterInstanceType 

func MasterInstanceType(cluster infrastructurev1alpha3.AWSCluster) string

func NATEIPName 

func NATEIPName(az string) string

func NATGatewayName 

func NATGatewayName(az string) string

func NATRouteName 

func NATRouteName(az string) string

func OIDCClientID 

func OIDCClientID(cluster infrastructurev1alpha3.AWSCluster) string

func OIDCGroupsClaim 

func OIDCGroupsClaim(cluster infrastructurev1alpha3.AWSCluster) string

func OIDCIssuerURL 

func OIDCIssuerURL(cluster infrastructurev1alpha3.AWSCluster) string

func OIDCUsernameClaim 

func OIDCUsernameClaim(cluster infrastructurev1alpha3.AWSCluster) string

func OSVersion 

func OSVersion(release releasev1alpha1.Release) (string, error)

func OperatorVersion 

func OperatorVersion(getter LabelsGetter) string

func OrganizationID 

func OrganizationID(getter LabelsGetter) string

func PodsCIDRBlock 

func PodsCIDRBlock(cluster infrastructurev1alpha3.AWSCluster) string

func PolicyNameMaster 

func PolicyNameMaster(cluster infrastructurev1alpha3.AWSCluster) string

func PrivateInternetGatewayRouteName 

func PrivateInternetGatewayRouteName(az string) string

func PrivateRouteTableName 

func PrivateRouteTableName(az string) string

func PrivateSubnetName 

func PrivateSubnetName(az string) string

func PrivateSubnetRouteTableAssociationName 

func PrivateSubnetRouteTableAssociationName(az string) string

func ProfileNameMaster 

func ProfileNameMaster(cluster infrastructurev1alpha3.AWSCluster) string

func PublicInternetGatewayRouteName 

func PublicInternetGatewayRouteName(az string) string

func PublicRouteTableName 

func PublicRouteTableName(az string) string

func PublicSubnetName 

func PublicSubnetName(az string) string

func PublicSubnetRouteTableAssociationName 

func PublicSubnetRouteTableAssociationName(az string) string

func Region 

func Region(cluster infrastructurev1alpha3.AWSCluster) string

func RegionARN 

func RegionARN(region string) string

func ReleaseName 

func ReleaseName(releaseVersion string) string

func ReleaseVersion 

func ReleaseVersion(getter LabelsGetter) string

func RoleARNMaster 

func RoleARNMaster(getter LabelsGetter, region string, accountID string) string

func RoleARNWorker 

func RoleARNWorker(getter LabelsGetter, region string, accountID string) string

func RoleNameMaster 

func RoleNameMaster(cluster infrastructurev1alpha3.AWSCluster) string

func RolePeerAccess 

func RolePeerAccess(cluster infrastructurev1alpha3.AWSCluster) string

func RouteTableName 

func RouteTableName(cluster infrastructurev1alpha3.AWSCluster, suffix, az string) string

func S3ObjectPathTCCPN 

func S3ObjectPathTCCPN(cr LabelsGetter, id int) string

S3ObjectPathTCCPN computes the S3 object path to the cloud config uploaded for the TCCPN stack. Note that the path is suffixed with the master ID, since Tenant Clusters may be Single Master or HA Masters, where the suffix -0 indicates a Single Master configuration. 

version/3.4.0/cloudconfig/v_3_2_5/cluster-al9qy-tccpn-a2wax-2

func S3ObjectPathTCNP 

func S3ObjectPathTCNP(getter LabelsGetter) string

S3ObjectPathTCNP computes the S3 object path to the cloud config uploaded for the TCCP stack. 

version/3.4.0/cloudconfig/v_3_2_5/cluster-al9qy-tcnp-g3j50

func SSLOnlyBucketPolicy 

func SSLOnlyBucketPolicy(bucketName string, region string) string

func SanitizeCFResourceName 

func SanitizeCFResourceName(l ...string) string

SanitizeCFResourceName filters out all non-ascii alphanumberics from input string. 

SanitizeCFResourceName("abc-123") == "abc123"
SanitizeCFResourceName("abc", "123") == "abc123"
SanitizeCFResourceName("Dear god why? щ（ﾟДﾟщ）") == "Deargodwhy"

func SecurityGroupName 

func SecurityGroupName(getter LabelsGetter, groupName string) string

func ServiceAccountV2SecretName 

func ServiceAccountV2SecretName(clusterName string) string

func StackComplete 

func StackComplete(status string) bool

func StackInProgress 

func StackInProgress(status string) bool

func StackNameTCCP 

func StackNameTCCP(getter LabelsGetter) string

func StackNameTCCPF 

func StackNameTCCPF(getter LabelsGetter) string

func StackNameTCCPI 

func StackNameTCCPI(getter LabelsGetter) string

func StackNameTCCPN 

func StackNameTCCPN(getter LabelsGetter) string

func StackNameTCNP 

func StackNameTCNP(getter LabelsGetter) string

func StackNameTCNPF 

func StackNameTCNPF(getter LabelsGetter) string

func StatusAWSConfigNetworkCIDR 

func StatusAWSConfigNetworkCIDR(customObject g8sv1alpha1.AWSConfig) string

func StatusClusterNetworkCIDR 

func StatusClusterNetworkCIDR(cluster infrastructurev1alpha3.AWSCluster) string

func TargetLogBucketName 

func TargetLogBucketName(getter LabelsGetter, accountID string) string

func TenantClusterBaseDomain 

func TenantClusterBaseDomain(cluster infrastructurev1alpha3.AWSCluster) string

func ToCluster 

func ToCluster(ctx context.Context, v interface{}) (infrastructurev1alpha3.AWSCluster, error)

func ToControlPlane 

func ToControlPlane(v interface{}) (infrastructurev1alpha3.AWSControlPlane, error)

func ToMachineDeployment 

func ToMachineDeployment(v interface{}) (infrastructurev1alpha3.AWSMachineDeployment, error)

func VPCPeeringRouteName 

func VPCPeeringRouteName(az string) string

func VersionLabelSelector 

func VersionLabelSelector(enabled bool, overridenVersion string) string

func VolumeNameDocker 

func VolumeNameDocker(cluster infrastructurev1alpha3.AWSCluster) string

func VolumeNameEtcd 

func VolumeNameEtcd(cluster infrastructurev1alpha3.AWSCluster) string

func VolumeNameLog 

func VolumeNameLog(cluster infrastructurev1alpha3.AWSCluster) string

Types

type AMIInfo 

type AMIInfo struct {
	Name string `json:"name"`
	PV   string `json:"pv"`
	HVM  string `json:"hvm"`
}

type AMIInfoList 

type AMIInfoList struct {
	AMIs []AMIInfo `json:"amis"`
}

type DeletionTimestampGetter 

type DeletionTimestampGetter interface {
	GetDeletionTimestamp() *metav1.Time
}

type LabelsGetter 

type LabelsGetter interface {
	GetLabels() map[string]string
}

Source Files

View all Source files

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.