- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 608 for prober (0.1 sec)
-
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) -
pkg/kubelet/kuberuntime/kuberuntime_container.go
func isProbeTerminationGracePeriodSecondsSet(pod *v1.Pod, containerSpec *v1.Container, probe *v1.Probe, containerName string, containerID kubecontainer.ContainerID, probeType string) bool { if probe != nil && probe.TerminationGracePeriodSeconds != nil { if *probe.TerminationGracePeriodSeconds > *pod.Spec.TerminationGracePeriodSeconds {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 54.7K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_manager.go
// If the container failed the liveness probe, we should kill it. message = fmt.Sprintf("Container %s failed liveness probe", container.Name) reason = reasonLivenessProbe } else if startup, found := m.startupManager.Get(containerStatus.ID); found && startup == proberesults.Failure { // If the container failed the startup probe, we should kill it.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 22 02:01:31 UTC 2024 - 64.7K bytes - Viewed (0) -
pkg/kube/apimirror/probe.go
URISchemeHTTP URIScheme = "HTTP" // URISchemeHTTPS means that the scheme used will be https:// URISchemeHTTPS URIScheme = "HTTPS" ) // HTTPHeader describes a custom header to be used in HTTP probes type HTTPHeader struct { // The header field name Name string `json:"name" protobuf:"bytes,1,opt,name=name"` // The header field value Value string `json:"value" protobuf:"bytes,2,opt,name=value"` }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 4.4K bytes - Viewed (0) -
docs/en/docs/img/sponsors/porter.png
porter.png...
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Wed Aug 09 17:04:49 UTC 2023 - 23.4K bytes - Viewed (0)