mirror of https://github.com/k3s-io/k3s
tweak a list to a watch verb when requested
parent
8bf4a3207a
commit
ec91c009e7
|
@ -21,6 +21,7 @@ import (
|
||||||
"net"
|
"net"
|
||||||
"net/http"
|
"net/http"
|
||||||
"strconv"
|
"strconv"
|
||||||
|
"strings"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
utilnet "k8s.io/apimachinery/pkg/util/net"
|
utilnet "k8s.io/apimachinery/pkg/util/net"
|
||||||
|
@ -99,6 +100,10 @@ func InstrumentRouteFunc(verb, resource string, routeFunc restful.RouteFunction)
|
||||||
response.ResponseWriter = rw
|
response.ResponseWriter = rw
|
||||||
|
|
||||||
routeFunc(request, response)
|
routeFunc(request, response)
|
||||||
|
|
||||||
|
if verb == "LIST" && strings.ToLower(request.QueryParameter("watch")) == "true" {
|
||||||
|
verb = "WATCH"
|
||||||
|
}
|
||||||
Monitor(&verb, &resource, utilnet.GetHTTPClient(request.Request), rw.Header().Get("Content-Type"), delegate.status, now)
|
Monitor(&verb, &resource, utilnet.GetHTTPClient(request.Request), rw.Header().Get("Content-Type"), delegate.status, now)
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue