- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 924 for prober (0.14 sec)
-
pkg/kube/inject/webhook.go
if rewrite { if prober := DumpAppProbers(pod, req.meshConfig.GetDefaultConfig().GetStatusPort()); prober != "" { // If sidecar.istio.io/status is not present then append instead of merge. _, previouslyInjected := pod.Annotations[annotation.SidecarStatus.Name] sidecar.Env = mergeOrAppendProbers(previouslyInjected, sidecar.Env, prober) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 17:59:39 UTC 2024 - 42.2K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller_base.go
resyncPeriod: p.SyncPeriod, operationTimestamps: metrics.NewOperationStartTimeCache(), } // Prober is nil because PV is not aware of Flexvolume. if err := controller.volumePluginMgr.InitPlugins(p.VolumePlugins, nil /* prober */, controller); err != nil { return nil, fmt.Errorf("could not initialize volume plugins for PersistentVolume Controller: %w", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 29.5K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
"k8s.io/kubernetes/pkg/kubelet/pluginmanager" kubepod "k8s.io/kubernetes/pkg/kubelet/pod" podtest "k8s.io/kubernetes/pkg/kubelet/pod/testing" proberesults "k8s.io/kubernetes/pkg/kubelet/prober/results" probetest "k8s.io/kubernetes/pkg/kubelet/prober/testing" "k8s.io/kubernetes/pkg/kubelet/secret" "k8s.io/kubernetes/pkg/kubelet/server" serverstats "k8s.io/kubernetes/pkg/kubelet/server/stats" "k8s.io/kubernetes/pkg/kubelet/stats"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0) -
pkg/kube/inject/webhook_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 17 20:25:52 UTC 2023 - 39K bytes - Viewed (1) -
pkg/controller/volume/attachdetach/attach_detach_controller.go
csiNodeInformer storageinformersv1.CSINodeInformer, csiDriverInformer storageinformersv1.CSIDriverInformer, volumeAttachmentInformer storageinformersv1.VolumeAttachmentInformer, plugins []volume.VolumePlugin, prober volume.DynamicPluginProber, disableReconciliationSync bool, reconcilerSyncDuration time.Duration, disableForceDetachOnTimeout bool, timerConfig TimerConfig) (AttachDetachController, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.6K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/framework_test.go
recycleCalls: expectedRecycleCalls, deleteCalls: expectedDeleteCalls, provisionCalls: expectedProvisionCalls, } ctrl.volumePluginMgr.InitPlugins([]volume.VolumePlugin{plugin}, nil /* prober */, ctrl) return toWrap(ctrl, reactor, test) } } // wrapTestWithReclaimCalls returns a testCall that: // - configures controller with recycler or deleter which will return provided
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 09:54:00 UTC 2023 - 38.3K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
// run to introspect the state of each pod. The probe manager acts on the actual state of the node // and is notified of pods by the podWorker. The probe manager is the authoritative source of the // most recent probe status and is responsible for notifying the status manager, which // synthesizes them into the overall pod status. probeManager prober.Manager
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0) -
pkg/istio-agent/agent.go
MetadataClientCertChain = "ISTIO_META_TLS_CLIENT_CERT_CHAIN" // MetadataClientRootCert is ISTIO_META env var used for client root cert. MetadataClientRootCert = "ISTIO_META_TLS_CLIENT_ROOT_CERT" ) var _ ready.Prober = &Agent{} type LifecycleEvent string const ( DrainLifecycleEvent LifecycleEvent = "drain" ExitLifecycleEvent LifecycleEvent = "exit" ) type SDSService interface {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 10:02:56 UTC 2024 - 26.7K bytes - Viewed (0) -
pkg/volume/emptydir/empty_dir_test.go
) // Construct an instance of a plugin, by name. func makePluginUnderTest(t *testing.T, plugName, basePath string) volume.VolumePlugin { plugMgr := volume.VolumePluginMgr{} plugMgr.InitPlugins(ProbeVolumePlugins(), nil /* prober */, volumetest.NewFakeVolumeHost(t, basePath, nil, nil)) plug, err := plugMgr.FindPluginByName(plugName) if err != nil { t.Fatal("Can't find the plugin by name") } return plug }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 30.7K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy.go
func initXdsProxy(ia *Agent) (*XdsProxy, error) { var err error localHostAddr := localHostIPv4 if ia.cfg.IsIPv6 { localHostAddr = localHostIPv6 } var envoyProbe ready.Prober if !ia.cfg.DisableEnvoy { envoyProbe = &ready.Probe{ AdminPort: uint16(ia.proxyConfig.ProxyAdminPort), LocalHostAddr: localHostAddr, } } cache := wasm.NewLocalFileCache(constants.IstioDataDir, ia.cfg.WASMOptions)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 27.9K bytes - Viewed (0)