- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 632 for Decoders (0.34 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)