Commit fe69dcf8 authored by Kubernetes Submit Queue's avatar Kubernetes Submit Queue Committed by GitHub

Merge pull request #40018 from sttts/sttts-genericapiserver-storage-dep

Automatic merge from submit-queue (batch tested with PRs 40008, 40005, 40018) Fix wrong rename pkg/storage.Is{TestFail -> Conflict}
parents 3a77dd18 72719214
...@@ -65,7 +65,7 @@ func InterpretCreateError(err error, qualifiedResource schema.GroupResource, nam ...@@ -65,7 +65,7 @@ func InterpretCreateError(err error, qualifiedResource schema.GroupResource, nam
// operation into the appropriate API error. // operation into the appropriate API error.
func InterpretUpdateError(err error, qualifiedResource schema.GroupResource, name string) error { func InterpretUpdateError(err error, qualifiedResource schema.GroupResource, name string) error {
switch { switch {
case storage.IsTestFailed(err), storage.IsNodeExist(err), storage.IsInvalidObj(err): case storage.IsConflict(err), storage.IsNodeExist(err), storage.IsInvalidObj(err):
return errors.NewConflict(qualifiedResource, name, err) return errors.NewConflict(qualifiedResource, name, err)
case storage.IsUnreachable(err): case storage.IsUnreachable(err):
return errors.NewServerTimeout(qualifiedResource, "update", 2) // TODO: make configurable or handled at a higher level return errors.NewServerTimeout(qualifiedResource, "update", 2) // TODO: make configurable or handled at a higher level
...@@ -86,7 +86,7 @@ func InterpretDeleteError(err error, qualifiedResource schema.GroupResource, nam ...@@ -86,7 +86,7 @@ func InterpretDeleteError(err error, qualifiedResource schema.GroupResource, nam
return errors.NewNotFound(qualifiedResource, name) return errors.NewNotFound(qualifiedResource, name)
case storage.IsUnreachable(err): case storage.IsUnreachable(err):
return errors.NewServerTimeout(qualifiedResource, "delete", 2) // TODO: make configurable or handled at a higher level return errors.NewServerTimeout(qualifiedResource, "delete", 2) // TODO: make configurable or handled at a higher level
case storage.IsTestFailed(err), storage.IsNodeExist(err), storage.IsInvalidObj(err): case storage.IsConflict(err), storage.IsNodeExist(err), storage.IsInvalidObj(err):
return errors.NewConflict(qualifiedResource, name, err) return errors.NewConflict(qualifiedResource, name, err)
case storage.IsInternalError(err): case storage.IsInternalError(err):
return errors.NewInternalError(err) return errors.NewInternalError(err)
......
...@@ -52,7 +52,7 @@ func apiStatus(err error) *metav1.Status { ...@@ -52,7 +52,7 @@ func apiStatus(err error) *metav1.Status {
status := http.StatusInternalServerError status := http.StatusInternalServerError
switch { switch {
//TODO: replace me with NewConflictErr //TODO: replace me with NewConflictErr
case storage.IsTestFailed(err): case storage.IsConflict(err):
status = http.StatusConflict status = http.StatusConflict
} }
// Log errors that were not converted to an error status // Log errors that were not converted to an error status
......
...@@ -105,8 +105,8 @@ func IsUnreachable(err error) bool { ...@@ -105,8 +105,8 @@ func IsUnreachable(err error) bool {
return isErrCode(err, ErrCodeUnreachable) return isErrCode(err, ErrCodeUnreachable)
} }
// IsTestFailed returns true if and only if err is a write conflict. // IsConflict returns true if and only if err is a write conflict.
func IsTestFailed(err error) bool { func IsConflict(err error) bool {
return isErrCode(err, ErrCodeResourceVersionConflicts) return isErrCode(err, ErrCodeResourceVersionConflicts)
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment