Mirrors/flux2
1
0
Fork 0
mirror of synced 2026-02-14 13:36:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add export flag to create commands

Browse Source
This commit is contained in:
stefanprodan
2020-06-09 12:15:31 +03:00
parent f5b738198f
commit 1bc637a43f
2 changed files with 12 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
cmd/tk/create.go
View File

@@ -13,9 +13,11 @@ var createCmd = &cobra.Command{
var ( var (
interval time.Duration interval time.Duration
export bool
) )
func init() { func init() {
createCmd.PersistentFlags().DurationVarP(&interval, "interval", "", time.Minute, "source sync interval") createCmd.PersistentFlags().DurationVarP(&interval, "interval", "", time.Minute, "source sync interval")
createCmd.PersistentFlags().BoolVar(&export, "export", false, "export in yaml format to stdout")
rootCmd.AddCommand(createCmd) rootCmd.AddCommand(createCmd)
} }

11
cmd/tk/create_kustomization.go
View File

@@ -3,11 +3,9 @@ package main
import ( import (
"context" "context"
"fmt" "fmt"
kustomizev1 "github.com/fluxcd/kustomize-controller/api/v1alpha1"
"strings" "strings"
"time" "time"
sourcev1 "github.com/fluxcd/source-controller/api/v1alpha1"
"github.com/spf13/cobra" "github.com/spf13/cobra"
corev1 "k8s.io/api/core/v1" corev1 "k8s.io/api/core/v1"
"k8s.io/apimachinery/pkg/api/errors" "k8s.io/apimachinery/pkg/api/errors"
@@ -15,6 +13,9 @@ import (
"k8s.io/apimachinery/pkg/types" "k8s.io/apimachinery/pkg/types"
"k8s.io/apimachinery/pkg/util/wait" "k8s.io/apimachinery/pkg/util/wait"
"sigs.k8s.io/controller-runtime/pkg/client" "sigs.k8s.io/controller-runtime/pkg/client"
kustomizev1 "github.com/fluxcd/kustomize-controller/api/v1alpha1"
sourcev1 "github.com/fluxcd/source-controller/api/v1alpha1"
) )
var createKsCmd = &cobra.Command{ var createKsCmd = &cobra.Command{
@@ -106,7 +107,9 @@ func createKsCmdRun(cmd *cobra.Command, args []string) error {
return err return err
} }
if !export {
logGenerate("generating kustomization") logGenerate("generating kustomization")
}
emptyAPIGroup := "" emptyAPIGroup := ""
kustomization := kustomizev1.Kustomization{ kustomization := kustomizev1.Kustomization{
@@ -171,6 +174,10 @@ func createKsCmdRun(cmd *cobra.Command, args []string) error {
} }
} }
if export {
return exportKs(kustomization)
}
logAction("applying kustomization") logAction("applying kustomization")
if err := upsertKustomization(ctx, kubeClient, kustomization); err != nil { if err := upsertKustomization(ctx, kubeClient, kustomization); err != nil {
return err return err