- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 94 for take (0.16 sec)
-
istioctl/pkg/xds/client.go
) ([]grpc.DialOption, error) { ctx := context.TODO() // If we are using the insecure 15010 don't bother getting a token if opts.Plaintext || opts.CertDir != "" { return make([]grpc.DialOption, 0), nil } // Use bearer token aud := tokenAudiences isMCP := strings.HasSuffix(opts.Xds, ".googleapis.com") || strings.HasSuffix(opts.Xds, ".googleapis.com:443") if isMCP {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Dec 19 22:42:42 GMT 2023 - 3.7K bytes - Viewed (0) -
istioctl/pkg/install/k8sversion/version_test.go
// limitations under the License. package k8sversion import ( "bytes" "fmt" "strings" "testing" "k8s.io/apimachinery/pkg/version" fakediscovery "k8s.io/client-go/discovery/fake" "istio.io/istio/operator/pkg/util/clog" "istio.io/istio/pkg/kube" pkgVersion "istio.io/istio/pkg/version" ) var ( version1_17 = &version.Info{ Major: "1", Minor: "17",
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 19 02:46:48 GMT 2024 - 6.3K bytes - Viewed (0) -
cni/pkg/install/cniconfig.go
delete(istioMap, "cniVersion") var newMap map[string]any if _, ok := existingMap["type"]; ok { // Assume it is a regular network conf file delete(existingMap, "cniVersion") plugins := make([]map[string]any, 2) plugins[0] = existingMap plugins[1] = istioMap newMap = map[string]any{ "name": "k8s-pod-network", "cniVersion": "0.3.1", "plugins": plugins, } } else {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 10.4K bytes - Viewed (0) -
cni/test/install_cni.go
) { ztunnelAddr := "/tmp/ztfoo" cniEventAddr := "/tmp/cnieventfoo" defer os.Remove(ztunnelAddr) defer os.Remove(cniEventAddr) // "fake" constant, overridable for tests // TODO this is gross, fix this constants.ServiceAccountPath = tempK8sSvcAcctDir installConfig := config.Config{ InstallConfig: config.InstallConfig{
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 12.5K bytes - Viewed (0) -
istioctl/pkg/dashboard/dashboard.go
fw.WaitForStop() return nil } return fmt.Errorf("failure running port forward process: %v", err) } func ClosePortForwarderOnInterrupt(fw kube.PortForwarder) { go func() { signals := make(chan os.Signal, 1) signal.Notify(signals, os.Interrupt) defer signal.Stop(signals) <-signals fw.Close() }() } func openBrowser(url string, writer io.Writer, browser bool) { var err error
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 15 01:29:35 GMT 2024 - 20.5K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
// Namespaces could be anything though, so we watch all of those // // NOTE that we are requeueing namespaces here explicitly to work around // test flakes with the fake kube client in `pkg/kube/client.go` - // because we are using `List()` in the handler, without this requeue, // the fake client will sometimes drop pod events leading to test flakes. // // WaitForCacheSync *helps*, but does not entirely fix this problem
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/precheck/precheck.go
"PERSIST_OLDEST_FIRST_HEURISTIC_FOR_VIRTUAL_SERVICE_HOST_MATCHING", "1.20", "previously, VirtualServices with overlapping wildcard hosts would have the oldest "+ "VirtualService take precedence. Now, the most specific VirtualService will win", "1.20"), ) continue } } } return nil } func ObjectToInstance(c controllers.Object) *resource.Instance {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 02:57:30 GMT 2024 - 19.3K bytes - Viewed (0) -
istioctl/pkg/writer/table/writer.go
header Row rows []Row addRowFunc func(obj interface{}) Row } func NewStyleWriter(writer io.Writer) *ColoredTableWriter { return &ColoredTableWriter{ writer: writer, rows: make([]Row, 0), header: Row{}, } } type BuildRowFunc func(obj interface{}) Row type Cell struct { Value string Attributes []color.Attribute } type Row struct { Cells []Cell }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Oct 08 04:41:42 GMT 2022 - 2.8K bytes - Viewed (0) -
istioctl/pkg/validate/validate.go
if ok { we.ErrorFormat = func(i []error) string { points := make([]string, len(i)) for i, err := range i { points[i] = fmt.Sprintf("* %s", err) } return fmt.Sprintf( "\n\t%s\n", strings.Join(points, "\n\t")) } } return w.Error() } func transformInterfaceArray(in []any) []any { out := make([]any, len(in)) for i, v := range in { out[i] = transformMapValue(v)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Jan 22 17:58:52 GMT 2024 - 15K bytes - Viewed (0) -
istioctl/pkg/kubeinject/kubeinject.go
sortBy := func(pods []*corev1.Pod) sort.Interface { return sort.Reverse(podutils.ActivePods(pods)) } podList, err := client.Pods(namespace).List(context.TODO(), options) if err != nil { return nil, err } pods := make([]*corev1.Pod, 0, len(podList.Items)) for i := range podList.Items { pod := podList.Items[i] pods = append(pods, &pod) } if len(pods) > 0 { sort.Sort(sortBy(pods)) return pods[0], nil }
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)