- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for unmarshalV1 (0.21 sec)
-
cmd/storage-datatypes_gen.go
func (z BaseOptions) MarshalMsg(b []byte) (o []byte, err error) { o = msgp.Require(b, z.Msgsize()) // map header, size 0 _ = z o = append(o, 0x80) return } // UnmarshalMsg implements msgp.Unmarshaler func (z *BaseOptions) UnmarshalMsg(bts []byte) (o []byte, err error) { var field []byte _ = field var zb0001 uint32 zb0001, bts, err = msgp.ReadMapHeaderBytes(bts) if err != nil { err = msgp.WrapError(err)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 130.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/authenticator/token/oidc/oidc_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 97.7K bytes - Viewed (0) -
cmd/object-handlers_test.go
if err != nil { t.Fatalf("[%s] Failed to read NewMultipartUpload response <ERROR> %v", instanceType, err) } err = xml.Unmarshal(mpartRespBytes, &mpartResp) if err != nil { t.Fatalf("[%s] Failed to unmarshal NewMultipartUpload response <ERROR> %v", instanceType, err) } noAPIErr := APIError{} missingDateHeaderErr := getAPIError(ErrMissingDateHeader)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 161.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go
} inMap := map[string]interface{}{} if err := json.Unmarshal(inBytes, &inMap); err != nil { t.Fatalf("failed to json.Unmarshal(in): %v", err) } outMap := map[string]interface{}{} if err := json.Unmarshal(outBytes, &outMap); err != nil { t.Fatalf("failed to json.Unmarshal(out): %v", err) } // Patch the maps to handle any expected differences before we compare
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 101.8K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_builder_test.go
t.Helper() if c.TransportSocket == nil { return nil } tlsContext := &tls.UpstreamTlsContext{} err := c.TransportSocket.GetTypedConfig().UnmarshalTo(tlsContext) if err != nil { t.Fatalf("Failed to unmarshall tls context: %v", err) } return tlsContext } func TestShouldH2Upgrade(t *testing.T) { tests := []struct { name string clusterName string
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 110.4K bytes - Viewed (0) -
src/crypto/x509/x509_test.go
t.Errorf("Marshal(rsa.PublicKey) = %x, want %x", derBytes2, derBytes) } pub3 := new(rsa.PublicKey) rest, err := asn1.Unmarshal(derBytes, pub3) if err != nil { t.Errorf("Unmarshal(rsa.PublicKey): %v", err) } if len(rest) != 0 || pub.N.Cmp(pub3.N) != 0 || pub.E != pub3.E { t.Errorf("Unmarshal(rsa.PublicKey) = %+v, %q want %+v, %q", pub, rest, pub2, []byte(nil)) } publicKeys := []struct {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:00:16 UTC 2024 - 163.4K bytes - Viewed (0) -
cmd/site-replication.go
var ver struct { Version int `json:"version"` } err = json.Unmarshal(buf, &ver) if err != nil { return err } if ver.Version != srStateFormatVersion1 { return fmt.Errorf("Unexpected ClusterRepl state version: %d", ver.Version) } var sdata srStateData err = json.Unmarshal(buf, &sdata) if err != nil { return err } c.Lock() defer c.Unlock()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 184.3K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_test.go
anyOptions := cluster.TypedExtensionProtocolOptions[v3.HttpProtocolOptionsType] g.Expect(anyOptions).NotTo(BeNil()) httpProtocolOptions := &http.HttpProtocolOptions{} anyOptions.UnmarshalTo(httpProtocolOptions) g.Expect(httpProtocolOptions.CommonHttpProtocolOptions.MaxRequestsPerConnection.GetValue()). To(Equal(uint32(expected.Http.MaxRequestsPerConnection)))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 108.8K bytes - Viewed (0) -
cmd/server_test.go
func verifyError(c *check, response *http.Response, code, description string, statusCode int) { c.Helper() data, err := io.ReadAll(response.Body) c.Assert(err, nil) errorResponse := APIErrorResponse{} err = xml.Unmarshal(data, &errorResponse) c.Assert(err, nil) c.Assert(errorResponse.Code, code) c.Assert(errorResponse.Message, description) c.Assert(response.StatusCode, statusCode) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 115.3K bytes - Viewed (0) -
pkg/kubelet/kubelet_node_status_test.go
if err != nil { return nil, fmt.Errorf("failed to apply strategic merge patch %q on node %#v: %v", patch, originalNode, err) } updatedNode := &v1.Node{} if err := json.Unmarshal(updated, updatedNode); err != nil { return nil, fmt.Errorf("failed to unmarshal updated node %q: %v", updated, err) } return updatedNode, nil } func notImplemented(action core.Action) (bool, runtime.Object, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 08 19:23:19 UTC 2024 - 115.8K bytes - Viewed (0)