forked from eksctl-io/eksctl
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Automatically update coredns assets using Github workflows (eksctl-io…
…#7178) * Automatically update coredns assets using github workflows * configure aws credentials * add id-token permission * update role duration value to minimum supported * fix typo
- Loading branch information
Showing
3 changed files
with
119 additions
and
9 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,92 @@ | ||
| package main | ||
|
|
||
| import ( | ||
| "context" | ||
| "fmt" | ||
| "log" | ||
| "os" | ||
| "path/filepath" | ||
| "regexp" | ||
| "sort" | ||
| "strings" | ||
|
|
||
| "github.com/aws/aws-sdk-go-v2/aws" | ||
| awseks "github.com/aws/aws-sdk-go-v2/service/eks" | ||
| "github.com/blang/semver" | ||
|
|
||
| api "github.com/weaveworks/eksctl/pkg/apis/eksctl.io/v1alpha5" | ||
| "github.com/weaveworks/eksctl/pkg/eks" | ||
| ) | ||
|
|
||
| func main() { | ||
| ctx := context.Background() | ||
|
|
||
| clusterProvider, err := eks.New(ctx, &api.ProviderConfig{}, nil) | ||
| if err != nil { | ||
| log.Fatalf("failed to create the AWS provider: %v", err) | ||
| } | ||
|
|
||
| for _, kubernetesVersion := range api.SupportedVersions() { | ||
| latestVersion := getLatestVersion(ctx, clusterProvider, kubernetesVersion) | ||
| if latestVersion == "" { | ||
| continue | ||
| } | ||
| replaceCurrentVersionIfOutdated(latestVersion, kubernetesVersion) | ||
| } | ||
|
|
||
| } | ||
|
|
||
| func getLatestVersion(ctx context.Context, clusterProvider *eks.ClusterProvider, kubernetesVersion string) string { | ||
| output, err := clusterProvider.AWSProvider.EKS().DescribeAddonVersions(ctx, &awseks.DescribeAddonVersionsInput{ | ||
| AddonName: aws.String("coredns"), | ||
| KubernetesVersion: &kubernetesVersion, | ||
| }) | ||
| if err != nil { | ||
| log.Fatalf("failed calling EKS::DescribeAddonVersions: %v", err) | ||
| } | ||
|
|
||
| corednsVersions := output.Addons[0].AddonVersions | ||
| if len(corednsVersions) == 0 { | ||
| return "" | ||
| } | ||
|
|
||
| sort.Slice(corednsVersions, func(i, j int) bool { | ||
| vi, err := semver.Parse(trim(*corednsVersions[i].AddonVersion)) | ||
| if err != nil { | ||
| log.Fatalf("failed to parse coredns version %s: %v", trim(*corednsVersions[i].AddonVersion), err) | ||
| } | ||
| vj, err := semver.Parse(trim(*corednsVersions[j].AddonVersion)) | ||
| if err != nil { | ||
| log.Fatalf("failed to parse coredns version %s: %v", trim(*corednsVersions[j].AddonVersion), err) | ||
| } | ||
| if vi.Compare(vj) >= 0 { | ||
| return true | ||
| } | ||
| return false | ||
| }) | ||
|
|
||
| return *corednsVersions[0].AddonVersion | ||
| } | ||
|
|
||
| func replaceCurrentVersionIfOutdated(latestVersion string, kubernetesVersion string) { | ||
| filePath := filepath.Join("pkg", "addons", "default", "assets", fmt.Sprintf("coredns-%s.json", kubernetesVersion)) | ||
| coreFile, err := os.ReadFile(filePath) | ||
| if err != nil { | ||
| log.Fatalf("failed to read coredns-%s.json: %v", kubernetesVersion, err) | ||
| } | ||
|
|
||
| regexpVersion := regexp.MustCompile(`v\d+\.\d+\.\d+-eksbuild\.\d+`) | ||
| currentVersion := regexpVersion.FindString(string(coreFile)) | ||
| if currentVersion == "" { | ||
| log.Fatalf("couldn't find coredns version in coredns-%s.json", kubernetesVersion) | ||
| } | ||
|
|
||
| updatedCoreFile := regexpVersion.ReplaceAllString(string(coreFile), latestVersion) | ||
| if err := os.WriteFile(filePath, []byte(updatedCoreFile), 0644); err != nil { | ||
| log.Fatalf("failed to write coredns-%s.json: %v", kubernetesVersion, err) | ||
| } | ||
| } | ||
|
|
||
| func trim(version string) string { | ||
| return strings.TrimPrefix(version, "v") | ||
| } |