Skip to content

Commit

Permalink
Move protokube image task to ProtokubeBuilder
Browse files Browse the repository at this point in the history
More logically consistent, and allows us to be lazier about loading
it when not needed.
  • Loading branch information
justinsb committed Jan 4, 2020
1 parent 976724d commit e190aa3
Show file tree
Hide file tree
Showing 3 changed files with 21 additions and 7 deletions.
9 changes: 9 additions & 0 deletions nodeup/pkg/model/protokube.go
Expand Up @@ -55,6 +55,15 @@ func (t *ProtokubeBuilder) Build(c *fi.ModelBuilderContext) error {
return nil
}

if protokubeImage := t.NodeupConfig.ProtokubeImage; protokubeImage != nil {
c.AddTask(&nodetasks.LoadImageTask{
Name: "protokube",
Sources: protokubeImage.Sources,
Hash: protokubeImage.Hash,
Runtime: t.Cluster.Spec.ContainerRuntime,
})
}

if t.IsMaster {
kubeconfig, err := t.BuildPKIKubeconfig("kops")
if err != nil {
Expand Down
8 changes: 1 addition & 7 deletions upup/pkg/fi/nodeup/command.go
Expand Up @@ -301,13 +301,7 @@ func (c *NodeUpCommand) Run(out io.Writer) error {
Runtime: c.cluster.Spec.ContainerRuntime,
}
}
if c.config.ProtokubeImage != nil {
taskMap["LoadImage.protokube"] = &nodetasks.LoadImageTask{
Sources: c.config.ProtokubeImage.Sources,
Hash: c.config.ProtokubeImage.Hash,
Runtime: c.cluster.Spec.ContainerRuntime,
}
}
// Protokube load image task is in ProtokubeBuilder

var cloud fi.Cloud
var keyStore fi.Keystore
Expand Down
11 changes: 11 additions & 0 deletions upup/pkg/fi/nodeup/nodetasks/load_image.go
Expand Up @@ -40,6 +40,7 @@ const (

// LoadImageTask is responsible for downloading a docker image
type LoadImageTask struct {
Name string
Sources []string
Hash string
Runtime string
Expand All @@ -64,6 +65,16 @@ func (t *LoadImageTask) GetDependencies(tasks map[string]fi.Task) []fi.Task {
return deps
}

var _ fi.HasName = &LoadImageTask{}

func (t *LoadImageTask) GetName() *string {
return t.Name
}

func (t *LoadImageTask) SetName(name string) {
klog.Fatalf("SetName not supported for LoadImageTask")
}

func (t *LoadImageTask) String() string {
return fmt.Sprintf("LoadImageTask: %v", t.Sources)
}
Expand Down

0 comments on commit e190aa3

Please sign in to comment.