operations

type Executor struct {
	// contains filtered or unexported fields
}

type FailureHandler interface {
	HandleFailure(operation model.Operation, cluster model.Cluster) error
}

type NonRecoverableError struct {
	// contains filtered or unexported fields
}

type ProcessingResult struct {
	Requeue bool
	Delay   time.Duration
}

type StageResult struct {
	Stage model.OperationStage
	Delay time.Duration
}

type Step interface {
	Name() model.OperationStage
	Run(cluster model.Cluster, operation model.Operation, logger logrus.FieldLogger) (StageResult, error)
	TimeLimit() time.Duration
}