Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 632 for Decoders (0.34 sec)

  1. staging/src/k8s.io/apiserver/pkg/server/storage/storage_codec.go

    	s := serializer.Serializer
    
    	// Give callers the opportunity to wrap encoders and decoders.  For decoders, each returned decoder will
    	// be passed to the recognizer so that multiple decoders are available.
    	var encoder runtime.Encoder = s
    	if opts.EncoderDecoratorFn != nil {
    		encoder = opts.EncoderDecoratorFn(encoder)
    	}
    	decoders := []runtime.Decoder{
    		// selected decoder as the primary
    		s,
    		// universal deserializer as a fallback
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Nov 05 15:03:23 UTC 2022
    - 3.8K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apimachinery/pkg/runtime/serializer/recognizer/recognizer.go

    }
    
    // NewDecoder creates a decoder that will attempt multiple decoders in an order defined
    // by:
    //
    // 1. The decoder implements RecognizingDecoder and identifies the data
    // 2. All other decoders, and any decoder that returned true for unknown.
    //
    // The order passed to the constructor is preserved within those priorities.
    func NewDecoder(decoders ...runtime.Decoder) runtime.Decoder {
    	return &decoder{
    		decoders: decoders,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Nov 19 21:24:36 UTC 2021
    - 3.5K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apimachinery/pkg/runtime/helper.go

    		objects[i] = &Unknown{Raw: data}
    	}
    	return errors.NewAggregate(errs)
    }
    
    func decodeListItem(obj *Unknown, decoders []Decoder) (Object, error) {
    	for _, decoder := range decoders {
    		// TODO: Decode based on ContentType.
    		obj, err := Decode(decoder, obj.Raw)
    		if err != nil {
    			if IsNotRegisteredError(err) {
    				continue
    			}
    			return nil, err
    		}
    		return obj, nil
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Dec 13 22:54:34 UTC 2023
    - 8.4K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apimachinery/pkg/runtime/serializer/json/json_limit_test.go

    			benchmark: true,
    		},
    	}
    }
    
    var decoders = map[string]func([]byte, interface{}) error{
    	"gojson":   gojson.Unmarshal,
    	"utiljson": utiljson.Unmarshal,
    }
    
    func TestJSONLimits(t *testing.T) {
    	for _, tc := range testcases() {
    		if tc.benchmark {
    			continue
    		}
    		t.Run(tc.name, func(t *testing.T) {
    			for decoderName, decoder := range decoders {
    				t.Run(decoderName, func(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Oct 20 16:49:23 UTC 2021
    - 4.5K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apimachinery/pkg/runtime/serializer/codec_factory.go

    	}
    	return versioning.NewDefaultingCodecForScheme(f.scheme, encoder, decoder, encode, decode)
    }
    
    // DecoderToVersion returns a decoder that targets the provided group version.
    func (f CodecFactory) DecoderToVersion(decoder runtime.Decoder, gv runtime.GroupVersioner) runtime.Decoder {
    	return f.CodecForVersions(nil, decoder, nil, gv)
    }
    
    // EncoderForVersion returns an encoder that targets the provided group version.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Dec 18 04:27:38 UTC 2022
    - 12.6K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/server/storage/storage_factory.go

    	encoderDecoratorFn func(runtime.Encoder) runtime.Encoder
    	// decoderDecoratorFn is optional and may wrap the provided decoders (can add new decoders). The order of
    	// returned decoders will be priority for attempt to decode.
    	decoderDecoratorFn func([]runtime.Decoder) []runtime.Decoder
    }
    
    // Apply overrides the provided config and options if the override has a value in that position
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 20 13:35:58 UTC 2023
    - 14.1K bytes
    - Viewed (0)
  7. src/encoding/binary/binary_test.go

    		t.Fatal(err)
    	}
    
    	for _, dec := range decoders {
    		t.Run(dec.name, func(t *testing.T) {
    			defer func() {
    				if recover() == nil {
    					t.Fatal("did not panic")
    				}
    			}()
    			var u2 Unexported
    			dec.fn(LittleEndian, &u2, buf.Bytes())
    		})
    	}
    
    }
    
    func TestReadErrorMsg(t *testing.T) {
    	for _, dec := range decoders {
    		t.Run(dec.name, func(t *testing.T) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon May 20 19:16:18 UTC 2024
    - 25.4K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apimachinery/pkg/runtime/serializer/streaming/streaming.go

    	NewEncoder(w io.Writer) Encoder
    	NewDecoder(r io.ReadCloser) Decoder
    }
    
    type decoder struct {
    	reader    io.ReadCloser
    	decoder   runtime.Decoder
    	buf       []byte
    	maxBytes  int
    	resetRead bool
    }
    
    // NewDecoder creates a streaming decoder that reads object chunks from r and decodes them with d.
    // The reader is expected to return ErrShortRead if the provided buffer is not large enough to read
    // an entire object.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Aug 25 14:51:36 UTC 2023
    - 3.7K bytes
    - Viewed (0)
  9. src/mime/quotedprintable/reader.go

    	softSuffix = []byte("=")
    )
    
    // Read reads and decodes quoted-printable data from the underlying reader.
    func (r *Reader) Read(p []byte) (n int, err error) {
    	// Deviations from RFC 2045:
    	// 1. in addition to "=\r\n", "=\n" is also treated as soft line break.
    	// 2. it will pass through a '\r' or '\n' not preceded by '=', consistent
    	//    with other broken QP encoders & decoders.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jun 27 17:00:08 UTC 2018
    - 3.6K bytes
    - Viewed (0)
  10. platforms/core-configuration/graph-serialization/src/main/kotlin/org/gradle/internal/serialize/graph/package-info.java

     * limitations under the License.
     */
    
    /**
     * This subsystem implements serialization of configuration state.
     * <h2>Key abstractions</h2>
     *
     * <h3>Encoders and Decoders</h3>
     *  <p>
     *  Serialization of an object that is supported by the configuration cache is performed by an {@link org.gradle.internal.serialize.graph.EncodingProvider}.
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Sat Jun 08 11:29:30 UTC 2024
    - 4.7K bytes
    - Viewed (0)
Back to top