kubernetes
/
apiserver
mirror of https://github.com/kubernetes/apiserver.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #72575 from liggitt/flush-streamer-headers 

Flush headers before streaming logs

Kubernetes-commit: 080d2a43ebd667685756d6ee013cef064bd4bf3b
This commit is contained in:
Kubernetes Publisher 2019-01-04 14:10:02 -08:00
parent 84dc8f2ac2 5e146b0a14
commit abe788eb29
2 changed files with 57 additions and 53 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

106
Godeps/Godeps.json generated
View File

@ -1084,215 +1084,215 @@
},
{
"ImportPath": "k8s.io/apimachinery/pkg/api/apitesting",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/api/apitesting/fuzzer",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/api/apitesting/roundtrip",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/api/equality",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/api/errors",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/api/meta",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/api/resource",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/api/validation",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/api/validation/path",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/apis/meta/fuzzer",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/apis/meta/internalversion",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/apis/meta/v1",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/apis/meta/v1/unstructured",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/apis/meta/v1/validation",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/apis/meta/v1beta1",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/conversion",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/conversion/queryparams",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/fields",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/labels",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/runtime",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/runtime/schema",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/runtime/serializer",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/runtime/serializer/json",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/runtime/serializer/protobuf",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/runtime/serializer/recognizer",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/runtime/serializer/streaming",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/runtime/serializer/versioning",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/selection",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/types",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/util/cache",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/util/clock",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/util/diff",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/util/errors",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/util/framer",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/util/intstr",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/util/json",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/util/mergepatch",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/util/naming",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/util/net",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/util/rand",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/util/runtime",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/util/sets",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/util/strategicpatch",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/util/uuid",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/util/validation",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/util/validation/field",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/util/wait",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/util/waitgroup",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/util/yaml",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/version",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/pkg/watch",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/third_party/forked/golang/json",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/apimachinery/third_party/forked/golang/reflect",
"Rev": "0cd393178e09f379032a493f73993dc600e1959d"
"Rev": "849b284f3b756a3fbb5084b09d2718dd41373068"
},
{
"ImportPath": "k8s.io/client-go/discovery",

4
pkg/endpoints/handlers/responsewriters/writers.go
View File

@ -101,6 +101,10 @@ func StreamObject(statusCode int, gv schema.GroupVersion, s runtime.NegotiatedSe
}
w.Header().Set("Content-Type", contentType)
w.WriteHeader(statusCode)
// Flush headers, if possible
if flusher, ok := w.(http.Flusher); ok {
flusher.Flush()
}
writer := w.(io.Writer)
if flush {
writer = flushwriter.Wrap(w)