- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 253 for podAdd (0.17 sec)
-
pkg/kubelet/config/file_linux.go
klog.V(4).InfoS("Ignored pod manifest, because it starts with dots", "eventName", e.Name) return nil } var eventType podEventType switch { case (e.Op & fsnotify.Create) > 0: eventType = podAdd case (e.Op & fsnotify.Write) > 0: eventType = podModify case (e.Op & fsnotify.Chmod) > 0: eventType = podModify case (e.Op & fsnotify.Remove) > 0: eventType = podDelete
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 02 17:27:26 UTC 2023 - 3.8K bytes - Viewed (0) -
pkg/scheduler/internal/queue/events.go
limitations under the License. */ package queue import ( "k8s.io/kubernetes/pkg/scheduler/framework" ) const ( // PodAdd is the event when a new pod is added to API server. PodAdd = "PodAdd" // ScheduleAttemptFailure is the event when a schedule attempt fails. ScheduleAttemptFailure = "ScheduleAttemptFailure" // BackoffComplete is the event when a pod finishes backoff.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 6.4K bytes - Viewed (0) -
pkg/kubelet/config/file.go
"k8s.io/client-go/tools/cache" api "k8s.io/kubernetes/pkg/apis/core" kubetypes "k8s.io/kubernetes/pkg/kubelet/types" utilio "k8s.io/utils/io" ) type podEventType int const ( podAdd podEventType = iota podModify podDelete eventBufferLen = 10 ) type watchEvent struct { fileName string eventType podEventType } type sourceFile struct { path string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 01 07:19:44 UTC 2021 - 6.2K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller.go
func (adc *attachDetachController) GetPluginDir(podUID string) string { return "" } func (adc *attachDetachController) GetVolumeDevicePluginDir(podUID string) string { return "" } func (adc *attachDetachController) GetPodsDir() string { return "" } func (adc *attachDetachController) GetPodVolumeDir(podUID types.UID, pluginName, volumeName string) string { return "" }
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/endpointslice/endpointslice_controller_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 65.5K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller_test.go
func TestPodAddsBatching(t *testing.T) { type podAdd struct { delay time.Duration } tests := []struct { name string batchPeriod time.Duration adds []podAdd finalDelay time.Duration wantRequestCount int }{ { name: "three adds with no batching", batchPeriod: 0 * time.Second, adds: []podAdd{ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 87.7K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
func (u *UnschedulablePods) addOrUpdate(pInfo *framework.QueuedPodInfo) { podID := u.keyFunc(pInfo.Pod) if _, exists := u.podInfoMap[podID]; !exists { if pInfo.Gated && u.gatedRecorder != nil { u.gatedRecorder.Inc() } else if !pInfo.Gated && u.unschedulableRecorder != nil { u.unschedulableRecorder.Inc() } } u.podInfoMap[podID] = pInfo } // delete deletes a pod from the unschedulable podInfoMap.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0) -
pkg/kubelet/server/server.go
Path("/attach") ws.Route(ws.GET("/{podNamespace}/{podID}/{containerName}"). To(s.getAttach). Operation("getAttach")) ws.Route(ws.POST("/{podNamespace}/{podID}/{containerName}"). To(s.getAttach). Operation("getAttach")) ws.Route(ws.GET("/{podNamespace}/{podID}/{uid}/{containerName}"). To(s.getAttach). Operation("getAttach")) ws.Route(ws.POST("/{podNamespace}/{podID}/{uid}/{containerName}"). To(s.getAttach).
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 40.1K bytes - Viewed (0) -
pkg/registry/core/pod/storage/storage.go
func (r *BindingREST) assignPod(ctx context.Context, podUID types.UID, podResourceVersion, podID string, machine string, annotations map[string]string, dryRun bool) (err error) { if _, err = r.setPodHostAndAnnotations(ctx, podUID, podResourceVersion, podID, machine, annotations, dryRun); err != nil { err = storeerr.InterpretGetError(err, api.Resource("pods"), podID) err = storeerr.InterpretUpdateError(err, api.Resource("pods"), podID)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 20 14:29:25 UTC 2023 - 13.7K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue_test.go
if _, ok, _ := q.podBackoffQ.Get(podInfo); !ok { t.Errorf("pod %v is not in the backoff queue", podID) } // Moved out of the backoff queue after timeout. cl.Step(backoff) q.flushBackoffQCompleted(logger) if _, ok, _ := q.podBackoffQ.Get(podInfo); ok { t.Errorf("pod %v is still in the backoff queue", podID) } }) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 146.9K bytes - Viewed (0)