- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for streamType (0.19 sec)
-
pkg/kubelet/server/server_test.go
require.NoError(t, err, "creating streaming connection") defer conn.Close() h := http.Header{} h.Set(api.StreamType, api.StreamTypeError) _, err = conn.CreateStream(h) require.NoError(t, err, "creating error stream") if test.stdin { h.Set(api.StreamType, api.StreamTypeStdin) stream, err := conn.CreateStream(h) require.NoError(t, err, "creating stdin stream")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 51.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtranslator_test.go
} if opts.Stderr { expectedStreams++ } if opts.Tty { expectedStreams++ } WaitForStreams: for { select { case stream := <-streamCh: streamType := stream.Headers().Get(v1.StreamType) switch streamType { case v1.StreamTypeError: replyChan <- struct{}{} ctx.writeStatus = v4WriteStatusFunc(stream) case v1.StreamTypeStdout: replyChan <- struct{}{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 27 23:21:55 UTC 2024 - 36.4K bytes - Viewed (0) -
pkg/apis/core/types.go
// Name of header that specifies stream type StreamType = "streamType" // Value for streamType header for stdin stream StreamTypeStdin = "stdin" // Value for streamType header for stdout stream StreamTypeStdout = "stdout" // Value for streamType header for stderr stream StreamTypeStderr = "stderr" // Value for streamType header for data stream StreamTypeData = "data"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 268.9K bytes - Viewed (0) -
staging/src/k8s.io/api/core/v1/types.go
// Name of header that specifies stream type StreamType = "streamType" // Value for streamType header for stdin stream StreamTypeStdin = "stdin" // Value for streamType header for stdout stream StreamTypeStdout = "stdout" // Value for streamType header for stderr stream StreamTypeStderr = "stderr" // Value for streamType header for data stream StreamTypeData = "data"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 390.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/storage/storage_factory_test.go
&metav1.APIResourceList{}, ) exampleinstall.Install(scheme) } type fakeNegotiater struct { serializer, streamSerializer runtime.Serializer framer runtime.Framer types, streamTypes []string } func (n *fakeNegotiater) SupportedMediaTypes() []runtime.SerializerInfo { var out []runtime.SerializerInfo for _, s := range n.types { mediaType, _, err := mime.ParseMediaType(s)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 20 13:35:58 UTC 2023 - 7.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/negotiation/negotiate_test.go
type statusError interface { Status() metav1.Status } type fakeNegotiater struct { serializer, streamSerializer runtime.Serializer framer runtime.Framer types, streamTypes []string } func (n *fakeNegotiater) SupportedMediaTypes() []runtime.SerializerInfo { var out []runtime.SerializerInfo for _, s := range n.types { mediaType, _, err := mime.ParseMediaType(s)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 10 10:53:34 UTC 2019 - 9K bytes - Viewed (0)