- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for pkgname (0.14 sec)
-
src/internal/reflectlite/reflect_mirror_test.go
} } } } return v } func loadTypes(path, pkgName string, v visitor) { fset := token.NewFileSet() filter := func(fi fs.FileInfo) bool { return strings.HasSuffix(fi.Name(), ".go") } pkgs, err := parser.ParseDir(fset, path, filter, 0) if err != nil { panic(err) } pkg := pkgs[pkgName] for _, f := range pkg.Files { ast.Walk(v, f) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 19 21:11:15 UTC 2024 - 2.8K bytes - Viewed (0) -
src/go/types/resolver_test.go
obj := uses[x] if obj == nil { t.Errorf("%s: unresolved qualified identifier %s", fset.Position(x.Pos()), x.Name) return false } if _, ok := obj.(*PkgName); ok && uses[s.Sel] == nil { t.Errorf("%s: unresolved selector %s", fset.Position(s.Sel.Pos()), s.Sel.Name) return false } return false } return true } return true
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 4.5K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconstruct.go
reconstructedVolumeNames := []v1.UniqueVolumeName{} for _, volume := range podVolumes { if rc.actualStateOfWorld.VolumeExistsWithSpecName(volume.podName, volume.volumeSpecName) { klog.V(4).InfoS("Volume exists in actual state, skip cleaning up mounts", "podName", volume.podName, "volumeSpecName", volume.volumeSpecName) // There is nothing to reconstruct continue } reconstructedVolume, err := rc.reconstructVolume(volume)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:23:12 UTC 2024 - 8.9K bytes - Viewed (0) -
tests/integration/pilot/piggyback_test.go
for _, workload := range workloads { podName := workload[0].WorkloadsOrFail(t)[0].PodName() namespace := workload.Config().Namespace.Name() retry.UntilSuccessOrFail(t, func() error { args := []string{ "x", "proxy-status", "--xds-via-agents", fmt.Sprintf("%s.%s", podName, namespace), } output, _, err := istioCtl.Invoke(args) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 3.3K bytes - Viewed (0) -
istioctl/pkg/util/ambient/util.go
"istio.io/istio/pkg/config/constants" "istio.io/istio/pkg/kube" ) func IsZtunnelPod(client kube.CLIClient, podName, podNamespace string) bool { isZtunnel := strings.HasPrefix(podName, "ztunnel") 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 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 02 21:29:40 UTC 2024 - 1.7K bytes - Viewed (0) -
cni/pkg/plugin/sidecar_iptables_linux.go
return err } defer netNs.Close() return netNs.Do(func(_ ns.NetNS) error { log.Infof("============= Start iptables configuration for %v =============", podName) defer log.Infof("============= End iptables configuration for %v =============", podName) return cmd.ProgramIptables(cfg) })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 17:36:41 UTC 2024 - 2.5K bytes - Viewed (0) -
pilot/pkg/bootstrap/options.go
fn(p) } return p } // Apply default value to PilotArgs func (p *PilotArgs) applyDefaults() { p.Namespace = PodNamespace p.CniNamespace = PodNamespace p.PodName = PodName p.Revision = Revision p.JwtRule = JwtRule p.KeepaliveOptions = keepalive.DefaultOption() p.RegistryOptions.DistributionTrackingEnabled = features.EnableDistributionTracking
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 6.1K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher_test.go
Netns: "/var/netns/foo", PodName: "pod-bingo", PodNamespace: "funkyns", } payload, _ := json.Marshal(valid) addEvent, err := processAddEvent(payload) assert.NoError(t, err) assert.Equal(t, valid, addEvent) } func TestProcessAddEventBadPayload(t *testing.T) { valid := CNIPluginAddEvent{ Netns: "/var/netns/foo", PodName: "pod-bingo", PodNamespace: "funkyns", }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 21:31:35 UTC 2024 - 7.6K bytes - Viewed (0) -
internal/config/identity/ldap/config.go
func (l *Config) GetConfigInfo(s config.Config, cfgName string) ([]madmin.IDPCfgInfo, error) { // For now only a single LDAP config is supported. if cfgName != madmin.Default { return nil, ErrProviderConfigNotFound } kvsrcs, err := s.GetResolvedConfigParams(config.IdentityLDAPSubSys, cfgName, true) if err != nil { return nil, err }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 8.1K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher.go
ambientPod, err := s.getPodWithRetry(log, addCmd.PodName, addCmd.PodNamespace) if err != nil { return err } log.Debugf("Pod: %s in ns: %s is enabled for ambient, adding to mesh.", addCmd.PodName, addCmd.PodNamespace) var podIps []netip.Addr for _, configuredPodIPs := range addCmd.IPs {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 21:31:35 UTC 2024 - 6.7K bytes - Viewed (0)