-
Notifications
You must be signed in to change notification settings - Fork 137
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
* Add new cmd/tink-controller package * Remove the `status.data` field on Workflows * Add tests for methods on API types * Add `pkg/controllers` package with controller logic * Controllers for individual types (workflows, templates, hardware) will reside in individual sub-packages * Add `pkg/convert` for type conversions * Add `pkg/internal/tests` for testing utilities * Added FrozenTime with Kubernetes and Protobuf methods Signed-off-by: Micah Hausler <[email protected]>
- Loading branch information
1 parent
96cbe60
commit a5ad5b7
Showing
31 changed files
with
2,703 additions
and
43 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
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,2 @@ | ||
| tink-controller | ||
| tink-controller-* |
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,10 @@ | ||
| FROM alpine:3.15 | ||
| ENTRYPOINT ["/usr/bin/tink-controller"] | ||
| EXPOSE 42113 | ||
| EXPOSE 42114 | ||
|
|
||
| ARG TARGETARCH | ||
| ARG TARGETVARIANT | ||
|
|
||
| RUN apk add --update ca-certificates | ||
| COPY tink-controller-linux-${TARGETARCH:-amd64}${TARGETVARIANT} /usr/bin/tink-controller |
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,125 @@ | ||
| package main | ||
|
|
||
| import ( | ||
| "context" | ||
| "fmt" | ||
| "os" | ||
| "strings" | ||
|
|
||
| "github.com/packethost/pkg/log" | ||
| "github.com/spf13/cobra" | ||
| "github.com/spf13/pflag" | ||
| "github.com/spf13/viper" | ||
| "github.com/tinkerbell/tink/pkg/controllers" | ||
| wfctrl "github.com/tinkerbell/tink/pkg/controllers/workflow" | ||
| "k8s.io/client-go/tools/clientcmd" | ||
| ) | ||
|
|
||
| // version is set at build time. | ||
| var version = "devel" | ||
|
|
||
| // DaemonConfig represents all the values you can configure as part of the tink-server. | ||
| // You can change the configuration via environment variable, or file, or command flags. | ||
| type DaemonConfig struct { | ||
| K8sAPI string | ||
| Kubeconfig string // only applies to out of cluster | ||
| } | ||
|
|
||
| func (c *DaemonConfig) AddFlags(fs *pflag.FlagSet) { | ||
| fs.StringVar(&c.K8sAPI, "kubernetes", "", "The Kubernetes URL") | ||
| fs.StringVar(&c.Kubeconfig, "kubeconfig", "", "Absolute path to the kubeconfig file") | ||
| } | ||
|
|
||
| func main() { | ||
| logger, err := log.Init("github.com/tinkerbell/tink") | ||
| if err != nil { | ||
| panic(err) | ||
| } | ||
| defer logger.Close() | ||
|
|
||
| config := &DaemonConfig{} | ||
|
|
||
| cmd := NewRootCommand(config, logger) | ||
| if err := cmd.ExecuteContext(context.Background()); err != nil { | ||
| defer os.Exit(1) | ||
| } | ||
| } | ||
|
|
||
| func NewRootCommand(config *DaemonConfig, logger log.Logger) *cobra.Command { | ||
| cmd := &cobra.Command{ | ||
| Use: "tink-controller", | ||
| PreRunE: func(cmd *cobra.Command, args []string) error { | ||
| viper, err := createViper(logger) | ||
| if err != nil { | ||
| return err | ||
| } | ||
| return applyViper(viper, cmd) | ||
| }, | ||
| RunE: func(cmd *cobra.Command, args []string) error { | ||
| logger.Info("starting controller version " + version) | ||
|
|
||
| config, err := clientcmd.BuildConfigFromFlags(config.K8sAPI, config.Kubeconfig) | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| manager, err := controllers.NewManager(config, controllers.GetControllerOptions()) | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| return manager.RegisterControllers( | ||
| cmd.Context(), | ||
| wfctrl.NewController(manager.GetClient()), | ||
| ).Start(cmd.Context()) | ||
| }, | ||
| } | ||
| config.AddFlags(cmd.Flags()) | ||
| return cmd | ||
| } | ||
|
|
||
| func createViper(logger log.Logger) (*viper.Viper, error) { | ||
| v := viper.New() | ||
| v.AutomaticEnv() | ||
| v.SetConfigName("tink-controller") | ||
| v.AddConfigPath("/etc/tinkerbell") | ||
| v.AddConfigPath(".") | ||
| v.SetEnvKeyReplacer(strings.NewReplacer("-", "_")) | ||
|
|
||
| // If a config file is found, read it in. | ||
| if err := v.ReadInConfig(); err != nil { | ||
| if _, ok := err.(viper.ConfigFileNotFoundError); !ok { | ||
| logger.With("configFile", v.ConfigFileUsed()).Error(err, "could not load config file") | ||
| return nil, err | ||
| } | ||
| logger.Info("no config file found") | ||
| } else { | ||
| logger.With("configFile", v.ConfigFileUsed()).Info("loaded config file") | ||
| } | ||
|
|
||
| return v, nil | ||
| } | ||
|
|
||
| func applyViper(v *viper.Viper, cmd *cobra.Command) error { | ||
| errors := []error{} | ||
|
|
||
| cmd.Flags().VisitAll(func(f *pflag.Flag) { | ||
| if !f.Changed && v.IsSet(f.Name) { | ||
| val := v.Get(f.Name) | ||
| if err := cmd.Flags().Set(f.Name, fmt.Sprintf("%v", val)); err != nil { | ||
| errors = append(errors, err) | ||
| return | ||
| } | ||
| } | ||
| }) | ||
|
|
||
| if len(errors) > 0 { | ||
| errs := []string{} | ||
| for _, err := range errors { | ||
| errs = append(errs, err.Error()) | ||
| } | ||
| return fmt.Errorf(strings.Join(errs, ", ")) | ||
| } | ||
|
|
||
| return nil | ||
| } |
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
Oops, something went wrong.