- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 90 for pdName (0.14 sec)
-
cni/pkg/nodeagent/options.go
) var ( PodNamespace = env.RegisterStringVar("POD_NAMESPACE", "", "pod's namespace").Get() SystemNamespace = env.RegisterStringVar("SYSTEM_NAMESPACE", constants.IstioSystemNamespace, "istio system namespace").Get() PodName = env.RegisterStringVar("POD_NAME", "", "").Get() NodeName = env.RegisterStringVar("NODE_NAME", "", "").Get() Revision = env.RegisterStringVar("REVISION", "", "").Get()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 21:52:29 UTC 2024 - 2.1K bytes - Viewed (0) -
cmd/kubeadm/app/util/dryrun/dryrun.go
return nil } // WaitForPodToDisappear just returns a dummy nil, to indicate that the program should just proceed func (w *Waiter) WaitForPodToDisappear(podName string) error { fmt.Printf("[dryrun] Would wait for the %q Pod in the %s namespace to be deleted\n", podName, metav1.NamespaceSystem) return nil } // WaitForKubelet blocks until the kubelet /healthz endpoint returns 'ok'
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 6.5K bytes - Viewed (0) -
pkg/registry/core/persistentvolume/storage/storage_test.go
t.Errorf("unexpected object: %s", cmp.Diff(pvIn.Status, pvOut.Status)) } } func getPhaseTranstitionTime(ctx context.Context, pvName string, storage *REST) (*metav1.Time, error) { obj, err := storage.Get(ctx, pvName, &metav1.GetOptions{}) if err != nil { return nil, err } return obj.(*api.PersistentVolume).Status.LastPhaseTransitionTime, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 7.4K bytes - Viewed (0) -
pilot/pkg/bootstrap/servicecontroller.go
args.RegistryOptions.KubeOptions.SystemNamespace = args.Namespace args.RegistryOptions.KubeOptions.MeshServiceController = s.ServiceController() // pass namespace to k8s service registry kubecontroller.NewMulticluster(args.PodName, s.kubeClient.Kube(), args.RegistryOptions.ClusterRegistriesNamespace, args.RegistryOptions.KubeOptions, s.serviceEntryController, s.configController, s.istiodCertBundleWatcher, args.Revision,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 3.2K bytes - Viewed (0) -
pkg/volume/nfs/nfs.go
}}, nil } // Recycle recycles/scrubs clean an NFS volume. // Recycle blocks until the pod has completed or any error occurs. func (plugin *nfsPlugin) Recycle(pvName string, spec *volume.Spec, eventRecorder recyclerclient.RecycleEventRecorder) error { if spec.PersistentVolume == nil || spec.PersistentVolume.Spec.NFS == nil { return fmt.Errorf("spec.PersistentVolumeSource.NFS is nil") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 9.5K bytes - Viewed (0) -
pilot/pkg/xds/xdsgen.go
// The Pod Name (instance identity) is in PilotArgs, but not reachable globally nor from DiscoveryServer podName := env.Register("POD_NAME", "", "").Get() byVersion, err := json.Marshal(IstioControlPlaneInstance{ Component: "istiod", ID: podName, Info: istioversion.Info, }) if err != nil { log.Warnf("XDS: Could not serialize control plane id: %v", err) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 6.3K bytes - Viewed (0) -
pilot/pkg/status/distribution/reporter_test.go
Expect(r.reverseStatus).To(Equal(map[string]sets.String{"a": {"conB~": x}, "c": {"conC~": x}, "d": {"conD~": x}})) } func initReporterWithoutStarting() (out Reporter) { out.PodName = "tespod" out.inProgressResources = map[string]*inProgressEntry{} out.client = nil // TODO out.clock = clock.RealClock{} // TODO out.UpdateInterval = 300 * time.Millisecond out.cm = nil // TODO
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 30 17:25:17 UTC 2024 - 4.4K bytes - Viewed (0) -
cni/pkg/plugin/cnieventclient_test.go
defer req.Body.Close() data, err := io.ReadAll(req.Body) assert.NoError(t, err) var msg nodeagent.CNIPluginAddEvent err = json.Unmarshal(data, &msg) assert.NoError(t, err) assert.Equal(t, msg.PodName, testPod) assert.Equal(t, msg.PodNamespace, testNS) assert.Equal(t, msg.Netns, fakeCmdArgs.Netns) res.WriteHeader(http.StatusOK) res.Write([]byte("server happy")) })) defer func() { testServer.Close() }()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 26 20:34:28 UTC 2024 - 4.2K bytes - Viewed (0) -
istioctl/pkg/proxystatus/proxystatus_test.go
args: strings.Split("deployment/random-gibberish.bogus", " "), wantException: true, }, { // case 5: supplying nonexistent pod name should result in error args: strings.Split("random-gibberish-podname-61789237418234", " "), wantException: true, }, { // case 6: new --revision argument args: strings.Split("--revision canary", " "),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 15 08:28:50 UTC 2024 - 5.5K bytes - Viewed (0) -
tests/integration/pilot/proxyconfig/proxyconfig_test.go
for _, w := range i.WorkloadsOrFail(t) { w := w for k, v := range values { // can we rely on printenv being in the container once distroless is default? out, _, err := i.Config().Cluster.PodExec(w.PodName(), i.Config().Namespace.Name(), "istio-proxy", fmt.Sprintf("printenv %s", k)) out = strings.TrimSuffix(out, "\n") if err != nil { return fmt.Errorf("could not exec into pod: %v", err) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 02 21:29:40 UTC 2024 - 6.3K bytes - Viewed (0)