- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 30 for amatch (0.24 sec)
-
istioctl/pkg/writer/envoy/configdump/listener.go
}) for _, match := range matches { if includeConfigType { name := fmt.Sprintf("listener/%s", l.Name) fmt.Fprintf(w, "%v\t%v\t%v\t%v\t%v\n", name, strings.Join(addresses, ","), port, match.match, match.destination) } else { fmt.Fprintf(w, "%v\t%v\t%v\t%v\n", strings.Join(addresses, ","), port, match.match, match.destination) } } } else {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Nov 29 12:37:14 GMT 2023 - 18.1K bytes - Viewed (0) -
istioctl/pkg/writer/compare/cluster.go
Context: c.context, } text, err := difflib.GetUnifiedDiffString(diff) if err != nil { return err } if text != "" { fmt.Fprintln(c.w, "Clusters Don't Match") fmt.Fprintln(c.w, text) } else { fmt.Fprintln(c.w, "Clusters Match") } return nil
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Mar 12 10:02:09 GMT 2024 - 1.9K bytes - Viewed (0) -
istioctl/pkg/writer/compare/listener.go
Context: c.context, } text, err := difflib.GetUnifiedDiffString(diff) if err != nil { return err } if text != "" { fmt.Fprintln(c.w, "Listeners Don't Match") fmt.Fprintln(c.w, text) } else { fmt.Fprintln(c.w, "Listeners Match") } return nil
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 04 20:29:08 GMT 2024 - 2K bytes - Viewed (0) -
operator/cmd/mesh/profile-diff_test.go
t.Helper() if c.expectedString != "" && !strings.Contains(output, c.expectedString) { t.Fatalf("Output didn't match for 'istioctl %s'\n got %v\nwant: %v", c.args, output, c.expectedString) } if c.notExpected != "" && strings.Contains(output, c.notExpected) { t.Fatalf("Output didn't match for 'istioctl %s'\n got %v\nDON'T want: %v", c.args, output, c.expectedString) } if c.shouldFail { if fErr == nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Jan 10 05:10:03 GMT 2024 - 3.6K bytes - Viewed (1) -
cni/pkg/repair/netns.go
} procs, err := fs.AllProcs() if err != nil { return "", fmt.Errorf("read procs: %v", err) } oldest := uint64(math.MaxUint64) best := "" // We will iterate over all processes. Our goal is to find a process with the same network ID as we found above. // There should be 1 or 2 processes that match: the pause container should always be there, and the istio-validation *might*.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Dec 20 22:14:13 GMT 2023 - 4.8K bytes - Viewed (0) -
istioctl/pkg/util/handlers/handlers.go
if getFirstPodFunc == nil { getFirstPodFunc = polymorphichelpers.GetFirstPod } pod, _, err := getFirstPodFunc(client, namespace, selector, timeout, sortBy) if err != nil { return "", "", fmt.Errorf("no pods match %q", resname) } return pod.Name, namespace, nil } // SelectorsForObject is a fork of upstream function to add additional Istio type support
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) -
istioctl/pkg/checkinject/checkinject.go
podMatchedLabels = append(podMatchedLabels, extractMatchLabels(wh.ObjectSelector)...) } if isDeactivated { return "The injection webhook is deactivated, and will never match labels." } return fmt.Sprintf("No matching namespace labels (%s) "+ "or pod labels (%s)", strings.Join(nsMatchedLabels, ", "), strings.Join(podMatchedLabels, ", ")) } return noMatchingReason(whs), false }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 9.3K bytes - Viewed (0) -
operator/cmd/mesh/manifest_shared_test.go
} var interceptorFunc = interceptor.Funcs{Patch: func( ctx context.Context, clnt client.WithWatch, obj client.Object, patch client.Patch, opts ...client.PatchOption, ) error { // Apply patches are supposed to upsert, but fake client fails if the object doesn't exist, // if an apply patch occurs for an object that doesn't yet exist, create it. if patch.Type() != types.ApplyPatchType {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Feb 20 22:39:28 GMT 2024 - 11.7K bytes - Viewed (1) -
cni/pkg/iptables/iptables.go
// we cannot make assumptions there. // -A OUTPUT -m owner --socket-exists -p tcp -m set --match-set istio-inpod-probes dst,dst -j SNAT --to-source 169.254.7.127 iptablesBuilder.AppendRuleV4( iptableslog.UndefinedCommand, ChainHostPostrouting, iptablesconstants.NAT, "-m", "owner", "--socket-exists", "-p", "tcp", "-m", "set", "--match-set", fmt.Sprintf(ipset.V4Name, ProbeIPSet), "dst", "-j", "SNAT",
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) -
istioctl/pkg/kubeinject/kubeinject.go
deserializer = codecs.UniversalDeserializer() ) // GetFirstPod returns a pod matching the namespace and label selector // and the number of all pods that match the label selector. // This is forked from polymorphichelpers.GetFirstPod to not watch and instead return an error if no pods are found func GetFirstPod(client v1.CoreV1Interface, namespace string, selector string) (*corev1.Pod, error) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 29 02:29:02 GMT 2024 - 21.6K bytes - Viewed (0)