- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for Hevery (0.24 sec)
-
istioctl/cmd/options.go
// (Currently the only global options we show are help options) rootCmd.PersistentFlags().VisitAll(func(flag *pflag.Flag) { if _, ok := helpFlags[flag.Name]; ok { // Currently every flag.Shorthand is "", so there is no point in showing shorthands shorthand := " " if flag.Shorthand != "" { shorthand = "-" + flag.Shorthand + "," }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jun 15 15:02:17 GMT 2023 - 1.8K bytes - Viewed (0) -
cni/pkg/plugin/sidecar_redirect.go
if valErr != nil { return nil, fmt.Errorf("annotation value error for value %s; annotationFound = %t: %v", "includeOutboundPorts", isFound, valErr) } // Add 15090 to sync with non-cni injection template // TODO: Revert below once https://github.com/istio/istio/pull/23037 or its follow up is merged. redir.excludeInboundPorts = strings.TrimSpace(redir.excludeInboundPorts)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 10.6K 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
allClusterGVKs = helmreconciler.ClusterResources ) func init() { if kubeBuilderInstalled() { // TestMode is required to not wait in the go client for resources that will never be created in the test server. helmreconciler.TestMode = true // Add install and controller to the list of commands to run tests against. testedManifestCmds = append(testedManifestCmds, cmdApply, cmdController) } }
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/nodeagent/ztunnelserver.go
go func() { log.Debug("handling conn") if err := z.handleConn(ctx, conn); err != nil { log.Errorf("failed to handle conn: %v", err) } }() } } // ZDS protocol is very simple, for every message sent, and ack is sent. // the ack only has temporal correlation (i.e. it is the first and only ack msg after the message was sent)
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) -
istioctl/pkg/util/common.go
"strings" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" binversion "istio.io/istio/operator/version" ) var NeverMatch = &metav1.LabelSelector{ MatchLabels: map[string]string{ "istio.io/deactivated": "never-match", }, } var ManifestsFlagHelpStr = `Specify a path to a directory of charts and profiles (e.g. ~/Downloads/istio-` + binversion.OperatorVersionString + `/manifests).`
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jun 15 15:02:17 GMT 2023 - 1.6K bytes - Viewed (0) -
cni/pkg/plugin/plugin_test.go
testDoAddRun(t, cniConf, excludedNS, pod, ns) wasCalled := serverClose() // If the pod is being added to a namespace that is explicitly excluded by plugin config denylist // it should never be added, even if the namespace has the annotation assert.Equal(t, wasCalled, false) } func TestCmdAdd(t *testing.T) { pod, ns := buildFakePodAndNSForClient()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 15:58:51 GMT 2024 - 17.5K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
return nil } err := s.dataplane.AddPodToMesh(s.ctx, pod, podIPs, "") log.Debugf("AddPodToMesh(%s) returned %v", newPod.Name, err) } case controllers.EventDelete: // TODO: as every pod on our node will come through here, check if pod is annotated? err := s.dataplane.DelPodFromMesh(s.ctx, pod) log.Debugf("DelPodFromMesh(%s) returned %v", pod.Name, err) } return nil
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) -
cni/pkg/repair/repaircontroller.go
m := podsRepaired.With(typeLabel.Value(repairType)) log := repairLog.WithLabels("pod", pod.Namespace+"/"+pod.Name) key := types.NamespacedName{Name: pod.Name, Namespace: pod.Namespace} // We will get an event every time the pod changes. The repair is not instantaneous, though -- it will only recover // once the pod restarts (in CrashLoopBackoff), which can take some time.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 10.4K bytes - Viewed (0) -
cni/pkg/iptables/iptables_linux.go
} for _, family := range families { // Equiv: // ip rule add fwmark 0x111/0xfff pref 32764 lookup 100 // // Adds in-pod rules for marking packets with the istio-specific TPROXY mark. // A very similar mechanism is used for sidecar TPROXY. // // TODO largely identical/copied from tools/istio-iptables/pkg/capture/run_linux.go inpodMarkRule := netlink.NewRule() inpodMarkRule.Family = family
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 3.3K bytes - Viewed (0)