Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NewFrameReader (0.28 sec)

  1. pkg/api/testing/serialization_test.go

    		}
    		out := &bytes.Buffer{}
    		w := framer.NewFrameWriter(out)
    		if n, err := w.Write(obj.Bytes()); err != nil || n != len(obj.Bytes()) {
    			t.Fatal(err)
    		}
    		sr := streaming.NewDecoder(framer.NewFrameReader(io.NopCloser(out)), s)
    		resultSecret := &v1.Secret{}
    		res, _, err := sr.Decode(nil, resultSecret)
    		if err != nil {
    			t.Fatalf("%v:\n%s", err, hex.Dump(obj.Bytes()))
    		}
    		resultSecret.Kind = "Secret"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Sep 25 11:04:08 UTC 2023
    - 19.3K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apimachinery/pkg/runtime/interfaces.go

    	EncodeParameters(obj Object, to schema.GroupVersion) (url.Values, error)
    }
    
    // Framer is a factory for creating readers and writers that obey a particular framing pattern.
    type Framer interface {
    	NewFrameReader(r io.ReadCloser) io.ReadCloser
    	NewFrameWriter(w io.Writer) io.Writer
    }
    
    // SerializerInfo contains information about a specific serialization format
    type SerializerInfo struct {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun May 28 03:26:35 UTC 2023
    - 19K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/endpoints/watch_test.go

    				}
    				objectCodec := codecs.DecoderToVersion(info.Serializer, testInternalGroupVersion)
    
    				var fr io.ReadCloser = r
    				if !protocol.selfFraming {
    					fr = streamSerializer.Framer.NewFrameReader(r)
    				}
    				d := streaming.NewDecoder(fr, streamSerializer.Serializer)
    
    				var w *watch.FakeWatcher
    				for w == nil {
    					w = simpleStorage.Watcher()
    					time.Sleep(time.Millisecond)
    				}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Nov 30 17:27:39 UTC 2023
    - 30K bytes
    - Viewed (0)
Back to top