- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 51 for OK (0.13 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) -
cni/pkg/util/pluginutil.go
for { select { case event, ok := <-watcher.Events: if !ok { return } if event.Op&(fsnotify.Create|fsnotify.Write|fsnotify.Remove) != 0 { log.Infof("file modified: %v", event.Name) fileModified <- struct{}{} } case err, ok := <-watcher.Errors: if !ok { return } errChan <- err } } }
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 3.6K bytes - Viewed (0) -
istioctl/pkg/cli/mock_client.go
results, ok := c.Results[podName] if !ok { return nil, fmt.Errorf("unable to retrieve Pod: pods %q not found", podName) } return results, nil } func (c MockClient) EnvoyDoWithPort(ctx context.Context, podName, podNamespace, method, path string, port int) ([]byte, error) { results, ok := c.Results[podName] if !ok {
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 2.1K bytes - Viewed (0) -
cni/pkg/nodeagent/podcgroupns.go
fi, err := fs.Stat(proc, netnsName) if err != nil { return nil, err } inode, err := GetInode(fi) if err != nil { return nil, err } if _, ok := netnsObserved[inode]; ok { log.Debugf("netns: %d already processed. skipping", inode) return nil, nil } cgroup, err := proc.Open(path.Join(entry.Name(), "cgroup")) if err != nil { return nil, nil }
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 11K 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)