- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 72 for doDecode (0.13 sec)
-
internal/s3select/select.go
return s3Select.recordReader.Close() } // NewS3Select - creates new S3Select by given request XML reader. func NewS3Select(r io.Reader) (*S3Select, error) { s3Select := &S3Select{} if err := xml.NewDecoder(r).Decode(s3Select); err != nil { return nil, err } return s3Select, nil } ////////////////// // Helpers /////////////////
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 21K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/ConfigurationCacheState.kt
} return readNestedBuildState(build) } private fun readNestedBuildState(build: ConfigurationCacheBuild): CachedBuildState { build.gradle.loadGradleProperties() // Decode the build state using the contextualized IO service for the build return build.gradle.serviceOf<ConfigurationCacheIO>().readIncludedBuildStateFrom( stateFileFor((build.state as NestedBuildState).buildDefinition),
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:30 UTC 2024 - 34.8K bytes - Viewed (0) -
pilot/pkg/bootstrap/istio_ca.go
if len(jwtSplit) != 3 { return nil, fmt.Errorf("invalid JWT parts: %s", jwt) } payload := jwtSplit[1] payloadBytes, err := util.DecodeJwtPart(payload) if err != nil { return nil, fmt.Errorf("failed to decode jwt: %v", err.Error()) } structuredPayload := &authenticate.JwtPayload{} err = json.Unmarshal(payloadBytes, &structuredPayload) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 20.6K bytes - Viewed (0) -
cmd/format-erasure.go
// same. 'volume not found' usually means its a fresh disk. if errors.Is(err, errFileNotFound) || errors.Is(err, errVolumeNotFound) { return nil, errUnformattedDisk } return nil, err } // Try to decode format json into formatConfigV1 struct. format = &formatErasureV3{} if err = json.Unmarshal(data, format); err != nil { return nil, err } if heal {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 23.2K bytes - Viewed (0) -
src/encoding/gob/encode.go
inProgress[rt] = &op // Special cases switch t := typ; t.Kind() { case reflect.Slice: if t.Elem().Kind() == reflect.Uint8 { op = encUint8Array break } // Slices have a header; we decode it to find the underlying array. elemOp, elemIndir := encOpFor(t.Elem(), inProgress, building) helper := encSliceHelper[t.Elem().Kind()] op = func(i *encInstr, state *encoderState, slice reflect.Value) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 02:00:26 UTC 2024 - 19K bytes - Viewed (0) -
src/cmd/vendor/github.com/google/pprof/profile/profile.go
// See the License for the specific language governing permissions and // limitations under the License. // Package profile provides a representation of profile.proto and // methods to encode/decode profiles in this format. package profile import ( "bytes" "compress/gzip" "fmt" "io" "math" "path/filepath" "regexp" "sort" "strings" "sync" "time" )
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 31 19:48:28 UTC 2024 - 22.3K bytes - Viewed (0) -
pkg/kube/inject/inject.go
} if err != nil { return nil, err } patched, err := applyJSONPatchToPod(pod, patchBytes) if err != nil { return nil, err } patchedObject, _, err := jsonSerializer.Decode(patched, nil, &corev1.Pod{}) if err != nil { return nil, err } patchedPod := patchedObject.(*corev1.Pod) *metadata = patchedPod.ObjectMeta *podSpec = patchedPod.Spec return out, nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 20:35:11 UTC 2024 - 28.8K bytes - Viewed (1) -
cmd/metacache-entries.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 04:34:26 UTC 2024 - 24K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/patch.go
if err != nil { return interpretStrategicMergePatchError(err) } // Rather than serialize the patched map to JSON, then decode it to an object, we go directly from a map to an object converter := runtime.DefaultUnstructuredConverter returnUnknownFields := validationDirective == metav1.FieldValidationWarn || validationDirective == metav1.FieldValidationStrict
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 28.5K bytes - Viewed (0) -
cmd/utils.go
if size > 0 { lbody = io.LimitReader(body, size) } else { lbody = body } d := xml.NewDecoder(lbody) // Ignore any encoding set in the XML body d.CharsetReader = nopCharsetConverter err := d.Decode(v) if errors.Is(err, io.EOF) { err = &xml.SyntaxError{ Line: 0, Msg: err.Error(), } } return err } // hasContentMD5 returns true if Content-MD5 header is set.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Jun 05 22:00:34 UTC 2024 - 31.9K bytes - Viewed (0)