Commit 2df5bb41 authored by Kubernetes Submit Queue's avatar Kubernetes Submit Queue Committed by GitHub

Merge pull request #39463 from NickrenREN/kubelet-stream-error-drop

Automatic merge from submit-queue (batch tested with PRs 39768, 39463) modify Umask() and delete ErrorTimeout function ErrorTimeout() is never used,remove it. And modify Umask() args
parents 12b344aa ad1f0d30
...@@ -20,7 +20,6 @@ import ( ...@@ -20,7 +20,6 @@ import (
"fmt" "fmt"
"net/http" "net/http"
"strconv" "strconv"
"time"
"google.golang.org/grpc" "google.golang.org/grpc"
"google.golang.org/grpc/codes" "google.golang.org/grpc/codes"
...@@ -30,10 +29,6 @@ func ErrorStreamingDisabled(method string) error { ...@@ -30,10 +29,6 @@ func ErrorStreamingDisabled(method string) error {
return grpc.Errorf(codes.NotFound, fmt.Sprintf("streaming method %s disabled", method)) return grpc.Errorf(codes.NotFound, fmt.Sprintf("streaming method %s disabled", method))
} }
func ErrorTimeout(op string, timeout time.Duration) error {
return grpc.Errorf(codes.DeadlineExceeded, fmt.Sprintf("%s timed out after %s", op, timeout.String()))
}
// The error returned when the maximum number of in-flight requests is exceeded. // The error returned when the maximum number of in-flight requests is exceeded.
func ErrorTooManyInFlight() error { func ErrorTooManyInFlight() error {
return grpc.Errorf(codes.ResourceExhausted, "maximum number of in-flight requests exceeded") return grpc.Errorf(codes.ResourceExhausted, "maximum number of in-flight requests exceeded")
......
...@@ -22,6 +22,6 @@ import ( ...@@ -22,6 +22,6 @@ import (
"errors" "errors"
) )
func Umask(mask int) (old int, err error) { func Umask(mask int) (int, error) {
return 0, errors.New("platform and architecture is not supported") return 0, errors.New("platform and architecture is not supported")
} }
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