Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewTaskRunner ¶
func NewTaskRunner(task Task, writer filewriter.FileWriter) *taskRunner
Types ¶
type CheckpointInfo ¶ added in v0.9.2
type CheckpointInfo struct {
CompletedTasks map[string]*CompletedTask `json:"completedTasks"`
}
type CommandContext ¶
type CommandContext struct {
Bootstrapper interfaces.Bootstrapper
Provider providers.Provider
ClusterManager interfaces.ClusterManager
AddonManager interfaces.AddonManager
Validations interfaces.Validator
Writer filewriter.FileWriter
EksdInstaller interfaces.EksdInstaller
PackageInstaller interfaces.PackageInstaller
EksdUpgrader interfaces.EksdUpgrader
CAPIManager interfaces.CAPIManager
ClusterSpec *cluster.Spec
CurrentClusterSpec *cluster.Spec
UpgradeChangeDiff *types.ChangeDiff
BootstrapCluster *types.Cluster
ManagementCluster *types.Cluster
WorkloadCluster *types.Cluster
Profiler *Profiler
OriginalError error
}
Command context maintains the mutable and shared entities
func (*CommandContext) SetError ¶
func (c *CommandContext) SetError(err error)
type CompletedTask ¶ added in v0.9.2
type CompletedTask struct {
Checkpoint TaskCheckpoint `json:"checkpoint"`
}
type Profiler ¶
type Profiler struct {
// contains filtered or unexported fields
}
func (*Profiler) MarkDoneTask ¶
needs to be called after setStart
func (*Profiler) SetStartTask ¶
profiler for a Task
type Task ¶
type Task interface {
Run(ctx context.Context, commandContext *CommandContext) Task
Name() string
Checkpoint() *CompletedTask
Restore(ctx context.Context, commandContext *CommandContext, completedTask *CompletedTask) (Task, error)
}
Task is a logical unit of work - meant to be implemented by each Task
type TaskCheckpoint ¶ added in v0.9.2
type TaskCheckpoint interface{}
Click to show internal directories.
Click to hide internal directories.