- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 177 for unmarshaler (1 sec)
-
istioctl/pkg/writer/pilot/status.go
for _, dr := range drs { for _, resource := range dr.Resources { clientConfig := xdsstatus.ClientConfig{} err := resource.UnmarshalTo(&clientConfig) if err != nil { return nil, nil, fmt.Errorf("could not unmarshal ClientConfig: %w", err) } meta, err := model.ParseMetadata(clientConfig.GetNode().GetMetadata()) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 15 04:16:55 UTC 2024 - 6.1K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/generated.pb.go
func (*APIGroup) ProtoMessage() {} func (*APIGroup) Descriptor() ([]byte, []int) { return fileDescriptor_a8431b6e0aeeb761, []int{0} } func (m *APIGroup) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *APIGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) if err != nil { return nil, err } return b[:n], nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:37 UTC 2024 - 281.4K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy_delta_test.go
} gotEcdsConfig := &core.TypedExtensionConfig{} if err := gotResp.Resources[0].Resource.UnmarshalTo(gotEcdsConfig); err != nil { t.Fatalf("wasm config conversion output %v failed to unmarshal", gotResp.Resources[0]) } assert.Equal(t, gotResp.Resources[0].Name, "extension-config") wasm := &wasm.Wasm{ Config: &wasmv3.PluginConfig{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 04:48:02 UTC 2024 - 6.3K bytes - Viewed (0) -
cmd/xl-storage-format-v1.go
Hash: hex.EncodeToString(c.Hash), } return json.Marshal(info) } // UnmarshalJSON - custom checksum info unmarshaller func (c *ChecksumInfo) UnmarshalJSON(data []byte) error { var info checksumInfoJSON json := jsoniter.ConfigCompatibleWithStandardLibrary if err := json.Unmarshal(data, &info); err != nil { return err } sum, err := hex.DecodeString(info.Hash) if err != nil { return err }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 8.2K bytes - Viewed (0) -
istioctl/pkg/describe/describe.go
err = l.ActiveState.Listener.UnmarshalTo(listenerTyped) if err != nil { return nil, err } if listenerTyped.Name == model.VirtualInboundListenerName { for _, filterChain := range listenerTyped.FilterChains { for _, filter := range filterChain.Filters { hcm := &hcm.HttpConnectionManager{} if err := filter.GetTypedConfig().UnmarshalTo(hcm); err == nil { return hcm, nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Apr 13 05:23:38 UTC 2024 - 50.4K bytes - Viewed (0) -
src/net/lookup.go
break } if err != nil { return "", nil, &DNSError{ Err: "cannot unmarshal DNS message", Name: name, Server: server, } } if h.Type != dnsmessage.TypeSRV { if err := p.SkipAnswer(); err != nil { return "", nil, &DNSError{ Err: "cannot unmarshal DNS message", Name: name, Server: server, } } continue }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Apr 14 18:23:45 UTC 2024 - 28.6K bytes - Viewed (0) -
src/internal/chacha8rand/chacha8.go
} return data } type errUnmarshalChaCha8 struct{} func (*errUnmarshalChaCha8) Error() string { return "invalid ChaCha8 encoding" } // Unmarshal unmarshals the state from a byte slice. func Unmarshal(s *State, data []byte) error { if len(data) != 6*8 || string(data[:8]) != "chacha8:" { return new(errUnmarshalChaCha8) } used := byteorder.BeUint64(data[1*8:])
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 13 21:47:29 UTC 2024 - 4.4K bytes - Viewed (0) -
staging/src/k8s.io/api/scheduling/v1/generated.pb.go
func (*PriorityClass) ProtoMessage() {} func (*PriorityClass) Descriptor() ([]byte, []int) { return fileDescriptor_3f12bd05064e996e, []int{0} } func (m *PriorityClass) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *PriorityClass) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) if err != nil { return nil, err } return b[:n], nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:37 UTC 2024 - 18.8K bytes - Viewed (0) -
pkg/proxy/util/linebuffer.go
// returns the number of times Write() or WriteBytes() was called; it assumes that // you never wrote any newlines to the buffer yourself. Lines() int } var _ logr.Marshaler = &realLineBuffer{} type realLineBuffer struct { b bytes.Buffer lines int } // NewLineBuffer returns a new "real" LineBuffer func NewLineBuffer() LineBuffer { return &realLineBuffer{} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 3.7K bytes - Viewed (0) -
cmd/kubeadm/app/util/config/upgradeconfiguration.go
// Set internalcfg to an empty struct value the deserializer will populate internalcfg = &kubeadmapi.UpgradeConfiguration{} // Decode the bytes into the internal struct. Under the hood, the bytes will be unmarshalled into the // right external version, defaulted, and converted into the internal version. if err := runtime.DecodeInto(kubeadmscheme.Codecs.UniversalDecoder(), bytes, internalcfg); err != nil { return nil, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 11:04:08 UTC 2024 - 7.8K bytes - Viewed (0)