- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 177 for unmarshaler (0.23 sec)
-
pkg/kube/inject/webhook.go
var existingKubeAppProber KubeAppProbers err := json.Unmarshal([]byte(env.Value), &existingKubeAppProber) if err != nil { log.Errorf("failed to unmarshal existing kubeAppProbers %v", err) return envVars } var newKubeAppProber KubeAppProbers err = json.Unmarshal([]byte(newProbers), &newKubeAppProber) if err != nil { log.Errorf("failed to unmarshal new kubeAppProbers %v", err) return envVars }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 17:59:39 UTC 2024 - 42.2K bytes - Viewed (0) -
src/regexp/all_test.go
} func TestUnmarshalText(t *testing.T) { unmarshaled := new(Regexp) for i := range goodRe { re := compileTest(t, goodRe[i], "") marshaled, err := re.MarshalText() if err != nil { t.Errorf("regexp %#q failed to marshal: %s", re, err) continue } if err := unmarshaled.UnmarshalText(marshaled); err != nil { t.Errorf("regexp %#q failed to unmarshal: %s", re, err) continue }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:36:03 UTC 2024 - 25.8K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconstruct_common.go
utilstrings "k8s.io/utils/strings" ) // these interfaces are necessary to keep the structures private // and at the same time log them correctly in structured logs. var _ logr.Marshaler = podVolume{} var _ logr.Marshaler = reconstructedVolume{} var _ logr.Marshaler = globalVolumeInfo{} type podVolume struct { podName volumetypes.UniquePodName volumeSpecName string volumePath string pluginName string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 14.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/interfaces.go
// match 'opts.ResourceVersion' according 'opts.ResourceVersionMatch'. Get(ctx context.Context, key string, opts GetOptions, objPtr runtime.Object) error // GetList unmarshalls objects found at key into a *List api object (an object // that satisfies runtime.IsList definition). // If 'opts.Recursive' is false, 'key' is used as an exact match. If `opts.Recursive'
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 07:53:48 UTC 2024 - 14.8K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/configdump.go
// TODO(fisherxu): migrate this to jsonpb when issue fixed in golang // Issue to track -> https://github.com/golang/protobuf/issues/632 err := json.Unmarshal(b, rawDump) if err != nil { return fmt.Errorf("error unmarshalling config dump response from ztunnel: %v", err) } // ensure that data gets unmarshalled into the right data type if err := unmarshalListOrMap(rawDump.Services, &zDump.Services); err != nil { return err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 20:18:34 UTC 2024 - 3.9K bytes - Viewed (0) -
pilot/pkg/xds/nds_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 16:59:05 UTC 2024 - 4.6K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy.go
} if ia.localDNSServer != nil { proxy.handlers[model.NameTableType] = func(resp *anypb.Any) error { var nt dnsProto.NameTable if err := resp.UnmarshalTo(&nt); err != nil { log.Errorf("failed to unmarshal name table: %v", err) return err } ia.localDNSServer.UpdateLookupTable(&nt) return nil } } if ia.cfg.EnableDynamicProxyConfig && ia.secretCache != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 27.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/micro_time.go
return MicroTime{time.Unix(sec, nsec)} } // UnmarshalJSON implements the json.Unmarshaller interface. func (t *MicroTime) UnmarshalJSON(b []byte) error { if len(b) == 4 && string(b) == "null" { t.Time = time.Time{} return nil } var str string err := json.Unmarshal(b, &str) if err != nil { return err } pt, err := time.Parse(RFC3339Micro, str) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 21:48:10 UTC 2024 - 5.2K bytes - Viewed (0) -
staging/src/k8s.io/api/rbac/v1beta1/generated.pb.go
func (*AggregationRule) ProtoMessage() {} func (*AggregationRule) Descriptor() ([]byte, []int) { return fileDescriptor_c5bc2d145acd4e45, []int{0} } func (m *AggregationRule) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *AggregationRule) 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 - 77.6K bytes - Viewed (0) -
staging/src/k8s.io/api/rbac/v1alpha1/generated.pb.go
func (*AggregationRule) ProtoMessage() {} func (*AggregationRule) Descriptor() ([]byte, []int) { return fileDescriptor_758889dfd9a88fa6, []int{0} } func (m *AggregationRule) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *AggregationRule) 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 - 77.7K bytes - Viewed (0)