- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for Rendle (0.22 sec)
-
operator/cmd/mesh/profile-dump.go
} return out2, nil } // Convert the generated YAML to pretty JSON. func yamlToPrettyJSON(yml string) (string, error) { // YAML objects are not completely compatible with JSON // objects. Let yaml.YAMLToJSON handle the edge cases and // we'll re-encode the result to pretty JSON. uglyJSON, err := yaml.YAMLToJSON([]byte(yml)) if err != nil { return "", err } var decoded any if uglyJSON[0] == '[' {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 7.1K bytes - Viewed (0) -
istioctl/pkg/util/configdump/wrapper.go
// Wrapper is a wrapper around the Envoy ConfigDump // It has extra helper functions for handling any/struct/marshal protobuf pain type Wrapper struct { *admin.ConfigDump } // UnmarshalJSON is a custom unmarshaller to handle protobuf pain func (w *Wrapper) UnmarshalJSON(b []byte) error { cd := &admin.ConfigDump{} err := protomarshal.UnmarshalAllowUnknownWithAnyResolver(nonStrictResolver, b, cd) *w = Wrapper{cd} return err
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sun Apr 21 17:42:54 GMT 2024 - 1.8K bytes - Viewed (0) -
istioctl/pkg/util/handlers/handlers.go
// Otherwise uses the namespace value passed into the function func inferNsInfo(name, namespace string) (string, string) { if idx := strings.LastIndex(name, "/"); idx > 0 { // If there is a / in it, we need to handle differently. This is resourcetype/name.namespace. // However, resourcetype can have . in it as well, so we should only look for namespace after the /. separator := strings.LastIndex(name[idx:], ".") if separator < 0 {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Feb 06 15:01:41 GMT 2024 - 6.2K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
s.currentPodSnapshot.Ensure(string(pod.UID)) openNetns, err := s.getOrOpenNetns(pod, netNs) if err != nil { return err } // Handle node healthcheck probe rewrites err = addPodToHostNSIpset(pod, podIPs, &s.hostsideProbeIPSet) if err != nil { log.Errorf("failed to add pod to ipset: %s/%s %v", pod.Namespace, pod.Name, err) return err }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1) -
cni/pkg/nodeagent/ztunnelserver.go
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
iptablesBuilder.AppendRule(iptableslog.UndefinedCommand, ChainInpodPrerouting, iptablesconstants.MANGLE, "-m", "mark", "--mark", inpodMark, "-j", "CONNMARK", "--set-xmark", inpodTproxyMark) // Handle healthcheck probes from the host node. In the host netns, before the packet enters the pod, we SNAT // the healthcheck packet to a fixed IP if the packet is coming from a node-local process with a socket. //
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue May 07 19:54:50 GMT 2024 - 19.7K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
s.queue = controllers.NewQueue("ambient", controllers.WithGenericReconciler(s.reconcile), controllers.WithMaxAttempts(5), ) // We only need to handle pods on our node s.pods = kclient.NewFiltered[*corev1.Pod](kubeClient, kclient.Filter{FieldSelector: "spec.nodeName=" + NodeName}) s.pods.AddEventHandler(controllers.FromEventHandler(func(o controllers.Event) { s.queue.Add(o)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 9.6K bytes - Viewed (0) -
istioctl/pkg/tag/generate_test.go
t.Fatalf("expected validation URL %s, got %s", tc.whURL, *validationWhConf.URL) } } if tc.whCA != "" { if string(validationWhConf.CABundle) != tc.whCA { t.Fatalf("expected CA bundle %q, got %q", tc.whCA, validationWhConf.CABundle) } } } }) } } func TestGenerateMutatingWebhook(t *testing.T) { tcs := []struct { name string
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Jan 16 17:43:49 GMT 2024 - 12.1K bytes - Viewed (0) -
istioctl/pkg/tag/tag.go
namespace "istio.io/rev=prod". The "prod" revision tag could point to "1-7-6" initially and then be changed to point to "1-8-1" at some later point. This allows operators to change which Istio control plane revision should handle injection for a namespace or set of namespaces without manual relabeling of the "istio.io/rev" tag. `, Args: func(cmd *cobra.Command, args []string) error { if len(args) != 0 {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 02 08:32:06 GMT 2024 - 16.3K bytes - Viewed (0) -
istioctl/pkg/util/clusters/wrapper.go
type Wrapper struct { *admin.Clusters } // MarshalJSON is a custom marshaller to handle protobuf pain func (w *Wrapper) MarshalJSON() ([]byte, error) { return protomarshal.Marshal(w) } // UnmarshalJSON is a custom unmarshaller to handle protobuf pain func (w *Wrapper) UnmarshalJSON(b []byte) error { cd := &admin.Clusters{} err := protomarshal.UnmarshalAllowUnknown(b, cd)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Nov 03 08:41:32 GMT 2022 - 1.2K bytes - Viewed (0)