Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for streamType (0.16 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
Back to top