- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 51 for ok (0.16 sec)
-
istioctl/pkg/util/ambient/util.go
if client == nil { return isZtunnel } pod, err := client.Kube().CoreV1().Pods(podNamespace).Get(context.Background(), podName, metav1.GetOptions{}) if err != nil { return isZtunnel } if v, ok := pod.Labels["app"]; ok { return v == "ztunnel" } return isZtunnel } // InAmbient returns true if a resource is in ambient data plane mode. func InAmbient(obj metav1.Object) bool { if obj == nil { return false
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Thu Jan 04 03:08:06 GMT 2024 - 1.7K bytes - Viewed (0) -
operator/cmd/mesh/manifest-generate.go
} if len(mgArgs.Components) != 0 { filteredManifests := name.ManifestMap{} for _, cArg := range mgArgs.Components { componentName := name.ComponentName(cArg) if cManifests, ok := manifests[componentName]; ok { filteredManifests[componentName] = cManifests } else { return fmt.Errorf("incorrect component name: %s. Valid options: %v", cArg, name.AllComponentNames) } }
Go - Registered: Wed Mar 20 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 8.5K bytes - Viewed (0) -
cni/pkg/install/cniconfig.go
if err != nil { return nil, fmt.Errorf("error loading existing CNI config (JSON error): %v", err) } 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
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 10.4K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
log.Debug("sending snapshot to ztunnel") if err := z.sendSnapshot(ctx, conn); err != nil { return err } for { // listen for updates: select { case update, ok := <-conn.Updates: if !ok { log.Debug("update channel closed - returning") return nil } log.Debugf("got update to send to ztunnel") resp, err := conn.sendDataAndWaitForAck(update.Update, update.Fd)
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
cni/test/install_cni.go
"kubeconfig": "__KUBECONFIG_FILEPATH__", "cni_bin_dir": "/opt/cni/bin", "exclude_namespaces": [ "istio-system" ] } } ` ) func getEnv(key, fallback string) string { if value, ok := os.LookupEnv(key); ok { return value } return fallback } func setEnv(key, value string, t *testing.T) { t.Helper() err := os.Setenv(key, value) if err != nil {
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 12.5K bytes - Viewed (0) -
istioctl/pkg/xds/google.go
if err != nil { return nil, err } spec, ok := u.Object["spec"].(map[string]any) if !ok { return nil, errors.New(`field "spec" is not a map`) } var mem hubMembership mem.WorkloadIdentityPool, ok = spec["workload_identity_pool"].(string) if !ok { return nil, errors.New(`field "spec.workload_identity_pool" is not a string`) } return &mem, nil }
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Mon Nov 14 20:23:34 GMT 2022 - 3.4K bytes - Viewed (0) -
istioctl/pkg/util/formatting/formatter.go
return "" } prefix, ok := colorPrefixes[m.Type.Level()] if !ok { return "" } return prefix } func colorSuffix(colorize bool) string { if !colorize { return "" } return "\033[0m" } func IstioctlColorDefault(writer io.Writer) bool { if strings.EqualFold(termEnvVar.Get(), "dumb") { return false } file, ok := writer.(*os.File) if ok {
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Tue Jul 11 02:41:45 GMT 2023 - 3.1K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/workload.go
return "None" } if svc, ok := services[wl.Waypoint.Destination]; ok { return svc.Name } return "NA" // Shouldn't normally reach here } func serviceWaypointName(svc *ZtunnelService, services map[string]*ZtunnelService) string { if svc.Waypoint == nil { return "None" } if svc, ok := services[svc.Waypoint.Destination]; ok { return svc.Name }
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Tue Apr 23 21:30:30 GMT 2024 - 4K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/configdump.go
if label, ok := md[buildLabelKey]; ok { fmt.Fprintf(&sb, "-%s", label.GetStringValue()) } if status, ok := md[statusKey]; ok { fmt.Fprintf(&sb, "/%s", status.GetStringValue()) } if typ, ok := md[buildTypeKey]; ok { fmt.Fprintf(&sb, "/%s", typ.GetStringValue()) } if sslVersion, ok := md[sslVersionKey]; ok { fmt.Fprintf(&sb, "/%s", sslVersion.GetStringValue()) }
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Thu Feb 29 20:46:41 GMT 2024 - 7.4K bytes - Viewed (0) -
cni/pkg/nodeagent/pod_cache.go
return info.Netns } return nil } // make sure uid is in the cache, even if we don't have a netns func (p *podNetnsCache) Ensure(uid string) { p.mu.Lock() defer p.mu.Unlock() if _, ok := p.currentPodCache[uid]; !ok { p.currentPodCache[uid] = WorkloadInfo{} } } func (p *podNetnsCache) addToCacheUnderLock(uid string, workload WorkloadInfo) { runtime.SetFinalizer(workload.Netns, closeNetns)
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.5K bytes - Viewed (0)