- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 51 for OK (0.68 sec)
-
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) -
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) -
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) -
cni/pkg/repair/repaircontroller.go
m := podsRepaired.With(typeLabel.Value(labelType)) repairLog.Infof("Pod detected as broken, adding label: %s/%s", pod.Namespace, pod.Name) labels := pod.GetLabels() if _, ok := labels[c.cfg.LabelKey]; ok { m.With(resultLabel.Value(resultSkip)).Increment() repairLog.Infof("Pod %s/%s already has label with key %s, skipping", pod.Namespace, pod.Name, c.cfg.LabelKey) return nil }
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 10.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) -
istioctl/pkg/checkinject/checkinject.go
switch me.Operator { case metav1.LabelSelectorOpDoesNotExist: v, ok := podLabels[me.Key] if ok { return fmt.Sprintf("Pod has %s=%s label, preventing injection", me.Key, v), false } case metav1.LabelSelectorOpNotIn: v, ok := podLabels[me.Key] if !ok { continue } for _, nv := range me.Values { if nv == v {
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 9.3K 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/tag/util.go
} // GetWebhookRevision extracts tag target revision from webhook object. func GetWebhookRevision(wh admitv1.MutatingWebhookConfiguration) (string, error) { if tagName, ok := wh.ObjectMeta.Labels[label.IoIstioRev.Name]; ok { return tagName, nil } return "", fmt.Errorf("could not extract tag revision from webhook") } // DeleteTagWebhooks deletes the given webhooks.
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Tue Jan 16 17:43:42 GMT 2024 - 5.4K bytes - Viewed (1)