diff --git a/pkg/kube/pod_controller.go b/pkg/kube/pod_controller.go index 752d771513..9580b46098 100644 --- a/pkg/kube/pod_controller.go +++ b/pkg/kube/pod_controller.go @@ -29,10 +29,10 @@ import ( ) var ( - ErrPodControllerNotInitialized = errkit.NewPureError("pod has not been initialized") - ErrPodControllerPodAlreadyStarted = errkit.NewPureError("pod has already been started") - ErrPodControllerPodNotReady = errkit.NewPureError("pod is not yet ready") - ErrPodControllerPodNotStarted = errkit.NewPureError("pod is not yet started") + ErrPodControllerNotInitialized = errkit.NewSentinelErr("pod has not been initialized") + ErrPodControllerPodAlreadyStarted = errkit.NewSentinelErr("pod has already been started") + ErrPodControllerPodNotReady = errkit.NewSentinelErr("pod is not yet ready") + ErrPodControllerPodNotStarted = errkit.NewSentinelErr("pod is not yet started") PodControllerDefaultStopTime = 30 * time.Second PodControllerInfiniteStopTime = 0 * time.Second ) diff --git a/pkg/kube/pod_file_writer_test.go b/pkg/kube/pod_file_writer_test.go index ac9180748f..7c9f1dc3be 100644 --- a/pkg/kube/pod_file_writer_test.go +++ b/pkg/kube/pod_file_writer_test.go @@ -79,7 +79,7 @@ func (s *PodFileWriterTestSuite) TestPodRunnerWriteFile(c *C) { ctx := context.Background() cli := fake.NewSimpleClientset() - simulatedError := errkit.NewPureError("SimulatedError") + simulatedError := errkit.NewSentinelErr("SimulatedError") cases := map[string]func(pfwp *fakePodFileWriterProcessor, pfw PodFileWriter){ "Write to pod failed": func(pfwp *fakePodFileWriterProcessor, pfw PodFileWriter) { diff --git a/pkg/kube/workload.go b/pkg/kube/workload.go index a03b93ca76..0d492f371d 100644 --- a/pkg/kube/workload.go +++ b/pkg/kube/workload.go @@ -310,7 +310,7 @@ func FetchReplicationController(cli kubernetes.Interface, namespace string, uid return nil, nil } -var errNotFound = errkit.NewPureError("not found") +var errNotFound = errkit.NewSentinelErr("not found") // FetchReplicaSet fetches the replicaset matching the specified owner UID func FetchReplicaSet(cli kubernetes.Interface, namespace string, uid types.UID, revision string) (*appsv1.ReplicaSet, error) { @@ -518,7 +518,7 @@ func IsPodRunning(cli kubernetes.Interface, podName, podNamespace string) (bool, func StatefulSetReplicas(ctx context.Context, kubeCli kubernetes.Interface, namespace, name string) (int32, error) { sts, err := kubeCli.AppsV1().StatefulSets(namespace).Get(ctx, name, metav1.GetOptions{}) if err != nil { - return 0, errors.Wrapf(err, "Could not get StatefulSet{Namespace %s, Name: %s}, to figure out replicas", namespace, name) + return 0, errkit.Wrap(err, "Could not get StatefulSet, to figure out replicas", "Namespace", namespace, "StatefulSet", name) } return *sts.Spec.Replicas, nil } @@ -526,7 +526,7 @@ func StatefulSetReplicas(ctx context.Context, kubeCli kubernetes.Interface, name func DeploymentReplicas(ctx context.Context, kubeCli kubernetes.Interface, namespace, name string) (int32, error) { d, err := kubeCli.AppsV1().Deployments(namespace).Get(ctx, name, metav1.GetOptions{}) if err != nil { - return 0, errors.Wrapf(err, "Could not get Deployment{Namespace %s, Name: %s}, to figure out replicas", namespace, name) + return 0, errkit.Wrap(err, "Could not get Deployment, to figure out replicas", "Namespace", namespace, "Deployment", name) } return *d.Spec.Replicas, nil } @@ -534,7 +534,7 @@ func DeploymentReplicas(ctx context.Context, kubeCli kubernetes.Interface, names func DeploymentConfigReplicas(ctx context.Context, osCli osversioned.Interface, namespace, name string) (int32, error) { dc, err := osCli.AppsV1().DeploymentConfigs(namespace).Get(ctx, name, metav1.GetOptions{}) if err != nil { - return 0, errors.Wrapf(err, "Could not get DeploymentConfig{Namespace %s, Name: %s}, to figure out replicas", namespace, name) + return 0, errkit.Wrap(err, "Could not get DeploymentConfig, to figure out replicas", "Namespace", namespace, "DeploymentConfig", name) } return dc.Spec.Replicas, nil }