-
Notifications
You must be signed in to change notification settings - Fork 4.7k
/
Copy pathtask.go
212 lines (173 loc) · 6.98 KB
/
task.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
/*
Copyright 2019 The Kubernetes Authors.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
package fi
import (
"context"
"fmt"
"reflect"
"strings"
"k8s.io/klog/v2"
)
type Task[T SubContext] interface {
Run(*Context[T]) error
}
type CloudupTask = Task[CloudupSubContext]
type InstallTask = Task[InstallSubContext]
type NodeupTask = Task[NodeupSubContext]
// TaskPreRun is implemented by tasks that perform some initial validation.
type TaskPreRun[T SubContext] interface {
Task[T]
// PreRun will be run for all TaskPreRuns, before any Run functions are invoked.
PreRun(*Context[T]) error
}
// TaskNormalize is implemented by tasks that perform some initial normalization.
type TaskNormalize[T SubContext] interface {
Task[T]
// Normalize will be run for all TaskNormalizes, before the Run function of
// the TaskNormalize and after the Run function of any Task it is dependent on.
Normalize(*Context[T]) error
}
type CloudupTaskNormalize = TaskNormalize[CloudupSubContext]
// TaskAsString renders the task for debug output
// TODO: Use reflection to make this cleaner: don't recurse into tasks - print their names instead
// also print resources in a cleaner way (use the resource source information?)
func TaskAsString[T SubContext](t Task[T]) string {
return fmt.Sprintf("%T %s", t, DebugAsJsonString(t))
}
// CloudupTaskAsString renders the task for debug output
// TODO: Use reflection to make this cleaner: don't recurse into tasks - print their names instead
// also print resources in a cleaner way (use the resource source information?)
func CloudupTaskAsString(t CloudupTask) string {
return TaskAsString(t)
}
// NodeupTaskAsString renders the task for debug output
// TODO: Use reflection to make this cleaner: don't recurse into tasks - print their names instead
// also print resources in a cleaner way (use the resource source information?)
func NodeupTaskAsString(t NodeupTask) string {
return TaskAsString(t)
}
type HasCheckExisting[T SubContext] interface {
Task[T]
CheckExisting(c *Context[T]) bool
}
type NodeupHasCheckExisting = HasCheckExisting[NodeupSubContext]
type CloudupHasCheckExisting = HasCheckExisting[CloudupSubContext]
// ModelBuilder allows for plugins that configure an aspect of the model, based on the configuration
type ModelBuilder[T SubContext] interface {
Build(context *ModelBuilderContext[T]) error
}
type CloudupModelBuilder = ModelBuilder[CloudupSubContext]
type NodeupModelBuilder = ModelBuilder[NodeupSubContext]
// HasDeletions is a ModelBuilder[CloudupContext] that creates tasks to delete cloud objects that no longer exist in the model.
type HasDeletions interface {
ModelBuilder[CloudupSubContext]
// FindDeletions finds cloud objects that are owned by the cluster but no longer in the model and creates tasks to delete them.
// It is not called for the Terraform target.
FindDeletions(context *ModelBuilderContext[CloudupSubContext], cloud Cloud) error
}
// ModelBuilderContext is a context object that holds state we want to pass to ModelBuilder
type ModelBuilderContext[T SubContext] struct {
// ctx holds the context.Context, ideally we would pass this in to every handler,
// but that is a fairly large refactor, and arguably ModelBuilderContext has a similar
// lifecycle to a context.Context
ctx context.Context
Tasks map[string]Task[T]
LifecycleOverrides map[string]Lifecycle
}
func (c *ModelBuilderContext[T]) WithContext(ctx context.Context) *ModelBuilderContext[T] {
c2 := *c
c2.ctx = ctx
return &c2
}
func (c *ModelBuilderContext[T]) Context() context.Context {
ctx := c.ctx
if ctx == nil {
ctx = context.TODO()
}
return ctx
}
type InstallModelBuilderContext = ModelBuilderContext[InstallSubContext]
type NodeupModelBuilderContext = ModelBuilderContext[NodeupSubContext]
type CloudupModelBuilderContext = ModelBuilderContext[CloudupSubContext]
func (c *ModelBuilderContext[T]) AddTask(task Task[T]) {
task = c.setLifecycleOverride(task)
key := buildTaskKey(task)
existing, found := c.Tasks[key]
if found {
klog.Fatalf("found duplicate tasks with name %q: %v and %v", key, task, existing)
}
c.Tasks[key] = task
}
// EnsureTask ensures that the specified task is configured.
// It adds the task if it does not already exist.
// If it does exist, it verifies that the existing task reflect.DeepEqual the new task,
// if they are different we panic; otherwise it's too easy to forget to check the error code,
// and realistically we have yet to find a scenario where we can recover from an error here.
func (c *ModelBuilderContext[T]) EnsureTask(task Task[T]) {
task = c.setLifecycleOverride(task)
key := buildTaskKey(task)
existing, found := c.Tasks[key]
if found {
if reflect.DeepEqual(task, existing) {
klog.V(8).Infof("EnsureTask ignoring identical ")
return
}
klog.Warningf("EnsureTask found task mismatch for %q", key)
klog.Warningf("\tExisting: %v", existing)
klog.Warningf("\tNew: %v", task)
// c.Errorf("cannot add different task with same key %q", key)
klog.Fatalf("cannot add different task with same key %q", key)
return
}
c.Tasks[key] = task
}
// setLifecycleOverride determines if a Lifecycle is in the LifecycleOverrides map for the current task.
// If the lifecycle exist then the task lifecycle is set to the lifecycle provides in LifecycleOverrides.
// This func allows for lifecycles to be passed in dynamically and have the task lifecycle set accordingly.
func (c *ModelBuilderContext[T]) setLifecycleOverride(task Task[T]) Task[T] {
// TODO(@chrislovecnm) - wonder if we should update the nodeup tasks to have lifecycle
// TODO - so that we can return an error here, rather than just returning.
// certain tasks have not implemented HasLifecycle interface
typeName := TypeNameForTask(task)
// typeName can be values like "InternetGateway"
value, ok := c.LifecycleOverrides[typeName]
if ok {
hl, okHL := task.(HasLifecycle)
if !okHL {
klog.Warningf("task %T does not implement HasLifecycle", task)
return task
}
klog.Infof("overriding task %s, lifecycle %s", task, value)
hl.SetLifecycle(value)
}
return task
}
func buildTaskKey[T SubContext](task Task[T]) string {
hasName, ok := task.(HasName)
if !ok {
klog.Fatalf("task %T does not implement HasName", task)
}
name := ValueOf(hasName.GetName())
if name == "" {
klog.Fatalf("task %T (%v) did not have a Name", task, task)
}
typeName := TypeNameForTask(task)
key := typeName + "/" + name
return key
}
func TypeNameForTask(task interface{}) string {
typeName := fmt.Sprintf("%T", task)
lastDot := strings.LastIndex(typeName, ".")
typeName = typeName[lastDot+1:]
return typeName
}