From f368ae5b7bf8fd1535e21808324af96f73429a66 Mon Sep 17 00:00:00 2001 From: Zach Aller Date: Thu, 25 Jan 2024 09:27:27 -0600 Subject: [PATCH] chore: remove accidental files Signed-off-by: Zach Aller --- rollout/step_plugins.go | 91 ----------------------------------------- rollout/steps/plugin.go | 23 ----------- 2 files changed, 114 deletions(-) delete mode 100644 rollout/step_plugins.go delete mode 100644 rollout/steps/plugin.go diff --git a/rollout/step_plugins.go b/rollout/step_plugins.go deleted file mode 100644 index 73b0bfab3c..0000000000 --- a/rollout/step_plugins.go +++ /dev/null @@ -1,91 +0,0 @@ -package rollout - -// -//import ( -// "fmt" -// "github.com/argoproj/argo-rollouts/pkg/apis/rollouts/v1alpha1" -// metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" -//) -// -//type stepContext struct { -// rollout *v1alpha1.Rollout -// pluginType string -// calledAt metav1.Time -// currentStepStatus v1alpha1.StepPluginStatuses -//} -// -//func newStepContext(rollout *v1alpha1.Rollout, pluginType string) *stepContext { -// sc := &stepContext{ -// rollout: rollout, -// pluginType: pluginType, -// } -// -// //mapStatuses := map[string]v1alpha1.StepPluginStatuses{} -// //json.Unmarshal(rollout.Status.SPluginStatus, &mapStatuses) -// for _, status := range sc.rollout.Status.StepPluginStatus { -// if status.Name == fmt.Sprintf("%s.%d", pluginType, *rollout.Status.CurrentStepIndex) { -// sc.currentStepStatus = status -// } -// } -// -// return sc -//} -// -//func (c *rolloutContext) reconcileStepPlugins() error { -// -// -// //currentStep, index := replicasetutil.GetCurrentCanaryStep(c.rollout) -// //if currentStep == nil { -// // return nil -// //} -// //if index == nil { -// // var ii int32 = 0 -// // index = &ii -// //} -// //revision, revisionFound := annotations.GetRevisionAnnotation(c.rollout) -// //if currentStep != nil && (revisionFound && revision <= 1) { -// // log.Printf("Skipping Step Plugin Reconcile for Rollout %s/%s, revision %d", c.rollout.Namespace, c.rollout.Name, revision) -// // return nil -// //} -// // -// //sps := steps.NewStepPluginReconcile(currentStep) -// //for _, plugin := range sps { -// // c.stepContext = newStepContext(c.rollout, plugin.Type()) -// // -// // c.newStatus = *c.rollout.Status.DeepCopy() -// // -// // if c.controllerStartTime.After(c.stepContext.calledAt.Time) { -// // log.Printf("Controller Running Step: %d, Plugin: %s", *index, plugin.Type()) -// // res, e := plugin.RunStep(*c.rollout, c.stepContext.currentStepStatus) -// // c.stepContext.currentStepStatus.HasBeenCalled = true -// // c.stepContext.currentStepStatus.CalledAt = metav1.Now() -// // if e != nil { -// // fmt.Println(e) -// // } -// // -// // if c.stepContext.currentStepStatus.IsEmpty() { -// // c.stepContext.currentStepStatus = v1alpha1.StepPluginStatuses{ -// // Name: fmt.Sprintf("%s.%d", plugin.Type(), *index), -// // StepIndex: index, -// // Status: v1alpha1.Object{Value: res}, -// // } -// // } -// // if res != nil { -// // c.stepContext.currentStepStatus.Status = v1alpha1.Object{Value: res} -// // } -// // } -// // -// // c.newStatus.StepPluginStatus[fmt.Sprintf("%s.%d", plugin.Type(), *index)] = c.stepContext.currentStepStatus -// //} -// -// return nil -//} -// -//func (c *rolloutContext) setStepCondition(pluginType string, status v1alpha1.StepPluginStatuses) { -// //c.newStatus = *c.rollout.Status.DeepCopy() -// //if c.newStatus.SPluginStatus == nil { -// // c.newStatus.SPluginStatus = map[string]v1alpha1.StepPluginStatuses{} -// //} -// //c.newStatus.SPluginStatus[fmt.Sprintf("%s.%d", pluginType, *c.rollout.Status.CurrentStepIndex)] = status -// //c.syncRolloutStatusCanary() -//} diff --git a/rollout/steps/plugin.go b/rollout/steps/plugin.go deleted file mode 100644 index bc1610081b..0000000000 --- a/rollout/steps/plugin.go +++ /dev/null @@ -1,23 +0,0 @@ -package steps - -//import ( -// "encoding/json" -// "github.com/argoproj/argo-rollouts/pkg/apis/rollouts/v1alpha1" -//) -// -//type StepPlugin interface { -// RunStep(rollout v1alpha1.Rollout, currentStepStatus v1alpha1.StepPluginStatuses) (json.RawMessage, error) -// IsStepCompleted(rollout v1alpha1.Rollout, currentStatus v1alpha1.StepPluginStatuses) (bool, json.RawMessage, error) -// Type() string -//} -// -//func NewStepPluginReconcile(currentStep *v1alpha1.CanaryStep) []StepPlugin { -// stepPlugins := make([]StepPlugin, 0) -// for pluginName, _ := range currentStep.RunPlugins { -// switch pluginName { -// case "consolelogger": -// //stepPlugins = append(stepPlugins, consolelogger.NewConsoleLoggerStep()) -// } -// } -// return stepPlugins -//}