- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 216 for qDecode (0.21 sec)
-
staging/src/k8s.io/apimachinery/pkg/runtime/serializer/cbor/internal/modes/decode.go
// timestamps. ByteStringToTime: cbor.ByteStringToTimeAllowed, }.DecMode() if err != nil { panic(err) } return decode }() // DecodeLax is derived from Decode, but does not complain about unknown fields in the input. var DecodeLax cbor.DecMode = func() cbor.DecMode { opts := Decode.DecOptions() opts.ExtraReturnErrors &^= cbor.ExtraDecErrorUnknownField // clear bit dm, err := opts.DecMode() if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 14:03:36 UTC 2024 - 3.9K bytes - Viewed (0) -
cmd/erasure-decode.go
} // If we cannot decode, just return read quorum error. return nil, fmt.Errorf("%w (offline-disks=%d/%d)", errErasureReadQuorum, disksNotFound, len(p.readers)) } // Decode reads from readers, reconstructs data if needed and writes the data to the writer. // A set of preferred drives can be supplied. In that case they will be used and the data reconstructed.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue May 21 14:36:21 UTC 2024 - 9.4K bytes - Viewed (0) -
src/encoding/json/decode.go
rv := reflect.ValueOf(v) if rv.Kind() != reflect.Pointer || rv.IsNil() { return &InvalidUnmarshalError{reflect.TypeOf(v)} } d.scan.reset() d.scanWhile(scanSkipSpace) // We decode rv not rv.Elem because the Unmarshaler interface // test must be applied at the top level of the value. err := d.value(rv) if err != nil { return d.addErrorContext(err) } return d.savedError }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 00:18:55 UTC 2024 - 35.3K bytes - Viewed (0) -
src/encoding/gob/encoder_test.go
in, out any } var ignoreTests = []ignoreTest{ // Decode normal struct into an empty struct {&struct{ A int }{23}, &struct{}{}}, // Decode normal struct into a nil. {&struct{ A int }{23}, nil}, // Decode singleton string into a nil. {"hello, world", nil}, // Decode singleton slice into a nil. {[]int{1, 2, 3, 4}, nil}, // Decode struct containing an interface into a nil.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 29.7K bytes - Viewed (0) -
platforms/core-configuration/core-serialization-codecs/src/main/kotlin/org/gradle/internal/serialize/codecs/core/IsolatedCodecs.kt
} override suspend fun ReadContext.decode(): NullValueSnapshot { return NullValueSnapshot.INSTANCE } } object IsolatedEnumValueSnapshotCodec : Codec<IsolatedEnumValueSnapshot> { override suspend fun WriteContext.encode(value: IsolatedEnumValueSnapshot) { write(value.value) } override suspend fun ReadContext.decode(): IsolatedEnumValueSnapshot {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 23:09:56 UTC 2024 - 7.3K bytes - Viewed (0) -
platforms/core-configuration/stdlib-serialization-codecs/src/main/kotlin/org/gradle/internal/serialize/codecs/stdlib/ArrayCodecs.kt
} } override suspend fun ReadContext.decode(): Array<*> = readArray { read() } } object ShortArrayCodec : Codec<ShortArray> { override suspend fun WriteContext.encode(value: ShortArray) = writeLengthPrefixedShorts(this, value) override suspend fun ReadContext.decode() = readLengthPrefixedShorts(this) }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat May 25 20:43:52 UTC 2024 - 4.1K bytes - Viewed (0) -
platforms/core-configuration/graph-serialization/src/main/kotlin/org/gradle/internal/serialize/graph/Codec.kt
} } } inline fun <T> ReadContext.decodePreservingIdentity(decode: ReadContext.(Int) -> T): T = decodePreservingIdentity(isolate.identities, decode) inline fun <T : Any> ReadContext.decodePreservingSharedIdentity(decode: ReadContext.(Int) -> T): T = decodePreservingIdentity(sharedIdentities) { id -> decode(id).also { sharedIdentities.putInstance(id, it) } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 23:09:56 UTC 2024 - 7.9K bytes - Viewed (0) -
platforms/core-configuration/graph-serialization/src/main/kotlin/org/gradle/internal/serialize/graph/Combinators.kt
SingletonCodec(value) fun <T> codec( encode: suspend WriteContext.(T) -> Unit, decode: suspend ReadContext.() -> T? ): Codec<T> = object : Codec<T> { override suspend fun WriteContext.encode(value: T) = encode(value) override suspend fun ReadContext.decode(): T? = decode() } inline fun <reified T> IsolateContext.ownerService() = ownerService(T::class.java)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 12:59:39 UTC 2024 - 8.4K bytes - Viewed (0) -
platforms/core-configuration/core-serialization-codecs/src/main/kotlin/org/gradle/internal/serialize/codecs/core/ProviderCodecs.kt
ValueSupplier.ExecutionTimeValue.ofNullable(value).withSideEffect(sideEffect) } 4.toByte() -> ValueSupplier.ExecutionTimeValue.changingValue<Any>(providerWithChangingValueCodec.run { decode() }!!.uncheckedCast()) else -> throw IllegalStateException("Unexpected provider value") } } class FlowProvidersCodec( private val flowProviders: FlowProviders
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:30 UTC 2024 - 17.2K bytes - Viewed (0) -
security/pkg/pki/util/crypto.go
// trailing newline characters removed func PemCertBytestoString(caCerts []byte) []string { certs := []string{} var cert string pemBlock := caCerts for block, rest := pem.Decode(pemBlock); block != nil && len(block.Bytes) != 0; block, rest = pem.Decode(pemBlock) { if len(rest) == 0 { cert = strings.TrimPrefix(strings.TrimSuffix(string(pemBlock), "\n"), "\n") certs = append(certs, cert) break }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 04 13:00:07 UTC 2024 - 5.3K bytes - Viewed (0)